gerrit.onap Code Review - policy/apex-pdp.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
   4  *  Modifications Copyright (C) 2021 Bell Canada. All rights reserved.
   5  * ================================================================================
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *      http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  * SPDX-License-Identifier: Apache-2.0
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.onap.policy.apex.service.engine.event.impl.apexprotocolplugin;
  23
  24 import java.util.ArrayList;
  25 import java.util.List;
  26 import org.onap.policy.apex.service.engine.event.ApexEvent;
  27 import org.onap.policy.apex.service.engine.event.ApexEventException;
  28 import org.onap.policy.apex.service.engine.event.ApexEventList;
  29 import org.onap.policy.apex.service.engine.event.ApexEventProtocolConverter;
  30 import org.onap.policy.apex.service.engine.event.ApexEventRuntimeException;
  31 import org.onap.policy.apex.service.parameters.eventprotocol.EventProtocolParameters;
  32 import org.slf4j.ext.XLogger;
  33 import org.slf4j.ext.XLoggerFactory;
  34
  35 /**
  36  * The Class Apex2ApexEventConverter passes through {@link ApexEvent} instances. It is used for
  37  * transferring Apex events directly as POJOs between APEX producers and consumers.
  38  *
  39  * @author Liam Fallon (liam.fallon@ericsson.com)
  40  */
  41 public class Apex2ApexEventConverter implements ApexEventProtocolConverter {
  42     private static final XLogger LOGGER = XLoggerFactory.getXLogger(Apex2ApexEventConverter.class);
  43
  44     /**
  45      * {@inheritDoc}.
  46      */
  47     @Override
  48     public void init(final EventProtocolParameters parameters) {
  49         // Check and get the APEX parameters
  50         if (!(parameters instanceof ApexEventProtocolParameters)) {
  51             final String errorMessage = "specified consumer properties are not applicable to the APEX event protocol";
  52             LOGGER.warn(errorMessage);
  53             throw new ApexEventRuntimeException(errorMessage);
  54         }
  55     }
  56
  57     /**
  58      * {@inheritDoc}.
  59      */
  60     @Override
  61     public List<ApexEvent> toApexEvent(final String eventName, final Object eventObject) throws ApexEventException {
  62         // Check the event eventObject
  63         if (eventObject == null) {
  64             throw new ApexEventException("event processing failed, event is null");
  65         }
  66
  67         // The list of events we will return
  68         final List<ApexEvent> eventList = new ArrayList<>();
  69
  70         try {
  71             // Check if its a single APEX event
  72             if (!(eventObject instanceof ApexEvent)) {
  73                 throw new ApexEventException("incoming event (" + eventObject + ") is not an ApexEvent");
  74             }
  75
  76             final ApexEvent event = (ApexEvent) eventObject;
  77
  78             // Check whether we have any ApexEventList fields, if so this is an event of events and
  79             // all fields should be of type ApexEventList
  80             boolean foundEventListFields = false;
  81             boolean foundOtherFields = false;
  82             for (final Object fieldObject : event.values()) {
  83                 if (fieldObject instanceof ApexEventList) {
  84                     foundEventListFields = true;
  85
  86                     // Add the events to the event list
  87                     eventList.addAll((ApexEventList) fieldObject);
  88                 } else {
  89                     foundOtherFields = true;
  90                 }
  91             }
  92
  93             // If we found both event list fields and other fields we're in trouble
  94             if (foundEventListFields && foundOtherFields) {
  95                 throw new ApexEventException("incoming event (" + eventObject
  96                         + ") has both event list fields and other fields, it cannot be processed");
  97             }
  98
  99             // Check if the incoming event just has other fields, if so it's just a regular event
 100             // and we add it to the event list as the only event there
 101             if (foundOtherFields) {
 102                 eventList.add(event);
 103             }
 104         } catch (final Exception e) {
 105             final String errorString = "Failed to unmarshal APEX event, event=" + eventObject;
 106             throw new ApexEventException(errorString, e);
 107         }
 108
 109         // Return the list of events we have unmarshalled
 110         return eventList;
 111     }
 112
 113     /**
 114      * {@inheritDoc}.
 115      */
 116     @Override
 117     public Object fromApexEvent(final ApexEvent apexEvent) throws ApexEventException {
 118         // Check the Apex event
 119         if (apexEvent == null) {
 120             throw new ApexEventException("event processing failed, Apex event is null");
 121         }
 122
 123         return apexEvent;
 124     }
 125 }