background

type AgentRunner interface {
	Run(ctx context.Context, sessionKey string, prompt string) (string, error)
}

type ChannelNotifier interface {
	SendMessage(ctx context.Context, channel string, message string) error
}

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

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

type MonitorSummary struct {
	Total     int `json:"total"`
	Pending   int `json:"pending"`
	Running   int `json:"running"`
	Done      int `json:"done"`
	Failed    int `json:"failed"`
	Cancelled int `json:"cancelled"`
}

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

type Origin struct {
	Channel string `json:"channel"`
	Session string `json:"session"`
}

type Projection interface {
	PrepareTask(ctx context.Context, prompt string, origin Origin) (string, error)
	SyncTask(ctx context.Context, snap TaskSnapshot) error
}

type Status int

type Task struct {
	ID            string
	Status        Status
	Prompt        string
	Result        string
	Error         string
	OriginChannel string // channel that initiated the request (e.g. "telegram", "slack")
	OriginSession string // original session key
	StartedAt     time.Time
	CompletedAt   time.Time
	TokensUsed    int
	// contains filtered or unexported fields
}

type TaskSnapshot struct {
	ID            string    `json:"id"`
	Status        Status    `json:"status"`
	StatusText    string    `json:"status_text"`
	Prompt        string    `json:"prompt"`
	Result        string    `json:"result"`
	Error         string    `json:"error,omitempty"`
	OriginChannel string    `json:"origin_channel"`
	OriginSession string    `json:"origin_session"`
	StartedAt     time.Time `json:"started_at"`
	CompletedAt   time.Time `json:"completed_at,omitempty"`
	TokensUsed    int       `json:"tokens_used"`
}

type TypingIndicator interface {
	StartTyping(ctx context.Context, channel string) (stop func(), err error)
}