API-102: fix perps library listeners

gateway-fm · Sep 13, 2023 · 7a6d4e9 · 7a6d4e9
1 parent 28d806c
commit 7a6d4e9
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 8 deletions.
diff --git a/events/liquidations.go b/events/liquidations.go
@@ -52,8 +52,10 @@ func (s *LiquidationSubscription) listen(rpcClient *ethclient.Client) {
 			close(s.contractEventChan)
 			return
 		case err := <-s.eventSub.Err():
-			logger.Log().WithField("layer", "Events-PositionLiquidated").Errorf("error listening position liquidated: %v", err.Error())
-			s.ErrChan <- err
+			if err != nil {
+				logger.Log().WithField("layer", "Events-PositionLiquidated").Errorf("error listening position liquidated: %v", err.Error())
+				s.ErrChan <- err
+			}
 			continue
 		case positionLiquidated := <-s.contractEventChan:
 			block, err := rpcClient.HeaderByNumber(context.Background(), big.NewInt(int64(positionLiquidated.Raw.BlockNumber)))

diff --git a/events/marketUpdate.go b/events/marketUpdate.go
@@ -54,8 +54,10 @@ func (s *MarketUpdateSubscription) listen(rpcClient *ethclient.Client) {
 			close(s.contractEventChan)
 			return
 		case err := <-s.eventSub.Err():
-			logger.Log().WithField("layer", "Events-MarketUpdated").Errorf("error listening market update: %v", err.Error())
-			s.ErrChan <- err
+			if err != nil {
+				logger.Log().WithField("layer", "Events-MarketUpdated").Errorf("error listening market update: %v", err.Error())
+				s.ErrChan <- err
+			}
 			continue
 		case marketUpdate := <-s.contractEventChan:
 			block, err := rpcClient.HeaderByNumber(context.Background(), big.NewInt(int64(marketUpdate.Raw.BlockNumber)))

diff --git a/events/orders.go b/events/orders.go
@@ -54,8 +54,10 @@ func (s *OrderSubscription) listen(rpcClient *ethclient.Client) {
 			close(s.contractEventChan)
 			return
 		case err := <-s.eventSub.Err():
-			logger.Log().WithField("layer", "Events-OrderCommitted").Errorf("error listening order committed: %v", err.Error())
-			s.ErrChan <- err
+			if err != nil {
+				logger.Log().WithField("layer", "Events-OrderCommitted").Errorf("error listening order committed: %v", err.Error())
+				s.ErrChan <- err
+			}
 			continue
 		case orderCommitted := <-s.contractEventChan:
 			block, err := rpcClient.HeaderByNumber(context.Background(), big.NewInt(int64(orderCommitted.Raw.BlockNumber)))

diff --git a/events/trades.go b/events/trades.go
@@ -54,8 +54,10 @@ func (s *TradeSubscription) listen(rpcClient *ethclient.Client) {
 			close(s.contractEventChan)
 			return
 		case err := <-s.eventSub.Err():
-			logger.Log().WithField("layer", "Events-OrderSettled").Errorf("error listening order settled: %v", err.Error())
-			s.ErrChan <- err
+			if err != nil {
+				logger.Log().WithField("layer", "Events-OrderSettled").Errorf("error listening order settled: %v", err.Error())
+				s.ErrChan <- err
+			}
 			continue
 		case orderSettled := <-s.contractEventChan:
 			block, err := rpcClient.HeaderByNumber(context.Background(), big.NewInt(int64(orderSettled.Raw.BlockNumber)))