feat: adding code response

app.py

@@ -1,4 +1,5 @@
 from fastapi import FastAPI
+from fastapi.responses import JSONResponse
 from fastapi.middleware.cors import CORSMiddleware
 from ultralytics import YOLO
 
@@ -70,7 +71,15 @@ async def start_detection(data: Dict):
     cameras     = data.get("cameras", [])
 
     if not station_id or not parts or not webhook_url or not cameras:
-        return {"status": "error", "message": "Missing required fields"}
+        return JSONResponse(
+                status_code=400,
+                content={
+                    "status": "error", 
+                    "station_id": station_id,
+                    "camera_count": len(cameras),
+                    "message": "Missing required fields"
+                }
+            )
 
     # -------------------------------
     # VALIDATION BEFORE EXECUTION
@@ -87,14 +96,15 @@ async def start_detection(data: Dict):
         logger.error("[VALIDATION FAILED] Input data is invalid.")
         for err in validation_errors:
             logger.error(f" - {err}")
-        return {
-            "code": 400,
-            "status": "error", 
-            "station_id": station_id,
-            "camera_count": len(cameras),
-            "message": " | ".join(validation_errors)
-        }
-
+        return JSONResponse(
+                status_code=400,
+                content={
+                    "status": "error", 
+                    "station_id": station_id,
+                    "camera_count": len(cameras),
+                    "message": " | ".join(validation_errors)
+                }
+            )
     logger.info(f"[INFO] Get metadata parts")
     model_path = model_by_id_metadata(parts['id'])
 
@@ -112,13 +122,15 @@ async def start_detection(data: Dict):
     # running background
     asyncio.create_task(run_detection_group(station_id, cameras, webhook_url, model, parts))
 
-    return {
-        "code": 200,
-        "status": "started",
-        "station_id": station_id,
-        "camera_count": len(cameras),
-        "message": "Detection is running in background."
-    }
+    return JSONResponse(
+            status_code=200,
+            content={
+            "status": "started",
+            "station_id": station_id,
+            "camera_count": len(cameras),
+            "message": "Detection is running in background."
+            }
+        )
 
 
 # ============================================================

core/defect_detection.py

@@ -10,9 +10,9 @@ load_dotenv()
 MODEL_VERSION   = os.getenv("MODEL_VERSION","v1.0.0")
 WEBHOOK_URL     = os.getenv("WEBHOOK_URL")
 
-MAX_RUNTIME_SEC     = float(os.getenv("MAX_RUNTIME_SEC", "5"))
+MAX_RUNTIME_SEC     = float(os.getenv("MAX_RUNTIME_SEC", "20"))
 FRAME_FAIL_SLEEP    = float(os.getenv("FRAME_FAIL_SLEEP", "0.05"))
-DEFAULT_FPS         = float(os.getenv("DEFAULT_FPS", "10"))
+DEFAULT_FPS         = float(os.getenv("DEFAULT_FPS", "25"))
 WEBHOOK_TIMEOUT     = float(os.getenv("WEBHOOK_TIMEOUT", "10.0"))
 
 # ============================================================
@@ -31,7 +31,6 @@ def detect_defect_from_video_url(station_id, camera_id: str, video_url: str, mod
     if not cap.isOpened():
         logger.error(f"[ERROR] Cannot open video URL: {video_url}")
         return {
-            "code": 400,
             "station_id": station_id,
             "camera_id": camera_id,
             "status": "error",
@@ -111,7 +110,6 @@ def detect_defect_from_video_url(station_id, camera_id: str, video_url: str, mod
                     logger.info(f"[DETECTED] Camera {camera_id} → {defect_name} ({conf:.2f})")
 
                     return {
-                        "code": 200,
                         "station_id": station_id,
                         "camera_id": camera_id,
                         "status": "success",
@@ -145,7 +143,6 @@ def detect_defect_from_video_url(station_id, camera_id: str, video_url: str, mod
         filepath = None
 
     return {
-        "code": 200,
         "station_id": station_id,
         "camera_id": camera_id,
         "status": "success",
@@ -192,19 +189,15 @@ async def run_detection_group(station_id: str, cameras: List[Dict], webhook_url:
 
     if all_error:
         status = "error"
-        code = 400
         message = "All cameras failed during detection"
     elif has_error:
         status = "partial_error"
-        code = 200
         message = "Some cameras failed during detection"
     else:
         status = "success"
-        code = 200
         message = "Success detecting defects"
 
     payload = {
-        "code": code,
         "status": status,
         "timestamp": time.strftime("%Y-%m-%dT%H:%M:%S", time.localtime()),
         "model_version": MODEL_VERSION,