protocol

type ActivationHook func(context.Context, *InboundMessage) error

type AgentUpdate struct {
	CallID, 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
	Bridge                BridgeID
	ID, Question, Details string
	ConversationID        string
	Options               []AskUserQuestionOption
	Multiple              bool
	SlackReply            *SlackReplyTarget
}

type BridgeID string

type Broadcast struct {
	Sender          BridgeID
	Message         *OutboundMessage
	Delivery        *OutboundMessage
	Relay           *ExternalMCPRelay
	RelayReply      *InboundMessage
	RelayChannel    string
	RelayCleanup    *InboundMessage
	RelayResponse   chan BroadcastReply
	Acknowledgement chan BroadcastAcknowledgement
}

type BroadcastAcknowledgement struct {
	Status BroadcastStatus
	Err    error
}

type BroadcastPublisher chan<- Broadcast

type BroadcastReply struct {
	Message *InboundMessage
	Err     error
}

type BroadcastStatus string

type Channels struct {
	Broadcasts chan Broadcast
}

type CronProgress struct {
	Thinking, Message func(context.Context, string) error
}

type CronRunResult struct {
	Text, VerbatimMessage string
	Attachments           []OutboundAttachment
}

type CronjobMessage struct {
	RelativePath, Agent, RanAt string
}

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
	Bridge                                                  BridgeID
	Label, Text                                             string
	VerbatimMessage                                         string
	VerbatimAttachments                                     []OutboundAttachment
	Attachments                                             []InboundAttachment
	SlackReply                                              *SlackReplyTarget
	HadAttachments, HadNonImageAttachments, Human, GoalTurn bool
	AttachmentWarnings                                      []string
	Kind                                                    InboundKind
	ConversationID                                          string
	Metadata                                                map[string]string
	Workflow                                                *WorkflowInvocation
	Response                                                chan Response
	// 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 LintFinding struct {
	Code, Severity, Path, Message string
}

type LintRequest struct {
	Context OverlayContext
}

type LintResult struct {
	Findings []LintFinding
}

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

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

type OutboundMessage struct {
	Text, ProgressText                 string
	Source                             Source
	Bridge                             BridgeID
	Targets                            []OutputTarget
	ConversationID, TurnID             string
	SessionEntryID                     int64
	ExternalConversationID             string
	Agent                              string
	Cronjob                            *CronjobMessage
	Sequence                           int
	PostProgressText, Complete         bool
	SlackReply                         *SlackReplyTarget
	Attachments                        []OutboundAttachment
	GoalTurn, GoalComplete, GoalActive bool
	GoalTurnNumber, GoalMaxTurns       int
	WorkflowAgent                      *AgentUpdate
	WorkflowPhase                      *PhaseUpdate
	WorkflowTerminal                   Terminal
	Response                           chan Response
	// contains filtered or unexported fields
}

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

type OutputTarget string

type OverlayContext struct {
	BaseOverlay string
	Files       []OverlayFile
}

type OverlayFile struct {
	Path, Content string
}

type OverlaySpec struct {
	Spec string
}

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
	Details                      string
}

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)
	InterruptConversation(conversationID string) *InboundMessage
	InterruptThread(target TextConversationTarget) (*InboundMessage, error)
	RegisterThread(target TextConversationTarget, agent string) (created bool, err error)
	RegisterCronThread(ctx context.Context, target TextConversationTarget, agent string) 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)
	SubmitWhenActive(ctx context.Context, target TextConversationTarget, inbound *InboundMessage, activation ActivationHook) (bool, error)
	StashThreadQueueItem(ctx context.Context, target TextConversationTarget, item *ThreadQueueItem) error
	ThreadQueueItems(ctx context.Context, target TextConversationTarget) ([]ThreadQueueItem, error)
	DeleteThreadQueueItem(ctx context.Context, target TextConversationTarget, id string) error
	ScheduledMessages(ctx context.Context, target TextConversationTarget) (map[string]ScheduledMessageState, error)
	ThreadBusy(target TextConversationTarget) bool
	PickQueuedWork(ctx context.Context, target TextConversationTarget) error
}

type ReloadRequest struct {
	Reason string
}

type Response struct {
	Payload ResponsePayload
	Err     error
}

type ResponseKind string

type ResponsePayload interface {
	ResponseKind() ResponseKind
}

type RestartRequest struct {
	Reason string
}

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 SideAskRequest struct {
	ConversationID    string
	SessionEntryID    int64
	Agent, Question   string
	Thinking, Message func(context.Context, string) error
}

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

type Source string

type StartNewThreadRequest struct {
	Source                                                   Source
	Bridge                                                   BridgeID
	SourceConversationID, CurrentAgent, Agent, Title, Prompt string
	AllowedAgents                                            []string
	SlackReply                                               *SlackReplyTarget
	Response                                                 chan Response
}

type StartNewThreadResponse struct {
	Request *StartNewThreadRequest
	Root    chan StartNewThreadRootResult
	Err     chan error
}

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 TextResponse struct {
	Kind    ResponseKind
	Message *OutboundMessage
}

type ThreadQueueItem struct {
	ID             string
	ConversationID string
	Message        string
	Principal      string
	StashAt        time.Time
	Position       int
	ParkAfter      string
	SlackChannel   string
	SlackTS        string
}

type TryTurnRequest struct {
	Context        OverlayContext
	Agent, Prompt  string
	ConversationID string
}

type TryTurnResult struct {
	ConversationID, Thinking, Answer string
}

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

type WorkflowDescription struct{ Name, Description string }

type WorkflowInvocation struct {
	RunID, Name, Args string
}