global notification slack

src/server/crowi/index.js

@@ -98,13 +98,17 @@ Crowi.prototype.init = async function() {
     this.setupMailer(),
     this.setupSlack(),
     this.setupCsrf(),
-    this.setUpGlobalNotification(),
     this.setUpFileUpload(),
     this.setUpAcl(),
     this.setUpCustomize(),
     this.setUpRestQiitaAPI(),
     this.setupUserGroup(),
   ]);
+
+  // globalNotification depends on slack and mailer
+  await Promise.all([
+    this.setUpGlobalNotification(),
+  ]);
 };
 
 Crowi.prototype.initForTest = async function() {

src/server/service/global-notification.js

@@ -8,6 +8,7 @@ class GlobalNotificationService {
   constructor(crowi) {
     this.crowi = crowi;
     this.mailer = crowi.getMailer();
+    this.slack = crowi.slack;
     this.GlobalNotification = crowi.model('GlobalNotificationSetting');
     this.User = crowi.model('User');
     this.appTitle = crowi.appService.getAppTitle();
@@ -18,7 +19,7 @@ class GlobalNotificationService {
   }
 
   notifyBySlack(notification, slackOption) {
-    // send slack notification here
+    this.slack.sendGlobalNotification(notification, slackOption);
   }
 
   fire(notifications, option) {
@@ -40,17 +41,22 @@ class GlobalNotificationService {
   async notifyPageCreate(page) {
     const notifications = await this.GlobalNotification.findSettingByPathAndEvent(page.path, 'pageCreate');
     const lang = 'en-US'; // FIXME
+    const baseOption = {
+      template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageCreate.txt`),
+      vars: {
+        appTitle: this.appTitle,
+        path: page.path,
+        username: page.creator.username,
+      },
+    };
     const option = {
       mail: {
         subject: `#pageCreate - ${page.creator.username} created ${page.path}`,
-        template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageCreate.txt`),
-        vars: {
-          appTitle: this.appTitle,
-          path: page.path,
-          username: page.creator.username,
-        },
-      },
-      slack: {},
+        ...baseOption,
+      },
+      slack: {
+        ...baseOption,
+      },
     };
 
     logger.debug('notifyPageCreate', option);
@@ -66,17 +72,22 @@ class GlobalNotificationService {
   async notifyPageEdit(page) {
     const notifications = await this.GlobalNotification.findSettingByPathAndEvent(page.path, 'pageEdit');
     const lang = 'en-US'; // FIXME
+    const baseOption = {
+      template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageEdit.txt`),
+      vars: {
+        appTitle: this.appTitle,
+        path: page.path,
+        username: page.creator.username,
+      },
+    };
     const option = {
       mail: {
         subject: `#pageEdit - ${page.creator.username} edited ${page.path}`,
-        template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageEdit.txt`),
-        vars: {
-          appTitle: this.appTitle,
-          path: page.path,
-          username: page.creator.username,
-        },
-      },
-      slack: {},
+        ...baseOption,
+      },
+      slack: {
+        ...baseOption,
+      },
     };
 
     logger.debug('notifyPageEdit', option);
@@ -92,17 +103,23 @@ class GlobalNotificationService {
   async notifyPageDelete(page) {
     const notifications = await this.GlobalNotification.findSettingByPathAndEvent(page.path, 'pageDelete');
     const lang = 'en-US'; // FIXME
+    const baseOption = {
+      template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageDelete.txt`),
+      vars: {
+        appTitle: this.appTitle,
+        path: page.path,
+        username: page.creator.username,
+      },
+    };
     const option = {
       mail: {
         subject: `#pageDelete - ${page.creator.username} deleted ${page.path}`, // FIXME
-        template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageDelete.txt`),
-        vars: {
-          appTitle: this.appTitle,
-          path: page.path,
-          username: page.creator.username,
-        },
-      },
-      slack: {},
+        ...baseOption,
+      },
+      slack: {
+        ...baseOption,
+
+      },
     };
 
     this.fire(notifications, option);
@@ -116,18 +133,23 @@ class GlobalNotificationService {
   async notifyPageMove(page, oldPagePath, user) {
     const notifications = await this.GlobalNotification.findSettingByPathAndEvent(page.path, 'pageMove');
     const lang = 'en-US'; // FIXME
+    const baseOption = {
+      template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageMove.txt`),
+      vars: {
+        appTitle: this.appTitle,
+        oldPath: oldPagePath,
+        newPath: page.path,
+        username: user.username,
+      },
+    };
     const option = {
       mail: {
         subject: `#pageMove - ${user.username} moved ${page.path} to ${page.path}`, // FIXME
-        template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageMove.txt`),
-        vars: {
-          appTitle: this.appTitle,
-          oldPath: oldPagePath,
-          newPath: page.path,
-          username: user.username,
-        },
-      },
-      slack: {},
+        ...baseOption,
+      },
+      slack: {
+        ...baseOption,
+      },
     };
 
     this.fire(notifications, option);
@@ -141,17 +163,22 @@ class GlobalNotificationService {
   async notifyPageLike(page, user) {
     const notifications = await this.GlobalNotification.findSettingByPathAndEvent(page.path, 'pageLike');
     const lang = 'en-US'; // FIXME
+    const baseOption = {
+      template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageLike.txt`),
+      vars: {
+        appTitle: this.appTitle,
+        path: page.path,
+        username: page.creator.username,
+      },
+    };
     const option = {
       mail: {
         subject: `#pageLike - ${user.username} liked ${page.path}`,
-        template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/pageLike.txt`),
-        vars: {
-          appTitle: this.appTitle,
-          path: page.path,
-          username: page.creator.username,
-        },
-      },
-      slack: {},
+        ...baseOption,
+      },
+      slack: {
+        ...baseOption,
+      },
     };
 
     this.fire(notifications, option);
@@ -167,18 +194,23 @@ class GlobalNotificationService {
     const notifications = await this.GlobalNotification.findSettingByPathAndEvent(path, 'comment');
     const lang = 'en-US'; // FIXME
     const user = await this.User.findOne({ _id: comment.creator });
+    const baseOption = {
+      template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/comment.txt`),
+      vars: {
+        appTitle: this.appTitle,
+        path,
+        username: user.username,
+        comment: comment.comment,
+      },
+    };
     const option = {
       mail: {
         subject: `#comment - ${user.username} commented on ${path}`,
-        template: nodePath.join(this.crowi.localeDir, `${lang}/notifications/comment.txt`),
-        vars: {
-          appTitle: this.appTitle,
-          path,
-          username: user.username,
-          comment: comment.comment,
-        },
-      },
-      slack: {},
+        ...baseOption,
+      },
+      slack: {
+        ...baseOption,
+      },
     };
 
     this.fire(notifications, option);

src/server/util/slack.js

@@ -1,5 +1,7 @@
 const debug = require('debug')('growi:util:slack');
+const { promisify } = require('util');
 const urljoin = require('url-join');
+const swig = require('swig-templates');
 
 /**
  * slack
@@ -168,6 +170,27 @@ module.exports = function(crowi) {
     return message;
   };
 
+  /**
+   * For GlobalNotification
+   * @param {GlobalNotification} notification
+  */
+  const prepareSlackMessageForGlobalNotification = async(notification, config) => {
+    const appTitle = crowi.appService.getAppTitle();
+    const templateVars = config.vars || {};
+    const output = await promisify(swig.renderFile)(
+      config.template,
+      templateVars,
+    );
+
+    const message = {
+      channel: `#${notification.slackChannels}`,
+      username: appTitle,
+      text: output,
+    };
+
+    return message;
+  };
+
   const getSlackMessageTextForPage = function(path, pageId, user, updateType) {
     let text;
     const url = crowi.appService.getSiteUrl();
@@ -204,6 +227,12 @@ module.exports = function(crowi) {
     return slackPost(messageObj);
   };
 
+  slack.sendGlobalNotification = async(notification, config) => {
+    const messageObj = await prepareSlackMessageForGlobalNotification(notification, config);
+
+    return slackPost(messageObj);
+  };
+
   const slackPost = (messageObj) => {
     // when incoming Webhooks is prioritized
     if (configManager.getConfig('notification', 'slack:isIncomingWebhookPrioritized')) {