feat: adding code response

app.py

@@ -88,6 +88,7 @@ async def start_detection(data: Dict):
         for err in validation_errors:
             logger.error(f" - {err}")
         return {
+            "code": 400,
             "status": "error", 
             "station_id": station_id,
             "camera_count": len(cameras),
@@ -112,6 +113,7 @@ async def start_detection(data: Dict):
     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),

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", "20"))
+MAX_RUNTIME_SEC     = float(os.getenv("MAX_RUNTIME_SEC", "5"))
 FRAME_FAIL_SLEEP    = float(os.getenv("FRAME_FAIL_SLEEP", "0.05"))
-DEFAULT_FPS         = float(os.getenv("DEFAULT_FPS", "25"))
+DEFAULT_FPS         = float(os.getenv("DEFAULT_FPS", "10"))
 WEBHOOK_TIMEOUT     = float(os.getenv("WEBHOOK_TIMEOUT", "10.0"))
 
 # ============================================================
@@ -31,6 +31,7 @@ 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",
@@ -110,6 +111,7 @@ 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",
@@ -143,6 +145,7 @@ 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",
@@ -189,15 +192,19 @@ 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,