delete files endpoints

Author: nextinterfaces

.gitignore

@@ -44,5 +44,4 @@ setup.sh
 .ignore
 
 node_modules
-apps/pdf-analyzer-service/data
 sample-pay-statement.pdf

apps/pdf-analyzer-service/api/openapi.yaml

@@ -180,3 +180,43 @@ paths:
                 properties:
                   error:
                     type: string
+  /v1/files:
+    get:
+      summary: List uploaded files
+      operationId: listFiles
+      tags: [files]
+      responses:
+        '200':
+          description: List of files in storage
+          content:
+            application/json:
+              schema:
+                type: object
+                properties:
+                  files:
+                    type: array
+                    items:
+                      type: object
+                      properties:
+                        name:
+                          type: string
+                        size:
+                          type: integer
+                          format: int64
+                        mtime:
+                          type: string
+                          format: date-time
+    delete:
+      summary: Delete all uploaded files
+      operationId: deleteAllFiles
+      tags: [files]
+      responses:
+        '200':
+          description: Deletion summary
+          content:
+            application/json:
+              schema:
+                type: object
+                properties:
+                  deleted:
+                    type: integer

apps/pdf-analyzer-service/src/controllers/files.controller.ts

@@ -0,0 +1,37 @@
+import fs from 'fs';
+import path from 'path';
+import { Request, Response } from 'express';
+import { paths } from '../config/index.js';
+
+export const listFiles = (_req: Request, res: Response) => {
+  if (!fs.existsSync(paths.uploadsDir)) {
+    res.json({ files: [] });
+    return;
+  }
+  const names = fs.readdirSync(paths.uploadsDir);
+  const files = names.map((name) => {
+    const full = path.join(paths.uploadsDir, name);
+    const st = fs.statSync(full);
+    return { name, size: st.size, mtime: st.mtime.toISOString() };
+  });
+  res.json({ files });
+};
+
+export const deleteAllFiles = (_req: Request, res: Response) => {
+  if (!fs.existsSync(paths.uploadsDir)) {
+    res.json({ deleted: 0 });
+    return;
+  }
+  const names = fs.readdirSync(paths.uploadsDir);
+  let deleted = 0;
+  for (const name of names) {
+    const full = path.join(paths.uploadsDir, name);
+    try {
+      fs.unlinkSync(full);
+      deleted += 1;
+    } catch (_) {
+      // ignore
+    }
+  }
+  res.json({ deleted });
+};

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

@@ -0,0 +1,9 @@
+import { Router } from 'express';
+import { listFiles, deleteAllFiles } from '../controllers/files.controller.js';
+
+const router = Router();
+
+router.get('/v1/files', listFiles);
+router.delete('/v1/files', deleteAllFiles);
+
+export default router;

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

@@ -1,8 +1,10 @@
 import { Express } from 'express';
 import healthRouter from './health.routes.js';
 import jobsRouter from './jobs.routes.js';
+import filesRouter from './files.routes.js';
 
 export function registerRoutes(app: Express) {
   app.use(healthRouter);
   app.use(jobsRouter);
+  app.use(filesRouter);
 }

infra/k8s/apps/pdf-analyzer-service-deployment.yaml

@@ -27,6 +27,11 @@ spec:
           value: "8080"
         - name: COMMIT_SHA
           value: "unknown"
+        - name: STORAGE_DIR
+          value: "/data"
+        volumeMounts:
+        - name: pdf-storage
+          mountPath: /data
         resources:
           requests:
             memory: "64Mi"
@@ -47,6 +52,10 @@ spec:
             port: 8080
           initialDelaySeconds: 5
           periodSeconds: 5
+      volumes:
+      - name: pdf-storage
+        persistentVolumeClaim:
+          claimName: pdf-analyzer-pvc
 ---
 apiVersion: v1
 kind: Service

infra/k8s/storage/pdf-analyzer-pvc.yaml

@@ -0,0 +1,12 @@
+apiVersion: v1
+kind: PersistentVolumeClaim
+metadata:
+  name: pdf-analyzer-pvc
+  namespace: default
+spec:
+  accessModes:
+    - ReadWriteOnce
+  storageClassName: hetzner-volume
+  resources:
+    requests:
+      storage: 10Gi