I2 17/events api use setinterval

.github/workflows/ci.yml

@@ -4,10 +4,12 @@ on:
   push:
     branches:
       - master
+      - qa
       - renovate/*
   pull_request:
     branches:
       - master
+      - qa
 
 jobs:
   api-ci:

.github/workflows/docker.yml

@@ -3,6 +3,7 @@ on:
   push:
     branches:
       - "master"
+      - "qa"
 
 jobs:
   build:
@@ -34,21 +35,21 @@ jobs:
         uses: docker/build-push-action@v5
         with:
           context: ${{ matrix.component }}
-          push: ${{ github.event_name != 'pull_request' }}
+          push: ${{ github.event_name != 'pull_request' && ( github.ref == 'refs/heads/master' || github.ref == 'refs/heads/qa' ) }}
           platforms: linux/amd64
           file: ${{ matrix.component }}/Dockerfile
           tags: |
             ghcr.io/csesoc/website-${{ matrix.component }}:${{ github.sha }}
             ghcr.io/csesoc/website-${{ matrix.component }}:latest
           labels: ${{ steps.meta.outputs.labels }}
-  deploy-prod:
-    name: Deploy Production (CD)
+  deploy:
+    name: Deploy (CD)
     runs-on: ubuntu-latest
     needs: [build]
     concurrency: prod
     environment:
       name: prod
-    if: ${{ github.event_name != 'pull_request' && github.ref == 'refs/heads/master' }}
+    if: ${{ github.event_name != 'pull_request' && ( github.ref == 'refs/heads/master' || github.ref == 'refs/heads/qa' ) }}
     steps:
       - name: Checkout repository
         uses: actions/checkout@v4
@@ -58,17 +59,29 @@ jobs:
           ref: develop
       - name: Install yq - portable yaml processor
         uses: mikefarah/yq@v4.27.2
+      - name: "Determine deployment type"
+        id: get_manifest
+        env:
+          BRANCH: ${{ github.ref }}
+        run: |
+          if [[ "${{ github.ref }}" == "refs/heads/master" ]]; then
+            echo "TYPE=prod" >> $GITHUB_OUTPUT
+          elif [[ "${{ github.ref }}" == "refs/heads/qa" ]]; then
+            echo "TYPE=qa" >> $GITHUB_OUTPUT
+          else
+            exit 1
+          fi
       - name: Update deployment
         env:
           GITHUB_TOKEN: ${{ secrets.GH_TOKEN }}
         run: |
           git config user.name "CSESoc CD"
           git config user.email "technical@csesoc.org.au"
-          git checkout -b update/website-prod/${{ github.sha }}
-          yq -i '.items[0].spec.template.spec.containers[0].image = "ghcr.io/csesoc/website-backend:${{ github.sha }}"' apps/projects/website/prod/deploy-backend.yml
-          yq -i '.items[0].spec.template.spec.containers[0].image = "ghcr.io/csesoc/website-frontend:${{ github.sha }}"' apps/projects/website/prod/deploy-frontend.yml
+          git checkout -b update/website-${{ steps.get_manifest.outputs.TYPE }}/${{ github.sha }}
+          yq -i '.items[0].spec.template.spec.containers[0].image = "ghcr.io/csesoc/website-backend:${{ github.sha }}"' apps/projects/website/${{ steps.get_manifest.outputs.TYPE }}/deploy-backend.yml
+          yq -i '.items[0].spec.template.spec.containers[0].image = "ghcr.io/csesoc/website-frontend:${{ github.sha }}"' apps/projects/website/${{ steps.get_manifest.outputs.TYPE }}/deploy-frontend.yml
           git add .
-          git commit -m "feat(website/prod): update image"
-          git push -u origin update/website-prod/${{ github.sha }}
-          gh pr create -B develop --title "feat(website/prod): update image" --body "Updates the image for the website-prod deployment to commit csesoc/csesoc-website@${{ github.sha }}." > URL
+          git commit -m "feat(website/${{ steps.get_manifest.outputs.TYPE }}): update image"
+          git push -u origin update/website-${{ steps.get_manifest.outputs.TYPE }}/${{ github.sha }}
+          gh pr create -B develop --title "feat(website/${{ steps.get_manifest.outputs.TYPE }}): update image" --body "Updates the image for the website-prod deployment to commit csesoc/csesoc-website@${{ github.sha }}." > URL
           gh pr merge $(cat URL) --squash -d

.gitignore

@@ -35,3 +35,5 @@ yarn-error.log*
 # typescript
 *.tsbuildinfo
 next-env.d.ts
+
+*.env

backend/package.json

@@ -9,6 +9,7 @@
     "@types/cors": "^2.8.17",
     "@types/express": "^4.17.21",
     "@types/node": "^20.12.13",
+    "async-mutex": "^0.5.0",
     "cors": "^2.8.5",
     "dotenv": "^16.4.5",
     "express": "^4.19.2",

backend/src/controllers/events.ts

@@ -0,0 +1,6 @@
+import { RequestHandler } from "express";
+import { eventInfo } from "../data/eventData";
+
+export const EventsHandler: RequestHandler = (req, res) => {
+  res.status(200).json(eventInfo);
+}

backend/src/controllers/eventsWebhook.ts

@@ -0,0 +1,137 @@
+import crypto from "crypto";
+import { RequestHandler } from "express";
+import { eventInfo, eventInfoMutex, fetchEvent } from "../data/eventData";
+import { filterInPlace, replaceInPlace } from "../util";
+
+interface FacebookWebhookPayload {
+  object: string;
+  entry: Array<{
+    id: string;
+    changes: Array<{
+      field: string;
+      value: {
+        event_id: string;
+        item: string;
+        verb: string;
+      };
+    }>;
+  }>;
+}
+
+const verifySignature = (
+  rawBody: Buffer,
+  signatureHeader?: string
+): boolean => {
+  if (!signatureHeader) return false;
+  const [algo, signature] = signatureHeader.split("=");
+  if (algo !== "sha256") return false;
+
+  const expected = crypto
+    .createHmac("sha256", process.env.FB_APP_SECRET as string)
+    .update(rawBody)
+    .digest("hex");
+
+  return crypto.timingSafeEqual(Buffer.from(signature), Buffer.from(expected));
+};
+
+export const EventsWebhookVerifier: RequestHandler = (req, res) => {
+  const mode = req.query["hub.mode"];
+  const token = req.query["hub.verify_token"];
+  const challenge = req.query["hub.challenge"];
+
+  if (mode === "subscribe" && token === process.env.FB_WEBHOOK_VERIFY_TOKEN) {
+    return res.status(200).send(challenge);
+  }
+
+  res.sendStatus(403);
+};
+
+/*
+Sample webhook payload
+https://developers.facebook.com/docs/graph-api/webhooks/getting-started/webhooks-for-pages -- for the outer wrapper
+https://developers.facebook.com/docs/graph-api/webhooks/reference/page/#feed -- for the inner objects
+
+{
+  "object": "page",
+  "entry": [
+    {
+      "id": "PAGE_ID",
+      "time": 1623242342342,
+      "changes": [
+        {
+          "field": "events",
+          "value": {
+            "event_id": "123456789",
+            "verb": "create",  // also "edit" or "delete"
+            "published": 1
+          }
+        }
+      ]
+    }
+  ]
+}
+*/
+
+export const EventsWebhookUpdate: RequestHandler = async (req, res) => {
+  const signature = req.headers["x-hub-signature-256"];
+  if (
+    !req.rawBody ||
+    typeof signature !== "string" ||
+    !verifySignature(req.rawBody, signature)
+  ) {
+    return res.sendStatus(401);
+  }
+
+  const notif: FacebookWebhookPayload = req.body;
+  if (
+    !notif ||
+    !notif.entry ||
+    notif.object !== "page" ||
+    notif.entry.length === 0
+  ) {
+    return res.sendStatus(400);
+  }
+
+  for (const entry of notif.entry) {
+    if (entry.id !== process.env.FB_EVENT_PAGE_ID) continue;
+
+    for (const change of entry.changes) {
+      if (change.field !== "feed" || change.value.item !== "event") continue;
+
+      try {
+        if (change.value.verb === "delete") {
+          await eventInfoMutex.runExclusive(() =>
+            filterInPlace(eventInfo, (val) => val.id !== change.value.event_id)
+          );
+          console.log(`Deleted event: ${change.value.event_id}`);
+        } else if (change.value.verb === "edit") {
+          const newEvent = await fetchEvent(change.value.event_id);
+
+          eventInfoMutex.runExclusive(() =>
+            replaceInPlace(
+              eventInfo,
+              (val) => val.id === change.value.event_id,
+              newEvent
+            )
+          );
+          console.log(`Edited event: ${change.value.event_id}`);
+        } else if (change.value.verb === "add") {
+          const newEvent = await fetchEvent(change.value.event_id);
+          await eventInfoMutex.runExclusive(() => eventInfo.push(newEvent));
+          console.log(`Added event: ${change.value.event_id}`);
+        } else {
+          console.warn(
+            `Unknown verb "${change.value.verb}" for event ${change.value.event_id}`
+          );
+        }
+      } catch (err) {
+        console.error(
+          `Error processing event: ${change.value.event_id}:\n${err}`
+        );
+        return res.sendStatus(500);
+      }
+    }
+  }
+
+  res.sendStatus(200);
+};

backend/src/data/eventData.ts

@@ -0,0 +1,101 @@
+import { Mutex } from "async-mutex";
+import { inspect } from "util";
+import { FacebookError, Result, ResultType } from "../util";
+
+class EventInfo {
+  // god forbid a class have public members
+  public id: string;
+  public title: string;
+  public startTime: string;
+  public endTime?: string;
+  public location: string;
+  public imageUrl: string;
+  public link: string;
+
+  constructor(
+    id: string,
+    title: string,
+    startTime: string,
+    endTime: string | undefined,
+    location: string,
+    imageUrl: string
+  ) {
+    this.id = id;
+    this.title = title;
+    this.startTime = startTime;
+    this.endTime = endTime;
+    this.location = location;
+    this.imageUrl = imageUrl;
+    // would use link as getter but getters are not enumerable so it doesn't appear in JSON.stringify :skull:
+    // maybe a cursed fix would be to use Object.defineProperty LOL
+    this.link = `https://www.facebook.com/events/${id}`;
+  }
+}
+
+interface FacebookEvent {
+  id: string;
+  name: string;
+  cover?: { source: string };
+  place?: { name: string };
+  start_time: string;
+  end_time?: string;
+}
+
+interface FacebookEventsResponse {
+  data: FacebookEvent[];
+}
+
+// this isn't in .env for different module compatiblity
+const FB_API_VERSION = "v23.0";
+const DEFAULT_EVENT_LOCATION = "Everything everywhere all at once!!!";
+const DEFAULT_EVENT_IMAGE = "/images/events/default_event.jpg";
+
+// we LOVE global variables
+export const eventInfoMutex = new Mutex();
+export const eventInfo: EventInfo[] = [];
+
+export async function fetchEvents() {
+  const response = await fetch(
+    `https://graph.facebook.com/${FB_API_VERSION}/${process.env.FB_EVENT_PAGE_ID}/events?access_token=${process.env.FB_ACCESS_TOKEN}&fields=id,name,cover,place,start_time,end_time`
+  );
+
+  if (!response.ok) {
+    throw new Error(JSON.stringify(response.json()));
+
+  }
+  const res: FacebookEventsResponse = await response.json();
+
+  const processed = res.data.map(
+    (e) =>
+      new EventInfo(
+        e.id,
+        e.name,
+        e.start_time,
+        e.end_time,
+        e.place?.name ?? DEFAULT_EVENT_LOCATION,
+        e.cover?.source ?? DEFAULT_EVENT_IMAGE
+      )
+  );
+
+  return processed;
+}
+
+export async function fetchEvent(id: string) {
+  const response = await fetch(
+    `https://graph.facebook.com/${FB_API_VERSION}/${id}?access_token=${process.env.FB_ACCESS_TOKEN}&fields=id,name,cover,place,start_time,end_time`
+  );
+
+  if (!response.ok) {
+    throw new Error(`Couldn't fetch details for event ${id}\n${JSON.stringify(response.json())}`);
+  }
+  const res: FacebookEvent = await response.json();
+
+  return new EventInfo(
+    res.id,
+    res.name,
+    res.start_time,
+    res.end_time,
+    res.place?.name ?? DEFAULT_EVENT_LOCATION,
+    res.cover?.source ?? DEFAULT_EVENT_IMAGE
+  );
+}