hooks

type AgentEndEvent struct {
	SessionID  string `json:"session_id,omitempty"`
	Success    bool   `json:"success"`
	Error      string `json:"error,omitempty"`
	Aborted    bool   `json:"aborted"`
	Response   string `json:"response,omitempty"`
	DurationMs int64  `json:"duration_ms"`
}

type Dispatcher struct {
	// contains filtered or unexported fields
}

type Event struct {
	Type      EventType `json:"type"`
	Timestamp time.Time `json:"timestamp"`
	SessionID string    `json:"session_id,omitempty"`
	Data      any       `json:"data"`
}

type EventType string

type HandlerConfig struct {
	// Name is an optional identifier for the handler (used in logging).
	Name string

	// Events lists the event types this handler responds to.
	Events []EventType

	// Handler is the function to call when an event occurs.
	Handler HandlerFunc
}

type HandlerFunc func(ctx context.Context, event Event) error

type Hook interface {
	// Name returns the hook identifier.
	Name() string

	// Events returns the event types this hook handles.
	Events() []EventType

	// Handle processes an event.
	Handle(ctx context.Context, event Event) error

	// Init initializes the hook. Called once at startup.
	Init(ctx context.Context) error

	// Close releases resources. Called on shutdown.
	Close() error
}

type JobEvent struct {
	JobID   string `json:"job_id"`
	JobName string `json:"job_name"`
	Success bool   `json:"success"`
}

type MessageEvent struct {
	Role    string `json:"role"`
	Content string `json:"content"`
}

type PromptTurn struct {
	// SessionID is the session the run belongs to (empty when the agent
	// runs without a session).
	SessionID string `json:"session_id,omitempty"`

	// Content is the user message that started the run.
	Content string `json:"content"`

	// Iteration is the zero-based tool-call loop iteration within the run.
	Iteration int `json:"iteration"`

	// Tools is the set of tool names currently available to the turn.
	Tools []string `json:"tools"`
}

type Registry struct {
	// contains filtered or unexported fields
}

type SessionEvent struct {
	SessionID string `json:"session_id"`
	Action    string `json:"action"` // created, updated
}

type SessionRolloverEvent struct {
	SessionID string `json:"session_id"`

	// Reason is the machine-readable rollover cause ("idle" or "daily").
	Reason string `json:"reason"`

	// Transcript holds the ended conversation as role/content pairs.
	Transcript []MessageEvent `json:"transcript"`

	// StartedAt is when the ended conversation began.
	StartedAt time.Time `json:"started_at"`

	// EndedAt is the ended conversation's last activity.
	EndedAt time.Time `json:"ended_at"`
}

type StorageAware interface {
	SetStorage(s kvs.Store)
}

type ToolEvent struct {
	Name   string         `json:"name"`
	Params map[string]any `json:"params,omitempty"`
	Result string         `json:"result,omitempty"`
	Error  string         `json:"error,omitempty"`
}

type ToolsAllowFunc func(ctx context.Context, turn PromptTurn) []string

type WebhookHook struct {
	// HookName is the identifier for this webhook.
	HookName string `json:"name" yaml:"name"`

	// HookEvents lists the event types this webhook receives.
	HookEvents []EventType `json:"events" yaml:"events"`

	// URL is the endpoint to send events to.
	URL string `json:"url" yaml:"url"`

	// Method is the HTTP method (POST or PUT). Defaults to POST.
	Method string `json:"method" yaml:"method"`

	// Headers are additional HTTP headers to send.
	Headers map[string]string `json:"headers" yaml:"headers"`

	// Timeout is the request timeout. Defaults to 10 seconds.
	Timeout time.Duration `json:"timeout" yaml:"timeout"`

	// RetryCount is the number of retries on failure. Defaults to 0.
	RetryCount int `json:"retry_count" yaml:"retry_count"`

	// RetryDelay is the delay between retries. Defaults to 1 second.
	RetryDelay time.Duration `json:"retry_delay" yaml:"retry_delay"`
	// contains filtered or unexported fields
}