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

"use strict";

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

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

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

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

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

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

  const allAttachments = logs.map(log => {
    const name = (0, _utils.removeAutoNamePrefix)(log.name, workspacesOptions.autoNamePrefix);
    return {
      color: slackOptions.colors[log.type],
      fields: [{
        title: `${name} v${log.version}`,
        value: log.messages.map(message => {
          if (message.type === 'dependencies') {
            return `${prefixes.required[message.type].value} update dependencies`;
          }

          return `${prefixes.required[message.type].value} ${message.value}`;
        }).join('\n')
      }]
    };
  });
  const numIterations = Math.ceil(allAttachments.length / _utils2.SLACK_MAX_ATTACHMENTS);
  const attachmentsInIteration = Math.ceil(allAttachments.length / numIterations);

  for (let i = 0; i < numIterations; ++i) {
    await (0, _requestPromiseNative.default)({
      uri: `${_utils2.SLACK_HOOKS_URL}${slackOptions.token}`,
      method: 'POST',
      json: {
        channel: slackOptions.channel,
        username: slackOptions.username,
        link_names: '1',
        icon_emoji: slackOptions.iconEmoji,
        unfurl_media: false,
        attachments: allAttachments.slice(i * attachmentsInIteration, Math.min((i + 1) * attachmentsInIteration, allAttachments.length))
      }
    });
  }
};

exports.sendSlackMessage = sendSlackMessage;