Fix indexing events multiple times

subquery · Oct 30, 2023 · 4553638 · 4553638
1 parent 98ab171
commit 4553638
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 1 deletion.
diff --git a/packages/node/src/indexer/indexer.manager.ts b/packages/node/src/indexer/indexer.manager.ts
@@ -120,8 +120,9 @@ export class IndexerManager extends BaseIndexerManager<
       for (const msg of msgs) {
         await this.indexMessage(msg, dataSources, getVM);
         const events = blockContent.events.filter(
-          (event) => event.msg?.idx === msg.idx,
+          (event) => event.tx.hash === tx.hash && event.msg?.idx === msg.idx,
         );
+
         for (const evt of events) {
           await this.indexEvent(evt, dataSources, getVM);
         }

diff --git a/packages/node/src/subcommands/testing.module.ts b/packages/node/src/subcommands/testing.module.ts
@@ -8,7 +8,9 @@ import {
   ConnectionPoolService,
   ConnectionPoolStateManager,
   DbModule,
+  InMemoryCacheService,
   PoiService,
+  PoiSyncService,
   StoreService,
   TestRunner,
 } from '@subql/node-core';
@@ -26,10 +28,12 @@ import { UnfinalizedBlocksService } from '../indexer/unfinalizedBlocks.service';
 
 @Module({
   providers: [
+    InMemoryCacheService,
     StoreService,
     StoreCacheService,
     EventEmitter2,
     PoiService,
+    PoiSyncService,
     SandboxService,
     DsProcessorService,
     DynamicDsService,

diff --git a/packages/types/src/interfaces.ts b/packages/types/src/interfaces.ts
@@ -28,6 +28,9 @@ export interface CosmosTransaction {
 }
 
 export interface CosmosMessage<T = any> {
+  /**
+   * The index of the message within the transaction
+   */
   idx: number;
   block: CosmosBlock;
   tx: CosmosTransaction;