Skip to content

Commit e2a0d95

Browse files
committed
fix oom
1 parent 92f922f commit e2a0d95

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/handlers/getBridgeStatsOnDay.ts

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,9 @@ const getBridgeStatsOnDay = async (timestamp: string = "0", chain: string, bridg
129129
});
130130

131131
const queryTimestamp = getTimestampAtStartOfDay(parseInt(timestamp));
132-
const endTimestamp = getCurrentUnixTimestamp();
132+
const maxEndTimestamp = queryTimestamp + 86400;
133+
const currentTimestamp = getCurrentUnixTimestamp();
134+
const endTimestamp = Math.max(queryTimestamp, Math.min(maxEndTimestamp, currentTimestamp));
133135

134136
let sourceChainsDailyData = [] as IAggregatedData[];
135137
await Promise.all(
@@ -140,9 +142,10 @@ const getBridgeStatsOnDay = async (timestamp: string = "0", chain: string, bridg
140142
config.chain,
141143
config.bridge_name
142144
);
143-
sourceChainsDailyData = [...sourceChainData, ...sourceChainsDailyData];
145+
sourceChainsDailyData.push(...sourceChainData);
144146
})
145147
);
148+
146149
const dailyData = await queryAggregatedTokensInRange(queryTimestamp, endTimestamp, queryChain, bridgeDbName);
147150
let dailyTokensDeposited = {} as TokenRecord;
148151
let dailyTokensWithdrawn = {} as TokenRecord;
@@ -176,6 +179,7 @@ const getBridgeStatsOnDay = async (timestamp: string = "0", chain: string, bridg
176179
collectTokenIds(total_tokens_deposited);
177180
collectTokenIds(total_tokens_withdrawn);
178181
});
182+
179183
let prices: Record<string, any> = {};
180184
try {
181185
prices = (await Promise.race([

0 commit comments

Comments
 (0)