Changeset 64 in code

Timestamp:

Feb 18, 2020, 3:31:18 PM (5 years ago)

Author:

contact

Message:

Add a -debug flag

Location:

trunk

Files:

• cmd/jounce/main.go (modified) (2 diffs)
• downstream.go (modified) (3 diffs)
• server.go (modified) (1 diff)
• upstream.go (modified) (2 diffs)

trunk/cmd/jounce/main.go

@@ -13 +13 @@
 func main() {
         var addr, configPath string
+        var debug bool
         flag.StringVar(&addr, "listen", "", "listening address")
         flag.StringVar(&configPath, "config", "", "path to configuration file")
+        flag.BoolVar(&debug, "debug", false, "enable debug logging")
         flag.Parse()
 
@@ -55 +57 @@
         // TODO: load from config/DB
         srv.Hostname = cfg.Hostname
+        srv.Debug = debug
         srv.Upstreams = []jounce.Upstream{{
                 Addr:     "chat.freenode.net:6697",

trunk/downstream.go

@@ -109 +109 @@
                 }
 
+                if dc.srv.Debug {
+                        dc.logger.Printf("received: %v", msg)
+                }
+
                 err = dc.handleMessage(msg)
                 if ircErr, ok := err.(ircError); ok {
@@ -131 +135 @@
                 select {
                 case msg := <-dc.messages:
+                        if dc.srv.Debug {
+                                dc.logger.Printf("sent: %v", msg)
+                        }
                         err = dc.irc.WriteMessage(msg)
                 case consumer := <-dc.consumers:
@@ -137 +144 @@
                                 if msg == nil {
                                         break
+                                }
+                                if dc.srv.Debug {
+                                        dc.logger.Printf("sent: %v", msg)
                                 }
                                 err = dc.irc.WriteMessage(msg)

trunk/server.go

@@ -103 +103 @@
         Logger    Logger
         RingCap   int
+        Debug     bool
         Upstreams []Upstream // TODO: per-user
 

trunk/upstream.go

@@ -73 +73 @@
         go func() {
                 for msg := range msgs {
+                        if uc.srv.Debug {
+                                uc.logger.Printf("sent: %v", msg)
+                        }
                         if err := uc.irc.WriteMessage(msg); err != nil {
                                 uc.logger.Printf("failed to write message: %v", err)
@@ -345 +348 @@
                 }
 
+                if uc.srv.Debug {
+                        uc.logger.Printf("received: %v", msg)
+                }
+
                 if err := uc.handleMessage(msg); err != nil {
                         uc.logger.Printf("failed to handle message %q: %v", msg, err)