✨ server: add maturity check and worker

Author: aguxez

.changeset/dull-candies-cheer.md

@@ -0,0 +1,5 @@
+---
+"@exactly/server": patch
+---
+
+✨ add maturity check and worker

app.config.ts

@@ -21,9 +21,8 @@ import versionCode from "./src/generated/versionCode.js";
 import type { IntercomPluginProps } from "@intercom/intercom-react-native/lib/typescript/module/expo-plugins/@types";
 import type { withSentry } from "@sentry/react-native/expo";
 import type { ExpoConfig } from "expo/config";
-import type * as OneSignalPlugin from "onesignal-expo-plugin/types/types";
+import type * as OneSignalPlugin from "onesignal-expo-plugin/build/types/types";
 
-const { Mode } = require("onesignal-expo-plugin/build/types/types") as typeof OneSignalPlugin; // eslint-disable-line unicorn/prefer-module
 
 if (env.EAS_BUILD_RUNNER === "eas-build") env.APP_DOMAIN ??= "web.exactly.app";
 if (env.APP_DOMAIN) env.EXPO_PUBLIC_DOMAIN = env.APP_DOMAIN;
@@ -121,7 +120,7 @@ export default {
     [
       "onesignal-expo-plugin",
       {
-        mode: env.NODE_ENV === "production" ? Mode.Prod : Mode.Dev,
+        mode: env.NODE_ENV === "production" ? "production" : "development",
         smallIcons: ["src/assets/notifications_default.png"],
         largeIcons: ["src/assets/notifications_default_large.png"],
       } satisfies OneSignalPlugin.OneSignalPluginProps,
@@ -168,7 +167,7 @@ export default {
     }`;
           let contents = readFileSync(buildGradle, "utf8");
           if (!contents.includes("nexus.ext.meawallet.com")) {
-            contents = contents.replace(/(allprojects[\s\S]*?repositories\s*\{)/, `$1\n${meaRepo}`);
+            contents = contents.replace(/(allprojects[\s\S]*?repositories\s*\{)/, `$1\n${meaRepo}`); // cspell:ignore allprojects
             writeFileSync(buildGradle, contents);
           }
           return c;

cspell.json

@@ -1,8 +1,6 @@
 {
   "language": "en",
-  "import": [
-    "@cspell/dict-es-es/cspell-ext.json"
-  ],
+  "import": ["@cspell/dict-es-es/cspell-ext.json", "@cspell/dict-pt-br/cspell-ext.json"],
   "ignorePaths": [
     "*.svg",
     "*.local.yaml",
@@ -213,13 +211,85 @@
         "montos",
         "refinancia",
         "refinanciamiento",
-        "refinanciar"
+        "refinanciar",
+        "repágala",
+        "verifícate"
       ]
+    },
+    {
+      "filename": "**/i18n/**/es-AR.json",
+      "language": "en,es",
+      "words": [
+        "accedé",
+        "aceptás",
+        "activá",
+        "actualizá",
+        "agregá",
+        "ahorrá",
+        "ajustá",
+        "aprendé",
+        "asegurate",
+        "biometría",
+        "cambiá",
+        "completá",
+        "conectate",
+        "conectá",
+        "conectás",
+        "configurá",
+        "conocé",
+        "conservá",
+        "copiá",
+        "creá",
+        "cripto",
+        "debés",
+        "depositá",
+        "desbloqueá",
+        "empezá",
+        "enviá",
+        "enviás",
+        "esperá",
+        "evitá",
+        "habilitá",
+        "hacé",
+        "hacés",
+        "ingresá",
+        "iniciá",
+        "intentalo",
+        "intentá",
+        "introducí",
+        "mantenete",
+        "maximizá",
+        "mejorá",
+        "montos",
+        "obtené",
+        "pagá",
+        "pasá",
+        "podés",
+        "ponete",
+        "presioná",
+        "probá",
+        "querés",
+        "recargá",
+        "refinanciar",
+        "refinanciá",
+        "registrate",
+        "renová",
+        "reportá",
+        "revisá",
+        "seleccioná",
+        "simulá",
+        "tocá",
+        "usalo",
+        "usás",
+        "verificate",
+        "verificá"
+      ]
+    },
+    {
+      "filename": "**/i18n/**/pt.json",
+      "language": "en,pt",
+      "words": ["autocustódia", "criptomoedas"]
     }
   ],
-  "ignoreRegExpList": [
-    "\\bitmpl_\\w+\\b",
-    "\\b(w|stat)?aBas\\w+\\b",
-    "\\baOpt\\w+\\b"
-  ]
+  "ignoreRegExpList": ["\\bitmpl_\\w+\\b", "\\b(w|stat)?aBas\\w+\\b", "\\baOpt\\w+\\b"]
 }

package.json

@@ -126,6 +126,7 @@
     "@changesets/cli": "^2.29.8",
     "@changesets/types": "^6.1.0",
     "@cspell/dict-es-es": "^3.0.8",
+    "@cspell/dict-pt-br": "^2.4.2",
     "@eslint/mcp": "^0.2.0",
     "@expo/fingerprint": "^0.15.4",
     "@nx/esbuild": "22.4.5",

pnpm-lock.yaml

@@ -4,11 +4,14 @@
   "Card purchase": "Compra con tarjeta",
   "Credit mode activated": "Modo crédito activado",
   "Credit mode is active": "El modo crédito está activo",
+  "Debt Maturity Alert": "Alerta de vencimiento de deuda",
   "Deposited funds": "Fondos depositados",
   "Fiat onramp activated": "Cuenta fiat activada",
   "Funds received": "Fondos recibidos",
   "Refund processed": "Reembolso procesado",
   "Withdraw completed": "Retiro completado",
+  "Your debt is due in 1 hour. Repay now to avoid liquidation.": "Tu deuda vence en 1 hora. Repágala ahora para evitar la liquidación.",
+  "Your debt is due in 24 hours. Repay now to avoid liquidation.": "Tu deuda vence en 24 horas. Repágala ahora para evitar la liquidación.",
   "Your fiat onramp account has been activated": "Tu cuenta para depositar dinero fiat ha sido activada",
   "{{amount}} at {{merchantName}}. Paid in {{count}} installments_zero": "{{amount}} en {{merchantName}}. Pagado con USDC",
   "{{amount}} at {{merchantName}}. Paid in {{count}} installments_one": "{{amount}} en {{merchantName}}. Pagado con crédito",

server/i18n/es.json

@@ -4,11 +4,14 @@
   "Card purchase": "Compra no cartão",
   "Credit mode activated": "Modo crédito ativado",
   "Credit mode is active": "O modo crédito está ativo",
+  "Debt Maturity Alert": "Alerta de vencimento de dívida",
   "Deposited funds": "Fundos depositados",
   "Fiat onramp activated": "Conta fiat ativada",
   "Funds received": "Fundos recebidos",
   "Refund processed": "Reembolso processado",
   "Withdraw completed": "Saque concluído",
+  "Your debt is due in 1 hour. Repay now to avoid liquidation.": "Sua dívida vence em 1 hora. Pague agora para evitar a liquidação.",
+  "Your debt is due in 24 hours. Repay now to avoid liquidation.": "Sua dívida vence em 24 horas. Pague agora para evitar a liquidação.",
   "Your fiat onramp account has been activated": "Sua conta para depositar dinheiro fiat foi ativada",
   "{{amount}} at {{merchantName}}. Paid in {{count}} installments_zero": "{{amount}} em {{merchantName}}. Pago com USDC",
   "{{amount}} at {{merchantName}}. Paid in {{count}} installments_one": "{{amount}} em {{merchantName}}. Pago no crédito",

server/i18n/pt.json

@@ -21,6 +21,7 @@ import androidFingerprints from "./utils/android/fingerprints";
 import appOrigin from "./utils/appOrigin";
 import auth from "./utils/auth";
 import { closeQueue as closeAccountQueue } from "./utils/createCredential";
+import { closeQueue as closeMaturityQueue, scheduleMaturityChecks } from "./utils/maturity";
 import { close as closeRedis } from "./utils/redis";
 import { closeAndFlush as closeSegment } from "./utils/segment";
 
@@ -319,20 +320,29 @@ export default app;
 const server = serve(app);
 
 export async function close() {
-  return new Promise((resolve, reject) => {
-    server.close((error) => {
-      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"));
-          else resolve(null);
-        })
-        .catch(reject);
-    });
+  const serverError = await new Promise<Error | undefined>((resolve) => {
+    server.close((error) => resolve(error));
   });
+  const results = await Promise.allSettled([
+    closeSentry(),
+    closeSegment(),
+    database.$client.end(),
+    closeAccountQueue(),
+    closeMaturityQueue(),
+    closeRedis(),
+  ]);
+  const errors = [
+    ...(serverError ? [serverError] : []),
+    ...results.filter((r): r is PromiseRejectedResult => r.status === "rejected").map((r) => r.reason as unknown),
+  ];
+  if (errors.length > 0) throw new AggregateError(errors, "closing services failed");
 }
 
 if (!process.env.VITEST) {
+  scheduleMaturityChecks().catch((error: unknown) => {
+    captureException(error, { level: "error", tags: { unhandled: true } });
+  });
+
   ["SIGINT", "SIGTERM"].map((code) => {
     process.on(code, () => {
       close()

server/index.ts

@@ -171,6 +171,57 @@ describe("proposal", () => {
       });
       expect(hasExpectedTransfers(receipts, expected)).toBe(true);
     });
+
+    it("sends withdraw notification after proposal execution", async () => {
+      const [withdraw, anotherWithdraw] = proposals;
+      if (!withdraw || !anotherWithdraw) throw new Error("missing proposals");
+      const sendPushNotification = vi.spyOn(onesignal, "sendPushNotification").mockResolvedValue({});
+      vi.spyOn(ensClient, "getEnsName").mockResolvedValue("alice.eth");
+      vi.spyOn(publicClient, "readContract").mockImplementation(({ functionName }) => {
+        if (functionName === "decimals") return Promise.resolve(6);
+        if (functionName === "symbol") return Promise.resolve("exaUSDC");
+        return Promise.reject(new Error("unexpected readContract call"));
+      });
+      const proposalExecutions = waitForSuccessfulProposalExecutions([withdraw.args.nonce, anotherWithdraw.args.nonce]);
+
+      await Promise.all([
+        appClient.index.$post({
+          ...withdrawProposal,
+          json: {
+            ...withdrawProposal.json,
+            event: {
+              ...withdrawProposal.json.event,
+              data: {
+                ...withdrawProposal.json.event.data,
+                block: {
+                  ...withdrawProposal.json.event.data.block,
+                  logs: [
+                    { topics: withdraw.topics, data: withdraw.data, account: { address: withdraw.address } },
+                    {
+                      topics: anotherWithdraw.topics,
+                      data: anotherWithdraw.data,
+                      account: { address: anotherWithdraw.address },
+                    },
+                  ],
+                },
+              },
+            },
+          },
+        }),
+        proposalExecutions,
+      ]);
+      await vi.waitUntil(() => sendPushNotification.mock.calls.length >= 2, 26_666);
+      expect(sendPushNotification).toHaveBeenCalledWith({
+        userId: bobAccount,
+        headings: { en: "Withdraw completed", es: "Retiro completado" }, // cspell:ignore Retiro completado
+        contents: { en: "3 USDC sent to alice.eth", es: "3 USDC enviados a alice.eth" }, // cspell:ignore enviados
+      });
+      expect(sendPushNotification).toHaveBeenCalledWith({
+        userId: bobAccount,
+        headings: { en: "Withdraw completed", es: "Retiro completado" },
+        contents: { en: "4 USDC sent to alice.eth", es: "4 USDC enviados a alice.eth" },
+      });
+    });
   });
 
   describe("with weth withdraw proposal", () => {

server/test/hooks/block.test.ts

@@ -1169,6 +1169,7 @@ describe("card operations", () => {
       });
 
       it("captures partial refund feedback errors", async () => {
+        const sendPushNotification = vi.spyOn(onesignal, "sendPushNotification");
         const error = new Error("feedback failed");
         vi.spyOn(sardine, "feedback").mockRejectedValue(error);
         const cardId = "partial-refund-feedback-error";
@@ -1213,6 +1214,14 @@ describe("card operations", () => {
 
         expect(captureException).toHaveBeenCalledWith(error, { level: "error" });
         expect(response.status).toBe(200);
+        expect(sendPushNotification).toHaveBeenCalledWith({
+          userId: account,
+          headings: t("Refund processed"),
+          contents: t("{{refundAmount}} USDC from {{merchantName}} have been refunded to your account", {
+            refundAmount: f(0.05),
+            merchantName: "99999",
+          }),
+        });
       });
 
       it("returns ok on reversal replay", async () => {