✨ server: add queue on user creation

.changeset/plain-pumas-relax.md

@@ -0,0 +1,5 @@
+---
+"@exactly/server": patch
+---
+
+✨ migrate webhook subscription to queue

cspell.json

@@ -139,6 +139,7 @@
     "reactnavigation",
     "redeployer",
     "reentrancy",
+    "retriable",
     "rpid",
     "rustup",
     "scannability",

server/api/auth/authentication.ts

@@ -44,7 +44,7 @@ import database, { credentials } from "../../database";
 import androidOrigins from "../../utils/android/origins";
 import appOrigin from "../../utils/appOrigin";
 import authSecret from "../../utils/authSecret";
-import createCredential from "../../utils/createCredential";
+import createCredential, { WebhookNotReadyError } from "../../utils/createCredential";
 import decodePublicKey from "../../utils/decodePublicKey";
 import getIntercomToken from "../../utils/intercom";
 import publicClient from "../../utils/publicClient";
@@ -341,6 +341,10 @@ Submit the signed SIWE message to prove ownership of an Ethereum address. The se
             200,
           );
         } catch (error) {
+          if (error instanceof WebhookNotReadyError) {
+            captureException(error, { level: "warning", tags: { retriable: true } });
+            return c.json({ code: "service unavailable" }, 503);
+          }
           captureException(error, { level: "error", tags: { unhandled: true } });
           return c.json({ code: "ouch", legacy: "ouch" }, 500);
         }

server/api/auth/registration.ts

@@ -40,7 +40,7 @@ import { Address, Base64URL, Hex } from "@exactly/common/validation";
 import { Authentication } from "./authentication";
 import androidOrigins from "../../utils/android/origins";
 import appOrigin from "../../utils/appOrigin";
-import createCredential from "../../utils/createCredential";
+import createCredential, { WebhookNotReadyError } from "../../utils/createCredential";
 import getIntercomToken from "../../utils/intercom";
 import publicClient from "../../utils/publicClient";
 import redis from "../../utils/redis";
@@ -370,6 +370,10 @@ export default new Hono()
           200,
         );
       } catch (error) {
+        if (error instanceof WebhookNotReadyError) {
+          captureException(error, { level: "warning", tags: { retriable: true } });
+          return c.json({ code: "service unavailable" }, 503);
+        }
         captureException(error, { level: "error", tags: { unhandled: true } });
         return c.json({ code: "ouch", legacy: "ouch" }, 500);
       }

server/hooks/activity.ts

@@ -323,10 +323,15 @@ findWebhook(({ webhook_type, webhook_url }) => webhook_type === "ADDRESS_ACTIVIT
   .then(async (currentHook) => {
     if (currentHook) {
       webhookId = currentHook.id;
+      debug("alchemy webhook initialized with existing hook: %s", webhookId);
       return signingKeys.add(currentHook.signing_key);
     }
     const newHook = await createWebhook({ webhook_type: "ADDRESS_ACTIVITY", webhook_url: url, addresses: [] });
     webhookId = newHook.id;
+    debug("alchemy webhook initialized with new hook: %s", webhookId);
     signingKeys.add(newHook.signing_key);
   })
-  .catch((error: unknown) => captureException(error));
+  .catch((error: unknown) => {
+    debug("failed to initialize alchemy webhook: %o", error);
+    captureException(error, { level: "error" });
+  });

server/index.ts

@@ -20,6 +20,7 @@ import panda from "./hooks/panda";
 import persona from "./hooks/persona";
 import androidFingerprints from "./utils/android/fingerprints";
 import appOrigin from "./utils/appOrigin";
+import { closeQueue as closeAccountQueue } from "./utils/createCredential";
 import { close as closeRedis } from "./utils/redis";
 import { closeAndFlush as closeSegment } from "./utils/segment";
 
@@ -319,10 +320,10 @@ export default app;
 
 const server = serve(app);
 
-export async function close() {
+export function close() {
   return new Promise((resolve, reject) => {
     server.close((error) => {
-      Promise.allSettled([closeSentry(), closeRedis(), closeSegment(), database.$client.end()])
+      Promise.allSettled([closeSentry(), closeRedis(), closeSegment(), database.$client.end(), closeAccountQueue()])
         .then((results) => {
           if (error) reject(error);
           else if (results.some((result) => result.status === "rejected")) reject(new Error("closing services failed"));