TRIAS StopEventRequest

application/pom.xml

@@ -217,6 +217,12 @@
             <artifactId>jersey-media-json-jackson</artifactId>
             <version>${jersey.version}</version>
         </dependency>
+        <!-- JAXB serialize Jersey response objects to XML. -->
+        <dependency>
+            <groupId>org.glassfish.jersey.media</groupId>
+            <artifactId>jersey-media-jaxb</artifactId>
+            <version>${jersey.version}</version>
+        </dependency>
         <!-- HK2 dependency injection framework for injecting context -->
         <dependency>
             <groupId>org.glassfish.jersey.inject</groupId>
@@ -378,6 +384,12 @@
             <version>0.28.2</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.opentripplanner</groupId>
+            <artifactId>ojp-java-model</artifactId>
+            <version>2.0.0</version>
+        </dependency>
+
         <!-- create zip test files-->
         <dependency>
             <groupId>org.apache.commons</groupId>

application/src/ext-test/java/org/opentripplanner/ext/ojp/id/HideFeedIdResolverTest.java

@@ -0,0 +1,23 @@
+package org.opentripplanner.ext.ojp.id;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+import org.opentripplanner.transit.model.framework.FeedScopedId;
+
+class HideFeedIdResolverTest {
+
+  private static final HideFeedIdResolver RESOLVER = new HideFeedIdResolver("aaa");
+
+  @Test
+  void parse() {
+    var id = RESOLVER.parse("bbb");
+    assertEquals(new FeedScopedId("aaa", "bbb"), id);
+  }
+
+  @Test
+  void tostring() {
+    var id = RESOLVER.toString(new FeedScopedId("aaa", "bbb"));
+    assertEquals("bbb", id);
+  }
+}

application/src/ext-test/java/org/opentripplanner/ext/ojp/id/UseFeedIdResolverTest.java

@@ -0,0 +1,23 @@
+package org.opentripplanner.ext.ojp.id;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+import org.opentripplanner.transit.model.framework.FeedScopedId;
+
+class UseFeedIdResolverTest {
+
+  private static final IdResolver RESOLVER = new UseFeedIdResolver();
+
+  @Test
+  void parse() {
+    var id = RESOLVER.parse("aaa:bbb");
+    assertEquals(new FeedScopedId("aaa", "bbb"), id);
+  }
+
+  @Test
+  void tostring() {
+    var id = RESOLVER.toString(new FeedScopedId("aaa", "bbb"));
+    assertEquals("aaa:bbb", id);
+  }
+}

application/src/ext-test/java/org/opentripplanner/ext/ojp/mapping/PtModeMapperTest.java

@@ -0,0 +1,16 @@
+package org.opentripplanner.ext.ojp.mapping;
+
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.EnumSource;
+import org.opentripplanner.transit.model.basic.TransitMode;
+
+class PtModeMapperTest {
+
+  @ParameterizedTest
+  @EnumSource(TransitMode.class)
+  void map(TransitMode mode) {
+    assertNotNull(PtModeMapper.map(mode));
+  }
+}

application/src/ext-test/java/org/opentripplanner/ext/ojp/service/OjpServiceMapperTest.java

@@ -0,0 +1,192 @@
+package org.opentripplanner.ext.ojp.service;
+
+import static com.google.common.truth.Truth.assertThat;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.opentripplanner.transit.model._data.TimetableRepositoryForTest.id;
+import static org.opentripplanner.transit.model.basic.TransitMode.BUS;
+import static org.opentripplanner.transit.model.basic.TransitMode.FERRY;
+
+import de.vdv.ojp20.IndividualTransportOptionStructure;
+import de.vdv.ojp20.ItModesStructure;
+import de.vdv.ojp20.LineDirectionFilterStructure;
+import de.vdv.ojp20.ModeFilterStructure;
+import de.vdv.ojp20.OJPStopEventRequestStructure;
+import de.vdv.ojp20.PersonalModesEnumeration;
+import de.vdv.ojp20.PlaceContextStructure;
+import de.vdv.ojp20.StopEventParamStructure;
+import de.vdv.ojp20.siri.LineDirectionStructure;
+import de.vdv.ojp20.siri.LineRefStructure;
+import de.vdv.ojp20.siri.VehicleModesOfTransportEnumeration;
+import java.math.BigInteger;
+import java.time.ZonedDateTime;
+import java.util.Set;
+import org.junit.jupiter.api.Test;
+import org.opentripplanner._support.time.ZoneIds;
+import org.opentripplanner.ext.ojp.id.UseFeedIdResolver;
+import org.opentripplanner.ext.ojp.service.OjpServiceMapper;
+import org.opentripplanner.transit.model.framework.FeedScopedId;
+import org.rutebanken.time.XmlDateTime;
+
+class OjpServiceMapperTest {
+
+  private static final ZonedDateTime ZDT = ZonedDateTime.parse("2025-02-17T14:24:02+01:00");
+  private static final UseFeedIdResolver ID_RESOLVER = new UseFeedIdResolver();
+  private static final OjpServiceMapper SERVICE = new OjpServiceMapper(
+    null,
+    ID_RESOLVER,
+    ZoneIds.BERLIN
+  );
+
+  private static final FeedScopedId LINE_ID = id("line1");
+
+  @Test
+  void defaultCase() {
+    var params = SERVICE.extractStopEventParams(stopEvent(new StopEventParamStructure()));
+    assertThat(params.includedAgencies()).isEmpty();
+    assertThat(params.excludedAgencies()).isEmpty();
+    assertThat(params.includedRoutes()).isEmpty();
+    assertThat(params.excludedAgencies()).isEmpty();
+    assertThat(params.includedModes()).isEmpty();
+    assertThat(params.excludedModes()).isEmpty();
+    assertEquals(OjpServiceMapper.DEFAULT_RADIUS_METERS, params.maximumWalkDistance());
+    assertEquals(OjpServiceMapper.DEFAULT_NUM_DEPARTURES, params.numDepartures());
+  }
+
+  @Test
+  void maxDistance() {
+    var params = SERVICE.extractStopEventParams(
+      new OJPStopEventRequestStructure()
+        .withLocation(
+          new PlaceContextStructure()
+            .withDepArrTime(new XmlDateTime(ZDT))
+            .withIndividualTransportOption(
+              new IndividualTransportOptionStructure()
+                .withItModeAndModeOfOperation(
+                  new ItModesStructure().withPersonalMode(PersonalModesEnumeration.FOOT)
+                )
+                .withMaxDistance(BigInteger.TEN)
+            )
+        )
+    );
+    assertEquals(10, params.maximumWalkDistance());
+  }
+
+  @Test
+  void numDepartures() {
+    var params = SERVICE.extractStopEventParams(
+      stopEvent(new StopEventParamStructure().withNumberOfResults(BigInteger.TWO))
+    );
+    assertEquals(2, params.numDepartures());
+  }
+
+  @Test
+  void lineFilterImplicitExclude() {
+    var params = SERVICE.extractStopEventParams(
+      lineFilter(
+        new LineDirectionFilterStructure()
+          .withLine(
+            new LineDirectionStructure()
+              .withLineRef(new LineRefStructure().withValue(LINE_ID.toString()))
+          )
+      )
+    );
+    assertThat(params.includedAgencies()).isEmpty();
+    assertThat(params.excludedAgencies()).isEmpty();
+    assertThat(params.includedRoutes()).isEmpty();
+    assertEquals(Set.of(LINE_ID), params.excludedRoutes());
+    assertThat(params.includedModes()).isEmpty();
+    assertThat(params.excludedModes()).isEmpty();
+  }
+
+  @Test
+  void lineFilterInclude() {
+    var params = SERVICE.extractStopEventParams(
+      lineFilter(
+        new LineDirectionFilterStructure()
+          .withExclude(true)
+          .withLine(
+            new LineDirectionStructure()
+              .withLineRef(new LineRefStructure().withValue(LINE_ID.toString()))
+          )
+      )
+    );
+    assertThat(params.includedAgencies()).isEmpty();
+    assertThat(params.excludedAgencies()).isEmpty();
+    assertThat(params.includedRoutes()).isEmpty();
+    assertEquals(Set.of(LINE_ID), params.excludedRoutes());
+    assertThat(params.includedModes()).isEmpty();
+    assertThat(params.excludedModes()).isEmpty();
+  }
+
+  @Test
+  void lineFilterExclude() {
+    var params = SERVICE.extractStopEventParams(
+      lineFilter(
+        new LineDirectionFilterStructure()
+          .withExclude(false)
+          .withLine(
+            new LineDirectionStructure()
+              .withLineRef(new LineRefStructure().withValue(LINE_ID.toString()))
+          )
+      )
+    );
+    assertThat(params.includedAgencies()).isEmpty();
+    assertThat(params.excludedAgencies()).isEmpty();
+    assertEquals(Set.of(LINE_ID), params.includedRoutes());
+    assertThat(params.excludedRoutes()).isEmpty();
+    assertThat(params.includedModes()).isEmpty();
+    assertThat(params.excludedModes()).isEmpty();
+  }
+
+  @Test
+  void modeFilter() {
+    var params = SERVICE.extractStopEventParams(
+      stopEvent(
+        new StopEventParamStructure()
+          .withModeFilter(
+            new ModeFilterStructure()
+              .withPtMode(
+                VehicleModesOfTransportEnumeration.BUS,
+                VehicleModesOfTransportEnumeration.FERRY
+              )
+          )
+      )
+    );
+    assertThat(params.includedAgencies()).isEmpty();
+    assertThat(params.excludedAgencies()).isEmpty();
+    assertThat(params.includedRoutes()).isEmpty();
+    assertThat(params.excludedRoutes()).isEmpty();
+    assertThat(params.includedModes()).isEmpty();
+    assertEquals(Set.of(BUS, FERRY), params.excludedModes());
+  }
+
+  @Test
+  void modeFilterExclude() {
+    var params = SERVICE.extractStopEventParams(
+      stopEvent(
+        new StopEventParamStructure()
+          .withModeFilter(
+            new ModeFilterStructure()
+              .withExclude(false)
+              .withPtMode(VehicleModesOfTransportEnumeration.BUS)
+          )
+      )
+    );
+    assertThat(params.includedAgencies()).isEmpty();
+    assertThat(params.excludedAgencies()).isEmpty();
+    assertThat(params.includedRoutes()).isEmpty();
+    assertThat(params.excludedRoutes()).isEmpty();
+    assertEquals(Set.of(BUS), params.includedModes());
+    assertThat(params.excludedModes()).isEmpty();
+  }
+
+  private static OJPStopEventRequestStructure lineFilter(LineDirectionFilterStructure value) {
+    return stopEvent(new StopEventParamStructure().withLineFilter(value));
+  }
+
+  private static OJPStopEventRequestStructure stopEvent(StopEventParamStructure p) {
+    return new OJPStopEventRequestStructure()
+      .withLocation(new PlaceContextStructure().withDepArrTime(new XmlDateTime(ZDT)))
+      .withParams(p);
+  }
+}