Mirror/orionprotocol-sdk
1
0
Fork 0
mirror of https://github.com/orionprotocol/sdk.git synced 2026-03-29 09:07:59 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix cache

Browse Source
This commit is contained in:
Aleksandr Kraiz
2023-08-23 19:31:54 +04:00
parent 837a11a56b
commit 0148be2e13
2 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/Orion/bridge/index.ts
View File

@@ -16,7 +16,7 @@ export const EXPIRATION_DAYS = 4;
type ExternalAtomicsData = Awaited<ReturnType<typeof getHistory>>;
export default class Bridge {
readonly EXTERNAL_ATOMICS_DATA_CACHE_TIME = 5 * 1000; // 5 seconds
readonly EXTERNAL_ATOMICS_DATA_CACHE_TIME_MS = 5 * 1000; // 5 seconds
private externalAtomicSwaps: Partial<Record<string, { // wallet address -> data
lastUpdate: number
data: ExternalAtomicsData
@@ -212,15 +212,20 @@ export default class Bridge {
}
async getHistory(address: string, limit = 1000) {
const cached = this.externalAtomicSwaps[address];
if (cached !== undefined && Date.now() - cached.lastUpdate < this.EXTERNAL_ATOMICS_DATA_CACHE_TIME) {
return cached.data;
const cachedData = this.externalAtomicSwaps[address];
let data: ExternalAtomicsData | undefined;
if (cachedData !== undefined) {
const cacheIsExpired = cachedData.lastUpdate + this.EXTERNAL_ATOMICS_DATA_CACHE_TIME_MS < Date.now();
if (!cacheIsExpired) data = cachedData.data;
}
if (data === undefined) {
data = await getHistory(this.unitsArray, address, limit);
this.externalAtomicSwaps[address] = {
lastUpdate: Date.now(),
data,
};
}
const data = await getHistory(this.unitsArray, address, limit);
this.externalAtomicSwaps[address] = {
lastUpdate: Date.now(),
data,
};
return data;
}