package main import ( "fmt" "sort" "strings" "github.com/gempir/go-twitch-irc/v4" "github.com/nouryxd/nourybot/pkg/commands" "github.com/nouryxd/nourybot/pkg/common" "github.com/nouryxd/nourybot/pkg/lastfm" "github.com/nouryxd/nourybot/pkg/owm" ) // handleCommand takes in a twitch.PrivateMessage and then routes the message // to the function that is responsible for each command and knows how to deal // with it accordingly. func (app *application) handleCommand(message twitch.PrivateMessage) { var reply string if message.Channel == "forsen" { return } // Increments the counter how many commands have been used, // called in the ping command. go common.CommandUsed() go app.InitUser(message.User.Name, message.User.ID) // commandName is the actual name of the command without the prefix. // e.g. `()ping` would be `ping`. commandName := strings.ToLower(strings.SplitN(message.Message, " ", 3)[0][2:]) // cmdParams are additional command parameters. // e.g. `()weather san antonio` // cmdParam[0] is `san` and cmdParam[1] = `antonio`. // // Since Twitch messages are at most 500 characters I use a // maximum count of 500+10 just to be safe. // https://discuss.dev.twitch.tv/t/missing-client-side-message-length-check/21316 cmdParams := strings.SplitN(message.Message, " ", 500) // msgLen is the amount of words in a message without the prefix. // Useful to check if enough cmdParams are provided. msgLen := len(strings.SplitN(message.Message, " ", -2)) userLevel := app.GetUserLevel(message) // target is the channelname the message originated from and // where the TwitchClient should send the response target := message.Channel app.Log.Infow("Command received", // "message", message, // Pretty taxing "message.Message", message.Message, "message.Channel", target, "commandName", commandName, "cmdParams", cmdParams, "msgLen", msgLen, "userLevel", userLevel, ) go app.LogCommand(message, commandName, userLevel) // A `commandName` is every message starting with `()`. // Hardcoded commands have a priority over database commands. // Switch over the commandName and see if there is a hardcoded case for it. // If there was no switch case satisfied, query the database if there is // a data.CommandModel.Name equal to the `commandName` // If there is return the data.CommandModel.Text entry. // Otherwise we ignore the message. switch commandName { case "": if msgLen == 1 { reply = "xd" } // -------------------------------- // pleb commands // -------------------------------- case "bttv": if msgLen < 2 { reply = "Not enough arguments provided. Usage: ()bttv " } else { reply = commands.Bttv(cmdParams[1]) } case "betterttv": if msgLen < 2 { reply = "Not enough arguments provided. Usage: ()bttv " } else { reply = commands.Bttv(cmdParams[1]) } case "coin": reply = commands.Coinflip() case "coinflip": reply = commands.Coinflip() case "cf": reply = commands.Coinflip() case "currency": if msgLen < 4 { reply = "Not enough arguments provided. Usage: ()currency 10 USD to EUR" } else { reply, _ = commands.Currency(cmdParams[1], cmdParams[2], cmdParams[4]) } case "osrs": reply = commands.OSRS(message.Message[7:len(message.Message)]) case "preview": reply = commands.Preview(cmdParams[1]) case "thumbnail": reply = commands.Preview(cmdParams[1]) case "ffz": reply = commands.Ffz(cmdParams[1]) case "frankerfacez": reply = commands.Ffz(cmdParams[1]) case "game": if msgLen == 1 { reply = app.getChannelGameByUsername(target) } else if msgLen == 2 { reply = app.getChannelGameByUsername(cmdParams[1]) } else { return } case "ddg": reply = commands.DuckDuckGo(message.Message[6:len(message.Message)]) case "youtube": reply = commands.Youtube(message.Message[10:len(message.Message)]) case "godoc": reply = commands.Godocs(message.Message[8:len(message.Message)]) case "godocs": reply = commands.Godocs(message.Message[9:len(message.Message)]) case "google": reply = commands.Google(message.Message[9:len(message.Message)]) case "duckduckgo": reply = commands.DuckDuckGo(message.Message[13:len(message.Message)]) case "seventv": reply = commands.SevenTV(cmdParams[1]) case "7tv": reply = commands.SevenTV(cmdParams[1]) case "lastfm": if msgLen == 1 { reply = app.UserCheckLastFM(message) } else { // Default to first argument supplied being the name // of the user to look up recently played. reply = lastfm.LastFmUserRecent(target, cmdParams[1]) } case "help": if msgLen > 1 { app.commandHelp(target, cmdParams[1], message.User.Name, message) } case "nourybot": reply = "Lidl Twitch bot made by @nouryxd. Prefix: ()" case "phonetic": if msgLen == 1 { reply = "Not enough arguments provided. Usage: ()phonetic " } else { reply, _ = commands.Phonetic(message.Message[11:len(message.Message)]) } case "ping": reply = commands.Ping(app.Environment) // ()weather case "weather": if msgLen == 1 { app.UserCheckWeather(message) } else if msgLen < 2 { reply = "Not enough arguments provided." } else { reply, _ = owm.Weather(message.Message[10:len(message.Message)]) } case "rxkcd": reply, _ = commands.RandomXkcd() case "randomxkcd": reply, _ = commands.RandomXkcd() case "xkcd": reply, _ = commands.Xkcd() case "uid": reply, _ = app.getUserID(cmdParams[1]) case "userid": reply, _ = app.getUserID(cmdParams[1]) case "uname": reply, _ = app.userIDtoUsername(cmdParams[1]) case "username": reply, _ = app.userIDtoUsername(cmdParams[1]) case "commands": reply = app.ListChannelCommands(message.Channel) case "timers": reply = fmt.Sprintf("https://bot.noury.li/timer/%s", message.Channel) case "title": if msgLen == 1 { reply = app.getChannelTitleByUsername(target) } else if msgLen == 2 { reply = app.getChannelTitleByUsername(cmdParams[1]) } else { return } case "set": switch cmdParams[1] { case "lastfm": app.SetUserLastFM(cmdParams[2], message) case "location": app.SetUserLocation(message) } // -------------------------------- // 100 user level // trusted // vip // -------------------------------- case "wa": if userLevel >= 100 { reply = commands.WolframAlphaQuery(message.Message[5:len(message.Message)], app.Config.wolframAlphaAppID) } case "query": if userLevel >= 100 { reply = commands.WolframAlphaQuery(message.Message[8:len(message.Message)], app.Config.wolframAlphaAppID) } case "debug": switch cmdParams[1] { case "user": if userLevel >= 100 { app.DebugUser(cmdParams[2], message) } case "command": if userLevel >= 100 { app.DebugCommand(cmdParams[2], message) } case "env": if userLevel >= 100 { reply = app.Environment } case "timers": if userLevel >= 100 { app.DebugChannelTimers(message.Channel) } case "eventsub": if userLevel >= 1000 { reply = app.listEventSubSubscriptions() } } // -------------------------------- // 250 user level // twitch mod/broadcaster // -------------------------------- // empty for now // -------------------------------- // 420 user level // dank // -------------------------------- case "catbox": if userLevel >= 420 { go app.NewDownload("catbox", target, cmdParams[1], message) } case "kappa": if userLevel >= 420 { go app.NewDownload("kappa", target, cmdParams[1], message) } case "notify": switch cmdParams[1] { case "live": if userLevel >= 420 { reply = app.createLiveSubscription(target, cmdParams[2]) } case "offline": if userLevel >= 420 { reply = app.createOfflineSubscription(target, cmdParams[2]) } } case "unnotify": switch cmdParams[1] { case "live": if userLevel >= 420 { reply = app.deleteLiveSubscription(target, cmdParams[2]) } case "offline": if userLevel >= 420 { reply = app.deleteOfflineSubscription(target, cmdParams[2]) } } case "yaf": if userLevel >= 420 { go app.NewDownload("yaf", target, cmdParams[1], message) } case "gofile": if userLevel >= 420 { go app.NewDownload("gofile", target, cmdParams[1], message) } //---------------------------------- // 500 User Level // trusted //--------------------------------- case "timer": switch cmdParams[1] { case "add": if userLevel >= 500 { app.AddTimer(cmdParams[2], cmdParams[3], message) } case "delete": if userLevel >= 500 { app.DeleteTimer(cmdParams[2], message) } case "edit": if userLevel >= 500 { app.EditTimer(cmdParams[2], cmdParams[3], message) } } case "command": switch cmdParams[1] { case "add": if userLevel >= 500 { app.AddCommand(cmdParams[2], message) } case "delete": if userLevel >= 500 { app.DeleteCommand(cmdParams[2], message) } case "list": if userLevel >= 500 { reply = app.ListCommands() } case "edit": switch cmdParams[2] { case "level": if userLevel >= 500 { app.EditCommandLevel(cmdParams[3], cmdParams[4], message) } } } //------------------------------------ // 1000 User Level // Admin //------------------------------------ case "conv": if userLevel >= 1000 { if msgLen > 1 { reply = "Not enough arguments provided" } else if msgLen == 2 { app.ConvertToMP4(cmdParams[1], message) } } case "meme": if userLevel < 1000 { // Unauthorized return } else if userLevel >= 1000 && msgLen <= 2 { // Authorized but not enough args. reply = "Not enough arguments provided." } else if userLevel >= 1000 && msgLen >= 3 { app.ConvertAndSave(cmdParams[1], cmdParams[2], message) } case "echo": if userLevel >= 1000 { reply = message.Message[7:len(message.Message)] } case "say": if userLevel >= 1000 { reply = message.Message[6:len(message.Message)] } // case "whisper": // if userLevel >= 1000 { // go app.sendWhisper(cmdParams[1], message.Message[10:len(message.Message)]) // } case "join": if userLevel >= 1000 { go app.AddChannel(cmdParams[1], message) } case "part": if userLevel >= 1000 { go app.DeleteChannel(cmdParams[1], message) } case "user": switch cmdParams[1] { case "edit": switch cmdParams[2] { case "level": if userLevel >= 1000 { app.EditUserLevel(cmdParams[3], cmdParams[4], message) } } case "set": switch cmdParams[2] { case "level": if userLevel >= 1000 { app.EditUserLevel(cmdParams[3], cmdParams[4], message) } } } default: r, err := app.GetCommand(target, commandName, userLevel) if err != nil { return } go app.SendNoBanphrase(target, r) return } if reply != "" { go app.Send(target, reply, message) return } } type command struct { Name string Alias []string Description string Level string Usage string } // Optional is [] // Required is < > var helpText = map[string]command{ "bttv": { Name: "bttv", Alias: []string{"bttv", "betterttv"}, Description: "Returns the search URL for a given BTTV emote.", Level: "0", Usage: "()bttv ", }, "catbox": { Name: "catbox", Alias: nil, Description: "Downloads the video of a given link with yt-dlp and then uploads the video to catbox.moe.", Level: "420", Usage: "()catbox ", }, "coin": { Name: "coin", Alias: []string{"coin", "coinflip", "cf"}, Description: "Flip a coin.", Level: "0", Usage: "()coin", }, "command add": { Name: "command add", Alias: nil, Description: "Adds a channel command to the database.", Level: "250", Usage: "()add command ", }, "command edit level": { Name: "command edit level", Alias: nil, Description: "Edits the required level of a channel command with the given name.", Level: "250", Usage: "()command edit level ", }, "command delete": { Name: "command delete", Alias: nil, Description: "Deletes the channel command with the given name.", Level: "250", Usage: "()command delete ", }, "commands": { Name: "commands", Alias: nil, Description: "Returns a link to the commands in the channel.", Level: "0", Usage: "()commands", }, "conv": { Name: "conv", Alias: nil, Description: "Converts the linked video into an .mp4 file.", Level: "1000", Usage: "()conv