feat: add initial upload endpoint

pyproject.toml

@@ -16,6 +16,8 @@ psycopg2-binary = "^2.9.9"
 asyncpg = "^0.29.0"
 regtech-api-commons = {git = "https://github.com/cfpb/regtech-api-commons.git"}
 regtech-data-validator = {git = "https://github.com/cfpb/regtech-data-validator.git"}
+python-multipart = "^0.0.6"
+boto3 = "^1.33.12"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^7.4.3"

src/main.py

@@ -1,8 +1,8 @@
 from fastapi import FastAPI
 
+from routers import filing_router
+
 app = FastAPI()
 
 
-@app.get("/test")
-def test():
-    return "test"
+app.include_router(filing_router, prefix="/v1/filing")

src/routers/__init__.py

@@ -0,0 +1,3 @@
+__all__ = ["filing_router"]
+
+from .filing import router as filing_router

src/routers/filing.py

@@ -0,0 +1,15 @@
+from http import HTTPStatus
+from fastapi import Request, UploadFile, BackgroundTasks
+from regtech_api_commons.api import Router
+from services import submission_processor
+
+router = Router()
+
+
+@router.post("/{lei}/submissions/{submission_id}", status_code=HTTPStatus.ACCEPTED)
+async def upload_file(
+    request: Request, lei: str, submission_id: str, file: UploadFile, background_tasks: BackgroundTasks
+):
+    content = await file.read()
+    await submission_processor.upload_to_storage(lei, submission_id, content)
+    background_tasks.add_task(submission_processor.validate_submission, lei, submission_id, content)

src/services/submission_processor.py

@@ -0,0 +1,8 @@
+async def upload_to_storage(lei: str, submission_id: str, content: bytes):
+    # implement uploading process here
+    pass
+
+
+async def validate_submission(lei: str, submission_id: str, content: bytes):
+    # implement validation process here
+    pass