Package energy.eddie.outbound.rest.web.agnostic

Class AgnosticController

java.lang.Object

energy.eddie.outbound.rest.web.agnostic.AgnosticController

All Implemented Interfaces:

AgnosticSwagger

@RestController
@RequestMapping("agnostic")
public class AgnosticController
extends Object
implements AgnosticSwagger

Constructor Summary

Constructors

Constructor	Description
AgnosticController(AgnosticConnector agnosticConnector, ConnectionStatusMessageRepository csmRepository, RawDataMessageRepository rawDataRepository, OpaqueEnvelopeRepository opaqueEnvelopeRepository, EventStream eventStream)

Method Summary

Modifier and Type	Method	Description
org.springframework.http.ResponseEntity<ConnectionStatusMessages>	connectionStatusMessages(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<@Valid @Pattern(regexp="[A-Z]{2}") String> countryCode, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<List<ConnectionStatusMessage>>	connectionStatusMessagesJson(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<@Valid @Pattern(regexp="[A-Z]{2}") String> countryCode, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<ConnectionStatusMessage>>	connectionStatusMessagesSSE()
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>>	connectionStatusMessagesSSEXML()
org.springframework.http.ResponseEntity<Void>	opaqueEnvelope(OpaqueEnvelope opaqueEnvelope)
org.springframework.http.ResponseEntity<OpaqueEnvelopes>	opaqueEnvelopes(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<List<OpaqueEnvelope>>	opaqueEnvelopesJson(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<OpaqueEnvelope>>	opaqueEnvelopeSSE()
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>>	opaqueEnvelopeSSEXML()
org.springframework.http.ResponseEntity<Void>	permissionCommand(PermissionCommand permissionCommand)
org.springframework.http.ResponseEntity<RawDataMessages>	rawDataMessages(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<String> countryCode, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<List<RawDataMessage>>	rawDataMessagesJSON(Optional<String> permissionId, Optional<String> connectionId, Optional<String> dataNeedId, Optional<String> countryCode, Optional<String> regionConnectorId, Optional<ZonedDateTime> from, Optional<ZonedDateTime> to)
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<RawDataMessage>>	rawDataMessagesSSE()
org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>>	rawDataMessagesSSEXML()

Methods inherited from class java.lang.Object

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

Constructor Details

AgnosticController

public AgnosticController(AgnosticConnector agnosticConnector,
 ConnectionStatusMessageRepository csmRepository,
 RawDataMessageRepository rawDataRepository,
 OpaqueEnvelopeRepository opaqueEnvelopeRepository,
 EventStream eventStream)

Method Details

connectionStatusMessagesSSE

@GetMapping(value="/connection-status-messages",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<ConnectionStatusMessage>> connectionStatusMessagesSSE()

Specified by:

connectionStatusMessagesSSE in interface AgnosticSwagger

connectionStatusMessagesSSEXML

@GetMapping(value="/connection-status-messages",
            produces="application/vnd.eddie.energy.sse+xml")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> connectionStatusMessagesSSEXML()

Specified by:

connectionStatusMessagesSSEXML in interface AgnosticSwagger

connectionStatusMessages

@GetMapping(value="/connection-status-messages",
            produces="application/xml")
public org.springframework.http.ResponseEntity<ConnectionStatusMessages> connectionStatusMessages(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<@Valid @Pattern(regexp="[A-Z]{2}") String> countryCode,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)

Specified by:

connectionStatusMessages in interface AgnosticSwagger

connectionStatusMessagesJson

@GetMapping(value="/connection-status-messages",
            produces="application/json")
public org.springframework.http.ResponseEntity<List<ConnectionStatusMessage>> connectionStatusMessagesJson(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<@Valid @Pattern(regexp="[A-Z]{2}") String> countryCode,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)

Specified by:

connectionStatusMessagesJson in interface AgnosticSwagger

rawDataMessagesSSE

@GetMapping(value="/raw-data-messages",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<RawDataMessage>> rawDataMessagesSSE()

Specified by:

rawDataMessagesSSE in interface AgnosticSwagger

rawDataMessagesSSEXML

@GetMapping(value="/raw-data-messages",
            produces="application/vnd.eddie.energy.sse+xml")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> rawDataMessagesSSEXML()

Specified by:

rawDataMessagesSSEXML in interface AgnosticSwagger

rawDataMessages

@GetMapping(value="/raw-data-messages",
            produces="application/xml")
public org.springframework.http.ResponseEntity<RawDataMessages> rawDataMessages(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<String> countryCode,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)

Specified by:

rawDataMessages in interface AgnosticSwagger

rawDataMessagesJSON

@GetMapping(value="/raw-data-messages",
            produces="application/json")
public org.springframework.http.ResponseEntity<List<RawDataMessage>> rawDataMessagesJSON(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<String> countryCode,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)

Specified by:

rawDataMessagesJSON in interface AgnosticSwagger

opaqueEnvelopeSSE

@GetMapping(value="/opaque-envelope",
            produces="text/event-stream")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<OpaqueEnvelope>> opaqueEnvelopeSSE()

Specified by:

opaqueEnvelopeSSE in interface AgnosticSwagger

opaqueEnvelopeSSEXML

@GetMapping(value="/opaque-envelope",
            produces="application/vnd.eddie.energy.sse+xml")
public org.springframework.http.ResponseEntity<reactor.core.publisher.Flux<String>> opaqueEnvelopeSSEXML()

Specified by:

opaqueEnvelopeSSEXML in interface AgnosticSwagger

opaqueEnvelopes

@GetMapping(value="/opaque-envelope",
            produces="application/xml")
public org.springframework.http.ResponseEntity<OpaqueEnvelopes> opaqueEnvelopes(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)

Specified by:

opaqueEnvelopes in interface AgnosticSwagger

opaqueEnvelopesJson

@GetMapping(value="/opaque-envelope",
            produces="application/json")
public org.springframework.http.ResponseEntity<List<OpaqueEnvelope>> opaqueEnvelopesJson(@RequestParam(required=false)
 Optional<String> permissionId,
 @RequestParam(required=false)
 Optional<String> connectionId,
 @RequestParam(required=false)
 Optional<String> dataNeedId,
 @RequestParam(required=false)
 Optional<String> regionConnectorId,
 @RequestParam(required=false)
 Optional<ZonedDateTime> from,
 @RequestParam(required=false)
 Optional<ZonedDateTime> to)

Specified by:

opaqueEnvelopesJson in interface AgnosticSwagger

permissionCommand

@PostMapping(value="permission-command",
             consumes={"application/json","application/xml"})
public org.springframework.http.ResponseEntity<Void> permissionCommand(@RequestBody
 PermissionCommand permissionCommand)

Specified by:

permissionCommand in interface AgnosticSwagger

opaqueEnvelope

@PostMapping(value="opaque-envelope",
             consumes={"application/json","application/xml"})
public org.springframework.http.ResponseEntity<Void> opaqueEnvelope(@RequestBody
 OpaqueEnvelope opaqueEnvelope)

Specified by:

opaqueEnvelope in interface AgnosticSwagger