implement channel-notifier

.funcignore

@@ -0,0 +1,7 @@
+*.js.map
+*.ts
+.git*
+.vscode
+local.settings.json
+test
+tsconfig.json

.gitignore

@@ -0,0 +1,97 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+
+# Diagnostic reports (https://nodejs.org/api/report.html)
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# TypeScript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+.env.test
+
+# parcel-bundler cache (https://parceljs.org/)
+.cache
+
+# next.js build output
+.next
+
+# nuxt.js build output
+.nuxt
+
+# vuepress build output
+.vuepress/dist
+
+# Serverless directories
+.serverless/
+
+# FuseBox cache
+.fusebox/
+
+# DynamoDB Local files
+.dynamodb/
+
+# TypeScript output
+dist
+out
+
+# Azure Functions artifacts
+bin
+obj
+appsettings.json
+local.settings.json
+
+# Others
+/tmp/

.vscode/extensions.json

@@ -0,0 +1,5 @@
+{
+  "recommendations": [
+    "ms-azuretools.vscode-azurefunctions"
+  ]
+}

.vscode/launch.json

@@ -0,0 +1,12 @@
+{
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "name": "Attach to Node Functions",
+      "type": "node",
+      "request": "attach",
+      "port": 9229,
+      "preLaunchTask": "func: host start"
+    }
+  ]
+}

.vscode/settings.json

@@ -0,0 +1,7 @@
+{
+  "azureFunctions.deploySubpath": ".",
+  "azureFunctions.projectLanguage": "TypeScript",
+  "azureFunctions.projectRuntime": "~2",
+  "debug.internalConsoleOptions": "neverOpen",
+  "azureFunctions.preDeployTask": "npm prune"
+}

.vscode/tasks.json

@@ -0,0 +1,31 @@
+{
+  "version": "2.0.0",
+  "tasks": [
+    {
+      "type": "func",
+      "command": "host start",
+      "problemMatcher": "$func-watch",
+      "isBackground": true,
+      "dependsOn": "npm build"
+    },
+    {
+      "type": "shell",
+      "label": "npm build",
+      "command": "npm run build",
+      "dependsOn": "npm install",
+      "problemMatcher": "$tsc"
+    },
+    {
+      "type": "shell",
+      "label": "npm install",
+      "command": "npm install"
+    },
+    {
+      "type": "shell",
+      "label": "npm prune",
+      "command": "npm prune --production",
+      "dependsOn": "npm build",
+      "problemMatcher": []
+    }
+  ]
+}

README.md

@@ -0,0 +1 @@
+# ap2020bot

SlackEvents/function.json

@@ -0,0 +1,20 @@
+{
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "res"
+    }
+  ],
+  "scriptFile": "../dist/SlackEvents/index.js"
+}

SlackEvents/handlers.ts

@@ -0,0 +1,39 @@
+import { Context } from "@azure/functions"
+import { WebClient } from '@slack/web-api';
+
+const webClient = new WebClient(process.env.SLACK_TOKEN_BOT);
+
+namespace Events {
+    export interface ChannelCreated {
+        type: "channel_created";
+        channel: {
+            id: string;
+            name: string;
+            created: number;
+            creator: string;
+        }
+    }
+
+    export interface ChannelUnarchive {
+        type: "channel_unarchive";
+        channel: string;
+        user: string;
+    }
+}
+
+// Handlers
+// the name of the handler must be the type of the event
+
+export const channel_created = async ({channel}: Events.ChannelCreated, context: Context) => {
+    await webClient.chat.postMessage({
+        channel: process.env.SLACK_CHANNEL_NOTIFICATIONS_OTHERS,
+        text: `:new: <@${channel.creator}> が <#${channel.id}> を作成しました :rocket:`,
+    });
+}
+
+export const channel_unarchive = async ({channel, user}: Events.ChannelUnarchive, context: Context) => {
+    await webClient.chat.postMessage({
+        channel: process.env.SLACK_CHANNEL_NOTIFICATIONS_OTHERS,
+        text: `:recycle: <@${user}> が <#${channel}> をアーカイブから復元しました :rocket:`,
+    });
+};

SlackEvents/index.ts

@@ -0,0 +1,52 @@
+import { AzureFunction, Context, HttpRequest } from "@azure/functions"
+import * as handlers from "./handlers";
+import * as crypto from "crypto";
+import * as timingSafeCompare from "tsscmp";
+
+const verify = (req: HttpRequest) => {
+    const version = 'v0';
+    const actual = req.headers['x-slack-signature'];
+
+    const timestamp = req.headers['x-slack-request-timestamp'];
+    const hmac = crypto.createHmac('sha256', process.env.SLACK_SIGNING_SECRET);
+    hmac.update(`${version}:${timestamp}:${req.rawBody}`);
+    const expected = `${version}=${hmac.digest('hex')}`;
+
+    return timingSafeCompare(expected, actual);
+}
+
+const httpTrigger: AzureFunction = async (context: Context, req: HttpRequest): Promise<void> => {
+    if (!verify(req)) {
+        context.log.error('unverified request from:', req.headers['x-forwarded-for']);
+        context.res = {
+            body: "",
+        };
+        return;
+    }
+    switch (req.body.type) {
+        case "url_verification":
+            context.log('Challenge from Slack');
+            context.res = {
+                body: req.body.challenge,
+            }
+            return;
+        case "event_callback":
+            let eventType = req.body.event.type
+            context.log('Incoming event: ', eventType);
+            context.res = {
+                body: "",
+            };
+            context.done(); // easy return because of the 3sec rule
+            if (eventType in handlers) {
+                // TODO: handle errors
+                await handlers[eventType](req.body.event, context);
+            } else {
+                context.log.error('no handler for event type:', eventType);
+            }
+            break;
+        default:
+            context.log.error('not recognized top-level event: ', req.body.type);
+    }
+};
+
+export default httpTrigger;

SlackEvents/sample.dat

@@ -0,0 +1,3 @@
+{
+    "name": "Azure"
+}

host.json

@@ -0,0 +1,7 @@
+{
+  "version": "2.0",
+  "extensionBundle": {
+    "id": "Microsoft.Azure.Functions.ExtensionBundle",
+    "version": "[1.*, 2.0.0)"
+  }
+}