core

type Adapter interface {
	// Connect starts delivering incoming messages and runs until ctx is
	// canceled. It uses deps to dispatch messages and to signal the run loop.
	Connect(ctx context.Context, deps AdapterDeps) error
	// Disconnect tears down the connection. It must be safe to call when the
	// adapter never connected.
	Disconnect() error
	// Send delivers text to channelID.
	Send(ctx context.Context, channelID, text string) error
	// Attachments extracts the platform-agnostic attachments of a message.
	Attachments(m *Message) ([]Attachment, error)
}

type AdapterDeps struct {
	// Dispatch routes an incoming message through middleware and command
	// matching.
	Dispatch func(ctx context.Context, m *Message)
	// Done signals the run loop that the connection has ended with err.
	Done func(err error)
	// Disconnect performs a full Bot.Disconnect; adapters that tear down on
	// context cancellation (e.g. Discord) use it.
	Disconnect func() error
}

type Attachment struct {
	IsImage   bool
	URL       string
	ExtraData any
}

type Bot struct {
	BotType BotType

	DiscordSession    *discordgo.Session
	SlackClient       *slack.Client
	SlackSocketClient *socketmode.Client
	// contains filtered or unexported fields
}

type BotType int

type CLIMessage struct {
	Text        string
	Attachments []Attachment
}

type Command struct {
	Pattern string
	Handler CommandHandler
	// contains filtered or unexported fields
}

type CommandHandler func(ctx context.Context, b *Bot, m *Message)

type Message struct {
	UserID    string
	ChannelID string
	Content   string

	DiscordData *discordgo.MessageCreate
	SlackData   *slackevents.MessageEvent
	CLIData     *CLIMessage
}

type Middleware func(ctx context.Context, b *Bot, m *Message, next CommandHandler)