Add UserCurrentTeam model and update plan creation

Introduces the UserCurrentTeam model to represent a user's current team. Updates the API router to generate a new plan with a unique ID and store it in the database, removing plan_id and team_id from InputTask. Plan creation now includes initial goal and status.

Author: Fr4nc3

src/backend/common/models/messages_kernel.py

@@ -98,6 +98,12 @@ class Session(BaseDataModel):
     current_status: str
     message_to_user: Optional[str] = None
 
+class UserCurrentTeam(BaseDataModel):
+    """Represents the current team of a user."""
+
+    data_type: Literal["user_current_team"] = Field("user_current_team", Literal=True)
+    user_id: str
+    team_id: str
 
 class Plan(BaseDataModel):
     """Represents a plan containing multiple steps."""
@@ -248,9 +254,8 @@ 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
+    # team_id: str
 
 
 class UserLanguage(KernelBaseModel):

src/backend/v3/api/router.py

@@ -8,8 +8,8 @@
 import v3.models.messages as messages
 from auth.auth_utils import get_authenticated_user_details
 from common.database.database_factory import DatabaseFactory
-from common.models.messages_kernel import (GeneratePlanRequest, InputTask,
-                                           TeamSelectionRequest)
+from common.models.messages_kernel import (GeneratePlanRequest, InputTask, PlanStatus,
+                                           TeamSelectionRequest, Plan)
 from common.utils.event_utils import track_event_if_configured
 from common.utils.utils_kernel import rai_success, rai_validate_team_config
 from fastapi import (APIRouter, BackgroundTasks, Depends, FastAPI, File,
@@ -224,16 +224,24 @@ 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())
+ 
+    plan_id = str(uuid.uuid4())
 
     try:
         current_user_id.set(user_id)  # Set context
         current_context = contextvars.copy_context()  # Capture context
         # background_tasks.add_task(
         #     lambda: current_context.run(lambda:OrchestrationManager().run_orchestration, user_id, input_task)
         # )
-
+        memory_store = await DatabaseFactory.get_database(user_id=user_id)
+        plan = Plan(
+            id=plan_id,
+            user_id=user_id,
+            team_id="", #TODO add current_team_id
+            initial_goal=input_task.description,
+            overall_status=PlanStatus.in_progress,
+        )
+        await memory_store.add_plan(plan)
         async def run_with_context():
             return await current_context.run(OrchestrationManager().run_orchestration, user_id, input_task)