events

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 {
	Requests   chan Request
	Broadcasts chan Broadcast
}

type CronjobMessage struct {
	RelativePath, Agent, RanAt string
}

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

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                                                *workflow.RunRequest
	Response                                                chan Response
	// contains filtered or unexported fields
}

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

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                      *workflow.AgentUpdate
	WorkflowPhase                      *workflow.PhaseUpdate
	WorkflowTerminal                   workflow.Terminal
	Response                           chan Response
	// contains filtered or unexported fields
}

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

type OutputTarget string

type Request struct {
	Sender    BridgeID
	Operation RequestOperation
	Response  chan Response
}

type RequestKind string

type RequestOperation interface {
	RequestKind() RequestKind
}

type Response struct {
	Payload ResponsePayload
	Err     error
}

type ResponseKind string

type ResponsePayload interface {
	ResponseKind() ResponseKind
}

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 TextConversationTarget struct{ ChannelID, MessageID, ThreadID string }

type TextRequest struct {
	Kind                                      RequestKind
	Target                                    TextConversationTarget
	Agent, Objective, CheckScript, Name, Args string
	ConversationID                            string
	MaxTurns                                  int
	Inbound                                   *InboundMessage
}

type TextResponse struct {
	Kind         ResponseKind
	Message      *OutboundMessage
	Handled      bool
	Created      bool
	Reserved     bool
	Agent        string
	Descriptions []workflow.Description
	Inbound      *InboundMessage
	Release      chan struct{}
}

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