protocol

type AdversarialOption func(*adversarialConfig)

type AwaitingInputError struct {
	Request InputRequest
}

type BrainstormingOption func(*brainstormingConfig)

type BreakoutOption func(*breakoutConfig)

type Config map[string]any

type ConfigProvider interface {
	Config() Config
}

type ContextConfig struct {
	MaxPromptTokens    int                 `json:"max_prompt_tokens" yaml:"max_prompt_tokens"`
	RollingWindow      int                 `json:"rolling_window" yaml:"rolling_window"`
	MaxToolOutputChars int                 `json:"max_tool_output_chars" yaml:"max_tool_output_chars"`
	Summarization      SummarizationConfig `json:"summarization" yaml:"summarization"`
}

type ContextMessageBuilder func(thread []agent.Message, currentRound, maxRounds int) agent.Message

type DivergentPromptBuilder func(input DivergentPromptInput) string

type DivergentPromptInput struct {
	BasePrompt string
	Scope      string
	Round      int
	MaxRounds  int
	IdeaTarget int
}

type Factory func(cfg Config) Protocol

type InputOption func(*InputOptions)

type InputOptions struct {
	Timeout  time.Duration
	Deadline time.Time
}

type InputRequest struct {
	RequestID       string
	ParticipantID   string
	ParticipantName string
	Context         string
	RequestedAt     time.Time
	TimeoutAt       time.Time
}

type InteractionPromptBuilder func(input InteractionPromptInput) string

type InteractionPromptInput struct {
	BasePrompt string
	Scope      string
	Board      string
	Round      int
	MaxRounds  int
	TurnIndex  int
	Speakers   int
	Move       string
}

type ModeratorClosingBuilder func(input ModeratorClosingInput) ModeratorPrompt

type ModeratorClosingInput struct {
	Scope     string
	Board     string
	Shortlist []string
	Tally     []VoteTally
}

type ModeratorInterjectionBuilder func(input ModeratorInterjectionInput) ModeratorPrompt

type ModeratorInterjectionInput struct {
	Scope        string
	Board        string
	Progress     float64
	CurrentRound int
	MaxRounds    int
	Recent       []string
}

type ModeratorOpeningBuilder func(input ModeratorOpeningInput) ModeratorPrompt

type ModeratorOpeningInput struct {
	Scope  string
	Agenda string
	Seed   string
}

type ModeratorPrompt struct {
	System            string
	User              string
	MaxToolIterations int
}

type ModeratorShortlistBuilder func(input ModeratorShortlistInput) ModeratorPrompt

type ModeratorShortlistInput struct {
	Scope  string
	Board  string
	Thread []string
	Limit  int
}

type ModeratorSynthesisBuilder func(input ModeratorSynthesisInput) ModeratorPrompt

type ModeratorSynthesisInput struct {
	Scope          string
	DivergentBrief string
}

type Participant interface {
	Identifier() string
	DisplayName() string
	IsHuman() bool
	IsAgent() bool
	Agent() (agent.Agent, bool)
}

type Protocol interface {
	ID() string
	Participants() []Participant
	Init(ctx context.Context, sess Session) error
	OnMessage(ctx context.Context, sess Session, msg agent.Message) error
	OnEvent(ctx context.Context, sess Session, ev event.Event) error
	Shutdown(ctx context.Context, sess Session) error
}

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

type ResultProvider interface {
	Result() map[string]any
}

type RunRequest struct {
	Messages          []agent.Message
	SystemMessages    []agent.Message
	Params            map[string]any
	MaxToolIterations int
	MaxRunDuration    time.Duration
	Tools             []string // Tool IDs to add for this run
	ToolPolicy        tool.Policy
	Context           ContextConfig
	OutputSchema      any // Optional: constrains output to this type (overrides agent-level schema)
	Silent            bool
}

type ScopeFallback func(userQuestion, configuredScope string) string

type ScopeRefinementPrompt func(userQuestion, configuredScope string) (systemPrompt, userPrompt string)

type Session interface {
	ID() string
	Name() string
	Tags() []string
	Metadata() map[string]any
	ProtocolID() string
	Participants() []Participant
	Facilitator() *agent.Agent
	Groups() map[string][]Participant
	Emit(event.Event) error
	EmitWithContext(ctx context.Context, ev event.Event) error
	RunAgent(ctx context.Context, agent agent.Agent, req RunRequest) (agent.Message, error)
	RunTurn(ctx context.Context, participant Participant, req RunRequest, opts ...TurnOption) (agent.Message, error)
	AwaitInput(ctx context.Context, participant Participant, turnContext string, resume TurnResume, opts ...InputOption) error
	// Tool registration for session-scoped tools
	RegisterTool(t any) error
	RegisterTools(tools ...any) error
	AddDefaultTools(ids ...string)
	DefaultTools() []string
}

type StatefulProtocol interface {
	Protocol
	GetState() (map[string]any, error)
	SetState(state map[string]any) error
}

type SummarizationConfig struct {
	Enabled         bool `json:"enabled" yaml:"enabled"`
	ThresholdTokens int  `json:"threshold_tokens" yaml:"threshold_tokens"`
}

type TimeoutProvider interface {
	DefaultTimeout() time.Duration
}

type TurnOption func(*TurnOptions)

type TurnOptions struct {
	Context  string
	Resume   TurnResume
	Timeout  time.Duration
	Deadline time.Time
}

type TurnResume func(ctx context.Context, response agent.Message) error

type VoteBallot struct {
	Agent     string   `json:"agent"`
	Picks     []string `json:"picks"`
	Rationale string   `json:"rationale,omitempty"`
	Raw       string   `json:"raw,omitempty"`
}

type VotePromptBuilder func(input VotePromptInput) string

type VotePromptInput struct {
	BasePrompt string
	Scope      string
	Shortlist  []string
	Picks      int
}

type VoteTally struct {
	Idea  string `json:"idea"`
	Score int    `json:"score"`
	Votes int    `json:"votes"`
}