src/main/java/org/onap/nbi/apis/hub/service/EventFactory.java

   1 /**
   2  * Copyright (c) 2018 Orange
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
   5  * 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 is distributed on
  10  * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
  11  * specific language governing permissions and limitations under the License.
  12  */
  13 package org.onap.nbi.apis.hub.service;
  14
  15 import com.fasterxml.jackson.databind.JsonNode;
  16 import com.fasterxml.jackson.databind.MappingJsonFactory;
  17 import com.fasterxml.jackson.databind.ObjectMapper;
  18 import com.fasterxml.jackson.databind.node.ObjectNode;
  19 import java.io.IOException;
  20 import java.text.DateFormat;
  21 import java.text.SimpleDateFormat;
  22 import java.util.Date;
  23 import java.util.UUID;
  24 import org.onap.nbi.apis.hub.model.Event;
  25 import org.onap.nbi.apis.hub.model.EventType;
  26 import org.onap.nbi.apis.hub.model.ServiceInstanceEvent;
  27 import org.onap.nbi.apis.serviceorder.model.ServiceOrder;
  28 import org.onap.nbi.apis.serviceorder.model.ServiceOrderItem;
  29 import org.onap.nbi.commons.JacksonFilter;
  30 import org.onap.nbi.commons.JsonRepresentation;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33
  34 public class EventFactory {
  35
  36     private static final ObjectMapper mapper = new ObjectMapper(new MappingJsonFactory());
  37     private static final Logger logger = LoggerFactory.getLogger(EventFactory.class);
  38
  39     public static Event getEvent(EventType eventType, ServiceOrder serviceOrder,
  40         ServiceOrderItem serviceOrderItem) {
  41         Event event = new Event();
  42         event.setEventId(UUID.randomUUID().toString());
  43         event.setEventDate(new Date());
  44         event.setEventType(eventType.value());
  45
  46         DateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
  47         mapper.setDateFormat(df);
  48
  49         JsonNode serviceOrderJson = mapper.valueToTree(filterServiceOrder(serviceOrder));
  50
  51         if (EventType.SERVICE_ORDER_ITEM_STATE_CHANGE.equals(eventType)) {
  52             JsonNode serviceOrderItemJson = mapper.valueToTree(serviceOrderItem);
  53             ((ObjectNode) serviceOrderJson).putArray("orderItem").add(serviceOrderItemJson);
  54         }
  55
  56         event.setEvent(serviceOrderJson);
  57
  58         return event;
  59     }
  60
  61     public static Event getEvent(EventType eventType, ServiceInstanceEvent serviceInstanceEvent) {
  62         Event event = new Event();
  63         event.setEventId(UUID.randomUUID().toString());
  64         event.setEventDate(new Date());
  65         event.setEventType(eventType.value());
  66
  67         DateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
  68         mapper.setDateFormat(df);
  69
  70         JsonNode serviceInstanceJson = mapper.valueToTree(serviceInstanceEvent);
  71
  72         event.setEvent(serviceInstanceJson);
  73
  74         return event;
  75     }
  76
  77     public static Event getEvent(EventType eventType, String eventString) {
  78         Event event = new Event();
  79         event.setEventId(UUID.randomUUID().toString());
  80         event.setEventDate(new Date());
  81         event.setEventType(eventType.value());
  82         DateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
  83         mapper.setDateFormat(df);
  84         JsonNode serviceInstanceJson = null;
  85         try {
  86             serviceInstanceJson = mapper.readTree(eventString);
  87             event.setEvent(serviceInstanceJson);
  88             return event;
  89         } catch (IOException e) {
  90             logger.error("IO Error when parsing Event JSON String {} ", eventString,
  91                 e.getMessage());
  92         }
  93         return null;
  94     }
  95
  96
  97     /**
  98      * Filter ServiceOrderObject to produce a lightweight object that fit the eventBody specification
  99      *
 100      * @param serviceOrder
 101      * @return
 102      */
 103     private static Object filterServiceOrder(final ServiceOrder serviceOrder) {
 104
 105         Object filteredServiceOrder = null;
 106
 107         if (serviceOrder != null) {
 108             JsonRepresentation jsonRepresentation = new JsonRepresentation();
 109             jsonRepresentation.add("id").add("href").add("externalId").add("state").add("orderDate")
 110                 .add("completionDateTime").add("orderItem");
 111
 112             filteredServiceOrder = JacksonFilter.createNode(serviceOrder, jsonRepresentation);
 113         }
 114
 115         return filteredServiceOrder;
 116     }
 117 }