feat: implement Phase 4 (Quota management, centralized logging, and env sync)

.env.example

@@ -1,46 +1,35 @@
-# Environment Variables — EdTech
-
-# Copy this file to .env and fill in the values.
-# NEVER commit the real .env file to git.
-
-# ─── API Auth ──────────────────────────────────────────────────────────────────
-ADMIN_API_KEY=              # Strong random secret, e.g. openssl rand -hex 32
-
-# ─── WhatsApp / Meta ───────────────────────────────────────────────────────────
-WHATSAPP_VERIFY_TOKEN=      # Token you set in the Meta App dashboard
-WHATSAPP_APP_SECRET=        # App Secret from Meta App Settings > Basic
-WHATSAPP_ACCESS_TOKEN=      # Permanent System User token from Meta Business
-WHATSAPP_PHONE_NUMBER_ID=   # Phone Number ID from Meta App > WhatsApp > Getting Started
-
-# ─── Database ──────────────────────────────────────────────────────────────────
-DATABASE_URL=postgresql://user:password@localhost:5432/edtech?schema=public
-
-# ─── Redis ─────────────────────────────────────────────────────────────────────
-REDIS_URL=                  # e.g. redis://default:password@host:6379
-# Or individual connection params (if REDIS_URL is not set):
-# REDIS_HOST=localhost
-# REDIS_PORT=6379
-# REDIS_USERNAME=default
-# REDIS_PASSWORD=
-# REDIS_TLS=false
-
-# ─── Stripe ────────────────────────────────────────────────────────────────────
-STRIPE_SECRET_KEY=          # sk_live_... (or sk_test_... for dev)
-STRIPE_WEBHOOK_SECRET=      # whsec_... from Stripe dashboard > Webhooks
-
-# ─── OpenAI / AI ───────────────────────────────────────────────────────────────
-OPENAI_API_KEY=             # sk-...
-
-# ─── Cloudflare R2 Storage ────────────────────────────────────────────────────
-R2_ACCOUNT_ID=              # Cloudflare Account ID
-R2_ACCESS_KEY_ID=           # R2 API token Access Key ID
-R2_SECRET_ACCESS_KEY=       # R2 API token Secret Access Key
-R2_BUCKET=                  # R2 bucket name (e.g. edtech-docs)
-R2_PUBLIC_URL=              # Public URL of the bucket (e.g. https://pub-xxx.r2.dev)
-
-# ─── Frontend ──────────────────────────────────────────────────────────────────
-VITE_CLIENT_URL=https://your-frontend.netlify.app
-VITE_WHATSAPP_NUMBER=221XXXXXXXXX  # Replace with your production WhatsApp Bot number
-
-# ─── Internal (Worker → API) ───────────────────────────────────────────────────
-API_URL=http://localhost:3001   # In prod: full URL of the Fastify API
+# ─── DATABASE ─────────────────────────────────────────────────────────────────
+DATABASE_URL="postgresql://user:pass@host:port/db?schema=public"
+REDIS_URL="redis://localhost:6379"
+
+# ─── SECURITY ─────────────────────────────────────────────────────────────────
+JWT_SECRET="your-super-secret-jwt-key"
+ADMIN_API_KEY="your-internal-admin-key"
+ENCRYPTION_SECRET="your-32-char-encryption-key-for-secrets"
+WHATSAPP_VERIFY_TOKEN="your-meta-webhook-verify-token"
+WHATSAPP_APP_SECRET="your-meta-app-secret-for-hmac"
+
+# ─── PROVIDERS (GLOBAL FALLBACKS) ─────────────────────────────────────────────
+OPENAI_API_KEY="sk-..."
+GOOGLE_AI_API_KEY="AIza..."
+STRIPE_SECRET_KEY="sk_test_..."
+STRIPE_WEBHOOK_SECRET="whsec_..."
+STRIPE_PAAS_SUBSCRIPTION_PRICE_ID="price_..."
+
+# ─── INFRASTRUCTURE ───────────────────────────────────────────────────────────
+PORT=8080
+NODE_ENV="production"
+VITE_CLIENT_URL="https://admin.xamle.studio"
+RAILWAY_INTERNAL_URL="http://whatsapp-worker.railway.internal:8082"
+RAILWAY_PUBLIC_URL="https://api.xamle.studio"
+
+# ─── STORAGE (R2/S3) ───────────���──────────────────────────────────────────────
+R2_ACCESS_KEY_ID="..."
+R2_SECRET_ACCESS_KEY="..."
+R2_ENDPOINT="https://<accountid>.r2.cloudflarestorage.com"
+R2_BUCKET_NAME="edtech-media"
+R2_PUBLIC_URL="https://pub-....r2.dev"
+
+# ─── OBSERVABILITY ────────────────────────────────────────────────────────────
+LOG_LEVEL="info"
+LOGTAIL_TOKEN="your-betterstack-token" # Optional: for centralized logging

apps/api/package.json

@@ -20,6 +20,8 @@
         "@fastify/rate-limit": "^9.1.0",
         "@fastify/static": "^9.1.3",
         "@google/generative-ai": "^0.24.1",
+        "@logtail/node": "^0.5.8",
+        "@logtail/pino": "^0.5.8",
         "@prisma/client": "^5.0.0",
         "@repo/database": "workspace:*",
         "@repo/prompts": "workspace:*",
@@ -36,6 +38,7 @@
         "ioredis": "^5.9.3",
         "node-cron": "^4.2.1",
         "openai": "^4.0.0",
+        "pino-pretty": "^13.1.3",
         "pptxgenjs": "^3.12.0",
         "puppeteer": "^22.0.0",
         "stripe": "^20.3.1",

apps/api/src/logger.ts

@@ -1,59 +1,35 @@
 import pino from 'pino';
-import { getOrganizationId } from '@repo/database';
 
-const pinoLogger = pino({
-  level: process.env.LOG_LEVEL || 'info',
-  transport: process.env.NODE_ENV !== 'production' ? {
-    target: 'pino-pretty',
-    options: {
-      colorize: true,
-      translateTime: 'SYS:standard',
-      ignore: 'pid,hostname'
-    }
-  } : undefined
+// Prepare transports
+const transports = [];
+
+// 1. Console transport (Standard)
+transports.push({
+  target: 'pino-pretty',
+  options: {
+    colorize: true,
+    ignore: 'pid,hostname',
+    translateTime: 'SYS:standard',
+  },
+  level: process.env.NODE_ENV === 'production' ? 'info' : 'debug'
 });
 
-function getEnrichedObject(obj: any = {}) {
-    const organizationId = getOrganizationId();
-    if (organizationId) {
-        return { ...obj, organizationId };
-    }
-    return obj;
+// 2. Optional: Logtail transport (if token is provided)
+if (process.env.LOGTAIL_TOKEN) {
+  transports.push({
+    target: '@logtail/pino',
+    options: { sourceToken: process.env.LOGTAIL_TOKEN },
+    level: 'info'
+  });
 }
 
-export const logger = {
-    info: (first: any, ...rest: any[]) => {
-        const orgId = getOrganizationId();
-        if (typeof first === 'string') {
-            pinoLogger.info(orgId ? { organizationId: orgId } : {}, first, ...rest);
-        } else {
-            pinoLogger.info(getEnrichedObject(first), rest[0] || '', ...rest.slice(1));
-        }
-    },
-    error: (first: any, ...rest: any[]) => {
-        const orgId = getOrganizationId();
-        if (first instanceof Error) {
-            pinoLogger.error(getEnrichedObject({ err: first }), rest[0] || first.message, ...rest.slice(1));
-        } else if (typeof first === 'string') {
-            pinoLogger.error(orgId ? { organizationId: orgId } : {}, first, ...rest);
-        } else {
-            pinoLogger.error(getEnrichedObject(first), rest[0] || '', ...rest.slice(1));
-        }
-    },
-    warn: (first: any, ...rest: any[]) => {
-        const orgId = getOrganizationId();
-        if (typeof first === 'string') {
-            pinoLogger.warn(orgId ? { organizationId: orgId } : {}, first, ...rest);
-        } else {
-            pinoLogger.warn(getEnrichedObject(first), rest[0] || '', ...rest.slice(1));
-        }
-    },
-    debug: (first: any, ...rest: any[]) => {
-        const orgId = getOrganizationId();
-        if (typeof first === 'string') {
-            pinoLogger.debug(orgId ? { organizationId: orgId } : {}, first, ...rest);
-        } else {
-            pinoLogger.debug(getEnrichedObject(first), rest[0] || '', ...rest.slice(1));
-        }
-    },
-};
+export const logger = pino({
+  level: process.env.LOG_LEVEL || (process.env.NODE_ENV === 'production' ? 'info' : 'debug'),
+  base: {
+    env: process.env.NODE_ENV,
+    service: 'api-gateway'
+  }
+}, pino.multistream(transports));
+
+// Compatibility with legacy logger usage if any
+export const log = logger;

apps/api/src/services/cleanup.ts

@@ -3,22 +3,26 @@ import fs from 'fs/promises';
 import path from 'path';
 import cron from 'node-cron';
 
+const TEMP_DIR = '/tmp';
+const GLOBAL_MAX_AGE = 30 * 60 * 1000; // 30 minutes
+const PER_TENANT_QUOTA_MB = 100; // 100MB per tenant limit
+
 /**
  * Cleanup Service
  * 
- * Scans /tmp for old media files and deletes them to prevent disk saturation.
+ * Manages /tmp storage by enforcing age limits and per-tenant quotas.
  */
-export async function cleanTempFiles(maxAgeMs: number = 30 * 60 * 1000) {
-    const tempDir = '/tmp';
+export async function cleanTempFiles() {
     const now = Date.now();
 
     try {
         const folders = ['', 'audio', 'images', 'documents'];
+        const tenantUsage: Record<string, number> = {};
+        const tenantFiles: Record<string, { path: string, size: number, mtime: number }[]> = {};
         
         for (const folder of folders) {
-            const dirPath = path.join(tempDir, folder);
+            const dirPath = path.join(TEMP_DIR, folder);
             
-            // Check if directory exists
             try {
                 await fs.access(dirPath);
             } catch {
@@ -29,31 +33,59 @@ export async function cleanTempFiles(maxAgeMs: number = 30 * 60 * 1000) {
             
             for (const file of files) {
                 const filePath = path.join(dirPath, file);
-                
-                // Skip directories
                 const stats = await fs.stat(filePath);
+                
                 if (stats.isDirectory()) continue;
 
-                // Check age
+                // 1. Check Age (Global cleanup)
                 const age = now - stats.mtimeMs;
-                if (age > maxAgeMs) {
+                if (age > GLOBAL_MAX_AGE) {
                     await fs.unlink(filePath);
-                    logger.info(`[CLEANUP] Deleted old temp file: ${filePath} (${Math.round(age / 60000)} min old)`);
+                    logger.info(`[CLEANUP] Deleted old file (Age): ${filePath}`);
+                    continue;
+                }
+
+                // 2. Track usage by tenant (Assumes files are named orgId_filename)
+                const orgId = file.split('_')[0];
+                if (orgId && orgId.length > 10) { // Basic orgId check
+                    tenantUsage[orgId] = (tenantUsage[orgId] || 0) + stats.size;
+                    if (!tenantFiles[orgId]) tenantFiles[orgId] = [];
+                    tenantFiles[orgId].push({ path: filePath, size: stats.size, mtime: stats.mtimeMs });
+                }
+            }
+        }
+
+        // 3. Enforce Quotas
+        for (const orgId in tenantUsage) {
+            const usageMB = tenantUsage[orgId] / (1024 * 1024);
+            if (usageMB > PER_TENANT_QUOTA_MB) {
+                logger.warn(`[CLEANUP] Quota exceeded for Org ${orgId}: ${usageMB.toFixed(2)}MB. Cleaning oldest files...`);
+                
+                // Sort by mtime (oldest first)
+                const files = tenantFiles[orgId].sort((a, b) => a.mtime - b.mtime);
+                let freed = 0;
+                const targetToFree = (usageMB - (PER_TENANT_QUOTA_MB * 0.8)) * 1024 * 1024; // Free up to 80% of quota
+
+                for (const file of files) {
+                    await fs.unlink(file.path);
+                    freed += file.size;
+                    if (freed >= targetToFree) break;
                 }
+                logger.info(`[CLEANUP] Freed ${(freed / (1024 * 1024)).toFixed(2)}MB for Org ${orgId}`);
             }
         }
+
     } catch (err: unknown) {
-        logger.error(`[CLEANUP] Error during temp file cleanup:`, (err instanceof Error ? err.message : String(err)));
+        logger.error(`[CLEANUP] Error during cleanup:`, (err instanceof Error ? err.message : String(err)));
     }
 }
 
 /**
- * Starts a cron job that runs every hour to clean up /tmp.
+ * Starts a cron job that runs every 30 minutes.
  */
 export function startCleanupCron() {
-    // Run every hour at minute 0
-    cron.schedule('0 * * * *', () => {
-        logger.info('[CLEANUP] 🧹 Starting scheduled temp file cleanup...');
+    cron.schedule('*/30 * * * *', () => {
+        logger.info('[CLEANUP] 🧹 Starting scheduled maintenance...');
         cleanTempFiles();
     });
     

pnpm-lock.yaml

@@ -118,6 +118,12 @@ importers:
       '@google/generative-ai':
         specifier: ^0.24.1
         version: 0.24.1
+      '@logtail/node':
+        specifier: ^0.5.8
+        version: 0.5.8
+      '@logtail/pino':
+        specifier: ^0.5.8
+        version: 0.5.8(pino@10.3.1)
       '@prisma/client':
         specifier: ^5.0.0
         version: 5.22.0(prisma@5.22.0)
@@ -166,6 +172,9 @@ importers:
       openai:
         specifier: ^4.0.0
         version: 4.104.0(ws@8.19.0)(zod@3.25.76)
+      pino-pretty:
+        specifier: ^13.1.3
+        version: 13.1.3
       pptxgenjs:
         specifier: ^3.12.0
         version: 3.12.0
@@ -1300,10 +1309,31 @@ packages:
   '@jridgewell/trace-mapping@0.3.31':
     resolution: {integrity: sha512-zzNR+SdQSDJzc8joaeP8QQoCQr8NuYx2dIIytl1QeBEZHJ9uW6hebsrYgbz8hJwUQao3TWCMtmfV8Nu1twOLAw==}
 
+  '@logtail/core@0.5.8':
+    resolution: {integrity: sha512-1LxjI46LCXeVRyENwjO4s0a1CWSIqHjYH6w2YVNhQLc5b7mVN0jhzxvmg9mps54aEuCSuK2SVCNmgvuNTDtAug==}
+
+  '@logtail/node@0.5.8':
+    resolution: {integrity: sha512-9XMxeToOL1QHVNp7IQlPxbRsu3iYUBtXl/SFCyOQQmtnwzS7z+tbiV39DYkXfwkzig6wjwTfLYDQj673Bqplqg==}
+
+  '@logtail/pino@0.5.8':
+    resolution: {integrity: sha512-MRRAAn0APedr0v3uP91YnLJT1dJts/PGSRaBkFTyeG3gS28TkWbQc7ZruD17pDKEgOhRNJkj7c2v9uh8AhKFug==}
+    peerDependencies:
+      pino: ^7.0.0 || ^8.0.0 || ^9.0.0 || ^10.0.0
+
+  '@logtail/tools@0.5.8':
+    resolution: {integrity: sha512-eAbbHaYSpRoB7Udp301xVUVDeKdgXTP2/s9FOeKX5tPLMM3hgbvuIx50bYJoV/to7bHGYBi36Gdsnj8ElcPXbg==}
+
+  '@logtail/types@0.5.8':
+    resolution: {integrity: sha512-CJIijD/2vqK8XwPRZJeUkiiBEhKTviHs5p1WI40WvW21kU18QiQ8PupFJ2uhrItxhwtlkXmRXul5+cNtv3cAFQ==}
+
   '@lukeed/ms@2.0.2':
     resolution: {integrity: sha512-9I2Zn6+NJLfaGoz9jN3lpwDgAYvfGeNYdbAIjJOqzs4Tpc+VU3Jqq4IofSUBKajiDS8k9fZIg18/z13mpk1bsA==}
     engines: {node: '>=8'}
 
+  '@msgpack/msgpack@2.8.0':
+    resolution: {integrity: sha512-h9u4u/jiIRKbq25PM+zymTyW6bhTzELvOoUd+AvYriWOAKpLGnIamaET3pnHYoI5iYphAHBI4ayx0MehR+VVPQ==}
+    engines: {node: '>= 10'}
+
   '@msgpackr-extract/msgpackr-extract-darwin-arm64@3.0.3':
     resolution: {integrity: sha512-QZHtlVgbAdy2zAqNA9Gu1UpIuI8Xvsd1v8ic6B2pZmeFnFcMWiPLfWXh7TVw4eGEZ/C9TH281KwhVoeQUKbyjw==}
     cpu: [arm64]
@@ -1929,6 +1959,9 @@ packages:
   '@types/react@18.3.28':
     resolution: {integrity: sha512-z9VXpC7MWrhfWipitjNdgCauoMLRdIILQsAEV+ZesIzBq/oUlxk0m3ApZuMFCXdnS4U7KrI+l3WRUEGQ8K1QKw==}
 
+  '@types/stack-trace@0.0.33':
+    resolution: {integrity: sha512-O7in6531Bbvlb2KEsJ0dq0CHZvc3iWSR5ZYMtvGgnHA56VgriAN/AU2LorfmcvAl2xc9N5fbCTRyMRRl8nd74g==}
+
   '@types/use-sync-external-store@0.0.6':
     resolution: {integrity: sha512-zFDAD+tlpf2r4asuHEj0XH6pY6i0g5NeAHPn+15wk3BV6JA69eERFXC1gyGThDkVa1zCyKr5jox1+2LbV/AMLg==}
 
@@ -2227,6 +2260,9 @@ packages:
   buffer@5.7.1:
     resolution: {integrity: sha512-EHcyIPBQ4BSGlvjB16k5KgAJ27CIsHY/2JBmCRReo48y9rQ3MaUzWX3KVlBa4U7MyX02HdVj0K7C3WaB3ju7FQ==}
 
+  buffer@6.0.3:
+    resolution: {integrity: sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==}
+
   bullmq@4.18.3:
     resolution: {integrity: sha512-H8t9vhfHEbJDaXp7aalSTe+Do+tR1nvr+lsT+jQxLhy+FFfFj/0p4aYJzADTNLdEqltuxneLVxCGVg92GkQx4w==}
 
@@ -2671,6 +2707,10 @@ packages:
   events-universal@1.0.1:
     resolution: {integrity: sha512-LUd5euvbMLpwOF8m6ivPCbhQeSiYVNb8Vs0fQ8QjXo0JTkEHpz8pxdQf0gStltaPpw0Cca8b39KxvK9cfKRiAw==}
 
+  events@3.3.0:
+    resolution: {integrity: sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q==}
+    engines: {node: '>=0.8.x'}
+
   execa@8.0.1:
     resolution: {integrity: sha512-VyhnebXciFV2DESc+p6B+y0LjSm0krU4OgJN44qFAhBY0TJ+1V61tYD2+wHusZ6F9n5K+vl8k0sTy7PEfV4qpg==}
     engines: {node: '>=16.17'}
@@ -3231,6 +3271,10 @@ packages:
     resolution: {integrity: sha512-lKwV/1brpG6mBUFHtb7NUmtABCb2WZZmm2wNiOA5hAb8VdCS4B3dtMWyvcoViccwAW/COERjXLt0zP1zXUN26g==}
     engines: {node: '>=10'}
 
+  minimatch@9.0.9:
+    resolution: {integrity: sha512-OBwBN9AL4dqmETlpS2zasx+vTeWclWzkblfZk7KTA5j3jeOONz/tRCnZomUyvNg83wL5Zv9Ss6HMJXAgL8R2Yg==}
+    engines: {node: '>=16 || 14 >=14.17'}
+
   minimist@1.2.8:
     resolution: {integrity: sha512-2yyAR8qBkN3YuheJanUpWC5U3bb5osDywNB8RzDVlDwDHbocAJveqqj1u8+SVD7jkWT4yvsHCpWqqWqAxb0zCA==}
 
@@ -3488,6 +3532,9 @@ packages:
     resolution: {integrity: sha512-udgsAY+fTnvv7kI7aaxbqwWNb0AHiB0qBO89PZKPkoTmGOgdbrHDKD+0B2X4uTfJ/FT1R09r9gTsjUjNJotuog==}
     engines: {node: '>=0.10.0'}
 
+  pino-abstract-transport@1.2.0:
+    resolution: {integrity: sha512-Guhh8EZfPCfH+PMXAb6rKOjGQEoy0xlAIn+irODG5kgfYV+BQ0rGYYWTIel3P5mmyXqkYkPmdIkywsn6QKUR1Q==}
+
   pino-abstract-transport@2.0.0:
     resolution: {integrity: sha512-F63x5tizV6WCh4R6RHyi2Ml+M70DNRXt/+HANowMflpgGFMAym/VKm6G7ZOQRjqN7XbGxK1Lg9t6ZrtzOaivMw==}
 
@@ -3727,6 +3774,10 @@ packages:
   readable-stream@2.3.8:
     resolution: {integrity: sha512-8p0AUk4XODgIewSi0l8Epjs+EVnWiK7NoDIEGU0HhE7+ZyY8D1IMY7odu5lRrFXGg71L15KG8QrPmum45RTtdA==}
 
+  readable-stream@4.7.0:
+    resolution: {integrity: sha512-oIGGmcpTLwPga8Bn6/Z75SVaH1z5dUut2ibSyAMVhmUggWpmDn2dapB0n7f8nwaSiRtepAsfJyfXIO5DCVAODg==}
+    engines: {node: ^12.22.0 || ^14.17.0 || >=16.0.0}
+
   readdirp@3.6.0:
     resolution: {integrity: sha512-hOS089on8RduqdbhvQ5Z37A0ESjsqz6qnRcffsMU3495FuTdqSm+7bhJ29JvIOsBDEEnan5DPu9t3To9VRlMzA==}
     engines: {node: '>=8.10.0'}
@@ -3870,6 +3921,10 @@ packages:
     engines: {node: '>=10'}
     hasBin: true
 
+  serialize-error@8.1.0:
+    resolution: {integrity: sha512-3NnuWfM6vBYoy5gZFvHiYsVbafvI9vZv/+jlIigFn4oP4zjNPK3LhcY0xSCgeb1a5L8jO71Mit9LlNoi2UfDDQ==}
+    engines: {node: '>=10'}
+
   set-cookie-parser@2.7.2:
     resolution: {integrity: sha512-oeM1lpU/UvhTxw+g3cIfxXHyJRc/uidd3yK1P242gzHds0udQBYzs3y8j4gCCW+ZJ7ad0yctld8RYO+bdurlvw==}
 
@@ -3945,6 +4000,9 @@ packages:
     resolution: {integrity: sha512-+idbmIXoYET47hH+d7dfm2epdOMUDjqcB4648sTZ+t2JwoyBFL/insLfB/racrDmsKB3diwsDA696pZMieAC5g==}
     engines: {node: '>=0.8'}
 
+  stack-trace@0.0.10:
+    resolution: {integrity: sha512-KGzahc7puUKkzyMt+IqAep+TVNbKP+k2Lmwhub39m1AsTSkaDutx56aDCo+HLDzf/D26BIHTJWNiTG1KAJiQCg==}
+
   stackback@0.0.2:
     resolution: {integrity: sha512-1XMJE5fQo1jGH6Y/7ebnwPOBEkIEnT4QF32d5R1+VXdXveM0IBMJt8zfaxX1P3QhVwrYe+576+jkANtSS2mBbw==}
 
@@ -3971,6 +4029,9 @@ packages:
   string_decoder@1.1.1:
     resolution: {integrity: sha512-n/ShnvDi6FHbbVfviro+WojiFzv+s8MPMHBczVePfUpDJLwoLT0ht1l4YwBCbi8pJAveEEdnkHyPyTP/mzRfwg==}
 
+  string_decoder@1.3.0:
+    resolution: {integrity: sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==}
+
   strip-ansi@6.0.1:
     resolution: {integrity: sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==}
     engines: {node: '>=8'}
@@ -4154,6 +4215,10 @@ packages:
     resolution: {integrity: sha512-Acylog8/luQ8L7il+geoSxhEkazvkslg7PSNKOX59mbB9cOveP5aq9h74Y7YU8yDpJwetzQQrfIwtf4Wp4LKcw==}
     engines: {node: '>=4'}
 
+  type-fest@0.20.2:
+    resolution: {integrity: sha512-Ne+eE4r0/iWnpAxD852z3A+N0Bt5RN//NjJwRd2VFHEmrywxf5vsZlh4R6lixl6B+wz/8d+maTSAkN1FIkI3LQ==}
+    engines: {node: '>=10'}
+
   typescript@5.9.3:
     resolution: {integrity: sha512-jl1vZzPDinLr9eUt3J/t7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSw==}
     engines: {node: '>=14.17'}
@@ -5502,8 +5567,38 @@ snapshots:
       '@jridgewell/resolve-uri': 3.1.2
       '@jridgewell/sourcemap-codec': 1.5.5
 
+  '@logtail/core@0.5.8':
+    dependencies:
+      '@logtail/tools': 0.5.8
+      '@logtail/types': 0.5.8
+      serialize-error: 8.1.0
+
+  '@logtail/node@0.5.8':
+    dependencies:
+      '@logtail/core': 0.5.8
+      '@logtail/types': 0.5.8
+      '@msgpack/msgpack': 2.8.0
+      '@types/stack-trace': 0.0.33
+      minimatch: 9.0.9
+      stack-trace: 0.0.10
+
+  '@logtail/pino@0.5.8(pino@10.3.1)':
+    dependencies:
+      '@logtail/node': 0.5.8
+      '@logtail/types': 0.5.8
+      pino: 10.3.1
+      pino-abstract-transport: 1.2.0
+
+  '@logtail/tools@0.5.8':
+    dependencies:
+      '@logtail/types': 0.5.8
+
+  '@logtail/types@0.5.8': {}
+
   '@lukeed/ms@2.0.2': {}
 
+  '@msgpack/msgpack@2.8.0': {}
+
   '@msgpackr-extract/msgpackr-extract-darwin-arm64@3.0.3':
     optional: true
 
@@ -6217,6 +6312,8 @@ snapshots:
       '@types/prop-types': 15.7.15
       csstype: 3.2.3
 
+  '@types/stack-trace@0.0.33': {}
+
   '@types/use-sync-external-store@0.0.6': {}
 
   '@types/yauzl@2.10.3':
@@ -6520,6 +6617,11 @@ snapshots:
       base64-js: 1.5.1
       ieee754: 1.2.1
 
+  buffer@6.0.3:
+    dependencies:
+      base64-js: 1.5.1
+      ieee754: 1.2.1
+
   bullmq@4.18.3:
     dependencies:
       cron-parser: 4.9.0
@@ -6998,6 +7100,8 @@ snapshots:
     transitivePeerDependencies:
       - bare-abort-controller
 
+  events@3.3.0: {}
+
   execa@8.0.1:
     dependencies:
       cross-spawn: 7.0.6
@@ -7569,6 +7673,10 @@ snapshots:
     dependencies:
       brace-expansion: 2.0.2
 
+  minimatch@9.0.9:
+    dependencies:
+      brace-expansion: 2.0.2
+
   minimist@1.2.8: {}
 
   minipass@7.1.3: {}
@@ -7815,6 +7923,11 @@ snapshots:
 
   pify@2.3.0: {}
 
+  pino-abstract-transport@1.2.0:
+    dependencies:
+      readable-stream: 4.7.0
+      split2: 4.2.0
+
   pino-abstract-transport@2.0.0:
     dependencies:
       split2: 4.2.0
@@ -8162,6 +8275,14 @@ snapshots:
       string_decoder: 1.1.1
       util-deprecate: 1.0.2
 
+  readable-stream@4.7.0:
+    dependencies:
+      abort-controller: 3.0.0
+      buffer: 6.0.3
+      events: 3.3.0
+      process: 0.11.10
+      string_decoder: 1.3.0
+
   readdirp@3.6.0:
     dependencies:
       picomatch: 2.3.1
@@ -8313,6 +8434,10 @@ snapshots:
 
   semver@7.7.4: {}
 
+  serialize-error@8.1.0:
+    dependencies:
+      type-fest: 0.20.2
+
   set-cookie-parser@2.7.2: {}
 
   setimmediate@1.0.5: {}
@@ -8406,6 +8531,8 @@ snapshots:
     dependencies:
       frac: 1.1.2
 
+  stack-trace@0.0.10: {}
+
   stackback@0.0.2: {}
 
   standard-as-callback@2.1.0: {}
@@ -8441,6 +8568,10 @@ snapshots:
     dependencies:
       safe-buffer: 5.1.2
 
+  string_decoder@1.3.0:
+    dependencies:
+      safe-buffer: 5.2.1
+
   strip-ansi@6.0.1:
     dependencies:
       ansi-regex: 5.0.1
@@ -8638,6 +8769,8 @@ snapshots:
 
   type-detect@4.1.0: {}
 
+  type-fest@0.20.2: {}
+
   typescript@5.9.3: {}
 
   ufo@1.6.3: {}