Package energy.eddie.regionconnector.be.fluvius.client

Class FluviusApiClient

java.lang.Object

energy.eddie.regionconnector.be.fluvius.client.FluviusApiClient

All Implemented Interfaces:

FluviusApi

@Component
@Priority(2)
public class FluviusApiClient
extends Object
implements FluviusApi

Field Summary

Fields

Modifier and Type	Field	Description
static final String	OCP_APIM_SUBSCRIPTION_KEY
static final String	PERIOD_TYPE_READ_TIME

Constructor Summary

Constructors

Constructor	Description
FluviusApiClient(org.springframework.web.reactive.function.client.WebClient webClient, FluviusConfiguration fluviusConfiguration, OAuthTokenService oAuthTokenService, String publicUrl)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<GetEnergyResponseModelApiDataResponse>	energy(String permissionId, String eanNumber, DataServiceType dataServiceType, ZonedDateTime from, ZonedDateTime to)
org.springframework.boot.actuate.health.Health	health()
reactor.core.publisher.Mono<GetMandateResponseModelApiDataResponse>	mandateFor(String permissionId)
reactor.core.publisher.Mono<CreateMandateResponseModelApiDataResponse>	mockMandate(String permissionId, ZonedDateTime from, ZonedDateTime to, String ean, Granularity granularity)
reactor.core.publisher.Mono<FluviusSessionCreateResultResponseModelApiDataResponse>	shortUrlIdentifier(String permissionId, Flow flow, ZonedDateTime from, ZonedDateTime to, Granularity granularity)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

OCP_APIM_SUBSCRIPTION_KEY

public static final String OCP_APIM_SUBSCRIPTION_KEY

See Also:

• Constant Field Values

PERIOD_TYPE_READ_TIME

public static final String PERIOD_TYPE_READ_TIME

See Also:

• Constant Field Values

Constructor Details

FluviusApiClient

public FluviusApiClient(org.springframework.web.reactive.function.client.WebClient webClient,
 FluviusConfiguration fluviusConfiguration,
 OAuthTokenService oAuthTokenService,
 @Value("${region-connector.be.fluvius.redirect-uri}")
 String publicUrl)

Method Details

shortUrlIdentifier

public reactor.core.publisher.Mono<FluviusSessionCreateResultResponseModelApiDataResponse> shortUrlIdentifier(String permissionId,
 Flow flow,
 ZonedDateTime from,
 ZonedDateTime to,
 Granularity granularity)

Specified by:

shortUrlIdentifier in interface FluviusApi

mandateFor

public reactor.core.publisher.Mono<GetMandateResponseModelApiDataResponse> mandateFor(String permissionId)

Specified by:

mandateFor in interface FluviusApi

mockMandate

public reactor.core.publisher.Mono<CreateMandateResponseModelApiDataResponse> mockMandate(String permissionId,
 ZonedDateTime from,
 ZonedDateTime to,
 String ean,
 Granularity granularity)

Specified by:

mockMandate in interface FluviusApi

energy

public reactor.core.publisher.Mono<GetEnergyResponseModelApiDataResponse> energy(String permissionId,
 String eanNumber,
 DataServiceType dataServiceType,
 ZonedDateTime from,
 ZonedDateTime to)

Specified by:

energy in interface FluviusApi

health

public org.springframework.boot.actuate.health.Health health()