Wire frontend push subscription to notifier service

Author: coder13

package.json

@@ -11,7 +11,9 @@
     "lint": "eslint ./src/",
     "check:type": "tsc --noEmit",
     "serve": "vite preview",
-    "prepare": "husky"
+    "prepare": "husky",
+    "notify:service": "yarn notify:service:build && node services/assignment-notifier/dist/index.js",
+    "notify:service:build": "tsc -p services/assignment-notifier/tsconfig.json"
   },
   "dependencies": {
     "@apollo/client": "^3.8.7",

services/assignment-notifier/README.md

@@ -0,0 +1,33 @@
+# Assignment Notifier Service (scaffold)
+
+This is a single-service scaffold that polls WCIFs, detects assignment changes, and dispatches placeholder push notifications.
+
+## What it includes
+
+- WCIF polling loop
+- Assignment hash snapshots and diffing
+- Notification job generation with dedupe keys
+- Local JSON store for snapshots/subscriptions
+- Placeholder push sender (logs output)
+
+## Configure
+
+Create environment variables:
+
+- `WCA_OAUTH_TOKEN` - WCA token with WCIF access
+- `WCIF_COMPETITION_IDS` - comma-separated competition IDs
+- `WCIF_API_BASE_URL` (optional, defaults to WCA v0 API)
+- `WCIF_POLL_INTERVAL_MS` (optional, defaults to 300000)
+
+## Run
+
+```bash
+yarn notify:service
+```
+
+## Next steps
+
+- Replace `sendPushNotifications` with actual Web Push delivery.
+- Add API routes to register/remove subscriptions.
+- Move store to a persistent DB.
+- Add upcoming-assignment reminder jobs.

services/assignment-notifier/data/.gitkeep

@@ -0,0 +1,5 @@
+{
+  "snapshots": [],
+  "subscriptions": [],
+  "deliveredDedupeKeys": []
+}

services/assignment-notifier/data/store.json

@@ -0,0 +1,23 @@
+'use strict';
+Object.defineProperty(exports, '__esModule', { value: true });
+exports.getNotifierServiceConfig = getNotifierServiceConfig;
+function readNumber(name, fallback) {
+  const raw = process.env[name];
+  if (!raw) {
+    return fallback;
+  }
+  const parsed = Number(raw);
+  return Number.isFinite(parsed) ? parsed : fallback;
+}
+function getNotifierServiceConfig() {
+  const competitionIds = (process.env.WCIF_COMPETITION_IDS ?? '')
+    .split(',')
+    .map((part) => part.trim())
+    .filter(Boolean);
+  return {
+    wcifPollIntervalMs: readNumber('WCIF_POLL_INTERVAL_MS', 5 * 60 * 1000),
+    wcifApiBaseUrl: process.env.WCIF_API_BASE_URL ?? 'https://www.worldcubeassociation.org/api/v0',
+    apiToken: process.env.WCA_OAUTH_TOKEN ?? '',
+    competitionIds,
+  };
+}

services/assignment-notifier/dist/config.js

@@ -0,0 +1,47 @@
+'use strict';
+Object.defineProperty(exports, '__esModule', { value: true });
+exports.createAssignmentSnapshots = createAssignmentSnapshots;
+exports.buildNotificationJobs = buildNotificationJobs;
+const crypto_1 = require('crypto');
+function hashAssignments(value) {
+  return (0, crypto_1.createHash)('sha256')
+    .update(JSON.stringify(value ?? null))
+    .digest('hex');
+}
+function createAssignmentSnapshots(wcif) {
+  return wcif.persons
+    .filter((person) => person.wcaUserId)
+    .map((person) => ({
+      competitionId: wcif.id,
+      personWcaUserId: person.wcaUserId,
+      assignmentsHash: hashAssignments(person.assignments),
+      fetchedAt: new Date().toISOString(),
+    }));
+}
+function buildNotificationJobs(params) {
+  const previousByUser = new Map(
+    params.previousSnapshots.map((snapshot) => [
+      `${snapshot.competitionId}:${snapshot.personWcaUserId}`,
+      snapshot,
+    ]),
+  );
+  return params.nextSnapshots.flatMap((snapshot) => {
+    const id = `${snapshot.competitionId}:${snapshot.personWcaUserId}`;
+    const previous = previousByUser.get(id);
+    if (!previous || previous.assignmentsHash === snapshot.assignmentsHash) {
+      return [];
+    }
+    const dedupeKey = `assignment-update:${id}:${snapshot.assignmentsHash}`;
+    return [
+      {
+        id: `${Date.now()}:${id}`,
+        userId: snapshot.personWcaUserId,
+        competitionId: snapshot.competitionId,
+        title: 'New assignment update',
+        body: 'Your assignments were updated. Open the app to review the latest groups.',
+        dedupeKey,
+        createdAt: new Date().toISOString(),
+      },
+    ];
+  });
+}

services/assignment-notifier/dist/diff.js

@@ -0,0 +1,45 @@
+'use strict';
+Object.defineProperty(exports, '__esModule', { value: true });
+const diff_1 = require('./diff');
+const config_1 = require('./config');
+const pushSender_1 = require('./pushSender');
+const store_1 = require('./store');
+const wcifClient_1 = require('./wcifClient');
+async function runOnce() {
+  const config = (0, config_1.getNotifierServiceConfig)();
+  const store = await (0, store_1.readStore)();
+  for (const competitionId of config.competitionIds) {
+    const wcif = await (0, wcifClient_1.fetchWcif)(competitionId, {
+      apiBaseUrl: config.wcifApiBaseUrl,
+      token: config.apiToken,
+    });
+    const nextSnapshots = (0, diff_1.createAssignmentSnapshots)(wcif);
+    const previousSnapshots = store.snapshots.filter(
+      (snapshot) => snapshot.competitionId === competitionId,
+    );
+    const jobs = (0, diff_1.buildNotificationJobs)({ previousSnapshots, nextSnapshots }).filter(
+      (job) => !store.deliveredDedupeKeys.includes(job.dedupeKey),
+    );
+    await (0, pushSender_1.sendPushNotifications)({
+      jobs,
+      subscriptions: store.subscriptions,
+    });
+    store.snapshots = [
+      ...store.snapshots.filter((snapshot) => snapshot.competitionId !== competitionId),
+      ...nextSnapshots,
+    ];
+    store.deliveredDedupeKeys.push(...jobs.map((job) => job.dedupeKey));
+  }
+  await (0, store_1.saveStore)(store);
+}
+async function main() {
+  const config = (0, config_1.getNotifierServiceConfig)();
+  await runOnce();
+  if (process.env.NOTIFIER_RUN_ONCE === 'true') {
+    return;
+  }
+  setInterval(() => {
+    void runOnce();
+  }, config.wcifPollIntervalMs);
+}
+void main();

services/assignment-notifier/dist/index.js

@@ -0,0 +1,21 @@
+'use strict';
+Object.defineProperty(exports, '__esModule', { value: true });
+exports.sendPushNotifications = sendPushNotifications;
+async function sendPushNotifications(params) {
+  for (const job of params.jobs) {
+    const subscriptions = params.subscriptions.filter(
+      (subscription) => subscription.userId === job.userId,
+    );
+    for (const subscription of subscriptions) {
+      console.log(
+        '[push-notifier] send placeholder push',
+        JSON.stringify({
+          userId: subscription.userId,
+          endpoint: subscription.endpoint,
+          competitionId: job.competitionId,
+          dedupeKey: job.dedupeKey,
+        }),
+      );
+    }
+  }
+}

services/assignment-notifier/dist/pushSender.js

@@ -0,0 +1,33 @@
+'use strict';
+var __importDefault =
+  (this && this.__importDefault) ||
+  function (mod) {
+    return mod && mod.__esModule ? mod : { default: mod };
+  };
+Object.defineProperty(exports, '__esModule', { value: true });
+exports.readStore = readStore;
+exports.saveStore = saveStore;
+const promises_1 = require('fs/promises');
+const path_1 = __importDefault(require('path'));
+const STORE_PATH = path_1.default.resolve(
+  process.cwd(),
+  'services/assignment-notifier/data/store.json',
+);
+async function ensureStore() {
+  try {
+    const content = await (0, promises_1.readFile)(STORE_PATH, 'utf8');
+    return JSON.parse(content);
+  } catch {
+    return {
+      snapshots: [],
+      subscriptions: [],
+      deliveredDedupeKeys: [],
+    };
+  }
+}
+async function readStore() {
+  return ensureStore();
+}
+async function saveStore(store) {
+  await (0, promises_1.writeFile)(STORE_PATH, JSON.stringify(store, null, 2), 'utf8');
+}

services/assignment-notifier/dist/store.js

@@ -0,0 +1,2 @@
+'use strict';
+Object.defineProperty(exports, '__esModule', { value: true });