diff --git a/pbf/index.js b/pbf/index.js index 5b7a4ef..3ab1eef 100644 --- a/pbf/index.js +++ b/pbf/index.js @@ -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{