feat: fatal exit upon loss of connection to sequencer

PowerLoom · Nov 18, 2024 · e3f73d8 · e3f73d8
1 parent 28bae07
commit e3f73d8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 21 deletions.
diff --git a/pkgs/service/libp2p_stream_pool.go b/pkgs/service/libp2p_stream_pool.go
@@ -171,11 +171,13 @@ func (p *StreamPool) createNewStreamWithRetry() (network.Stream, error) {
 		// Get current connection state
 		hostConn, seqId, err := GetSequencerConnection()
 		if err != nil {
-			return fmt.Errorf("cannot create stream: %w", err)
+			log.Fatal("Lost connection to sequencer - terminating service for restart")
+			return fmt.Errorf("fatal: sequencer connection lost")
 		}
 
 		if hostConn.Network().Connectedness(seqId) != network.Connected {
-			return fmt.Errorf("connection to sequencer lost")
+			log.Fatal("Lost connection to sequencer - terminating service for restart")
+			return fmt.Errorf("fatal: connection to sequencer lost")
 		}
 
 		stream, err = p.createStream()

diff --git a/pm2.config.js b/pm2.config.js