feat: join channels

1 files changed, 6 insertions, 4 deletions

diff --git a/cmd/irclogs/main.go b/cmd/irclogs/main.go
index 509447f..1090e66 100644
--- a/cmd/irclogs/main.go
+++ b/cmd/irclogs/main.go
@@ -22,7 +22,7 @@ func main() {
 	clients := []irclogs.IRCClient{}
 
 	for {
-		rows, err := db.Query("SELECT host, port, nick, pass, capabilities FROM servers")
+		rows, err := db.Query("SELECT id, host, port, nick, pass, capabilities FROM servers")
 		if err != nil {
 			log.Fatalf("Failed to get servers: %v\n", err)
 			continue
@@ -30,8 +30,8 @@ func main() {
 
 		for rows.Next() {
 			var host, nick, pass, caps string
-			var port int
-			if err = rows.Scan(&host, &port, &nick, &pass, &caps); err != nil {
+			var dbid, port int
+			if err = rows.Scan(&dbid, &host, &port, &nick, &pass, &caps); err != nil {
 				log.Fatalf("Failed to scan rows: %v\n", err)
 				continue
 			}
@@ -40,7 +40,7 @@ func main() {
 				return c.Host == host
 			}) {
 				log.Printf("Connecting to %s:%d...\n", host, port)
-				c := irclogs.NewIRCClient(host, port, nick, pass, strings.Split(caps, "\n"))
+				c := irclogs.NewIRCClient(dbid, host, port, nick, pass, strings.Split(caps, "\n"))
 
 				go func() {
 					if err = c.Connect(); err != nil {
@@ -48,6 +48,8 @@ func main() {
 					}
 				}()
 
+				go c.JoinChannels(db)
+
 				clients = append(clients, c)
 			}
 		}