amv-trafficsoft-restclient-demo

amv-trafficsoft-restclient-demo is a simple Java demo application to demonstrate accessing the AMV Trafficsoft API with amv-trafficsoft-rest.

build

./gradlew clean build

run

Following demo profiles are currently available:

get-oems-demo
get-last-data-demo
get-data-and-confirm-deliveries-demo
get-data-and-confirm-deliveries-recursive-demo

The active profile can be specified via spring.profiles.active argument:

./gradlew bootRun -Dspring.profiles.active=get-last-data-demo

Multiple profiles can be active as well:

./gradlew bootRun -Dspring.profiles.active=my-profile,get-last-data-demo,get-oems-demo

usage

The application.yml acts as a template for your own configuration parameter.

configuration

Copy the contents of the application.yml file to application-my-profile.yml and start the application with --spring.profiles.active=my-profile. Or simply adapt the application.yml contents to your needs.

examples

LastData

See LastDataRunner.java.

Example of a simple GetLastData call which prints the result to console.

long contractId = 42;
List<Long> vehicleIds = ImmutableList.of(1337L, 9001L);

Action1<List<NodeRestDto>> onNext = nodeRestDtos -> {
    log.info("Received Nodes: {}", nodeRestDtos);
};
Action1<Throwable> onError = error -> {
    log.error("{}", error);
};
Action0 onComplete = () -> {
    log.info("Completed.");
};

log.info("==================================================");
this.xfcdClient.getLastData(contractId, vehicleIds)
        .toObservable()
        .subscribe(onNext, onError, onComplete);
log.info("==================================================");

Example output:

[main] INFO LastDataRunner - ==================================================
[main] INFO LastDataRunner - Received Nodes: [NodeRestDto(id=1, timestamp=Thu Apr 13 14:25:29 CEST 2017, longitude=10.084392, latitude=38.384910, speed=null, heading=null, altitude=null, satellites=null, hdop=null, vdop=null, xfcds=[ParameterRestDto(param=kmrd, value=19221, timestamp=Fri Apr 14 18:39:00 CEST 2017, longitude=10.084373, latitude=38.385097)], states=[ParameterRestDto(param=move, value=0, timestamp=Thu Apr 13 14:21:19 CEST 2017, longitude=null, latitude=null)])]
[main] INFO LastDataRunner - Completed.
[main] INFO LastDataRunner - ==================================================

AllSeriesAndModelsOfOem

See AllSeriesAndModelsOfOemRunner.java.

Example of how to fetch all series and models of all oems.

long contractId = 42;

Action1<SeriesWithModels> onNext = seriesWithModels -> {
    log.info("Received SeriesWithModels: {}", seriesWithModels);
};
Action1<Throwable> onError = error -> {
    log.error("{}", error);
};
Action0 onComplete = () -> {
    log.info("Completed.");
};

// fetch all series of an oem
Func1<OemRestDto, Observable<SeriesRestDto>> fetchSeriesOfOem = oem -> asgRegisterClient
        .getSeries(contractId, oem.getOemCode())
        .toObservable()
        .flatMap(seriesResponse -> Observable.from(seriesResponse.getSeries()));


// fetch all models of a series and transform it to objects holding the series and a list of models
Func1<SeriesRestDto, Observable<ModelRestDto>> fetchModelsOfSeries = series -> asgRegisterClient
        .getModels(contractId, series.getOemCode(), series.getSeriesCode())
        .toObservable()
        .flatMap(modelsResponse -> Observable.from(modelsResponse.getModels()));

log.info("==================================================");
this.asgRegisterClient.getOems(contractId)
        .toObservable()
        .flatMap(oemResponse -> Observable.from(oemResponse.getOems()))
        .flatMap(fetchSeriesOfOem)
        .flatMap(series -> fetchModelsOfSeries.call(series)
                .toList()
                .map(modelList -> SeriesWithModels.builder()
                        .series(series)
                        .models(modelList)
                        .build()))
        .subscribe(onNext, onError, onComplete);
log.info("==================================================");