Function createTask

projects/openade-module/src/yjsMutation.ts:494–568

(request)

        },

        async createTask(request) {
            const isolationStrategy = request.isolationStrategy ?? { type: "head" }
            const taskId = request.taskId ?? createId()
            const slug = request.slug ?? createSlug()
            const createdAt = request.createdAt ?? now()
            const title = request.title ?? "New task"
            const reposDoc = await loadDoc(storage, "code:repos")
            const taskDoc = await loadDoc(storage, `code:task:${taskId}`)

            try {
                const repoMap = findRepoMap(reposDoc, request.repoId)
                if (!repoMap) throw new Error(`Repository ${request.repoId} not found`)

                const meta = taskDoc.getMap("task:meta")
                const existingMetaId = meta.get("id")
                if (typeof existingMetaId === "string" && existingMetaId && existingMetaId !== taskId) {
                    throw new Error(`Task document ${taskId} has mismatched metadata id ${existingMetaId}`)
                }

                if (!existingMetaId) {
                    taskDoc.transact(() => {
                        setMapObject(meta, {
                            id: taskId,
                            repoId: request.repoId,
                            slug,
                            title,
                            description: request.input,
                            isolationStrategy,
                            sessionIds: {},
                            createdBy: request.createdBy,
                            createdAt,
                            updatedAt: createdAt,
                            ...(request.enabledMcpServerIds && request.enabledMcpServerIds.length > 0
                                ? { enabledMcpServerIds: request.enabledMcpServerIds }
                                : {}),
                        })

                        if (!hasOrderedItem(taskDoc, "task:deviceEnvironments", request.deviceId)) {
                            pushOrderedItem(taskDoc, "task:deviceEnvironments", (request.deviceEnvironment ?? {
                                id: request.deviceId,
                                deviceId: request.deviceId,
                                setupComplete: true,
                                createdAt,
                                lastUsedAt: createdAt,
                            }) as unknown as Record<string, unknown> & { id: string })
                        }
                        if (request.setupEvent) {
                            pushOrderedItem(taskDoc, "task:events", {
                                id: request.setupEvent.eventId ?? createId(),
                                type: "setup_environment",
                                status: "completed",
                                createdAt: request.setupEvent.createdAt ?? createdAt,
                                completedAt: request.setupEvent.completedAt ?? request.setupEvent.createdAt ?? createdAt,
                                userInput: "Environment setup",
                                worktreeId: request.setupEvent.worktreeId,
                                deviceId: request.setupEvent.deviceId,
                                workingDir: request.setupEvent.workingDir,
                                setupOutput: request.setupEvent.setupOutput,