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

   1 /*******************************************************************************
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk feature sdnr wt sdnr-wt-devicemanager-provider
   4  *  ================================================================================
   5  * Copyright (C) 2019 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.devicemanager.test.mock;
  23
  24 import com.google.common.base.Optional;
  25 import com.google.common.util.concurrent.CheckedFuture;
  26 import java.util.ArrayList;
  27 import java.util.List;
  28 import java.util.concurrent.ExecutionException;
  29 import java.util.concurrent.Executor;
  30 import java.util.concurrent.TimeUnit;
  31 import java.util.concurrent.TimeoutException;
  32 import org.onap.ccsdk.features.sdnr.wt.devicemanager.base.netconf.wrapperc.WrapperMicrowaveModelRev181010;
  33 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  34 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  35 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNode;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNodeBuilder;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNodeConnectionStatus.ConnectionStatus;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.AvailableCapabilitiesBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.available.capabilities.AvailableCapability;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.netconf.node.connection.status.available.capabilities.AvailableCapabilityBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  43 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
  44 import org.opendaylight.yangtools.yang.binding.DataObject;
  45 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  46
  47 /**
  48  * @author herbert
  49  *
  50  */
  51 @SuppressWarnings("deprecation")
  52 public class ReadOnlyTransactionMock implements ReadOnlyTransaction {
  53
  54
  55     @Override
  56     public Object getIdentifier() {
  57         return null;
  58     }
  59
  60     @Override
  61     public <T extends DataObject> CheckedFuture<Optional<T>, ReadFailedException> read(LogicalDatastoreType store,
  62             InstanceIdentifier<T> path) {
  63
  64         NetconfNodeBuilder netconfNodeBuilder = new NetconfNodeBuilder();
  65         netconfNodeBuilder.setConnectionStatus(ConnectionStatus.Connected);
  66         netconfNodeBuilder.setAvailableCapabilities(getCababilitiesList(WrapperMicrowaveModelRev181010.QNAME.toString()).build());
  67         NetconfNode nnode = netconfNodeBuilder.build();
  68         NodeBuilder nodeBuilder = new NodeBuilder();
  69         nodeBuilder.addAugmentation(NetconfNode.class, nnode);
  70         Node node = nodeBuilder.build();
  71         @SuppressWarnings("unchecked")
  72         Optional<T> res1 = (Optional<T>) Optional.of(node);
  73         CheckedFuture<Optional<T>, ReadFailedException> res = new CheckedFuture<Optional<T>, ReadFailedException>() {
  74
  75             @Override
  76             public void addListener(Runnable arg0, Executor arg1) {
  77             }
  78
  79             @Override
  80             public boolean cancel(boolean mayInterruptIfRunning) {
  81                 return false;
  82             }
  83
  84             @Override
  85             public Optional<T> get() throws InterruptedException, ExecutionException {
  86                 return null;
  87             }
  88
  89             @Override
  90             public Optional<T> get(long timeout, TimeUnit unit)
  91                     throws InterruptedException, ExecutionException, TimeoutException {
  92                 return null;
  93             }
  94
  95             @Override
  96             public boolean isCancelled() {
  97                 return false;
  98             }
  99
 100             @Override
 101             public boolean isDone() {
 102                 return false;
 103             }
 104
 105             @Override
 106             public Optional<T> checkedGet() throws ReadFailedException {
 107                 return res1;
 108             }
 109
 110             @Override
 111             public Optional<T> checkedGet(long arg0, TimeUnit arg1) throws TimeoutException, ReadFailedException {
 112                 return null;
 113             }
 114
 115         };
 116
 117
 118         return res;
 119     }
 120
 121     private AvailableCapabilitiesBuilder getCababilitiesList(String ... strings) {
 122         return getCababilitiesList(null, strings);
 123     }
 124
 125     private AvailableCapabilitiesBuilder getCababilitiesList(AvailableCapabilitiesBuilder valueBuilder, String ... strings) {
 126         if (valueBuilder == null) {
 127             valueBuilder = new AvailableCapabilitiesBuilder();
 128         }
 129         List<AvailableCapability> capabilites = new ArrayList<>();
 130         for (String s : strings) {
 131             AvailableCapabilityBuilder capabilityBuilder = new AvailableCapabilityBuilder();
 132             capabilityBuilder.setCapability(s);
 133             capabilites.add(capabilityBuilder.build());
 134         }
 135         valueBuilder.setAvailableCapability(capabilites);
 136         return valueBuilder;
 137     }
 138
 139     @Override
 140     public void close() {
 141     }
 142
 143 }