interactions

type Answer struct {
	Text       string            `json:"text,omitempty"`
	Values     map[string]string `json:"values,omitempty"`
	MessageID  string            `json:"message_id,omitempty"`
	ReceivedAt int64             `json:"received_at"`
}

type CreateRequest struct {
	ID             string
	Kind           Kind
	Route          Route
	Origin         Origin
	Questions      []Question
	PromptSummary  string
	ApprovalAction string
	ExpiresAt      time.Time
}

type DeliveryState string

type Event struct {
	SchemaVersion  string    `json:"schema_version"`
	EventID        string    `json:"event_id"`
	CommitSequence uint64    `json:"commit_sequence,omitempty"`
	InteractionID  string    `json:"interaction_id"`
	Type           EventType `json:"type"`
	From           Status    `json:"from,omitempty"`
	To             Status    `json:"to,omitempty"`
	Outcome        Outcome   `json:"outcome,omitempty"`
	Revision       int64     `json:"revision"`
	Sequence       int64     `json:"sequence"`
	EmittedAt      int64     `json:"emitted_at"`
	Code           string    `json:"code,omitempty"`
	Success        *bool     `json:"success,omitempty"`
}

type EventObservation struct {
	Event  Event
	Record Record
}

type EventType string

type Kind string

type ObservationSnapshot struct {
	Through uint64
	Records []Record
	Events  []Event
}

type Observer func(EventObservation)

type Option struct {
	Label       string `json:"label"`
	Description string `json:"description,omitempty"`
}

type Options struct {
	TerminalRetention time.Duration
	MaxRecords        int
	MaxEvents         int
	MaxSnapshotBytes  int
	Now               func() time.Time
}

type Origin struct {
	TurnID                 string              `json:"turn_id"`
	ExecutionID            string              `json:"execution_id,omitempty"`
	ToolCallID             string              `json:"tool_call_id"`
	ToolName               string              `json:"tool_name"`
	TaskID                 string              `json:"task_id,omitempty"`
	ContinuationSessionKey string              `json:"continuation_session_key,omitempty"`
	ArgumentHash           string              `json:"argument_hash,omitempty"`
	ExecutionContext       *bus.InboundContext `json:"execution_context,omitempty"`
}

type Outcome string

type Question struct {
	ID          string   `json:"id"`
	Header      string   `json:"header,omitempty"`
	Question    string   `json:"question"`
	Options     []Option `json:"options,omitempty"`
	MultiSelect bool     `json:"multi_select,omitempty"`
}

type Record struct {
	ID                  string        `json:"id"`
	ShortID             string        `json:"short_id"`
	Kind                Kind          `json:"kind"`
	Status              Status        `json:"status"`
	Outcome             Outcome       `json:"outcome,omitempty"`
	Revision            int64         `json:"revision"`
	LastEventSeq        int64         `json:"last_event_sequence"`
	Route               Route         `json:"route"`
	Origin              Origin        `json:"origin"`
	Questions           []Question    `json:"questions,omitempty"`
	PromptSummary       string        `json:"prompt_summary,omitempty"`
	ApprovalAction      string        `json:"approval_action,omitempty"`
	Answer              *Answer       `json:"answer,omitempty"`
	CreatedAt           int64         `json:"created_at"`
	UpdatedAt           int64         `json:"updated_at"`
	ExpiresAt           int64         `json:"expires_at"`
	ResolvedAt          int64         `json:"resolved_at,omitempty"`
	CleanupAfter        int64         `json:"cleanup_after,omitempty"`
	DeliveryTries       int           `json:"delivery_tries,omitempty"`
	LastDeliveryAt      int64         `json:"last_delivery_at,omitempty"`
	DeliveryError       string        `json:"delivery_error,omitempty"`
	PromptDelivered     bool          `json:"prompt_delivered,omitempty"`
	PromptDeliveryState DeliveryState `json:"prompt_delivery_state,omitempty"`
	FinalDeliveryTries  int           `json:"final_delivery_tries,omitempty"`
	LastFinalDeliveryAt int64         `json:"last_final_delivery_at,omitempty"`
	FinalDelivered      bool          `json:"final_delivered,omitempty"`
	FinalDeliveryError  string        `json:"final_delivery_error,omitempty"`
	FinalDeliveryState  DeliveryState `json:"final_delivery_state,omitempty"`
	ResumeTries         int           `json:"resume_tries,omitempty"`
	LastResumeAt        int64         `json:"last_resume_at,omitempty"`
	ResumeError         string        `json:"resume_error,omitempty"`
	FailureCode         string        `json:"failure_code,omitempty"`
	FailureDetail       string        `json:"failure_detail,omitempty"`
	ApprovalConsumedAt  int64         `json:"approval_consumed_at,omitempty"`
}

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

type Route struct {
	AgentID         string `json:"agent_id"`
	SessionKey      string `json:"session_key"`
	RouteSessionKey string `json:"route_session_key,omitempty"`
	Channel         string `json:"channel"`
	AccountID       string `json:"account_id,omitempty"`
	ChatID          string `json:"chat_id"`
	ChatType        string `json:"chat_type,omitempty"`
	TopicID         string `json:"topic_id,omitempty"`
	SpaceID         string `json:"space_id,omitempty"`
	SpaceType       string `json:"space_type,omitempty"`
	SenderID        string `json:"sender_id"`
}

type Snapshot struct {
	SchemaVersion  string   `json:"schema_version"`
	CommitSequence uint64   `json:"commit_sequence,omitempty"`
	Records        []Record `json:"records"`
	Events         []Event  `json:"events,omitempty"`
}

type Stats struct {
	RecordCount      int
	EventCount       int
	NonterminalCount int
	SnapshotBytes    int
	Retention        time.Duration
	MaxRecords       int
	MaxEvents        int
	MaxSnapshotBytes int
	OverBudget       bool
}

type Status string

type Store interface {
	Create(CreateRequest) (Record, error)
	Get(string) (Record, bool)
	ListNonterminal() []Record
	FindWaitingByRoute(Route) []Record
	Prune(time.Time) error
}

type SuspensionRequest struct {
	Kind          Kind
	Questions     []Question
	PromptSummary string
	Timeout       time.Duration
}

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