Function readTask

projects/openade-module/src/yjsProjection.ts:184–236

(repoId: string, taskId: string)

    }

    async function readTask(repoId: string, taskId: string): Promise<OpenADETask> {
        const documentId = `code:task:${taskId}`
        const [meta, events, comments, deviceEnvironments, preview] = await Promise.all([
            storage.readMapObject(documentId, "task:meta"),
            storage.readOrderedArray<Record<string, unknown>>(documentId, "task:events"),
            storage.readOrderedArray<Record<string, unknown>>(documentId, "task:comments"),
            storage.readOrderedArray<Record<string, unknown>>(documentId, "task:deviceEnvironments"),
            readTaskList(repoId).then((tasks) => tasks.find((task) => task.id === taskId)),
        ])

        if (!meta) {
            if (!preview) throw new Error(`Task ${taskId} not found`)
            return {
                id: preview.id,
                repoId,
                slug: preview.slug,
                title: preview.title,
                description: "",
                isolationStrategy: { type: "head" },
                closed: preview.closed,
                unavailableReason: "Task data is unavailable on the desktop host.",
                deviceEnvironments: [],
                events: [],
                comments: [],
            }
        }

        const metaId = stringValue(meta.id)
        if (metaId !== taskId) {
            throw new Error(`Task document ${taskId} has mismatched metadata id ${metaId || "<empty>"}`)
        }

        return {
            id: metaId,
            repoId: stringValue(meta.repoId, repoId),
            slug: stringValue(meta.slug, preview?.slug ?? ""),
            title: stringValue(meta.title, preview?.title ?? "Untitled task"),
            description: stringValue(meta.description),
            isolationStrategy: isRecord(meta.isolationStrategy)
                ? (meta.isolationStrategy as OpenADETask["isolationStrategy"])
                : { type: "head" },
            enabledMcpServerIds: Array.isArray(meta.enabledMcpServerIds)
                ? meta.enabledMcpServerIds.filter((id): id is string => typeof id === "string")
                : undefined,
            sessionIds: stringRecord(meta.sessionIds),
            queuedTurns: queuedTurns(meta.queuedTurns),
            cancelledPlanEventId: optionalString(meta.cancelledPlanEventId),
            deviceEnvironments: (deviceEnvironments ?? []) as unknown as OpenADETask["deviceEnvironments"],
            closed: optionalBoolean(meta.closed),
            events: events ?? [],
            comments: comments ?? [],
        }
    }

    async function listDataDocuments(): Promise<string[]> {
        return storage.listDocuments()