infraestructure and feature upload

.gitignore

@@ -0,0 +1,2 @@
+#venv
+Api/venv

Api/requirements.txt

@@ -0,0 +1,4 @@
+fastapi 
+uvicorn 
+PyPDF2
+python-multipart

Api/src/db_local_storage/files_db.py

@@ -0,0 +1,2 @@
+FILES_NAMES_DATABASE = {}
+FILES_DIRECTORY = "src/db_local_storage/files"

Api/src/main.py

@@ -0,0 +1,29 @@
+import uvicorn
+from fastapi import APIRouter, FastAPI
+from fastapi.middleware.cors import CORSMiddleware
+from src.modules.uploadDocument.routes.uploadDocument_route import \
+    router as upload_file_routes
+
+app = FastAPI()
+
+origins = [
+    "http://localhost:8000",
+    "http://localhost:3000",
+]
+
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=origins,
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+app_router = APIRouter(prefix="/api")
+app_router.include_router(upload_file_routes, prefix="/upload", tags=["upload"])
+
+@app_router.get("/")
+async def root():
+    return {"message": "Hello World"}
+
+app.include_router(app_router)

Api/src/modules/uploadDocument/controllers/file_upload_controller.py

@@ -0,0 +1,23 @@
+import shutil
+from typing import Any
+
+from fastapi import HTTPException, UploadFile
+from fastapi.responses import JSONResponse
+from src.modules.uploadDocument.features.uploadDocument_feature import \
+    UploadDocumentFeature
+
+
+class FileUploadController:
+
+    async def handle_file_upload(self, file: UploadFile) -> Any:
+        try:
+            print(file)
+            result = await UploadDocumentFeature.uploadFile(file)
+            message = result.get("message", "No message provided")
+
+            return JSONResponse(
+                status_code=200, content={"message": message}
+            )
+
+        except Exception as e:
+            raise HTTPException(status_code=500, detail=str(e))

Api/src/modules/uploadDocument/features/uploadDocument_feature.py

@@ -0,0 +1,39 @@
+import os
+from typing import Dict
+
+from fastapi import UploadFile
+from src.db_local_storage.files_db import FILES_DIRECTORY, FILES_NAMES_DATABASE
+
+
+class UploadDocumentFeature:
+
+    @staticmethod
+    def ensure_directory_exists(folder_path: str) -> None:
+        """Ensure that the directory exists."""
+        if not os.path.exists(folder_path):
+            os.makedirs(folder_path)
+
+    @staticmethod
+    async def saveFile(document: UploadFile, directory: str) -> str:
+        """Save the uploaded file to the specified directory."""
+        file_path = os.path.join(directory, document.filename)
+        with open(file_path, "wb") as file:
+            content = await document.read()
+            file.write(content)
+        return file_path
+
+    @staticmethod
+    async def uploadFile(document: UploadFile) -> Dict[str, str]:
+        """
+        Upload a file to the server
+        :param document: the file to upload
+        :return: a message to confirm the upload
+        """
+
+        UploadDocumentFeature.ensure_directory_exists(FILES_DIRECTORY)
+        id = len(FILES_NAMES_DATABASE) + 1
+        FILES_NAMES_DATABASE[id] = document.filename
+
+        file_path = await UploadDocumentFeature.saveFile(document, FILES_DIRECTORY)
+
+        return {"message": "Document Updated"}

Api/src/modules/uploadDocument/routes/uploadDocument_route.py

@@ -0,0 +1,13 @@
+from fastapi import APIRouter, File, HTTPException, UploadFile
+from src.modules.uploadDocument.controllers.file_upload_controller import \
+    FileUploadController
+
+router = APIRouter()
+controller = FileUploadController()
+
+
+@router.post(
+    "/document",
+)
+async def upload_file(file: UploadFile = File(...)):
+    return await controller.handle_file_upload(file)

Api/src/modules/uploadDocument/schemas/uploadDocument_schema.py

@@ -0,0 +1,10 @@
+from pydantic import BaseModel
+
+
+class DocumentUpload(BaseModel):
+    filename: str
+
+
+class DocumentResponse(BaseModel):
+    id: int
+    filename: str