Method _handle_command

core/daemon.py:114–193

Handle a user command (prompt). The 0.5B model on port 8081 plans the task into numbered steps. Each step is added as a dependent task so the 7B agent works through them one at a time. If the planner is unavailable, times out, or returns fewer than 2 steps,

(self, data: Dict)

        return {"status": "ok", "message": "pong"}
    
    async def _handle_command(self, data: Dict) -> Dict:
        """Handle a user command (prompt).

        The 0.5B model on port 8081 plans the task into numbered steps.
        Each step is added as a dependent task so the 7B agent works through
        them one at a time.

        If the planner is unavailable, times out, or returns fewer than 2 steps,
        the prompt is queued as a single direct task.  Planner failure is always
        silent (logged only) and never surfaces as an error.
        """
        prompt = data.get("prompt", "")
        if not prompt:
            return {"status": "error", "message": "No prompt provided"}

        # Log to episodic log
        self.state.log_action("command_received", prompt[:200])

        # ── plannd integration (Change 1) ────────────────────────────────────
        no_plan = data.get("no_plan", False)
        if not no_plan:
            try:
                from core.planner_client import send_plan_request_async
                steps = await asyncio.wait_for(
                    send_plan_request_async(prompt),
                    timeout=180.0,
                )
                if steps and len(steps) > 1:
                    if data.get("plan_only", False):
                        task_ids = []
                        info(f"plannd: returned {len(steps)}-step plan (plan_only)")
                    else:
                        # Inject original prompt into step 1 (the create step)
                        # so the executor has full requirements context.
                        # Later steps (run/verify) are usually self-contained
                        # and don't need the full prompt — just the step.
                        total = len(steps)
                        enriched = []
                        for i, step in enumerate(steps):
                            if i == 0:
                                # Step 1: full context — the executor needs
                                # all requirements to write the code
                                enriched.append(
                                    f"User's full request: {prompt}\n\n"
                                    f"Your task (step {i+1}/{total}): {step}\n\n"
                                    "Write the COMPLETE file with ALL features "
                                    "described above. Do not skip any requirement."
                                )
                            else:
                                enriched.append(
                                    f"Previous context: {prompt[:200]}\n\n"
                                    f"Your task (step {i+1}/{total}): {step}\n\n"
                                    "Complete only this step."
                                )
                        task_ids = self.planner.add_tasks(enriched)
                        info(f"plannd: queued {len(steps)}-step plan")
                    return {
                        "status": "ok",