WIP: initial action matchers setup

src/actions/actionHandlers.ts

@@ -0,0 +1,5 @@
+import { ActionHandler } from './types';
+
+export const handleMintTokensAction: ActionHandler = async (events) => {
+  console.log('Mint Tokens action ', events);
+};

src/actions/actionMatchers.ts

@@ -0,0 +1 @@
+const actionMatchers = [];

src/actions/types.ts

@@ -0,0 +1,17 @@
+import { ContractEvent } from '~graphql';
+
+interface BaseActionMatcher {
+  handler: (events: ContractEvent[]) => Promise<void>;
+}
+
+interface SimpleActionMatcher extends BaseActionMatcher {
+  eventSignatures: string[];
+}
+
+interface FunctionActionMatcher extends BaseActionMatcher {
+  matcherFn: (events: ContractEvent[]) => boolean;
+}
+
+export type ActionMatcher = SimpleActionMatcher | FunctionActionMatcher;
+
+export type ActionHandler = (events: ContractEvent[]) => Promise<void>;

src/blockProcessor.ts

@@ -11,6 +11,8 @@ import {
   setLastBlockNumber,
 } from '~utils';
 import { BLOCK_PAGING_SIZE } from '~constants';
+import { ContractEventsSignatures } from '~types';
+import { handleMintTokensAction } from '~actions/actionHandlers';
 
 let isProcessing = false;
 const blockLogs = new Map<number, Log[]>();
@@ -176,6 +178,8 @@ export const processNextBlock = async (): Promise<void> => {
       }
     }
 
+    const blockEvents = [];
+
     for (const log of logs) {
       // Find listeners that match the log
       const listeners = getMatchingListeners(log.topics, log.address);
@@ -201,11 +205,20 @@ export const processNextBlock = async (): Promise<void> => {
           continue;
         }
 
+        blockEvents.push(event);
+
         // Call the handler in a blocking way to ensure events get processed sequentially
         await listener.handler(event, listener);
       }
     }
 
+    const actionMatchers = [
+      {
+        eventSignatures: [ContractEventsSignatures.TokensMinted],
+        handler: handleMintTokensAction,
+      },
+    ];
+
     verbose('processed block', currentBlockNumber);
 
     lastBlockNumber = currentBlockNumber;