mirror of
https://github.com/brendan-ch/project-inter-server.git
synced 2026-04-17 16:00:32 +00:00
remove clearing of data in timed repository and update tests
This commit is contained in:
@@ -47,15 +47,10 @@ export class TimedApiBasedRepositoryLoader extends ApiBasedRepositoryLoader {
|
|||||||
if (!this.shouldBeRunning) return;
|
if (!this.shouldBeRunning) return;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await this.repository.clearSystemData();
|
|
||||||
await this.fetchAndUpdateSystemData();
|
await this.fetchAndUpdateSystemData();
|
||||||
await this.repository.clearRouteData();
|
|
||||||
await this.fetchAndUpdateRouteDataForExistingSystemsInRepository();
|
await this.fetchAndUpdateRouteDataForExistingSystemsInRepository();
|
||||||
await this.repository.clearStopData();
|
|
||||||
await this.fetchAndUpdateStopAndPolylineDataForRoutesInExistingSystemsInRepository();
|
await this.fetchAndUpdateStopAndPolylineDataForRoutesInExistingSystemsInRepository();
|
||||||
await this.repository.clearShuttleData();
|
|
||||||
await this.fetchAndUpdateShuttleDataForExistingSystemsInRepository();
|
await this.fetchAndUpdateShuttleDataForExistingSystemsInRepository();
|
||||||
await this.repository.clearEtaData();
|
|
||||||
await this.fetchAndUpdateEtaDataForExistingStopsForSystemsInRepository();
|
await this.fetchAndUpdateEtaDataForExistingStopsForSystemsInRepository();
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
console.error(e);
|
console.error(e);
|
||||||
|
|||||||
@@ -1,10 +1,9 @@
|
|||||||
import { afterEach, beforeAll, beforeEach, describe, expect, it, jest } from "@jest/globals";
|
import { afterEach, beforeAll, beforeEach, describe, expect, it, jest } from "@jest/globals";
|
||||||
import { TimedApiBasedRepositoryLoader } from "../../src/loaders/TimedApiBasedRepositoryLoader";
|
import { TimedApiBasedRepositoryLoader } from "../../src/loaders/TimedApiBasedRepositoryLoader";
|
||||||
import { resetGlobalFetchMockJson } from "../mockHelpers/fetchMockHelpers";
|
import { resetGlobalFetchMockJson } from "../mockHelpers/fetchMockHelpers";
|
||||||
import { GetterSetterRepository } from "../../src/repositories/GetterSetterRepository";
|
import { UnoptimizedInMemoryRepository } from "../../src/repositories/UnoptimizedInMemoryRepository";
|
||||||
|
|
||||||
describe("TimedApiBasedRepositoryLoader", () => {
|
describe("TimedApiBasedRepositoryLoader", () => {
|
||||||
let repositoryMock: GetterSetterRepository;
|
|
||||||
let loader: TimedApiBasedRepositoryLoader;
|
let loader: TimedApiBasedRepositoryLoader;
|
||||||
let spies: any;
|
let spies: any;
|
||||||
|
|
||||||
@@ -16,15 +15,7 @@ describe("TimedApiBasedRepositoryLoader", () => {
|
|||||||
beforeEach(() => {
|
beforeEach(() => {
|
||||||
resetGlobalFetchMockJson();
|
resetGlobalFetchMockJson();
|
||||||
|
|
||||||
repositoryMock = {
|
loader = new TimedApiBasedRepositoryLoader(new UnoptimizedInMemoryRepository());
|
||||||
clearSystemData: jest.fn(),
|
|
||||||
clearRouteData: jest.fn(),
|
|
||||||
clearStopData: jest.fn(),
|
|
||||||
clearShuttleData: jest.fn(),
|
|
||||||
clearEtaData: jest.fn(),
|
|
||||||
} as unknown as GetterSetterRepository;
|
|
||||||
|
|
||||||
loader = new TimedApiBasedRepositoryLoader(repositoryMock);
|
|
||||||
|
|
||||||
spies = {
|
spies = {
|
||||||
fetchAndUpdateSystemData: jest.spyOn(loader, 'fetchAndUpdateSystemData'),
|
fetchAndUpdateSystemData: jest.spyOn(loader, 'fetchAndUpdateSystemData'),
|
||||||
@@ -49,9 +40,6 @@ describe("TimedApiBasedRepositoryLoader", () => {
|
|||||||
await loader.start();
|
await loader.start();
|
||||||
expect(loader["shouldBeRunning"]).toBe(true);
|
expect(loader["shouldBeRunning"]).toBe(true);
|
||||||
|
|
||||||
Object.values(repositoryMock).forEach((mockFn) => {
|
|
||||||
expect(mockFn).toHaveBeenCalled();
|
|
||||||
});
|
|
||||||
Object.values(spies).forEach((spy: any) => {
|
Object.values(spies).forEach((spy: any) => {
|
||||||
expect(spy).toHaveBeenCalled();
|
expect(spy).toHaveBeenCalled();
|
||||||
});
|
});
|
||||||
@@ -64,9 +52,6 @@ describe("TimedApiBasedRepositoryLoader", () => {
|
|||||||
await loader.start();
|
await loader.start();
|
||||||
await loader.start();
|
await loader.start();
|
||||||
|
|
||||||
Object.values(repositoryMock).forEach((mockFn) => {
|
|
||||||
expect(mockFn).toHaveBeenCalledTimes(1);
|
|
||||||
});
|
|
||||||
Object.values(spies).forEach((spy: any) => {
|
Object.values(spies).forEach((spy: any) => {
|
||||||
expect(spy).toHaveBeenCalledTimes(1);
|
expect(spy).toHaveBeenCalledTimes(1);
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user