// todo: DRY with vbb tests import tap from 'tap'; import isRoughlyEqual from 'is-roughly-equal'; import {DateTime} from 'luxon'; import flatMap from 'lodash/flatMap.js'; import {createWhen} from './lib/util.js'; import {createClient} from '../../index.js'; import {profile as bvgProfile} from '../../p/bvg/index.js'; import {createValidateFptfWith as createValidate} from './lib/validate-fptf-with.js'; import {createVbbBvgValidators} from './lib/vbb-bvg-validators.js'; import {testJourneysStationToStation} from './lib/journeys-station-to-station.js'; import {testJourneysStationToAddress} from './lib/journeys-station-to-address.js'; import {testJourneysStationToPoi} from './lib/journeys-station-to-poi.js'; import {testJourneysWalkingSpeed} from './lib/journeys-walking-speed.js'; import {testEarlierLaterJourneys} from './lib/earlier-later-journeys.js'; import {testLegCycleAlternatives} from './lib/leg-cycle-alternatives.js'; import {testRefreshJourney} from './lib/refresh-journey.js'; import {journeysFailsWithNoProduct} from './lib/journeys-fails-with-no-product.js'; import {testDepartures} from './lib/departures.js'; import {testDeparturesInDirection} from './lib/departures-in-direction.js'; import {testArrivals} from './lib/arrivals.js'; import {testJourneysWithDetour} from './lib/journeys-with-detour.js'; import {testReachableFrom} from './lib/reachable-from.js'; import {testRemarks} from './lib/remarks.js'; import {testLines} from './lib/lines.js'; const T_MOCK = 1731394800 * 1000; // 2024-11-12T08:00:00+01:00 const when = createWhen(bvgProfile.timezone, bvgProfile.locale, T_MOCK); const { cfg, validateStation, validateJourneyLeg, validateDeparture, validateMovement, } = createVbbBvgValidators({ when, }); const validate = createValidate(cfg, { station: validateStation, journeyLeg: validateJourneyLeg, departure: validateDeparture, movement: validateMovement, }); const client = createClient(bvgProfile, 'public-transport/hafas-client:test'); const amrumerStr = '900009101'; const spichernstr = '900042101'; const bismarckstr = '900024201'; const westhafen = '900001201'; const wedding = '900009104'; const württembergallee = '900026153'; const tiergarten = '900003103'; const jannowitzbrücke = '900100004'; const hour = 60 * 60 * 1000; tap.test('journeys – Spichernstr. to Bismarckstr.', async (t) => { const res = await client.journeys(spichernstr, bismarckstr, { results: 4, departure: when, stopovers: true, }); await testJourneysStationToStation({ test: t, res, validate, fromId: spichernstr, toId: bismarckstr, }); // todo: find a journey where there ticket info is always available t.end(); }); tap.test('journeys – only subway', async (t) => { const res = await client.journeys(spichernstr, bismarckstr, { results: 20, departure: when, products: { suburban: false, subway: true, tram: false, bus: false, ferry: false, express: false, regional: false, }, }); validate(t, res, 'journeysResult', 'res'); t.ok(res.journeys.length > 1); for (let i = 0; i < res.journeys.length; i++) { const journey = res.journeys[i]; for (let j = 0; j < journey.legs.length; j++) { const leg = journey.legs[j]; const name = `res.journeys[${i}].legs[${j}].line`; if (leg.line) { t.equal(leg.line.mode, 'train', name + '.mode is invalid'); t.equal(leg.line.product, 'subway', name + '.product is invalid'); } t.ok(journey.legs.some(l => l.line), name + '.legs has no subway leg'); } } t.end(); }); tap.test('journeys – fails with no product', async (t) => { await journeysFailsWithNoProduct({ test: t, fetchJourneys: client.journeys, fromId: spichernstr, toId: bismarckstr, when, products: bvgProfile.products, }); t.end(); }); // BerlKönig for public use is suspended during COVID-19. tap.skip('journeys – BerlKönig', async (t) => { const when = DateTime .fromMillis(Date.now(), { zone: 'Europe/Berlin', locale: 'de-De', }) .startOf('day') .plus({days: 1, hours: 18}) .toISO(); const {journeys} = await client.journeys({ type: 'location', address: '12101 Berlin-Tempelhof, Peter-Str.r-Weg 1', latitude: 52.476283, longitude: 13.384947, }, { type: 'location', id: '900981505', poi: true, name: 'Berlin, Tempelhofer Park Eingang Oderstr.', latitude: 52.476688, longitude: 13.41872, }, { berlkoenig: true, departure: when, }); const withBerlkoenig = flatMap(journeys, j => j.legs) .find(l => l.line && l.line.product === 'berlkoenig'); t.ok(withBerlkoenig, 'journey with BerlKönig not found'); t.ok(withBerlkoenig.line); t.equal(withBerlkoenig.line.public, true); t.equal(withBerlkoenig.line.mode, 'taxi'); t.equal(withBerlkoenig.line.product, 'berlkoenig'); t.end(); }); // todo: opt.walkingSpeed doesn't seem to work right now tap.skip('journeys: walkingSpeed', async (t) => { const havelchaussee = { type: 'location', address: 'Havelchaussee', latitude: 52.443576, longitude: 13.198973, }; const wannsee = '900053301'; await testJourneysWalkingSpeed({ test: t, journeys: client.journeys, validate, from: havelchaussee, to: wannsee, products: {bus: false}, minTimeDifference: 5 * 60 * 1000, }); }); tap.test('earlier/later journeys', async (t) => { await testEarlierLaterJourneys({ test: t, fetchJourneys: client.journeys, validate, fromId: spichernstr, toId: bismarckstr, when, }); t.end(); }); if (!process.env.VCR_MODE) { tap.test('journeys – leg cycle & alternatives', async (t) => { await testLegCycleAlternatives({ test: t, fetchJourneys: client.journeys, fromId: tiergarten, toId: jannowitzbrücke, }); t.end(); }); } tap.test('refreshJourney', async (t) => { await testRefreshJourney({ test: t, fetchJourneys: client.journeys, refreshJourney: client.refreshJourney, validate, fromId: spichernstr, toId: bismarckstr, when, }); t.end(); }); tap.test('trip details', async (t) => { const res = await client.journeys(spichernstr, amrumerStr, { results: 1, departure: when, }); const p = res.journeys[0].legs.find(l => !l.walking); t.ok(p.tripId, 'precondition failed'); t.ok(p.line.name, 'precondition failed'); const tripRes = await client.trip(p.tripId, {when}); validate(t, tripRes, 'tripResult', 'res'); t.end(); }); tap.test('journeys – station to address', async (t) => { const torfstr = { type: 'location', address: '13353 Berlin-Wedding, Torfstraße 17', latitude: 52.541797, longitude: 13.350042, }; const res = await client.journeys(spichernstr, torfstr, { results: 3, departure: when, }); await testJourneysStationToAddress({ test: t, res, validate, fromId: spichernstr, to: torfstr, }); t.end(); }); tap.test('journeys – station to POI', async (t) => { const atze = { type: 'location', id: '900980720', poi: true, name: 'Berlin, Atze Musiktheater für Kinder', latitude: 52.543333, longitude: 13.351686, }; const res = await client.journeys(spichernstr, atze, { results: 3, departure: when, }); await testJourneysStationToPoi({ test: t, res, validate, fromId: spichernstr, to: atze, }); t.end(); }); tap.test('journeys: via works – with detour', async (t) => { // Going from Westhafen to Wedding via Württembergalle without detour // is currently impossible. We check if the routing engine computes a detour. const res = await client.journeys(westhafen, wedding, { via: württembergallee, results: 1, departure: when, stopovers: true, }); await testJourneysWithDetour({ test: t, res, validate, detourIds: [württembergallee], }); t.end(); }); // todo: without detour test tap.test('departures', async (t) => { const res = await client.departures(spichernstr, { duration: 5, when, }); await testDepartures({ test: t, res, validate, id: spichernstr, }); t.end(); }); tap.test('departures with station object', async (t) => { const res = await client.departures({ type: 'station', id: spichernstr, name: 'U Spichernstr', location: { type: 'location', latitude: 1.23, longitude: 2.34, }, }, {when}); validate(t, res, 'departuresResponse', 'res'); t.end(); }); tap.test('departures at Spichernstr. in direction of Westhafen', async (t) => { await testDeparturesInDirection({ test: t, fetchDepartures: client.departures, fetchTrip: client.trip, id: spichernstr, directionIds: [westhafen], when, validate, }); t.end(); }); tap.test('departures at 7-digit station', async (t) => { const eisenach = '8010097'; // see derhuerst/vbb-hafas#22 await client.departures(eisenach, {when}); t.pass('did not fail'); t.end(); }); tap.test('arrivals', async (t) => { const res = await client.arrivals(spichernstr, { duration: 5, when, }); await testArrivals({ test: t, res, validate, id: spichernstr, }); t.end(); }); tap.test('nearby', async (t) => { const berlinerStr = '900044201'; const landhausstr = '900043252'; // Berliner Str./Bundesallee const nearby = await client.nearby({ type: 'location', latitude: 52.4873452, longitude: 13.3310411, }, { // Even though HAFAS reports Landhausstr. to be 179m, we have to pass way more here. 🙄 distance: 600, }); validate(t, nearby, 'locations', 'nearby'); t.equal(nearby[0].id, berlinerStr); t.equal(nearby[0].name, 'U Berliner Str. (Berlin)'); t.ok(nearby[0].distance > 0); t.ok(nearby[0].distance < 100); const res = nearby.find(s => s.id === landhausstr); t.ok(res, `Landhausstr. ${landhausstr} is not among the nearby stops`); t.equal(nearby[1].name, 'Landhausstr. (Berlin)'); t.ok(nearby[1].distance > 100); t.ok(nearby[1].distance < 200); t.end(); }); tap.test('locations', async (t) => { const locations = await client.locations('Alexanderplatz', {results: 20}); validate(t, locations, 'locations', 'locations'); t.ok(locations.length <= 20); t.ok(locations.find(s => s.type === 'stop' || s.type === 'station')); t.ok(locations.find(s => s.poi)); // POIs t.ok(locations.find(s => !s.name && s.address)); // addresses t.end(); }); tap.test('stop', async (t) => { const s = await client.stop(spichernstr); validate(t, s, ['stop', 'station'], 'stop'); t.equal(s.id, spichernstr); t.end(); }); tap.test('radar', async (t) => { const res = await client.radar({ north: 52.52411, west: 13.41002, south: 52.51942, east: 13.41709, }, { duration: 5 * 60, when, }); validate(t, res, 'radarResult', 'res'); t.end(); }); tap.test('reachableFrom', async (t) => { const torfstr17 = { type: 'location', address: '13353 Berlin-Wedding, Torfstr. 17', latitude: 52.541797, longitude: 13.350042, }; await testReachableFrom({ test: t, reachableFrom: client.reachableFrom, address: torfstr17, when, maxDuration: 15, validate, }); t.end(); }); tap.test('remarks', async (t) => { await testRemarks({ test: t, fetchRemarks: client.remarks, when, validate, }); t.end(); }); tap.test('lines', async (t) => { await testLines({ test: t, fetchLines: client.lines, validate, query: 'M10', }); t.end(); });