storing uploads directly to CSI instead of temp file

Author: nextinterfaces

apps/pdf-analyzer-service/src/routes/jobs.routes.ts

@@ -1,11 +1,22 @@
 import { Router } from 'express';
 import multer from 'multer';
+import path from 'path';
+import { v4 as uuidv4 } from 'uuid';
 import { paths } from '../config/index.js';
 import { upload, listJobs, getJob, completeJob } from '../controllers/jobs.controller.js';
 
 const router = Router();
 
-const uploadMw = multer({ dest: paths.tmpUploadDir });
+const uploadMw = multer({
+  storage: multer.diskStorage({
+    destination: paths.uploadsDir,
+    filename: (_req, file, cb) => {
+      const id = uuidv4().replace(/-/g, '');
+      const ext = path.extname(file.originalname) || '.pdf';
+      cb(null, `${id}${ext}`);
+    },
+  }),
+});
 
 router.post('/v1/uploads', uploadMw.single('file'), upload);
 router.get('/v1/jobs', listJobs);

apps/pdf-analyzer-service/src/services/job.service.ts

@@ -12,16 +12,14 @@ class JobService {
     ensureDir(paths.uploadsDir);
   }
 
-  createJobFromUpload(tempPath: string, originalName: string): string {
-    const id = uuidv4().replace(/-/g, '');
-    const ext = path.extname(originalName) || '.pdf';
-    const finalPath = path.join(paths.uploadsDir, `${id}${ext}`);
-    fs.renameSync(tempPath, finalPath);
+  createJobFromUpload(filePath: string, originalName: string): string {
+    // Extract ID from the filename (multer has already named it with UUID + extension)
+    const id = path.basename(filePath, path.extname(filePath));
     const now = new Date().toISOString();
     const job: Job = {
       id,
       status: 'queued',
-      filePath: finalPath,
+      filePath,
       originalName,
       createdAt: now,
       updatedAt: now,