bubble up errors when fetching proposer duties fails (reset client re…

…adiness)
ethpandaops · Sep 13, 2023 · b6f0008 · b6f0008
1 parent 4634360
commit b6f0008
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/indexer/client.go b/indexer/client.go
@@ -255,7 +255,11 @@ func (client *IndexerClient) runIndexerClient() error {
 		currentEpoch := utils.TimeToEpoch(time.Now())
 		if currentEpoch > client.lastEpochStats {
 			// ensure latest epoch stats are loaded for chain of this client
-			client.ensureEpochStats(uint64(currentEpoch), client.lastHeadRoot)
+			err := client.ensureEpochStats(uint64(currentEpoch), client.lastHeadRoot)
+			if err != nil {
+				client.isConnected = false
+				return err
+			}
 		}
 	}
 }
@@ -344,7 +348,10 @@ func (client *IndexerClient) prefillCache(finalizedSlot uint64, latestHeader *rp
 	}
 	currentEpoch := utils.EpochOfSlot(currentBlock.Slot)
 	for epoch := firstEpoch; epoch <= currentEpoch; epoch++ {
-		client.ensureEpochStats(epoch, currentBlock.Root)
+		err := client.ensureEpochStats(epoch, currentBlock.Root)
+		if err != nil {
+			return err
+		}
 	}
 
 	return nil

diff --git a/rpc/beaconapi.go b/rpc/beaconapi.go
@@ -101,6 +101,7 @@ func (bc *BeaconClient) getJson(requrl string, returnValue interface{}) error {
 			return errNotFound
 		}
 		data, _ := io.ReadAll(resp.Body)
+		logger.WithField("client", bc.name).Debugf("RPC Error %v: %v", resp.StatusCode, data)
 		return fmt.Errorf("url: %v, error-response: %s", logurl, data)
 	}