weseek__growi/packages/app/src/server/service/user-notification/index.js

const toArrayFromCsv = require('~/utils/to-array-from-csv');

/**
 * service class of UserNotification
 */
class UserNotificationService {

  constructor(crowi) {
    this.crowi = crowi;

    this.Page = this.crowi.model('Page');
  }

  /**
   * fire user notification
   *
   * @memberof UserNotificationService
   *
   * @param {Page} page
   * @param {User} user
   * @param {string} slackChannelsStr comma separated string. e.g. 'general,channel1,channel2'
   * @param {string} mode 'create' or 'update' or 'comment'
   * @param {string} previousRevision
   * @param {Comment} comment
   */
  async fire(page, user, slackChannelsStr, mode, option, comment = {}) {
    const {
      slackIntegrationService, slackLegacy, slack,
    } = this.crowi;

    const opt = option || {};
    const previousRevision = opt.previousRevision || '';

    await page.updateSlackChannels(slackChannelsStr);

    if (!slackIntegrationService.hasSlackConfig()) {
      throw new Error('slackIntegrationService has not been set up');
    }

    // "dev,slacktest" => [dev,slacktest]
    const slackChannels = toArrayFromCsv(slackChannelsStr);

    const promises = slackChannels.map(async(chan) => {
      let res;
      if (mode === 'comment') {
        res = await slack.postComment(comment, user, chan, page.path);
        res = await slackLegacy.postComment(comment, user, chan, page.path);
      }
      else {
        res = await slack.postPage(page, user, chan, mode, previousRevision);
        res = await slackLegacy.postPage(page, user, chan, mode, previousRevision);
      }
      return res;
    });

    return Promise.allSettled(promises);
  }

}

module.exports = UserNotificationService;