Fix filtering issue with undefined filter options

subquery · Aug 7, 2024 · 7ab85e6 · 7ab85e6
1 parent 43b95ff
commit 7ab85e6
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 3 deletions.
diff --git a/packages/node/src/algorand/utils.algorand.spec.ts b/packages/node/src/algorand/utils.algorand.spec.ts
@@ -85,5 +85,14 @@ describe('Algorand Filters', () => {
         }),
       ).toBeTruthy();
     });
+
+    it('should not filter undefined options', () => {
+      expect(
+        filterTransaction(block.transactions![4], {
+          sender: 'ZW3ISEHZUHPO7OZGMKLKIIMKVICOUDRCERI454I3DB2BH52HGLSO67W754',
+          receiver: undefined,
+        }),
+      ).toBeTruthy();
+    });
   });
 });
diff --git a/packages/node/src/algorand/utils.algorand.ts b/packages/node/src/algorand/utils.algorand.ts
@@ -137,11 +137,11 @@ export function filterTransaction(
   for (const key in filterByKey) {
     if (
       mappingFilterTransaction[txn.txType] &&
+      filterByKey[key] !== undefined &&
       !txComparator(
         filterByKey[key],
         get(txn, mappingFilterTransaction[txn.txType][key]),
       )
-      // filterByKey[key] !== get(txn, mappingFilterTransaction[txn.txType][key])
     ) {
       return false;
     }

diff --git a/packages/node/src/indexer/dictionary/algorandDictionary.service.ts b/packages/node/src/indexer/dictionary/algorandDictionary.service.ts
@@ -54,6 +54,7 @@ export class AlgorandDictionaryService extends DictionaryService<
         );
       }
     }
+
     this.init(dictionariesV1);
   }
 

diff --git a/packages/node/src/indexer/dictionary/v1/algorandDictionaryV1.ts b/packages/node/src/indexer/dictionary/v1/algorandDictionaryV1.ts
@@ -13,7 +13,6 @@ import { AlgorandBlockFilter, AlgorandDataSource } from '@subql/types-algorand';
 import {
   DictionaryQueryCondition,
   DictionaryQueryEntry as DictionaryV1QueryEntry,
-  DsProcessor,
 } from '@subql/types-core';
 import { sortBy, uniqBy } from 'lodash';
 import { SubqueryProject } from '../../../configure/SubqueryProject';
@@ -71,7 +70,6 @@ function buildDictionaryV1QueryEntries(
       const baseHandlerKind = getBaseHandlerKind(ds, handler, getDsProcessor);
       let filterList: AlgorandRuntimeHandlerFilter[];
       if (isCustomDs(ds)) {
-        //const processor = plugin.handlerProcessors[handler.kind];
         filterList = getBaseHandlerFilters<AlgorandRuntimeHandlerFilter>(
           ds,
           handler.kind,

diff --git a/packages/node/src/indexer/indexer.manager.ts b/packages/node/src/indexer/indexer.manager.ts
@@ -93,6 +93,7 @@ export class IndexerManager extends BaseIndexerManager<
     getVM: (d: AlgorandDataSource) => Promise<IndexerSandbox>,
   ): Promise<void> {
     await this.indexBlockContent(block, dataSources, getVM);
+
     for (const tx of block.transactions ?? []) {
       await this.indexBlockTransactionContent(tx, dataSources, getVM);
     }