feat: save reviews to s3

api/main.py

@@ -3,14 +3,16 @@
 from fastapi.staticfiles import StaticFiles
 from fastapi.templating import Jinja2Templates
 from mangum import Mangum
+from utils import s3
 
 app = FastAPI()
 
 app.mount("/static", StaticFiles(directory="static"), name="static")
 
-
 templates = Jinja2Templates(directory="templates")
 
+BUCKET = "coffee-review"
+
 
 @app.get("/", response_class=HTMLResponse)
 async def home(request: Request):
@@ -24,8 +26,11 @@ async def home(request: Request):
 async def review(request: Request):
     # Get the form data
     form = await request.form()
-    print(form)
-    return templates.TemplateResponse(request=request, name="success.html")
+    res = s3.upload_review(dict(form), BUCKET)
+    if res:
+        return templates.TemplateResponse(request=request, name="success.html")
+    else:
+        return templates.TemplateResponse(request=request, name="error.html")
 
 
 @app.get("/api/review", response_class=HTMLResponse)

api/requirements.txt

@@ -2,6 +2,7 @@ fastapi
 jinja2
 mangum
 python-multipart
+boto3
 
 # Testing
 # uvicorn

api/templates/error.html

@@ -0,0 +1,5 @@
+<div class="text-center flex flex-col items-center justify-center h-screen">
+    <h1 class="text-5xl mb-16">Something went wrong submitted review</h1>
+    <button class="btn btn-primary" hx-get="/api/review" hx-swap="innerHTML" hx-target="body">
+        Make another review</button>
+</div>

api/utils/s3.py

@@ -0,0 +1,15 @@
+import boto3
+import json
+import uuid
+
+
+def upload_review(review: dict, bucket: str) -> bool:
+    """Uploads a review to S3"""
+    s3 = boto3.client("s3")
+    key = f"{uuid.uuid4()}.json"
+    try:
+        s3.put_object(Bucket=bucket, Key=key, Body=json.dumps(review))
+        return True
+    except Exception as e:
+        print(e)
+        return False

template.yaml

@@ -15,6 +15,9 @@ Resources:
       CodeUri: api
       Handler: main.handler
       Runtime: python3.11
+      Policies:
+        - S3CrudPolicy:
+            BucketName: coffee-review
       Events:
         Api:
           Type: HttpApi