Issue 1366 - Slack integrations [ Docker Events ]

tools/autodeployment/env.example

@@ -16,3 +16,14 @@ UNSPLASH_CLIENT_ID=
 
 # Path to certificates
 PATH_TO_CERTS=
+
+# Slack "Incoming WebHook" to send messages to #telescope channel.
+# For more information: https://api.slack.com/messaging/webhooks
+# Example:
+# await fetch(SLACK_SEND_MESSAGE, {
+#       method: 'post',
+#       headers: { 'Content-Type': 'application/json' },
+#       body: "text": "This is the message"
+#     });
+# This will send the following message to our Slack channel: "This is the message"
+SLACK_SEND_MESSAGE=

tools/autodeployment/package.json

@@ -4,12 +4,13 @@
   "description": "A tool for automatic deployment",
   "main": "server.js",
   "dependencies": {
+    "node-fetch": "^2.6.1",
     "date-fns": "^2.16.1",
     "dotenv": "^8.2.0",
     "github-webhook-handler": "^1.0.0",
     "merge-stream": "^2.0.0",
     "pm2": "^4.4.1",
-    "shelljs": "^0.8.3"
+    "shelljs": "^0.8.4"
   },
   "scripts": {
     "start": "node server.js"

tools/autodeployment/server.js

@@ -7,7 +7,7 @@ const mergeStream = require('merge-stream');
 const fs = require('fs');
 
 const { buildStart, buildStop, handleStatus } = require('./info');
-
+const { dockerMonitor } = require('./src/docker_events');
 // Current build process output stream (if any)
 let out;
 const {
@@ -27,6 +27,9 @@ const credentials = {
   cert: certificate,
 };
 
+// Docker Monitor module:
+dockerMonitor();
+
 function handleError(req, res) {
   res.statusCode = 404;
   res.end('Not Found');

tools/autodeployment/src/docker_events/docker-listener.sh

@@ -0,0 +1,11 @@
+# This script listens to docker events and will report only the following events:
+# START, UNPAUSE, RESTART, PAUSE, DIE and STOP.
+
+
+#!/bin/bash
+
+docker events --format '{{json .}}' --filter 'event=start' --filter 'event=unpause' --filter 'event=restart' --filter 'event=pause' --filter 'event=die' --filter 'event=stop'|
+while read event;
+do
+    echo ${event}
+done

tools/autodeployment/src/docker_events/index.js

@@ -0,0 +1,108 @@
+/* eslint-disable no-unused-expressions */
+const shell = require('shelljs');
+const fetch = require('node-fetch');
+const Events = require('events');
+
+const { SLACK_SEND_MESSAGE } = process.env;
+
+const dockerEvents = new Events.EventEmitter();
+
+const server = process.DEPLOY_TYPE === 'production' ? 'PRODUCTION' : 'DEV';
+
+const eventsDown = ['pause', 'die', 'stop'];
+const eventsBack = ['start', 'unpause', 'restart'];
+
+const containersUp = new Set();
+const containersDown = new Set();
+
+const message = (eventLog) => {
+  const {
+    status,
+    Action,
+    Actor: {
+      Attributes: { name },
+    },
+  } = eventLog;
+
+  const isDown = eventsDown.includes(Action);
+
+  const logo = isDown
+    ? 'https://www.iconsdb.com/icons/preview/red/warning-xxl.png'
+    : 'https://www.iconsdb.com/icons/preview/green/up-circular-xxl.png';
+
+  return {
+    blocks: [
+      {
+        type: 'divider',
+      },
+      {
+        type: 'section',
+        text: {
+          type: 'mrkdwn',
+          text: `* ${server} DOCKER CONTAINER: ${
+            isDown ? 'DOWN' : 'UP'
+          }*\n\nContainer: ${name}\nAction: ${Action}\nCurrent Status: ${status}\n`,
+        },
+        accessory: {
+          type: 'image',
+          image_url: logo,
+          alt_text: 'alt text for image',
+        },
+      },
+      {
+        type: 'divider',
+      },
+    ],
+  };
+};
+
+const sendMessage = async (containerEvent) => {
+  await fetch(SLACK_SEND_MESSAGE, {
+    method: 'post',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify(message(containerEvent)),
+  });
+};
+
+const eventHandle = (containerEvent) => {
+  const {
+    Action,
+    Actor: {
+      Attributes: { name },
+    },
+  } = containerEvent;
+
+  if (
+    (containersDown.has(name) && eventsDown.includes(Action)) ||
+    (containersUp.has(name) && eventsBack.includes(Action))
+  )
+    return;
+
+  if (eventsDown.includes(Action)) {
+    containersUp.has(name) ? containersUp.delete(name) : null;
+    containersDown.add(name);
+  } else {
+    containersDown.has(name) ? containersDown.delete(name) : null;
+    containersUp.add(name);
+  }
+  sendMessage(containerEvent);
+};
+
+const dockerListener = () => {
+  const event = shell.exec('./docker-listener.sh', {
+    silent: true,
+    async: true,
+  });
+  event.stdout.on('data', (data) => {
+    const containerEvent = JSON.parse(data);
+    if (containerEvent.Actor.Attributes.name.includes('telescope')) {
+      eventHandle(containerEvent);
+    }
+  });
+};
+
+dockerEvents.on('start', dockerListener);
+
+const dockerMonitor = () => dockerEvents.emit('start');
+
+module.exports = { dockerMonitor };