chore: update error handling for event subscription

Author: blockchainluffy

rolling-shutter/medley/chainsync/syncer/eonpubkey.go

@@ -61,7 +61,8 @@ func (s *EonPubKeySyncer) Start(ctx context.Context, runner service.Runner) erro
 		return err
 	}
 	runner.Go(func() error {
-		if err := s.watchNewEonPubkey(ctx, subs.Err()); err != nil {
+		err := s.watchNewEonPubkey(ctx, subs.Err())
+		if err != nil {
 			s.Log.Error("error watching new eon pubkey", err.Error())
 		}
 		subs.Unsubscribe()

rolling-shutter/medley/chainsync/syncer/keyperset.go

@@ -71,7 +71,8 @@ func (s *KeyperSetSyncer) Start(ctx context.Context, runner service.Runner) erro
 		return err
 	}
 	runner.Go(func() error {
-		if err := s.watchNewKeypersService(ctx, subs.Err()); err != nil {
+		err := s.watchNewKeypersService(ctx, subs.Err())
+		if err != nil {
 			s.Log.Error("error watching new keypers", err.Error())
 		}
 		subs.Unsubscribe()

rolling-shutter/medley/chainsync/syncer/shutterstate.go

@@ -61,7 +61,8 @@ func (s *ShutterStateSyncer) Start(ctx context.Context, runner service.Runner) e
 	}
 
 	runner.Go(func() error {
-		if err := s.watchPaused(ctx, subs.Err(), subsUnpaused.Err()); err != nil {
+		err := s.watchPaused(ctx, subs.Err(), subsUnpaused.Err())
+		if err != nil {
 			s.Log.Error("error watching paused", err.Error())
 		}
 		subs.Unsubscribe()

rolling-shutter/medley/chainsync/syncer/unsafehead.go

@@ -32,7 +32,8 @@ func (s *UnsafeHeadSyncer) Start(ctx context.Context, runner service.Runner) err
 		return err
 	}
 	runner.Go(func() error {
-		if err := s.watchLatestUnsafeHead(ctx, subs.Err()); err != nil {
+		err := s.watchLatestUnsafeHead(ctx, subs.Err())
+		if err != nil {
 			s.Log.Error("error watching latest unsafe head", err.Error())
 		}
 		subs.Unsubscribe()