@auto/log/node/send-telegram-message.js

"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.sendTelegramMessage = void 0;

var _requestPromiseNative = _interopRequireDefault(require("request-promise-native"));

var _utils = require("@auto/utils");

var _utils2 = require("./utils");

const sendTelegramMessage = async (logs, prefixes, workspacesOptions, telegramOptions) => {
  if (typeof telegramOptions.token !== 'string') {
    throw new Error('Telegram token is required');
  }

  let data = logs.reduce((result, log) => {
    const name = (0, _utils.removeAutoNamePrefix)(log.name, workspacesOptions.autoNamePrefix);
    let text = '';

    if (result.length > 0) {
      text += '\n\n';
    }

    text += `*${name} v${log.version}*\n`;
    log.messages.forEach(message => {
      text += `\n${prefixes.required[message.type].value} ${message.value}`;
    });
    return result + text;
  }, '');

  if (data.length > _utils2.TELEGRAM_MESSAGE_MAX_LENGTH) {
    data = `${data.slice(0, _utils2.TELEGRAM_MESSAGE_MAX_LENGTH - 1)}…`;
  }

  const response = JSON.parse((await (0, _requestPromiseNative.default)({
    url: `${_utils2.TELEGRAM_API_URL}bot${telegramOptions.token}/sendMessage`,
    headers: {
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      chat_id: telegramOptions.chatId,
      parse_mode: 'markdown',
      text: data
    })
  })));

  if (!response.ok) {
    throw new Error(response.description);
  }
};

exports.sendTelegramMessage = sendTelegramMessage;