Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove support for many non-standard fields in trips.txt #284

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
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
96 changes: 0 additions & 96 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 All @@ -57,27 +54,6 @@ public final class Trip extends IdentityBean<AgencyAndId> {
@CsvField(optional = true, defaultValue = "0")
private int wheelchairAccessible = 0;

@CsvField(optional = true)
private String drtMaxTravelTime;

@CsvField(optional = true)
private String drtAvgTravelTime;

@CsvField(optional = true, defaultValue = "-1")
private double drtAdvanceBookMin;

@CsvField(optional = true)
private String drtPickupMessage;

@CsvField(optional = true)
private String drtDropOffMessage;

@CsvField(optional = true)
private String continuousPickupMessage;

@CsvField(optional = true)
private String continuousDropOffMessage;

@Experimental(proposedBy = "https://github.com/MobilityData/gtfs-flex/pull/79")
@CsvField(optional = true)
private Double meanDurationFactor;
Expand Down Expand Up @@ -147,18 +123,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 +181,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 +213,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