update sync monitor to not check for dkg and ws error to panic keyper

Author: blockchainluffy

rolling-shutter/keyperimpl/shutterservice/syncmonitor.go

@@ -59,15 +59,6 @@ func (s *SyncMonitor) runCheck(
 	keyperdb *keyperDB.Queries,
 	lastBlockNumber *int64,
 ) error {
-	isRunning, err := s.isDKGRunning(ctx, keyperdb)
-	if err != nil {
-		return fmt.Errorf("syncMonitor | error in dkgIsRunning: %w", err)
-	}
-	if isRunning {
-		log.Debug().Msg("dkg is running, skipping sync monitor checks")
-		return nil
-	}
-
 	record, err := db.GetIdentityRegisteredEventsSyncedUntil(ctx)
 	if err != nil {
 		if errors.Is(err, pgx.ErrNoRows) {
@@ -91,31 +82,3 @@ func (s *SyncMonitor) runCheck(
 		Msg("block number has not increased between checks")
 	return ErrBlockNotIncreasing
 }
-
-func (s *SyncMonitor) isDKGRunning(ctx context.Context, keyperdb *keyperDB.Queries) (bool, error) {
-	// if latest eon is registered then EonStarted event has triggered, which means the dkg can start
-	eons, err := keyperdb.GetAllEons(ctx)
-	if errors.Is(err, pgx.ErrNoRows) {
-		return false, nil
-	}
-	if err != nil {
-		log.Error().
-			Err(err).
-			Msg("syncMonitor | error getting all eons")
-		return false, err
-	}
-
-	if len(eons) == 0 {
-		return false, nil
-	}
-
-	// if we get no rows in getting dkg result then dkg is not completed for that eon
-	_, err = keyperdb.GetDKGResult(ctx, eons[len(eons)-1].Eon)
-	if errors.Is(err, pgx.ErrNoRows) {
-		return true, nil
-	} else if err != nil {
-		log.Error().Err(err).Msg("syncMonitor | error getting dkg result")
-		return false, err
-	}
-	return false, nil
-}

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

@@ -149,7 +149,8 @@ func (s *EonPubKeySyncer) watchNewEonPubkey(ctx context.Context, subsErr <-chan
 			}
 		case err := <-subsErr:
 			if err != nil {
-				s.Log.Error("subscription error for watchNewEonPubkey", err)
+				s.Log.Error("subscription error for watchNewEonPubkey", err.Error())
+				return err
 			}
 		case <-ctx.Done():
 			return ctx.Err()

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

@@ -236,7 +236,8 @@ func (s *KeyperSetSyncer) watchNewKeypersService(ctx context.Context, subsErr <-
 			}
 		case err := <-subsErr:
 			if err != nil {
-				s.Log.Error("subscription error for watchNewKeypersService", err)
+				s.Log.Error("subscription error for watchNewKeypersService", err.Error())
+				return err
 			}
 		case <-ctx.Done():
 			return ctx.Err()

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

@@ -125,11 +125,13 @@ func (s *ShutterStateSyncer) watchPaused(ctx context.Context, subsErr <-chan err
 			s.handle(ctx, ev)
 		case err := <-subsErr:
 			if err != nil {
-				s.Log.Error("subscription error for watchPaused")
+				s.Log.Error("subscription error for watchPaused", err.Error())
+				return err
 			}
 		case err := <-subsErrUnpaused:
 			if err != nil {
-				s.Log.Error("subscription error for watchUnpaused", err)
+				s.Log.Error("subscription error for watchUnpaused", err.Error())
+				return err
 			}
 		case <-ctx.Done():
 			return ctx.Err()

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

@@ -60,7 +60,8 @@ func (s *UnsafeHeadSyncer) watchLatestUnsafeHead(ctx context.Context, subsErr <-
 			}
 		case err := <-subsErr:
 			if err != nil {
-				s.Log.Error("subscription error for watchLatestUnsafeHead", err)
+				s.Log.Error("subscription error for watchLatestUnsafeHead", err.Error())
+				return err
 			}
 		case <-ctx.Done():
 			return ctx.Err()