Function startTurn

projects/openade-module/src/node.ts:290–417

(params: OpenADETurnStartRequest, context?: { runtimeId?: string })

    }

    async function startTurn(params: OpenADETurnStartRequest, context?: { runtimeId?: string }): Promise<{ taskId: string; eventId: string }> {
        let taskId = params.inTaskId || ""
        if (!taskId) {
            const createdAt = now()
            const request: OpenADETaskCreateRequest = {
                repoId: params.repoId,
                input: params.input,
                createdBy: { id: "headless-runtime", email: "headless@openade.local" },
                deviceId: "headless-runtime",
                title: params.title ?? fallbackTitle(params.input),
                taskId: taskIdForClientRequest(params.repoId, params.clientRequestId),
                createdAt,
                isolationStrategy: params.isolationStrategy,
                enabledMcpServerIds: params.enabledMcpServerIds,
            }
            const result = await writer.createTask(request)
            taskId = result.taskId
        }

        const task = await projection.readTask(params.repoId, taskId)
        const project = (await projection.readProjects()).find((candidate) => candidate.id === params.repoId)
        if (!project) throw new Error(`Repository ${params.repoId} not found`)

        if (params.type === "hyperplan") {
            const strategy = params.hyperplanStrategy
            if (!strategy) {
                return startTurn({ ...params, type: "plan", label: params.label ?? "HyperPlan", inTaskId: taskId }, context)
            }
            if (isStandardOpenADEHyperPlanStrategy(strategy)) {
                const step = strategy.steps[0]
                return startTurn(
                    {
                        ...params,
                        type: "plan",
                        harnessId: step.agent.harnessId,
                        modelId: step.agent.modelId,
                        label: params.label ?? "HyperPlan",
                        inTaskId: taskId,
                    },
                    context
                )
            }
            return startHyperPlan({ params, task, project, strategy, context })
        }

        let promptType = params.type
        let planEventId = latestCompletedPlanEventId(task.events)
        if (promptType === "revise" && !planEventId) {
            promptType = "plan"
            planEventId = undefined
        }
        if (promptType === "run_plan" && !planEventId) {
            throw new Error("Run Plan requires a completed plan event")
        }

        const prompt = buildOpenADEPrompt({
            type: promptType as "plan" | "do" | "ask" | "revise" | "run_plan",
            input: params.input,