mirror of
https://github.com/brendan-ch/project-inter-server.git
synced 2026-04-19 08:50:29 +00:00
Fix typing errors in test
This commit is contained in:
@@ -84,7 +84,7 @@ describe("ETANotificationScheduler", () => {
|
|||||||
// Act
|
// Act
|
||||||
await notificationRepository.addOrUpdateNotification(notificationData1);
|
await notificationRepository.addOrUpdateNotification(notificationData1);
|
||||||
await notificationRepository.addOrUpdateNotification(notificationData2);
|
await notificationRepository.addOrUpdateNotification(notificationData2);
|
||||||
await shuttleRepository.addOrUpdateEtaFromExternalSource(eta);
|
await etaRepository.addOrUpdateEtaFromExternalSource(eta);
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
// Wait for the callback to actually be called
|
// Wait for the callback to actually be called
|
||||||
@@ -107,7 +107,7 @@ describe("ETANotificationScheduler", () => {
|
|||||||
|
|
||||||
// Act
|
// Act
|
||||||
await notificationRepository.addOrUpdateNotification(notificationData1);
|
await notificationRepository.addOrUpdateNotification(notificationData1);
|
||||||
await shuttleRepository.addOrUpdateEtaFromExternalSource(eta);
|
await etaRepository.addOrUpdateEtaFromExternalSource(eta);
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
await waitForMilliseconds(500);
|
await waitForMilliseconds(500);
|
||||||
@@ -141,7 +141,7 @@ describe("ETANotificationScheduler", () => {
|
|||||||
|
|
||||||
// Act
|
// Act
|
||||||
await notificationRepository.addOrUpdateNotification(notificationData1);
|
await notificationRepository.addOrUpdateNotification(notificationData1);
|
||||||
await shuttleRepository.addOrUpdateEtaFromExternalSource(eta);
|
await etaRepository.addOrUpdateEtaFromExternalSource(eta);
|
||||||
|
|
||||||
// Assert
|
// Assert
|
||||||
// The notification should stay scheduled to be retried once
|
// The notification should stay scheduled to be retried once
|
||||||
|
|||||||
@@ -3,8 +3,9 @@ import { generateMockEtas, generateMockRoutes } from "../../../testHelpers/mockD
|
|||||||
import { IShuttle } from "../../entities/ShuttleRepositoryEntities";
|
import { IShuttle } from "../../entities/ShuttleRepositoryEntities";
|
||||||
import { setupTestServerContext, setupTestServerHolder } from "../../../testHelpers/apolloTestServerHelpers";
|
import { setupTestServerContext, setupTestServerHolder } from "../../../testHelpers/apolloTestServerHelpers";
|
||||||
import { addMockShuttleToRepository } from "../../../testHelpers/repositorySetupHelpers";
|
import { addMockShuttleToRepository } from "../../../testHelpers/repositorySetupHelpers";
|
||||||
import assert = require("node:assert");
|
|
||||||
import { InterchangeSystem } from "../../entities/InterchangeSystem";
|
import { InterchangeSystem } from "../../entities/InterchangeSystem";
|
||||||
|
import { ExternalSourceETARepository } from "../../repositories/shuttle/eta/ExternalSourceETARepository";
|
||||||
|
import assert from "node:assert";
|
||||||
|
|
||||||
|
|
||||||
describe("ShuttleResolvers", () => {
|
describe("ShuttleResolvers", () => {
|
||||||
@@ -25,7 +26,7 @@ describe("ShuttleResolvers", () => {
|
|||||||
const etas = generateMockEtas();
|
const etas = generateMockEtas();
|
||||||
await Promise.all(etas.map(async (eta) => {
|
await Promise.all(etas.map(async (eta) => {
|
||||||
eta.shuttleId = shuttleId;
|
eta.shuttleId = shuttleId;
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(eta);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(eta);
|
||||||
}));
|
}));
|
||||||
return etas;
|
return etas;
|
||||||
}
|
}
|
||||||
@@ -146,9 +147,9 @@ describe("ShuttleResolvers", () => {
|
|||||||
const e1 = { ...generateMockEtas()[0], shuttleId: mockShuttle.id, stopId: "stA", secondsRemaining: 300 };
|
const e1 = { ...generateMockEtas()[0], shuttleId: mockShuttle.id, stopId: "stA", secondsRemaining: 300 };
|
||||||
const e2 = { ...generateMockEtas()[0], shuttleId: mockShuttle.id, stopId: "stB", secondsRemaining: 30 };
|
const e2 = { ...generateMockEtas()[0], shuttleId: mockShuttle.id, stopId: "stB", secondsRemaining: 30 };
|
||||||
const e3 = { ...generateMockEtas()[0], shuttleId: mockShuttle.id, stopId: "stC", secondsRemaining: 120 };
|
const e3 = { ...generateMockEtas()[0], shuttleId: mockShuttle.id, stopId: "stC", secondsRemaining: 120 };
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(e1);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(e1);
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(e2);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(e2);
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(e3);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(e3);
|
||||||
|
|
||||||
const response = await holder.testServer.executeOperation({
|
const response = await holder.testServer.executeOperation({
|
||||||
query,
|
query,
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ import {
|
|||||||
import { generateMockEtas, generateMockOrderedStops } from "../../../testHelpers/mockDataGenerators";
|
import { generateMockEtas, generateMockOrderedStops } from "../../../testHelpers/mockDataGenerators";
|
||||||
import { IStop } from "../../entities/ShuttleRepositoryEntities";
|
import { IStop } from "../../entities/ShuttleRepositoryEntities";
|
||||||
import { addMockStopToRepository } from "../../../testHelpers/repositorySetupHelpers";
|
import { addMockStopToRepository } from "../../../testHelpers/repositorySetupHelpers";
|
||||||
import assert = require("node:assert");
|
import { ExternalSourceETARepository } from "../../repositories/shuttle/eta/ExternalSourceETARepository";
|
||||||
|
import assert from "node:assert";
|
||||||
|
|
||||||
describe("StopResolvers", () => {
|
describe("StopResolvers", () => {
|
||||||
const holder = setupTestServerHolder();
|
const holder = setupTestServerHolder();
|
||||||
@@ -106,7 +107,7 @@ describe("StopResolvers", () => {
|
|||||||
mockEtas = mockEtas.filter((eta) => eta.stopId === mockEtas[0].stopId);
|
mockEtas = mockEtas.filter((eta) => eta.stopId === mockEtas[0].stopId);
|
||||||
await Promise.all(mockEtas.map(async eta => {
|
await Promise.all(mockEtas.map(async eta => {
|
||||||
eta.stopId = mockStop.id;
|
eta.stopId = mockStop.id;
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(eta);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(eta);
|
||||||
}));
|
}));
|
||||||
|
|
||||||
const response = await getResponseForQuery(query);
|
const response = await getResponseForQuery(query);
|
||||||
@@ -128,9 +129,9 @@ describe("StopResolvers", () => {
|
|||||||
const e1 = { ...generateMockEtas()[0], stopId: mockStop.id, shuttleId: "shA", secondsRemaining: 240 };
|
const e1 = { ...generateMockEtas()[0], stopId: mockStop.id, shuttleId: "shA", secondsRemaining: 240 };
|
||||||
const e2 = { ...generateMockEtas()[0], stopId: mockStop.id, shuttleId: "shB", secondsRemaining: 60 };
|
const e2 = { ...generateMockEtas()[0], stopId: mockStop.id, shuttleId: "shB", secondsRemaining: 60 };
|
||||||
const e3 = { ...generateMockEtas()[0], stopId: mockStop.id, shuttleId: "shC", secondsRemaining: 120 };
|
const e3 = { ...generateMockEtas()[0], stopId: mockStop.id, shuttleId: "shC", secondsRemaining: 120 };
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(e1);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(e1);
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(e2);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(e2);
|
||||||
await context.systems[0].shuttleRepository.addOrUpdateEtaFromExternalSource(e3);
|
await (context.systems[0].etaRepository as ExternalSourceETARepository).addOrUpdateEtaFromExternalSource(e3);
|
||||||
|
|
||||||
const response = await getResponseForQuery(query);
|
const response = await getResponseForQuery(query);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user