fix(local pub sub): use error for subscription cancelled (instead of …

…info) (#853)
dymensionxyz · May 18, 2024 · e0bb19f · e0bb19f
1 parent a524381
commit e0bb19f
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/block/synctarget.go b/block/synctarget.go
@@ -38,7 +38,7 @@ func (m *Manager) SyncTargetLoop(ctx context.Context) {
 			m.UpdateSyncParams(eventData.EndHeight)
 			m.SyncTargetDiode.Set(diodes.GenericDataType(&eventData.EndHeight))
 		case <-subscription.Cancelled():
-			m.logger.Info("syncTargetLoop subscription canceled")
+			m.logger.Error("syncTargetLoop subscription canceled")
 			return
 		}
 	}

diff --git a/settlement/dymension/dymension.go b/settlement/dymension/dymension.go
@@ -255,7 +255,7 @@ func (d *HubClient) PostBatch(batch *types.Batch, daClient da.Client, daResult *
 			return d.ctx.Err()
 
 		case <-subscription.Cancelled():
-			return fmt.Errorf("subscription cancelled: %w", err)
+			return fmt.Errorf("subscription cancelled")
 
 		case <-subscription.Out():
 			d.logger.Debug("Batch accepted", "startHeight", batch.StartHeight, "endHeight", batch.EndHeight)

diff --git a/utils/event/funcs.go b/utils/event/funcs.go
@@ -34,7 +34,7 @@ func MustSubscribe(
 		case event := <-subscription.Out():
 			callback(event)
 		case <-subscription.Cancelled():
-			logger.Info(clientID + " subscription canceled")
+			logger.Error("subscription cancelled", "clientID", clientID)
 			return
 		}
 	}