Function createActionEvent

projects/openade-module/src/yjsMutation.ts:638–677

(request)

        },

        async createActionEvent(request) {
            const eventId = request.eventId ?? createId()
            const createdAt = request.createdAt ?? now()
            const taskDoc = await loadDoc(storage, `code:task:${request.taskId}`)

            try {
                const meta = taskDoc.getMap("task:meta")
                assertTaskMeta(meta, request.taskId)

                taskDoc.transact(() => {
                    if (!hasOrderedItem(taskDoc, "task:events", eventId)) {
                        const execution: Record<string, unknown> = {
                            harnessId: request.harnessId,
                            executionId: request.executionId,
                            modelId: request.modelId,
                            fastMode: request.fastMode,
                            events: [],
                            gitRefsBefore: request.gitRefsBefore,
                        }
                        pushOrderedItem(taskDoc, "task:events", {
                            id: eventId,
                            type: "action",
                            status: "in_progress",
                            createdAt,
                            userInput: request.userInput,
                            ...(request.images && request.images.length > 0 ? { images: request.images } : {}),
                            execution,
                            source: request.source,
                            includesCommentIds: request.includesCommentIds ?? [],
                        })
                    }
                    meta.set("updatedAt", createdAt)
                })
                await saveDoc(storage, `code:task:${request.taskId}`, taskDoc)

                return { eventId, createdAt }
            } finally {
                taskDoc.destroy()
            }
        },

        async appendActionStreamEvent(request) {
            const taskDoc = await loadDoc(storage, `code:task:${request.taskId}`)