weseek__growi/lib/util/slack.js

/**
 * slack
 */

module.exports = function(crowi) {
  'use strict';

  var debug = require('debug')('crowi:util:slack'),
    Config = crowi.model('Config'),
    Botkit = require('botkit'),
    sprintf = require('sprintf'),
    bot = null,
    slack = {};
  slack.controller = undefined;

  slack.createBot = function() {
    // alreay created
    if (bot) {
      return bot;
    }

    var config = crowi.getConfig();

    if (!slack.controller) {
      slack.configureSlackApp();
    }

    if (!slack.controller) {
      return false;
    }

    if (Config.hasSlackToken(config)) {
      bot = slack.controller.spawn({token: config.notification['slack:token']});
    } else {
      bot = slack.controller.spawn();
    }
    return bot;
  };

  slack.configureSlackApp = function ()
  {
    var config = crowi.getConfig();
    if (Config.hasSlackConfig(config)) {
      slack.controller = Botkit.slackbot();
      slack.controller.configureSlackApp({
        clientId: config.notification['slack:clientId'],
        clientSecret: config.notification['slack:clientSecret'],
        redirectUri: slack.getSlackAuthCallbackUrl(),
        scopes: ['chat:write:bot']
      });

      return true;
    }

    return false;
  }

  // hmmm
  slack.getSlackAuthCallbackUrl = function()
  {
    var config = crowi.getConfig();
    // Web アクセスがきてないと app:url がセットされないので crowi.setupSlack 時にはできない
    // cli, bot 系作るときに問題なりそう
    return (config.crowi['app:url'] || '') + '/admin/notification/slackAuth';
  }

  slack.getAuthorizeURL = function () {
    if (!slack.controller) {
      slack.configureSlackApp();
    }

    if (!slack.controller) {
      return '';
    }

    return slack.controller.getAuthorizeURL();
  }

  slack.post = function (message) {
    var bot = slack.createBot();

    return new Promise(function(resolve, reject) {
      bot.api.chat.postMessage(message, function(err, res) {
        if (err) {
          debug('Post error', err, res);
          debug('Sent data to slack is:', message);
          return reject(err);
        }

        resolve(res);
      });
    });
  };

  slack.prepareSlackMessage = function(page, user, channel, updateType) {
    var config = crowi.getConfig();
    var url = config.crowi['app:url'] || '';

    var body = page.revision.body;
    if (body.length > 2000) {
      body = body.substr(0, 2000) + '...';
    }

    var attachment = {
      color: '#263a3c',
      author_name: '@' + user.username,
      author_link: url + '/user/' + user.username,
      author_icon: user.image,
      title: page.path,
      title_link: url + page.path,
      text: body,
      mrkdwn_in: ["text"],
    };
    if (user.image) {
      attachment.author_icon = user.image;
    }

    var message = {
      channel: '#' + channel,
      username: 'Crowi',
      text: this.getSlackMessageText(page.path, user, updateType),
      attachments: [attachment],
    };

    return message;
  };

  slack.getSlackMessageText = function(path, user, updateType) {
    var text;

    if (updateType == 'create') {
      text = sprintf('%s created a new page! %s', user.username, path);
    } else {
      text = sprintf('%s updated %s', user.username, path);
    }

    return text;
  };
  return slack;
};