gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk features
   4  * ================================================================================
   5  * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
   6  * All rights reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *     http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  *
  21  */
  22 package org.onap.ccsdk.features.sdnr.wt.yang.mapper.serialize;
  23
  24 import com.fasterxml.jackson.core.JsonParser;
  25 import com.fasterxml.jackson.core.JsonProcessingException;
  26 import com.fasterxml.jackson.databind.DeserializationContext;
  27 import com.fasterxml.jackson.databind.JsonDeserializer;
  28 import com.google.common.reflect.ClassPath;
  29 import java.io.IOException;
  30 import java.util.List;
  31 import java.util.stream.Collectors;
  32 import org.onap.ccsdk.features.sdnr.wt.yang.mapper.YangToolsMapperHelper;
  33 import org.opendaylight.yangtools.yang.binding.BaseIdentity;
  34 import org.slf4j.Logger;
  35 import org.slf4j.LoggerFactory;
  36
  37 public class BaseIdentityDeserializer<T> extends JsonDeserializer<T> {
  38
  39     private static final Logger LOG = LoggerFactory.getLogger(BaseIdentityDeserializer.class);
  40     private final JsonDeserializer<?> deser;
  41
  42     public BaseIdentityDeserializer(final JsonDeserializer<?> deser) {
  43         this.deser = deser;
  44     }
  45
  46     private static List<Class<? extends BaseIdentity>> getTypesInNamespace(String packageName) throws IOException {
  47         return ClassPath.from(Thread.currentThread().getContextClassLoader()).getTopLevelClasses(packageName).
  48                 stream().map(e -> (Class<? extends BaseIdentity>)e.load()).collect(Collectors.toList());
  49     }
  50
  51     @SuppressWarnings("unchecked")
  52     @Override
  53     public T deserialize(JsonParser parser, DeserializationContext ctxt) throws IOException, JsonProcessingException {
  54         LOG.debug("BaseIdentityDeserializer class for '{}'", parser.getValueAsString());
  55         String clazzToSearch = parser.getValueAsString();
  56         String simpleName;
  57         Class<? extends BaseIdentity> clazz;
  58         // clazz from Elasticsearch is full qualified
  59         int lastDot = clazzToSearch.lastIndexOf(".");
  60         if (lastDot > -1) {
  61             simpleName = clazzToSearch.substring(lastDot + 1);
  62             String finalSimpleName;
  63             if(simpleName.endsWith("Identity")){
  64                 finalSimpleName = simpleName.substring(0, simpleName.length()-8);
  65             }
  66             else{
  67                 finalSimpleName=simpleName;
  68             }
  69             clazz = getTypesInNamespace(clazzToSearch.substring(0, lastDot)).stream()
  70                     .filter(e -> e.getSimpleName().equals(finalSimpleName)).findFirst().orElse(null);
  71             if (clazz != null)
  72                 return (T) YangToolsMapperHelper.getIdentityValueFromClass(clazz);
  73         } else {
  74             simpleName = clazzToSearch.substring(0, 1).toUpperCase() + clazzToSearch.substring(1);
  75             if(simpleName.endsWith("Identity")){
  76                 simpleName = simpleName.substring(0, simpleName.length()-8);
  77             }
  78         }
  79
  80         try {
  81             clazz = (Class<? extends BaseIdentity>) YangToolsMapperHelper.findClass(simpleName);
  82             if (clazz != null)
  83                 return (T) YangToolsMapperHelper.getIdentityValueFromClass(clazz);
  84         } catch (ClassNotFoundException e) {
  85             LOG.warn("BaseIdentityDeserializer class not found for '" + parser.getValueAsString() + "'", e);
  86         }
  87         return (T) deser.deserialize(parser, ctxt);
  88     }
  89 }