3

backend/src/index.js

@@ -79,6 +79,8 @@ require('./auth/auth');
 
 app.use(bodyParser.json());
 
+app.use('/uploads', express.static(path.join(__dirname, '../uploads')));
+
 app.use('/api/auth', authRoutes);
 app.enable('trust proxy');
 

backend/src/middlewares/upload.js

@@ -1,11 +1,34 @@
 const util = require('util');
 const Multer = require('multer');
+const path = require('path');
+const fs = require('fs');
+
 const maxSize = 10 * 1024 * 1024;
 
-let processFile = Multer({
+// Ensure uploads directory exists
-  storage: Multer.memoryStorage(),
+const uploadDir = path.join(__dirname, '../../uploads');
-  limits: { fileSize: maxSize },
+if (!fs.existsSync(uploadDir)) {
-}).single("file");
+  fs.mkdirSync(uploadDir, { recursive: true });
+}
 
+// Configure disk storage
+const storage = Multer.diskStorage({
+  destination: (req, file, cb) => cb(null, uploadDir),
+  filename: (req, file, cb) => {
+    const ext = path.extname(file.originalname);
+    const base = path.basename(file.originalname, ext);
+    const uniqueSuffix = Date.now() + '-' + Math.round(Math.random() * 1e9);
+    cb(null, `${base}-${uniqueSuffix}${ext}`);
+  },
+});
+
+// Create multer instance
+let processFile = Multer({
+  storage,
+  limits: { fileSize: maxSize },
+}).single('file');
+
+// Promisify for async/await
 let processFileMiddleware = util.promisify(processFile);
+
 module.exports = processFileMiddleware;

backend/src/routes/documents.js

@@ -3,6 +3,7 @@ const express = require('express');
 
 const DocumentsService = require('../services/documents');
 const DocumentsDBApi = require('../db/api/documents');
+const processFile = require('../middlewares/upload');
 const wrapAsync = require('../helpers').wrapAsync;
 
 const router = express.Router();
@@ -66,14 +67,28 @@ const { parse } = require('json2csv');
 *          description: Invalid input data
 *        500:
 *          description: Some server error
-*/
+router.post('/', processFile, wrapAsync(async (req, res) => {
-router.post('/', wrapAsync(async (req, res) => {
     const referer = req.headers.referer || `${req.protocol}://${req.hostname}${req.originalUrl}`;
     const link = new URL(referer);
-    await DocumentsService.create(req.body.data, req.currentUser, true, link.host);
+    // Parse data from multipart/form-data or JSON
+    let data = {};
+    if (req.body.data) {
+      data = req.body.data;
+    } else {
+      data = {
+        title: req.body.title,
+        document_type: req.body.document_type,
+      };
+    }
+    // Attach file URL if file was uploaded
+    if (req.file) {
+      data.fileurl = `/uploads/${req.file.filename}`;
+    }
+    await DocumentsService.create(data, req.currentUser, true, link.host);
     const payload = true;
     res.status(200).send(payload);
 }));
+}));
 
 /**
  * @swagger
@@ -151,11 +166,24 @@ router.post('/bulk-import', wrapAsync(async (req, res) => {
   *              required:
   *                - id
   *      responses:
-  *        200:
+router.put('/:id', processFile, wrapAsync(async (req, res) => {
-  *          description: The item data was successfully updated
+    // Parse data from multipart/form-data or JSON
-  *          content:
+    let data = {};
-  *            application/json:
+    if (req.body.data) {
-  *              schema:
+      data = req.body.data;
+    } else {
+      data = {
+        title: req.body.title,
+        document_type: req.body.document_type,
+      };
+    }
+    // Attach file URL if file was uploaded
+    if (req.file) {
+      data.fileurl = `/uploads/${req.file.filename}`;
+    }
+    await DocumentsService.update(data, req.params.id, req.currentUser);
+    res.status(200).send(true);
+}));
   *                $ref: "#/components/schemas/Documents"
   *        400:
   *          description: Invalid ID supplied