mirror of
https://github.com/public-transport/db-vendo-client.git
synced 2025-02-23 07:09:35 +02:00
c671e995cb
* parse bahn.de boards * add optional chaining in line.js * unit tests for bahn.de boards * fix product check in line.js for bahn.de boards * add integration tests for bahn.de boards * allow letting hafas decide the amount of vias * split dbweb and dbregioguide profiles; add db profile * commit location-filter.js (forgot that in the last commit) * simplify how db profile works * remove `ezGleis` from coalesce for scheduled platform * un-break parsing of remarks * determine fahrtNr by removing all non-digits * employ enrichStations for board stop property * prevent timeouts in dbweb e2e test from calling `end()` twice * use promises in dbweb e2e tests when waiting for enrichStations to work * replace vias option with stopovers option for dbweb profile; enrich stations when only name is known * change dbweb-departures test covering enrichStation feature for stop and stopovers * remove check for not existing option * move verkehrsmittel.name in front of verkehrsmittel.langText when parsing name in line.js
62 lines
2.1 KiB
JavaScript
62 lines
2.1 KiB
JavaScript
const ARRIVAL = 'a';
|
|
const DEPARTURE = 'd';
|
|
|
|
const createParseArrOrDep = (prefix) => {
|
|
if (prefix !== ARRIVAL && prefix !== DEPARTURE) {
|
|
throw new Error('invalid prefix');
|
|
}
|
|
|
|
const parseArrOrDep = (ctx, d) => { // d = raw arrival/departure
|
|
const {profile, opt} = ctx;
|
|
const cancelled = profile.parseCancelled(d);
|
|
const res = {
|
|
tripId: d.journeyID || d.journeyId || d.train?.journeyId || d.zuglaufId,
|
|
stop: profile.parseLocation(ctx, d.station || d.abfrageOrt || {bahnhofsId: d.bahnhofsId}),
|
|
...profile.parseWhen(
|
|
ctx,
|
|
null,
|
|
d.timeSchedule || d.time || d.zeit || d.abgangsDatum || d.ankunftsDatum,
|
|
d.timeType != 'SCHEDULE' ? d.timePredicted || d.time || d.ezZeit || d.ezAbgangsDatum || d.ezAnkunftsDatum : null,
|
|
cancelled),
|
|
...profile.parsePlatform(ctx, d.platformSchedule || d.platform || d.gleis, d.platformPredicted || d.platform || d.ezGleis, cancelled),
|
|
// prognosisType: TODO
|
|
direction: d.transport?.direction?.stopPlaces?.length > 0 && profile.parseStationName(ctx, d.transport?.direction?.stopPlaces[0].name) || profile.parseStationName(ctx, d.destination?.name || d.richtung || d.terminus) || null,
|
|
provenance: profile.parseStationName(ctx, d.transport?.origin?.name || d.origin?.name || d.abgangsOrt?.name) || null,
|
|
line: profile.parseLine(ctx, d) || null,
|
|
remarks: [],
|
|
origin: profile.parseLocation(ctx, d.transport?.origin || d.origin) || null,
|
|
destination: profile.parseLocation(ctx, d.transport?.destination || d.destination) || null,
|
|
// loadFactor: profile.parseArrOrDepWithLoadFactor(ctx, d)
|
|
};
|
|
|
|
// TODO pos
|
|
|
|
if (cancelled) {
|
|
res.cancelled = true;
|
|
Object.defineProperty(res, 'canceled', {value: true});
|
|
}
|
|
|
|
if (opt.remarks) {
|
|
res.remarks = profile.parseRemarks(ctx, d);
|
|
}
|
|
|
|
if (opt.stopovers && Array.isArray(d.ueber)) {
|
|
const stopovers = d.ueber
|
|
.map(viaName => profile.parseStopover(ctx, {name: viaName}, null));
|
|
|
|
if (prefix === ARRIVAL) {
|
|
res.previousStopovers = stopovers;
|
|
} else if (prefix === DEPARTURE) {
|
|
res.nextStopovers = stopovers;
|
|
}
|
|
}
|
|
|
|
return res;
|
|
};
|
|
|
|
return parseArrOrDep;
|
|
};
|
|
|
|
export {
|
|
createParseArrOrDep,
|
|
};
|