Package energy.eddie.regionconnector.us.green.button.client

Class GreenButtonClient

java.lang.Object

energy.eddie.regionconnector.us.green.button.client.GreenButtonClient

All Implemented Interfaces:

GreenButtonApi

@Component
public class GreenButtonClient
extends Object
implements GreenButtonApi

Constructor Summary

Constructors

Constructor	Description
GreenButtonClient(org.springframework.web.reactive.function.client.WebClient webClient, GreenButtonConfiguration config)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<com.rometools.rome.feed.synd.SyndFeed>	batchSubscription(String authId, String accessToken, Iterable<String> meters, ZonedDateTime publishedMin, ZonedDateTime publishedMax)
reactor.core.publisher.Mono<HistoricalCollectionResponse>	collectHistoricalData(List<String> meterIds, String company)	Triggers historical data collection for the meters.
reactor.core.publisher.Mono<Meter>	fetchMeter(String meterId, String company)	Fetches the details for one meter.
reactor.core.publisher.Flux<MeterListing>	fetchMeters(Pages slurp, List<String> authIds, String company)	Fetches all meters that have been shared with this utility user.
reactor.core.publisher.Mono<Boolean>	isAlive()
reactor.core.publisher.Mono<org.naesb.espi.ServiceStatus>	readServiceStatus()
reactor.core.publisher.Mono<com.rometools.rome.feed.synd.SyndFeed>	retailCustomer(String authId, String accessToken)
reactor.core.publisher.Mono<Authorization>	revoke(String authUid, String company)

Methods inherited from class java.lang.Object

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

Constructor Details

GreenButtonClient

public GreenButtonClient(org.springframework.web.reactive.function.client.WebClient webClient,
 GreenButtonConfiguration config)

Method Details

readServiceStatus

public reactor.core.publisher.Mono<org.naesb.espi.ServiceStatus> readServiceStatus()

Specified by:

readServiceStatus in interface GreenButtonApi

isAlive

public reactor.core.publisher.Mono<Boolean> isAlive()

Specified by:

isAlive in interface GreenButtonApi

batchSubscription

public reactor.core.publisher.Flux<com.rometools.rome.feed.synd.SyndFeed> batchSubscription(String authId,
 String accessToken,
 Iterable<String> meters,
 ZonedDateTime publishedMin,
 ZonedDateTime publishedMax)

Specified by:

batchSubscription in interface GreenButtonApi

retailCustomer

public reactor.core.publisher.Mono<com.rometools.rome.feed.synd.SyndFeed> retailCustomer(String authId,
 String accessToken)

Specified by:

retailCustomer in interface GreenButtonApi

collectHistoricalData

public reactor.core.publisher.Mono<HistoricalCollectionResponse> collectHistoricalData(List<String> meterIds,
 String company)

Description copied from interface: GreenButtonApi

Triggers historical data collection for the meters.

Specified by:

collectHistoricalData in interface GreenButtonApi

Parameters:

meterIds - the meters for which the collection should be triggered

company - the company to which the meters belong to

Returns:

the result of the API call

fetchMeters

public reactor.core.publisher.Flux<MeterListing> fetchMeters(Pages slurp,
 List<String> authIds,
 String company)

Description copied from interface: GreenButtonApi

Fetches all meters that have been shared with this utility user. Uses the JSON API to fetch the meter data: https://utilityapi.com/docs/api/meters/list. The API supports pagination, so it's possible to only request the first page or all pages.

Specified by:

fetchMeters in interface GreenButtonApi

Parameters:

slurp - if all pages should be requested

authIds - auth IDs of the meters of interest

company - the company which the meters belong to

Returns:

shared meter

fetchMeter

public reactor.core.publisher.Mono<Meter> fetchMeter(String meterId,
 String company)

Description copied from interface: GreenButtonApi

Fetches the details for one meter.

Specified by:

fetchMeter in interface GreenButtonApi

Parameters:

meterId - the UID of the meter

company - the company of the meter

Returns:

the meter details

revoke

public reactor.core.publisher.Mono<Authorization> revoke(String authUid,
 String company)

Specified by:

revoke in interface GreenButtonApi