orchestrator

type Bot interface {
	Start(ctx context.Context) error
	Stop() error
	SendMessage(ctx context.Context, msg *OutgoingMessage) error
	SendTyping(ctx context.Context, channelID string) error
	RegisterCommands(ctx context.Context) error
	RemoveCommands(ctx context.Context) error
	OnMessage(handler func(ctx context.Context, msg *IncomingMessage))
	OnInteraction(handler func(ctx context.Context, i any))
	BotUserID() string
	CreateChannel(ctx context.Context, guildID, name string) (string, error)
	CreateThread(ctx context.Context, channelID, name string) (string, error)
	GetChannelParentID(ctx context.Context, channelID string) (string, error)
}

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

type IncomingMessage struct {
	ChannelID    string
	GuildID      string
	AuthorID     string
	AuthorName   string
	Content      string
	MessageID    string
	IsBotMention bool
	IsReplyToBot bool
	HasPrefix    bool
	IsDM         bool
	Timestamp    time.Time
}

type Interaction struct {
	ChannelID   string
	GuildID     string
	CommandName string
	Options     map[string]string
}

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

type OutgoingMessage struct {
	ChannelID        string
	Content          string
	ReplyToMessageID string
}

type Runner interface {
	Run(ctx context.Context, req *agent.AgentRequest) (*agent.AgentResponse, error)
	Cleanup(ctx context.Context) error
}

type Scheduler interface {
	Start(ctx context.Context) error
	Stop() error
	AddTask(ctx context.Context, task *db.ScheduledTask) (int64, error)
	RemoveTask(ctx context.Context, taskID int64) error
	ListTasks(ctx context.Context, channelID string) ([]*db.ScheduledTask, error)
	SetTaskEnabled(ctx context.Context, taskID int64, enabled bool) error
	ToggleTask(ctx context.Context, taskID int64) (bool, error)
	EditTask(ctx context.Context, taskID int64, schedule, taskType, prompt *string) error
}

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