mirror of
https://github.com/public-transport/db-vendo-client.git
synced 2025-02-23 07:09:35 +02:00
376 lines
8.4 KiB
JavaScript
376 lines
8.4 KiB
JavaScript
'use strict'
|
||
|
||
const tap = require('tap')
|
||
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 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 T_MOCK = 1641897000 * 1000 // 2022-01-11T11:30:00+01
|
||
const when = createWhen(nahshProfile.timezone, nahshProfile.locale, T_MOCK)
|
||
|
||
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'
|
||
|
||
tap.test('journeys – Kiel Hbf to Flensburg', async (t) => {
|
||
const res = await client.journeys(kielHbf, flensburg, {
|
||
results: 4,
|
||
departure: when,
|
||
stopovers: true
|
||
})
|
||
|
||
const kaistr = '9049113'
|
||
await testJourneysStationToStation({
|
||
test: t,
|
||
res,
|
||
validate,
|
||
fromIds: [kielHbf, kaistr],
|
||
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
|
||
|
||
tap.test('journeys – fails with no product', async (t) => {
|
||
await journeysFailsWithNoProduct({
|
||
test: t,
|
||
fetchJourneys: client.journeys,
|
||
fromId: kielHbf,
|
||
toId: flensburg,
|
||
when,
|
||
products
|
||
})
|
||
t.end()
|
||
})
|
||
|
||
tap.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()
|
||
})
|
||
|
||
tap.test('Kiel Hbf to Holstentor', async (t) => {
|
||
const holstentor = {
|
||
type: 'location',
|
||
id: '970003168',
|
||
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()
|
||
})
|
||
|
||
tap.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()
|
||
})
|
||
|
||
tap.test('earlier/later journeys, Kiel Hbf -> Flensburg', async (t) => {
|
||
await testEarlierLaterJourneys({
|
||
test: t,
|
||
fetchJourneys: client.journeys,
|
||
validate,
|
||
fromId: kielHbf,
|
||
toId: flensburg,
|
||
when
|
||
})
|
||
|
||
t.end()
|
||
})
|
||
|
||
tap.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
|
||
|
||
tap.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 tripRes = await client.trip(p.tripId, p.line.name, {when})
|
||
|
||
validate(t, tripRes, 'tripResult', 'res')
|
||
t.end()
|
||
})
|
||
|
||
tap.test('departures at Kiel Räucherei', async (t) => {
|
||
const res = await client.departures(kielRaeucherei, {
|
||
duration: 30, when,
|
||
})
|
||
|
||
await testDepartures({
|
||
test: t,
|
||
res,
|
||
validate,
|
||
id: kielRaeucherei
|
||
})
|
||
t.end()
|
||
})
|
||
|
||
tap.test('departures with station object', async (t) => {
|
||
const res = await client.departures({
|
||
type: 'station',
|
||
id: kielHbf,
|
||
name: 'Kiel Hbf',
|
||
location: {
|
||
type: 'location',
|
||
latitude: 1.23,
|
||
longitude: 2.34
|
||
}
|
||
}, {when})
|
||
|
||
validate(t, res, 'departuresResponse', 'res')
|
||
t.end()
|
||
})
|
||
|
||
tap.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()
|
||
})
|
||
|
||
tap.test('arrivals at Kiel Räucherei', async (t) => {
|
||
const res = await client.arrivals(kielRaeucherei, {
|
||
duration: 30, when
|
||
})
|
||
|
||
await testArrivals({
|
||
test: t,
|
||
res,
|
||
validate,
|
||
id: kielRaeucherei
|
||
})
|
||
t.end()
|
||
})
|
||
|
||
tap.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()
|
||
})
|
||
|
||
tap.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()
|
||
})
|
||
|
||
tap.test('stop', async (t) => {
|
||
const s = await client.stop(kielHbf)
|
||
|
||
validate(t, s, ['stop', 'station'], 'stop')
|
||
t.equal(s.id, kielHbf)
|
||
|
||
t.end()
|
||
})
|
||
|
||
tap.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()
|
||
})
|
||
|
||
tap.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()
|
||
})
|