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.train?.journeyId || d.zuglaufId, stop: profile.parseLocation(ctx, d.station || d.abfrageOrt), ...profile.parseWhen( ctx, null, d.timeSchedule || d.time || d.abgangsDatum || d.ankunftsDatum, d.timeType != 'SCHEDULE' ? d.timePredicted || d.time || 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) || 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); } // TODO opt.stopovers return res; }; return parseArrOrDep; }; export { createParseArrOrDep, };