20 Commits

Author SHA1 Message Date
cde128cf92 release: prepare release 2.0.7
All checks were successful
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build is passing
2024-06-29 13:58:11 +02:00
50e98353ef fix: rename getStreeamPath to getStreamPath
All checks were successful
continuous-integration/drone/push Build is passing
2024-06-29 13:50:39 +02:00
ff2650e8c1 test: minor test code refactoring 2024-06-29 13:48:29 +02:00
14f4266cb1 build: generate and attach CycloneDX SBOM 2024-06-29 13:35:10 +02:00
65895d4167 deps: update build and test dependencies 2024-06-29 13:33:00 +02:00
ae2093b9fc docs: fix some typos on javadocs
All checks were successful
continuous-integration/drone/push Build is passing
2024-05-07 18:50:58 +02:00
47f9ad86db deps: update jackson to 2.17.1
All checks were successful
continuous-integration/drone/push Build is passing
2024-05-07 18:48:42 +02:00
c2af3a911d docs: add changelog for v2.0.6
Some checks reported errors
continuous-integration/drone/push Build is passing
continuous-integration/drone/tag Build was killed
2024-03-23 18:26:20 +01:00
6f7109f527 docs: mark v1.x as no longer supported
All checks were successful
continuous-integration/drone/push Build is passing
2024-03-23 18:25:01 +01:00
21484e2e0b ci: update GitHub actions
All checks were successful
continuous-integration/drone/push Build is passing
2024-03-23 18:20:47 +01:00
72fbbdf91b ci: run sonar analysis with JDK 21
All checks were successful
continuous-integration/drone/push Build is passing
2024-03-23 18:06:50 +01:00
38d866aaac deps: update maven plugins and test dependencies
All checks were successful
continuous-integration/drone/push Build is passing
2024-03-23 17:58:34 +01:00
8ee9ccb9c9 deps: update jackson to 2.17.0 2024-03-23 17:58:23 +01:00
b99d3099ee build and test with JDK 21
All checks were successful
continuous-integration/drone/push Build is passing
2023-10-15 17:23:12 +02:00
0ab7aa8f16 prepare release 2.0.5
All checks were successful
continuous-integration/drone/push Build is passing
2023-10-03 10:37:00 +02:00
30f39f8a5b update copyright notice
All checks were successful
continuous-integration/drone/push Build is passing
2023-10-03 10:32:14 +02:00
c9acee5676 deps: update maven plugins and test dependencies
All checks were successful
continuous-integration/drone/push Build is passing
2023-10-03 10:29:09 +02:00
21985c5cb2 deps: bump jackson-databind from 2.14.0 to 2.15.2
Some checks reported errors
continuous-integration/drone/push Build was killed
Plus some minor test dependency updates.
2023-09-08 20:47:56 +02:00
f551da2f2b build and test with JDK 20
All checks were successful
continuous-integration/drone/push Build is passing
2023-04-07 10:09:31 +02:00
eccfe908ec minor dependency updates
Some checks reported errors
continuous-integration/drone/push Build was killed
2023-04-07 10:05:44 +02:00
25 changed files with 145 additions and 90 deletions

View File

@ -22,10 +22,10 @@ steps:
---
kind: pipeline
type: docker
name: java19
name: java21
steps:
- name: test
image: maven:3-eclipse-temurin-19
image: maven:3-eclipse-temurin-21
commands:
- mvn -B clean test

View File

@ -5,17 +5,17 @@ jobs:
runs-on: ubuntu-latest
strategy:
matrix:
jdk: [ 11, 17, 19 ]
jdk: [ 11, 17, 21 ]
include:
- jdk: 11
- jdk: 21
analysis: true
steps:
- name: Checkout
uses: actions/checkout@v3
uses: actions/checkout@v4
with:
fetch-depth: 0
- name: Set up Java
uses: actions/setup-java@v3
uses: actions/setup-java@v4
with:
java-version: ${{ matrix.jdk }}
distribution: 'temurin'
@ -27,7 +27,6 @@ jobs:
mvn -B sonar:sonar
-Dsonar.host.url=https://sonarcloud.io
-Dsonar.organization=stklcode-github
-Dsonar.login=$SONAR_TOKEN
env:
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}

View File

@ -1,6 +1,34 @@
# Changelog
All notable changes to this project will be documented in this file.
## 2.0.7 - 2024-06-29
### Fixed
* renamed `UraClientConfiguration#getStreeamPath()` to `getStreamPath()`
### Dependencies
* Updated Jackson dependency to 2.17.1
### Improvement
* Generate and attach CycloneDX SBOM
## 2.0.6 - 2024-03-23
### Dependencies
* Updated Jackson dependency to 2.17.0
### Misc
* Tested with JDK 21
## 2.0.5 - 2023-10-03
### Dependencies
* Updated Jackson dependency to 2.15.2
### Misc
* Tested with JDK 20
## 2.0.4 - 2022-11-21
### Security
* Updated Jackson dependency to 2.14.0
@ -47,6 +75,14 @@ All notable changes to this project will be documented in this file.
----
## 1.3.3 - 2022-11-21
### Security
* Updated Jackson dependency to 2.14.0
### Fixed
* Querying trips and messages with limit directly from `Query` instance (#19)
## 1.3.2 - 2022-08-30
### Improvements

View File

@ -15,8 +15,7 @@ Version 2.x requires Java 11 or later.
It also contains some new features and allows configuration using a dedicated configuration object.
Version 1.x requires Java 8 or later.
This version currently receives security and bugfix updates.
However, new features might not be backported.
This version is no longer supported and will not receive any future updates.
## Usage Examples
@ -81,7 +80,7 @@ List<Message> msgs = ura.forStops("100000")
<dependency>
<groupId>de.stklcode.pubtrans</groupId>
<artifactId>juraclient</artifactId>
<version>2.0.4</version>
<version>2.0.7</version>
</dependency>
```

49
pom.xml
View File

@ -6,7 +6,7 @@
<groupId>de.stklcode.pubtrans</groupId>
<artifactId>juraclient</artifactId>
<version>2.0.4</version>
<version>2.0.7</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@ -50,13 +50,13 @@
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.14.0</version>
<version>2.17.1</version>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<version>5.9.1</version>
<version>5.10.3</version>
<scope>test</scope>
</dependency>
<dependency>
@ -66,9 +66,9 @@
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.github.tomakehurst</groupId>
<artifactId>wiremock-jre8</artifactId>
<version>2.35.0</version>
<groupId>org.wiremock</groupId>
<artifactId>wiremock</artifactId>
<version>3.8.0</version>
<scope>test</scope>
</dependency>
</dependencies>
@ -78,7 +78,7 @@
<dependency>
<groupId>org.sonarsource.scanner.maven</groupId>
<artifactId>sonar-maven-plugin</artifactId>
<version>3.9.1.2184</version>
<version>4.0.0.4121</version>
</dependency>
</dependencies>
</dependencyManagement>
@ -88,7 +88,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.10.1</version>
<version>3.13.0</version>
<configuration>
<release>11</release>
<source>11</source>
@ -98,7 +98,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<version>3.3.0</version>
<version>3.4.2</version>
<configuration>
<archive>
<manifest>
@ -114,7 +114,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.22.2</version>
<version>3.3.0</version>
</plugin>
</plugins>
</build>
@ -127,7 +127,7 @@
<plugin>
<groupId>org.jacoco</groupId>
<artifactId>jacoco-maven-plugin</artifactId>
<version>0.8.8</version>
<version>0.8.11</version>
<executions>
<execution>
<id>prepare-agent</id>
@ -158,7 +158,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-source-plugin</artifactId>
<version>3.2.1</version>
<version>3.3.1</version>
<executions>
<execution>
<id>attach-sources</id>
@ -182,7 +182,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-javadoc-plugin</artifactId>
<version>3.4.1</version>
<version>3.7.0</version>
<configuration>
<overview>${basedir}/src/main/javadoc/overview.html</overview>
<source>11</source>
@ -200,6 +200,27 @@
</build>
</profile>
<profile>
<id>sbom</id>
<build>
<plugins>
<plugin>
<groupId>org.cyclonedx</groupId>
<artifactId>cyclonedx-maven-plugin</artifactId>
<version>2.8.0</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>makeBom</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</profile>
<profile>
<id>sign</id>
<build>
@ -207,7 +228,7 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-gpg-plugin</artifactId>
<version>3.0.1</version>
<version>3.2.4</version>
<executions>
<execution>
<id>sign-artifacts</id>

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -314,7 +314,7 @@ public class UraClient implements Serializable {
// Create the reader.
try {
AsyncUraTripReader reader = new AsyncUraTripReader(
URI.create(requestURL(config.getBaseURL() + config.getStreeamPath(), REQUEST_TRIP, query)),
URI.create(requestURL(config.getBaseURL() + config.getStreamPath(), REQUEST_TRIP, query)),
config,
consumers
);

View File

@ -87,7 +87,7 @@ public class UraClientConfiguration implements Serializable {
*
* @return Stream endpoint path.
*/
public String getStreeamPath() {
public String getStreamPath() {
return this.streamPath;
}

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -187,7 +187,7 @@ public class Message implements Model {
/**
* Messages are assigned a priority in order for them to be ranked.
* Since it is possible for a stop to be assigned multiple messages it is important to ensure priority is given.
* Priorities are between 1 and 10 (where 1 is the highest priority). By default the message priority is set to 3.
* Priorities are between 1 and 10 (where 1 is the highest priority). By default, the message priority is set to 3.
*
* @return Message priority.
*/

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -196,7 +196,7 @@ public final class Stop implements Model {
}
/**
* The longitude of the stop. This isexpressed using the WGS84 coordinate system.
* The longitude of the stop. This is expressed using the WGS84 coordinate system.
*
* @return The stop geolocation longitude.
*/

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.

View File

@ -12,9 +12,9 @@ import static org.junit.jupiter.api.Assertions.assertNull;
*
* @author Stefan Kalscheuer
*/
public class UraClientConfigurationTest {
class UraClientConfigurationTest {
@Test
public void configBuilderTest() {
void configBuilderTest() {
final String baseURL = "https://ura.example.com";
final String instantPath = "/path/to/instant";
final String streamPath = "/path/to/stream";
@ -25,7 +25,7 @@ public class UraClientConfigurationTest {
UraClientConfiguration config = UraClientConfiguration.forBaseURL(baseURL).build();
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
assertEquals("/interfaces/ura/instant_V1", config.getInstantPath(), "Unexpected default instant path");
assertEquals("/interfaces/ura/stream_V1", config.getStreeamPath(), "Unexpected default stream path");
assertEquals("/interfaces/ura/stream_V1", config.getStreamPath(), "Unexpected default stream path");
assertNull(config.getConnectTimeout(), "No default connection timeout expected");
assertNull(config.getTimeout(), "No default timeout expected");
@ -36,7 +36,7 @@ public class UraClientConfigurationTest {
.build();
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
assertEquals(instantPath, config.getInstantPath(), "Unexpected custom instant path");
assertEquals(streamPath, config.getStreeamPath(), "Unexpected custom stream path");
assertEquals(streamPath, config.getStreamPath(), "Unexpected custom stream path");
// With timeouts. (#14)
config = UraClientConfiguration.forBaseURL(baseURL)

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -45,19 +45,19 @@ import static org.junit.jupiter.api.Assertions.*;
/**
* Unit test for the URA Client.
* Tests run against mocked data collected from ASEAG API (no longer available) and
* TFL API (http://countdown.api.tfl.gov.uk)
* TFL API (<a href="https://countdown.api.tfl.gov.uk">https://countdown.api.tfl.gov.uk</a>)
*
* @author Stefan Kalscheuer
*/
public class UraClientTest {
class UraClientTest {
@RegisterExtension
public static WireMockExtension wireMock = WireMockExtension.newInstance()
static WireMockExtension wireMock = WireMockExtension.newInstance()
.options(wireMockConfig().dynamicPort())
.build();
@Test
public void getStopsTest() throws UraClientException {
void getStopsTest() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(2, "instant_V2_stops.txt");
@ -83,7 +83,7 @@ public class UraClientTest {
}
@Test
public void getStopsForLineTest() throws UraClientException {
void getStopsForLineTest() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(2, "instant_V2_stops_line.txt");
@ -101,7 +101,7 @@ public class UraClientTest {
}
@Test
public void getStopsForPositionTest() throws UraClientException {
void getStopsForPositionTest() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(1, "instant_V1_stops_circle.txt");
@ -127,7 +127,7 @@ public class UraClientTest {
}
@Test
public void getTripsForDestinationNamesTest() throws UraClientException {
void getTripsForDestinationNamesTest() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(1, "instant_V1_trips_destination.txt");
@ -150,7 +150,7 @@ public class UraClientTest {
}
@Test
public void getTripsTowardsTest() throws UraClientException {
void getTripsTowardsTest() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(1, "instant_V1_trips_towards.txt");
@ -165,7 +165,7 @@ public class UraClientTest {
}
@Test
public void getTripsTest() throws UraClientException {
void getTripsTest() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(1, "instant_V1_trips_all.txt");
@ -229,11 +229,11 @@ public class UraClientTest {
"Expected reader to raise an exception"
);
assertEquals("Failed to read trips from API", exception.getMessage(), "Unexpected error message");
assertTrue(exception.getCause() instanceof IOException, "Unexpected error cause");
assertInstanceOf(IOException.class, exception.getCause(), "Unexpected error cause");
}
@Test
public void getTripsForStopTest() throws UraClientException {
void getTripsForStopTest() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(1, "instant_V1_trips_stop.txt");
@ -274,11 +274,11 @@ public class UraClientTest {
"Expected reader to raise an exception"
);
assertEquals("Failed to read stops from API", exception.getMessage(), "Unexpected error message");
assertTrue(exception.getCause() instanceof IOException, "Unexpected error cause");
assertInstanceOf(IOException.class, exception.getCause(), "Unexpected error cause");
}
@Test
public void getTripsForLine() throws UraClientException {
void getTripsForLine() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(1, "instant_V1_trips_line.txt");
@ -327,7 +327,7 @@ public class UraClientTest {
}
@Test
public void getTripsForStopAndLine() throws UraClientException {
void getTripsForStopAndLine() throws UraClientException {
// Mock the HTTP call.
mockHttpToFile(1, "instant_V1_trips_stop_line.txt");
@ -348,7 +348,7 @@ public class UraClientTest {
@Test
public void getMessages() throws UraClientException {
void getMessages() throws UraClientException {
UraClient uraClient = new UraClient(wireMock.baseUrl());
// Mock the HTTP call.
@ -379,11 +379,11 @@ public class UraClientTest {
"Expected reader to raise an exception"
);
assertEquals("Failed to read messages from API", exception.getMessage(), "Unexpected error message");
assertTrue(exception.getCause() instanceof IOException, "Unexpected error cause");
assertInstanceOf(IOException.class, exception.getCause(), "Unexpected error cause");
}
@Test
public void getMessagesForStop() throws UraClientException {
void getMessagesForStop() throws UraClientException {
UraClient uraClient = new UraClient(wireMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream");
// Mock the HTTP call.
@ -406,7 +406,7 @@ public class UraClientTest {
}
@Test
public void timeoutTest() {
void timeoutTest() {
// Try to read trips from TEST-NET-1 IP that is not routed (hopefully) and will not connect within 100ms.
UraClientException exception = assertThrows(
UraClientException.class,
@ -417,7 +417,7 @@ public class UraClientTest {
).forDestinationNames("Piccadilly Circus").getTrips(),
"Connection to TEST-NET-1 address should fail"
);
assertTrue(exception.getCause() instanceof HttpConnectTimeoutException, "Exception cause is not HttpConnectionTimeoutException");
assertInstanceOf(HttpConnectTimeoutException.class, exception.getCause(), "Exception cause is not HttpConnectionTimeoutException");
// Mock the HTTP call with delay of 200ms, but immediate connection.
wireMock.stubFor(
@ -444,7 +444,7 @@ public class UraClientTest {
).forDestinationNames("Piccadilly Circus").getTrips(),
"Response timeout did not raise an exception"
);
assertTrue(exception.getCause() instanceof HttpTimeoutException, "Exception cause is not HttpTimeoutException");
assertInstanceOf(HttpTimeoutException.class, exception.getCause(), "Exception cause is not HttpTimeoutException");
assertDoesNotThrow(
() -> new UraClient(

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -30,13 +30,13 @@ import static org.hamcrest.core.Is.is;
import static org.junit.jupiter.api.Assertions.fail;
/**
* Unit test for the {@link Message} meta model.
* Unit test for the {@link Message} model.
*
* @author Stefan Kalscheuer
*/
public class MessageTest {
class MessageTest {
@Test
public void basicConstructorTest() {
void basicConstructorTest() {
Message message = new Message("sid",
"name",
"indicator",
@ -60,7 +60,7 @@ public class MessageTest {
}
@Test
public void listConstructorTest() {
void listConstructorTest() {
/* Create valid raw data list */
List<Serializable> raw = new ArrayList<>();
raw.add(1);

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -30,13 +30,13 @@ import static org.hamcrest.core.Is.is;
import static org.junit.jupiter.api.Assertions.fail;
/**
* Unit test for the {@link Stop} meta model.
* Unit test for the {@link Stop} model.
*
* @author Stefan Kalscheuer
*/
public class StopTest {
class StopTest {
@Test
public void basicConstructorTest() {
void basicConstructorTest() {
Stop stop = new Stop("id", "name", "indicator", 1, 2.345, 6.789);
assertThat(stop.getId(), is("id"));
assertThat(stop.getName(), is("name"));
@ -47,7 +47,7 @@ public class StopTest {
}
@Test
public void listConstructorTest() {
void listConstructorTest() {
/* Create valid raw data list */
List<Serializable> raw = new ArrayList<>();
raw.add(1);

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -30,13 +30,13 @@ import static org.hamcrest.core.Is.is;
import static org.junit.jupiter.api.Assertions.fail;
/**
* Unit test for the {@link Trip} meta model.
* Unit test for the {@link Trip} model.
*
* @author Stefan Kalscheuer
*/
public class TripTest {
class TripTest {
@Test
public void basicConstructorTest() {
void basicConstructorTest() {
Trip trip = new Trip("sid",
"name",
"indicator",
@ -70,7 +70,7 @@ public class TripTest {
}
@Test
public void listConstructorTest() {
void listConstructorTest() {
/* Create valid raw data list */
List<Serializable> raw = new ArrayList<>();
raw.add(1);

View File

@ -1,5 +1,5 @@
/*
* Copyright 2016-2021 Stefan Kalscheuer
* Copyright 2016-2023 Stefan Kalscheuer
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@ -18,13 +18,12 @@ package de.stklcode.pubtrans.ura.reader;
import com.github.tomakehurst.wiremock.WireMockServer;
import com.github.tomakehurst.wiremock.client.WireMock;
import com.github.tomakehurst.wiremock.common.FileSource;
import com.github.tomakehurst.wiremock.core.WireMockConfiguration;
import com.github.tomakehurst.wiremock.extension.Parameters;
import com.github.tomakehurst.wiremock.extension.ResponseTransformer;
import com.github.tomakehurst.wiremock.extension.ResponseTransformerV2;
import com.github.tomakehurst.wiremock.http.ChunkedDribbleDelay;
import com.github.tomakehurst.wiremock.http.Request;
import com.github.tomakehurst.wiremock.http.Response;
import com.github.tomakehurst.wiremock.stubbing.ServeEvent;
import de.stklcode.pubtrans.ura.UraClientConfiguration;
import de.stklcode.pubtrans.ura.model.Trip;
import org.junit.jupiter.api.AfterAll;
@ -54,7 +53,7 @@ import static org.junit.jupiter.api.Assumptions.assumeTrue;
*
* @author Stefan Kalscheuer
*/
public class AsyncUraTripReaderTest {
class AsyncUraTripReaderTest {
private static WireMockServer httpMock;
@BeforeAll
@ -82,7 +81,7 @@ public class AsyncUraTripReaderTest {
* @throws InterruptedException Thread interrupted.
*/
@Test
public void readerTest() throws InterruptedException {
void readerTest() throws InterruptedException {
// Callback counter for some unhandy async mockery.
final AtomicInteger counter = new AtomicInteger(0);
@ -161,7 +160,7 @@ public class AsyncUraTripReaderTest {
* @throws InterruptedException Thread interrupted.
*/
@Test
public void streamClosedTest() throws InterruptedException {
void streamClosedTest() throws InterruptedException {
// Callback counter for some unhandy async mockery.
final AtomicInteger counter = new AtomicInteger(0);
@ -202,7 +201,7 @@ public class AsyncUraTripReaderTest {
}
@Test
public void timeoutTest() throws InterruptedException {
void timeoutTest() throws InterruptedException {
// Callback counter for some unhandy async mockery.
final AtomicInteger counter = new AtomicInteger(0);
@ -289,9 +288,10 @@ public class AsyncUraTripReaderTest {
);
}
public static class StreamTransformer extends ResponseTransformer {
public static class StreamTransformer implements ResponseTransformerV2 {
@Override
public Response transform(Request request, Response response, FileSource files, Parameters parameters) {
public Response transform(Response response, ServeEvent serveEvent) {
Parameters parameters = serveEvent.getTransformerParameters();
int chunks = parameters.getInt("chunks", 1);
return Response.Builder.like(response)
// Read source file to response.