Upload folder using huggingface_hub

apps/api/src/proxy.ts

@@ -1,7 +1,9 @@
 import 'dotenv/config'
 import express from 'express'
+import type { Request, Response, NextFunction } from 'express'
 import path from 'path'
 import { authMiddleware } from './middleware/authMiddleware'
+import { logger } from './logger.js'
 import { authRouter } from './services/auth/auth.routes'
 import { chatRouter } from './services/chat/chat.routes'
 import { expenseRouter } from './services/expense/router'
@@ -43,6 +45,17 @@ app.use('/v1', chatRouter)
 app.use('/v1/expense', expenseRouter)
 app.use('/v1/slip-queue', slipQueueRouter)
 
+app.use((err: unknown, req: Request, res: Response, _next: NextFunction) => {
+  logger.error('unhandled_route_error', {
+    method: req.method,
+    path: req.path,
+    error: err instanceof Error ? err.message : String(err),
+    stack: err instanceof Error ? err.stack : undefined,
+  })
+  if (res.headersSent) return
+  res.status(500).json({ error: 'Internal server error' })
+})
+
 const PORT = parseInt(process.env['PORT'] ?? '7860', 10)
 const FOUR_MINUTES = 4 * 60 * 1000
 

apps/api/src/services/expense/slip-queue/slip-queue.service.ts

@@ -1,4 +1,5 @@
 import type { ISlipQueueRepository, IReceiptParser, IImageStore, SlipQueueItem } from '../ports/index.js'
+import { logger } from '../../../logger.js'
 
 export class SlipQueueService {
   constructor(
@@ -26,8 +27,8 @@ export class SlipQueueService {
     let failed = 0
 
     for (const slip of pending) {
-      await this.slipRepo.update(slip.id, { status: 'processing' })
       try {
+        await this.slipRepo.update(slip.id, { status: 'processing' })
         const imageBase64 = await this.imageStore.get(slip.image_base64)
         const parsed = await this.parser.parse({ imageBase64 })
         if (!parsed || !parsed.amount) {
@@ -41,21 +42,29 @@ export class SlipQueueService {
         succeeded++
       } catch (err: unknown) {
         const msg = err instanceof Error ? err.message : String(err)
+        logger.warn('slip_queue_item_failed', { slipId: slip.id, error: msg })
         const newRetryCount = slip.retry_count + 1
-        if (newRetryCount < 3) {
-          await this.slipRepo.update(slip.id, {
-            status: 'pending',
-            retry_count: newRetryCount,
-            error_message: msg,
+        try {
+          if (newRetryCount < 3) {
+            await this.slipRepo.update(slip.id, {
+              status: 'pending',
+              retry_count: newRetryCount,
+              error_message: msg,
+            })
+          } else {
+            await this.slipRepo.update(slip.id, {
+              status: 'failed',
+              retry_count: newRetryCount,
+              error_message: msg,
+              processed_at: new Date().toISOString(),
+            })
+            failed++
+          }
+        } catch (updateErr: unknown) {
+          logger.error('slip_queue_item_update_failed', {
+            slipId: slip.id,
+            error: updateErr instanceof Error ? updateErr.message : String(updateErr),
           })
-        } else {
-          await this.slipRepo.update(slip.id, {
-            status: 'failed',
-            retry_count: newRetryCount,
-            error_message: msg,
-            processed_at: new Date().toISOString(),
-          })
-          failed++
         }
       }
     }