Merge pull request #29 from pinax-network/rename-finalBlocksOnly

format

index.ts

@@ -16,7 +16,7 @@ export async function action(options: WebhookRunOptions) {
   const finalBlocksOnly = boolean.parse(options.finalBlocksOnly);
 
   // Block Emitter
-  const { emitter, moduleHash } = await setup({...options, cursor});
+  const { emitter, moduleHash } = await setup({ ...options, cursor });
 
   // Queue
   const queue = new PQueue({ concurrency: 1 }); // all messages are sent in block order, no need to parallelize
@@ -80,5 +80,3 @@ export async function action(options: WebhookRunOptions) {
     http.server.close();
   });
 }
-
-

src/postWebhook.ts

@@ -18,17 +18,18 @@ function now() {
 }
 
 let blocks = 0;
-let start = now();
+const start = now();
 // let lastUpdate = now();
 
 // TO-DO replace with Prometheus metrics
 function logProgress(metadata?: Metadata) {
-  if ( !metadata ) return;
+  if (!metadata) return;
   const delta = now() - start;
   const rate = Math.round(blocks / delta);
   const minutes = Math.round(delta / 60);
   const seconds = delta % 60;
-  if ( blocks ) logUpdate(`[app] timestamp=${metadata.clock.timestamp} block_number=${metadata.clock.number} blocks=${blocks} [${rate} b/s] (${minutes}m ${seconds}s)`);
+  if (blocks)
+    logUpdate(`[app] timestamp=${metadata.clock.timestamp} block_number=${metadata.clock.number} blocks=${blocks} [${rate} b/s] (${minutes}m ${seconds}s)`);
   blocks++;
 }