mirror of
https://github.com/public-transport/db-vendo-client.git
synced 2025-02-23 07:09:35 +02:00
80 lines
1.8 KiB
JavaScript
80 lines
1.8 KiB
JavaScript
'use strict'
|
||
|
||
const moment = require('moment-timezone')
|
||
|
||
|
||
|
||
const dateTime = (tz, date, time) => {
|
||
let offset = 0 // in days
|
||
if (time.length > 6) {
|
||
offset = +time.slice(0, -6)
|
||
time = time.slice(-6)
|
||
}
|
||
return moment.tz(date + 'T' + time, tz)
|
||
.add(offset, 'days')
|
||
.valueOf()
|
||
}
|
||
|
||
|
||
|
||
const types = {P: 'poi', S: 'station', A: 'address'}
|
||
// todo: what is s.rRefL?
|
||
const location = (l) => {
|
||
const type = types[l.type] || 'unknown'
|
||
const result = {
|
||
type, name: l.name
|
||
, latitude: l.crd ? l.crd.y / 1000000 : null
|
||
, longitude: l.crd ? l.crd.x / 1000000 : null
|
||
}
|
||
if (type === 'poi' || type === 'station') result.id = parseInt(l.extId)
|
||
if ('pCls' in l) result.products = l.pCls
|
||
return result
|
||
}
|
||
|
||
|
||
|
||
// todo: what is p.number vs p.line?
|
||
// todo: what is p.icoX?
|
||
// todo: what is p.cls?
|
||
// todo: what is p.oprX?
|
||
const product = (p) => {
|
||
if (!p.prodCtx) return null
|
||
return {
|
||
name: p.name, nr: +p.number, class: p.cls,
|
||
productCode: +p.prodCtx.catCode, productName: p.prodCtx.catOutS
|
||
}
|
||
}
|
||
|
||
|
||
|
||
const remark = (r) => null // todo
|
||
|
||
|
||
|
||
const agency = (a) => a.name
|
||
|
||
|
||
|
||
|
||
// todo: what is d.jny.dirFlg?
|
||
// todo: d.stbStop.dProgType
|
||
// todo: what is d.stbStop.dTimeR?
|
||
// tz = timezone, s = stations, p = products, r = remarks
|
||
const departure = (tz, s, p, r) => (d) => {
|
||
const result = {
|
||
station: s[parseInt(d.stbStop.locX)]
|
||
, when: new Date(dateTime(tz, d.date, d.stbStop.dTimeR || d.stbStop.dTimeS))
|
||
, direction: shorten(d.dirTxt) // todo: parse this
|
||
, product: p[parseInt(d.prodX)]
|
||
, remarks: d.remL ? d.remL.map((rm) => r[parseInt(rm.remX)]) : null
|
||
, trip: +d.jid.split('|')[1]
|
||
}
|
||
if (d.stbStop.dTimeR && d.stbStop.dTimeS) result.delay =
|
||
dateTime(tz, d.date, d.stbStop.dTimeR) - dateTime(tz, d.date, d.stbStop.dTimeS)
|
||
return result
|
||
}
|
||
module.exports = {
|
||
dateTime,
|
||
location, product, remark, agency,
|
||
departure
|
||
}
|