binding/mdsal-binding-dom-codec/src/main/java/org/opendaylight/mdsal/binding/dom/codec/impl/UnionTypeCodec.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.mdsal.binding.dom.codec.impl;
   9
  10 import com.google.common.collect.ImmutableSet;
  11 import java.lang.reflect.Method;
  12 import java.util.LinkedHashSet;
  13 import java.util.Set;
  14 import java.util.concurrent.Callable;
  15 import org.opendaylight.mdsal.binding.yang.types.BaseYangTypes;
  16 import org.opendaylight.yangtools.concepts.Codec;
  17 import org.opendaylight.yangtools.yang.binding.BindingMapping;
  18 import org.opendaylight.yangtools.yang.model.api.LeafSchemaNode;
  19 import org.opendaylight.yangtools.yang.model.api.Module;
  20 import org.opendaylight.yangtools.yang.model.api.RevisionAwareXPath;
  21 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
  22 import org.opendaylight.yangtools.yang.model.api.SchemaNode;
  23 import org.opendaylight.yangtools.yang.model.api.TypeDefinition;
  24 import org.opendaylight.yangtools.yang.model.api.type.LeafrefTypeDefinition;
  25 import org.opendaylight.yangtools.yang.model.api.type.UnionTypeDefinition;
  26 import org.opendaylight.yangtools.yang.model.util.SchemaContextUtil;
  27
  28 final class UnionTypeCodec extends ReflectionBasedCodec {
  29     private final ImmutableSet<UnionValueOptionContext> typeCodecs;
  30
  31     private UnionTypeCodec(final Class<?> unionCls,final Set<UnionValueOptionContext> codecs) {
  32         super(unionCls);
  33         typeCodecs = ImmutableSet.copyOf(codecs);
  34     }
  35
  36     static Callable<UnionTypeCodec> loader(final Class<?> unionCls, final UnionTypeDefinition unionType,
  37                                            final BindingCodecContext bindingCodecContext) {
  38         return () -> {
  39             final Set<UnionValueOptionContext> values = new LinkedHashSet<>();
  40             for (final TypeDefinition<?> subtype : unionType.getTypes()) {
  41                 if (subtype instanceof LeafrefTypeDefinition) {
  42                     addLeafrefValueCodec(unionCls, unionType, bindingCodecContext, values, subtype);
  43                 } else {
  44                     final Method valueGetter =
  45                             unionCls.getMethod("get" + BindingMapping.getClassName(subtype.getQName()));
  46                     final Class<?> valueType = valueGetter.getReturnType();
  47                     final Codec<Object, Object> valueCodec = bindingCodecContext.getCodec(valueType, subtype);
  48
  49                     values.add(new UnionValueOptionContext(unionCls, valueType, valueGetter, valueCodec));
  50                 }
  51             }
  52
  53             return new UnionTypeCodec(unionCls, values);
  54         };
  55     }
  56
  57     /**
  58      * Prepare codec for type from leaf's return type of leafref.
  59      *
  60      * @param unionCls
  61      *            - union class
  62      * @param unionType
  63      *            - union type
  64      * @param bindingCodecContext
  65      *            - binding codec context
  66      * @param values
  67      *            - union values
  68      * @param subtype
  69      *            - subtype of union
  70      * @throws NoSuchMethodException
  71      */
  72     private static void addLeafrefValueCodec(final Class<?> unionCls, final UnionTypeDefinition unionType,
  73             final BindingCodecContext bindingCodecContext, final Set<UnionValueOptionContext> values,
  74             final TypeDefinition<?> subtype) throws NoSuchMethodException {
  75         final SchemaContext schemaContext = bindingCodecContext.getRuntimeContext().getSchemaContext();
  76         final Module module = schemaContext.findModuleByNamespaceAndRevision(subtype.getQName().getNamespace(),
  77                 subtype.getQName().getRevision());
  78         final RevisionAwareXPath xpath = ((LeafrefTypeDefinition) subtype).getPathStatement();
  79         // find schema node in schema context by xpath of leafref
  80         final SchemaNode dataNode;
  81         if (xpath.isAbsolute()) {
  82             dataNode = SchemaContextUtil.findDataSchemaNode(schemaContext, module, xpath);
  83         } else {
  84             dataNode = SchemaContextUtil.findDataSchemaNodeForRelativeXPath(schemaContext, module, unionType, xpath);
  85         }
  86         final String className = BindingMapping.getClassName(unionCls.getSimpleName());
  87         final LeafSchemaNode typeNode = (LeafSchemaNode) dataNode;
  88
  89         // prepare name of type form return type of referenced leaf
  90         final String typeName = BindingMapping.getClassName(BaseYangTypes.BASE_YANG_TYPES_PROVIDER
  91                 .javaTypeForSchemaDefinitionType(typeNode.getType(), typeNode).getName());
  92
  93         // get method via reflection from generated code according to
  94         // get_TypeName_Value method
  95         final Method valueGetterParent = unionCls
  96                 .getMethod(new StringBuilder("get").append(typeName).append(className).append("Value").toString());
  97         final Class<?> returnType = valueGetterParent.getReturnType();
  98
  99         // prepare codec of union subtype according to return type of referenced
 100         // leaf
 101         final Codec<Object, Object> valueCodec = bindingCodecContext.getCodec(returnType, subtype);
 102         values.add(new UnionValueOptionContext(unionCls, returnType, valueGetterParent, valueCodec));
 103     }
 104
 105     @Override
 106     public Object deserialize(final Object input) {
 107         for (final UnionValueOptionContext member : typeCodecs) {
 108             final Object ret = member.deserializeUnion(input);
 109             if (ret != null) {
 110                 return ret;
 111             }
 112         }
 113
 114         throw new IllegalArgumentException(String.format("Failed to construct instance of %s for input %s",
 115             getTypeClass(), input));
 116     }
 117
 118     @Override
 119     public Object serialize(final Object input) {
 120         if (input != null) {
 121             for (final UnionValueOptionContext valCtx : typeCodecs) {
 122                 final Object domValue = valCtx.serialize(input);
 123                 if (domValue != null) {
 124                     return domValue;
 125                 }
 126             }
 127         }
 128         return null;
 129     }
 130 }