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

   1 /*******************************************************************************
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk feature sdnr wt
   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 package org.onap.ccsdk.features.sdnr.wt.devicemanager.test.util;
  22
  23 import com.google.common.base.Optional;
  24 import com.google.common.util.concurrent.CheckedFuture;
  25 import java.util.concurrent.ExecutionException;
  26 import java.util.concurrent.Executor;
  27 import java.util.concurrent.TimeUnit;
  28 import java.util.concurrent.TimeoutException;
  29 import org.opendaylight.controller.md.sal.binding.api.NotificationService;
  30 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  31 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  32 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
  33 import org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.core.model.rev170320.NetworkElement;
  34 import org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.MicrowaveModelListener;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNode;
  36 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  37 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
  38 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  39 import org.opendaylight.yangtools.yang.binding.DataObject;
  40 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  41 import org.opendaylight.yangtools.yang.binding.NotificationListener;
  42
  43 /**
  44  * @author herbert
  45  *
  46  */
  47 @SuppressWarnings("deprecation")
  48 public class ReadOnlyTransactionMountpoint1211pMock implements ReadOnlyTransaction, NotificationService {
  49
  50     private final Model1211pObjectMock mock = new Model1211pObjectMock();
  51     private MicrowaveModelListener modelListener;
  52
  53     @Override
  54     public Object getIdentifier() {
  55         return null;
  56     }
  57
  58     public Model1211pObjectMock getMock() {
  59         return mock;
  60     }
  61
  62     @SuppressWarnings("unchecked")
  63     @Override
  64     public <T extends DataObject> CheckedFuture<Optional<T>, ReadFailedException> read(LogicalDatastoreType store,
  65             InstanceIdentifier<T> path) {
  66
  67         System.out.println("READ: " + path + " Store: " + store);
  68
  69         Optional<T> res1;
  70
  71         if (path.getTargetType().equals(Node.class)) {
  72             System.out.println("Deliver " + path.getTargetType());
  73             NetconfNode nNode = mock.getNetconfNode();
  74             NodeBuilder nodeBuilder = new NodeBuilder();
  75             nodeBuilder.addAugmentation(NetconfNode.class, nNode);
  76             Node node = nodeBuilder.build();
  77             res1 = (Optional<T>) Optional.of(node);
  78
  79         } else if (path.getTargetType().equals(NetworkElement.class)) {
  80             System.out.println("Deliver " + path.getTargetType());
  81             NetworkElement ne = mock.getNetworkElement();
  82             res1 = (Optional<T>) Optional.of(ne);
  83
  84         } else if (path.getTargetType().equals(
  85                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.pac.AirInterfaceCurrentProblems.class)) {
  86             // MwAirInterfacePac
  87             System.out.println("Deliver " + path.getTargetType());
  88             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
  89                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.current.problems.g.CurrentProblemListBuilder.class,
  90                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.pac.AirInterfaceCurrentProblemsBuilder.class));
  91
  92         } else if (path.getTargetType().equals(
  93                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblems.class)) {
  94             // MwAirInterfaceDiversityPac
  95             System.out.println("Deliver " + path.getTargetType());
  96             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
  97                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.diversity.current.problems.g.CurrentProblemListBuilder.class,
  98                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblemsBuilder.class));
  99
 100         } else if (path.getTargetType().equals(
 101                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.hybrid.mw.structure.pac.HybridMwStructureCurrentProblems.class)) {
 102             // MwHybridMwStructurePac
 103             System.out.println("Deliver " + path.getTargetType());
 104             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 105                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.hybrid.mw.structure.current.problems.g.CurrentProblemListBuilder.class,
 106                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.hybrid.mw.structure.pac.HybridMwStructureCurrentProblemsBuilder.class));
 107
 108         } else if (path.getTargetType().equals(
 109                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblems.class)) {
 110             // MwAirInterfaceDiversityPac
 111             System.out.println("Deliver " + path.getTargetType());
 112             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 113                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.diversity.current.problems.g.CurrentProblemListBuilder.class,
 114                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblemsBuilder.class));
 115
 116         } else if (path.getTargetType().equals(
 117                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.pure.ethernet.structure.pac.PureEthernetStructureCurrentProblems.class)) {
 118             // MwPureEthernetStructurePac
 119             System.out.println("Deliver " + path.getTargetType());
 120             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 121                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.pure.ethernet.structure.current.problems.g.CurrentProblemListBuilder.class,
 122                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.pure.ethernet.structure.pac.PureEthernetStructureCurrentProblemsBuilder.class));
 123
 124
 125         } else if (path.getTargetType().equals(
 126                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.ethernet.container.pac.EthernetContainerCurrentProblems.class)) {
 127             //EthernetContainerCurrentProblems
 128             System.out.println("Deliver " + path.getTargetType());
 129             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 130                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.ethernet.container.current.problems.g.CurrentProblemListBuilder.class,
 131                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.ethernet.container.pac.EthernetContainerCurrentProblemsBuilder.class));
 132
 133         } else if (path.getTargetType().equals(
 134                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.tdm.container.pac.TdmContainerCurrentProblems.class)) {
 135             // TdmContainerCurrentProblems
 136             System.out.println("Deliver " + path.getTargetType());
 137             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 138                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.tdm.container.current.problems.g.CurrentProblemListBuilder.class,
 139                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.tdm.container.pac.TdmContainerCurrentProblemsBuilder.class));
 140
 141         } else {
 142             System.err.println("Nothing to deliver for" + path.getTargetType());
 143             res1 = Optional.absent();
 144         }
 145
 146
 147         CheckedFuture<Optional<T>, ReadFailedException> res = new CheckedFuture<Optional<T>, ReadFailedException>() {
 148
 149             @Override
 150             public void addListener(Runnable arg0, Executor arg1) {}
 151
 152             @Override
 153             public boolean cancel(boolean mayInterruptIfRunning) {
 154                 return false;
 155             }
 156
 157             @Override
 158             public Optional<T> get() throws InterruptedException, ExecutionException {
 159                 return res1;
 160             }
 161
 162             @Override
 163             public Optional<T> get(long timeout, TimeUnit unit)
 164                     throws InterruptedException, ExecutionException, TimeoutException {
 165                 return null;
 166             }
 167
 168             @Override
 169             public boolean isCancelled() {
 170                 return false;
 171             }
 172
 173             @Override
 174             public boolean isDone() {
 175                 return false;
 176             }
 177
 178             @Override
 179             public Optional<T> checkedGet() throws ReadFailedException {
 180                 return res1;
 181             }
 182
 183             @Override
 184             public Optional<T> checkedGet(long arg0, TimeUnit arg1) throws TimeoutException, ReadFailedException {
 185                 return null;
 186             }
 187
 188         };
 189         return res;
 190
 191     }
 192
 193
 194     @Override
 195     public void close() {}
 196
 197     @Override
 198     public <T extends NotificationListener> ListenerRegistration<T> registerNotificationListener(T listener) {
 199         this.modelListener = (MicrowaveModelListener)listener;
 200         return null;
 201     }
 202
 203
 204     public void sendProblemNotification() {
 205         System.out.println("Send out Problemnotification");
 206         modelListener.onProblemNotification(mock.getProblemNotification());
 207     }
 208
 209 }