daemon

type ActorAddArgs struct {
	GroupID  string            `json:"group_id"`
	ID       string            `json:"id"`
	Role     actor.Role        `json:"role"`
	CostTier actor.CostTier    `json:"cost_tier,omitempty"`
	Title    string            `json:"title,omitempty"`
	Command  []string          `json:"command"`
	Env      map[string]string `json:"env,omitempty"`
	Model    string            `json:"model,omitempty"`
	Provider string            `json:"provider,omitempty"`
	Runner   actor.RunnerKind  `json:"runner,omitempty"`
}

type ActorIDArgs struct {
	ID string `json:"id"`
}

type ActorListArgs struct {
	GroupID string `json:"group_id,omitempty"`
}

type ActorRegistry interface {
	Add(a *actor.Actor) error
	Get(id string) (*actor.Actor, bool)
	Update(id string, fn func(*actor.Actor)) error
	Remove(id string) error
	List() []*actor.Actor
	ListByGroup(groupID string) []*actor.Actor
	ListByRole(role actor.Role) []*actor.Actor
	ListByState(state actor.ActorState) []*actor.Actor
	Count() int
	CountByGroup(groupID string) int
	CountRunning() int
	SetState(id string, state actor.ActorState) error
	SetSession(id string, sessionID string) error
	SetGroup(id string, groupID string) error
}

type ActorStartArgs struct {
	ID      string            `json:"id"`
	Command string            `json:"command"`
	Args    []string          `json:"args,omitempty"`
	Cwd     string            `json:"cwd,omitempty"`
	Env     map[string]string `json:"env,omitempty"`
}

type ActorStopArgs struct {
	ID string `json:"id"`
}

type ActorUpdateArgs struct {
	ID       string            `json:"id"`
	Title    string            `json:"title,omitempty"`
	Enabled  *bool             `json:"enabled,omitempty"`
	Env      map[string]string `json:"env,omitempty"`
	Autonomy string            `json:"autonomy,omitempty"` // high/medium/low for orchestrator
}

type ActorWriteArgs struct {
	ID   string `json:"id"`
	Data string `json:"data"`
}

type AdaptiveBatchConfig struct {
	MinBatchSize      int
	MaxBatchSize      int
	MinInterval       time.Duration
	MaxInterval       time.Duration
	HighLoadThreshold int // Events per second
}

type AdaptiveBatcher struct {
	*sync.RWMutex
	// contains filtered or unexported fields
}

type AuthOverride struct {
	APIKey  string `json:"api_key,omitempty"`
	BaseURL string `json:"base_url,omitempty"`
	Enabled bool   `json:"enabled"`
}

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

type BatchConfig struct {
	MaxBatchSize  int           // Maximum events per batch
	FlushInterval time.Duration // Maximum time to wait before flushing
	Enabled       bool          // Whether batching is enabled
}

type BatchStats struct {
	TotalBatches   int64
	TotalEvents    int64
	AvgBatchSize   float64
	FlushesBySize  int64
	FlushesByTime  int64
	DroppedBatches int64
}

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

type BatchedSubscription struct {
	*Subscription
	// contains filtered or unexported fields
}

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

type Config struct {
	SocketPath     string
	LedgerPath     string
	WorkspaceRoot  string
	WorkDir        string
	ArtifactsDir   string
	CacheDir       string
	TmpDir         string
	MetaDir        string
	NetworkMode    string
	NetworkAllow   []string
	NetworkDeny    []string
	NetworkLog     string
	GroupStatePath string   // Path for group persistence (default: <meta>/groups.json)
	HTTPAddr       string   // HTTP server address (default: localhost:8080)
	AuthToken      string   // Bearer token for HTTP API authentication
	CORSOrigins    []string // Allowed origins, empty = same-origin only
	CORSMode       string   // "strict", "development", or empty

	// Connection pool settings
	MaxConnections int           // Maximum concurrent connections (0 = unlimited)
	ReadTimeout    time.Duration // HTTP read timeout
	WriteTimeout   time.Duration // HTTP write timeout
	IdleTimeout    time.Duration // HTTP idle timeout
	MaxHeaderBytes int           // Maximum header bytes (default: 1MB)

	// Rate limiting settings
	RateLimitRequests int           // Maximum requests per window (0 = unlimited)
	RateLimitWindow   time.Duration // Rate limit window duration

	// Transport configuration (for daemon RPC, not HTTP API)
	TransportMode string // "auto", "unix", "tcp", "pipe" (default: "auto")
	TCPPort       int    // TCP port for daemon RPC when TransportMode is "tcp" (default: 9876)
}

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

type DecisionCreateArgs struct {
	GroupID     string              `json:"group_id"`
	Title       string              `json:"title"`
	Description string              `json:"description,omitempty"`
	Context     string              `json:"context,omitempty"`
	Options     []decision.Option   `json:"options"`
	Importance  decision.Importance `json:"importance,omitempty"`
	CreatedBy   string              `json:"created_by"`
}

type DecisionDecideArgs struct {
	CardID    string `json:"card_id"`
	OptionID  string `json:"option_id"`
	Reason    string `json:"reason,omitempty"`
	DecidedBy string `json:"decided_by"`
}

type DecisionGetArgs struct {
	CardID string `json:"card_id"`
}

type DecisionListArgs struct {
	GroupID string              `json:"group_id,omitempty"`
	Status  decision.CardStatus `json:"status,omitempty"`
}

type DecisionVoteArgs struct {
	CardID    string `json:"card_id"`
	ActorID   string `json:"actor_id"`
	ActorRole string `json:"actor_role"`
	OptionID  string `json:"option_id"`
	Reason    string `json:"reason,omitempty"`
}

type EventBroadcaster interface {
	Subscribe(opts SubscribeOptions) *Subscription
	Unsubscribe(sub *Subscription)
	UnsubscribeByID(id string)
	OnAppend(event map[string]any)
	Count() int
	CountByGroup(groupID string) int
	CloseAll()
}

type EventsStreamArgs struct {
	GroupID string   `json:"group_id,omitempty"` // Filter by group
	ActorID string   `json:"actor_id,omitempty"` // Filter by actor
	Kinds   []string `json:"kinds,omitempty"`    // Filter by kinds
}

type FileContentResponse struct {
	Path     string `json:"path"`
	Content  string `json:"content"`
	Size     int64  `json:"size"`
	Modified string `json:"modified"`
	MimeType string `json:"mime_type"`
	Encoding string `json:"encoding"`
	IsBinary bool   `json:"is_binary"`
}

type FileEntry struct {
	Name          string    `json:"name"`
	Type          string    `json:"type"` // "file" or "directory"
	Size          int64     `json:"size"`
	Modified      time.Time `json:"modified"`
	MimeType      string    `json:"mime_type,omitempty"`
	ChildrenCount int       `json:"children_count,omitempty"`
}

type GroupCreateArgs struct {
	ID          string                 `json:"id,omitempty"`
	Title       string                 `json:"title"`
	Topic       string                 `json:"topic,omitempty"`
	Scopes      []group.Scope          `json:"scopes,omitempty"`
	ActiveScope string                 `json:"active_scope,omitempty"`
	Automation  group.AutomationConfig `json:"automation,omitempty"`
	Delivery    group.DeliveryConfig   `json:"delivery,omitempty"`
}

type GroupIDArgs struct {
	ID string `json:"id"`
}

type GroupManager interface {
	Create(cfg group.Config) (*group.Group, error)
	Get(id string) (*group.Group, bool)
	List() []*group.Group
	Delete(id string) error
	Start(id string) error
	Stop(id string) error
	Pause(id string) error
	Resume(id string) error
	ListByState(state group.State) []*group.Group
	Count() int
	CountByState(state group.State) int
	AddActorToGroup(groupID, actorID string) error
	RemoveActorFromGroup(groupID, actorID string) error
	GetActorsInGroup(groupID string) ([]string, error)
	SetState(id string, state group.State) error
	ImportDiscoveredGroups(wsCfg workspace.Config) ([]*group.Group, []error)
	SetOnStart(fn func(g *group.Group))
	SetOnStop(fn func(g *group.Group))
	SetOnResume(fn func(g *group.Group))
}

type GroupSetStateArgs struct {
	ID    string      `json:"id"`
	State group.State `json:"state"`
}

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

type Handler func(ctx context.Context, req Request) Response

type InboxListArgs struct {
	ActorID    string `json:"actor_id"`
	UnreadOnly bool   `json:"unread_only,omitempty"`
}

type InboxMarkReadArgs struct {
	ActorID   string `json:"actor_id"`
	MessageID string `json:"message_id,omitempty"` // Empty = mark all
}

type Ledger interface {
	Append(event ledger.Event) error
	ReadAll() ([]ledger.Event, error)
	ReadFrom(offset int) ([]ledger.Event, error)
	Tail(n int) ([]ledger.Event, error)
	FilterByKind(kind string) ([]ledger.Event, error)
	FilterByActor(actorID string) ([]ledger.Event, error)
	LastN(n int) ([]ledger.Event, error)
	Count() (int, error)
}

type LedgerAppendArgs struct {
	Kind    string         `json:"kind"`
	ActorID string         `json:"actor_id,omitempty"`
	Data    map[string]any `json:"data,omitempty"`
}

type LedgerReadArgs struct {
	Offset int    `json:"offset,omitempty"`
	Limit  int    `json:"limit,omitempty"`
	Kind   string `json:"kind,omitempty"`
}

type LedgerTailArgs struct {
	N int `json:"n"`
}

type LogEntry struct {
	Timestamp string                 `json:"timestamp"`
	Level     LogLevel               `json:"level"`
	Message   string                 `json:"message"`
	Component string                 `json:"component,omitempty"`
	Fields    map[string]interface{} `json:"fields,omitempty"`
}

type LogLevel string

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

type MessageReplyArgs struct {
	GroupID   string         `json:"group_id"`
	From      string         `json:"from"`
	ReplyToID string         `json:"reply_to_id"`
	Content   string         `json:"content"`
	Data      map[string]any `json:"data,omitempty"`
}

type MessageSendArgs struct {
	GroupID string         `json:"group_id"`
	From    string         `json:"from"`
	To      string         `json:"to,omitempty"` // Empty = broadcast
	Kind    string         `json:"kind"`
	Content string         `json:"content"`
	Data    map[string]any `json:"data,omitempty"`
}

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

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

type Request struct {
	Op   string          `json:"op"`
	Args json.RawMessage `json:"args,omitempty"`
}

type Response struct {
	OK    bool            `json:"ok"`
	Data  json.RawMessage `json:"data,omitempty"`
	Error string          `json:"error,omitempty"`
}

type RoleDefaultsRequest struct {
	Command          string            `json:"command"`
	Args             []string          `json:"args"`
	WorkingDir       string            `json:"working_dir"`
	Env              map[string]string `json:"env"`
	AutoStart        bool              `json:"auto_start"`
	RestartOnFailure bool              `json:"restart_on_failure"`
	ModelOverride    string            `json:"model_override,omitempty"`
	MaxConcurrent    int               `json:"max_concurrent,omitempty"`
	TimeoutMinutes   int               `json:"timeout_minutes,omitempty"`
}

type RoleDefaultsResponse struct {
	Role             string            `json:"role"`
	Command          string            `json:"command"`
	Args             []string          `json:"args"`
	WorkingDir       string            `json:"working_dir"`
	Env              map[string]string `json:"env"`
	AutoStart        bool              `json:"auto_start"`
	RestartOnFailure bool              `json:"restart_on_failure"`
	ModelOverride    string            `json:"model_override,omitempty"`
	MaxConcurrent    int               `json:"max_concurrent,omitempty"`
	TimeoutMinutes   int               `json:"timeout_minutes,omitempty"`
}

type ScheduledTask struct {
	ID       string
	Name     string
	Interval time.Duration
	LastRun  time.Time
	NextRun  time.Time
	Handler  func() error
	Enabled  bool
}

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

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

type ServerOption func(*Server)

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

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

type SubscribeOptions struct {
	ID        string   // Subscription ID (auto-generated if empty)
	GroupID   string   // Only events from this group
	ActorID   string   // Only events from this actor
	Kinds     []string // Only these event kinds
	QueueSize int      // Queue buffer size (default 100)
}

type Subscription struct {
	ID      string
	GroupID string          // Filter by group (empty = all groups)
	By      string          // Filter by actor (empty = all actors)
	Kinds   map[string]bool // Filter by kind (empty = all kinds)
	Queue   chan map[string]any
	// contains filtered or unexported fields
}

type TermAttachArgs struct {
	ActorID string `json:"actor_id"`
}

type TerminalSession struct {
	ID       string
	GroupID  string
	FilePath string
	Editor   string // "vim" or "nano"

	// Channels for I/O
	InputCh  chan []byte
	OutputCh chan []byte
	DoneCh   chan struct{}
	// contains filtered or unexported fields
}

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

type TerminalWSMessage struct {
	Type string `json:"type"`
	Data string `json:"data"`
	Cols int    `json:"cols,omitempty"`
	Rows int    `json:"rows,omitempty"`
}

type ValidationError struct {
	Field   string `json:"field"`
	Message string `json:"message"`
}

type WhiteboardApproveArgs struct {
	GroupID    string `json:"group_id"`
	ProposalID string `json:"proposal_id"`
	ApprovedBy string `json:"approved_by"`
	Role       string `json:"role"`
}

type WhiteboardGetArgs struct {
	GroupID string `json:"group_id"`
	Section string `json:"section,omitempty"`
}

type WhiteboardMergeArgs struct {
	GroupID    string `json:"group_id"`
	ProposalID string `json:"proposal_id"`
	MergedBy   string `json:"merged_by"`
	Role       string `json:"role"`
}

type WhiteboardProposeArgs struct {
	GroupID     string `json:"group_id"`
	By          string `json:"by"`
	Section     string `json:"section"`
	Content     string `json:"content"`
	Description string `json:"description,omitempty"`
}