Compare commits

...

8 Commits
v0.3.1 ... main

Author SHA1 Message Date
bfe9601cd3
emoji updates 2025-07-16 15:53:22 -04:00
c6d877b101
correcting unicode for built-in bolt emojis 2025-07-16 13:35:39 -04:00
3bf763f196
adding proper intents for reactions 2025-07-16 13:04:39 -04:00
8f9205fbf0
adding emojis 2025-07-15 19:06:44 -04:00
e1bae3edea
adding more emojis 2025-07-10 15:36:25 -04:00
34fdf453c1
readme update 2025-07-10 14:36:21 -04:00
113c6927cb
better errors
- no fatal calls
- more descriptive errors
2025-07-09 18:05:55 -04:00
90a17ded2b adding reaction support (#2)
- some rework of structure to allow for more puposeful response usage
- react and response now live on the message itself
- message structs split into own file
- readme updated to use new methods

Reviewed-on: #2
Co-authored-by: jake <jake.young.dev@gmail.com>
Co-committed-by: jake <jake.young.dev@gmail.com>
2025-07-09 20:11:12 +00:00
4 changed files with 194 additions and 78 deletions

View File

@ -1,28 +1,49 @@
# bolt # bolt
The nuts and bolts of a Discord bots. Bolt is a wrapper for [discordgo](https://github.com/bwmarrin/discordgo) that provides very quick bootstrapping for simple Discord bots. The nuts-and-bolts of Discord bots. Bolt is a wrapper for [discordgo](https://github.com/bwmarrin/discordgo) that provides quick and easy bootstrapping for simple Discord bots.
## Usage ## Usage
### Token ### Token
Bolt requires a Discord bot token to run, the token must be set as an environment variable labeled "DISCORD_TOKEN" Bolt requires a Discord bot token to run, the token must be set as an environment variable labeled "DISCORD_TOKEN"
### Commands ### Commands
Commands are represented by the Command struct. Any roles in the Command struct can run the command, if the Roles field is empty anyone can run the command. Commands are represented by the command struct and contain all needed information for bolt to handle the command payload. Including the command timeout as well as the Roles allowed to run the command.
```go ```go
type Command struct { type Command struct {
Trigger string //command that triggers payload NOT including the indicator Trigger string //command that triggers payload NOT including the indicator
Payload Payload //payload function to run when a command is detected Payload Payload //payload function to run when a command is detected
Timeout time.Duration //the amount of time before command can be run again Timeout time.Duration //the amount of time before command can be run again
lastRun time.Time //timestamp of last command run lastRun time.Time //timestamp of last command run
Roles []string //roles that can use command, if none are set anyone can run the command Roles []string //roles that can use command, if none are set anyone can run
} }
``` ```
### Payload ### Payload
Payload functions are executed when a command is detected, if no errors are returned and the returned string is not empty, then the returned string is sent in reply to the command message. Payload functions are executed when a command is detected
```go ```go
type Payload func(msg Message) (string, error) type Payload func(msg Message) error
``` ```
Payload functions are given a Message argument containing the needed data for handling commands
```go
type Message struct {
Author string //username of message author
ID string //discord ID of message author
Words []string //words from message split on whitespace
Content string //entire message content
Channel string //message channel
Server string //message guild
Attachments []MessageAttachment //message attachments
}
```
The Message struct also exposes some methods to support replying to, or acknowledging command messages
```go
func (m *Message) React(emoji Reaction) error
```
The React method will react to the command message by adding the requested emoji as a reaction. Bolt comes with a few preset emoji's for easy handling but any valid emoji string can be passed.
```go
func (m *Message) Respond(res string) error
```
The Respond method will send the value of <b>res</b> in response to the command message.
### Example ### Example
```go ```go
@ -32,47 +53,57 @@ import (
"time" "time"
"code.jakeyoungdev.com/jake/bolt" "code.jakeyoungdev.com/jake/bolt"
_ "github.com/joho/godotenv/autoload"
) )
func main() { func main() {
//bolt defaults the command indicator to '.' however that can be changed with the options //bolt defaults the command indicator to '.' however that can be changed with the options
//Example: bolt.New(bolt.WithIndicator('!')) would support commands like !ping //Example: bolt.New(bolt.WithIndicator('!')) would support commands like !ping
b := bolt.New(bolt.WithLogLevel(bolt.LogLevelCmd)) b, err := bolt.New(bolt.WithLogLevel(bolt.LogLevelCmd))
if err != nil {
panic(err)
}
b.AddCommands( b.AddCommands(
// .ping can be run at any time by anyone and will respond with 'pong' // basic ping pong command, .ping can be run at anytime by anyone and will reply "pong"
bolt.Command{ bolt.Command{
Trigger: "ping", Trigger: "ping",
Payload: func(msg bolt.Message) (string, error) { Payload: func(msg bolt.Message) error {
return "pong", nil //any strings returned will be sent in response to the Discord message return msg.Respond("pong")
}, },
}, },
// .time can be run every 25 seconds by anyone and will respond with 'yer' // .react will add a +1 reaction to the command message, .react can be run by anyone at any rate
bolt.Command{
Trigger: "react",
Payload: func(msg bolt.Message) error {
return msg.React(bolt.ReactionThumbsUp)
},
},
// .time responds with the current date/time, .time can be run once every 25 seconds by any role
bolt.Command{ bolt.Command{
Trigger: "time", Trigger: "time",
Payload: func(msg bolt.Message) (string, error) { Payload: func(msg bolt.Message) error {
return "yer", nil return msg.Respond(time.Now().String())
}, },
Timeout: time.Second * 25, Timeout: time.Second * 25,
}, },
// .role can be run every 10 seconds by anyone with the 'admin' role and will respond with 'hi' // .role command can be ran every 10 seconds by anyone with the admin role and will return the string "admin"
bolt.Command{ bolt.Command{
Trigger: "role", Trigger: "role",
Payload: func(msg bolt.Message) (string, error) { Payload: func(msg bolt.Message) error {
return "hi", nil return msg.Respond("admin")
}, },
Timeout: time.Second * 10, Timeout: time.Second * 10,
Roles: []string{"admin"}, Roles: []string{"admin"},
}, },
) )
//start is a blocking call that handles safe-shutdown, all configuration and setup should be done before calling Start() //start is a blocking call that handles safe-shutdown, all configuration and setup should be done before calling Start()
err := b.Start() err = b.Start()
if err != nil { if err != nil {
panic(err) panic(err)
} }
} }
``` ```
## Development ## Development

101
bolt.go
View File

@ -20,7 +20,8 @@ const (
dg.IntentGuildMembers | dg.IntentGuildMembers |
dg.IntentGuildPresences | dg.IntentGuildPresences |
dg.IntentMessageContent | dg.IntentMessageContent |
dg.IntentsGuildMessages dg.IntentsGuildMessages |
dg.IntentGuildMessageReactions
) )
// basic bot structure containing discordgo connection as well as the command map // basic bot structure containing discordgo connection as well as the command map
@ -44,20 +45,16 @@ type Bolt interface {
timeoutCheck(msg *dg.MessageCreate, s *dg.Session, run Command) (bool, error) timeoutCheck(msg *dg.MessageCreate, s *dg.Session, run Command) (bool, error)
} }
// setup // create a new bolt interface
func init() { func New(opts ...Option) (Bolt, error) {
//validate environment variables
_, check := os.LookupEnv(TOKEN_ENV_VAR) _, check := os.LookupEnv(TOKEN_ENV_VAR)
if !check { if !check {
log.Fatalf("the %s environment variable must be set", TOKEN_ENV_VAR) return nil, fmt.Errorf("environment variable %s must be set", TOKEN_ENV_VAR)
} }
}
// create a new bolt interface
func New(opts ...Option) Bolt {
bot, err := dg.New(fmt.Sprintf("Bot %s", os.Getenv(TOKEN_ENV_VAR))) bot, err := dg.New(fmt.Sprintf("Bot %s", os.Getenv(TOKEN_ENV_VAR)))
if err != nil { if err != nil {
log.Fatal(err) return nil, fmt.Errorf("failed to create Discord session: %e", err)
} }
bot.Identify.Intents = BOT_INTENTS bot.Identify.Intents = BOT_INTENTS
@ -74,7 +71,7 @@ func New(opts ...Option) Bolt {
opt(b) opt(b)
} }
return b return b, nil
} }
// starts the bot, commands are added and the connection to Discord is opened, this is a BLOCKING // starts the bot, commands are added and the connection to Discord is opened, this is a BLOCKING
@ -85,7 +82,7 @@ func (b *bolt) Start() error {
err := b.Open() err := b.Open()
if err != nil { if err != nil {
return err return fmt.Errorf("failed to open websocket connection with Discord: %e", err)
} }
//safe shutdown handler //safe shutdown handler
@ -117,35 +114,35 @@ func (b *bolt) messageHandler(s *dg.Session, msg *dg.MessageCreate) {
//get server information //get server information
server, err := s.Guild(msg.GuildID) server, err := s.Guild(msg.GuildID)
if err != nil { if err != nil {
log.Println(err) log.Printf("failed to get guild: %e\n", err)
return return
} }
channel, err := s.Channel(msg.ChannelID) channel, err := s.Channel(msg.ChannelID)
if err != nil { if err != nil {
log.Println(err) log.Printf("failed to get channel from guild: %e\n", err)
return return
} }
//if there is no content it is likely an image or a GIF, updating message content for //if there is no content it is likely an image, gif, or sticker, updating message content for
//better logging and to avoid confusion //better logging and to avoid confusion
if len(msg.Content) == 0 { if len(msg.Content) == 0 {
msg.Content = "GIF/IMAGE" msg.Content = "[Embedded Content]"
}
if b.logLvl == LogLevelAll {
//log message
log.Printf("< %s | %s | %s > %s\n", server.Name, channel.Name, msg.Author.Username, msg.Content)
} }
//the bot will ignore it's own messages to prevent command loops //the bot will ignore it's own messages to prevent command loops
if msg.Author.ID == s.State.User.ID { if msg.Author.ID == s.State.User.ID {
if b.logLvl == LogLevelCmd { if b.logLvl == LogLevelCmd {
//log commands //log command responses
log.Printf("< %s | %s | %s > %s\n", server.Name, channel.Name, msg.Author.Username, msg.Content) log.Printf("< %s | %s | %s > %s\n", server.Name, channel.Name, msg.Author.Username, msg.Content)
} }
return return
} }
if b.logLvl == LogLevelAll {
//log message
log.Printf("< %s | %s | %s > %s\n", server.Name, channel.Name, msg.Author.Username, msg.Content)
}
//does the message have the command indicator //does the message have the command indicator
lg := len(b.indicator) lg := len(b.indicator)
if msg.Content[:lg] == b.indicator { if msg.Content[:lg] == b.indicator {
@ -173,7 +170,7 @@ func (b *bolt) handleCommand(msg *dg.MessageCreate, s *dg.Session, server *dg.Gu
//has command met its timeout requirements //has command met its timeout requirements
tc, err := b.timeoutCheck(msg, s, run) tc, err := b.timeoutCheck(msg, s, run)
if err != nil { if err != nil {
return err return fmt.Errorf("failed to calculate timeout for %s\n%e", run.Trigger, err)
} }
if !tc { if !tc {
return nil return nil
@ -183,34 +180,50 @@ func (b *bolt) handleCommand(msg *dg.MessageCreate, s *dg.Session, server *dg.Gu
if run.Roles != nil { if run.Roles != nil {
check, err := b.roleCheck(msg, s, run) check, err := b.roleCheck(msg, s, run)
if err != nil { if err != nil {
return err return fmt.Errorf("failed to perform permission checks for %s\n%e", run.Trigger, err)
} }
if !check { if !check {
return nil return nil
} }
} }
//run command payload plMsg := Message{
res, err := run.Payload(Message{ Author: msg.Author.Username,
Author: msg.Author.Username, ID: msg.Author.ID,
ID: msg.Author.ID, msgID: msg.ID,
Words: words, Words: words,
Content: msg.Content, Content: msg.Content,
Channel: channel.Name, Channel: channel.Name,
Server: server.Name, channelID: msg.ChannelID,
}) Server: server.Name,
serverID: server.ID,
if err != nil { sesh: b,
return err
} }
//if a reply is returned send back to Discord //check for file attachments
if res != "" { if len(msg.Attachments) > 0 {
reply := b.createReply(res, msg.ID, msg.ChannelID, msg.GuildID) var att []MessageAttachment
_, err := s.ChannelMessageSendComplex(msg.ChannelID, reply) for _, a := range msg.Attachments {
if err != nil { att = append(att, MessageAttachment{
return err ID: a.ID,
URL: a.URL,
ProxyURL: a.ProxyURL,
Filename: a.Filename,
ContentType: a.ContentType,
Width: a.Width,
Height: a.Height,
Size: a.Size,
DurationSecs: a.DurationSecs,
})
} }
plMsg.Attachments = att
}
//run command payload
err = run.Payload(plMsg)
if err != nil {
return fmt.Errorf("failed to execute payload function: %e", err)
} }
//update run time //update run time
@ -263,7 +276,7 @@ func (b *bolt) roleCheck(msg *dg.MessageCreate, s *dg.Session, run Command) (boo
//get role name from ID //get role name from ID
n, err := s.State.Role(msg.GuildID, r) n, err := s.State.Role(msg.GuildID, r)
if err != nil { if err != nil {
return false, err return false, fmt.Errorf("failed to get role from ID %s\n%e", msg.GuildID, err)
} }
//does this role exist in command roles //does this role exist in command roles
check := slices.Contains(run.Roles, n.Name) check := slices.Contains(run.Roles, n.Name)
@ -278,7 +291,7 @@ func (b *bolt) roleCheck(msg *dg.MessageCreate, s *dg.Session, run Command) (boo
reply := b.createReply("you do not have permissions to run that command", msg.ID, msg.ChannelID, msg.GuildID) reply := b.createReply("you do not have permissions to run that command", msg.ID, msg.ChannelID, msg.GuildID)
_, err := s.ChannelMessageSendComplex(msg.ChannelID, reply) _, err := s.ChannelMessageSendComplex(msg.ChannelID, reply)
if err != nil { if err != nil {
return false, err return false, fmt.Errorf("failed to send permission response: %e", err)
} }
return false, nil return false, nil
} }
@ -293,7 +306,7 @@ func (b *bolt) timeoutCheck(msg *dg.MessageCreate, s *dg.Session, run Command) (
reply := b.createReply(fmt.Sprintf("that command cannot be run for another %s", b.getRemainingTimeout(wait)), msg.ID, msg.ChannelID, msg.GuildID) reply := b.createReply(fmt.Sprintf("that command cannot be run for another %s", b.getRemainingTimeout(wait)), msg.ID, msg.ChannelID, msg.GuildID)
_, err := s.ChannelMessageSendComplex(msg.ChannelID, reply) _, err := s.ChannelMessageSendComplex(msg.ChannelID, reply)
if err != nil { if err != nil {
return false, err return false, fmt.Errorf("failed to send timeout response: %e", err)
} }
return false, nil return false, nil
} }

View File

@ -1,6 +1,8 @@
package bolt package bolt
import "time" import (
"time"
)
// custom Discord commands // custom Discord commands
type Command struct { type Command struct {
@ -12,14 +14,4 @@ type Command struct {
} }
// command payload functions, any strings returned are sent as a response to the command // command payload functions, any strings returned are sent as a response to the command
type Payload func(msg Message) (string, error) type Payload func(msg Message) error
// message information passed to payload function
type Message struct {
Author string //username of message author
ID string //discord ID of message author
Words []string //words from message split on whitespace
Content string //entire message content
Channel string //message channel
Server string //message guild
}

80
message.go Normal file
View File

@ -0,0 +1,80 @@
package bolt
import "fmt"
//built-in Discord reactions
type Reaction string
//a few easy-to-use emojis, Discordgo/Discord API requires them to be saved like this.
const (
ReactionThumbsUp Reaction = "👍"
ReactionThumbsDown Reaction = "👎"
ReactionHundred Reaction = "💯"
ReactionHeart Reaction = "❤️"
ReactionPinkHeart Reaction = "🩷"
ReactionOrangeHeart Reaction = "🧡"
ReactionYellowHeart Reaction = "💛"
ReactionGreenHeart Reaction = "💚"
ReactionBlueHeart Reaction = "💙"
ReactionBlackHeart Reaction = "🖤"
ReactionPointUp Reaction = "☝️"
ReactionPointDown Reaction = "👇"
ReactionHotdog Reaction = "🌭"
ReactionDog Reaction = "🐶"
ReactionCat Reaction = "🐱"
ReactionMonkey Reaction = "🐒"
ReactionGiraffe Reaction = "🦒"
ReactionDuck Reaction = "🦆"
ReactionGoose Reaction = "🪿"
ReactionWatermelon Reaction = "🍉"
ReactionHoney Reaction = "🍯"
ReactionSandwich Reaction = "🥪"
ReactionPepper Reaction = "🌶️"
ReactionNoPedestrians Reaction = "🚷"
ReactionExclamation Reaction = "❗"
ReactionDoubleExclamation Reaction = "‼️"
ReactionSkull Reaction = "💀"
ReactionSpeakingHead Reaction = "🗣️"
ReactionGreenCheck Reaction = "✅"
ReactionDragon Reaction = "🐉"
)
// information about attachments to messages
type MessageAttachment struct {
ID string
URL string
ProxyURL string
Filename string
ContentType string
Width int
Height int
Size int
DurationSecs float64
}
// represents a Discord message
type Message struct {
Author string //username of message author
ID string //discord ID of message author
msgID string //id string of message
Words []string //words from message split on whitespace
Content string //entire message content
Channel string //message channel
channelID string //id of channel message was sent in
Server string //message guild
serverID string //id of guild message was sent in
Attachments []MessageAttachment
sesh *bolt
}
// applies reaction to message
func (m *Message) React(emoji Reaction) error {
return m.sesh.MessageReactionAdd(m.channelID, m.msgID, fmt.Sprint(emoji))
}
// sends the value of res in response to the message
func (m *Message) Respond(res string) error {
rep := m.sesh.createReply(res, m.msgID, m.channelID, m.serverID)
_, err := m.sesh.ChannelMessageSendComplex(m.channelID, rep)
return err
}