mirror of
https://github.com/public-transport/db-vendo-client.git
synced 2025-02-23 23:29:35 +02:00
114 lines
3.1 KiB
JavaScript
114 lines
3.1 KiB
JavaScript
'use strict'
|
|
|
|
const shorten = require('vbb-short-station-name')
|
|
const {to12Digit, to9Digit} = require('vbb-translate-ids')
|
|
const parseLineName = require('vbb-parse-line')
|
|
const getStations = require('vbb-stations')
|
|
|
|
const _createParseLine = require('../../parse/line')
|
|
const _parseLocation = require('../../parse/location')
|
|
const _createParseDeparture = require('../../parse/departure')
|
|
const _formatStation = require('../../format/station')
|
|
|
|
const products = require('./products')
|
|
|
|
const transformReqBody = (body) => {
|
|
body.client = {type: 'IPA', id: 'BVG', name: 'FahrInfo', v: '4070700'}
|
|
body.ext = 'BVG.1'
|
|
body.ver = '1.15' // todo: 1.16 with `mic` and `mac` query params
|
|
body.auth = {type: 'AID', aid: '1Rxs112shyHLatUX4fofnmdxK'}
|
|
|
|
return body
|
|
}
|
|
|
|
const createParseLine = (profile, opt, data) => {
|
|
const parseLine = _createParseLine(profile, opt, data)
|
|
|
|
const parseLineWithMoreDetails = (l) => {
|
|
const res = parseLine(l)
|
|
|
|
res.name = l.name.replace(/^(bus|tram)\s+/i, '')
|
|
const details = parseLineName(res.name)
|
|
res.symbol = details.symbol
|
|
res.nr = details.nr
|
|
res.metro = details.metro
|
|
res.express = details.express
|
|
res.night = details.night
|
|
|
|
return res
|
|
}
|
|
return parseLineWithMoreDetails
|
|
}
|
|
|
|
const parseLocation = (profile, opt, data, l) => {
|
|
const res = _parseLocation(profile, opt, data, l)
|
|
|
|
if (res.type === 'stop' || res.type === 'station') {
|
|
res.name = shorten(res.name)
|
|
res.id = to12Digit(res.id)
|
|
if (!res.location.latitude || !res.location.longitude) {
|
|
const [s] = getStations(res.id)
|
|
if (s) Object.assign(res.location, s.location)
|
|
}
|
|
}
|
|
return res
|
|
}
|
|
|
|
const createParseDeparture = (profile, opt, data) => {
|
|
const parseDeparture = _createParseDeparture(profile, opt, data)
|
|
|
|
const ringbahnClockwise = /^ringbahn s\s?41$/i
|
|
const ringbahnAnticlockwise = /^ringbahn s\s?42$/i
|
|
const parseDepartureRenameRingbahn = (j) => {
|
|
const res = parseDeparture(j)
|
|
|
|
if (res.line && res.line.product === 'suburban') {
|
|
const d = res.direction && res.direction.trim()
|
|
if (ringbahnClockwise.test(d)) res.direction = 'Ringbahn S41 ⟳'
|
|
else if (ringbahnAnticlockwise.test(d)) res.direction = 'Ringbahn S42 ⟲'
|
|
}
|
|
|
|
return res
|
|
}
|
|
|
|
return parseDepartureRenameRingbahn
|
|
}
|
|
|
|
const validIBNR = /^\d+$/
|
|
const formatStation = (id) => {
|
|
if ('string' !== typeof id) throw new Error('station ID must be a string.')
|
|
const l = id.length
|
|
if ((l !== 7 && l !== 9 && l !== 12) || !validIBNR.test(id)) {
|
|
throw new Error('station ID must be a valid IBNR.')
|
|
}
|
|
// BVG has some 7-digit stations. We don't convert them to 12 digits,
|
|
// because it only recognizes in the 7-digit format. see derhuerst/vbb-hafas#22
|
|
if (l !== 7) id = to9Digit(id)
|
|
return _formatStation(id)
|
|
}
|
|
|
|
// todo: adapt/extend `vbb-parse-ticket` to support the BVG markup
|
|
|
|
const bvgProfile = {
|
|
locale: 'de-DE',
|
|
timezone: 'Europe/Berlin',
|
|
endpoint: 'https://bvg-apps.hafas.de/bin/mgate.exe',
|
|
|
|
transformReqBody,
|
|
|
|
products,
|
|
|
|
parseStationName: shorten,
|
|
parseLocation,
|
|
parseLine: createParseLine,
|
|
parseDeparture: createParseDeparture,
|
|
|
|
formatStation,
|
|
|
|
trip: true,
|
|
radar: true,
|
|
refreshJourney: true,
|
|
reachableFrom: true
|
|
}
|
|
|
|
module.exports = bvgProfile
|