dancingCycle
/
sandbox-node
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(pbf): parse TripUpdate enitity

This commit is contained in:
dancingCycle 2023-02-15 15:05:56 +01:00
parent 6ddc4150a8
commit 0fa2cd5e4c
1 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
pbf/index.js
View File

@ -32,6 +32,9 @@ async function run() {
let entityCount=0;
let entityVhclCount=0;
let entityTrpCount=0;
let entityTrpTrpCount=0;
let entityTrpVhclCount=0;
let entityTrpStuCount=0;
let entityAlrtCount=0;
let entityTbdCount=0;
feed.entity.forEach(entity => {
@ -42,10 +45,10 @@ async function run() {
const alert=entity.alert;
if (vehiclePos) {
entityVhclCount++;
debug('entity has vehicle position');
//debug('entity has vehicle position');
const { trip, position, vehicle } = vehiclePos;
if (trip && position && vehicle) {
debug('vehiclePos has either trip, position or vehicle');
//debug('vehiclePos has either trip, position or vehicle');
const latitude = position.latitude;
if(latitude){
debug('position has latitude: '+latitude);
@ -55,6 +58,19 @@ async function run() {
}
}else if(tripUpdate){
entityTrpCount++;
const {trip,vehicle,stop_time_update,timestamp,delay,trip_properties}=tripUpdate;
if(trip){
entityTrpTrpCount++;
const {trip_id,route_id,direction_id,start_time,start_date,schedule_relationship}=trip;
}
if(vehicle){
entityTrpVhclCount++;
const {id,label,license_plate}=vehicle;
}
if(stop_time_update){
entityTrpStuCount++;
const {stop_sequence,stop_id,arrival,departure,departure_occupancy_status,schedule_relationship,stop_time_properties}=stop_time_update;
}
}else if(alert){
entityAlrtCount++;
}else{
@ -64,6 +80,9 @@ async function run() {
debug('entityCount: '+entityCount);
debug('entityVhclCount: '+entityVhclCount);
debug('entityTrpCount: '+entityTrpCount);
debug('entityTrpTrpCount: '+entityTrpTrpCount);
debug('entityTrpVhclCount: '+entityTrpVhclCount);
debug('entityTrpStuCount: '+entityTrpStuCount);
debug('entityAlrtCount: '+entityAlrtCount);
debug('entityTbdCount: '+entityTbdCount);
}else{