(request)
| 744 | }, |
| 745 | |
| 746 | async stoppedActionEvent(request) { |
| 747 | const completedAt = request.completedAt ?? now() |
| 748 | const taskDoc = await loadDoc(storage, `code:task:${request.taskId}`) |
| 749 | |
| 750 | try { |
| 751 | const meta = taskDoc.getMap("task:meta") |
| 752 | assertTaskMeta(meta, request.taskId) |
| 753 | const event = getActionEventMap(taskDoc, request.taskId, request.eventId) |
| 754 | |
| 755 | taskDoc.transact(() => { |
| 756 | event.set("status", "stopped") |
| 757 | event.set("completedAt", completedAt) |
| 758 | const execution = ensureYMap(event, "execution") |
| 759 | if (request.sessionId) execution.set("sessionId", request.sessionId) |
| 760 | if (request.parentSessionId) execution.set("parentSessionId", request.parentSessionId) |
| 761 | meta.set("updatedAt", completedAt) |
| 762 | }) |
| 763 | await saveDoc(storage, `code:task:${request.taskId}`, taskDoc) |
| 764 | await syncActionEventPreview(storage, request.taskId, taskDoc, event, stringValue(meta.get("lastEventAt"), event.get("createdAt") as string)) |
| 765 | } finally { |
| 766 | taskDoc.destroy() |
| 767 | } |
| 768 | }, |
| 769 | |
| 770 | async reconcileActionEventRuntime(request) { |
| 771 | const completedAt = request.completedAt ?? now() |
nothing calls this directly
no test coverage detected