2016-06-22 02:09:02 +02:00
|
|
|
|
'use strict'
|
|
|
|
|
|
2016-06-25 20:54:33 +02:00
|
|
|
|
const moment = require('moment-timezone')
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2016-06-26 18:16:10 +02:00
|
|
|
|
const dateTime = (tz, date, time) => {
|
2016-06-25 20:54:33 +02:00
|
|
|
|
let offset = 0 // in days
|
|
|
|
|
if (time.length > 6) {
|
|
|
|
|
offset = +time.slice(0, -6)
|
|
|
|
|
time = time.slice(-6)
|
|
|
|
|
}
|
2016-06-26 18:16:10 +02:00
|
|
|
|
return moment.tz(date + 'T' + time, tz)
|
2016-06-25 20:54:33 +02:00
|
|
|
|
.add(offset, 'days')
|
|
|
|
|
.valueOf()
|
|
|
|
|
}
|
|
|
|
|
|
2016-06-22 02:09:02 +02:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
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
|
2016-06-26 18:16:10 +02:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 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
|
|
|
|
|
}
|
2016-06-27 22:13:52 +02:00
|
|
|
|
|
|
|
|
|
// todo: remarks
|
|
|
|
|
// todo: products
|
|
|
|
|
// todo: what is s.pCls?
|
|
|
|
|
// todo: what is s.wt?
|
|
|
|
|
// todo: what is s.dur?
|
|
|
|
|
const nearby = (n) => {
|
|
|
|
|
const result = location(n)
|
|
|
|
|
result.distance = n.dist
|
|
|
|
|
return result
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2016-06-22 02:09:02 +02:00
|
|
|
|
module.exports = {
|
|
|
|
|
dateTime,
|
2016-06-26 18:16:10 +02:00
|
|
|
|
location, product, remark, agency,
|
2016-06-27 22:13:52 +02:00
|
|
|
|
departure,
|
|
|
|
|
nearby
|
2016-06-22 02:09:02 +02:00
|
|
|
|
}
|