eu.dnetlib.broker.openaireAlerts

Class OpenaireAlertsBrokerController

java.lang.Object

eu.dnetlib.common.controller.AbstractDnetController

eu.dnetlib.broker.openaireAlerts.OpenaireAlertsBrokerController

@Profile(value="openaire")
 @RestController
 @RequestMapping(value="/api/openaire-alerts")
public class OpenaireAlertsBrokerController
extends AbstractDnetController

Nested Class Summary

Nested classes/interfaces inherited from class eu.dnetlib.common.controller.AbstractDnetController

AbstractDnetController.ErrorMessage

Constructor Summary

Constructors

Constructor and Description
OpenaireAlertsBrokerController()

Method Summary

Modifier and Type	Method and Description
List<OpenaireDsStat>	deleteStats(String dsId)
List<DatasourceWithAlert>	findDatasourcesWithAlerts()
AlertsPage	findNotifications(String subscrId, int nPage, int size)
AlertsPage	findNotificationsForDs(int nPage, int size, String dsId, String topic)
protected static String	prepareTopicForCompatibility(String compatibility)
Subscription	registerSubscription(String compatibility, String email, String dsId)
List<AlertSubscriptionDesc>	subscriptions(String email, String dsId)
OpenaireDsStat	updateStats(OpenaireDsStat stats)

Methods inherited from class eu.dnetlib.common.controller.AbstractDnetController

handleException

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenaireAlertsBrokerController

public OpenaireAlertsBrokerController()

Method Detail

findDatasourcesWithAlerts

@GetMapping(value="/datasources-with-alerts")
public List<DatasourceWithAlert> findDatasourcesWithAlerts()

registerSubscription

@PostMapping(value="/subscribe/{compatibility}")
public Subscription registerSubscription(@PathVariable
                                                                                          String compatibility,
                                                                                          @RequestParam
                                                                                          String email,
                                                                                          @RequestParam
                                                                                          String dsId)

prepareTopicForCompatibility

protected static String prepareTopicForCompatibility(String compatibility)

subscriptions

@GetMapping(value="/subscriptions")
public List<AlertSubscriptionDesc> subscriptions(@RequestParam(required=false)
                                                                                     String email,
                                                                                     @RequestParam(required=false)
                                                                                     String dsId)

findNotificationsForDs

@GetMapping(value="/notifications-for-ds/{nPage}/{size}")
public AlertsPage findNotificationsForDs(@PathVariable
                                                                                                   int nPage,
                                                                                                   @PathVariable
                                                                                                   int size,
                                                                                                   @RequestParam
                                                                                                   String dsId,
                                                                                                   @RequestParam
                                                                                                   String topic)

findNotifications

@GetMapping(value="/notifications/{subscrId}/{nPage}/{size}")
public AlertsPage findNotifications(@PathVariable
                                                                                                  String subscrId,
                                                                                                  @PathVariable
                                                                                                  int nPage,
                                                                                                  @PathVariable
                                                                                                  int size)

updateStats

@PostMapping(value="/stats/update")
public OpenaireDsStat updateStats(@RequestBody
                                                                      OpenaireDsStat stats)

deleteStats

@GetMapping(value="/stats/clearForDatasource")
public List<OpenaireDsStat> deleteStats(@RequestParam
                                                                                       String dsId)