src/test/java/org/onap/nbi/api/listener/ListenerResourceTest.java

   1 /**
   2  * Copyright (c) 2019 Orange
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
   5  * in compliance with the License. You may obtain a copy of the License at
   6  *
   7  * http://www.apache.org/licenses/LICENSE-2.0
   8  *
   9  * Unless required by applicable law or agreed to in writing, software distributed under the License
  10  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
  11  * or implied. See the License for the specific language governing permissions and limitations under
  12  * the License.
  13  */
  14
  15 package org.onap.nbi.api.listener;
  16
  17 import java.net.URI;
  18 import java.util.ArrayList;
  19 import java.util.Collection;
  20 import java.util.Map;
  21 import java.util.concurrent.ConcurrentHashMap;
  22 import org.apache.commons.lang3.StringUtils;
  23 import org.onap.nbi.commons.ResourceManagement;
  24 import org.slf4j.Logger;
  25 import org.slf4j.LoggerFactory;
  26 import org.springframework.http.MediaType;
  27 import org.springframework.http.ResponseEntity;
  28 import org.springframework.util.MultiValueMap;
  29 import org.springframework.web.bind.annotation.DeleteMapping;
  30 import org.springframework.web.bind.annotation.GetMapping;
  31 import org.springframework.web.bind.annotation.PathVariable;
  32 import org.springframework.web.bind.annotation.PostMapping;
  33 import org.springframework.web.bind.annotation.RequestBody;
  34 import org.springframework.web.bind.annotation.RequestMapping;
  35 import org.springframework.web.bind.annotation.RequestParam;
  36 import org.springframework.web.bind.annotation.RestController;
  37 import org.springframework.web.servlet.support.ServletUriComponentsBuilder;
  38 import com.fasterxml.jackson.databind.JsonNode;
  39
  40 @RestController
  41 @RequestMapping("/test/listener")
  42 public class ListenerResourceTest extends ResourceManagement {
  43
  44     Logger logger = LoggerFactory.getLogger(ListenerResourceTest.class);
  45
  46     static Map<String, JsonNode> events = new ConcurrentHashMap<>();
  47
  48     /*
  49      * listener resource test for hub resource
  50      */
  51     @PostMapping(consumes = MediaType.APPLICATION_JSON_VALUE)
  52     public ResponseEntity<JsonNode> postListener(@RequestBody JsonNode event) {
  53         if (logger.isDebugEnabled()) {
  54             logger.debug("POST event from nbi : {}", event.toString());
  55         }
  56         String eventId = event.get("eventId").asText();
  57         logger.info("putting eventId {} in the events map", eventId);
  58         events.put(eventId, event);
  59
  60         URI location = ServletUriComponentsBuilder.fromCurrentRequest().path("/{id}").buildAndExpand(eventId).toUri();
  61
  62         return ResponseEntity.created(location).body(event);
  63     }
  64
  65     @GetMapping(value = "", produces = MediaType.APPLICATION_JSON_VALUE)
  66     public ResponseEntity<Collection<JsonNode>> findEvents(@RequestParam MultiValueMap<String, String> params) {
  67         logger.info("called listener get with params {} : " + params.toString());
  68         Collection<JsonNode> values = new ArrayList<>();
  69         String serviceOrderId = params.getFirst("serviceOrderId");
  70         String serviceInstanceId = params.getFirst("serviceInstanceId");
  71         if (StringUtils.isNotEmpty(serviceOrderId)) {
  72             for (JsonNode jsonNode : events.values()) {
  73                 String id = jsonNode.get("event").get("id").asText();
  74                 logger.info("found event with service order id : " + id);
  75                 if (id.equals(serviceOrderId)) {
  76                     values.add(jsonNode);
  77                 }
  78             }
  79             if (!values.isEmpty()) {
  80                 return ResponseEntity.ok(values);
  81             } else {
  82                 logger.error("cannot found events with service order id : " + serviceOrderId);
  83                 return ResponseEntity.notFound().build();
  84             }
  85         } else if (StringUtils.isNotEmpty(serviceInstanceId)) {
  86             for (JsonNode jsonNode : events.values()) {
  87                 String id = jsonNode.get("event").get("id").asText();
  88                 logger.info("found event with service Instance id : " + id);
  89                 if (id.equals(serviceInstanceId)) {
  90                     values.add(jsonNode);
  91                 }
  92             }
  93             if (!values.isEmpty()) {
  94                 return ResponseEntity.ok(values);
  95             } else {
  96                 logger.error("cannot found events with service instance id : " + serviceInstanceId);
  97                 return ResponseEntity.notFound().build();
  98             }
  99         } else {
 100             values = events.values();
 101         }
 102         return ResponseEntity.ok(values);
 103     }
 104
 105     @GetMapping(value = "/{eventId}", produces = MediaType.APPLICATION_JSON_VALUE)
 106     public ResponseEntity<Object> getEvent(@PathVariable String eventId) {
 107
 108         return ResponseEntity.ok(events.get(eventId));
 109
 110     }
 111
 112     @DeleteMapping(value = "/{eventId}", produces = MediaType.APPLICATION_JSON_VALUE)
 113     public ResponseEntity<Object> deleteEvent(@PathVariable String eventId) {
 114
 115         events.remove(eventId);
 116         return ResponseEntity.noContent().build();
 117
 118     }
 119
 120     @DeleteMapping(produces = MediaType.APPLICATION_JSON_VALUE)
 121     public ResponseEntity<Object> deleteEvents() {
 122
 123         events.clear();
 124         return ResponseEntity.noContent().build();
 125
 126     }
 127
 128 }