const { markdown2Html } = require('../../services/markdown'); const axios = require('axios'); /** * splitting an array into chunks because Telegram only allows for messages up to * 4096 chars, thus we have to split messages into chunks * @param inputArray * @param perChunk */ const arrayChunks = (inputArray, perChunk) => inputArray.reduce((all, one, i) => { const ch = Math.floor(i / perChunk); all[ch] = [].concat(all[ch] || [], one); return all; }, []); /** * sends new listings to telegram * @param serviceName e.g immowelt * @param newListings an array with newly found listings * @param notificationConfig config of this notification adapter * * @param jobKey name of the current job that is being executed * @returns {Promise | void} */ exports.send = ({ serviceName, newListings, notificationConfig, jobKey }) => { const { token, chatId } = notificationConfig.find((adapter) => adapter.id === 'telegram').fields; //we have to split messages into chunk, because otherwise messages are going to become too big and will fail const chunks = arrayChunks(newListings, 3); const promises = chunks.map((chunk) => { let message = `Job: ${jobKey} | Service ${serviceName} found ${newListings.length} new listings:\n\n`; message += chunk.map( (o) => `${shorten(o.title.replace(/\*/g, ''), 45)}\n` + [o.address, o.price, o.size].join(' | ') + '\n' + `${o.link}\n\n` ); return axios.post(`https://api.telegram.org/bot${token}/sendMessage`, { chat_id: chatId, text: message, parse_mode: 'HTML', disable_web_page_preview: true, }); }); return Promise.all(promises); }; function shorten(str, len = 30) { return str.length > len ? str.substring(0, len) + '...' : str; } /** * exported config is being used in the frontend to generate the fields * incoming values will be the keys (and values) of the fields * */ exports.config = { id: __filename.slice(__dirname.length + 1, -3), name: 'Telegram', readme: markdown2Html('lib/notification/adapter/telegram.md'), description: 'Fredy will send new listings to your mobile, using Telegram.', fields: { token: { type: 'text', label: 'Token', description: 'The token needed to access this service.', }, chatId: { type: 'chatId', label: 'Chat Id', description: 'The chat id to send messages to you.', }, }, };