dispatch

type Agent struct {
	SessionName string
	WindowIndex int
	PaneIndex   int
	Label       string // e.g. "session:0.1"
}

type AgentFinder interface {
	FindIdleAgents(ctx context.Context) ([]Agent, error)
}

type AgentSender interface {
	SendPrompt(ctx context.Context, agent Agent, prompt string) error
}

type CompositeNotifier struct {
	Notifiers []Notifier
}

type Config struct {
	PollInterval time.Duration
}

type Dispatcher struct {
	Source   MessageSource
	Finder   AgentFinder
	Sender   AgentSender
	Notifier Notifier
	Config   Config
	Logger   zerolog.Logger
	// contains filtered or unexported fields
}

type MessageSource interface {
	FetchMessages(ctx context.Context) ([]QueuedMessage, error)
	AckMessage(ctx context.Context, updateID int) error
}

type Notifier interface {
	Notify(ctx context.Context, chatID int64, text string) error
}

type QueuedMessage struct {
	UpdateID int
	ChatID   int64
	From     string
	Text     string
}

type SlackNotifier struct {
	Client SlackSender
}

type SlackSender interface {
	SendMessage(ctx context.Context, text string) error
}

type TelegramFetcher interface {
	GetUpdates(ctx context.Context, limit int) ([]telegram.Update, error)
	AckUpdate(ctx context.Context, updateID int) error
}

type TelegramNotifier struct {
	Client TelegramSender
}

type TelegramSender interface {
	SendMessage(ctx context.Context, chatID int64, text string) error
}

type TelegramSource struct {
	Client       TelegramFetcher
	AllowedUsers []int64
	AllowedChats []int64 // see telegram.Config.AllowedChats
	Logger       zerolog.Logger
	// contains filtered or unexported fields
}

type TmuxAgentFinder struct {
	InstanceFinder claude.InstanceFinder
	TmuxClient     claude.TmuxClient
	ProcessLister  claude.ProcessLister
}

type TmuxSender struct {
	Runner claude.CommandRunner
}