Fix 'client already started' error on finding common ancestor

cffls · Nov 7, 2024 · 1ff9c05 · 1ff9c05
1 parent 136bb86
commit 1ff9c05
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/zk/datastream/client/stream_client.go b/zk/datastream/client/stream_client.go
@@ -128,7 +128,11 @@ func (c *StreamClient) GetL2BlockByNumber(blockNum uint64) (fullBLock *types.Ful
 			if fullBLock, err = c.getL2BlockByNumber(blockNum); err == nil {
 				break
 			}
-			if !errors.Is(err, ErrSocket) {
+
+			if errors.Is(err, types.ErrAlreadyStarted) {
+				// if the client is already started, we can stop the client and try again
+				c.Stop()
+			} else if !errors.Is(err, ErrSocket) {
 				return nil, fmt.Errorf("getL2BlockByNumber: %w", err)
 			}