Merge pull request #270 from Pythagora-io/staging

Staging

cloud/config-docker.json

@@ -97,6 +97,11 @@
       "provider": "openai",
       "model": "claude-sonnet-4-20250514",
       "temperature": 0.0
+    },
+    "Troubleshooter.define_user_review_goal": {
+      "provider": "anthropic",
+      "model": "claude-sonnet-4-20250514",
+      "temperature": 0.0
     }
   },
   "prompt": {

core/config/__init__.py

@@ -45,6 +45,7 @@ PARSE_TASK_AGENT_NAME = "Developer.parse_task"
 TASK_BREAKDOWN_AGENT_NAME = "Developer.breakdown_current_task"
 TROUBLESHOOTER_BUG_REPORT = "Troubleshooter.generate_bug_report"
 TROUBLESHOOTER_GET_RUN_COMMAND = "Troubleshooter.get_run_command"
+TROUBLESHOOTER_DEFINE_USER_REVIEW_GOAL = "Troubleshooter.define_user_review_goal"
 TECH_LEAD_PLANNING = "TechLead.plan_epic"
 TECH_LEAD_EPIC_BREAKDOWN = "TechLead.epic_breakdown"
 SPEC_WRITER_AGENT_NAME = "SpecWriter"
@@ -406,6 +407,11 @@ class Config(_StrictModel):
                 model="claude-sonnet-4-20250514",
                 temperature=0.0,
             ),
+            TROUBLESHOOTER_DEFINE_USER_REVIEW_GOAL: AgentLLMConfig(
+                provider=LLMProvider.OPENAI,
+                model="claude-sonnet-4-20250514",
+                temperature=0.0,
+            ),
         }
     )
     prompt: PromptConfig = PromptConfig()

core/ui/api_server.py

@@ -346,7 +346,7 @@ class IPCServer:
             await self._add_to_chat_history(project_state_id, convo, message, str(response))
 
             # Send final message
-            # await send_stream_chunk(writer, message_type, None, request_id)
+            await send_stream_chunk(writer, message_type, None, request_id)
 
         except (ConnectionResetError, BrokenPipeError) as err:
             log.error(f"Failed to send streaming response: {err}", exc_info=True)

core/ui/ipc_client.py

@@ -228,7 +228,7 @@ class IPCClientUI(UIBase):
             return
 
         if chunk is None:
-            chunk = "\n"  # end of stream
+            chunk = "<__stream_end__>"  # end of stream
 
         await self._send(
             MessageType.STREAM,