Add webhook refresh

ebs/package.json

@@ -7,6 +7,7 @@
         "build": "esbuild --bundle --minify --platform=node --sourcemap=inline --outfile=dist/index.js src/index.ts"
     },
     "dependencies": {
+        "@octokit/webhooks": "^13.2.7",
         "@twurple/api": "^7.1.0",
         "@twurple/ebs-helper": "^7.1.0",
         "body-parser": "^1.20.2",

ebs/src/modules/config.ts

@@ -4,6 +4,7 @@ import { sendPubSubMessage } from "../util/pubsub";
 import { strToU8, compressSync, strFromU8 } from "fflate";
 import { getBannedUsers } from "../util/db";
 import { asyncCatch } from "../util/middleware";
+import { Webhooks } from "@octokit/webhooks";
 
 let activeConfig: Config | undefined;
 let configData: Config | undefined;
@@ -84,6 +85,26 @@ app.get("/private/refresh", asyncCatch(async (_, res) => {
     res.sendStatus(200);
 }));
 
+const webhooks = new Webhooks({
+    secret: process.env.PRIVATE_API_KEY!,
+});
+
+app.post("/webhook/refresh", asyncCatch(async (req, res) => {
+    // github webhook
+    const signature = req.headers["x-hub-signature-256"] as string;
+    const body = req.body as string;
+
+    if(!(await webhooks.verify(body, signature))) {
+        res.sendStatus(403);
+        return;
+    }
+
+    await refreshConfig();
+    console.log("Refreshed config, new config version is ", activeConfig!.version);
+    await broadcastConfigRefresh(activeConfig!);
+    res.sendStatus(200);
+}));
+
 app.get("/public/config", asyncCatch(async (req, res) => {
     const config = await getConfig();
     res.send(JSON.stringify(config));