✨ server: add debt repayment notification

.changeset/dull-candies-cheer.md

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

cspell.json

@@ -1,9 +1,6 @@
 {
   "language": "en",
-  "import": [
-    "@cspell/dict-es-es/cspell-ext.json",
-    "@cspell/dict-pt-br/cspell-ext.json"
-  ],
+  "import": ["@cspell/dict-es-es/cspell-ext.json", "@cspell/dict-pt-br/cspell-ext.json"],
   "ignorePaths": [
     "*.svg",
     "*.local.yaml",
@@ -213,6 +210,7 @@
         "refinancia",
         "refinanciamiento",
         "refinanciar",
+        "repágala",
         "verifícate"
       ]
     },
@@ -288,15 +286,8 @@
     {
       "filename": "**/i18n/**/pt.json",
       "language": "en,pt",
-      "words": [
-        "autocustódia",
-        "criptomoedas"
-      ]
+      "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"]
 }

server/i18n/es.json

@@ -4,13 +4,16 @@
   "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",
   "Exa Card purchase rejected": "Compra con Exa Card rechazada",
   "Fiat onramp activated": "Cuenta fiat activada",
   "Funds received": "Fondos recibidos",
   "Refund processed": "Reembolso procesado",
   "Transaction at {{merchantName}} for {{amount}} rejected: {{reason}}": "Transacción en {{merchantName}} por {{amount}} rechazada: {{reason}}",
   "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",
   "frozen card": "tarjeta bloqueada",
   "insufficient funds": "fondos insuficientes",

server/i18n/pt.json

@@ -4,13 +4,16 @@
   "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",
   "Exa Card purchase rejected": "Compra com Exa Card recusada",
   "Fiat onramp activated": "Conta fiat ativada",
   "Funds received": "Fundos recebidos",
   "Refund processed": "Reembolso processado",
   "Transaction at {{merchantName}} for {{amount}} rejected: {{reason}}": "Transação em {{merchantName}} de {{amount}} recusada: {{reason}}",
   "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",
   "frozen card": "cartão bloqueado",
   "insufficient funds": "fundos insuficientes",

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 closeMaturityQueue, scheduleMaturityChecks } from "./utils/maturity";
 import { close as closeRedis } from "./utils/redis";
 import { closeAndFlush as closeSegment } from "./utils/segment";
 
@@ -320,20 +321,28 @@ 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()])
-        .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(),
+    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()