Add plan_id to InputTask and update API logic

Introduces a plan_id field to the InputTask model and ensures it is set if missing in the process_request API endpoint. Also updates response to include plan_id, modifies .env.sample, switches dependency from fastmcp to mcp in pyproject.toml, and comments out user ownership check in team_service.

Author: Fr4nc3

src/backend/.env.sample

@@ -26,8 +26,8 @@ MCP_SERVER_DESCRIPTION=My MCP Server
 TENANT_ID=
 CLIENT_ID=
 BACKEND_API_URL=http://localhost:8000
-FRONTEND_SITE_NAME=*
-SUPPORTED_MODELS=
+FRONTEND_SITE_NAME=
+SUPPORTED_MODELS='["o3","o4-mini","gpt-4.1","gpt-4.1-mini"]'
 AZURE_AI_SEARCH_CONNECTION_NAME=
 AZURE_AI_SEARCH_INDEX_NAME=
 AZURE_AI_SEARCH_ENDPOINT=

src/backend/common/models/messages_kernel.py

@@ -248,6 +248,7 @@ class InputTask(KernelBaseModel):
     """Message representing the initial input task from the user."""
 
     session_id: str
+    plan_id: str
     description: str  # Initial goal
     team_id: str
 

src/backend/pyproject.toml

@@ -31,5 +31,5 @@ dependencies = [
     "uvicorn>=0.34.2",
     "pylint-pydantic>=0.3.5",
     "pexpect>=4.9.0",
-    "fastmcp==2.11.3",
+    "mcp>=1.13.1"
 ]

src/backend/v3/api/router.py

@@ -54,7 +54,7 @@ async def start_comms(websocket: WebSocket, process_id: str):
     connection_config.add_connection(process_id=process_id, connection=websocket, user_id=user_id)
     track_event_if_configured("WebSocketConnectionAccepted", {"process_id": process_id, "user_id": user_id})
 
-      # Keep the connection open - FastAPI will close the connection if this returns
+    # Keep the connection open - FastAPI will close the connection if this returns
     try:
         # Keep the connection open - FastAPI will close the connection if this returns
         while True:
@@ -224,6 +224,8 @@ async def process_request(background_tasks: BackgroundTasks, input_task: InputTa
 
     if not input_task.session_id:
         input_task.session_id = str(uuid.uuid4())
+    if not input_task.plan_id:
+        input_task.plan_id = str(uuid.uuid4())
 
     try:
         current_user_id.set(user_id)  # Set context
@@ -240,6 +242,7 @@ async def run_with_context():
         return {
             "status": "Request started successfully",
             "session_id": input_task.session_id,
+            "plan_id": input_task.plan_id,
         }
 
     except Exception as e:

src/backend/v3/common/services/team_service.py

@@ -204,13 +204,13 @@ async def get_team_configuration(
                 return None
 
             # Verify the configuration belongs to the user
-            if team_config.user_id != user_id:
-                self.logger.warning(
-                    "Access denied: config %s does not belong to user %s",
-                    team_id,
-                    user_id,
-                )
-                return None
+            # if team_config.user_id != user_id:
+            #     self.logger.warning(
+            #         "Access denied: config %s does not belong to user %s",
+            #         team_id,
+            #         user_id,
+            #     )
+            #     return None
 
             return team_config