summaryrefslogtreecommitdiff
path: root/cmd/irclogs/main.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd/irclogs/main.go')
-rw-r--r--cmd/irclogs/main.go10
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)
}
}