Compare commits
No commits in common. "main" and "v2.0.0" have entirely different histories.
20
.drone.yml
Normal file
20
.drone.yml
Normal file
@ -0,0 +1,20 @@
|
|||||||
|
kind: pipeline
|
||||||
|
type: docker
|
||||||
|
name: java11
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: test
|
||||||
|
image: maven:3-openjdk-11
|
||||||
|
commands:
|
||||||
|
- mvn clean test
|
||||||
|
|
||||||
|
---
|
||||||
|
kind: pipeline
|
||||||
|
type: docker
|
||||||
|
name: java15
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: test
|
||||||
|
image: maven:3-openjdk-15
|
||||||
|
commands:
|
||||||
|
- mvn clean test
|
11
.github/dependabot.yml
vendored
11
.github/dependabot.yml
vendored
@ -1,11 +0,0 @@
|
|||||||
version: 2
|
|
||||||
updates:
|
|
||||||
- package-ecosystem: "maven"
|
|
||||||
directory: "/"
|
|
||||||
schedule:
|
|
||||||
interval: "weekly"
|
|
||||||
|
|
||||||
- package-ecosystem: "github-actions"
|
|
||||||
directory: "/"
|
|
||||||
schedule:
|
|
||||||
interval: "weekly"
|
|
32
.github/workflows/ci.yml
vendored
32
.github/workflows/ci.yml
vendored
@ -1,32 +0,0 @@
|
|||||||
name: CI
|
|
||||||
on: [ push, pull_request ]
|
|
||||||
jobs:
|
|
||||||
build:
|
|
||||||
runs-on: ubuntu-latest
|
|
||||||
strategy:
|
|
||||||
matrix:
|
|
||||||
jdk: [ 11, 17, 21 ]
|
|
||||||
include:
|
|
||||||
- jdk: 21
|
|
||||||
analysis: true
|
|
||||||
steps:
|
|
||||||
- name: Checkout
|
|
||||||
uses: actions/checkout@v4
|
|
||||||
with:
|
|
||||||
fetch-depth: 0
|
|
||||||
- name: Set up Java
|
|
||||||
uses: actions/setup-java@v4
|
|
||||||
with:
|
|
||||||
java-version: ${{ matrix.jdk }}
|
|
||||||
distribution: 'temurin'
|
|
||||||
- name: Test
|
|
||||||
run: ./mvnw -B -P coverage clean verify
|
|
||||||
- name: Analysis
|
|
||||||
if: matrix.analysis && env.SONAR_TOKEN != ''
|
|
||||||
run: >
|
|
||||||
./mvnw -B sonar:sonar
|
|
||||||
-Dsonar.host.url=https://sonarcloud.io
|
|
||||||
-Dsonar.organization=stklcode-github
|
|
||||||
env:
|
|
||||||
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
|
|
||||||
SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}
|
|
12
.gitignore
vendored
12
.gitignore
vendored
@ -1,15 +1,3 @@
|
|||||||
target/
|
target/
|
||||||
pom.xml.tag
|
|
||||||
pom.xml.releaseBackup
|
|
||||||
pom.xml.versionsBackup
|
|
||||||
pom.xml.next
|
|
||||||
release.properties
|
|
||||||
dependency-reduced-pom.xml
|
|
||||||
buildNumber.properties
|
|
||||||
.mvn/timing.properties
|
|
||||||
.mvn/wrapper/maven-wrapper.jar
|
|
||||||
|
|
||||||
.idea/
|
.idea/
|
||||||
*.iml
|
*.iml
|
||||||
|
|
||||||
*~
|
|
||||||
|
2
.mvn/wrapper/maven-wrapper.properties
vendored
2
.mvn/wrapper/maven-wrapper.properties
vendored
@ -1,2 +0,0 @@
|
|||||||
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.9/apache-maven-3.9.9-bin.zip
|
|
||||||
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar
|
|
16
.travis.yml
Normal file
16
.travis.yml
Normal file
@ -0,0 +1,16 @@
|
|||||||
|
language: java
|
||||||
|
jdk:
|
||||||
|
- openjdk11
|
||||||
|
- openjdk15
|
||||||
|
install: true
|
||||||
|
addons:
|
||||||
|
sonarcloud:
|
||||||
|
organization: "stklcode-github"
|
||||||
|
token:
|
||||||
|
secure: "FkEe/+MKpF4pSX3ZYOgu7oeIKf0460Q3XVLUhIX9bk2dyY8hoab74oCo4FtD7jim0+ZC13JVHGDX7iOQMUtS5EZ+x+pA0qpppzCK5zV8afN/l46HJ07kJldvr+EH0klbDVMFZQ5dT7r/w6CoDzjtENHzKQAJLcheUVDNpkcuBdaplTqIAVf3lQpKtOuVjQJ5qZDwwS5wsHNqPcYbcEGrPmcKDVnp3mD3bfI6dT1bbRt845QcD73rPYkQKxen8eIwJxFf5MZStgvbj7yphPxPGwoLAsoLP6LpThTDYcrg+vgUnSs+l9GckL3IbhPAmecixLbKVnphBZzRTvpdMTt5KeOoAJ2nM6RLs5cRCqiEgLEioWkVaSH5WxoBj38Z1h4fTsDV3dTcCuQWX8GFxdeeTelu+XbatdRWMnUgiF7oax+uNvR62fasTbAc7dWPJbARiD7ZbkWH4nHEY07xKKx87xzUz36ZeEHGoBXgqnLmv/FCwqMrEpOoIT41fc0WYtdIA4wjRoAyG0u+wNBMbVlf4PK72seM4b/bmU+TtmaaVla/SvNOiz+A3DHxtJEUScPcL3QGjviddglMf+wyD6VXVViq9VuYRKZFyjpuoNpb5lwEbwmRnmLabBx8jBgyPinjpmqHYlIntcPAwuyLRaqTHFcmCrbeeZEf7KaPRYKx+Cs="
|
||||||
|
cache:
|
||||||
|
directories:
|
||||||
|
- '$HOME/.m2/repository'
|
||||||
|
- '$HOME/.sonar/cache'
|
||||||
|
script:
|
||||||
|
- if [ "$TRAVIS_JDK_VERSION" == "openjdk11" ]; then mvn -P coverage clean package sonar:sonar; else mvn clean test; fi
|
88
CHANGELOG.md
88
CHANGELOG.md
@ -1,80 +1,6 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
All notable changes to this project will be documented in this file.
|
All notable changes to this project will be documented in this file.
|
||||||
|
|
||||||
## 2.0.9 - 2025-04-19
|
|
||||||
|
|
||||||
### Dependencies
|
|
||||||
* Updated Jackson dependency to 2.18.3
|
|
||||||
|
|
||||||
### Improvement
|
|
||||||
* Minor adjustments for reproducible builds
|
|
||||||
|
|
||||||
|
|
||||||
## 2.0.8 - 2024-10-03
|
|
||||||
|
|
||||||
### Fixed
|
|
||||||
* Remove `Automatic-Module-Name` from JAR manifest
|
|
||||||
|
|
||||||
### Dependencies
|
|
||||||
* Updated Jackson dependency to 2.18.0
|
|
||||||
|
|
||||||
|
|
||||||
## 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
|
|
||||||
|
|
||||||
### Fixed
|
|
||||||
* Querying trips and messages with limit directly from `Query` instance (#18)
|
|
||||||
|
|
||||||
### Misc
|
|
||||||
* Tested with JDK 19
|
|
||||||
|
|
||||||
|
|
||||||
## 2.0.3 - 2022-08-30
|
|
||||||
### Security
|
|
||||||
* Updated dependencies
|
|
||||||
|
|
||||||
|
|
||||||
## 2.0.2 - 2022-04-13
|
|
||||||
### Security
|
|
||||||
* Updated dependencies
|
|
||||||
|
|
||||||
|
|
||||||
## 2.0.1 - 2021-10-02
|
|
||||||
### Security
|
|
||||||
* Updated dependencies
|
|
||||||
|
|
||||||
### Improvement
|
|
||||||
* Built and tested with JDK 17
|
|
||||||
|
|
||||||
## 2.0.0 - 2021-01-30
|
## 2.0.0 - 2021-01-30
|
||||||
### Breaking
|
### Breaking
|
||||||
* Java 11 or later required
|
* Java 11 or later required
|
||||||
@ -93,20 +19,6 @@ 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
|
|
||||||
* Dependency updates
|
|
||||||
|
|
||||||
|
|
||||||
## 1.3.1 - 2020-12-12
|
## 1.3.1 - 2020-12-12
|
||||||
### Fixed
|
### Fixed
|
||||||
* Allow reopening an `AsyncUraTripReader` without raising an exception (#13)
|
* Allow reopening an `AsyncUraTripReader` without raising an exception (#13)
|
||||||
|
@ -107,7 +107,7 @@ Files ending with `Test.java` will be automatically included into the test suite
|
|||||||
|
|
||||||
## Continuous Integration
|
## Continuous Integration
|
||||||
|
|
||||||
Automated tests are run using [GitHub Actions](https://github.com/stklcode/juraclient/actions/) for every commit including pull requests.
|
Automated tests are run using [Travis CI](https://travis-ci.com/stklcode/juraclient) for every commit including pull requests.
|
||||||
|
|
||||||
There is also a code quality analysis pushing results to [SonarCloud](https://sonarcloud.io/dashboard?id=de.stklcode.pubtrans%3Ajuraclient).
|
There is also a code quality analysis pushing results to [SonarCloud](https://sonarcloud.io/dashboard?id=de.stklcode.pubtrans%3Ajuraclient).
|
||||||
Keep in mind that the ruleset is not yet perfect, so not every minor issue has to be fixed immediately.
|
Keep in mind that the ruleset is not yet perfect, so not every minor issue has to be fixed immediately.
|
||||||
|
29
README.md
29
README.md
@ -1,8 +1,8 @@
|
|||||||
# jURAclient
|
# jURAclient
|
||||||
[](https://github.com/stklcode/juraclient/actions/workflows/ci.yml)
|
[](https://travis-ci.com/stklcode/juraclient)
|
||||||
[](https://sonarcloud.io/summary/new_code?id=de.stklcode.pubtrans%3Ajuraclient)
|
[](https://sonarcloud.io/dashboard?id=de.stklcode.pubtrans%3Ajuraclient)
|
||||||
[](https://www.javadoc.io/doc/de.stklcode.pubtrans/juraclient)
|
[](https://www.javadoc.io/doc/de.stklcode.pubtrans/juraclient)
|
||||||
[](https://central.sonatype.com/artifact/de.stklcode.pubtrans/juraclient)
|
[](https://search.maven.org/#search%7Cga%7C1%7Cg%3A%22de.stklcode.pubtrans%22%20AND%20a%3A%22juraclient%22)
|
||||||
[](https://github.com/stklcode/juraclient/blob/master/LICENSE.txt)
|
[](https://github.com/stklcode/juraclient/blob/master/LICENSE.txt)
|
||||||
|
|
||||||
Java client for URA based public transport APIs.
|
Java client for URA based public transport APIs.
|
||||||
@ -15,23 +15,24 @@ Version 2.x requires Java 11 or later.
|
|||||||
It also contains some new features and allows configuration using a dedicated configuration object.
|
It also contains some new features and allows configuration using a dedicated configuration object.
|
||||||
|
|
||||||
Version 1.x requires Java 8 or later.
|
Version 1.x requires Java 8 or later.
|
||||||
This version is no longer supported and will not receive any future updates.
|
This version currently receives security and bugfix updates.
|
||||||
|
However, new features might not be backported.
|
||||||
|
|
||||||
## Usage Examples
|
## Usage Examples
|
||||||
|
|
||||||
### Initialization
|
### Initialization
|
||||||
```java
|
```java
|
||||||
// Instantiate the client.
|
// Instantiate the client (e.g. using the TFL API)
|
||||||
UraClient ura = new UraClient("https://ura.example.com");
|
UraClient ura = new UraClient("http://countdown.api.tfl.gov.uk");
|
||||||
|
|
||||||
// Initialize the API with non-standard endpoints.
|
// Initialize the API with non-standard endpoints (e.g. ASEAG with API V2)
|
||||||
UraClient ura = new UraClient("https://ura.example.com",
|
UraClient ura = new UraClient("http://ivu.aseag.de",
|
||||||
"interfaces/ura/instant_V2",
|
"interfaces/ura/instant_V2",
|
||||||
"interfaces/ura/stream_V2");
|
"interfaces/ura/stream_V2");
|
||||||
|
|
||||||
// Initialization with configuration builder (Client v2.x)
|
// Initialization with configuration builder (Client v2.x)
|
||||||
UraClient ura = new UraClient(
|
UraClient ura = new UraClient(
|
||||||
UraClientConfiguration.forBaseURL("https://ura.example.com")
|
UraClientConfiguration.forBaseURL("http://ura.example.com")
|
||||||
.withInstantPath("interfaces/ura/instant_V2")
|
.withInstantPath("interfaces/ura/instant_V2")
|
||||||
.withStreamPath("interfaces/ura/stream_V2")
|
.withStreamPath("interfaces/ura/stream_V2")
|
||||||
.withConnectTimeout(Duration.ofSeconds(2))
|
.withConnectTimeout(Duration.ofSeconds(2))
|
||||||
@ -56,13 +57,13 @@ List<Stop> stops = ura.forPosition(51.51009, -0.1345734, 200)
|
|||||||
|
|
||||||
```java
|
```java
|
||||||
// Get next 10 trips for given stops and lines in a single direction (all filters optional)
|
// Get next 10 trips for given stops and lines in a single direction (all filters optional)
|
||||||
List<Trip> trips = ura.forStops("100000")
|
List<Trip> trips = ura.forStop("100000")
|
||||||
.forLines("25", "35")
|
.forLines("25", "35")
|
||||||
.forDirection(1)
|
.forDirection(1)
|
||||||
.getTrips(10);
|
.getTrips(10);
|
||||||
|
|
||||||
// Get trips from given stop towards your destination
|
// Get trips from given stop towards your destination
|
||||||
List<Trip> trips = ura.forStopsByName("Piccadilly Circus")
|
List<Trip> trips = ura.forStopByName("Piccadilly Circus")
|
||||||
.towards("Marble Arch")
|
.towards("Marble Arch")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
```
|
```
|
||||||
@ -71,7 +72,7 @@ List<Trip> trips = ura.forStopsByName("Piccadilly Circus")
|
|||||||
|
|
||||||
```java
|
```java
|
||||||
// Get next 10 trips for given stops and lines in a single direction (all filters optional)
|
// Get next 10 trips for given stops and lines in a single direction (all filters optional)
|
||||||
List<Message> msgs = ura.forStops("100000")
|
List<Message> msgs = ura.forStop("100000")
|
||||||
.getMessages();
|
.getMessages();
|
||||||
```
|
```
|
||||||
|
|
||||||
@ -80,10 +81,10 @@ List<Message> msgs = ura.forStops("100000")
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>de.stklcode.pubtrans</groupId>
|
<groupId>de.stklcode.pubtrans</groupId>
|
||||||
<artifactId>juraclient</artifactId>
|
<artifactId>juraclient</artifactId>
|
||||||
<version>2.0.9</version>
|
<version>2.0.0</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
```
|
```
|
||||||
|
|
||||||
## License
|
## License
|
||||||
|
|
||||||
The project is licensed under [Apache License 2.0](https://www.apache.org/licenses/LICENSE-2.0).
|
The project is licensed under [Apache License 2.0](http://www.apache.org/licenses/LICENSE-2.0).
|
||||||
|
332
mvnw
vendored
332
mvnw
vendored
@ -1,332 +0,0 @@
|
|||||||
#!/bin/sh
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
# Licensed to the Apache Software Foundation (ASF) under one
|
|
||||||
# or more contributor license agreements. See the NOTICE file
|
|
||||||
# distributed with this work for additional information
|
|
||||||
# regarding copyright ownership. The ASF licenses this file
|
|
||||||
# to you under the Apache License, Version 2.0 (the
|
|
||||||
# "License"); you may not use this file except in compliance
|
|
||||||
# with the License. You may obtain a copy of the License at
|
|
||||||
#
|
|
||||||
# http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
#
|
|
||||||
# Unless required by applicable law or agreed to in writing,
|
|
||||||
# software distributed under the License is distributed on an
|
|
||||||
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
||||||
# KIND, either express or implied. See the License for the
|
|
||||||
# specific language governing permissions and limitations
|
|
||||||
# under the License.
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
# Apache Maven Wrapper startup batch script, version 3.3.2
|
|
||||||
#
|
|
||||||
# Required ENV vars:
|
|
||||||
# ------------------
|
|
||||||
# JAVA_HOME - location of a JDK home dir
|
|
||||||
#
|
|
||||||
# Optional ENV vars
|
|
||||||
# -----------------
|
|
||||||
# MAVEN_OPTS - parameters passed to the Java VM when running Maven
|
|
||||||
# e.g. to debug Maven itself, use
|
|
||||||
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
|
|
||||||
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
|
|
||||||
# ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
if [ -z "$MAVEN_SKIP_RC" ]; then
|
|
||||||
|
|
||||||
if [ -f /usr/local/etc/mavenrc ]; then
|
|
||||||
. /usr/local/etc/mavenrc
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -f /etc/mavenrc ]; then
|
|
||||||
. /etc/mavenrc
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -f "$HOME/.mavenrc" ]; then
|
|
||||||
. "$HOME/.mavenrc"
|
|
||||||
fi
|
|
||||||
|
|
||||||
fi
|
|
||||||
|
|
||||||
# OS specific support. $var _must_ be set to either true or false.
|
|
||||||
cygwin=false
|
|
||||||
darwin=false
|
|
||||||
mingw=false
|
|
||||||
case "$(uname)" in
|
|
||||||
CYGWIN*) cygwin=true ;;
|
|
||||||
MINGW*) mingw=true ;;
|
|
||||||
Darwin*)
|
|
||||||
darwin=true
|
|
||||||
# Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
|
|
||||||
# See https://developer.apple.com/library/mac/qa/qa1170/_index.html
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
if [ -x "/usr/libexec/java_home" ]; then
|
|
||||||
JAVA_HOME="$(/usr/libexec/java_home)"
|
|
||||||
export JAVA_HOME
|
|
||||||
else
|
|
||||||
JAVA_HOME="/Library/Java/Home"
|
|
||||||
export JAVA_HOME
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
if [ -r /etc/gentoo-release ]; then
|
|
||||||
JAVA_HOME=$(java-config --jre-home)
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
# For Cygwin, ensure paths are in UNIX format before anything is touched
|
|
||||||
if $cygwin; then
|
|
||||||
[ -n "$JAVA_HOME" ] \
|
|
||||||
&& JAVA_HOME=$(cygpath --unix "$JAVA_HOME")
|
|
||||||
[ -n "$CLASSPATH" ] \
|
|
||||||
&& CLASSPATH=$(cygpath --path --unix "$CLASSPATH")
|
|
||||||
fi
|
|
||||||
|
|
||||||
# For Mingw, ensure paths are in UNIX format before anything is touched
|
|
||||||
if $mingw; then
|
|
||||||
[ -n "$JAVA_HOME" ] && [ -d "$JAVA_HOME" ] \
|
|
||||||
&& JAVA_HOME="$(
|
|
||||||
cd "$JAVA_HOME" || (
|
|
||||||
echo "cannot cd into $JAVA_HOME." >&2
|
|
||||||
exit 1
|
|
||||||
)
|
|
||||||
pwd
|
|
||||||
)"
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
javaExecutable="$(which javac)"
|
|
||||||
if [ -n "$javaExecutable" ] && ! [ "$(expr "$javaExecutable" : '\([^ ]*\)')" = "no" ]; then
|
|
||||||
# readlink(1) is not available as standard on Solaris 10.
|
|
||||||
readLink=$(which readlink)
|
|
||||||
if [ ! "$(expr "$readLink" : '\([^ ]*\)')" = "no" ]; then
|
|
||||||
if $darwin; then
|
|
||||||
javaHome="$(dirname "$javaExecutable")"
|
|
||||||
javaExecutable="$(cd "$javaHome" && pwd -P)/javac"
|
|
||||||
else
|
|
||||||
javaExecutable="$(readlink -f "$javaExecutable")"
|
|
||||||
fi
|
|
||||||
javaHome="$(dirname "$javaExecutable")"
|
|
||||||
javaHome=$(expr "$javaHome" : '\(.*\)/bin')
|
|
||||||
JAVA_HOME="$javaHome"
|
|
||||||
export JAVA_HOME
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -z "$JAVACMD" ]; then
|
|
||||||
if [ -n "$JAVA_HOME" ]; then
|
|
||||||
if [ -x "$JAVA_HOME/jre/sh/java" ]; then
|
|
||||||
# IBM's JDK on AIX uses strange locations for the executables
|
|
||||||
JAVACMD="$JAVA_HOME/jre/sh/java"
|
|
||||||
else
|
|
||||||
JAVACMD="$JAVA_HOME/bin/java"
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
JAVACMD="$(
|
|
||||||
\unset -f command 2>/dev/null
|
|
||||||
\command -v java
|
|
||||||
)"
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ ! -x "$JAVACMD" ]; then
|
|
||||||
echo "Error: JAVA_HOME is not defined correctly." >&2
|
|
||||||
echo " We cannot execute $JAVACMD" >&2
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
if [ -z "$JAVA_HOME" ]; then
|
|
||||||
echo "Warning: JAVA_HOME environment variable is not set." >&2
|
|
||||||
fi
|
|
||||||
|
|
||||||
# traverses directory structure from process work directory to filesystem root
|
|
||||||
# first directory with .mvn subdirectory is considered project base directory
|
|
||||||
find_maven_basedir() {
|
|
||||||
if [ -z "$1" ]; then
|
|
||||||
echo "Path not specified to find_maven_basedir" >&2
|
|
||||||
return 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
basedir="$1"
|
|
||||||
wdir="$1"
|
|
||||||
while [ "$wdir" != '/' ]; do
|
|
||||||
if [ -d "$wdir"/.mvn ]; then
|
|
||||||
basedir=$wdir
|
|
||||||
break
|
|
||||||
fi
|
|
||||||
# workaround for JBEAP-8937 (on Solaris 10/Sparc)
|
|
||||||
if [ -d "${wdir}" ]; then
|
|
||||||
wdir=$(
|
|
||||||
cd "$wdir/.." || exit 1
|
|
||||||
pwd
|
|
||||||
)
|
|
||||||
fi
|
|
||||||
# end of workaround
|
|
||||||
done
|
|
||||||
printf '%s' "$(
|
|
||||||
cd "$basedir" || exit 1
|
|
||||||
pwd
|
|
||||||
)"
|
|
||||||
}
|
|
||||||
|
|
||||||
# concatenates all lines of a file
|
|
||||||
concat_lines() {
|
|
||||||
if [ -f "$1" ]; then
|
|
||||||
# Remove \r in case we run on Windows within Git Bash
|
|
||||||
# and check out the repository with auto CRLF management
|
|
||||||
# enabled. Otherwise, we may read lines that are delimited with
|
|
||||||
# \r\n and produce $'-Xarg\r' rather than -Xarg due to word
|
|
||||||
# splitting rules.
|
|
||||||
tr -s '\r\n' ' ' <"$1"
|
|
||||||
fi
|
|
||||||
}
|
|
||||||
|
|
||||||
log() {
|
|
||||||
if [ "$MVNW_VERBOSE" = true ]; then
|
|
||||||
printf '%s\n' "$1"
|
|
||||||
fi
|
|
||||||
}
|
|
||||||
|
|
||||||
BASE_DIR=$(find_maven_basedir "$(dirname "$0")")
|
|
||||||
if [ -z "$BASE_DIR" ]; then
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
|
|
||||||
MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
|
|
||||||
export MAVEN_PROJECTBASEDIR
|
|
||||||
log "$MAVEN_PROJECTBASEDIR"
|
|
||||||
|
|
||||||
##########################################################################################
|
|
||||||
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
|
|
||||||
# This allows using the maven wrapper in projects that prohibit checking in binary data.
|
|
||||||
##########################################################################################
|
|
||||||
wrapperJarPath="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar"
|
|
||||||
if [ -r "$wrapperJarPath" ]; then
|
|
||||||
log "Found $wrapperJarPath"
|
|
||||||
else
|
|
||||||
log "Couldn't find $wrapperJarPath, downloading it ..."
|
|
||||||
|
|
||||||
if [ -n "$MVNW_REPOURL" ]; then
|
|
||||||
wrapperUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
else
|
|
||||||
wrapperUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
fi
|
|
||||||
while IFS="=" read -r key value; do
|
|
||||||
# Remove '\r' from value to allow usage on windows as IFS does not consider '\r' as a separator ( considers space, tab, new line ('\n'), and custom '=' )
|
|
||||||
safeValue=$(echo "$value" | tr -d '\r')
|
|
||||||
case "$key" in wrapperUrl)
|
|
||||||
wrapperUrl="$safeValue"
|
|
||||||
break
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
done <"$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties"
|
|
||||||
log "Downloading from: $wrapperUrl"
|
|
||||||
|
|
||||||
if $cygwin; then
|
|
||||||
wrapperJarPath=$(cygpath --path --windows "$wrapperJarPath")
|
|
||||||
fi
|
|
||||||
|
|
||||||
if command -v wget >/dev/null; then
|
|
||||||
log "Found wget ... using wget"
|
|
||||||
[ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--quiet"
|
|
||||||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
|
|
||||||
wget $QUIET "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
|
|
||||||
else
|
|
||||||
wget $QUIET --http-user="$MVNW_USERNAME" --http-password="$MVNW_PASSWORD" "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
|
|
||||||
fi
|
|
||||||
elif command -v curl >/dev/null; then
|
|
||||||
log "Found curl ... using curl"
|
|
||||||
[ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--silent"
|
|
||||||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
|
|
||||||
curl $QUIET -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath"
|
|
||||||
else
|
|
||||||
curl $QUIET --user "$MVNW_USERNAME:$MVNW_PASSWORD" -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath"
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
log "Falling back to using Java to download"
|
|
||||||
javaSource="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.java"
|
|
||||||
javaClass="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.class"
|
|
||||||
# For Cygwin, switch paths to Windows format before running javac
|
|
||||||
if $cygwin; then
|
|
||||||
javaSource=$(cygpath --path --windows "$javaSource")
|
|
||||||
javaClass=$(cygpath --path --windows "$javaClass")
|
|
||||||
fi
|
|
||||||
if [ -e "$javaSource" ]; then
|
|
||||||
if [ ! -e "$javaClass" ]; then
|
|
||||||
log " - Compiling MavenWrapperDownloader.java ..."
|
|
||||||
("$JAVA_HOME/bin/javac" "$javaSource")
|
|
||||||
fi
|
|
||||||
if [ -e "$javaClass" ]; then
|
|
||||||
log " - Running MavenWrapperDownloader.java ..."
|
|
||||||
("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$wrapperUrl" "$wrapperJarPath") || rm -f "$wrapperJarPath"
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
##########################################################################################
|
|
||||||
# End of extension
|
|
||||||
##########################################################################################
|
|
||||||
|
|
||||||
# If specified, validate the SHA-256 sum of the Maven wrapper jar file
|
|
||||||
wrapperSha256Sum=""
|
|
||||||
while IFS="=" read -r key value; do
|
|
||||||
case "$key" in wrapperSha256Sum)
|
|
||||||
wrapperSha256Sum=$value
|
|
||||||
break
|
|
||||||
;;
|
|
||||||
esac
|
|
||||||
done <"$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties"
|
|
||||||
if [ -n "$wrapperSha256Sum" ]; then
|
|
||||||
wrapperSha256Result=false
|
|
||||||
if command -v sha256sum >/dev/null; then
|
|
||||||
if echo "$wrapperSha256Sum $wrapperJarPath" | sha256sum -c >/dev/null 2>&1; then
|
|
||||||
wrapperSha256Result=true
|
|
||||||
fi
|
|
||||||
elif command -v shasum >/dev/null; then
|
|
||||||
if echo "$wrapperSha256Sum $wrapperJarPath" | shasum -a 256 -c >/dev/null 2>&1; then
|
|
||||||
wrapperSha256Result=true
|
|
||||||
fi
|
|
||||||
else
|
|
||||||
echo "Checksum validation was requested but neither 'sha256sum' or 'shasum' are available." >&2
|
|
||||||
echo "Please install either command, or disable validation by removing 'wrapperSha256Sum' from your maven-wrapper.properties." >&2
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
if [ $wrapperSha256Result = false ]; then
|
|
||||||
echo "Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised." >&2
|
|
||||||
echo "Investigate or delete $wrapperJarPath to attempt a clean download." >&2
|
|
||||||
echo "If you updated your Maven version, you need to update the specified wrapperSha256Sum property." >&2
|
|
||||||
exit 1
|
|
||||||
fi
|
|
||||||
fi
|
|
||||||
|
|
||||||
MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
|
|
||||||
|
|
||||||
# For Cygwin, switch paths to Windows format before running java
|
|
||||||
if $cygwin; then
|
|
||||||
[ -n "$JAVA_HOME" ] \
|
|
||||||
&& JAVA_HOME=$(cygpath --path --windows "$JAVA_HOME")
|
|
||||||
[ -n "$CLASSPATH" ] \
|
|
||||||
&& CLASSPATH=$(cygpath --path --windows "$CLASSPATH")
|
|
||||||
[ -n "$MAVEN_PROJECTBASEDIR" ] \
|
|
||||||
&& MAVEN_PROJECTBASEDIR=$(cygpath --path --windows "$MAVEN_PROJECTBASEDIR")
|
|
||||||
fi
|
|
||||||
|
|
||||||
# Provide a "standardized" way to retrieve the CLI args that will
|
|
||||||
# work with both Windows and non-Windows executions.
|
|
||||||
MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $*"
|
|
||||||
export MAVEN_CMD_LINE_ARGS
|
|
||||||
|
|
||||||
WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
|
|
||||||
|
|
||||||
# shellcheck disable=SC2086 # safe args
|
|
||||||
exec "$JAVACMD" \
|
|
||||||
$MAVEN_OPTS \
|
|
||||||
$MAVEN_DEBUG_OPTS \
|
|
||||||
-classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
|
|
||||||
"-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
|
|
||||||
${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"
|
|
206
mvnw.cmd
vendored
206
mvnw.cmd
vendored
@ -1,206 +0,0 @@
|
|||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
@REM Licensed to the Apache Software Foundation (ASF) under one
|
|
||||||
@REM or more contributor license agreements. See the NOTICE file
|
|
||||||
@REM distributed with this work for additional information
|
|
||||||
@REM regarding copyright ownership. The ASF licenses this file
|
|
||||||
@REM to you under the Apache License, Version 2.0 (the
|
|
||||||
@REM "License"); you may not use this file except in compliance
|
|
||||||
@REM with the License. You may obtain a copy of the License at
|
|
||||||
@REM
|
|
||||||
@REM http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
@REM
|
|
||||||
@REM Unless required by applicable law or agreed to in writing,
|
|
||||||
@REM software distributed under the License is distributed on an
|
|
||||||
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
||||||
@REM KIND, either express or implied. See the License for the
|
|
||||||
@REM specific language governing permissions and limitations
|
|
||||||
@REM under the License.
|
|
||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
@REM Apache Maven Wrapper startup batch script, version 3.3.2
|
|
||||||
@REM
|
|
||||||
@REM Required ENV vars:
|
|
||||||
@REM JAVA_HOME - location of a JDK home dir
|
|
||||||
@REM
|
|
||||||
@REM Optional ENV vars
|
|
||||||
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
|
|
||||||
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
|
|
||||||
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
|
|
||||||
@REM e.g. to debug Maven itself, use
|
|
||||||
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
|
|
||||||
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
|
|
||||||
@REM ----------------------------------------------------------------------------
|
|
||||||
|
|
||||||
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
|
|
||||||
@echo off
|
|
||||||
@REM set title of command window
|
|
||||||
title %0
|
|
||||||
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
|
|
||||||
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
|
|
||||||
|
|
||||||
@REM set %HOME% to equivalent of $HOME
|
|
||||||
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
|
|
||||||
|
|
||||||
@REM Execute a user defined script before this one
|
|
||||||
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
|
|
||||||
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
|
|
||||||
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
|
|
||||||
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
|
|
||||||
:skipRcPre
|
|
||||||
|
|
||||||
@setlocal
|
|
||||||
|
|
||||||
set ERROR_CODE=0
|
|
||||||
|
|
||||||
@REM To isolate internal variables from possible post scripts, we use another setlocal
|
|
||||||
@setlocal
|
|
||||||
|
|
||||||
@REM ==== START VALIDATION ====
|
|
||||||
if not "%JAVA_HOME%" == "" goto OkJHome
|
|
||||||
|
|
||||||
echo. >&2
|
|
||||||
echo Error: JAVA_HOME not found in your environment. >&2
|
|
||||||
echo Please set the JAVA_HOME variable in your environment to match the >&2
|
|
||||||
echo location of your Java installation. >&2
|
|
||||||
echo. >&2
|
|
||||||
goto error
|
|
||||||
|
|
||||||
:OkJHome
|
|
||||||
if exist "%JAVA_HOME%\bin\java.exe" goto init
|
|
||||||
|
|
||||||
echo. >&2
|
|
||||||
echo Error: JAVA_HOME is set to an invalid directory. >&2
|
|
||||||
echo JAVA_HOME = "%JAVA_HOME%" >&2
|
|
||||||
echo Please set the JAVA_HOME variable in your environment to match the >&2
|
|
||||||
echo location of your Java installation. >&2
|
|
||||||
echo. >&2
|
|
||||||
goto error
|
|
||||||
|
|
||||||
@REM ==== END VALIDATION ====
|
|
||||||
|
|
||||||
:init
|
|
||||||
|
|
||||||
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
|
|
||||||
@REM Fallback to current working directory if not found.
|
|
||||||
|
|
||||||
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
|
|
||||||
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
|
|
||||||
|
|
||||||
set EXEC_DIR=%CD%
|
|
||||||
set WDIR=%EXEC_DIR%
|
|
||||||
:findBaseDir
|
|
||||||
IF EXIST "%WDIR%"\.mvn goto baseDirFound
|
|
||||||
cd ..
|
|
||||||
IF "%WDIR%"=="%CD%" goto baseDirNotFound
|
|
||||||
set WDIR=%CD%
|
|
||||||
goto findBaseDir
|
|
||||||
|
|
||||||
:baseDirFound
|
|
||||||
set MAVEN_PROJECTBASEDIR=%WDIR%
|
|
||||||
cd "%EXEC_DIR%"
|
|
||||||
goto endDetectBaseDir
|
|
||||||
|
|
||||||
:baseDirNotFound
|
|
||||||
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
|
|
||||||
cd "%EXEC_DIR%"
|
|
||||||
|
|
||||||
:endDetectBaseDir
|
|
||||||
|
|
||||||
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
|
|
||||||
|
|
||||||
@setlocal EnableExtensions EnableDelayedExpansion
|
|
||||||
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
|
|
||||||
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
|
|
||||||
|
|
||||||
:endReadAdditionalConfig
|
|
||||||
|
|
||||||
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
|
|
||||||
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
|
|
||||||
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
|
|
||||||
|
|
||||||
set WRAPPER_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
|
|
||||||
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
|
|
||||||
IF "%%A"=="wrapperUrl" SET WRAPPER_URL=%%B
|
|
||||||
)
|
|
||||||
|
|
||||||
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
|
|
||||||
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
|
|
||||||
if exist %WRAPPER_JAR% (
|
|
||||||
if "%MVNW_VERBOSE%" == "true" (
|
|
||||||
echo Found %WRAPPER_JAR%
|
|
||||||
)
|
|
||||||
) else (
|
|
||||||
if not "%MVNW_REPOURL%" == "" (
|
|
||||||
SET WRAPPER_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.3.2/maven-wrapper-3.3.2.jar"
|
|
||||||
)
|
|
||||||
if "%MVNW_VERBOSE%" == "true" (
|
|
||||||
echo Couldn't find %WRAPPER_JAR%, downloading it ...
|
|
||||||
echo Downloading from: %WRAPPER_URL%
|
|
||||||
)
|
|
||||||
|
|
||||||
powershell -Command "&{"^
|
|
||||||
"$webclient = new-object System.Net.WebClient;"^
|
|
||||||
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
|
|
||||||
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
|
|
||||||
"}"^
|
|
||||||
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%WRAPPER_URL%', '%WRAPPER_JAR%')"^
|
|
||||||
"}"
|
|
||||||
if "%MVNW_VERBOSE%" == "true" (
|
|
||||||
echo Finished downloading %WRAPPER_JAR%
|
|
||||||
)
|
|
||||||
)
|
|
||||||
@REM End of extension
|
|
||||||
|
|
||||||
@REM If specified, validate the SHA-256 sum of the Maven wrapper jar file
|
|
||||||
SET WRAPPER_SHA_256_SUM=""
|
|
||||||
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
|
|
||||||
IF "%%A"=="wrapperSha256Sum" SET WRAPPER_SHA_256_SUM=%%B
|
|
||||||
)
|
|
||||||
IF NOT %WRAPPER_SHA_256_SUM%=="" (
|
|
||||||
powershell -Command "&{"^
|
|
||||||
"Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash;"^
|
|
||||||
"$hash = (Get-FileHash \"%WRAPPER_JAR%\" -Algorithm SHA256).Hash.ToLower();"^
|
|
||||||
"If('%WRAPPER_SHA_256_SUM%' -ne $hash){"^
|
|
||||||
" Write-Error 'Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised.';"^
|
|
||||||
" Write-Error 'Investigate or delete %WRAPPER_JAR% to attempt a clean download.';"^
|
|
||||||
" Write-Error 'If you updated your Maven version, you need to update the specified wrapperSha256Sum property.';"^
|
|
||||||
" exit 1;"^
|
|
||||||
"}"^
|
|
||||||
"}"
|
|
||||||
if ERRORLEVEL 1 goto error
|
|
||||||
)
|
|
||||||
|
|
||||||
@REM Provide a "standardized" way to retrieve the CLI args that will
|
|
||||||
@REM work with both Windows and non-Windows executions.
|
|
||||||
set MAVEN_CMD_LINE_ARGS=%*
|
|
||||||
|
|
||||||
%MAVEN_JAVA_EXE% ^
|
|
||||||
%JVM_CONFIG_MAVEN_PROPS% ^
|
|
||||||
%MAVEN_OPTS% ^
|
|
||||||
%MAVEN_DEBUG_OPTS% ^
|
|
||||||
-classpath %WRAPPER_JAR% ^
|
|
||||||
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
|
|
||||||
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
|
|
||||||
if ERRORLEVEL 1 goto error
|
|
||||||
goto end
|
|
||||||
|
|
||||||
:error
|
|
||||||
set ERROR_CODE=1
|
|
||||||
|
|
||||||
:end
|
|
||||||
@endlocal & set ERROR_CODE=%ERROR_CODE%
|
|
||||||
|
|
||||||
if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
|
|
||||||
@REM check for post script, once with legacy .bat ending and once with .cmd ending
|
|
||||||
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
|
|
||||||
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
|
|
||||||
:skipRcPost
|
|
||||||
|
|
||||||
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
|
|
||||||
if "%MAVEN_BATCH_PAUSE%"=="on" pause
|
|
||||||
|
|
||||||
if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
|
|
||||||
|
|
||||||
cmd /C exit /B %ERROR_CODE%
|
|
87
pom.xml
87
pom.xml
@ -6,7 +6,7 @@
|
|||||||
|
|
||||||
<groupId>de.stklcode.pubtrans</groupId>
|
<groupId>de.stklcode.pubtrans</groupId>
|
||||||
<artifactId>juraclient</artifactId>
|
<artifactId>juraclient</artifactId>
|
||||||
<version>2.0.10-SNAPSHOT</version>
|
<version>2.0.0</version>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||||
@ -22,7 +22,7 @@
|
|||||||
<licenses>
|
<licenses>
|
||||||
<license>
|
<license>
|
||||||
<name>Apache License 2.0</name>
|
<name>Apache License 2.0</name>
|
||||||
<url>https://www.apache.org/licenses/LICENSE-2.0.html</url>
|
<url>http://www.apache.org/licenses/LICENSE-2.0.html</url>
|
||||||
<distribution>repo</distribution>
|
<distribution>repo</distribution>
|
||||||
</license>
|
</license>
|
||||||
</licenses>
|
</licenses>
|
||||||
@ -39,7 +39,6 @@
|
|||||||
<connection>scm:git:git://github.com/stklcode/juraclient.git</connection>
|
<connection>scm:git:git://github.com/stklcode/juraclient.git</connection>
|
||||||
<developerConnection>scm:git:git@github.com:stklcode/juraclient.git</developerConnection>
|
<developerConnection>scm:git:git@github.com:stklcode/juraclient.git</developerConnection>
|
||||||
<url>https://github.com/stklcode/juraclient</url>
|
<url>https://github.com/stklcode/juraclient</url>
|
||||||
<tag>HEAD</tag>
|
|
||||||
</scm>
|
</scm>
|
||||||
|
|
||||||
<issueManagement>
|
<issueManagement>
|
||||||
@ -51,25 +50,25 @@
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.fasterxml.jackson.core</groupId>
|
<groupId>com.fasterxml.jackson.core</groupId>
|
||||||
<artifactId>jackson-databind</artifactId>
|
<artifactId>jackson-databind</artifactId>
|
||||||
<version>2.18.3</version>
|
<version>2.12.1</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.junit.jupiter</groupId>
|
<groupId>org.junit.jupiter</groupId>
|
||||||
<artifactId>junit-jupiter</artifactId>
|
<artifactId>junit-jupiter</artifactId>
|
||||||
<version>5.12.2</version>
|
<version>5.7.0</version>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.hamcrest</groupId>
|
<groupId>org.hamcrest</groupId>
|
||||||
<artifactId>hamcrest</artifactId>
|
<artifactId>hamcrest</artifactId>
|
||||||
<version>3.0</version>
|
<version>2.2</version>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.wiremock</groupId>
|
<groupId>com.github.tomakehurst</groupId>
|
||||||
<artifactId>wiremock</artifactId>
|
<artifactId>wiremock</artifactId>
|
||||||
<version>3.12.1</version>
|
<version>2.27.2</version>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
@ -79,7 +78,7 @@
|
|||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.sonarsource.scanner.maven</groupId>
|
<groupId>org.sonarsource.scanner.maven</groupId>
|
||||||
<artifactId>sonar-maven-plugin</artifactId>
|
<artifactId>sonar-maven-plugin</artifactId>
|
||||||
<version>5.1.0.4751</version>
|
<version>3.8.0.2131</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
</dependencyManagement>
|
</dependencyManagement>
|
||||||
@ -89,7 +88,7 @@
|
|||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
<artifactId>maven-compiler-plugin</artifactId>
|
<artifactId>maven-compiler-plugin</artifactId>
|
||||||
<version>3.14.0</version>
|
<version>3.8.1</version>
|
||||||
<configuration>
|
<configuration>
|
||||||
<release>11</release>
|
<release>11</release>
|
||||||
</configuration>
|
</configuration>
|
||||||
@ -97,20 +96,19 @@
|
|||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
<artifactId>maven-jar-plugin</artifactId>
|
<artifactId>maven-jar-plugin</artifactId>
|
||||||
<version>3.4.2</version>
|
<version>3.2.0</version>
|
||||||
<configuration>
|
<configuration>
|
||||||
<archive>
|
<archive>
|
||||||
<manifest>
|
<manifestEntries>
|
||||||
<addClasspath>true</addClasspath>
|
<Automatic-Module-Name>de.stklcode.pubtrans.juraclient</Automatic-Module-Name>
|
||||||
<addDefaultImplementationEntries>true</addDefaultImplementationEntries>
|
</manifestEntries>
|
||||||
</manifest>
|
|
||||||
</archive>
|
</archive>
|
||||||
</configuration>
|
</configuration>
|
||||||
</plugin>
|
</plugin>
|
||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
<artifactId>maven-surefire-plugin</artifactId>
|
<artifactId>maven-surefire-plugin</artifactId>
|
||||||
<version>3.5.3</version>
|
<version>2.22.2</version>
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
@ -123,7 +121,7 @@
|
|||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.jacoco</groupId>
|
<groupId>org.jacoco</groupId>
|
||||||
<artifactId>jacoco-maven-plugin</artifactId>
|
<artifactId>jacoco-maven-plugin</artifactId>
|
||||||
<version>0.8.13</version>
|
<version>0.8.6</version>
|
||||||
<executions>
|
<executions>
|
||||||
<execution>
|
<execution>
|
||||||
<id>prepare-agent</id>
|
<id>prepare-agent</id>
|
||||||
@ -154,7 +152,7 @@
|
|||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
<artifactId>maven-source-plugin</artifactId>
|
<artifactId>maven-source-plugin</artifactId>
|
||||||
<version>3.3.1</version>
|
<version>3.2.1</version>
|
||||||
<executions>
|
<executions>
|
||||||
<execution>
|
<execution>
|
||||||
<id>attach-sources</id>
|
<id>attach-sources</id>
|
||||||
@ -178,7 +176,7 @@
|
|||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
<artifactId>maven-javadoc-plugin</artifactId>
|
<artifactId>maven-javadoc-plugin</artifactId>
|
||||||
<version>3.11.2</version>
|
<version>3.2.0</version>
|
||||||
<configuration>
|
<configuration>
|
||||||
<overview>${basedir}/src/main/javadoc/overview.html</overview>
|
<overview>${basedir}/src/main/javadoc/overview.html</overview>
|
||||||
<source>11</source>
|
<source>11</source>
|
||||||
@ -196,30 +194,6 @@
|
|||||||
</build>
|
</build>
|
||||||
</profile>
|
</profile>
|
||||||
|
|
||||||
<profile>
|
|
||||||
<id>sbom</id>
|
|
||||||
<build>
|
|
||||||
<plugins>
|
|
||||||
<plugin>
|
|
||||||
<groupId>org.cyclonedx</groupId>
|
|
||||||
<artifactId>cyclonedx-maven-plugin</artifactId>
|
|
||||||
<version>2.9.1</version>
|
|
||||||
<executions>
|
|
||||||
<execution>
|
|
||||||
<phase>package</phase>
|
|
||||||
<goals>
|
|
||||||
<goal>makeBom</goal>
|
|
||||||
</goals>
|
|
||||||
<configuration>
|
|
||||||
<skipNotDeployed>false</skipNotDeployed>
|
|
||||||
</configuration>
|
|
||||||
</execution>
|
|
||||||
</executions>
|
|
||||||
</plugin>
|
|
||||||
</plugins>
|
|
||||||
</build>
|
|
||||||
</profile>
|
|
||||||
|
|
||||||
<profile>
|
<profile>
|
||||||
<id>sign</id>
|
<id>sign</id>
|
||||||
<build>
|
<build>
|
||||||
@ -227,7 +201,7 @@
|
|||||||
<plugin>
|
<plugin>
|
||||||
<groupId>org.apache.maven.plugins</groupId>
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
<artifactId>maven-gpg-plugin</artifactId>
|
<artifactId>maven-gpg-plugin</artifactId>
|
||||||
<version>3.2.7</version>
|
<version>1.6</version>
|
||||||
<executions>
|
<executions>
|
||||||
<execution>
|
<execution>
|
||||||
<id>sign-artifacts</id>
|
<id>sign-artifacts</id>
|
||||||
@ -260,20 +234,17 @@
|
|||||||
</profile>
|
</profile>
|
||||||
|
|
||||||
<profile>
|
<profile>
|
||||||
<id>central</id>
|
<id>sonatype</id>
|
||||||
<build>
|
<distributionManagement>
|
||||||
<plugins>
|
<repository>
|
||||||
<plugin>
|
<id>ossrh</id>
|
||||||
<groupId>org.sonatype.central</groupId>
|
<url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
|
||||||
<artifactId>central-publishing-maven-plugin</artifactId>
|
</repository>
|
||||||
<version>0.7.0</version>
|
<snapshotRepository>
|
||||||
<extensions>true</extensions>
|
<id>ossrh</id>
|
||||||
<configuration>
|
<url>https://oss.sonatype.org/content/repositories/snapshots</url>
|
||||||
<publishingServerId>central</publishingServerId>
|
</snapshotRepository>
|
||||||
</configuration>
|
</distributionManagement>
|
||||||
</plugin>
|
|
||||||
</plugins>
|
|
||||||
</build>
|
|
||||||
</profile>
|
</profile>
|
||||||
</profiles>
|
</profiles>
|
||||||
</project>
|
</project>
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
@ -225,7 +225,7 @@ public class UraClient implements Serializable {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* Get list of trips with limit.
|
* Get list of trips with limit.
|
||||||
* If {@link #forStops(String...)} and/or {@link #forLines(String...)} has been called, those will be used as filter.
|
* If forStops() and/or forLines() has been called, those will be used as filter.
|
||||||
*
|
*
|
||||||
* @param limit Maximum number of results.
|
* @param limit Maximum number of results.
|
||||||
* @return List of trips.
|
* @return List of trips.
|
||||||
@ -314,7 +314,7 @@ public class UraClient implements Serializable {
|
|||||||
// Create the reader.
|
// Create the reader.
|
||||||
try {
|
try {
|
||||||
AsyncUraTripReader reader = new AsyncUraTripReader(
|
AsyncUraTripReader reader = new AsyncUraTripReader(
|
||||||
URI.create(requestURL(config.getBaseURL() + config.getStreamPath(), REQUEST_TRIP, query)),
|
URI.create(requestURL(config.getBaseURL() + config.getStreeamPath(), REQUEST_TRIP, query)),
|
||||||
config,
|
config,
|
||||||
consumers
|
consumers
|
||||||
);
|
);
|
||||||
@ -342,7 +342,7 @@ public class UraClient implements Serializable {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* List available stopIDs.
|
* List available stopIDs.
|
||||||
* If {@link #forStops(String...)} and/or {@link #forLines(String...)} has been called, those will be used as filter.
|
* If forStops() and/or forLines() has been called, those will be used as filter.
|
||||||
*
|
*
|
||||||
* @param query The query.
|
* @param query The query.
|
||||||
* @return The list.
|
* @return The list.
|
||||||
@ -395,20 +395,6 @@ public class UraClient implements Serializable {
|
|||||||
return getMessages(query, null);
|
return getMessages(query, null);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Get list of messages with limit.
|
|
||||||
* If forStops() has been called, those will be used as filter.
|
|
||||||
*
|
|
||||||
* @param limit Maximum number of results.
|
|
||||||
* @return List of trips.
|
|
||||||
* @throws UraClientException Error with API communication.
|
|
||||||
* @since 2.0.4
|
|
||||||
*/
|
|
||||||
public List<Message> getMessages(final Integer limit) throws UraClientException {
|
|
||||||
return getMessages(new Query(), limit);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get list of messages for given stopIDs with result limit.
|
* Get list of messages for given stopIDs with result limit.
|
||||||
*
|
*
|
||||||
@ -656,18 +642,6 @@ public class UraClient implements Serializable {
|
|||||||
return UraClient.this.getTrips(this);
|
return UraClient.this.getTrips(this);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Get trips for set filters with limit.
|
|
||||||
*
|
|
||||||
* @param limit Maximum number of results.
|
|
||||||
* @return List of matching trips.
|
|
||||||
* @throws UraClientException Error with API communication.
|
|
||||||
* @since 2.0.4
|
|
||||||
*/
|
|
||||||
public List<Trip> getTrips(final Integer limit) throws UraClientException {
|
|
||||||
return UraClient.this.getTrips(this, limit);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get trips for set filters.
|
* Get trips for set filters.
|
||||||
*
|
*
|
||||||
@ -704,17 +678,5 @@ public class UraClient implements Serializable {
|
|||||||
public List<Message> getMessages() throws UraClientException {
|
public List<Message> getMessages() throws UraClientException {
|
||||||
return UraClient.this.getMessages(this);
|
return UraClient.this.getMessages(this);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Get trips for set filters.
|
|
||||||
*
|
|
||||||
* @param limit Maximum number of results.
|
|
||||||
* @return List of matching messages.
|
|
||||||
* @throws UraClientException Error with API communication.
|
|
||||||
* @since 2.0.4
|
|
||||||
*/
|
|
||||||
public List<Message> getMessages(final Integer limit) throws UraClientException {
|
|
||||||
return UraClient.this.getMessages(this, limit);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,26 +1,10 @@
|
|||||||
/*
|
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package de.stklcode.pubtrans.ura;
|
package de.stklcode.pubtrans.ura;
|
||||||
|
|
||||||
import java.io.Serializable;
|
import java.io.Serializable;
|
||||||
import java.time.Duration;
|
import java.time.Duration;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Configuration Object for the {@link UraClient}.
|
* Configurstion Object for the {@link UraClient}.
|
||||||
*
|
*
|
||||||
* @author Stefan Kalscheuer
|
* @author Stefan Kalscheuer
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
@ -103,7 +87,7 @@ public class UraClientConfiguration implements Serializable {
|
|||||||
*
|
*
|
||||||
* @return Stream endpoint path.
|
* @return Stream endpoint path.
|
||||||
*/
|
*/
|
||||||
public String getStreamPath() {
|
public String getStreeamPath() {
|
||||||
return this.streamPath;
|
return this.streamPath;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,19 +1,3 @@
|
|||||||
/*
|
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package de.stklcode.pubtrans.ura.model;
|
package de.stklcode.pubtrans.ura.model;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
@ -203,7 +187,7 @@ public class Message implements Model {
|
|||||||
/**
|
/**
|
||||||
* Messages are assigned a priority in order for them to be ranked.
|
* 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.
|
* 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.
|
* @return Message priority.
|
||||||
*/
|
*/
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
|
@ -1,19 +1,3 @@
|
|||||||
/*
|
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
|
||||||
*
|
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
||||||
* you may not use this file except in compliance with the License.
|
|
||||||
* You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package de.stklcode.pubtrans.ura;
|
package de.stklcode.pubtrans.ura;
|
||||||
|
|
||||||
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.Test;
|
||||||
@ -28,9 +12,9 @@ import static org.junit.jupiter.api.Assertions.assertNull;
|
|||||||
*
|
*
|
||||||
* @author Stefan Kalscheuer
|
* @author Stefan Kalscheuer
|
||||||
*/
|
*/
|
||||||
class UraClientConfigurationTest {
|
public class UraClientConfigurationTest {
|
||||||
@Test
|
@Test
|
||||||
void configBuilderTest() {
|
public void configBuilderTest() {
|
||||||
final String baseURL = "https://ura.example.com";
|
final String baseURL = "https://ura.example.com";
|
||||||
final String instantPath = "/path/to/instant";
|
final String instantPath = "/path/to/instant";
|
||||||
final String streamPath = "/path/to/stream";
|
final String streamPath = "/path/to/stream";
|
||||||
@ -41,7 +25,7 @@ class UraClientConfigurationTest {
|
|||||||
UraClientConfiguration config = UraClientConfiguration.forBaseURL(baseURL).build();
|
UraClientConfiguration config = UraClientConfiguration.forBaseURL(baseURL).build();
|
||||||
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
|
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
|
||||||
assertEquals("/interfaces/ura/instant_V1", config.getInstantPath(), "Unexpected default instant path");
|
assertEquals("/interfaces/ura/instant_V1", config.getInstantPath(), "Unexpected default instant path");
|
||||||
assertEquals("/interfaces/ura/stream_V1", config.getStreamPath(), "Unexpected default stream path");
|
assertEquals("/interfaces/ura/stream_V1", config.getStreeamPath(), "Unexpected default stream path");
|
||||||
assertNull(config.getConnectTimeout(), "No default connection timeout expected");
|
assertNull(config.getConnectTimeout(), "No default connection timeout expected");
|
||||||
assertNull(config.getTimeout(), "No default timeout expected");
|
assertNull(config.getTimeout(), "No default timeout expected");
|
||||||
|
|
||||||
@ -52,7 +36,7 @@ class UraClientConfigurationTest {
|
|||||||
.build();
|
.build();
|
||||||
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
|
assertEquals(baseURL, config.getBaseURL(), "Unexpected base URL");
|
||||||
assertEquals(instantPath, config.getInstantPath(), "Unexpected custom instant path");
|
assertEquals(instantPath, config.getInstantPath(), "Unexpected custom instant path");
|
||||||
assertEquals(streamPath, config.getStreamPath(), "Unexpected custom stream path");
|
assertEquals(streamPath, config.getStreeamPath(), "Unexpected custom stream path");
|
||||||
|
|
||||||
// With timeouts. (#14)
|
// With timeouts. (#14)
|
||||||
config = UraClientConfiguration.forBaseURL(baseURL)
|
config = UraClientConfiguration.forBaseURL(baseURL)
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
@ -16,14 +16,17 @@
|
|||||||
|
|
||||||
package de.stklcode.pubtrans.ura;
|
package de.stklcode.pubtrans.ura;
|
||||||
|
|
||||||
|
import com.github.tomakehurst.wiremock.WireMockServer;
|
||||||
|
import com.github.tomakehurst.wiremock.client.WireMock;
|
||||||
|
import com.github.tomakehurst.wiremock.core.WireMockConfiguration;
|
||||||
import com.github.tomakehurst.wiremock.http.Fault;
|
import com.github.tomakehurst.wiremock.http.Fault;
|
||||||
import com.github.tomakehurst.wiremock.junit5.WireMockExtension;
|
|
||||||
import de.stklcode.pubtrans.ura.exception.UraClientException;
|
import de.stklcode.pubtrans.ura.exception.UraClientException;
|
||||||
import de.stklcode.pubtrans.ura.model.Message;
|
import de.stklcode.pubtrans.ura.model.Message;
|
||||||
import de.stklcode.pubtrans.ura.model.Stop;
|
import de.stklcode.pubtrans.ura.model.Stop;
|
||||||
import de.stklcode.pubtrans.ura.model.Trip;
|
import de.stklcode.pubtrans.ura.model.Trip;
|
||||||
|
import org.junit.jupiter.api.AfterAll;
|
||||||
|
import org.junit.jupiter.api.BeforeAll;
|
||||||
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.Test;
|
||||||
import org.junit.jupiter.api.extension.RegisterExtension;
|
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.http.HttpConnectTimeoutException;
|
import java.net.http.HttpConnectTimeoutException;
|
||||||
@ -33,7 +36,6 @@ import java.util.List;
|
|||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
import static com.github.tomakehurst.wiremock.client.WireMock.*;
|
import static com.github.tomakehurst.wiremock.client.WireMock.*;
|
||||||
import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.wireMockConfig;
|
|
||||||
import static org.hamcrest.CoreMatchers.nullValue;
|
import static org.hamcrest.CoreMatchers.nullValue;
|
||||||
import static org.hamcrest.CoreMatchers.startsWith;
|
import static org.hamcrest.CoreMatchers.startsWith;
|
||||||
import static org.hamcrest.MatcherAssert.assertThat;
|
import static org.hamcrest.MatcherAssert.assertThat;
|
||||||
@ -44,25 +46,35 @@ import static org.junit.jupiter.api.Assertions.*;
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* Unit test for the URA Client.
|
* Unit test for the URA Client.
|
||||||
* Tests run against mocked data collected from ASEAG API (no longer available) and
|
* Tests run against mocked data collected from ASEAG API (http://ivu.aseag.de) and
|
||||||
* TFL API (<a href="https://countdown.api.tfl.gov.uk">https://countdown.api.tfl.gov.uk</a>)
|
* TFL API (http://http://countdown.api.tfl.gov.uk)
|
||||||
*
|
*
|
||||||
* @author Stefan Kalscheuer
|
* @author Stefan Kalscheuer
|
||||||
*/
|
*/
|
||||||
class UraClientTest {
|
public class UraClientTest {
|
||||||
|
private static WireMockServer httpMock;
|
||||||
|
|
||||||
@RegisterExtension
|
@BeforeAll
|
||||||
static WireMockExtension wireMock = WireMockExtension.newInstance()
|
public static void setUp() {
|
||||||
.options(wireMockConfig().dynamicPort())
|
// Initialize HTTP mock.
|
||||||
.build();
|
httpMock = new WireMockServer(WireMockConfiguration.options().dynamicPort());
|
||||||
|
httpMock.start();
|
||||||
|
WireMock.configureFor("localhost", httpMock.port());
|
||||||
|
}
|
||||||
|
|
||||||
|
@AfterAll
|
||||||
|
public static void tearDown() {
|
||||||
|
httpMock.stop();
|
||||||
|
httpMock = null;
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getStopsTest() throws UraClientException {
|
public void getStopsTest() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(2, "instant_V2_stops.txt");
|
mockHttpToFile(2, "instant_V2_stops.txt");
|
||||||
|
|
||||||
// List stops and verify some values.
|
// List stops and verify some values.
|
||||||
List<Stop> stops = new UraClient(wireMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream").getStops();
|
List<Stop> stops = new UraClient(httpMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream").getStops();
|
||||||
assertThat(stops, hasSize(10));
|
assertThat(stops, hasSize(10));
|
||||||
assertThat(stops.get(0).getId(), is("100210"));
|
assertThat(stops.get(0).getId(), is("100210"));
|
||||||
assertThat(stops.get(1).getName(), is("Brockenberg"));
|
assertThat(stops.get(1).getName(), is("Brockenberg"));
|
||||||
@ -74,7 +86,7 @@ class UraClientTest {
|
|||||||
mockHttpToError(500);
|
mockHttpToError(500);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
new UraClient(wireMock.baseUrl()).getStops();
|
new UraClient(httpMock.baseUrl()).getStops();
|
||||||
} catch (RuntimeException e) {
|
} catch (RuntimeException e) {
|
||||||
assertThat(e, is(instanceOf(IllegalStateException.class)));
|
assertThat(e, is(instanceOf(IllegalStateException.class)));
|
||||||
assertThat(e.getCause(), is(instanceOf(IOException.class)));
|
assertThat(e.getCause(), is(instanceOf(IOException.class)));
|
||||||
@ -83,12 +95,12 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getStopsForLineTest() throws UraClientException {
|
public void getStopsForLineTest() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(2, "instant_V2_stops_line.txt");
|
mockHttpToFile(2, "instant_V2_stops_line.txt");
|
||||||
|
|
||||||
// List stops and verify some values.
|
// List stops and verify some values.
|
||||||
List<Stop> stops = new UraClient(wireMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream")
|
List<Stop> stops = new UraClient(httpMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream")
|
||||||
.forLines("33")
|
.forLines("33")
|
||||||
.getStops();
|
.getStops();
|
||||||
assertThat(stops, hasSize(47));
|
assertThat(stops, hasSize(47));
|
||||||
@ -101,12 +113,12 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getStopsForPositionTest() throws UraClientException {
|
public void getStopsForPositionTest() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_stops_circle.txt");
|
mockHttpToFile(1, "instant_V1_stops_circle.txt");
|
||||||
|
|
||||||
// List stops and verify some values.
|
// List stops and verify some values.
|
||||||
List<Stop> stops = new UraClient(wireMock.baseUrl())
|
List<Stop> stops = new UraClient(httpMock.baseUrl())
|
||||||
.forPosition(51.51009, -0.1345734, 200)
|
.forPosition(51.51009, -0.1345734, 200)
|
||||||
.getStops();
|
.getStops();
|
||||||
assertThat(stops, hasSize(13));
|
assertThat(stops, hasSize(13));
|
||||||
@ -118,7 +130,7 @@ class UraClientTest {
|
|||||||
assertThat(stops.get(5).getIndicator(), is(nullValue()));
|
assertThat(stops.get(5).getIndicator(), is(nullValue()));
|
||||||
|
|
||||||
mockHttpToFile(1, "instant_V1_stops_circle_name.txt");
|
mockHttpToFile(1, "instant_V1_stops_circle_name.txt");
|
||||||
stops = new UraClient(wireMock.baseUrl())
|
stops = new UraClient(httpMock.baseUrl())
|
||||||
.forStopsByName("Piccadilly Circus")
|
.forStopsByName("Piccadilly Circus")
|
||||||
.forPosition(51.51009, -0.1345734, 200)
|
.forPosition(51.51009, -0.1345734, 200)
|
||||||
.getStops();
|
.getStops();
|
||||||
@ -127,18 +139,18 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getTripsForDestinationNamesTest() throws UraClientException {
|
public void getTripsForDestinationNamesTest() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_trips_destination.txt");
|
mockHttpToFile(1, "instant_V1_trips_destination.txt");
|
||||||
|
|
||||||
// List stops and verify some values.
|
// List stops and verify some values.
|
||||||
List<Trip> trips = new UraClient(wireMock.baseUrl()).forDestinationNames("Piccadilly Circus").getTrips();
|
List<Trip> trips = new UraClient(httpMock.baseUrl()).forDestinationNames("Piccadilly Circus").getTrips();
|
||||||
assertThat(trips, hasSize(9));
|
assertThat(trips, hasSize(9));
|
||||||
assertThat(trips.stream().filter(t -> !t.getDestinationName().equals("Piccadilly Cir")).findAny(),
|
assertThat(trips.stream().filter(t -> !t.getDestinationName().equals("Piccadilly Cir")).findAny(),
|
||||||
is(Optional.empty()));
|
is(Optional.empty()));
|
||||||
|
|
||||||
mockHttpToFile(1, "instant_V1_trips_stop_destination.txt");
|
mockHttpToFile(1, "instant_V1_trips_stop_destination.txt");
|
||||||
trips = new UraClient(wireMock.baseUrl())
|
trips = new UraClient(httpMock.baseUrl())
|
||||||
.forStops("156")
|
.forStops("156")
|
||||||
.forDestinationNames("Marble Arch")
|
.forDestinationNames("Marble Arch")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
@ -150,27 +162,27 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getTripsTowardsTest() throws UraClientException {
|
public void getTripsTowardsTest() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_trips_towards.txt");
|
mockHttpToFile(1, "instant_V1_trips_towards.txt");
|
||||||
|
|
||||||
/* List stops and verify some values */
|
/* List stops and verify some values */
|
||||||
List<Trip> trips = new UraClient(wireMock.baseUrl()).towards("Marble Arch").getTrips();
|
List<Trip> trips = new UraClient(httpMock.baseUrl()).towards("Marble Arch").getTrips();
|
||||||
assertThat(trips, hasSize(10));
|
assertThat(trips, hasSize(10));
|
||||||
|
|
||||||
mockHttpToFile(1, "instant_V1_trips_stop_towards.txt");
|
mockHttpToFile(1, "instant_V1_trips_stop_towards.txt");
|
||||||
trips = new UraClient(wireMock.baseUrl()).forStops("156").towards("Marble Arch").getTrips();
|
trips = new UraClient(httpMock.baseUrl()).forStops("156").towards("Marble Arch").getTrips();
|
||||||
assertThat(trips, hasSize(17));
|
assertThat(trips, hasSize(17));
|
||||||
assertThat(trips.stream().filter(t -> !t.getStop().getId().equals("156")).findAny(), is(Optional.empty()));
|
assertThat(trips.stream().filter(t -> !t.getStop().getId().equals("156")).findAny(), is(Optional.empty()));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getTripsTest() throws UraClientException {
|
public void getTripsTest() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_trips_all.txt");
|
mockHttpToFile(1, "instant_V1_trips_all.txt");
|
||||||
|
|
||||||
// Get trips without filters and verify some values.
|
// Get trips without filters and verify some values.
|
||||||
List<Trip> trips = new UraClient(wireMock.baseUrl()).getTrips();
|
List<Trip> trips = new UraClient(httpMock.baseUrl()).getTrips();
|
||||||
assertThat(trips, hasSize(10));
|
assertThat(trips, hasSize(10));
|
||||||
assertThat(trips.get(0).getId(), is("27000165015001"));
|
assertThat(trips.get(0).getId(), is("27000165015001"));
|
||||||
assertThat(trips.get(1).getLineID(), is("55"));
|
assertThat(trips.get(1).getLineID(), is("55"));
|
||||||
@ -183,17 +195,11 @@ class UraClientTest {
|
|||||||
assertThat(trips.get(8).getVisitID(), is(30));
|
assertThat(trips.get(8).getVisitID(), is(30));
|
||||||
assertThat(trips.get(9).getStop().getId(), is("100002"));
|
assertThat(trips.get(9).getStop().getId(), is("100002"));
|
||||||
|
|
||||||
// With limit.
|
|
||||||
trips = new UraClient(wireMock.baseUrl()).getTrips(5);
|
|
||||||
assertThat(trips, hasSize(5));
|
|
||||||
trips = new UraClient(wireMock.baseUrl()).getTrips(11);
|
|
||||||
assertThat(trips, hasSize(10));
|
|
||||||
|
|
||||||
// Repeat test for API V2.
|
// Repeat test for API V2.
|
||||||
mockHttpToFile(2, "instant_V2_trips_all.txt");
|
mockHttpToFile(2, "instant_V2_trips_all.txt");
|
||||||
|
|
||||||
// Get trips without filters and verify some values.
|
// Get trips without filters and verify some values.
|
||||||
trips = new UraClient(wireMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream")
|
trips = new UraClient(httpMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
assertThat(trips, hasSize(10));
|
assertThat(trips, hasSize(10));
|
||||||
assertThat(trips.get(0).getId(), is("27000165015001"));
|
assertThat(trips.get(0).getId(), is("27000165015001"));
|
||||||
@ -209,13 +215,13 @@ class UraClientTest {
|
|||||||
|
|
||||||
// Get limited number of trips.
|
// Get limited number of trips.
|
||||||
mockHttpToFile(1, "instant_V1_trips_all.txt");
|
mockHttpToFile(1, "instant_V1_trips_all.txt");
|
||||||
trips = new UraClient(wireMock.baseUrl()).getTrips(5);
|
trips = new UraClient(httpMock.baseUrl()).getTrips(5);
|
||||||
assertThat(trips, hasSize(5));
|
assertThat(trips, hasSize(5));
|
||||||
|
|
||||||
// Test mockException handling.
|
// Test mockException handling.
|
||||||
mockHttpToError(502);
|
mockHttpToError(502);
|
||||||
try {
|
try {
|
||||||
new UraClient(wireMock.baseUrl()).getTrips();
|
new UraClient(httpMock.baseUrl()).getTrips();
|
||||||
} catch (RuntimeException e) {
|
} catch (RuntimeException e) {
|
||||||
assertThat(e, is(instanceOf(IllegalStateException.class)));
|
assertThat(e, is(instanceOf(IllegalStateException.class)));
|
||||||
assertThat(e.getCause(), is(instanceOf(IOException.class)));
|
assertThat(e.getCause(), is(instanceOf(IOException.class)));
|
||||||
@ -225,20 +231,20 @@ class UraClientTest {
|
|||||||
mockHttpToException();
|
mockHttpToException();
|
||||||
UraClientException exception = assertThrows(
|
UraClientException exception = assertThrows(
|
||||||
UraClientException.class,
|
UraClientException.class,
|
||||||
() -> new UraClient(wireMock.baseUrl()).getTrips(),
|
() -> new UraClient(httpMock.baseUrl()).getTrips(),
|
||||||
"Expected reader to raise an exception"
|
"Expected reader to raise an exception"
|
||||||
);
|
);
|
||||||
assertEquals("Failed to read trips from API", exception.getMessage(), "Unexpected error message");
|
assertEquals("Failed to read trips from API", exception.getMessage(), "Unexpected error message");
|
||||||
assertInstanceOf(IOException.class, exception.getCause(), "Unexpected error cause");
|
assertTrue(exception.getCause() instanceof IOException, "Unexpected error cause");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getTripsForStopTest() throws UraClientException {
|
public void getTripsForStopTest() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_trips_stop.txt");
|
mockHttpToFile(1, "instant_V1_trips_stop.txt");
|
||||||
|
|
||||||
// Get trips for stop ID 100000 (Aachen Bushof) and verify some values.
|
// Get trips for stop ID 100000 (Aachen Bushof) and verify some values.
|
||||||
List<Trip> trips = new UraClient(wireMock.baseUrl())
|
List<Trip> trips = new UraClient(httpMock.baseUrl())
|
||||||
.forStops("100000")
|
.forStops("100000")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
assertThat(trips, hasSize(10));
|
assertThat(trips, hasSize(10));
|
||||||
@ -248,15 +254,9 @@ class UraClientTest {
|
|||||||
assertThat(trips.get(2).getLineName(), is("25"));
|
assertThat(trips.get(2).getLineName(), is("25"));
|
||||||
assertThat(trips.get(3).getStop().getIndicator(), is("H.15"));
|
assertThat(trips.get(3).getStop().getIndicator(), is("H.15"));
|
||||||
|
|
||||||
// With limit.
|
|
||||||
trips = new UraClient(wireMock.baseUrl())
|
|
||||||
.forStops("100000")
|
|
||||||
.getTrips(7);
|
|
||||||
assertThat(trips, hasSize(7));
|
|
||||||
|
|
||||||
// Get trips for stop name "Uniklinik" and verify some values.
|
// Get trips for stop name "Uniklinik" and verify some values.
|
||||||
mockHttpToFile(1, "instant_V1_trips_stop_name.txt");
|
mockHttpToFile(1, "instant_V1_trips_stop_name.txt");
|
||||||
trips = new UraClient(wireMock.baseUrl())
|
trips = new UraClient(httpMock.baseUrl())
|
||||||
.forStopsByName("Uniklinik")
|
.forStopsByName("Uniklinik")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
assertThat(trips, hasSize(10));
|
assertThat(trips, hasSize(10));
|
||||||
@ -270,20 +270,20 @@ class UraClientTest {
|
|||||||
mockHttpToException();
|
mockHttpToException();
|
||||||
UraClientException exception = assertThrows(
|
UraClientException exception = assertThrows(
|
||||||
UraClientException.class,
|
UraClientException.class,
|
||||||
() -> new UraClient(wireMock.baseUrl()).getStops(),
|
() -> new UraClient(httpMock.baseUrl()).getStops(),
|
||||||
"Expected reader to raise an exception"
|
"Expected reader to raise an exception"
|
||||||
);
|
);
|
||||||
assertEquals("Failed to read stops from API", exception.getMessage(), "Unexpected error message");
|
assertEquals("Failed to read stops from API", exception.getMessage(), "Unexpected error message");
|
||||||
assertInstanceOf(IOException.class, exception.getCause(), "Unexpected error cause");
|
assertTrue(exception.getCause() instanceof IOException, "Unexpected error cause");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getTripsForLine() throws UraClientException {
|
public void getTripsForLine() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_trips_line.txt");
|
mockHttpToFile(1, "instant_V1_trips_line.txt");
|
||||||
|
|
||||||
// Get trips for line ID 3 and verify some values.
|
// Get trips for line ID 3 and verify some values.
|
||||||
List<Trip> trips = new UraClient(wireMock.baseUrl())
|
List<Trip> trips = new UraClient(httpMock.baseUrl())
|
||||||
.forLines("3")
|
.forLines("3")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
assertThat(trips, hasSize(10));
|
assertThat(trips, hasSize(10));
|
||||||
@ -295,7 +295,7 @@ class UraClientTest {
|
|||||||
|
|
||||||
// Get trips for line name "3.A" and verify some values.
|
// Get trips for line name "3.A" and verify some values.
|
||||||
mockHttpToFile(1, "instant_V1_trips_line_name.txt");
|
mockHttpToFile(1, "instant_V1_trips_line_name.txt");
|
||||||
trips = new UraClient(wireMock.baseUrl())
|
trips = new UraClient(httpMock.baseUrl())
|
||||||
.forLinesByName("3.A")
|
.forLinesByName("3.A")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
assertThat(trips, hasSize(10));
|
assertThat(trips, hasSize(10));
|
||||||
@ -307,7 +307,7 @@ class UraClientTest {
|
|||||||
|
|
||||||
// Get trips for line 3 with direction 1 and verify some values.
|
// Get trips for line 3 with direction 1 and verify some values.
|
||||||
mockHttpToFile(1, "instant_V1_trips_line_direction.txt");
|
mockHttpToFile(1, "instant_V1_trips_line_direction.txt");
|
||||||
trips = new UraClient(wireMock.baseUrl())
|
trips = new UraClient(httpMock.baseUrl())
|
||||||
.forLines("412")
|
.forLines("412")
|
||||||
.forDirection(2)
|
.forDirection(2)
|
||||||
.getTrips();
|
.getTrips();
|
||||||
@ -317,7 +317,7 @@ class UraClientTest {
|
|||||||
|
|
||||||
// Test lineID and direction in different order.
|
// Test lineID and direction in different order.
|
||||||
mockHttpToFile(1, "instant_V1_trips_line_direction.txt");
|
mockHttpToFile(1, "instant_V1_trips_line_direction.txt");
|
||||||
trips = new UraClient(wireMock.baseUrl())
|
trips = new UraClient(httpMock.baseUrl())
|
||||||
.forDirection(2)
|
.forDirection(2)
|
||||||
.forLines("412")
|
.forLines("412")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
@ -327,12 +327,12 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getTripsForStopAndLine() throws UraClientException {
|
public void getTripsForStopAndLine() throws UraClientException {
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_trips_stop_line.txt");
|
mockHttpToFile(1, "instant_V1_trips_stop_line.txt");
|
||||||
|
|
||||||
// Get trips for line ID 25 and 25 at stop 100000 and verify some values.
|
// Get trips for line ID 25 and 25 at stop 100000 and verify some values.
|
||||||
List<Trip> trips = new UraClient(wireMock.baseUrl())
|
List<Trip> trips = new UraClient(httpMock.baseUrl())
|
||||||
.forLines("25", "35")
|
.forLines("25", "35")
|
||||||
.forStops("100000")
|
.forStops("100000")
|
||||||
.getTrips();
|
.getTrips();
|
||||||
@ -348,14 +348,13 @@ class UraClientTest {
|
|||||||
|
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getMessages() throws UraClientException {
|
public void getMessages() throws UraClientException {
|
||||||
UraClient uraClient = new UraClient(wireMock.baseUrl());
|
|
||||||
|
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(1, "instant_V1_messages.txt");
|
mockHttpToFile(1, "instant_V1_messages.txt");
|
||||||
|
|
||||||
// Get messages without filter and verify some values.
|
// Get messages without filter and verify some values.
|
||||||
List<Message> messages = uraClient.getMessages();
|
List<Message> messages = new UraClient(httpMock.baseUrl())
|
||||||
|
.getMessages();
|
||||||
assertThat(messages, hasSize(2));
|
assertThat(messages, hasSize(2));
|
||||||
assertThat(messages.get(0).getStop().getId(), is("100707"));
|
assertThat(messages.get(0).getStop().getId(), is("100707"));
|
||||||
assertThat(messages.get(0).getUuid(), is("016e1231d4e30014_100707"));
|
assertThat(messages.get(0).getUuid(), is("016e1231d4e30014_100707"));
|
||||||
@ -366,47 +365,35 @@ class UraClientTest {
|
|||||||
assertThat(messages.get(0).getText(), is("Sehr geehrte Fahrgäste, wegen Strassenbauarbeiten kann diese Haltestelle nicht von den Bussen der Linien 17, 44 und N2 angefahren werden."));
|
assertThat(messages.get(0).getText(), is("Sehr geehrte Fahrgäste, wegen Strassenbauarbeiten kann diese Haltestelle nicht von den Bussen der Linien 17, 44 und N2 angefahren werden."));
|
||||||
assertThat(messages.get(1).getText(), is("Sehr geehrte Fahrgäste, diese Haltestelle wird vorübergehend von den Linien 47, 147 und N3 nicht angefahren."));
|
assertThat(messages.get(1).getText(), is("Sehr geehrte Fahrgäste, diese Haltestelle wird vorübergehend von den Linien 47, 147 und N3 nicht angefahren."));
|
||||||
|
|
||||||
// With limit.
|
|
||||||
messages = uraClient.getMessages(1);
|
|
||||||
assertThat(messages, hasSize(1));
|
|
||||||
messages = uraClient.getMessages(3);
|
|
||||||
assertThat(messages, hasSize(2));
|
|
||||||
|
|
||||||
mockHttpToException();
|
mockHttpToException();
|
||||||
UraClientException exception = assertThrows(
|
UraClientException exception = assertThrows(
|
||||||
UraClientException.class,
|
UraClientException.class,
|
||||||
() -> new UraClient(wireMock.baseUrl()).getMessages(),
|
() -> new UraClient(httpMock.baseUrl()).getMessages(),
|
||||||
"Expected reader to raise an exception"
|
"Expected reader to raise an exception"
|
||||||
);
|
);
|
||||||
assertEquals("Failed to read messages from API", exception.getMessage(), "Unexpected error message");
|
assertEquals("Failed to read messages from API", exception.getMessage(), "Unexpected error message");
|
||||||
assertInstanceOf(IOException.class, exception.getCause(), "Unexpected error cause");
|
assertTrue(exception.getCause() instanceof IOException, "Unexpected error cause");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getMessagesForStop() throws UraClientException {
|
public void getMessagesForStop() throws UraClientException {
|
||||||
UraClient uraClient = new UraClient(wireMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream");
|
|
||||||
|
|
||||||
// Mock the HTTP call.
|
// Mock the HTTP call.
|
||||||
mockHttpToFile(2, "instant_V2_messages_stop.txt");
|
mockHttpToFile(2, "instant_V2_messages_stop.txt");
|
||||||
|
|
||||||
// Get trips for stop ID 100707 (Berensberger Str.) and verify some values.
|
// Get trips for stop ID 100707 (Berensberger Str.) and verify some values.
|
||||||
List<Message> messages = uraClient.forStops("100707").getMessages();
|
List<Message> messages = new UraClient(httpMock.baseUrl(), "/interfaces/ura/instant_V2", "/interfaces/ura/stream")
|
||||||
|
.forStops("100707")
|
||||||
|
.getMessages();
|
||||||
assertThat(messages, hasSize(1));
|
assertThat(messages, hasSize(1));
|
||||||
assertThat(messages.stream().filter(t -> !t.getStop().getId().equals("100707")).findAny(), is(Optional.empty()));
|
assertThat(messages.stream().filter(t -> !t.getStop().getId().equals("100707")).findAny(), is(Optional.empty()));
|
||||||
assertThat(messages.get(0).getUuid(), is("016e1231d4e30014_100707"));
|
assertThat(messages.get(0).getUuid(), is("016e1231d4e30014_100707"));
|
||||||
assertThat(messages.get(0).getType(), is(0));
|
assertThat(messages.get(0).getType(), is(0));
|
||||||
assertThat(messages.get(0).getPriority(), is(3));
|
assertThat(messages.get(0).getPriority(), is(3));
|
||||||
assertThat(messages.get(0).getText(), is("Sehr geehrte Fahrgäste, wegen Strassenbauarbeiten kann diese Haltestelle nicht von den Bussen der Linien 17, 44 und N2 angefahren werden."));
|
assertThat(messages.get(0).getText(), is("Sehr geehrte Fahrgäste, wegen Strassenbauarbeiten kann diese Haltestelle nicht von den Bussen der Linien 17, 44 und N2 angefahren werden."));
|
||||||
|
|
||||||
// With limit.
|
|
||||||
messages = uraClient.forStops("100707").getMessages(0);
|
|
||||||
assertThat(messages, hasSize(0));
|
|
||||||
messages = uraClient.forStops("100707").getMessages(2);
|
|
||||||
assertThat(messages, hasSize(1));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void timeoutTest() {
|
public void timeoutTest() {
|
||||||
// Try to read trips from TEST-NET-1 IP that is not routed (hopefully) and will not connect within 100ms.
|
// Try to read trips from TEST-NET-1 IP that is not routed (hopefully) and will not connect within 100ms.
|
||||||
UraClientException exception = assertThrows(
|
UraClientException exception = assertThrows(
|
||||||
UraClientException.class,
|
UraClientException.class,
|
||||||
@ -417,17 +404,17 @@ class UraClientTest {
|
|||||||
).forDestinationNames("Piccadilly Circus").getTrips(),
|
).forDestinationNames("Piccadilly Circus").getTrips(),
|
||||||
"Connection to TEST-NET-1 address should fail"
|
"Connection to TEST-NET-1 address should fail"
|
||||||
);
|
);
|
||||||
assertInstanceOf(HttpConnectTimeoutException.class, exception.getCause(), "Exception cause is not HttpConnectionTimeoutException");
|
assertTrue(exception.getCause() instanceof HttpConnectTimeoutException, "Exception cause is not HttpConnectionTimeoutException");
|
||||||
|
|
||||||
// Mock the HTTP call with delay of 200ms, but immediate connection.
|
// Mock the HTTP call with delay of 200ms, but immediate connection.
|
||||||
wireMock.stubFor(
|
WireMock.stubFor(
|
||||||
get(urlPathEqualTo("/interfaces/ura/instant_V1")).willReturn(
|
get(urlPathEqualTo("/interfaces/ura/instant_V1")).willReturn(
|
||||||
aResponse().withFixedDelay(200).withBodyFile("instant_V1_trips_destination.txt")
|
aResponse().withFixedDelay(200).withBodyFile("instant_V1_trips_destination.txt")
|
||||||
)
|
)
|
||||||
);
|
);
|
||||||
assertDoesNotThrow(
|
assertDoesNotThrow(
|
||||||
() -> new UraClient(
|
() -> new UraClient(
|
||||||
UraClientConfiguration.forBaseURL(wireMock.baseUrl())
|
UraClientConfiguration.forBaseURL(httpMock.baseUrl())
|
||||||
.withConnectTimeout(Duration.ofMillis(100))
|
.withConnectTimeout(Duration.ofMillis(100))
|
||||||
.build()
|
.build()
|
||||||
).forDestinationNames("Piccadilly Circus").getTrips(),
|
).forDestinationNames("Piccadilly Circus").getTrips(),
|
||||||
@ -438,17 +425,17 @@ class UraClientTest {
|
|||||||
exception = assertThrows(
|
exception = assertThrows(
|
||||||
UraClientException.class,
|
UraClientException.class,
|
||||||
() -> new UraClient(
|
() -> new UraClient(
|
||||||
UraClientConfiguration.forBaseURL(wireMock.baseUrl())
|
UraClientConfiguration.forBaseURL(httpMock.baseUrl())
|
||||||
.withTimeout(Duration.ofMillis(100))
|
.withTimeout(Duration.ofMillis(100))
|
||||||
.build()
|
.build()
|
||||||
).forDestinationNames("Piccadilly Circus").getTrips(),
|
).forDestinationNames("Piccadilly Circus").getTrips(),
|
||||||
"Response timeout did not raise an exception"
|
"Response timeout did not raise an exception"
|
||||||
);
|
);
|
||||||
assertInstanceOf(HttpTimeoutException.class, exception.getCause(), "Exception cause is not HttpTimeoutException");
|
assertTrue(exception.getCause() instanceof HttpTimeoutException, "Exception cause is not HttpTimeoutException");
|
||||||
|
|
||||||
assertDoesNotThrow(
|
assertDoesNotThrow(
|
||||||
() -> new UraClient(
|
() -> new UraClient(
|
||||||
UraClientConfiguration.forBaseURL(wireMock.baseUrl())
|
UraClientConfiguration.forBaseURL(httpMock.baseUrl())
|
||||||
.withTimeout(Duration.ofMillis(300))
|
.withTimeout(Duration.ofMillis(300))
|
||||||
.build()
|
.build()
|
||||||
).forDestinationNames("Piccadilly Circus").getTrips(),
|
).forDestinationNames("Piccadilly Circus").getTrips(),
|
||||||
@ -457,7 +444,7 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private static void mockHttpToFile(int version, String resourceFile) {
|
private static void mockHttpToFile(int version, String resourceFile) {
|
||||||
wireMock.stubFor(
|
WireMock.stubFor(
|
||||||
get(urlPathEqualTo("/interfaces/ura/instant_V" + version)).willReturn(
|
get(urlPathEqualTo("/interfaces/ura/instant_V" + version)).willReturn(
|
||||||
aResponse().withBodyFile(resourceFile)
|
aResponse().withBodyFile(resourceFile)
|
||||||
)
|
)
|
||||||
@ -465,7 +452,7 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private static void mockHttpToError(int code) {
|
private static void mockHttpToError(int code) {
|
||||||
wireMock.stubFor(
|
WireMock.stubFor(
|
||||||
get(anyUrl()).willReturn(
|
get(anyUrl()).willReturn(
|
||||||
aResponse().withStatus(code)
|
aResponse().withStatus(code)
|
||||||
)
|
)
|
||||||
@ -473,7 +460,7 @@ class UraClientTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private static void mockHttpToException() {
|
private static void mockHttpToException() {
|
||||||
wireMock.stubFor(
|
WireMock.stubFor(
|
||||||
get(anyUrl()).willReturn(
|
get(anyUrl()).willReturn(
|
||||||
aResponse().withFault(Fault.MALFORMED_RESPONSE_CHUNK)
|
aResponse().withFault(Fault.MALFORMED_RESPONSE_CHUNK)
|
||||||
)
|
)
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with 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;
|
import static org.junit.jupiter.api.Assertions.fail;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Unit test for the {@link Message} model.
|
* Unit test for the {@link Message} meta model.
|
||||||
*
|
*
|
||||||
* @author Stefan Kalscheuer
|
* @author Stefan Kalscheuer
|
||||||
*/
|
*/
|
||||||
class MessageTest {
|
public class MessageTest {
|
||||||
@Test
|
@Test
|
||||||
void basicConstructorTest() {
|
public void basicConstructorTest() {
|
||||||
Message message = new Message("sid",
|
Message message = new Message("sid",
|
||||||
"name",
|
"name",
|
||||||
"indicator",
|
"indicator",
|
||||||
@ -60,7 +60,7 @@ class MessageTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void listConstructorTest() {
|
public void listConstructorTest() {
|
||||||
/* Create valid raw data list */
|
/* Create valid raw data list */
|
||||||
List<Serializable> raw = new ArrayList<>();
|
List<Serializable> raw = new ArrayList<>();
|
||||||
raw.add(1);
|
raw.add(1);
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with 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;
|
import static org.junit.jupiter.api.Assertions.fail;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Unit test for the {@link Stop} model.
|
* Unit test for the {@link Stop} meta model.
|
||||||
*
|
*
|
||||||
* @author Stefan Kalscheuer
|
* @author Stefan Kalscheuer
|
||||||
*/
|
*/
|
||||||
class StopTest {
|
public class StopTest {
|
||||||
@Test
|
@Test
|
||||||
void basicConstructorTest() {
|
public void basicConstructorTest() {
|
||||||
Stop stop = new Stop("id", "name", "indicator", 1, 2.345, 6.789);
|
Stop stop = new Stop("id", "name", "indicator", 1, 2.345, 6.789);
|
||||||
assertThat(stop.getId(), is("id"));
|
assertThat(stop.getId(), is("id"));
|
||||||
assertThat(stop.getName(), is("name"));
|
assertThat(stop.getName(), is("name"));
|
||||||
@ -47,7 +47,7 @@ class StopTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void listConstructorTest() {
|
public void listConstructorTest() {
|
||||||
/* Create valid raw data list */
|
/* Create valid raw data list */
|
||||||
List<Serializable> raw = new ArrayList<>();
|
List<Serializable> raw = new ArrayList<>();
|
||||||
raw.add(1);
|
raw.add(1);
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with 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;
|
import static org.junit.jupiter.api.Assertions.fail;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Unit test for the {@link Trip} model.
|
* Unit test for the {@link Trip} meta model.
|
||||||
*
|
*
|
||||||
* @author Stefan Kalscheuer
|
* @author Stefan Kalscheuer
|
||||||
*/
|
*/
|
||||||
class TripTest {
|
public class TripTest {
|
||||||
@Test
|
@Test
|
||||||
void basicConstructorTest() {
|
public void basicConstructorTest() {
|
||||||
Trip trip = new Trip("sid",
|
Trip trip = new Trip("sid",
|
||||||
"name",
|
"name",
|
||||||
"indicator",
|
"indicator",
|
||||||
@ -70,7 +70,7 @@ class TripTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void listConstructorTest() {
|
public void listConstructorTest() {
|
||||||
/* Create valid raw data list */
|
/* Create valid raw data list */
|
||||||
List<Serializable> raw = new ArrayList<>();
|
List<Serializable> raw = new ArrayList<>();
|
||||||
raw.add(1);
|
raw.add(1);
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright 2016-2024 Stefan Kalscheuer
|
* Copyright 2016-2021 Stefan Kalscheuer
|
||||||
*
|
*
|
||||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
* you may not use this file except in compliance with the License.
|
* you may not use this file except in compliance with the License.
|
||||||
@ -18,12 +18,13 @@ package de.stklcode.pubtrans.ura.reader;
|
|||||||
|
|
||||||
import com.github.tomakehurst.wiremock.WireMockServer;
|
import com.github.tomakehurst.wiremock.WireMockServer;
|
||||||
import com.github.tomakehurst.wiremock.client.WireMock;
|
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.core.WireMockConfiguration;
|
||||||
import com.github.tomakehurst.wiremock.extension.Parameters;
|
import com.github.tomakehurst.wiremock.extension.Parameters;
|
||||||
import com.github.tomakehurst.wiremock.extension.ResponseTransformerV2;
|
import com.github.tomakehurst.wiremock.extension.ResponseTransformer;
|
||||||
import com.github.tomakehurst.wiremock.http.ChunkedDribbleDelay;
|
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.http.Response;
|
||||||
import com.github.tomakehurst.wiremock.stubbing.ServeEvent;
|
|
||||||
import de.stklcode.pubtrans.ura.UraClientConfiguration;
|
import de.stklcode.pubtrans.ura.UraClientConfiguration;
|
||||||
import de.stklcode.pubtrans.ura.model.Trip;
|
import de.stklcode.pubtrans.ura.model.Trip;
|
||||||
import org.junit.jupiter.api.AfterAll;
|
import org.junit.jupiter.api.AfterAll;
|
||||||
@ -53,7 +54,7 @@ import static org.junit.jupiter.api.Assumptions.assumeTrue;
|
|||||||
*
|
*
|
||||||
* @author Stefan Kalscheuer
|
* @author Stefan Kalscheuer
|
||||||
*/
|
*/
|
||||||
class AsyncUraTripReaderTest {
|
public class AsyncUraTripReaderTest {
|
||||||
private static WireMockServer httpMock;
|
private static WireMockServer httpMock;
|
||||||
|
|
||||||
@BeforeAll
|
@BeforeAll
|
||||||
@ -81,7 +82,7 @@ class AsyncUraTripReaderTest {
|
|||||||
* @throws InterruptedException Thread interrupted.
|
* @throws InterruptedException Thread interrupted.
|
||||||
*/
|
*/
|
||||||
@Test
|
@Test
|
||||||
void readerTest() throws InterruptedException {
|
public void readerTest() throws InterruptedException {
|
||||||
// Callback counter for some unhandy async mockery.
|
// Callback counter for some unhandy async mockery.
|
||||||
final AtomicInteger counter = new AtomicInteger(0);
|
final AtomicInteger counter = new AtomicInteger(0);
|
||||||
|
|
||||||
@ -160,7 +161,7 @@ class AsyncUraTripReaderTest {
|
|||||||
* @throws InterruptedException Thread interrupted.
|
* @throws InterruptedException Thread interrupted.
|
||||||
*/
|
*/
|
||||||
@Test
|
@Test
|
||||||
void streamClosedTest() throws InterruptedException {
|
public void streamClosedTest() throws InterruptedException {
|
||||||
// Callback counter for some unhandy async mockery.
|
// Callback counter for some unhandy async mockery.
|
||||||
final AtomicInteger counter = new AtomicInteger(0);
|
final AtomicInteger counter = new AtomicInteger(0);
|
||||||
|
|
||||||
@ -201,7 +202,7 @@ class AsyncUraTripReaderTest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
void timeoutTest() throws InterruptedException {
|
public void timeoutTest() throws InterruptedException {
|
||||||
// Callback counter for some unhandy async mockery.
|
// Callback counter for some unhandy async mockery.
|
||||||
final AtomicInteger counter = new AtomicInteger(0);
|
final AtomicInteger counter = new AtomicInteger(0);
|
||||||
|
|
||||||
@ -288,10 +289,9 @@ class AsyncUraTripReaderTest {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
public static class StreamTransformer implements ResponseTransformerV2 {
|
public static class StreamTransformer extends ResponseTransformer {
|
||||||
@Override
|
@Override
|
||||||
public Response transform(Response response, ServeEvent serveEvent) {
|
public Response transform(Request request, Response response, FileSource files, Parameters parameters) {
|
||||||
Parameters parameters = serveEvent.getTransformerParameters();
|
|
||||||
int chunks = parameters.getInt("chunks", 1);
|
int chunks = parameters.getInt("chunks", 1);
|
||||||
return Response.Builder.like(response)
|
return Response.Builder.like(response)
|
||||||
// Read source file to response.
|
// Read source file to response.
|
||||||
|
Loading…
x
Reference in New Issue
Block a user