diff --git a/src/loaders/RepositoryDataLoader.ts b/src/loaders/RepositoryDataLoader.ts index c4996f1..efe4298 100644 --- a/src/loaders/RepositoryDataLoader.ts +++ b/src/loaders/RepositoryDataLoader.ts @@ -48,6 +48,7 @@ export class RepositoryDataLoader { if (!this.shouldBeRunning) return; try { + await this.clearAllData(); await this.fetchAndUpdateSystemData(); await this.fetchAndUpdateRouteDataForExistingSystems(); await this.fetchAndUpdateStopAndPolylineDataForRoutesInExistingSystems(); @@ -60,6 +61,15 @@ export class RepositoryDataLoader { this.timer = setTimeout(this.startFetchDataAndUpdate, timeout); } + private async clearAllData() { + await this.repository.clearRouteData(); + await this.repository.clearSystemData(); + await this.repository.clearEtaData(); + await this.repository.clearStopData(); + await this.repository.clearOrderedStopData(); + await this.repository.clearShuttleData(); + } + private async fetchAndUpdateSystemData() { const params = { getSystems: "2",