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
  42
  43 public class SmooksUtils {
  44
  45
  46         private final static Logger LOGGER = LoggerFactory.getLogger(SmooksUtils.class);
  47
  48         /**
  49          * converts the incoming json using passed smooks instance and return the pojo representation of VES event
  50          *
  51          * @param smooks smooks object for the event type
  52          * @param incomingJsonString
  53          * @return VES json's pojo representation
  54          * @throws IOException
  55          */
  56         public static VesEvent getTransformedObjectForInput(Smooks smooks, String incomingJsonString) {
  57
  58                 LOGGER.info("Transforming incoming json " );
  59                 ExecutionContext executionContext = smooks.createExecutionContext();
  60                 LOGGER.info("Context created");
  61                 Locale defaultLocale = Locale.getDefault();
  62         Locale.setDefault(new Locale("en", "IE"));
  63
  64         StringResult result = new StringResult();
  65
  66         smooks.filterSource(executionContext, new StreamSource(new ByteArrayInputStream(incomingJsonString.getBytes(StandardCharsets.UTF_8))), result);
  67
  68         Locale.setDefault(defaultLocale);
  69         VesEvent vesEvent = (VesEvent) executionContext.getBeanContext().getBean("vesEvent");
  70         LOGGER.debug("consversion successful to VES Event");
  71
  72                 return vesEvent;
  73         }
  74
  75 }