Function startReview

projects/openade-module/src/node.ts:419–570

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

    }

    async function startReview(params: OpenADEReviewStartRequest, context?: { runtimeId?: string }): Promise<{ taskId: string; eventId: string }> {
        const task = await projection.readTask(params.repoId, params.taskId)
        const project = (await projection.readProjects()).find((candidate) => candidate.id === params.repoId)
        if (!project) throw new Error(`Repository ${params.repoId} not found`)

        const latestPlan = latestCompletedPlanEvent(task.events)
        const latestPlanHarnessId = actionHarnessId(latestPlan, params.harnessId)
        const planText = latestPlan ? (extractOpenADEPlanText(executionEvents(latestPlan), latestPlanHarnessId) ?? "") : ""
        const threadXml = taskReviewThreadXml(task)
        const changedFiles = recentSnapshotFiles(task)
        const reviewPrompt =
            params.reviewType === "plan"
                ? buildOpenADEPlanReviewPrompt({
                      threadXml,
                      planText,
                      changedFiles,
                      customInstructions: params.customInstructions,
                  })
                : buildOpenADEWorkReviewPrompt({
                      threadXml,
                      changedFiles,
                      customInstructions: params.customInstructions,
                  })

        const userLabel = params.reviewType === "plan" ? "Review Plan" : "Review"
        const reviewDisplayInput = params.customInstructions?.trim() ? `${userLabel}: ${params.customInstructions.trim()}` : userLabel
        const executionId = executionIdForTask(params.taskId)
        const action = await writer.createActionEvent({
            taskId: params.taskId,
            userInput: reviewDisplayInput,
            executionId,
            harnessId: params.harnessId,
            source: {
                type: "review",
                userLabel,
                reviewType: params.reviewType,
                userInstructions: params.customInstructions,
            },
            includesCommentIds: [],
            modelId: params.modelId,
        })

        const runtimeId = context?.runtimeId ?? `openade-review:${params.taskId}`
        if (server) {
            const runtimePatch = {
                status: "running" as const,
                scope: {
                    ownerType: "openade-task",
                    ownerId: params.taskId,
                    repoPath: project.path,
                    rootPath: project.path,
                    labels: {
                        eventId: action.eventId,
                        executionId,
                    },
                },
                nativeId: executionId,
            }