Merge pull request #27 from mysteriumnetwork/nats-reconnect

Panic if nats connection closed

listener/proposal.go

@@ -7,6 +7,7 @@ package listener
 import (
 	"encoding/json"
 	"errors"
+	"time"
 
 	v2 "github.com/mysteriumnetwork/discovery/proposal/v2"
 
@@ -30,7 +31,16 @@ func New(brokerURL string, repository *proposal.Repository) *Listener {
 }
 
 func (l *Listener) Listen() error {
-	conn, err := nats.Connect(l.brokerURL)
+	var opts = func(opts *nats.Options) error {
+		opts.PingInterval = time.Second * 5
+		opts.MaxReconnect = 5
+		opts.ClosedCB = func(c *nats.Conn) {
+			panic("nats connection closed")
+		}
+		return nil
+	}
+
+	conn, err := nats.Connect(l.brokerURL, opts)
 	if err != nil {
 		return err
 	}

proposal/service.go

@@ -77,7 +77,7 @@ func (s *Service) List(opts ListOpts) ([]v2.Proposal, error) {
 		// exclude monitoringFailed nodes
 		sessionsResponse, err := s.qualityService.Sessions(opts.from)
 		if err != nil {
-			log.Warn().Err(err).Msgf("Could not fetch session stats for consumer", opts.from)
+			log.Warn().Err(err).Msgf("Could not fetch session stats for consumer %v", opts.from)
 		} else {
 			for k, proposal := range resultMap {
 				if sessionsResponse.MonitoringFailed(proposal.ProviderID, proposal.ServiceType) {