Reconnect NATS forever and log NATS connection events.

src/app/spreed-webrtc-server/bus_manager.go

@@ -72,9 +72,9 @@ func NewBusManager(id string, useNats bool, subjectPrefix string) BusManager {
 	if useNats {
 		b, err = newNatsBus(id, subjectPrefix)
 		if err == nil {
-			log.Println("Nats bus connected")
+			log.Println("NATS bus connected")
 		} else {
-			log.Println("Error connecting nats bus", err)
+			log.Println("Error connecting NATS bus", err)
 			b = &noopBus{id}
 		}
 	} else {

src/app/spreed-webrtc-server/nats.go

@@ -20,7 +20,26 @@ var DefaultNatsURL = nats.DefaultURL
 // and tries to establish the connection. It returns the connection
 // and any connection error encountered.
 func NewNatsConnection() (*nats.EncodedConn, error) {
-	nc, err := nats.Connect(DefaultNatsURL)
+	opts := &nats.Options{
+		Url:            DefaultNatsURL,
+		AllowReconnect: true,
+		MaxReconnect:   -1, // Reconnect forever.
+		ReconnectWait:  nats.DefaultReconnectWait,
+		Timeout:        nats.DefaultTimeout,
+		PingInterval:   nats.DefaultPingInterval,
+		MaxPingsOut:    nats.DefaultMaxPingOut,
+		SubChanLen:     nats.DefaultMaxChanLen,
+		ClosedCB: func(conn *nats.Conn) {
+			log.Println("NATS connection closed")
+		},
+		DisconnectedCB: func(conn *nats.Conn) {
+			log.Println("NATS disconnected")
+		},
+		ReconnectedCB: func(conn *nats.Conn) {
+			log.Println("NATS reconnected")
+		},
+	}
+	nc, err := opts.Connect()
 	if err != nil {
 		return nil, err
 	}