UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/SmooksUtils.java

   1 /*
   2 * ============LICENSE_START=======================================================
   3 * ONAP : DCAE
   4 * ================================================================================
   5 * Copyright 2018 TechMahindra
   6 *=================================================================================
   7 * Licensed under the Apache License, Version 2.0 (the "License");
   8 * you may not use this file except in compliance with the License.
   9 * You may obtain a copy of the License at
  10 *
  11 *     http://www.apache.org/licenses/LICENSE-2.0
  12 *
  13 * Unless required by applicable law or agreed to in writing, software
  14 * distributed under the License is distributed on an "AS IS" BASIS,
  15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16 * See the License for the specific language governing permissions and
  17 * limitations under the License.
  18 * ============LICENSE_END=========================================================
  19 */
  20 package org.onap.universalvesadapter.utils;
  21
  22 import java.io.ByteArrayInputStream;
  23 import java.io.IOException;
  24 import java.nio.charset.StandardCharsets;
  25 import java.util.Locale;
  26 import javax.xml.transform.stream.StreamSource;
  27 import org.milyn.Smooks;
  28 import org.milyn.container.ExecutionContext;
  29 import org.milyn.payload.StringResult;
  30 import org.onap.dcaegen2.ves.domain.VesEvent;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33
  34
  35 /**
  36  * Utility methods for smooks module
  37  *
  38  * @author kmalbari
  39  *
  40  */
  41 public class SmooksUtils {
  42
  43
  44         private final static Logger LOGGER = LoggerFactory.getLogger(SmooksUtils.class);
  45
  46         /**
  47          * converts the incoming json using passed smooks instance and return the pojo representation of VES event
  48          *
  49          * @param smooks smooks object for the event type
  50          * @param incomingJsonString
  51          * @return VES json's pojo representation
  52          * @throws IOException
  53          */
  54         public static VesEvent getTransformedObjectForInput(Smooks smooks, String incomingJsonString) {
  55
  56                 LOGGER.debug("Transforming json " + incomingJsonString);
  57                 ExecutionContext executionContext = smooks.createExecutionContext();
  58                 LOGGER.debug("Context created");
  59                 Locale defaultLocale = Locale.getDefault();
  60         Locale.setDefault(new Locale("en", "IE"));
  61
  62         StringResult result = new StringResult();
  63
  64         // Configure the execution context to generate a report...
  65 //        executionContext.setEventListener(new HtmlReportGenerator("target/report/report.html"));
  66
  67         // Filter the input message to the outputWriter, using the execution context...
  68         smooks.filterSource(executionContext, new StreamSource(new ByteArrayInputStream(incomingJsonString.getBytes(StandardCharsets.UTF_8))), result);
  69         LOGGER.debug("Transformed incoming json now");
  70         Locale.setDefault(defaultLocale);
  71         VesEvent vesEvent = (VesEvent) executionContext.getBeanContext().getBean("vesEvent");
  72         LOGGER.debug("Converted vesEvent from incoming json");
  73                 return vesEvent;
  74         }
  75
  76 }