Log attestation's journey published by local validators

ChainSafe · Dec 17, 2021 · bcf5b1e · bcf5b1e
1 parent f40f42b
commit bcf5b1e
Show file tree

Hide file tree

Showing 4 changed files with 36 additions and 0 deletions.
diff --git a/packages/lodestar/src/api/impl/beacon/pool/index.ts b/packages/lodestar/src/api/impl/beacon/pool/index.ts
@@ -58,6 +58,17 @@ export function getBeaconPoolApi({
               network.gossip.publishBeaconAttestation(attestation, subnet),
               chain.attestationPool.add(attestation),
             ]);
+
+            const attestingIndex = indexedAttestation.attestingIndices[0];
+            if (metrics?.hasLocalValidator(attestingIndex)) {
+              const {slot, index} = attestation.data;
+              logger.verbose("Local validator published attestation", {
+                attestingIndex,
+                slot,
+                index,
+                subnet,
+              });
+            }
           } catch (e) {
             errors.push(e as Error);
             logger.error(

diff --git a/packages/lodestar/src/api/impl/validator/index.ts b/packages/lodestar/src/api/impl/validator/index.ts
@@ -442,6 +442,16 @@ export function getValidatorApi({chain, config, logger, metrics, network, sync}:
               signedAggregateAndProof,
               indexedAttestation
             );
+            for (const validatorIndex of indexedAttestation.attestingIndices) {
+              if (metrics?.hasLocalValidator(validatorIndex)) {
+                const {slot, index} = indexedAttestation.data;
+                logger.verbose("Local validator attestation is included in api AggregatedAndProof and published", {
+                  validatorIndex,
+                  slot,
+                  index,
+                });
+              }
+            }
 
             await Promise.all([
               chain.aggregatedAttestationPool.add(

diff --git a/packages/lodestar/src/metrics/validatorMonitor.ts b/packages/lodestar/src/metrics/validatorMonitor.ts
@@ -19,6 +19,7 @@ export enum OpSource {
 
 export interface IValidatorMonitor {
   registerLocalValidator(index: number): void;
+  hasLocalValidator(index: number): boolean;
   registerValidatorStatuses(currentEpoch: Epoch, statuses: allForks.IAttesterStatus[], balances?: number[]): void;
   registerBeaconBlock(src: OpSource, seenTimestampSec: Seconds, block: allForks.BeaconBlock): void;
   registerUnaggregatedAttestation(
@@ -175,6 +176,10 @@ export function createValidatorMonitor(
       }
     },
 
+    hasLocalValidator(index) {
+      return validators.has(index);
+    },
+
     registerValidatorStatuses(currentEpoch, statuses, balances) {
       // Prevent registering status for the same epoch twice. processEpoch() may be ran more than once for the same epoch.
       if (currentEpoch <= lastRegisteredStatusEpoch) {

diff --git a/packages/lodestar/src/network/gossip/handlers/index.ts b/packages/lodestar/src/network/gossip/handlers/index.ts
@@ -131,6 +131,16 @@ export function getGossipHandlers(modules: ValidatorFnsModules): GossipHandlers
           signedAggregateAndProof,
           indexedAttestation
         );
+        for (const validatorIndex of indexedAttestation.attestingIndices) {
+          if (metrics?.hasLocalValidator(validatorIndex)) {
+            const {slot, index} = indexedAttestation.data;
+            logger.verbose("Local validator attestation is included in gossip AggregatedAndProof", {
+              validatorIndex,
+              slot,
+              index,
+            });
+          }
+        }
 
         // TODO: Add DoS resistant pending attestation pool
         // switch (e.type.code) {