Update controllers/project_controller.py

controllers/project_controller.py

@@ -1,107 +1,70 @@
-from fastapi import APIRouter, Request, Header
-from session import SessionStore
-from service_config import ServiceConfig
-from prompt_engine import PromptEngine
-from llm_connector import LLMConnector
-from api_connector import APIConnector
-from validation_engine import ValidationEngine
-from log import log
-import traceback
-
-router = APIRouter()
-
-# Core bileşenler
-service_config = ServiceConfig()
-service_config.load()
-session_store = SessionStore()
-prompt_engine = PromptEngine(service_config)
-llm_connector = LLMConnector(service_config)
-api_connector = APIConnector(service_config)
-validation_engine = ValidationEngine()
-
-@router.post("/start_chat")
-def start_chat(request: Request):
-    project_name = request.query_params.get("project_name")
-    if not project_name:
-        return {"error": "Missing project_name parameter."}
-    session = session_store.create_session(project_name)
-    return {"session_id": session.session_id}
-
-@router.post("/chat")
-async def chat(request: Request, x_session_id: str = Header(None)):
-    if not x_session_id:
-        return {"error": "Missing X-Session-ID header."}
-    session = session_store.get_session(x_session_id)
-    if not session:
-        return {"error": "Invalid or expired session."}
-    try:
-        body = await request.json()
-        user_input = body.get("user_input", "").strip()
-        if not user_input:
-            return {"error": "Empty user input."}
-        session.chat_history.append({"role": "user", "content": user_input})
-        project_name = session.project_name
-
-        if session.state == "intent_detection":
-            prompt = prompt_engine.build_intent_prompt(project_name)
-            llm_response = llm_connector.call_spark(project_name, prompt, session.chat_history)
-            if llm_response is None:
-                return {"error": "Failed to get intent detection result."}
-            intent = llm_response.get("intent")
-            params = llm_response.get("params", {})
-            missing = llm_response.get("missing", [])
-            session.last_intent = intent
-            session.variables.update(params)
-            session.awaiting_parameters = missing
-            if missing:
-                session.state = "parameter_extraction"
-                return {"response": f"Please provide: {', '.join(missing)}"}
-            session.state = "validation"
-
-        if session.state == "parameter_extraction":
-            prompt = prompt_engine.build_parameter_prompt(project_name, session.last_intent, session.awaiting_parameters)
-            llm_response = llm_connector.call_spark(project_name, prompt, session.chat_history)
-            if llm_response is None:
-                return {"error": "Failed to extract parameters."}
-            params = llm_response.get("params", {})
-            missing = llm_response.get("missing", [])
-            session.variables.update(params)
-            session.awaiting_parameters = missing
-            if missing:
-                return {"response": f"Please provide: {', '.join(missing)}"}
-            session.state = "validation"
-
-        if session.state == "validation":
-            intent_def = next((i for i in service_config.get_project_intents(project_name) if i["name"] == session.last_intent), None)
-            if not intent_def:
-                return {"error": f"Intent definition not found: {session.last_intent}"}
-            is_valid, errors = validation_engine.validate_parameters(intent_def, session.variables)
-            if not is_valid:
-                return {"response": " ".join(errors)}
-            session.state = "api_call"
-
-        if session.state == "api_call":
-            intent_def = next((i for i in service_config.get_project_intents(project_name) if i["name"] == session.last_intent), None)
-            api_response = api_connector.call_api(intent_def, session)
-            if "fallback" in api_response:
-                return {"response": api_response["fallback"]}
-            session.state = "humanization"
-            session.variables["api_result"] = api_response
-
-        if session.state == "humanization":
-            prompt = prompt_engine.build_humanization_prompt(project_name, session.last_intent)
-            chat_history = [{"role": "system", "content": str(session.variables["api_result"])}]
-            humanized_response = llm_connector.call_spark(project_name, prompt, chat_history)
-            if humanized_response is None:
-                return {"error": "Failed to humanize response."}
-            session.chat_history.append({"role": "assistant", "content": humanized_response.get("answer")})
-            session.state = "intent_detection"
-            session.last_intent = None
-            session.variables = {}
-            session.awaiting_parameters = []
-            return {"response": humanized_response.get("answer")}
-
-    except Exception as e:
-        log(f"❌ Error in chat: {e}")
-        traceback.print_exc()
-        return {"error": str(e)}
+from fastapi import APIRouter, Request
+from service_config import ServiceConfig
+from log import log
+import json
+
+router = APIRouter()
+service_config = ServiceConfig()
+service_config.load()
+
+@router.get("/list_projects")
+def list_projects():
+    projects = list(service_config.projects.keys())
+    log("📋 Listing projects.")
+    return {"projects": projects}
+
+@router.post("/add_project")
+async def add_project(request: Request):
+    data = await request.json()
+    project_name = data.get("project_name")
+    if not project_name:
+        return {"error": "Project name required."}
+
+    if project_name in service_config.projects:
+        return {"error": "Project already exists."}
+
+    service_config.projects[project_name] = {
+        "project_name": project_name,
+        "project_version": 1,
+        "llm": {},
+        "intents": []
+    }
+
+    with open(service_config.config_path, "w", encoding="utf-8") as f:
+        json.dump({
+            "config": {
+                "work_mode": service_config.work_mode,
+                "cloud_token": service_config.cloud_token,
+                "system_prompt": service_config.system_prompt,
+                "llm_inference_service_url": service_config.llm_inference_service_url
+            },
+            "projects": service_config.projects,
+            "apis": service_config.apis
+        }, f, indent=2)
+
+    log(f"🆕 Added project: {project_name}")
+    return {"message": f"Project {project_name} added."}
+
+@router.post("/delete_project")
+async def delete_project(request: Request):
+    data = await request.json()
+    project_name = data.get("project_name")
+    if project_name not in service_config.projects:
+        return {"error": "Project not found."}
+
+    del service_config.projects[project_name]
+
+    with open(service_config.config_path, "w", encoding="utf-8") as f:
+        json.dump({
+            "config": {
+                "work_mode": service_config.work_mode,
+                "cloud_token": service_config.cloud_token,
+                "system_prompt": service_config.system_prompt,
+                "llm_inference_service_url": service_config.llm_inference_service_url
+            },
+            "projects": service_config.projects,
+            "apis": service_config.apis
+        }, f, indent=2)
+
+    log(f"🗑️ Deleted project: {project_name}")
+    return {"message": f"Project {project_name} deleted."}