daemon

type AgentConfig struct {
	// ID is the unique agent identifier.
	ID string `yaml:"id"`

	// Type is the agent type (tmux, process).
	Type string `yaml:"type"`

	// TmuxSession is the tmux session name (for type=tmux).
	TmuxSession string `yaml:"tmux_session"`

	// TmuxPane is the tmux pane identifier (for type=tmux).
	TmuxPane string `yaml:"tmux_pane"`
}

type AgentInfo struct {
	ID     string `json:"id"`
	Type   string `json:"type"`
	Target string `json:"target"` // e.g., "tmux:session:pane"
	Status string `json:"status"` // "online" or "offline"
}

type AgentMessageParams struct {
	// FromAgentID is the source agent sending the message.
	FromAgentID string `json:"from_agent_id"`

	// ToAgentID is the destination agent to receive the message.
	ToAgentID string `json:"to_agent_id"`

	// Message is the text content to send.
	Message string `json:"message"`
}

type AgentMessageResult struct {
	EventID   string `json:"event_id"`
	Delivered bool   `json:"delivered"`
}

type AgentsResult struct {
	Agents []AgentInfo `json:"agents"`
}

type ChannelInfo struct {
	ChannelID string `json:"channel_id"`
	AgentID   string `json:"agent_id"`
	Provider  string `json:"provider"`
}

type ChannelMapping struct {
	// ChannelID is the full channel identifier (provider:chatid).
	ChannelID string `yaml:"channel_id"`

	// AgentID is the target agent ID.
	AgentID string `yaml:"agent_id"`
}

type ChannelsResult struct {
	Channels []ChannelInfo `json:"channels"`
}

type ChatConfig struct {
	// Discord configuration (optional).
	Discord *DiscordConfig `yaml:"discord"`

	// Telegram configuration (optional).
	Telegram *TelegramConfig `yaml:"telegram"`

	// WhatsApp configuration (optional).
	WhatsApp *WhatsAppConfig `yaml:"whatsapp"`

	// Channels maps chat channels to agents.
	Channels []ChannelMapping `yaml:"channels"`
}

type ChatSender interface {
	SendMessage(ctx context.Context, channelID, content string) error
}

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

type Config struct {
	// DataDir is the directory for storing data (default: ~/.agentcomms).
	DataDir string

	// SocketPath is the Unix socket path for IPC.
	SocketPath string

	// Logger is the structured logger.
	Logger *slog.Logger
}

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

type DaemonConfig struct {
	// DataDir overrides the default data directory.
	DataDir string `yaml:"data_dir"`

	// LogLevel sets the logging level (debug, info, warn, error).
	LogLevel string `yaml:"log_level"`

	// Agents defines the available agents.
	Agents []AgentConfig `yaml:"agents"`

	// Chat holds chat provider configuration (omnichat).
	Chat *ChatConfig `yaml:"chat"`
}

type DiscordConfig struct {
	// Token is the Discord bot token.
	Token string `yaml:"token"`

	// GuildID is the Discord guild (server) ID for filtering.
	GuildID string `yaml:"guild_id"`
}

type ErrorInfo struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type EventInfo struct {
	ID        string         `json:"id"`
	AgentID   string         `json:"agent_id"`
	ChannelID string         `json:"channel_id"`
	Type      string         `json:"type"`
	Role      string         `json:"role"`
	Timestamp time.Time      `json:"timestamp"`
	Status    string         `json:"status"`
	Payload   map[string]any `json:"payload"`
}

type EventsParams struct {
	AgentID string `json:"agent_id"`
	Limit   int    `json:"limit,omitempty"`
	Since   string `json:"since,omitempty"` // Event ID to start after
}

type EventsResult struct {
	Events []EventInfo `json:"events"`
}

type InterruptParams struct {
	AgentID string `json:"agent_id"`
	Reason  string `json:"reason,omitempty"`
}

type InterruptResult struct {
	EventID   string `json:"event_id"`
	Delivered bool   `json:"delivered"`
}

type PingResult struct {
	Pong bool `json:"pong"`
}

type ReplyParams struct {
	// ChannelID is the target channel (format: "provider:chatid").
	ChannelID string `json:"channel_id"`

	// Message is the text to send.
	Message string `json:"message"`

	// AgentID is the agent sending the message (for event tracking).
	AgentID string `json:"agent_id,omitempty"`
}

type ReplyResult struct {
	EventID   string `json:"event_id"`
	Delivered bool   `json:"delivered"`
}

type Request struct {
	// ID is a unique request identifier for correlation.
	ID string `json:"id"`

	// Method is the RPC method name.
	Method string `json:"method"`

	// Params contains method-specific parameters.
	Params json.RawMessage `json:"params,omitempty"`
}

type Response struct {
	// ID matches the request ID.
	ID string `json:"id"`

	// Result contains the method result (on success).
	Result json.RawMessage `json:"result,omitempty"`

	// Error contains error details (on failure).
	Error *ErrorInfo `json:"error,omitempty"`
}

type SendParams struct {
	AgentID string `json:"agent_id"`
	Message string `json:"message"`
}

type SendResult struct {
	EventID   string `json:"event_id"`
	Delivered bool   `json:"delivered"`
}

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

type ServerConfig struct {
	SocketPath string
	Client     *ent.Client
	Router     *router.Router
	DaemonCfg  *DaemonConfig
	ChatSender ChatSender
	Providers  []string
	Logger     *slog.Logger
}

type StatusResult struct {
	Running   bool      `json:"running"`
	StartedAt time.Time `json:"started_at"`
	Agents    int       `json:"agents"`
	Providers []string  `json:"providers"`
}

type TelegramConfig struct {
	// Token is the Telegram bot token.
	Token string `yaml:"token"`
}

type WhatsAppConfig struct {
	// DBPath is the SQLite database path for session storage.
	DBPath string `yaml:"db_path"`
}