feat: added /documents endpoint and multiple docs upload

Author: WillACosta

src/app.ts

@@ -8,6 +8,7 @@ import { appConfig } from './config'
 
 import AuthRoutes from '@/modules/auth/application/routes'
 import GenAIRoutes from '@/modules/genai/application/routes'
+import ResourcesRoutes from '@/modules/resources/application/routes'
 import StatusRoutes from '@/modules/status/application/routes'
 import UserRoutes from '@/modules/users/application/routes'
 
@@ -29,6 +30,7 @@ app.use('/', AuthRoutes)
 app.use('/status', StatusRoutes)
 app.use('/users', UserRoutes)
 app.use('/gen-ai', GenAIRoutes)
+app.use('/resources', ResourcesRoutes)
 
 app.listen(port, () => {
 	console.log(`Server listening to http://localhost:${port}`)

src/di/index.ts

@@ -9,6 +9,7 @@ import {
 
 import { AuthController } from '@/modules/auth/application/controllers/auth.controller'
 import { GenAIController } from '@/modules/genai/application/controllers/gen-ai.controller'
+import { ResourcesController } from '@/modules/resources/application/controllers/resources.controller'
 import { UserDataProvider } from '@/modules/users/adapters/dataproviders/user.dataprovider'
 import { UsersController } from '@/modules/users/application/controllers/users.controller'
 
@@ -33,14 +34,18 @@ const usersController = new UsersController(userDatProvider)
 // Auth Module
 const authController = new AuthController(userDatProvider)
 
+// Resources Module
+const resourcesController = new ResourcesController()
+
 export {
-  authController,
-  documentService,
-  genAIController,
-  llmService,
-  prismaClient,
-  searchInDocumentUseCase,
-  translateUseCase,
-  userDatProvider,
-  usersController
+	authController,
+	documentService,
+	genAIController,
+	llmService,
+	prismaClient,
+	resourcesController,
+	searchInDocumentUseCase,
+	translateUseCase,
+	userDatProvider,
+	usersController,
 }

src/modules/core/index.ts

@@ -0,0 +1 @@
+export * from './utils'

src/modules/core/utils/index.ts

@@ -0,0 +1 @@
+export * from './upload.config'

src/modules/core/utils/upload.config.ts

@@ -0,0 +1,60 @@
+import { Request, Response } from 'express'
+
+import crypto from 'crypto'
+import multer from 'multer'
+import path from 'path'
+
+const storageConfig = multer.diskStorage({
+	destination: (_, __, callBack) => {
+		callBack(null, 'uploads/')
+	},
+	filename: (_, file, callBack) => {
+		const fileExt = path.extname(file.originalname)
+		const fileName = `user-document-${crypto.randomUUID()}${fileExt}`
+		callBack(null, fileName)
+	},
+})
+
+const fileFilter = (
+	_: Request,
+	file: Express.Multer.File,
+	cb: multer.FileFilterCallback,
+) => {
+	const allowedTypes = ['image/jpeg', 'image/png', 'application/pdf']
+	if (allowedTypes.includes(file.mimetype)) {
+		cb(null, true)
+	} else {
+		cb(new Error('Invalid file type. Only JPEG, PNG, and PDF are allowed.'))
+	}
+}
+
+export const uploadSingle = multer({
+	storage: storageConfig,
+	fileFilter,
+	limits: { fileSize: 5 * 1024 * 1024 },
+}).single('document')
+
+export const uploadMultipleDocs = multer({
+	storage: storageConfig,
+	fileFilter,
+	limits: { fileSize: 5 * 1024 * 1024 },
+}).array('documents', 10)
+
+export function handleMulterErrorMessages(err: any, res: Response): Response {
+	if (err instanceof multer.MulterError) {
+		switch (err.code) {
+			case 'LIMIT_FILE_SIZE':
+				return res.status(400).json({ error: 'File size exceeds the limit!' })
+			case 'LIMIT_FILE_COUNT':
+				return res.status(400).json({ error: 'Too many files uploaded!' })
+			case 'LIMIT_UNEXPECTED_FILE':
+				return res.status(400).json({ error: 'Unexpected file uploaded!' })
+			default:
+				return res
+					.status(400)
+					.json({ error: 'Unexpected error was occurred while uploading!' })
+		}
+	}
+
+	return res.status(500).json({ error: 'An unknown error occurred!' })
+}

src/modules/genai/application/controllers/gen-ai.controller.ts

@@ -1,6 +1,6 @@
 import { AppRequest, AppResponse } from '@/common/types';
 import { searchInDocumentUseCase, translateUseCase } from '@/di';
-import { upload } from '../../core';
+import { uploadSingle } from '@/modules/core'
 
 export class GenAIController {
 	async translateText(
@@ -16,7 +16,7 @@ export class GenAIController {
 		req: AppRequest<any, any, { query: string }>,
 		res: AppResponse,
 	) {
-		upload(req, res, async (err) => {
+		uploadSingle(req, res, async (err) => {
 			if (err) {
 				return res
 					.status(500)

src/modules/genai/core/utils/index.ts

@@ -1,2 +1 @@
 export * from './constants'
-export * from './upload.config'

src/modules/genai/core/utils/upload.config.ts

@@ -0,0 +1,37 @@
+import { AppRequest, AppResponse } from '@/common/types'
+import { handleMulterErrorMessages, uploadMultipleDocs } from '@/modules/core'
+
+export class ResourcesController {
+	async uploadDocs(
+		req: AppRequest<any, any, { query: string }>,
+		res: AppResponse,
+	) {
+		uploadMultipleDocs(req, res, async (err) => {
+			if (err) handleMulterErrorMessages(err, res)
+
+			if (!req.files || (req.files as Express.Multer.File[]).length === 0) {
+				return res.status(400).json({
+					success: false,
+					error: { message: 'Please provide at least one document!' },
+				})
+			}
+
+			const files = req.files as Express.Multer.File[]
+			const fileDetails = files.map((file) => ({
+				originalName: file.originalname,
+				fileName: file.filename,
+				path: file.path,
+				size: file.size,
+			}))
+
+			// TODO: Implement logic to process and store the uploaded files
+
+			return res.status(201).json({
+				success: true,
+				data: {
+					documents: fileDetails,
+				},
+			})
+		})
+	}
+}

src/modules/resources/application/controllers/resources.controller.ts

@@ -0,0 +1,10 @@
+import express from 'express'
+
+import { isAuthenticated } from '@/common/middlewares'
+import { resourcesController } from '@/di'
+
+const router = express.Router()
+
+router.post('/docs', isAuthenticated, resourcesController.uploadDocs)
+
+export default router