summaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
authorromaingimbert <romain.gimbert@orange.com>2019-01-31 13:36:07 +0100
committerromaingimbert <romain.gimbert@orange.com>2019-01-31 13:39:01 +0100
commitcd65ca359cee4d5c46ca61df2c4d022f15ec08b6 (patch)
tree4aa83a80fe04038afe153bfbe153daefbd855102 /src/main/java
parentcf9e2869aaff92b58fb1806b2403a6790d62a709 (diff)
multiple identical hub
-change hubresource -add test Change-Id: Ibb8ef363b84d9bcff83b1786cf7547a7660f957e Issue-ID: EXTAPI-187 Signed-off-by: romaingimbert <romain.gimbert@orange.com>
Diffstat (limited to 'src/main/java')
-rwxr-xr-xsrc/main/java/org/onap/nbi/apis/hub/model/Subscription.java3
-rw-r--r--src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java51
-rw-r--r--src/main/java/org/onap/nbi/exceptions/ApiExceptionHandler.java2
3 files changed, 38 insertions, 18 deletions
diff --git a/src/main/java/org/onap/nbi/apis/hub/model/Subscription.java b/src/main/java/org/onap/nbi/apis/hub/model/Subscription.java
index 53f33ab..34e23e1 100755
--- a/src/main/java/org/onap/nbi/apis/hub/model/Subscription.java
+++ b/src/main/java/org/onap/nbi/apis/hub/model/Subscription.java
@@ -16,8 +16,9 @@
package org.onap.nbi.apis.hub.model;
import java.util.stream.Collectors;
+import org.onap.nbi.commons.Resource;
-public class Subscription {
+public class Subscription implements Resource{
private String id;
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 09826bc..550c185 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
@@ -1,25 +1,28 @@
/**
- * Copyright (c) 2018 Orange
+ * Copyright (c) 2018 Orange
*
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
*
- * http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
*/
package org.onap.nbi.apis.hub.service;
+import com.google.common.collect.Lists;
+import java.text.MessageFormat;
+import java.util.List;
import org.onap.nbi.apis.hub.model.Subscriber;
import org.onap.nbi.apis.hub.model.Subscription;
import org.onap.nbi.apis.hub.repository.SubscriberRepository;
+import org.onap.nbi.exceptions.ValidationException;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Example;
import org.springframework.stereotype.Service;
+import org.springframework.validation.ObjectError;
@Service
public class SubscriptionService {
@@ -27,16 +30,32 @@ public class SubscriptionService {
@Autowired
SubscriberRepository subscriberRepository;
- public Subscriber findSubscriptionById(String subscriptionId){
+ public Subscriber findSubscriptionById(String subscriptionId) {
return subscriberRepository.findOne(subscriptionId);
}
- public Subscriber createSubscription(Subscription subscription){
- Subscriber sub = Subscriber.createFromSubscription(subscription);
- return subscriberRepository.save(sub);
+ public Subscriber createSubscription(Subscription subscription) {
+ subscription.setId(null);
+ Subscriber subscriber = Subscriber.createFromSubscription(subscription);
+ if (isSubscriberAlreadyExisting(subscriber)) {
+ String message = MessageFormat
+ .format("subscription with callback {0} and query {1} already exists", subscription.getCallback(),
+ subscription.getQuery());
+ ObjectError error = new ObjectError("subscription", message);
+ List<ObjectError> errors = Lists.newArrayList(error);
+ throw new ValidationException(errors);
+ } else {
+ return subscriberRepository.save(subscriber);
+ }
}
- public void deleteSubscription(String subscriptionId){
+ private boolean isSubscriberAlreadyExisting(Subscriber subscriber) {
+ Example<Subscriber> subscriberExample = Example.of(subscriber);
+ Subscriber subscriberAlreadyExisting = subscriberRepository.findOne(subscriberExample);
+ return subscriberAlreadyExisting != null;
+ }
+
+ public void deleteSubscription(String subscriptionId) {
subscriberRepository.delete(subscriptionId);
}
@@ -44,7 +63,7 @@ public class SubscriptionService {
subscriberRepository.deleteAll();
}
- public long countSubscription(){
+ public long countSubscription() {
return subscriberRepository.count();
}
diff --git a/src/main/java/org/onap/nbi/exceptions/ApiExceptionHandler.java b/src/main/java/org/onap/nbi/exceptions/ApiExceptionHandler.java
index fa2a65b..e008f09 100644
--- a/src/main/java/org/onap/nbi/exceptions/ApiExceptionHandler.java
+++ b/src/main/java/org/onap/nbi/exceptions/ApiExceptionHandler.java
@@ -54,6 +54,6 @@ public class ApiExceptionHandler {
@ResponseBody
public ResponseEntity<ApiError> validationExceptionHandler(final ValidationException exception) {
ApiError apiError = new ApiError("400", HttpStatus.BAD_REQUEST.getReasonPhrase(), exception.getMessages(), "");
- return new ResponseEntity<>(apiError, HttpStatus.INTERNAL_SERVER_ERROR);
+ return new ResponseEntity<>(apiError, HttpStatus.BAD_REQUEST);
}
}