fix: request schema

app.py

@@ -105,35 +105,42 @@ async def upload2(
     job_no: Annotated[str, Form()] = '',
     s3key: Annotated[str, Form()] = '',
     ref: Annotated[str, Form()] = '',
-    file: Annotated[bytes, File()] = File(...)
+    file: UploadFile = File(...)
 ):
     res = Response()
+    res.data = ref
+
     logging.info("--------------------------------")
     logging.info("Received request to upload image")
-    
+
     # Validate headers
     if not is_valid(x_request_user, x_api_key):
         res.status = HTTPStatus.FORBIDDEN
         res.error = "Invalid credentials"
-    else:
-        key = f'{s3key}/{job_no}/{file.filename}'
-        logging.info(f'Key for S3 upload: {key}')
+        return res
+
+    if file is None:
+        res.status = HTTPStatus.BAD_REQUEST
+        res.error = "File not found"
+        return res
 
-        try:
-            # Read the file content directly from UploadFile
-            file_content = await file.read()
-            logging.info(f'File content length: {len(file_content)} bytes')
+    key = f'{s3key}/{job_no}/{file.filename}'
+    logging.info(f'Key for S3 upload: {key}')
 
-            # 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, key)
-            logging.info("File uploaded successfully")
+    try:
+        # Read the file content directly from UploadFile
+        file_content = await file.read()
+        logging.info(f'File content length: {len(file_content)} bytes')
 
-        except Exception as e:
-            res.error = str(e)
-            logging.warning(f"Error during upload: {res.error}")
+        # 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, key)
+        logging.info("File uploaded successfully")
+
+    except Exception as e:
+        res.error = str(e)
+        logging.warning(f"Error during upload: {res.error}")
     
-    res.data = ref
     return res
 
 def is_valid(u, p):