Implement paho mqtt client logging (#182)

Author: JohnRoesler

cmd/chirpstack-gateway-bridge/cmd/configfile.go

@@ -227,6 +227,7 @@ marshaler="{{ .Integration.Marshaler }}"
   # Keep alive will set the amount of time (in seconds) that the client should
   # wait before sending a PING request to the broker. This will allow the client
   # to know that a connection has not been lost with the server.
+  # Valid units are 'ms', 's', 'm', 'h'. Note that these values can be combined, e.g. '24h30m15s'.
   keep_alive="{{ .Integration.MQTT.KeepAlive }}"
 
   # Maximum interval that will be waited between reconnection attempts when connection is lost.

cmd/chirpstack-gateway-bridge/main.go

@@ -1,6 +1,35 @@
 package main
 
-import "github.com/brocaar/chirpstack-gateway-bridge/cmd/chirpstack-gateway-bridge/cmd"
+import (
+	"github.com/brocaar/chirpstack-gateway-bridge/cmd/chirpstack-gateway-bridge/cmd"
+	paho "github.com/eclipse/paho.mqtt.golang"
+	log "github.com/sirupsen/logrus"
+)
+
+type pahoLogWrapper struct {
+	ln func(...interface{})
+	f  func(string, ...interface{})
+}
+
+func (d pahoLogWrapper) Println(v ...interface{}) {
+	d.ln(v...)
+}
+
+func (d pahoLogWrapper) Printf(format string, v ...interface{}) {
+	d.f(format, v...)
+}
+
+func enableClientLogging() {
+	l := log.WithField("module", "mqtt")
+	paho.DEBUG = pahoLogWrapper{l.Debugln, l.Debugf}
+	paho.ERROR = pahoLogWrapper{l.Errorln, l.Errorf}
+	paho.WARN = pahoLogWrapper{l.Warningln, l.Warningf}
+	paho.CRITICAL = pahoLogWrapper{l.Errorln, l.Errorf}
+}
+
+func init() {
+	enableClientLogging()
+}
 
 var version string // set by the compiler