brendan/project-inter-server
1
0
Fork 0
mirror of https://github.com/brendan-ch/project-inter-server.git synced 2026-04-17 07:50:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix logic for getting stop data

Browse Source
This commit is contained in:
Brendan Chen
2025-01-09 13:34:50 -08:00
parent 798a708793
commit 04a9d4494e
1 changed files with 17 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/repositories/ApiBasedRepository.ts
View File

@@ -305,7 +305,7 @@ ${json}`);
public async getStopsBySystemId(systemId: string): Promise<IStop[]> { public async getStopsBySystemId(systemId: string): Promise<IStop[]> {
await this.updateStopsForSystemIdIfTTL(systemId); await this.updateStopsForSystemIdIfTTL(systemId);
if (!this.cache.stopsBySystemId || this.cache.stopsBySystemId[systemId]) { if (!this.cache.stopsBySystemId || !this.cache.stopsBySystemId[systemId]) {
return []; return [];
} }
return this.cache.stopsBySystemId[systemId]; return this.cache.stopsBySystemId[systemId];
@@ -339,6 +339,10 @@ ${json}`);
if (json.stops) { if (json.stops) {
const jsonStops = Object.values(json.stops); const jsonStops = Object.values(json.stops);
// TODO: restore normal cache behavior
this.cache.stopsBySystemId = {};
this.cache.stopByStopId = {};
await Promise.all(jsonStops.map(async (stop: any) => { await Promise.all(jsonStops.map(async (stop: any) => {
const constructedStop: IStop = { const constructedStop: IStop = {
name: stop.name, name: stop.name,
@@ -350,13 +354,21 @@ ${json}`);
}, },
}; };
if (this.cache.stopsBySystemId) { if (!this.cache.stopsBySystemId) {
this.cache.stopsBySystemId[systemId]?.push(constructedStop); this.cache.stopsBySystemId = {};
} }
if (this.cache.stopByStopId) { if (!this.cache.stopsBySystemId[systemId]) {
this.cache.stopByStopId[constructedStop.id] = constructedStop; this.cache.stopsBySystemId[systemId] = [];
} }
this.cache.stopsBySystemId[systemId].push(constructedStop);
if (!this.cache.stopByStopId) {
this.cache.stopByStopId = {};
}
this.cache.stopByStopId[constructedStop.id] = constructedStop;
})); }));
} }
} catch (e) { } catch (e) {