Submit new telemetry for block seen (#1005)

This submits a new telemetry if the block has been successfully added.
I decided to only submit this telemtry so if invalid blocks are sent,
they aren't added to our data points. We also add data points for forks
and not forks, so that we can measure properly.

ironfish/src/syncer.ts

@@ -31,6 +31,7 @@ export class Syncer {
   readonly chain: Blockchain
   readonly strategy: Strategy
   readonly metrics: MetricsMonitor
+  readonly telemetry: Telemetry
   readonly logger: Logger
   readonly speed: Meter
 
@@ -57,6 +58,8 @@ export class Syncer {
     this.chain = options.chain
     this.strategy = options.strategy
     this.logger = logger.withTag('syncer')
+    this.telemetry = options.telemetry
+
     this.metrics =
       options.metrics ||
       new MetricsMonitor({ telemetry: options.telemetry, logger: this.logger })
@@ -484,6 +487,8 @@ export class Syncer {
       return false
     }
 
+    const seenAt = new Date()
+
     const { added, block } = await this.addBlock(peer, newBlock)
 
     if (!peer.sequence || block.header.sequence > peer.sequence) {
@@ -492,6 +497,10 @@ export class Syncer {
 
     this.onGossip.emit(block)
 
+    if (added) {
+      this.telemetry.submitNewBlockSeen(block, seenAt)
+    }
+
     return added
   }
 

ironfish/src/telemetry/interfaces/metric.ts

@@ -12,7 +12,7 @@ export interface Metric {
    * A description for the container that the fields measure. Defaults to
    * 'node' because all metrics are submitted from an Iron Fish node.
    */
-  measurement: 'node'
+  measurement: string
 
   /**
    * The name of whatever is being measured.

ironfish/src/telemetry/telemetry.ts

@@ -166,4 +166,30 @@ export class Telemetry {
       ],
     })
   }
+
+  submitNewBlockSeen(block: Block, seenAt: Date): void {
+    this.submit({
+      measurement: 'propagation',
+      name: 'propagation',
+      timestamp: seenAt,
+      tags: [
+        {
+          name: 'block_hash',
+          value: block.header.hash.toString('hex'),
+        },
+      ],
+      fields: [
+        {
+          name: 'block_timestamp',
+          type: 'integer',
+          value: block.header.timestamp.valueOf(),
+        },
+        {
+          name: 'block_sequence',
+          type: 'integer',
+          value: block.header.sequence,
+        },
+      ],
+    })
+  }
 }