Method emitHookDrivenShutdown

pkg/runtime/loop.go:156–171

emitHookDrivenShutdown fans out the standard Error / notification(level=error) / on_error stanzas when a hook (post_tool_use or before_llm_call) signals run termination.

(
	ctx context.Context,
	a *agent.Agent,
	sess *session.Session,
	message string,
	events EventSink,
)

// notification(level=error) / on_error stanzas when a hook
// (post_tool_use or before_llm_call) signals run termination.
func (r *LocalRuntime) emitHookDrivenShutdown(
	ctx context.Context,
	a *agent.Agent,
	sess *session.Session,
	message string,
	events EventSink,
) {
	if message == "" {
		// aggregate() always populates Result.Message on a deny
		// verdict; the fallback covers any future hook that returns
		// block without a reason.
		message = "Agent terminated by a hook."
	}
	events.Emit(ErrorWithCodeForSession(sess.ID, ErrorCodeHookBlocked, message))
	r.notifyError(ctx, a, sess.ID, message)
}

// finalizeEventChannel performs cleanup at the end of a RunStream goroutine:
// emits the StreamStopped event, fires hooks, records telemetry, restores the