'use strict' const isRoughlyEqual = require('is-roughly-equal') const {createWhen} = require('./lib/util') const createClient = require('../..') const nahshProfile = require('../../p/nahsh') const products = require('../../p/nahsh/products') const { line: createValidateLine, station: createValidateStation } = require('./lib/validators') const createValidate = require('./lib/validate-fptf-with') const {test} = require('./lib/util') const testJourneysStationToStation = require('./lib/journeys-station-to-station') const testJourneysStationToAddress = require('./lib/journeys-station-to-address') const testJourneysStationToPoi = require('./lib/journeys-station-to-poi') const testEarlierLaterJourneys = require('./lib/earlier-later-journeys') const testRefreshJourney = require('./lib/refresh-journey') const journeysFailsWithNoProduct = require('./lib/journeys-fails-with-no-product') const testDepartures = require('./lib/departures') const testDeparturesInDirection = require('./lib/departures-in-direction') const testArrivals = require('./lib/arrivals') const testReachableFrom = require('./lib/reachable-from') const when = createWhen('Europe/Berlin', 'de-DE') const cfg = { when, stationCoordsOptional: false, products, maxLatitude: 55.15, minLongitude: 7.5, minLatitude: 53.15, maxLongitude: 11.6 } const _validateLine = createValidateLine(cfg) const validateLine = (validate, l, name) => { if (l && l.product === 'onCall') { // skip line validation // https://github.com/derhuerst/hafas-client/issues/8#issuecomment-355839965 l = Object.assign({}, l) l.mode = 'taxi' } _validateLine(validate, l, name) } const validate = createValidate(cfg, { line: validateLine }) const assertValidPrice = (t, p) => { t.ok(p) if (p.amount !== null) { t.equal(typeof p.amount, 'number') t.ok(p.amount > 0) } if (p.hint !== null) { t.equal(typeof p.hint, 'string') t.ok(p.hint) } } const client = createClient(nahshProfile, 'public-transport/hafas-client:test') const kielHbf = '9049079' const flensburg = '9027253' const luebeckHbf = '9057819' const husum = '9044660' const schleswig = '9081683' const ellerbekerMarkt = '9049027' const seefischmarkt = '9049245' const kielRaeucherei = '9049217' test('journeys – Kiel Hbf to Flensburg', async (t) => { const res = await client.journeys(kielHbf, flensburg, { results: 4, departure: when, stopovers: true }) await testJourneysStationToStation({ test: t, res, validate, fromId: kielHbf, toId: flensburg }) for (let i = 0; i < res.journeys.length; i++) { const j = res.journeys[i] // todo: find a journey where there pricing info is always available if (j.price) assertValidPrice(t, j.price, `res.journeys[${i}].price`) } t.end() }) // todo: journeys, only one product test('journeys – fails with no product', (t) => { journeysFailsWithNoProduct({ test: t, fetchJourneys: client.journeys, fromId: kielHbf, toId: flensburg, when, products }) t.end() }) test('Kiel Hbf to Berliner Str. 80, Husum', async (t) => { const berlinerStr = { type: 'location', address: 'Husum, Berliner Straße 80', latitude: 54.488995, longitude: 9.056263 } const res = await client.journeys(kielHbf, berlinerStr, { results: 3, departure: when }) await testJourneysStationToAddress({ test: t, res, validate, fromId: kielHbf, to: berlinerStr }) t.end() }) test('Kiel Hbf to Holstentor', async (t) => { const holstentor = { type: 'location', id: '970003118', poi: true, name: 'Hansestadt Lübeck, Holstentor (Denkmal)', latitude: 53.866321, longitude: 10.679976 } const res = await client.journeys(kielHbf, holstentor, { results: 3, departure: when }) await testJourneysStationToPoi({ test: t, res, validate, fromId: kielHbf, to: holstentor }) t.end() }) test('Husum to Lübeck Hbf with stopover at Kiel Hbf', async (t) => { const res = await client.journeys(husum, luebeckHbf, { via: kielHbf, results: 1, departure: when, stopovers: true }) validate(t, res, 'journeysResult', 'res') const leg = res.journeys[0].legs.some((leg) => { return leg.stopovers && leg.stopovers.some((stopover) => { const s = stopover.stop return s.station && s.station.id === kielHbf || s.id === kielHbf }) }) t.ok(leg, 'Kiel Hbf is not being passed') t.end() }) test('earlier/later journeys, Kiel Hbf -> Flensburg', async (t) => { await testEarlierLaterJourneys({ test: t, fetchJourneys: client.journeys, validate, fromId: kielHbf, toId: flensburg, when }) t.end() }) test('refreshJourney', async (t) => { await testRefreshJourney({ test: t, fetchJourneys: client.journeys, refreshJourney: client.refreshJourney, validate, fromId: kielHbf, toId: flensburg, when }) t.end() }) // todo: with detour test // todo: without detour test test('trip details', async (t) => { const res = await client.journeys(flensburg, husum, { 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 trip = await client.trip(p.tripId, p.line.name, {when}) validate(t, trip, 'trip', 'trip') t.end() }) test('departures at Kiel Räucherei', async (t) => { const departures = await client.departures(kielRaeucherei, { duration: 30, when, stopovers: true }) await testDepartures({ test: t, departures, validate, id: kielRaeucherei }) t.end() }) test('departures with station object', async (t) => { const deps = await client.departures({ type: 'station', id: kielHbf, name: 'Kiel Hbf', location: { type: 'location', latitude: 1.23, longitude: 2.34 } }, {when}) validate(t, deps, 'departures', 'departures') t.end() }) test('departures at Berlin Hbf in direction of Berlin Ostbahnhof', async (t) => { await testDeparturesInDirection({ test: t, fetchDepartures: client.departures, fetchTrip: client.trip, id: ellerbekerMarkt, directionIds: [seefischmarkt, '710102'], when, validate }) t.end() }) test('arrivals at Kiel Räucherei', async (t) => { const arrivals = await client.arrivals(kielRaeucherei, { duration: 30, when }) await testArrivals({ test: t, arrivals, validate, id: kielRaeucherei }) t.end() }) test('nearby Kiel Hbf', async (t) => { const kielHbfPosition = { type: 'location', latitude: 54.314982, longitude: 10.131976 } const nearby = await client.nearby(kielHbfPosition, { results: 2, distance: 400 }) validate(t, nearby, 'locations', 'nearby') t.ok(Array.isArray(nearby)) t.equal(nearby.length, 2) t.ok(nearby[0].id === kielHbf || nearby[0].id === '8000199') t.equal(nearby[0].name, 'Kiel Hbf') t.ok(nearby[0].distance >= 0) t.ok(nearby[0].distance <= 100) t.end() }) test('locations named "Kiel Rathaus"', async (t) => { const kielRathaus = '9049200' const locations = await client.locations('Kiel Rathaus', { results: 15 }) validate(t, locations, 'locations', 'locations') t.ok(locations.length <= 15) t.ok(locations.find(l => l.type === 'stop' || l.type === 'station')) t.ok(locations.find(l => l.poi)) // POIs t.ok(locations.some(l => l.station && l.station.id === kielRathaus || l.id === kielRathaus)) t.end() }) test('stop', async (t) => { const s = await client.stop(kielHbf) validate(t, s, ['stop', 'station'], 'stop') t.equal(s.id, kielHbf) t.end() }) test('radar', async (t) => { const vehicles = await client.radar({ north: 54.4, west: 10.0, south: 54.2, east: 10.2 }, { duration: 5 * 60, when }) // todo: cfg.stationProductsOptional option const allProducts = products.reduce((acc, p) => (acc[p.id] = true, acc), {}) const validateStation = createValidateStation(cfg) const validate = createValidate(cfg, { station: (validate, s, name) => { s = Object.assign({ products: allProducts // todo: fix station.products }, s) if (!s.name) s.name = 'foo' // todo, see #34 validateStation(validate, s, name) } }) validate(t, vehicles, 'movements', 'vehicles') t.end() }) test('reachableFrom', async (t) => { const berlinerStr = { type: 'location', address: 'Husum, Berliner Straße 80', latitude: 54.488995, longitude: 9.056263 } await testReachableFrom({ test: t, reachableFrom: client.reachableFrom, address: berlinerStr, when, maxDuration: 60, validate }) t.end() })