Update config_controller.py

config_controller.py

@@ -1,4 +1,4 @@
-from fastapi import APIRouter, Request
+from fastapi import APIRouter, Request, HTTPException
 from service_config import ServiceConfig
 
 router = APIRouter()
@@ -17,13 +17,20 @@ def get_config():
 @router.post("/update")
 async def update_config(request: Request):
     data = await request.json()
-    service_config.work_mode = data.get("work_mode", service_config.work_mode)
-    service_config.cloud_token = data.get("cloud_token", service_config.cloud_token)
-    service_config.spark_endpoint = data.get("spark_endpoint", service_config.spark_endpoint)
+    work_mode = data.get("work_mode")
+    cloud_token = data.get("cloud_token")
+    spark_endpoint = data.get("spark_endpoint")
+
+    if not work_mode or not spark_endpoint:
+        raise HTTPException(status_code=400, detail="work_mode and spark_endpoint cannot be empty")
+
+    service_config.work_mode = work_mode
+    service_config.cloud_token = cloud_token
+    service_config.spark_endpoint = spark_endpoint
 
-    # Config'i kaydet
     with open(service_config.config_path, "w", encoding="utf-8") as f:
         import json
         json.dump(service_config, f, indent=2)
 
     return {"message": "Configuration updated successfully"}
+