Function createRuntimeNodeOpenADEAdapters

projects/openade-module/src/node.ts:264–771

(options: RuntimeNodeOpenADEOptions = {})

}

export function createRuntimeNodeOpenADEAdapters(options: RuntimeNodeOpenADEOptions = {}): OpenADEModuleAdapters {
    const storage = createOpenADENodeYjsStorage(options.dataDir ?? defaultDataDir())
    const projection = createOpenADEYjsProjection({
        ...storage,
        hostName: () => options.hostName,
    })
    const writer = createOpenADEYjsWriter({
        ...storage,
        hostName: () => options.hostName,
    })
    const server = options.server
    const agentExecutor = options.agentExecutor ?? createRuntimeNodeHarnessAgentExecutor()
    const activeTaskExecutions = new Map<string, ActiveTaskExecution>()
    if (server) {
        server.registerRuntimeStopHandler((runtime) =>
            stopActiveOpenADERuntime({
                server,
                writer,
                agentExecutor,
                activeTaskExecutions,
                runtime,
            })
        )
        void reconcileCheckpointedOpenADEActionEvents({ server, writer })
    }

    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(
                    {