'use strict' const parseDateTime = require('./date-time') const findRemark = require('./find-remark') const clone = obj => Object.assign({}, obj) const locX = Symbol('locX') const applyRemarks = (leg, hints, warnings, refs) => { for (let ref of refs) { const remark = findRemark(hints, warnings, ref) if (!remark) continue if ('number' === typeof ref.fLocX && 'number' === typeof ref.tLocX) { const fromI = leg.stopovers.findIndex(s => s[locX] === ref.fLocX) const toI = leg.stopovers.findIndex(s => s[locX] === ref.tLocX) if (fromI < 0 || toI < 0) continue const wholeLeg = fromI === 0 && toI === (leg.stopovers.length - 1) if (!wholeLeg) { for (let i = fromI; i <= toI; i++) { const stopover = leg.stopovers[i] if (!stopover) continue if (Array.isArray(stopover.remarks)) { stopover.remarks.push(remark) } else { stopover.remarks = [remark] } } continue } } if (Array.isArray(leg.remarks)) leg.remarks.push(remark) else leg.remarks = [remark] // todo: `ref.tagL` } } const createParseJourneyLeg = (profile, opt, data) => { const {locations, lines, hints, warnings, polylines} = data // todo: pt.status, pt.isPartCncl // todo: pt.isRchbl, pt.chRatingRT, pt.chgDurR, pt.minChg // todo: pt.dep.dProgType, pt.arr.dProgType // todo: what is pt.jny.dirFlg? // j = journey, pt = part // todo: pt.planrtTS const parseJourneyLeg = (j, pt, parseStopovers = true) => { const dep = profile.parseDateTime(profile, j.date, pt.dep.dTimeR || pt.dep.dTimeS, pt.dep.dTZOffset) const arr = profile.parseDateTime(profile, j.date, pt.arr.aTimeR || pt.arr.aTimeS, pt.arr.aTZOffset) const res = { origin: clone(locations[parseInt(pt.dep.locX)]) || null, destination: clone(locations[parseInt(pt.arr.locX)]), departure: dep, arrival: arr } // todo: DRY with parseDeparture // todo: DRY with parseStopover if (pt.dep.dTimeR && pt.dep.dTimeS) { const realtime = profile.parseDateTime(profile, j.date, pt.dep.dTimeR, pt.dep.dTZOffset, true) const planned = profile.parseDateTime(profile, j.date, pt.dep.dTimeS, pt.dep.dTZOffset, true) res.departureDelay = Math.round((realtime - planned) / 1000) } if (pt.arr.aTimeR && pt.arr.aTimeS) { const realtime = profile.parseDateTime(profile, j.date, pt.arr.aTimeR, pt.dep.aTZOffset, true) const planned = profile.parseDateTime(profile, j.date, pt.arr.aTimeS, pt.dep.aTZOffset, true) res.arrivalDelay = Math.round((realtime - planned) / 1000) } if (pt.jny && pt.jny.polyG) { let p = pt.jny.polyG.polyXL p = Array.isArray(p) && polylines[p[0]] // todo: there can be >1 polyline const parse = profile.parsePolyline(profile, opt, data) res.polyline = p && parse(p) || null } if (pt.type === 'WALK' || pt.type === 'TRSF') { res.public = true res.walking = true res.distance = pt.gis && pt.gis.dist || null if (pt.type === 'TRSF') res.transfer = true if (opt.remarks && Array.isArray(pt.gis.msgL)) { applyRemarks(res, hints, warnings, pt.gis.msgL) } } else if (pt.type === 'JNY') { // todo: pull `public` value from `profile.products` res.tripId = pt.jny.jid res.line = lines[parseInt(pt.jny.prodX)] || null res.direction = profile.parseStationName(pt.jny.dirTxt) || null if (pt.dep.dPlatfS) res.departurePlatform = pt.dep.dPlatfS if (pt.arr.aPlatfS) res.arrivalPlatform = pt.arr.aPlatfS if (parseStopovers && pt.jny.stopL) { const parse = profile.parseStopover(profile, opt, data, j.date) const stopL = pt.jny.stopL res.stopovers = stopL.map(parse) // todo: is there a `pt.jny.remL`? if (opt.remarks && Array.isArray(pt.jny.msgL)) { for (let i = 0; i < stopL.length; i++) { Object.defineProperty(res.stopovers[i], locX, { value: stopL[i].locX }) } // todo: apply leg-wide remarks if `parseStopovers` is false applyRemarks(res, hints, warnings, pt.jny.msgL) } // filter stations the train passes without stopping, as this doesn't comply with fptf (yet) res.stopovers = res.stopovers.filter((x) => !x.passBy) } const freq = pt.jny.freq || {} // todo: expose `res.cycle` even if only one field exists (breaking) if (freq.minC && freq.maxC) { res.cycle = { min: freq.minC * 60, max: freq.maxC * 60 } // nr of connections in this frequency, from now on if (freq.numC) res.cycle.nr = freq.numC } if (freq.jnyL) { const parseAlternative = (a) => { // todo: parse this just like a `leg` (breaking) // todo: parse `a.stopL`, `a.ctxRecon`, `a.msgL` const st0 = a.stopL[0] let when = null, delay = null if (st0) { const planned = st0.dTimeS && profile.parseDateTime(profile, j.date, st0.dTimeS, st0.dTZOffset) if (st0.dTimeR && planned) { const realtime = profile.parseDateTime(profile, j.date, st0.dTimeR, st0.dTZOffset) when = realtime delay = Math.round((new Date(realtime) - new Date(planned)) / 1000) } else if (planned) when = planned } return { tripId: a.jid, line: lines[parseInt(a.prodX)] || null, direction: a.dirTxt || null, when, delay } } res.alternatives = freq.jnyL.map(parseAlternative) } } // todo: DRY with parseDeparture // todo: DRY with parseStopover if (pt.arr.aCncl || pt.dep.dCncl) { res.cancelled = true Object.defineProperty(res, 'canceled', {value: true}) if (pt.arr.aCncl) { res.arrival = res.arrivalPlatform = res.arrivalDelay = null const arr = profile.parseDateTime(profile, j.date, pt.arr.aTimeS, pt.arr.aTZOffset) res.formerScheduledArrival = arr } if (pt.dep.dCncl) { res.departure = res.departurePlatform = res.departureDelay = null const dep = profile.parseDateTime(profile, j.date, pt.dep.dTimeS, pt.dep.dTZOffset) res.formerScheduledDeparture = dep } } return res } return parseJourneyLeg } module.exports = createParseJourneyLeg