configurable delay (experimental)

galacticcouncil · Dec 12, 2024 · c68f186 · c68f186
1 parent d126f2a
commit c68f186
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/config.js b/src/config.js
@@ -3,6 +3,7 @@ dotenv.config();
 
 export const rpc = process.env.RPC_URL || 'wss://localhost:9988';
 export const ahRpc = process.env.AH_RPC_URL || 'wss://polkadot-asset-hub-rpc.polkadot.io';
+export const delay = Number(process.env.DELAY) || 1;
 export const token = process.env.DISCORD_TOKEN;
 export const channel = process.env.DISCORD_CHANNEL;
 export const sha = process.env.COMMIT_SHA || 'dev';

diff --git a/src/events.js b/src/events.js
@@ -1,5 +1,6 @@
 import {api} from './api.js';
 import ethers from "ethers";
+import {delay} from "./config.js";
 
 export class Events {
   listeners = [];
@@ -39,7 +40,7 @@ export class Events {
 
   startWatching() {
     this.killWatcher = api().query.system.number(head => {
-      const block = head.toNumber() - 1;
+      const block = head.toNumber() - delay;
       this.emitFromBlock(block);
     });
   }