Package energy.eddie.regionconnector.de.eta.permission.handlers

Class AccountingPointDataHandler

java.lang.Object

energy.eddie.regionconnector.de.eta.permission.handlers.AccountingPointDataHandler

All Implemented Interfaces:

EventHandler<PermissionEvent>

@Component
public class AccountingPointDataHandler
extends Object
implements EventHandler<PermissionEvent>

Handles ACCEPTED permission events for permission requests whose data need is AccountingPointDataNeed. Performs a single-shot fetch against the accounting-point endpoint, publishes the payload to AccountingPointDataStream, and commits the corresponding terminal event.

On 401 the handler attempts one in-flight refresh of the customer's access token using the persisted refresh token; the refreshed token is held only for the duration of the retry and is not persisted.

Constructor Summary

Constructors

Constructor	Description
AccountingPointDataHandler(EventBus eventBus, DePermissionRequestRepository repository, DataNeedsService dataNeedsService, EtaPlusApiClient apiClient, EtaAuthService authService, AccountingPointDataStream stream, Outbox outbox, DePermissionCredentialsRepository credentialsRepository)

Method Summary

Modifier and Type	Method	Description
void	accept(PermissionEvent event)	Subscription method for the event bus

Methods inherited from class java.lang.Object

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

Constructor Details

AccountingPointDataHandler

public AccountingPointDataHandler(EventBus eventBus,
 DePermissionRequestRepository repository,
 DataNeedsService dataNeedsService,
 EtaPlusApiClient apiClient,
 EtaAuthService authService,
 AccountingPointDataStream stream,
 Outbox outbox,
 DePermissionCredentialsRepository credentialsRepository)

Method Details

accept

public void accept(PermissionEvent event)

Description copied from interface: EventHandler

Subscription method for the event bus

Specified by:

accept in interface EventHandler<PermissionEvent>

Parameters:

event - event that indicates that a permission request has been changed