Skip to content

Commit d6095f7

Browse files
committed
fix skip bridge
1 parent 3b34f98 commit d6095f7

File tree

2 files changed

+19
-14
lines changed

2 files changed

+19
-14
lines changed

src/server/jobs/runAllAdapters.ts

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import bridgeNetworks from "../../data/bridgeNetworkData";
22
import { sql } from "../../utils/db";
3-
import { runAdapterToCurrentBlock } from "../../utils/adapter";
3+
import { runAdapterToCurrentBlock, shouldSkipBridge } from "../../utils/adapter";
44
import { PromisePool } from "@supercharge/promise-pool";
55

66
export const runAllAdapters = async () => {
@@ -25,6 +25,9 @@ export const runAllAdapters = async () => {
2525
.for(shuffledBridgeNetworks)
2626
.process(async (adapter) => {
2727
try {
28+
if (shouldSkipBridge(adapter.bridgeDbName)) {
29+
return;
30+
}
2831
console.log("Starting adapter", adapter.bridgeDbName);
2932
await runAdapterToCurrentBlock(adapter, true, "upsert", lastRecordedBlocks[0].result);
3033
} catch (e) {

src/utils/adapter.ts

Lines changed: 15 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,20 @@ const retry = require("async-retry");
2222

2323
const SECONDS_IN_DAY = 86400;
2424

25+
export const bridgesToSkip = [
26+
"wormhole",
27+
"layerzero",
28+
"hyperlane",
29+
"intersoon",
30+
"relay",
31+
"cashmere",
32+
"teleswap",
33+
"mayan",
34+
"ccip",
35+
];
36+
37+
export const shouldSkipBridge = (bridgeDbName: string) => bridgesToSkip.includes(bridgeDbName);
38+
2539
interface AdapterProgress {
2640
lastSuccessfulBlock: number;
2741
lastUpdated: number;
@@ -340,18 +354,6 @@ export const runAllAdaptersTimestampRange = async (
340354
console.log("runAllAdaptersTimestampRange successfully ran.");
341355
};
342356

343-
const bridgesToSkip = [
344-
"wormhole",
345-
"layerzero",
346-
"hyperlane",
347-
"intersoon",
348-
"relay",
349-
"cashmere",
350-
"teleswap",
351-
"mayan",
352-
"ccip",
353-
];
354-
355357
export const runAdapterHistorical = async (
356358
startBlock: number,
357359
endBlock: number,
@@ -366,7 +368,7 @@ export const runAdapterHistorical = async (
366368
const bridgeNetwork = bridgeNetworks.filter((bridgeNetwork) => bridgeNetwork.id === bridgeNetworkId)[0];
367369
const { bridgeDbName, displayName } = bridgeNetwork;
368370

369-
if (bridgesToSkip.includes(bridgeDbName)) {
371+
if (shouldSkipBridge(bridgeDbName)) {
370372
return;
371373
}
372374

0 commit comments

Comments
 (0)