bcr.go

package bcr

import (
	"strings"
	"sync"
	"time"

	"github.com/diamondburned/arikawa/v3/api"
	"github.com/diamondburned/arikawa/v3/discord"
	"github.com/diamondburned/arikawa/v3/gateway"
	"github.com/diamondburned/arikawa/v3/session/shard"
	"github.com/diamondburned/arikawa/v3/state"
)

// Version returns the current brc version
func Version() string {
	return "0.18.0"
}

// RequiredIntents are the intents required for the command handler
const RequiredIntents = gateway.IntentGuildMessages | gateway.IntentGuildMessageReactions | gateway.IntentDirectMessages | gateway.IntentDirectMessageReactions | gateway.IntentGuilds

// Router is the command router
type Router struct {
	BotOwners []string

	Prefixes []string
	Prefixer Prefixer

	ShardManager *shard.Manager
	Bot          *discord.User
	Logger       *Logger

	BlacklistFunc   func(Contexter) bool
	HelpCommand     func(*Context) error
	DefaultMentions *api.AllowedMentions
	EmbedColor      discord.Color
	// global permission check
	// "routing" is true if it's being executed during routing, false if it's executed just for the name
	// return: permission name, allowed/blocked, error message
	PermissionCheck func(ctx *Context, routing bool) (name string, allowed bool, data api.SendMessageData)

	ReactTimeout time.Duration

	cooldowns *CooldownCache
	cmds      map[string]*Command
	cmdMu     sync.RWMutex

	SlashGroups []*Group

	// maps + mutexes
	reactions     map[reactionKey]reactionInfo
	reactionMu    sync.RWMutex
	messages      map[messageKey]messageInfo
	messageMu     sync.RWMutex
	buttons       map[buttonKey]buttonInfo
	buttonMu      sync.RWMutex
	slashButtons  map[buttonKey]slashButtonInfo
	slashButtonMu sync.RWMutex
}

// New creates a new router object
func New(s *shard.Manager, owners, prefixes []string) *Router {
	r := &Router{
		ShardManager: s,
		BotOwners:    owners,
		Prefixes:     prefixes,
		EmbedColor:   discord.DefaultEmbedColor,

		Logger: NewStdlibLogger(false),

		DefaultMentions: &api.AllowedMentions{
			Parse: []api.AllowedMentionType{api.AllowUserMention},
		},

		ReactTimeout: 15 * time.Minute,

		cmds:         make(map[string]*Command),
		reactions:    make(map[reactionKey]reactionInfo),
		messages:     make(map[messageKey]messageInfo),
		buttons:      make(map[buttonKey]buttonInfo),
		slashButtons: make(map[buttonKey]slashButtonInfo),
		cooldowns:    newCooldownCache(),
	}

	// set prefixer
	r.Prefixer = r.DefaultPrefixer

	// add required handlers
	r.AddHandler(r.ReactionAdd)
	r.AddHandler(r.ReactionRemove)
	r.AddHandler(r.ReactionMessageDelete)
	r.AddHandler(r.MsgHandlerCreate)
	r.AddHandler(r.ButtonHandler)

	return r
}

// NewWithState creates a new router with a state.
// The token is automatically prefixed with `Bot `.
func NewWithState(token string, owners []discord.UserID, prefixes []string) (*Router, error) {
	return NewWithIntents(token, owners, prefixes, RequiredIntents)
}

// NewWithIntents creates a new router with a state, with the specified intents.
// The token is automatically prefixed with `Bot `.
func NewWithIntents(token string, owners []discord.UserID, prefixes []string, intents gateway.Intents) (*Router, error) {
	ownerStrings := make([]string, 0)
	for _, o := range owners {
		ownerStrings = append(ownerStrings, o.String())
	}

	newShard := state.NewShardFunc(func(m *shard.Manager, s *state.State) {
		s.AddIntents(intents)
	})

	m, err := shard.NewManager("Bot "+token, newShard)
	if err != nil {
		return nil, err
	}

	r := New(m, ownerStrings, prefixes)
	return r, nil
}

// AddCommand adds a command to the router
func (r *Router) AddCommand(c *Command) *Command {
	if c.Options != nil && c.SlashCommand == nil {
		panic("command.Options set without command.SlashCommand being set")
	}

	c.id = sGen.Get()
	r.cmdMu.Lock()
	defer r.cmdMu.Unlock()
	r.cmds[strings.ToLower(c.Name)] = c

	for _, a := range c.Aliases {
		r.cmds[strings.ToLower(a)] = c
	}

	return c
}

// AddHandler adds a handler to all States in this Router
func (r *Router) AddHandler(v interface{}) {
	r.ShardManager.ForEach(func(s shard.Shard) {
		state := s.(*state.State)

		state.AddHandler(v)
	})
}

// StateFromGuildID returns the state.State for the given guild ID
func (r *Router) StateFromGuildID(guildID discord.GuildID) (st *state.State, id int) {
	if guildID.IsValid() {
		s, shardID := r.ShardManager.FromGuildID(guildID)
		return s.(*state.State), shardID
	}

	s := r.ShardManager.Shard(0)
	return s.(*state.State), 0
}