binding2/mdsal-binding2-dom-adapter/src/main/java/org/opendaylight/mdsal/binding/javav2/dom/adapter/impl/operation/BindingDOMOperationProviderServiceAdapter.java

   1 /*
   2  * Copyright (c) 2017 Pantheon Technologies s.r.o. 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.javav2.dom.adapter.impl.operation;
   9
  10 import com.google.common.annotations.Beta;
  11 import com.google.common.collect.ImmutableSet;
  12 import java.lang.reflect.Method;
  13 import java.util.ArrayList;
  14 import java.util.Collection;
  15 import java.util.HashSet;
  16 import java.util.Map;
  17 import java.util.Set;
  18 import org.opendaylight.mdsal.binding.javav2.api.RpcActionProviderService;
  19 import org.opendaylight.mdsal.binding.javav2.dom.adapter.registration.BindingDOMOperationAdapterRegistration;
  20 import org.opendaylight.mdsal.binding.javav2.dom.codec.impl.BindingToNormalizedNodeCodec;
  21 import org.opendaylight.mdsal.binding.javav2.spec.base.Action;
  22 import org.opendaylight.mdsal.binding.javav2.spec.base.InstanceIdentifier;
  23 import org.opendaylight.mdsal.binding.javav2.spec.base.KeyedInstanceIdentifier;
  24 import org.opendaylight.mdsal.binding.javav2.spec.base.ListAction;
  25 import org.opendaylight.mdsal.binding.javav2.spec.base.Rpc;
  26 import org.opendaylight.mdsal.binding.javav2.spec.base.TreeNode;
  27 import org.opendaylight.mdsal.dom.api.DOMRpcIdentifier;
  28 import org.opendaylight.mdsal.dom.api.DOMRpcImplementationRegistration;
  29 import org.opendaylight.mdsal.dom.api.DOMRpcProviderService;
  30 import org.opendaylight.yangtools.concepts.Identifier;
  31 import org.opendaylight.yangtools.concepts.ObjectRegistration;
  32 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
  33 import org.opendaylight.yangtools.yang.model.api.SchemaPath;
  34
  35 //FIXME missing support of Action operation (dependence on support of Yang 1.1 in DOM part of MD-SAL)
  36 /**
  37  * Operation service provider adapter.
  38  */
  39 @Beta
  40 public class BindingDOMOperationProviderServiceAdapter implements RpcActionProviderService {
  41
  42     private static final Set<YangInstanceIdentifier> GLOBAL = ImmutableSet.of(YangInstanceIdentifier.builder().build());
  43     private final BindingToNormalizedNodeCodec codec;
  44     private final DOMRpcProviderService domRpcRegistry;
  45
  46     public BindingDOMOperationProviderServiceAdapter(final DOMRpcProviderService domRpcRegistry,
  47             final BindingToNormalizedNodeCodec codec) {
  48         this.codec = codec;
  49         this.domRpcRegistry = domRpcRegistry;
  50     }
  51
  52     @Override
  53     public <S extends Rpc<?, ?>, T extends S> ObjectRegistration<T> registerRpcImplementation(final Class<S> type,
  54             final T implementation) {
  55         return register(type, implementation, GLOBAL);
  56     }
  57
  58     @Override
  59     public <S extends Rpc<?, ?>, T extends S> ObjectRegistration<T> registerRpcImplementation(final Class<S> type,
  60             final T implementation, final Set<InstanceIdentifier<?>> paths) {
  61         return register(type, implementation, toYangInstanceIdentifiers(paths));
  62     }
  63
  64     private <S extends Rpc<?, ?>, T extends S> ObjectRegistration<T> register(final Class<S> type,
  65             final T implementation, final Collection<YangInstanceIdentifier> rpcContextPaths) {
  66         final Map<SchemaPath, Method> rpcs = codec.getRPCMethodToSchemaPath(type).inverse();
  67
  68         final BindingDOMOperationImplementationAdapter adapter =
  69                 new BindingDOMOperationImplementationAdapter(codec.getCodecRegistry(), type, rpcs, implementation);
  70         final Set<DOMRpcIdentifier> domRpcs = createDomRpcIdentifiers(rpcs.keySet(), rpcContextPaths);
  71         final DOMRpcImplementationRegistration<?> domReg = domRpcRegistry.registerRpcImplementation(adapter, domRpcs);
  72         return new BindingDOMOperationAdapterRegistration<>(implementation, domReg);
  73     }
  74
  75     private static Set<DOMRpcIdentifier> createDomRpcIdentifiers(final Set<SchemaPath> rpcs,
  76             final Collection<YangInstanceIdentifier> paths) {
  77         final Set<DOMRpcIdentifier> ret = new HashSet<>();
  78         for (final YangInstanceIdentifier path : paths) {
  79             for (final SchemaPath rpc : rpcs) {
  80                 ret.add(DOMRpcIdentifier.create(rpc, path));
  81             }
  82         }
  83         return ret;
  84     }
  85
  86     private Collection<YangInstanceIdentifier> toYangInstanceIdentifiers(final Set<InstanceIdentifier<?>> identifiers) {
  87         final Collection<YangInstanceIdentifier> ret = new ArrayList<>(identifiers.size());
  88         for (final InstanceIdentifier<?> binding : identifiers) {
  89             ret.add(codec.toYangInstanceIdentifierCached(binding));
  90         }
  91         return ret;
  92     }
  93
  94     @Override
  95     public <S extends Action<? extends TreeNode, ?, ?, ?>, T extends S, P extends TreeNode> ObjectRegistration<T>
  96             registerActionImplementation(final Class<S> type, final InstanceIdentifier<P> parent,
  97                     final T implementation) {
  98      // TODO implement after improve DOM part of MD-SAL for support of Yang 1.1
  99         throw new UnsupportedOperationException();
 100     }
 101
 102     @Override
 103     public <S extends ListAction<? extends TreeNode, ?, ?, ?>, T extends S, P extends TreeNode, K extends Identifier>
 104             ObjectRegistration<T> registerListActionImplementation(final Class<S> type,
 105         final KeyedInstanceIdentifier<P, K> parent, final T implementation) {
 106      // TODO implement after improve DOM part of MD-SAL for support of Yang 1.1
 107         throw new UnsupportedOperationException();
 108     }
 109 }