protocol

type AgentUpdate struct {
	PhaseID, Label, Activity string
}

type AskUserQuestionAnswer struct {
	Selected []string `json:"selected"`
	Custom   string   `json:"custom"`
	Source   Source   `json:"source"`
}

type AskUserQuestionOption struct{ Label, Value, Description string }

type AskUserQuestionRequest struct {
	Source                Source
	ID, Question, Details string
	ConversationID        string
	Options               []AskUserQuestionOption
	Multiple              bool
	SlackReply            *SlackReplyTarget
}

type Conversation struct {
	ID, Agent, CreatedBy string
	Settled              bool
}

type CronRunResult struct {
	ConversationID string
}

type CronjobMessage struct {
	RelativePath, Agent, RanAt string
}

type Event struct {
	Message         *OutboundMessage
	Acknowledgement chan error
}

type ExternalMCPRelay struct {
	ConversationID, ExternalConversationID, Agent, Text string
	Attachments                                         []OutboundAttachment
}

type GoalRequest struct {
	Objective, CheckScript string
	MaxTurns               int
}

type InboundAttachment struct {
	Name, MIMEType string
	Data           []byte
}

type InboundContent struct {
	Text                   string
	TextAttachments        []string
	Attachments            []InboundAttachment
	HadAttachments         bool
	HadNonImageAttachments bool
	AttachmentWarnings     []string
}

type InboundKind string

type InboundMessage struct {
	Source                                                  Source
	Label, Text                                             string
	Attachments                                             []InboundAttachment
	SlackReply                                              *SlackReplyTarget
	HadAttachments, HadNonImageAttachments, Human, GoalTurn bool
	AttachmentWarnings                                      []string
	Kind                                                    InboundKind
	ConversationID                                          string
	Metadata                                                map[string]string
	Workflow                                                *WorkflowInvocation
	SyncDestination                                         string
	RequireOutputDecision                                   bool
	Cronjob                                                 *CronjobMessage
	// contains filtered or unexported fields
}

type InboundResponse struct {
	Text        string
	Attachments []OutboundAttachment
	Err         error
}

type LaterWorkKind string

type LaterWorkRow struct {
	Kind        LaterWorkKind
	Queue       ThreadQueueItem
	ScheduledID string
	Scheduled   ScheduledMessageState
}

type OneOffCronjob struct {
	Agent, Prompt, RelativePath, TextChannel string
	ConversationID                           string
}

type OutboundAttachment struct {
	ID                 string
	Name, MIMEType     string
	Data               []byte
	OriginalUnverified bool
	Size               int64 // Stored byte length for metadata-only reads.
}

type OutboundMessage struct {
	ConsumedID, ConsumedText           string
	ConsumedRawText                    string
	ConsumedSource                     Source
	Text, ProgressText                 string
	ConversationID, TurnID             string
	ExternalConversationID             string
	Agent                              string
	Model, SourceConversationID        string
	ReasoningEffort                    *string
	Cronjob                            *CronjobMessage
	Complete                           bool
	SlackReply                         *SlackReplyTarget
	Attachments                        []OutboundAttachment
	GoalTurn, GoalComplete, GoalActive bool
	GoalTurnNumber, GoalMaxTurns       int
	WorkflowAgent                      *AgentUpdate
	WorkflowPhase                      *PhaseUpdate
	WorkflowTerminal                   Terminal
	// contains filtered or unexported fields
}

type OutboundPublisher interface {
	PublishOutbound(context.Context, *OutboundMessage) error
}

type PendingSteer struct {
	Text, Principal, SlackChannel, SlackTS, SlackThreadTS string
}

type PendingSteersSink struct {
	Set func(conversationID string, steers []PendingSteer) error
}

type PhaseStatus string

type PhaseUpdate struct {
	PhaseID, Name                string
	Status                       PhaseStatus
	Scheduled, Running, Complete int
}

type PrimaryTextRouter interface {
	StartThread(ctx context.Context, agent string, target TextConversationTarget, inbound *InboundMessage) error
	StartGoalInThread(ctx context.Context, agent, objective, checkScript string, maxTurns int, target TextConversationTarget, inbound *InboundMessage) error
	StartWorkflowInThread(ctx context.Context, agent, name, args string, target TextConversationTarget, inbound *InboundMessage) error
	ReserveWorkflowTurn(target TextConversationTarget) (release func(), reserved bool, err error)
	WorkflowDescriptions() ([]WorkflowDescription, error)
	SkillDescriptions(agent string) ([]SkillDescription, error)
	InterruptConversation(conversationID string) *InboundMessage
	InterruptThread(target TextConversationTarget) (*InboundMessage, error)
	RegisterThread(target TextConversationTarget, agent string) (created bool, err error)
	ThreadAgent(target TextConversationTarget) (agent string, handled bool, err error)
	SwitchThreadAgent(target TextConversationTarget, agent string) (bool, error)
	SubmitThreadReply(ctx context.Context, target TextConversationTarget, inbound *InboundMessage) (bool, error)
	StashThreadQueueItem(ctx context.Context, target TextConversationTarget, item *ThreadQueueItem) error
	ThreadQueueItems(target TextConversationTarget) ([]ThreadQueueItem, error)
	DeleteThreadQueueItem(ctx context.Context, target TextConversationTarget, id string) (bool, error)
	PromoteThreadQueueItem(ctx context.Context, target TextConversationTarget, id string) (bool, error)
	ScheduledMessages(target TextConversationTarget) (map[string]ScheduledMessageState, error)
	ThreadBusy(target TextConversationTarget) bool
}

type ScheduledMessageState struct {
	ConversationID string        `json:"conversation_id,omitempty"`
	Agent          string        `json:"agent,omitempty"`
	Message        string        `json:"message,omitempty"`
	DueAt          time.Time     `json:"due_at,omitzero"`
	Recurring      bool          `json:"recurring,omitempty"`
	Interval       time.Duration `json:"interval,omitempty"`
}

type SessionSummary struct {
	ConversationID, LastMessage string
	LastUpdated                 time.Time
}

type SkillDescription struct {
	Name, Description string
}

type SlackReplyTarget struct {
	ChannelID, MessageTS, ThreadTS   string
	RecipientTeamID, RecipientUserID string
}

type Source string

type StartNewThreadRequest struct {
	Source                             Source
	CurrentAgent, Agent, Title, Prompt string
	AllowedAgents                      []string
	SlackReply                         *SlackReplyTarget
}

type StartNewThreadResult struct {
	ConversationID string `json:"conversation_id"`
	URL            string `json:"url,omitempty"`
}

type StartNewThreadRootResult struct {
	Target TextConversationTarget
	URL    string
}

type Terminal string

type TextConversationTarget struct{ ChannelID, MessageID, ThreadID string }

type ThreadQueueItem struct {
	Kind           InboundKind
	ID             string
	ConversationID string
	Message        string
	Content        InboundContent
	Source         Source
	SlackReply     *SlackReplyTarget
	Principal      string
	StashAt        time.Time
	Position       int
	ParkAfter      string
	SlackChannel   string
	SlackTS        string
}

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

type WorkflowDescription struct{ Name, Description string }

type WorkflowInvocation struct {
	Name, Args string
}