trade/trade-drift-dlob
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add back returning after cache hit

Browse Source
This commit is contained in:
Nour Alharithi
2024-12-03 16:35:42 -08:00
parent bae6bfef80
commit 3c8ca58975
1 changed files with 18 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/index.ts
View File

@@ -650,7 +650,8 @@ const main = async (): Promise<void> => {
const depth = Math.min(parseInt(adjustedDepth as string) ?? 1, 100); const depth = Math.min(parseInt(adjustedDepth as string) ?? 1, 100);
redisL2['bids'] = redisL2['bids']?.slice(0, depth); redisL2['bids'] = redisL2['bids']?.slice(0, depth);
redisL2['asks'] = redisL2['asks']?.slice(0, depth); redisL2['asks'] = redisL2['asks']?.slice(0, depth);
console.log(redisL2['slot']);
console.log(SLOT_STALENESS_TOLERANCE);
if ( if (
redisL2 && redisL2 &&
dlobProvider.getSlot() - redisL2['slot'] < SLOT_STALENESS_TOLERANCE dlobProvider.getSlot() - redisL2['slot'] < SLOT_STALENESS_TOLERANCE
@@ -675,6 +676,7 @@ const main = async (): Promise<void> => {
) { ) {
l2Formatted = JSON.stringify(redisL2); l2Formatted = JSON.stringify(redisL2);
} }
}
if (l2Formatted) { if (l2Formatted) {
cacheHitCounter.add(1, { cacheHitCounter.add(1, {
@@ -685,7 +687,6 @@ const main = async (): Promise<void> => {
res.end(l2Formatted); res.end(l2Formatted);
return; return;
} }
}
let validateIncludeVamm = false; let validateIncludeVamm = false;
if (!isSpot && `${includeVamm}`.toLowerCase() === 'true') { if (!isSpot && `${includeVamm}`.toLowerCase() === 'true') {
@@ -824,6 +825,7 @@ const main = async (): Promise<void> => {
l2Formatted = redisL2; l2Formatted = redisL2;
} }
} }
}
if (l2Formatted) { if (l2Formatted) {
cacheHitCounter.add(1, { cacheHitCounter.add(1, {
@@ -832,7 +834,6 @@ const main = async (): Promise<void> => {
}); });
return l2Formatted; return l2Formatted;
} }
}
let validateIncludeVamm = false; let validateIncludeVamm = false;
if (!isSpot && `${includeVamm}`.toLowerCase() === 'true') { if (!isSpot && `${includeVamm}`.toLowerCase() === 'true') {