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))
	OnChannelDelete(handler func(ctx context.Context, channelID string, isThread bool))
	BotUserID() string
	CreateChannel(ctx context.Context, guildID, name string) (string, error)
	CreateThread(ctx context.Context, channelID, name, mentionUserID string) (string, error)
	DeleteThread(ctx context.Context, threadID 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
}