Package energy.eddie.aiida.services.record

Class LatestRecordService

java.lang.Object

energy.eddie.aiida.services.record.LatestRecordService

@Service
public class LatestRecordService
extends Object

Constructor Summary

Constructors

Constructor	Description
LatestRecordService(AiidaRecordRepository aiidaRecordRepository, PermissionLatestRecordMap permissionLatestRecordMap, InboundRecordService inboundRecordService, PermissionRepository permissionRepository, InboundAggregator inboundAggregator, AuthService authService)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<LastMessageEventDto>	lastMessageStream()	Streams a LastMessageEventDto for every new inbound/outbound message belonging to the current user's permissions.
LatestDataSourceRecordDto	latestDataSourceRecord(UUID dataSourceId)
List<LatestDataSourceRecordDto>	latestDataSourceRecords(UUID dataSourceId, int amount)
LatestInboundPermissionRecordDto	latestInboundPermissionRecord(UUID permissionId)
LatestOutboundPermissionRecordDto	latestOutboundPermissionRecord(UUID permissionId)

Methods inherited from class java.lang.Object

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

Constructor Details

LatestRecordService

@Autowired
public LatestRecordService(AiidaRecordRepository aiidaRecordRepository,
 PermissionLatestRecordMap permissionLatestRecordMap,
 InboundRecordService inboundRecordService,
 PermissionRepository permissionRepository,
 InboundAggregator inboundAggregator,
 AuthService authService)

Method Details

latestDataSourceRecord

public LatestDataSourceRecordDto latestDataSourceRecord(UUID dataSourceId)
                                                 throws LatestAiidaRecordNotFoundException

Throws:

LatestAiidaRecordNotFoundException

latestDataSourceRecords

public List<LatestDataSourceRecordDto> latestDataSourceRecords(UUID dataSourceId,
 int amount)
                                                        throws LatestAiidaRecordNotFoundException

Throws:

LatestAiidaRecordNotFoundException

latestOutboundPermissionRecord

public LatestOutboundPermissionRecordDto latestOutboundPermissionRecord(UUID permissionId)
                                                                 throws LatestPermissionRecordNotFoundException

Throws:

LatestPermissionRecordNotFoundException

latestInboundPermissionRecord

public LatestInboundPermissionRecordDto latestInboundPermissionRecord(UUID permissionId)
                                                               throws PermissionNotFoundException,
InvalidDataSourceTypeException,
InboundRecordNotFoundException,
UnsupportedInboundRecordTransformationException,
InvalidInboundPermissionException

Throws:

PermissionNotFoundException

InvalidDataSourceTypeException

InboundRecordNotFoundException

UnsupportedInboundRecordTransformationException

InvalidInboundPermissionException

lastMessageStream

public reactor.core.publisher.Flux<LastMessageEventDto> lastMessageStream()
                                                                   throws InvalidUserException

Streams a LastMessageEventDto for every new inbound/outbound message belonging to the current user's permissions. The stream filters per user and not per permission as HTTP/1.1 limits concurrent SSE streams to a maximum of 6.

Throws:

InvalidUserException - if the current request has no valid authenticated user.