Package energy.eddie.aiida.services

Class HandshakeService

java.lang.Object

energy.eddie.aiida.services.HandshakeService

@Component
public class HandshakeService
extends Object

Constructor Summary

Constructors

Constructor	Description
HandshakeService(ApplicationInformationService applicationInformationService, org.springframework.web.reactive.function.client.WebClient webClient)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<PermissionDetailsDto>	fetchDetailsForPermission(Permission permission)	Fetches the details about the permission and the associated data need from the respective EDDIE framework.
reactor.core.publisher.Mono<MqttDto>	fetchMqttDetails(Permission permission)	Accepts the permission and sends the appropriate message to the respective EDDIE framework.
void	sendUnfulfillableOrRejected(Permission permission, PermissionStatus status)	Makes a blocking request to the EDDIE framework to update the permission to indicate that this AIIDA instance cannot fulfill this permission request.

Methods inherited from class java.lang.Object

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

Constructor Details

HandshakeService

public HandshakeService(ApplicationInformationService applicationInformationService,
 org.springframework.web.reactive.function.client.WebClient webClient)

Method Details

fetchDetailsForPermission

public reactor.core.publisher.Mono<PermissionDetailsDto> fetchDetailsForPermission(Permission permission)

Fetches the details about the permission and the associated data need from the respective EDDIE framework. This call is blocking.

sendUnfulfillableOrRejected

public void sendUnfulfillableOrRejected(Permission permission,
 PermissionStatus status)

Makes a blocking request to the EDDIE framework to update the permission to indicate that this AIIDA instance cannot fulfill this permission request. Any occurring errors are just logged.

fetchMqttDetails

public reactor.core.publisher.Mono<MqttDto> fetchMqttDetails(Permission permission)

Accepts the permission and sends the appropriate message to the respective EDDIE framework. Will return the MQTT credentials and topic names that are to be used by the associated permission.