Skip to content

Commit

Permalink
Remove support for many non-standard fields in trips.txt
Browse files Browse the repository at this point in the history
  • Loading branch information
leonardehrenfried committed Sep 12, 2024
1 parent fae638d commit a4f1afb
Show file tree
Hide file tree
Showing 12 changed files with 3 additions and 139 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -312,7 +312,6 @@

<property name="tripShortName" />
<property name="tripHeadsign" />
<property name="routeShortName" />
<property name="directionId" />
<property name="blockId" index="blockId" />
<property name="wheelchairAccessible"/>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ public class GtfsMappingTest {
private static GtfsReader _reader;

@BeforeEach
public void setup() throws IOException {
public void setup() {

Configuration config = new Configuration();
config = config.configure("org/onebusaway/gtfs/hibernate-configuration.xml");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,6 @@ public void testGetTripById() {
assertNull(trip.getBlockId());
assertEquals("0", trip.getDirectionId());
assertEquals(route, trip.getRoute());
assertNull(trip.getRouteShortName());
assertEquals(aid("WD01272009"), trip.getServiceId());
assertEquals(aid("cal_sj_sf"), trip.getShapeId());
assertEquals("101", trip.getTripShortName());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,23 +50,8 @@ public void run(TransformContext context, GtfsMutableRelationalDao dao) {
trip.setTripHeadsign(tripHeadSign);
update++;
}
else {
fallbackSetHeadsign(trip);
fallback++;
}
}
else {
fallbackSetHeadsign(trip);
fallback++;
}
}
_log.info("trip headsign update:{} fallback: {}", update, fallback);
}

private void fallbackSetHeadsign (Trip trip) {
if (trip.getTripHeadsign() == null) {
trip.setTripHeadsign(trip.getRouteShortName());

}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@ public String getName() {
public void run(TransformContext context, GtfsMutableRelationalDao dao) {

GtfsMutableRelationalDao reference = (GtfsMutableRelationalDao) context.getReferenceReader().getEntityStore();
String agency = reference.getAllTrips().iterator().next().getId().getAgencyId();
ArrayList<String> missingStops = new ArrayList<>();

for (Trip trip : dao.getAllTrips()) {
Expand Down Expand Up @@ -74,14 +73,11 @@ public void run(TransformContext context, GtfsMutableRelationalDao dao) {
}
else {
_log.error("No stoptimes for trip {} mta id", trip.toString(), trip.getMtaTripId());
if (trip.getTripHeadsign() == null && trip.getRouteShortName() == null) {
if (trip.getTripHeadsign() == null) {
//if trip has no headsign, no stoptimes and no shortname, remove it
_log.error("Removing trip {}", trip.getId());
dao.removeEntity(trip);
}
else {
genericSetHeadsign(trip);
}
}
}
}
Expand All @@ -91,16 +87,6 @@ private void fallbackSetHeadsign (Trip trip, Stop stop) {
trip.setTripHeadsign(stop.getName());
//_log.info("Setting headsign {} on {}", stop.getName(), trip.toString());
}
else {
genericSetHeadsign(trip);
}
}

private void genericSetHeadsign (Trip trip) {
if (trip.getRouteShortName() != null) {
trip.setTripHeadsign(trip.getRouteShortName());
//_log.info("Setting headsign {} on {}", trip.getRouteShortName(), trip.toString());
}
}

@CsvField(ignore = true)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,10 +62,6 @@ public void run(TransformContext context, GtfsMutableRelationalDao dao) {
trip.setTripHeadsign(tripHeadSign);
update++;
}
else {
fallbackSetHeadsign(trip);
fallback++;
}
}
else {
noChange++;
Expand All @@ -74,20 +70,10 @@ public void run(TransformContext context, GtfsMutableRelationalDao dao) {
}
}
}
else {
fallbackSetHeadsign(trip);
fallback++;
}
}
_log.info("trip headsign update:{} fallback: {} no change: {} shuttle: {}", update, fallback, noChange, shuttle);
}

private void fallbackSetHeadsign (Trip trip) {
if (trip.getTripHeadsign() == null) {
trip.setTripHeadsign(trip.getRouteShortName());
}
}

@CsvField(ignore = true)
private String _referenceAgencyId = null;
private String getReferenceAgencyId(GtfsMutableRelationalDao dao) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -44,21 +44,9 @@ public void run(TransformContext context, GtfsMutableRelationalDao dao) {
if (tripHeadSign != null) {
trip.setTripHeadsign(tripHeadSign);
}
else {
fallbackSetHeadsign(trip);
}
}
else {
fallbackSetHeadsign(trip);
}
}
}
}

private void fallbackSetHeadsign (Trip trip) {
if (trip.getTripHeadsign() == null) {
trip.setTripHeadsign(trip.getRouteShortName());
_log.info("Setting headsign to route short name: ", trip.getRouteShortName());
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public void run(TransformContext context, GtfsMutableRelationalDao dao) {
List<StopTime> stopTimes = dao.getStopTimesForTrip(trip);

if (stopTimes != null && stopTimes.size() > 0) {
String existingTripHeadsign = (trip.getTripHeadsign() != null) ? trip.getTripHeadsign() : trip.getRouteShortName();
String existingTripHeadsign = (trip.getTripHeadsign() != null) ? trip.getTripHeadsign() : "trip route short name";

Calendar calendar = Calendar.getInstance();
calendar.setTimeInMillis(stopTimes.get(0).getDepartureTime() * 1000);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -115,8 +115,6 @@ private String areTripsEquivalent(Trip tripA, Trip tripB) {
return "directionId";
if (!equals(tripA.getRoute(), tripB.getRoute()))
return "route";
if (!equals(tripA.getRouteShortName(), tripB.getRouteShortName()))
return "routeShortName";
if (!equals(tripA.getShapeId(), tripB.getShapeId()))
return "shapeId";
if (!equals(tripA.getTripHeadsign(), tripB.getTripHeadsign()))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,6 @@ public void run(TransformContext context, GtfsMutableRelationalDao dao) {
boolean isExpress = trip.getTripShortName().equals("EXPRESS");
if (isExpress) {
_log.info("route(" + route.getShortName() + ") gets an E for trip " + trip.getId());
trip.setRouteShortName(trip.getRoute().getShortName() + "E");
if (addLocalVsExpressToTripName) {
String tripHeadsign = trip.getTripHeadsign();
if (tripHeadsign != null)
Expand Down
75 changes: 0 additions & 75 deletions onebusaway-gtfs/src/main/java/org/onebusaway/gtfs/model/Trip.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,6 @@ public final class Trip extends IdentityBean<AgencyAndId> {
@CsvField(optional = true)
private String tripHeadsign;

@CsvField(optional = true)
private String routeShortName;

@CsvField(optional = true)
private String directionId;

Expand Down Expand Up @@ -147,18 +144,10 @@ public Trip(Trip obj) {
this.serviceId = obj.serviceId;
this.tripShortName = obj.tripShortName;
this.tripHeadsign = obj.tripHeadsign;
this.routeShortName = obj.routeShortName;
this.directionId = obj.directionId;
this.blockId = obj.blockId;
this.shapeId = obj.shapeId;
this.wheelchairAccessible = obj.wheelchairAccessible;
this.drtMaxTravelTime = obj.drtMaxTravelTime;
this.drtAvgTravelTime = obj.drtAvgTravelTime;
this.drtAdvanceBookMin = obj.drtAdvanceBookMin;
this.drtPickupMessage = obj.drtPickupMessage;
this.drtDropOffMessage = obj.drtDropOffMessage;
this.continuousPickupMessage = obj.continuousPickupMessage;
this.continuousDropOffMessage = obj.continuousDropOffMessage;
this.meanDurationFactor = obj.meanDurationFactor;
this.meanDurationOffset = obj.meanDurationOffset;
this.safeDurationFactor = obj.safeDurationFactor;
Expand Down Expand Up @@ -213,14 +202,6 @@ public void setTripHeadsign(String tripHeadsign) {
this.tripHeadsign = tripHeadsign;
}

public String getRouteShortName() {
return routeShortName;
}

public void setRouteShortName(String routeShortName) {
this.routeShortName = routeShortName;
}

public String getDirectionId() {
return directionId;
}
Expand Down Expand Up @@ -253,62 +234,6 @@ public int getWheelchairAccessible() {
return wheelchairAccessible;
}

public String getDrtMaxTravelTime() {
return drtMaxTravelTime;
}

public void setDrtMaxTravelTime(String drtMaxTravelTime) {
this.drtMaxTravelTime = drtMaxTravelTime;
}

public String getDrtAvgTravelTime() {
return drtAvgTravelTime;
}

public void setDrtAvgTravelTime(String drtAvgTravelTime) {
this.drtAvgTravelTime = drtAvgTravelTime;
}

public double getDrtAdvanceBookMin() {
return drtAdvanceBookMin;
}

public void setDrtAdvanceBookMin(double drtAdvanceBookMin) {
this.drtAdvanceBookMin = drtAdvanceBookMin;
}

public String getDrtPickupMessage() {
return drtPickupMessage;
}

public void setDrtPickupMessage(String drtPickupMessage) {
this.drtPickupMessage = drtPickupMessage;
}

public String getDrtDropOffMessage() {
return drtDropOffMessage;
}

public void setDrtDropOffMessage(String drtDropOffMessage) {
this.drtDropOffMessage = drtDropOffMessage;
}

public String getContinuousPickupMessage() {
return continuousPickupMessage;
}

public void setContinuousPickupMessage(String continuousPickupMessage) {
this.continuousPickupMessage = continuousPickupMessage;
}

public String getContinuousDropOffMessage() {
return continuousDropOffMessage;
}

public void setContinuousDropOffMessage(String continuousDropOffMessage) {
this.continuousDropOffMessage = continuousDropOffMessage;
}

public Double getMeanDurationFactor() {
return meanDurationFactor;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,6 @@ public void testAllFields() throws IOException {
assertEquals("1", trip.getDirectionId());
assertEquals("B1", trip.getBlockId());
assertEquals(new AgencyAndId("1", "SHP1"), trip.getShapeId());
assertEquals("10X", trip.getRouteShortName());
assertEquals(1, trip.getTripBikesAllowed());
assertEquals(2, trip.getBikesAllowed());
assertEquals(1, trip.getCarsAllowed());
Expand Down

0 comments on commit a4f1afb

Please sign in to comment.