feat: add metadata attribute to json string format into to headers

apis/s3.py

@@ -33,7 +33,7 @@ class S3:
         return [self.client.generate_presigned_url('get_object', Params={'Bucket': bucket_name, 'Key': key}) for key in image_keys]
 
     # Function to upload file to S3
-    def upload_file(self, bucket_name, file, name, req_id):
+    def upload_file(self, bucket_name, file, name, metadata):
         res = Response()
         try:
             # self.client.upload_fileobj(
@@ -49,9 +49,8 @@ class S3:
                 Body=file, 
                 Bucket=bucket_name, 
                 Key=name, 
-                Metadata={
-                    'x-request-id': req_id,
-                })
+                Metadata=metadata
+            )
             res.status = 200
         except botocore.exceptions.ClientError as error:
             res.status = 429

app.py

@@ -1,5 +1,5 @@
 from http import HTTPStatus
-import os, io, base64
+import os, io, base64, json
 from typing import Optional
 from fastapi.responses import JSONResponse
 from typing_extensions import Annotated
@@ -68,7 +68,8 @@ def healthcheck():
 async def upload(
     o: ImageObject,
     x_request_user: str = Header(...),
-    x_api_key: str = Header(...)
+    x_api_key: str = Header(...),
+    metadata: str = Header(...),
 ):
     res = Response()
     logging.info("--------------------------------")
@@ -78,6 +79,11 @@ async def upload(
         key = f'{o.key}/{o.job_no}/{o.name}'
         logging.info(f'Key for S3 upload: {key}')
         if o.content is not None:
+            try:
+                metadata = json.loads(metadata)
+            except Exception:
+                metadata = {}
+
             try:
                 # Decode base64 content
                 decoded_content = base64.b64decode(o.content)
@@ -88,7 +94,8 @@ async def upload(
 
                 # Upload file object to S3
                 # logging.info(f"Uploading file to S3 bucket '{AWS_S3_BUCKET_NAME}' with key '{key}'")
-                res = s3client.upload_file(AWS_S3_BUCKET_NAME, file_obj, key, req_id=x_request_user)
+                metadata['x-request-id'] = x_request_user
+                res = s3client.upload_file(AWS_S3_BUCKET_NAME, file_obj, key, metadata=metadata)
                 logging.info("File uploaded successfully")
 
             except Exception as e: