Function onEvent

projects/openade-module/src/node.ts:1065–1091

(event)

                        server?.notify("runtime/updated", runtime)
                    },
                    onEvent(event) {
                        events.push(event)
                        server?.supervisor.touchByOwner("openade-task", taskId)
                        server?.notify("agent/event", event)
                        if (isTerminal) {
                            persist(writer.appendActionStreamEvent({ taskId, eventId, streamEvent: event }))
                        } else {
                            persist(writer.appendHyperPlanSubExecutionStreamEvent({ taskId, eventId, stepId: step.id, streamEvent: event }))
                        }
                        if (event.type === "session_started" && typeof event.sessionId === "string") {
                            sessionId = event.sessionId
                            if (isTerminal) {
                                persist(writer.updateActionExecution({ taskId, eventId, sessionId: event.sessionId, parentSessionId: resumeSessionId }))
                            } else {
                                persist(
                                    writer.updateHyperPlanSubExecution({
                                        taskId,
                                        eventId,
                                        stepId: step.id,
                                        sessionId: event.sessionId,
                                        parentSessionId: resumeSessionId,
                                    })
                                )
                            }
                        }
                        notifyTaskChanged(server, repoId, taskId)
                    },
                    onSettled(result) {
                        if (result.status === "completed") finish({ status: "completed", sessionId: result.sessionId })
                        else if (result.status === "stopped") finish({ status: "stopped", sessionId: result.sessionId, error: result.error })