improved transform logging

src/queues/transform.ts

@@ -73,9 +73,9 @@ export class TransformationsQueue extends BaseQueue<TransformationsQueuePayload>
       throw new Error('no contract address nor code ID filter provided')
     } else {
       console.log(
-        `transforming events for contract addresses: ${addresses?.join(
-          ', '
-        )} and code IDs: ${codeIds.join(', ')}`
+        `transforming events for contract addresses: ${
+          addresses?.join(', ') || '<any>'
+        } and code IDs: ${codeIds.length > 0 ? codeIds.join(', ') : '<any>'}`
       )
     }
 
@@ -110,6 +110,11 @@ export class TransformationsQueue extends BaseQueue<TransformationsQueuePayload>
     let processed = 0
     let transformed = 0
 
+    const logState = () =>
+      console.log(
+        `transformed/processed/total: ${transformed.toLocaleString()}/${processed.toLocaleString()}/${total.toLocaleString()}. latest block height: ${latestBlockHeight.toLocaleString()}`
+      )
+
     let latestBlockEventIdsSeen: number[] = []
     while (processed < total) {
       const events = await WasmStateEvent.findAll({
@@ -172,11 +177,11 @@ export class TransformationsQueue extends BaseQueue<TransformationsQueuePayload>
 
       transformed += transformations.length
 
-      console.log(
-        `transformed/processed/total: ${transformed.toLocaleString()}/${processed.toLocaleString()}/${total.toLocaleString()}. latest block height: ${latestBlockHeight.toLocaleString()}`
-      )
+      logState()
     }
 
+    logState()
+
     console.log('done!')
   }
 }

src/scripts/transform.ts

@@ -48,8 +48,6 @@ const main = async () => {
     codeIdsKeys,
   } = program.opts()
 
-  console.log(`\n[${new Date().toISOString()}] Transforming existing events...`)
-
   // Load config with config option.
   const config = loadConfig(_config)
 
@@ -73,8 +71,6 @@ const main = async () => {
     },
   } as any)
 
-  console.log(`\n[${new Date().toISOString()}] Transforming complete.`)
-
   await sequelize.close()
 
   process.exit(0)