Package energy.eddie.regionconnector.us.green.button.services.historical.collection

Class HistoricalCollectionService

java.lang.Object

energy.eddie.regionconnector.us.green.button.services.historical.collection.HistoricalCollectionService

@Service
public class HistoricalCollectionService
extends Object

Constructor Summary

Constructors

Constructor	Description
HistoricalCollectionService(GreenButtonApi api, DataNeedMatcher dataNeedMatcher, MeterReadingRepository meterReadingRepository)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<MeterReading>	persistMetersForPermissionRequest(UsGreenButtonPermissionRequest permissionRequest)	Persists meters for permission request if it matches the DataNeedMatcher criteria.
reactor.core.publisher.Mono<Void>	triggerHistoricalDataCollection(UsGreenButtonPermissionRequest permissionRequest)	Activates historical collection for all passed MeterReadings.
reactor.core.publisher.Mono<Void>	triggerHistoricalDataCollection(List<MeterReading> meters, UsGreenButtonPermissionRequest permissionRequest)	Activates historical collection for all passed MeterReadings.

Methods inherited from class java.lang.Object

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

Constructor Details

HistoricalCollectionService

public HistoricalCollectionService(GreenButtonApi api,
 DataNeedMatcher dataNeedMatcher,
 MeterReadingRepository meterReadingRepository)

Method Details

persistMetersForPermissionRequest

public reactor.core.publisher.Flux<MeterReading> persistMetersForPermissionRequest(UsGreenButtonPermissionRequest permissionRequest)

Persists meters for permission request if it matches the DataNeedMatcher criteria.

Parameters:

permissionRequest - the permission request that is used to request meters

Returns:

Empty mono

triggerHistoricalDataCollection

public reactor.core.publisher.Mono<Void> triggerHistoricalDataCollection(List<MeterReading> meters,
 UsGreenButtonPermissionRequest permissionRequest)

Activates historical collection for all passed MeterReadings. If historical collection could not be triggered for a meter, it is removed from the permission request.

Parameters:

meters - that should be activated for historical collection

permissionRequest - permission request containing the meters

triggerHistoricalDataCollection

public reactor.core.publisher.Mono<Void> triggerHistoricalDataCollection(UsGreenButtonPermissionRequest permissionRequest)

Activates historical collection for all passed MeterReadings. If historical collection could not be triggered for a meter, it is removed from the permission request.

Parameters:

permissionRequest - contains the meters that should be activated for historical collection