Slack notifications automation (#833)

Author: gaspergrom

backend/.env.dist.local

@@ -102,6 +102,10 @@ CROWD_SLACK_CLIENT_SECRET=
 CROWD_SLACK_REPORTER_TOKEN=
 CROWD_SLACK_REPORTER_CHANNEL=
 
+# Slack notifier settings
+CROWD_SLACK_NOTIFIER_CLIENT_ID=
+CROWD_SLACK_NOTIFIER_CLIENT_SECRET=
+
 # Google settings
 CROWD_GOOGLE_CLIENT_ID=
 CROWD_GOOGLE_CLIENT_SECRET=

backend/config/custom-environment-variables.json

@@ -114,6 +114,10 @@
     "appId": "CROWD_SLACK_APP_ID",
     "appToken": "CROWD_SLACK_APP_TOKEN"
   },
+  "slackNotifier": {
+    "clientId": "CROWD_SLACK_NOTIFIER_CLIENT_ID",
+    "clientSecret": "CROWD_SLACK_NOTIFIER_CLIENT_SECRET"
+  },
   "google": {
     "clientId": "CROWD_GOOGLE_CLIENT_ID",
     "clientSecret": "CROWD_GOOGLE_CLIENT_SECRET",

backend/config/default.json

@@ -31,6 +31,7 @@
   "slack": {
     "maxRetrospectInSeconds": 3600
   },
+  "slackNotifier": {},
   "google": {},
   "discord": {
     "maxRetrospectInSeconds": 3600

backend/package-lock.json

@@ -84,6 +84,7 @@
     "formidable-serverless": "1.1.1",
     "he": "^1.2.0",
     "helmet": "4.1.1",
+    "html-to-mrkdwn-ts": "^1.1.0",
     "html-to-text": "^8.2.1",
     "json2csv": "^5.0.7",
     "jsonwebtoken": "8.5.1",

backend/package.json

@@ -32,7 +32,7 @@ export default class ApiResponseHandler extends LoggingBase {
           method: req.method,
           query: error.sql,
           body: req.body,
-          errorMessage: error.original.message,
+          errorMessage: error.original?.message,
         },
         'Database error while processing REST API request!',
       )

backend/src/api/apiResponseHandler.ts

@@ -34,6 +34,7 @@ export default async (req, res) => {
         activityTypes: await SettingsRepository.buildActivityTypes(
           tenantUser.tenant.settings[0].dataValues,
         ),
+        slackWebHook: !!tenantUser.tenant.settings[0].dataValues.slackWebHook,
       }
 
       return tenantUser

backend/src/api/auth/authMe.ts

@@ -0,0 +1,18 @@
+import Axios from 'axios'
+import Permissions from '../../security/permissions'
+import PermissionChecker from '../../services/user/permissionChecker'
+import SettingsService from '../../services/settingsService'
+
+export default async (req, res) => {
+  new PermissionChecker(req).validateHas(Permissions.values.automationCreate)
+  const { redirectUrl } = JSON.parse(Buffer.from(req.query.state, 'base64').toString())
+
+  const { url } = req.account
+
+  await SettingsService.save({ slackWebHook: url }, req)
+  await Axios.post(url, {
+    text: 'Crowd.dev Notifier has been successfully connected.',
+  })
+
+  res.redirect(redirectUrl)
+}

backend/src/api/automation/automationSlackCallback.ts

@@ -0,0 +1,20 @@
+import passport from 'passport'
+import Permissions from '../../security/permissions'
+import PermissionChecker from '../../services/user/permissionChecker'
+import { getSlackNotifierStrategy } from '../../services/auth/passportStrategies/slackStrategy'
+
+export default async (req, res, next) => {
+  new PermissionChecker(req).validateHas(Permissions.values.automationCreate)
+  const state = {
+    tenantId: req.params.tenantId,
+    redirectUrl: req.query.redirectUrl,
+    crowdToken: req.query.crowdToken,
+  }
+
+  const authenticator = passport.authenticate(getSlackNotifierStrategy(), {
+    scope: ['incoming-webhook'],
+    state: Buffer.from(JSON.stringify(state)).toString('base64'),
+  })
+
+  authenticator(req, res, next)
+}