types

const (
	EventWorkflowStart        EventType = "workflow_start"        // Workflow execution began.
	EventWorkflowEnd          EventType = "workflow_end"          // Workflow execution completed.
	EventStepStart            EventType = "step_start"            // Step execution began.
	EventStepEnd              EventType = "step_end"              // Step execution completed.
	EventStepSkipped          EventType = "step_skipped"          // Step was skipped (failed dep or condition).
	EventAgentTurn            EventType = "agent_turn"            // Emitted by AgentRunner on each LLM request/response.
	EventToolCall             EventType = "tool_call"             // Emitted by AgentRunner around each tool execution (phase=start/end).
	EventMessage              EventType = "message"               // Informational message (e.g., child agent model warning).
	EventError                EventType = "error"                 // Error occurred (step failure, storage error, judge failure).
	EventCoordinatorNarration EventType = "coordinator_narration" // Coordinator narration after a step event.
	EventCoordinatorMessage   EventType = "coordinator_message"   // Coordinator targeted message to a running agent.
	EventCoordinatorSynthesis EventType = "coordinator_synthesis" // Coordinator final synthesis.
	// EventCoordinatorInboxMessage is emitted when the executor drains a
	// RouterMessage addressed to the coordinator inbox (notably reverse
	// replies from resumed steps). Data["from"]=originating step id
	// (e.g. "team-pro"); Data["type"]=RouterMessageType string. Message
	// holds the content. Without this event, a reverse reply would sit
	// unread in the coordinator mailbox forever and operators would never
	// see the resumed agent's response.
	EventCoordinatorInboxMessage EventType = "coordinator_inbox_message"
	// EventMessageSent fires whenever an agent or coord successfully queues
	// a message via send_message (agent to coord) or forward_to_agent
	// (coord to agent). The send is the OUTBOUND side of message visibility;
	// the matching INBOUND event is EventAgentInboxDrain (when the recipient
	// drains the message into its LLM conversation) or
	// EventCoordinatorInboxMessage (for reverse replies into coord).
	// Fields: StepID = sender's StepID. Data["to"] = recipient StepID.
	// Data["text"] = full text sent. Data["msg_type"] = RouterMessageType
	// int. Message = text (sinks may truncate).
	EventMessageSent     EventType = "message_sent"
	EventPlanReady       EventType = "plan_ready"        // Goal decomposition produced a workflow (Data["workflow"] = *Workflow).
	EventAgentInboxDrain EventType = "agent_inbox_drain" // Agent drained ONE RouterMessage into its LLM conversation. Message="[from]: content"; Data["from"]=string, Data["msg_type"]=int (same shape as EventMessageSent / EventMessageDropped). Fires once per message.
	// EventMessageDropped is emitted whenever a router message is
	// discarded without ever reaching the target agent's LLM conversation.
	// Reasons are open-ended strings (Data["reason"]); current values:
	// - "workflow-cancelled": workflow ctx cancelled before delivery.
	// - "target-terminal": Send to a step whose mailbox was closed.
	// - "unknown-step": Send to a stepID that was never registered
	// and has no pending senders.
	// - "mailbox-closed-by-finalize": Send raced a Close; the closed
	// flag won.
	// The contract is: zero silent drops - every drop produces exactly
	// one EventMessageDropped.
	EventMessageDropped EventType = "message_dropped"

	// Agent lifecycle observability events. Emitted by AgentRunner when
	// in mailbox-driven mode (Mailbox+Wake non-nil) so the CLI/TUI can
	// surface idle-waiting and wake-driven resume.
	// - EventAgentIdle: agent finished a goai iteration with no unread
	// messages and is parked waiting for Wake. Data["unread_count"]=0.
	// - EventAgentWake: agent re-entered goai after draining N unread
	// messages. Data["message_count"]=int, Data["cycle"]=int
	// (1-indexed wake cycle).
	// - EventMaxWakeCyclesWarning: wake-loop reached 80% of the
	// configured maxWakeCycles cap. Data: "current_cycle"=int,
	// "max_cycles"=int, "unread_remaining"=int. Operators can use
	// this as an early signal a hot-loop / pathological producer is
	// about to trigger DropReasonMaxWakeCycles.
	EventAgentIdle            EventType = "agent_idle"
	EventAgentWake            EventType = "agent_wake"
	EventMaxWakeCyclesWarning EventType = "max_wake_cycles_warning"

	// Resume Mechanism events. Emitted by Executor.ResumeStep when a
	// router message arrives for a terminated step and the auto-resume
	// path fires.
	// - EventResumeStarted: resume goroutine spawned for the step.
	// Data: "resumeID"=string, "from"=string (original sender).
	// - EventResumeCompleted: resumed AgentRunner returned a final
	// response. Data: "resumeID", "durationMs"=int64, "from",
	// optionally "result".
	// - EventResumeFailed: resume could not complete (ctx cancel,
	// transcript cap, agent error). Data: "resumeID", "from",
	// "reason"=string (e.g. "workflow-shutdown",
	// "transcript-too-large", "agent-error").
	EventResumeStarted   EventType = "resume_started"
	EventResumeCompleted EventType = "resume_completed"
	EventResumeFailed    EventType = "resume_failed"
	// EventResumeQueued: a resume attempt arrived while a resume for the
	// same stepID was already in flight. The incoming message was
	// appended to the running resume's mailbox instead of spawning a
	// second goroutine. Data: "resumeID"=string (queued handle),
	// "from"=string, "activeResumeID"=string (optional; the running
	// handle). Prevents silent accept of queued messages.
	EventResumeQueued EventType = "resume_queued"

	// EventTranscriptSealed: emitted once per stepID when a transcript
	// Append first hits ErrTranscriptTooLarge (or any other store error).
	// Subsequent Appends for the same step are silently suppressed (see
	// AgentRunner.Run flushTranscript). The event carries Data: "stepID",
	// "runID", "reason" (e.g. "transcript-too-large", "store-error").
	// Makes sealing observable mid-Run instead of only surfacing at the
	// next Resume attempt.
	EventTranscriptSealed EventType = "transcript_sealed"
)

const (
	MessageKindNotification MessageKind = "notification"
	MessageKindContent      MessageKind = "content"
)