25 Commits

Author SHA1 Message Date
748addcd2b adding message method to join vc's 2025-08-17 20:52:35 -04:00
eb64bdf803 starting research for vc support 2025-08-17 20:37:22 -04:00
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
113fcbf2d1 adding author id to message struct 2025-06-25 19:12:34 -04:00
dd20b73b76 adding log level option (#1)
Reviewed-on: #1
Co-authored-by: jake <jake.young.dev@gmail.com>
Co-committed-by: jake <jake.young.dev@gmail.com>
2025-06-25 22:51:32 +00:00
5f72f58c74 readme update 2025-06-11 17:37:59 -04:00
2d70c450a9 merge fix 2025-06-08 02:27:46 -04:00
08ffade13d [chore] comments and function scope
- methods no longer exported if not used
- readme update
- comments updated
2025-06-08 02:26:06 -04:00
0b39a0996f Update README.md 2025-06-07 13:41:19 +00:00
9ffab89ebf adding TODO comments 2025-06-07 09:31:00 -04:00
b8bfb76b83 code cleanup, split handler func 2025-06-07 00:34:26 -04:00
d1a5de82fe removing named return values
- avoiding confusion w long functions for naked returns
2025-06-04 23:22:10 -04:00
5b32d09a27 better naming standards 2025-06-04 23:15:00 -04:00
cc77adeadc adding license file 2025-06-04 21:03:17 -04:00
4e44b972d8 readme update 2025-06-04 21:00:23 -04:00
dc3ef04778 removing public stop method
- safe shutdown handled in library
2025-06-04 20:44:25 -04:00
55b7a717f6 adding options
- ability to update indicator
2025-06-04 18:28:27 -04:00
d9ff09da6b readme update 2025-06-04 17:08:50 -04:00
6 changed files with 477 additions and 156 deletions

19
LICENSE Normal file
View File

@@ -0,0 +1,19 @@
Copyright 2025 jake
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in all
copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
SOFTWARE.

107
README.md
View File

@@ -1,69 +1,110 @@
# bolt
Base Discord bot framework
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.
## Introduction
bolt is a wrapper for Discordgo to provide very quick and easy setup for simple Discord bots. The only code required to run bolt is the command handler functions, this provides developers with the ability to have text-based commands on a Discord server without all the bootstrapping and setup usually required. Any strings returned from the Payload function will be sent back to the Discord server as a reply to the command message.
## Usage
### Token
Bolt requires a Discord bot token to run, the token must be set as an environment variable labeled "DISCORD_TOKEN"
## Basic Usage
bolt allows developers to create a Discord bot with simply a discord bot token and a few lines of Go code, the below example creates a Discord bot and registers three commands: ".test", ".time", and ".role"
### Commands
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
type Command struct {
Trigger string //command that triggers payload NOT including the indicator
Payload Payload //payload function to run when a command is detected
Timeout time.Duration //the amount of time before command can be run again
lastRun time.Time //timestamp of last command run
Roles []string //roles that can use command, if none are set anyone can run
}
```
### Payload
Payload functions are executed when a command is detected
```go
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
```go
package main
import (
"log"
"os"
"os/signal"
"syscall"
"time"
"code.jakeyoungdev.com/jake/bolt"
_ "github.com/joho/godotenv/autoload"
)
func main() {
b := bolt.New()
//bolt defaults the command indicator to '.' however that can be changed with the options
//Example: bolt.New(bolt.WithIndicator('!')) would support commands like !ping
b, err := bolt.New(bolt.WithLogLevel(bolt.LogLevelCmd))
if err != nil {
panic(err)
}
b.AddCommands(
// .test can be run at any time by anyone
// basic ping pong command, .ping can be run at anytime by anyone and will reply "pong"
bolt.Command{
Trigger: ".test",
Payload: func(msg bolt.Message) (res string, err error) {
return "nah", nil //any strings returned will be sent in response to the Discord message
Trigger: "ping",
Payload: func(msg bolt.Message) error {
return msg.Respond("pong")
},
},
// .time can be run every 25 seconds by anyone
// .react will add a +1 reaction to the command message, .react can be run by anyone at any rate
bolt.Command{
Trigger: ".time",
Payload: func(msg bolt.Message) (res string, err error) {
return "yer", nil
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{
Trigger: "time",
Payload: func(msg bolt.Message) error {
return msg.Respond(time.Now().String())
},
Timeout: time.Second * 25,
},
// .role can be run every 10 seconds by anyone with the 'admin' role
// .role command can be ran every 10 seconds by anyone with the admin role and will return the string "admin"
bolt.Command{
Trigger: ".role",
Payload: func(msg bolt.Message) (res string, err error) {
return "hi", nil
Trigger: "role",
Payload: func(msg bolt.Message) error {
return msg.Respond("admin")
},
Timeout: time.Second * 10,
Roles: []string{"admin"},
},
)
_ = b.Start()
//set up safe CTRL-C
sigChannel := make(chan os.Signal, 1)
signal.Notify(sigChannel, syscall.SIGINT)
log.Println("bot running")
<-sigChannel
if err := b.Stop(); err != nil {
//start is a blocking call that handles safe-shutdown, all configuration and setup should be done before calling Start()
err = b.Start()
if err != nil {
panic(err)
}
}
```
## Development
bolt is in heavy development at the moment and may break occasionally before a v1 release, it is currently in a testing phase and should not be used until tagged.
bolt is in development at the moment and may break occasionally before a v1 release

299
bolt.go
View File

@@ -1,11 +1,14 @@
package bolt
import (
"errors"
"fmt"
"log"
"os"
"os/signal"
"slices"
"strings"
"syscall"
"time"
dg "github.com/bwmarrin/discordgo"
@@ -18,169 +21,237 @@ const (
dg.IntentGuildMembers |
dg.IntentGuildPresences |
dg.IntentMessageContent |
dg.IntentsGuildMessages
dg.IntentsGuildMessages |
dg.IntentGuildMessageReactions
)
// basic bot structure containing discordgo connection as well as the command map
type bolt struct {
*dg.Session //holds discordgo internals
Commands map[string]Command //maps trigger phrase to command struct for fast lookup
commands map[string]Command //maps trigger phrase to command struct for fast lookup
indicator string //the indicator used to detect whether a message is a command
logLvl LogLevel //determines how much the bot logs
}
type Bolt interface {
Start() error
Stop() error
AddCommands(cmd Command)
AddCommands(cmd ...Command)
//filtered methods
stop() error
messageHandler(s *dg.Session, msg *dg.MessageCreate)
handleCommand(msgEvent *MessageCreateEvent, s *dg.Session, lg int) error
createReply(content, message, channel, guild string) *dg.MessageSend
getRemainingTimeout(timeout time.Time) string
}
// setup
func init() {
//validate environment variables
_, check := os.LookupEnv(TOKEN_ENV_VAR)
if !check {
log.Fatalf("the %s environment variable must be set", TOKEN_ENV_VAR)
}
roleCheck(guild string, roles []string, s *dg.Session, run Command) (bool, error)
timeoutCheck(msgID, channelID, guildID string, s *dg.Session, run Command) (bool, error)
joinUserVoice(guild, user string, s *dg.Session) (*dg.VoiceConnection, error)
}
// create a new bolt interface
func New() *bolt {
func New(opts ...Option) (Bolt, error) {
_, check := os.LookupEnv(TOKEN_ENV_VAR)
if !check {
return nil, fmt.Errorf("environment variable %s must be set", TOKEN_ENV_VAR)
}
bot, err := dg.New(fmt.Sprintf("Bot %s", os.Getenv(TOKEN_ENV_VAR)))
if err != nil {
log.Fatal(err)
return nil, fmt.Errorf("failed to create Discord session: %e", err)
}
bot.Identify.Intents = BOT_INTENTS
return &bolt{
b := &bolt{
Session: bot,
Commands: make(map[string]Command, 0),
commands: make(map[string]Command, 0),
logLvl: LogLevelAll,
}
//set default command indicator
b.indicator = "."
//apply options
for _, opt := range opts {
opt(b)
}
return b, nil
}
// adds command handler and starts the bot
// starts the bot, commands are added and the connection to Discord is opened, this is a BLOCKING call
// that handles safe shutdown of the bot
func (b *bolt) Start() error {
//register commands and open connection
b.AddHandler(b.messageHandler)
return b.Open()
err := b.Open()
if err != nil {
return fmt.Errorf("failed to open websocket connection with Discord: %e", err)
}
//safe shutdown handler
sigChannel := make(chan os.Signal, 1)
signal.Notify(sigChannel, syscall.SIGINT)
<-sigChannel
if err := b.stop(); err != nil {
return err
}
return nil
}
// stops the bot
func (b *bolt) Stop() error {
func (b *bolt) stop() error {
return b.Close()
}
// adds commands to bot command map for use
func (b *bolt) AddCommands(cmd ...Command) {
for _, c := range cmd {
b.Commands[c.Trigger] = c
b.commands[c.Trigger] = c
}
}
// handler function that parses message data and executes any command payloads
// handler function that parses message data, handles logging the message based on logLevel, and executes
// the payload function in a goroutine
func (b *bolt) messageHandler(s *dg.Session, msg *dg.MessageCreate) {
//get server information
server, err := s.Guild(msg.GuildID)
if err != nil {
log.Println(err)
log.Printf("failed to get guild: %e\n", err)
return
}
channel, err := s.Channel(msg.ChannelID)
if err != nil {
log.Println(err)
log.Printf("failed to get channel from guild: %e\n", err)
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
if len(msg.Content) == 0 {
msg.Content = "GIF/IMAGE"
msg.Content = "[Embedded Content]"
}
//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
if msg.Author.ID == s.State.User.ID {
if b.logLvl == LogLevelCmd || b.logLvl == LogLevelAll {
//log command responses
log.Printf("< %s | %s | %s > %s\n", server.Name, channel.Name, msg.Author.Username, msg.Content)
}
return
}
//does the message have the command indicator "."
if msg.Content[:1] == "." {
words := strings.Split(msg.Content, " ")
run, ok := b.Commands[words[0]]
if !ok {
return //command doesn't exist, maybe log or respond to author
if b.logLvl == LogLevelAll {
//log message
log.Printf("< %s | %s | %s > %s\n", server.Name, channel.Name, msg.Author.Username, msg.Content)
}
//has command met its timeout requirements
wait := run.LastRun.Add(run.Timeout)
if !time.Now().After(wait) {
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)
//does the message have the command indicator
lg := len(b.indicator)
if msg.Content[:lg] == b.indicator {
mCreate := &MessageCreateEvent{
AuthorUsername: msg.Author.Username,
AuthorID: msg.Author.ID,
AuthorRoles: msg.Member.Roles,
MsgID: msg.ID,
Msg: msg.Content,
MsgChanID: msg.ChannelID,
MsgGuildID: msg.GuildID,
MsgAttachments: msg.Attachments,
}
if b.logLvl == LogLevelCmd {
//log commands
log.Printf("< %s | %s | %s > %s\n", mCreate.MsgGuildName, mCreate.MsgChanName, mCreate.AuthorUsername, mCreate.Msg)
}
//handled in its own goroutine to allow for async commands
go func() {
err := b.handleCommand(mCreate, s, lg)
if err != nil {
log.Println(err)
}
return //running too soon
}()
}
}
// parses command from message and handles timeout checks, role checks, and command execution. All command responses are sent back to Discord
func (b *bolt) handleCommand(msgEvent *MessageCreateEvent, s *dg.Session, lg int) error {
words := strings.Split(msgEvent.Msg, " ")
run, ok := b.commands[words[0][lg:]]
if !ok {
return nil //command doesn't exist, maybe log or respond to author
}
//has command met its timeout requirements
tc, err := b.timeoutCheck(msgEvent.MsgID, msgEvent.MsgChanID, msgEvent.MsgGuildID, s, run)
if err != nil {
return fmt.Errorf("failed to calculate timeout for %s\n%e", run.Trigger, err)
}
if !tc {
return nil
}
//does user have correct permissions
if run.Roles != nil {
var found bool
for _, r := range msg.Member.Roles {
n, err := s.State.Role(msg.GuildID, r)
check, err := b.roleCheck(msgEvent.MsgGuildID, msgEvent.AuthorRoles, s, run)
if err != nil {
log.Println(err)
return
return fmt.Errorf("failed to perform permission checks for %s\n%e", run.Trigger, err)
}
check := slices.Contains(run.Roles, n.Name)
if check {
found = true
if !check {
reply := b.createReply("you do not have permissions to run that command", msgEvent.MsgID, msgEvent.MsgChanID, msgEvent.MsgGuildID)
_, err := s.ChannelMessageSendComplex(msgEvent.MsgChanID, reply)
if err != nil {
return err
}
return nil
}
}
//can't find role, don't run command
if !found {
reply := b.createReply("you do not have permissions to run that command", msg.ID, msg.ChannelID, msg.GuildID)
_, err := s.ChannelMessageSendComplex(msg.ChannelID, reply)
if err != nil {
log.Println(err)
//populate message struct exposed to client
plMsg := Message{
Author: msgEvent.AuthorUsername,
ID: msgEvent.AuthorID,
msgID: msgEvent.MsgID,
Words: words,
Content: msgEvent.Msg,
Channel: msgEvent.MsgChanName,
channelID: msgEvent.MsgChanID,
Server: msgEvent.MsgGuildName,
serverID: msgEvent.MsgGuildID,
sesh: b,
}
return
//check for file attachments
if len(msgEvent.MsgAttachments) > 0 {
var att []MessageAttachment
for _, a := range msgEvent.MsgAttachments {
att = append(att, MessageAttachment{
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
res, err := run.Payload(Message{
Author: msg.Author.Username,
Words: words,
Message: msg.Content,
Channel: channel.Name,
Server: server.Name,
})
err = run.Payload(plMsg)
if err != nil {
log.Println(err)
return
}
//if a reply is returned send back to Discord
if res != "" {
reply := b.createReply(res, msg.ID, msg.ChannelID, msg.GuildID)
_, err := s.ChannelMessageSendComplex(msg.ChannelID, reply)
if err != nil {
log.Println(err)
return
}
return fmt.Errorf("failed to execute payload function: %e", err)
}
//update run time
run.LastRun = time.Now()
b.Commands[run.Trigger] = run
}
run.lastRun = time.Now()
b.commands[run.Trigger] = run
return nil
}
// basic wrapper function to create easy Discord responses
@@ -217,3 +288,71 @@ func (b *bolt) getRemainingTimeout(timeout time.Time) string {
return fmt.Sprintf("%d%s", timeLeft, metric)
}
// checks if the author of msg has the correct role to run the requested command
func (b *bolt) roleCheck(guild string, roles []string, s *dg.Session, run Command) (bool, error) {
var found bool
//loop thru author roles, there may be a better way to check for this UNION
//TODO: improve role search performance to support bigger lists
for _, r := range roles {
//get role name from ID
n, err := s.State.Role(guild, r)
if err != nil {
return false, fmt.Errorf("failed to get role from ID %s\n%e", guild, err)
}
//does this role exist in command roles
check := slices.Contains(run.Roles, n.Name)
if check {
found = true
break
}
}
//can't find role, don't run command
if !found {
return false, nil
}
return true, nil
}
// check if the command timeout has been met, responding with remaining time if timeout has not been met yet.
func (b *bolt) timeoutCheck(msgID, channelID, guildID string, s *dg.Session, run Command) (bool, error) {
wait := run.lastRun.Add(run.Timeout)
if !time.Now().After(wait) {
reply := b.createReply(fmt.Sprintf("that command cannot be run for another %s", b.getRemainingTimeout(wait)), msgID, channelID, guildID)
_, err := s.ChannelMessageSendComplex(channelID, reply)
if err != nil {
return false, fmt.Errorf("failed to send timeout response: %e", err)
}
return false, nil
}
return true, nil
}
func (b *bolt) joinUserVoice(guild, user string, s *dg.Session) (*dg.VoiceConnection, error) {
g, err := s.State.Guild(guild)
if err != nil {
return nil, err
}
var chanID string
for _, x := range g.VoiceStates {
if user == x.UserID {
chanID = x.ChannelID
}
}
if chanID == "" {
return nil, errors.New("user is not in a voice channel")
}
//joining voice channel: false = not muted, true = deafened
dgv, err := s.ChannelVoiceJoin(guild, chanID, false, true)
if err != nil {
return nil, err
}
return dgv, nil
}

View File

@@ -1,24 +1,17 @@
package bolt
import "time"
import (
"time"
)
// custom Discord commands
type Command struct {
Trigger string //.command that triggers payload INCLUDING the '.'
Trigger string //command that triggers payload NOT including the indicator
Payload Payload //payload function to run when a command is detected
Timeout time.Duration //the amount of time before command can run again
LastRun time.Time //timestamp of last command run
Roles []string //roles that can use command
Timeout time.Duration //the amount of time before command can be run again
lastRun time.Time //timestamp of last command run
Roles []string //roles that can use command, if none are set anyone can run the command
}
// payload function type handling commands. The returned error is parsed and, if no error,
// is detected then the response string (res) will be sent in response to the command message
type Payload func(msg Message) (res string, err error)
// contains the basic information needed for a message command
type Message struct {
Author string //username of message author
Words []string //words from message split on whitespace
Message string //entire message content
Channel string //channel message was sent in
Server string //guild message was sent in
}
// command payload functions, any strings returned are sent as a response to the command
type Payload func(msg Message) error

104
message.go Normal file
View File

@@ -0,0 +1,104 @@
package bolt
import (
"fmt"
dg "github.com/bwmarrin/discordgo"
)
// 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 = "🐉"
)
// struct containing message event fields to prevent passing MessageCreate events and holding up routines
type MessageCreateEvent struct {
AuthorUsername string
AuthorID string
AuthorRoles []string
MsgID string
Msg string
MsgChanID string
MsgChanName string
MsgGuildID string
MsgGuildName string
MsgAttachments []*dg.MessageAttachment
}
// 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
}
// joins the message author's voice channel. Returns the voice connection object, this connection must be cleaned
// up by the client to prevent issues
func (m *Message) JoinVoiceChannel() (*dg.VoiceConnection, error) {
return m.sesh.joinUserVoice(m.serverID, m.ID, m.sesh.Session)
}

25
option.go Normal file
View File

@@ -0,0 +1,25 @@
package bolt
type Option func(b *bolt)
type LogLevel int
const (
LogLevelAll LogLevel = iota //logs all messages, and errors
LogLevelCmd LogLevel = iota //log only commands and responses, and errors
LogLevelErr LogLevel = iota //logs only errors
)
// sets the substring that must be present at the beginning of the message to indicate a command
func WithIndicator(i string) Option {
return func(b *bolt) {
b.indicator = i
}
}
// sets the log level to determine how much bolt logs
func WithLogLevel(lvl LogLevel) Option {
return func(b *bolt) {
b.logLvl = lvl
}
}