diff options
5 files changed, 29 insertions, 10 deletions
diff --git a/src/main/java/org/onap/nbi/apis/hub/model/Subscriber.java b/src/main/java/org/onap/nbi/apis/hub/model/Subscriber.java index df0cffd..ab2b05f 100755 --- a/src/main/java/org/onap/nbi/apis/hub/model/Subscriber.java +++ b/src/main/java/org/onap/nbi/apis/hub/model/Subscriber.java @@ -56,7 +56,7 @@ public class Subscriber implements Resource { return query; } - public static Subscriber createFromRequest(Subscription request) { + public static Subscriber createFromSubscription(Subscription request) { Subscriber sub = new Subscriber(); sub.setCallback(request.getCallback()); diff --git a/src/main/java/org/onap/nbi/apis/hub/service/EventFactory.java b/src/main/java/org/onap/nbi/apis/hub/service/EventFactory.java index b2a017c..3e04b84 100644 --- a/src/main/java/org/onap/nbi/apis/hub/service/EventFactory.java +++ b/src/main/java/org/onap/nbi/apis/hub/service/EventFactory.java @@ -59,13 +59,15 @@ public class EventFactory { */ private static Object filterServiceOrder(final ServiceOrder serviceOrder) { - Object filteredServiceOrder; + Object filteredServiceOrder = null; - JsonRepresentation jsonRepresentation = new JsonRepresentation(); - jsonRepresentation.add("id").add("href").add("externalId").add("state").add("orderDate").add + if (serviceOrder != null) { + JsonRepresentation jsonRepresentation = new JsonRepresentation(); + jsonRepresentation.add("id").add("href").add("externalId").add("state").add("orderDate").add ("completionDateTime").add("orderItem"); - filteredServiceOrder = JacksonFilter.createNode(serviceOrder, jsonRepresentation); + filteredServiceOrder = JacksonFilter.createNode(serviceOrder, jsonRepresentation); + } return filteredServiceOrder; } diff --git a/src/main/java/org/onap/nbi/apis/hub/service/NotifierService.java b/src/main/java/org/onap/nbi/apis/hub/service/NotifierService.java index 2bfbca1..4f7a549 100755 --- a/src/main/java/org/onap/nbi/apis/hub/service/NotifierService.java +++ b/src/main/java/org/onap/nbi/apis/hub/service/NotifierService.java @@ -19,6 +19,7 @@ import org.onap.nbi.apis.hub.model.Event; import org.onap.nbi.apis.hub.model.Subscriber; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.scheduling.annotation.Async; @@ -31,9 +32,12 @@ import javax.validation.Valid; public class NotifierService { private final Logger logger = LoggerFactory.getLogger(NotifierService.class); + @Autowired + RestTemplate restTemplate; + @Async public void run(Subscriber subscriber, @Valid Event event) { - ResponseEntity<String> re = new RestTemplate().postForEntity(subscriber.getCallback(), event, String.class); + ResponseEntity<String> re = restTemplate.postForEntity(subscriber.getCallback(), event, String.class); if (re.getStatusCode() == HttpStatus.OK) logger.debug("FAILED"); } } diff --git a/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java b/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java index cf9ab66..09826bc 100644 --- a/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java +++ b/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java @@ -32,7 +32,7 @@ public class SubscriptionService { } public Subscriber createSubscription(Subscription subscription){ - Subscriber sub = Subscriber.createFromRequest(subscription); + Subscriber sub = Subscriber.createFromSubscription(subscription); return subscriberRepository.save(sub); } diff --git a/src/test/java/org/onap/nbi/apis/assertions/HubAssertions.java b/src/test/java/org/onap/nbi/apis/assertions/HubAssertions.java index 486c4ef..f2b72f8 100644 --- a/src/test/java/org/onap/nbi/apis/assertions/HubAssertions.java +++ b/src/test/java/org/onap/nbi/apis/assertions/HubAssertions.java @@ -15,14 +15,19 @@ */ package org.onap.nbi.apis.assertions; +import org.onap.nbi.apis.hub.model.Event; +import org.onap.nbi.apis.hub.model.EventType; import org.onap.nbi.apis.hub.model.Subscription; +import java.util.Date; +import java.util.UUID; + public class HubAssertions { public static Subscription createServiceOrderCreationSubscription(){ Subscription subscription = new Subscription(); subscription.setId("id"); - subscription.setCallback("http://localhost:8090"); + subscription.setCallback("http://localhost:8080/test"); subscription.setQuery("eventType = ServiceOrderCreationNotification"); return subscription; } @@ -30,7 +35,7 @@ public class HubAssertions { public static Subscription createServiceOrderStateChangeSubscription(){ Subscription subscription = new Subscription(); subscription.setId("id"); - subscription.setCallback("http://localhost:8090"); + subscription.setCallback("http://localhost/test"); subscription.setQuery("eventType = ServiceOrderStateChangeNotification"); return subscription; } @@ -38,8 +43,16 @@ public class HubAssertions { public static Subscription createServiceOrderItemStateChangeSubscription(){ Subscription subscription = new Subscription(); subscription.setId("id"); - subscription.setCallback("http://localhost:8090"); + subscription.setCallback("http://localhost/test"); subscription.setQuery("eventType = ServiceOrderItemStateChangeNotification"); return subscription; } + + public static Event createFakeEvent() { + Event event = new Event(); + event.setEventId(UUID.randomUUID().toString()); + event.setEventDate(new Date()); + event.setEventType(EventType.SERVICE_ORDER_CREATION.value()); + return event; + } } |