internal/irc/irc.go

@@ -2,8 +2,8 @@ package irc
 
 import (
 	"bufio"
-	"encoding/base64"
 	"encoding/json"
+	"encoding/base64"
 	"errors"
 	"fmt"
 	"io"
@@ -16,23 +16,17 @@ import (
 	"time"
 
 	rgb "github.com/foresthoffman/rgblog"
-	uuid "github.com/google/uuid"
 	scribble "github.com/nanobox-io/golang-scribble"
+	uuid "github.com/google/uuid"
 )
 
 const PSTFormat = "Jan 2 15:04:05 PST"
 
-// Regex for parsing connection messages
-//
-// First matched group is our real username - twitch doesn't complain at using NICK command but doesn't honor it.
-var ConnectRegex *regexp.Regexp = regexp.MustCompile(`^:tmi.twitch.tv 001 ([^ ]+) .*`)
-
 // Regex for parsing PRIVMSG strings.
 //
 // First matched group is the user's name, second is the channel? and the third matched group is the content of the
 // user's message.
 var MsgRegex *regexp.Regexp = regexp.MustCompile(`^:(\w+)!\w+@\w+\.tmi\.twitch\.tv (PRIVMSG) #(\w+)(?: :(.*))?$`)
-var DirectMsgRegex *regexp.Regexp = regexp.MustCompile(`^:(\w+)!\w+@\w+\.tmi\.twitch\.tv (PRIVMSG) (\w+)(?: :(.*))?$`)
 
 // Regex for parsing user commands, from already parsed PRIVMSG strings.
 //
@@ -70,7 +64,6 @@ type ChannelData struct {
 	Command       string `json:"customcommand,omitempty"`
 	ExtraStrings  string `json:"extrastrings,omitempty"`
 	JoinTime      time.Time `json:"jointime"`
-	ControlChannel bool
 }
 
 // Connects the bot to the Twitch IRC server. The bot will continue to try to connect until it
@@ -125,29 +118,9 @@ func (bb *KardBot) HandleChat() error {
 			bb.conn.Write([]byte("PONG :tmi.twitch.tv\r\n"))
 			continue
 		} else {
-			matches := ConnectRegex.FindStringSubmatch(line)
-			if nil != matches {
-				realUserName := matches[1]
-				if bb.ChannelData[realUserName].Name == "" {
-					record := ChannelData{Name: realUserName, JoinTime: time.Now(), Command: "card", ControlChannel: true}
-					bb.Database.Write("channelData", realUserName, record)
-					bb.ChannelData[realUserName] = record
-				}
-				bb.JoinChannel(realUserName)
-			}
-
-			matches = DirectMsgRegex.FindStringSubmatch(line)
-			if nil != matches {
-				userName := matches[1]
-//				msgType := matches[2]
-//				channel := matches[3]
-				msg := matches[4]
-				rgb.GPrintf("[%s] Direct message %s: %s\n", TimeStamp(), userName, msg)
-
-			}
 
 			// handle a PRIVMSG message
-			matches = MsgRegex.FindStringSubmatch(line)
+			matches := MsgRegex.FindStringSubmatch(line)
 			if nil != matches {
 				userName := matches[1]
 				msgType := matches[2]
@@ -169,16 +142,6 @@ func (bb *KardBot) HandleChat() error {
 							rgb.CPrintf("[%s] Card asked for by %s on %s' channel!\n", TimeStamp(), userName, channel)
 
 							bb.Say("Your prompt is : "+bb.Prompts[rand.Intn(len(bb.Prompts))], channel)
-						case "join":
-							if bb.ChannelData[channel].ControlChannel {
-								rgb.CPrintf("[%s] Join asked for by %s on %s' channel!\n", TimeStamp(), userName, channel)
-								if bb.ChannelData[userName].Name == "" {
-									record := ChannelData{Name: userName, JoinTime: time.Now(), Command: "card", ControlChannel: true}
-									bb.Database.Write("channelData", userName, record)
-									bb.ChannelData[userName] = record
-								}
-								bb.JoinChannel(userName)
-							}
 						}
 
 						// channel-owner specific commands
@@ -192,17 +155,13 @@ func (bb *KardBot) HandleChat() error {
 
 								bb.Disconnect()
 								return nil
-							case "kcardadmin":
+							case "wat":
 								magicCode := bb.readOrCreateChannelKey(channel)
 								rgb.CPrintf(
 									"[%s] Magic code is %s - https://karaokards.ing.martyn.berlin/admin/%s/%s\n",
 									TimeStamp(),
 									magicCode, userName, magicCode,
 								)
-								err := bb.Msg("Welcome to Karaokards, your admin panel is https://karaokards.ing.martyn.berlin/admin/"+userName+"/"+magicCode, userName)
-								if err != nil {
-									rgb.RPrintf("[%s] ERROR %s\n",err)
-								}
 								bb.Say("Ack.")
 							default:
 								// do nothing
@@ -226,6 +185,7 @@ func (bb *KardBot) Login() {
 	bb.conn.Write([]byte("NICK " + bb.Name + "\r\n"))
 }
 
+
 func (bb *KardBot) LeaveChannel(channels ...string) {
 	for _, channel := range channels {
 		rgb.YPrintf("[%s] Leaving #%s...\n", TimeStamp(), channel)
@@ -267,31 +227,6 @@ func (bb *KardBot) ReadCredentials() error {
 	return nil
 }
 
-func (bb *KardBot) Msg(msg string, users ...string) error {
-	if "" == msg {
-		return errors.New("BasicBot.Say: msg was empty.")
-	}
-
-	// check if message is too large for IRC
-	if len(msg) > 512 {
-		return errors.New("BasicBot.Say: msg exceeded 512 bytes")
-	}
-
-	if len(users) == 0 {
-		return errors.New("BasicBot.Say: users was empty.")
-	}
-
-	rgb.YPrintf("[%s] sending %s to users %v as @%s!\n", TimeStamp(), msg, users, bb.Name)
-	for _, channel := range users {
-		_, err := bb.conn.Write([]byte(fmt.Sprintf("PRIVMSG %s :%s\r\n", channel, msg)))
-		rgb.YPrintf("[%s] PRIVMSG %s :%s\r\n", TimeStamp(), channel, msg)
-		if nil != err {
-			return err
-		}
-	}
-	return nil
-}
-
 // Makes the bot send a message to the chat channel.
 func (bb *KardBot) Say(msg string, channels ...string) error {
 	if "" == msg {
@@ -340,7 +275,7 @@ func (bb *KardBot) Start() {
 		bb.Connect()
 		bb.Login()
 		if len(bb.ChannelData) > 0 {
-			for channelName := range bb.ChannelData {
+			for channelName := range(bb.ChannelData) {
 				bb.JoinChannel(channelName)
 			}
 		} else {
@@ -369,13 +304,13 @@ func (bb *KardBot) readChannelData() error {
 			return err
 		}
 		bb.ChannelData = make(map[string]ChannelData)
-		bb.ChannelData[bb.Channel] = record
+		bb.ChannelData[bb.Channel] = record;
 	} else {
 		bb.ChannelData = make(map[string]ChannelData)
 	}
 	for _, data := range records {
 		record := ChannelData{}
-		err := json.Unmarshal([]byte(data), &record)
+		err := json.Unmarshal([]byte(data), &record);
 		if err != nil {
 			return err
 		}
@@ -411,7 +346,7 @@ func (bb *KardBot) readOrCreateChannelKey(channel string) string {
 	var record ChannelData
 	if record, ok := bb.ChannelData[channel]; !ok {
 		rgb.YPrintf("[%s] No channel data for #%s exists, creating\n", TimeStamp(), channel)
-		err = bb.Database.Read("channelData", channel, &record)
+		err = bb.Database.Read("channelData", channel, &record);
 		if err == nil {
 			bb.ChannelData[channel] = record
 		}

internal/webserver/webserver.go

@@ -104,27 +104,27 @@ func AdminHandler(response http.ResponseWriter, request *http.Request) {
 
 	if request.Method == "POST" {
 		request.ParseForm()
-		if strings.Join(request.PostForm["leave"], ",") == "Leave twitch channel" {
+		if strings.Join(request.PostForm["leave"],",") == "Leave twitch channel" {
 			td.Leaving = true
-		} else if strings.Join(request.PostForm["reallyleave"], ",") == "Really leave twitch channel" {
+		} else if strings.Join(request.PostForm["reallyleave"],",") == "Really leave twitch channel" {
-			delete(ircBot.ChannelData, vars["channel"])
+			delete(ircBot.ChannelData,vars["channel"])
 			ircBot.Database.Delete("channelData", vars["channel"])
 			ircBot.LeaveChannel(vars["channel"])
 			LeaveHandler(response, request)
 			return
 		}
 		sourceData := ircBot.ChannelData[vars["channel"]]
-		if strings.Join(request.PostForm["Command"], ",") != "" {
+		if strings.Join(request.PostForm["Command"],",") != ""  {
-			sourceData.Command = strings.Join(request.PostForm["Command"], ",")
+			sourceData.Command = strings.Join(request.PostForm["Command"],",")
 			td.Command = sourceData.Command
 			ircBot.ChannelData[vars["channel"]] = sourceData
 		}
-		if strings.Join(request.PostForm["ExtraStrings"], ",") != sourceData.ExtraStrings {
+		if strings.Join(request.PostForm["ExtraStrings"],",") != sourceData.ExtraStrings {
-			sourceData.ExtraStrings = strings.Join(request.PostForm["ExtraStrings"], ",")
+			sourceData.ExtraStrings = strings.Join(request.PostForm["ExtraStrings"],",")
 			td.ExtraStrings = sourceData.ExtraStrings
 			ircBot.ChannelData[vars["channel"]] = sourceData
 		}
-		ircBot.Database.Write("channelData", vars["channel"], sourceData)
+		ircBot.Database.Write("channelData", vars["channel"], sourceData);
 	}
 	tmpl := template.Must(template.ParseFiles("web/admin.html"))
 	tmpl.Execute(response, td)

main.go

@@ -51,7 +51,7 @@ func readConfig() {
 		if _, err := os.Stat(exPath + "/config.json"); os.IsNotExist(err) {
 			rgb.YPrintf("[%s] Warning, KARAOKARDS_CONFIGFILE env var unset and `config.json` not alongside executable!\n", irc.TimeStamp())
 			if _, err := os.Stat("/etc/karaokards/config.json"); os.IsNotExist(err) {
-				rgb.RPrintf("[%s] Error, KARAOKARDS_CONFIGFILE env var unset and neither '%s' nor '%s' exist!\n", irc.TimeStamp(), exPath+"/config.json", "/etc/karaokards/config.json")
+				rgb.RPrintf("[%s] Error, KARAOKARDS_CONFIGFILE env var unset and neither '%s' nor '%s' exist!\n", irc.TimeStamp(), exPath + "/config.json", "/etc/karaokards/config.json")
 				os.Exit(1)
 			} else {
 				configFile = "/etc/karaokards/config.json"
@@ -92,10 +92,10 @@ func openDatabase() *scribble.Driver {
 			}
 			exPath := filepath.Dir(ex)
 			if _, err := os.Stat(exPath + "/data"); os.IsNotExist(err) {
-				rgb.YPrintf("[%s] Warning %s doesn't exist, trying to create it.\n", irc.TimeStamp(), exPath+"/data")
+				rgb.YPrintf("[%s] Warning %s doesn't exist, trying to create it.\n", irc.TimeStamp(), exPath + "/data")
-				err = os.Mkdir(exPath+"/data", 0770)
+				err = os.Mkdir(exPath + "/data", 0770)
 				if err != nil {
-					rgb.RPrintf("[%s] Error cannot create %s: %s!\n", irc.TimeStamp(), exPath+"/data", err)
+					rgb.RPrintf("[%s] Error cannot create %s: %s!\n", irc.TimeStamp(), exPath + "/data", err)
 					os.Exit(1)
 				}
 			}