debug logs

Cerebellum-Network · Oct 23, 2024 · 7d57db4 · 7d57db4
1 parent f79abf6
commit 7d57db4
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 1 deletion.
diff --git a/src/main.ts b/src/main.ts
@@ -21,8 +21,8 @@ import {DdcCustomerDepositsProcessor} from "./processors/ddcCustomerDepositsProc
 import {DdcCustomerChargesProcessor} from "./processors/ddcCustomerChargesProcessor";
 
 processor.run(new TypeormDatabase({ supportHotBlocks: true }), async (ctx) => {
+    console.log("Got " + ctx.blocks.length + " blocks")
     const logger = ctx.log
-
     // set up processors
     const cereBalancesProcessor = new CereBalancesProcessor()
     const ddcBalancesProcessor = new DdcBalancesProcessor()
@@ -307,6 +307,7 @@ processor.run(new TypeormDatabase({ supportHotBlocks: true }), async (ctx) => {
             amount: deposit.amount
         }))
     })
+    console.log("Storing customer deposits " + ddcCustomerDepositEntities.length)
     await ctx.store.insert(ddcCustomerDepositEntities)
 
     const ddcCustomerChargeEntities: DdcCustomerCharge[] = []
@@ -318,5 +319,6 @@ processor.run(new TypeormDatabase({ supportHotBlocks: true }), async (ctx) => {
             amount: charge.amount
         }))
     })
+    console.log("Storing customer charges " + ddcCustomerChargeEntities.length)
     await ctx.store.insert(ddcCustomerChargeEntities)
 })
diff --git a/src/processor.ts b/src/processor.ts
@@ -8,6 +8,9 @@ import {
 } from '@subsquid/substrate-processor'
 import { events } from './types'
 
+console.info("Start squid indexer")
+
+
 export const processor = new SubstrateBatchProcessor()
     .setRpcEndpoint({
         url: assertNotNull(process.env.RPC_CERE_HTTP, 'No RPC endpoint supplied'),

diff --git a/src/processors/ddcCustomerChargesProcessor.ts b/src/processors/ddcCustomerChargesProcessor.ts
@@ -24,9 +24,12 @@ export class DdcCustomerChargesProcessor extends BaseProcessor<State> {
 
         switch (event.name) {
             case events.ddcCustomers.charged.name: {
+                console.log("Got customer charged event")
                 if (events.ddcCustomers.charged.v48013.is(event)) {
+                    console.log("Event version v48013")
                     // unsupported version, just skip
                 } else if (events.ddcCustomers.charged.v48014.is(event)) {
+                    console.log("Event version v48014")
                     const decoded = events.ddcCustomers.charged.v48014.decode(event)
                     const accountId = decoded[0]
                     const amount = decoded[1]
@@ -36,6 +39,7 @@ export class DdcCustomerChargesProcessor extends BaseProcessor<State> {
                         amount: amount
                     })
                 } else if (events.ddcCustomers.charged.v48800.is(event)) {
+                    console.log("Event version v48800")
                     const decoded = events.ddcCustomers.charged.v48800.decode(event)
                     const accountId = decoded.ownerId
                     const amount = decoded.charged

diff --git a/src/processors/ddcCustomerDepositsProcessor.ts b/src/processors/ddcCustomerDepositsProcessor.ts
@@ -24,7 +24,9 @@ export class DdcCustomerDepositsProcessor extends BaseProcessor<State> {
 
         switch (event.name) {
             case events.ddcCustomers.deposited.name: {
+                console.log("Got customer deposited event")
                 if (events.ddcCustomers.deposited.v48013.is(event)) {
+                    console.log("Event version v48013")
                     const decoded = events.ddcCustomers.deposited.v48013.decode(event)
                     const accountId = decoded[0]
                     const amount = decoded[1]
@@ -34,6 +36,7 @@ export class DdcCustomerDepositsProcessor extends BaseProcessor<State> {
                         amount: amount
                     })
                 } else if (events.ddcCustomers.deposited.v48800.is(event)) {
+                    console.log("Event version v48800")
                     const decoded = events.ddcCustomers.deposited.v48800.decode(event)
                     const accountId = decoded.ownerId
                     const amount = decoded.amount