Function appendActionStreamEvent

projects/openade-module/src/yjsMutation.ts:679–699

(request)

        },

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

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

                taskDoc.transact(() => {
                    const execution = ensureYMap(event, "execution")
                    const events = ensureYArray(execution, "events")
                    if (!hasArrayItemWithId(events, request.streamEvent.id)) {
                        const converted = toYValue(request.streamEvent)
                        if (converted !== undefined) events.push([converted])
                    }
                })
                await saveDoc(storage, `code:task:${request.taskId}`, taskDoc)
            } finally {
                taskDoc.destroy()
            }
        },

        async completeActionEvent(request) {
            const completedAt = request.completedAt ?? now()