refactor server breaking it down to sub packages

Author: nextinterfaces

.gitignore

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

apps/pdf-analyzer-service/package.json

@@ -4,9 +4,9 @@
   "private": true,
   "type": "module",
   "scripts": {
-    "dev": "tsx watch src/index.ts",
+    "dev": "tsx watch src/server.ts",
     "build": "tsc -p tsconfig.json",
-    "start": "node dist/index.js"
+    "start": "node dist/server.js"
   },
   "dependencies": {
     "express": "^4.19.2",

apps/pdf-analyzer-service/src/app.ts

@@ -0,0 +1,21 @@
+import express from 'express';
+import swaggerUi from 'swagger-ui-express';
+import { registerRoutes } from './routes/index.js';
+import { errorHandler } from './middleware/error.middleware.js';
+import { notFound } from './middleware/notFound.middleware.js';
+import { loadOpenApi } from './utils/swagger.js';
+
+const app = express();
+
+app.use(express.json());
+
+const openapiDoc = loadOpenApi();
+app.use('/docs', swaggerUi.serve, swaggerUi.setup(openapiDoc));
+app.get('/', (_req, res) => res.redirect('/docs'));
+
+registerRoutes(app);
+
+app.use(notFound);
+app.use(errorHandler);
+
+export default app;

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

@@ -0,0 +1,14 @@
+import path from 'path';
+import os from 'os';
+
+export const config = {
+  port: process.env.PORT ? Number(process.env.PORT) : 8080,
+  commitSha: process.env.COMMIT_SHA || 'local-dev',
+  storageRoot: process.env.STORAGE_DIR || path.join(process.cwd(), 'data'),
+};
+
+export const paths = {
+  uploadsDir: path.join(config.storageRoot, 'uploads'),
+  tmpUploadDir: path.join(os.tmpdir(), 'pdf-analyzer-uploads'),
+  openapiPath: path.join(process.cwd(), 'api', 'openapi.yaml'),
+};

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

@@ -0,0 +1,6 @@
+import { Request, Response } from 'express';
+import { config } from '../config/index.js';
+
+export const health = (_req: Request, res: Response) => {
+  res.json({ status: 'ok', commit: config.commitSha });
+};

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

@@ -0,0 +1,34 @@
+import { Request, Response } from 'express';
+import { jobService } from '../services/job.service.js';
+
+export const upload = (req: Request, res: Response) => {
+  if (!req.file) {
+    res.status(400).json({ error: 'file is required' });
+    return;
+  }
+  const id = jobService.createJobFromUpload(req.file.path, req.file.originalname);
+  res.status(201).json({ jobId: id });
+};
+
+export const listJobs = (_req: Request, res: Response) => {
+  res.json({ jobs: jobService.listJobs() });
+};
+
+export const getJob = (req: Request, res: Response) => {
+  const job = jobService.getJob(req.params.id);
+  if (!job) {
+    res.status(404).json({ error: 'not found' });
+    return;
+  }
+  res.json(job);
+};
+
+export const completeJob = (req: Request, res: Response) => {
+  const status = req.body?.status === 'failed' ? 'failed' : 'completed';
+  const ok = jobService.completeJob(req.params.id, status, req.body?.result, req.body?.error);
+  if (!ok) {
+    res.status(404).json({ error: 'not found' });
+    return;
+  }
+  res.json({ ok: true });
+};

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

@@ -0,0 +1,6 @@
+import { Request, Response, NextFunction } from 'express';
+
+export function errorHandler(err: any, _req: Request, res: Response, _next: NextFunction) {
+  console.error('Unhandled error:', err);
+  res.status(500).json({ error: 'internal server error' });
+}

apps/pdf-analyzer-service/src/middleware/error.middleware.ts

@@ -0,0 +1,5 @@
+import { Request, Response, NextFunction } from 'express';
+
+export function notFound(_req: Request, res: Response, _next: NextFunction) {
+  res.status(404).json({ error: 'not found' });
+}

apps/pdf-analyzer-service/src/middleware/notFound.middleware.ts

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