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.util.concurrent.FluentFuture;
  24 import java.util.Optional;
  25 import org.eclipse.jdt.annotation.NonNull;
  26 import org.opendaylight.mdsal.binding.api.NotificationService;
  27 import org.opendaylight.mdsal.binding.api.ReadTransaction;
  28 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  29 import org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.core.model.rev170320.NetworkElement;
  30 import org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.MicrowaveModelListener;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.NetconfNode;
  32 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  33 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
  34 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  35 import org.opendaylight.yangtools.yang.binding.DataObject;
  36 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  37 import org.opendaylight.yangtools.yang.binding.NotificationListener;
  38
  39 /**
  40  * @author herbert
  41  *
  42  */
  43 @SuppressWarnings("deprecation")
  44 public class ReadOnlyTransactionMountpoint1211pMock implements ReadTransaction, NotificationService {
  45
  46     private final Model1211pObjectMock mock = new Model1211pObjectMock();
  47     private MicrowaveModelListener modelListener;
  48
  49     @Override
  50     public Object getIdentifier() {
  51         return null;
  52     }
  53
  54     public Model1211pObjectMock getMock() {
  55         return mock;
  56     }
  57
  58     @SuppressWarnings("unchecked")
  59
  60     @Override
  61     public <T extends DataObject> @NonNull FluentFuture<java.util.Optional<T>> read(@NonNull LogicalDatastoreType store,
  62             @NonNull InstanceIdentifier<T> path) {
  63
  64         System.out.println("READ: " + path + " Store: " + store);
  65
  66         Optional<T> res1;
  67
  68         if (path.getTargetType().equals(Node.class)) {
  69             System.out.println("Deliver " + path.getTargetType());
  70             NetconfNode nNode = mock.getNetconfNode();
  71             NodeBuilder nodeBuilder = new NodeBuilder();
  72             nodeBuilder.addAugmentation(NetconfNode.class, nNode);
  73             Node node = nodeBuilder.build();
  74             res1 = (Optional<T>) Optional.of(node);
  75
  76         } else if (path.getTargetType().equals(NetworkElement.class)) {
  77             System.out.println("Deliver " + path.getTargetType());
  78             NetworkElement ne = mock.getNetworkElement();
  79             res1 = (Optional<T>) Optional.of(ne);
  80
  81         } else if (path.getTargetType().equals(
  82                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.pac.AirInterfaceCurrentProblems.class)) {
  83             // MwAirInterfacePac
  84             System.out.println("Deliver " + path.getTargetType());
  85             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
  86                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.current.problems.g.CurrentProblemListBuilder.class,
  87                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.pac.AirInterfaceCurrentProblemsBuilder.class));
  88
  89         } else if (path.getTargetType().equals(
  90                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblems.class)) {
  91             // MwAirInterfaceDiversityPac
  92             System.out.println("Deliver " + path.getTargetType());
  93             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
  94                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.diversity.current.problems.g.CurrentProblemListBuilder.class,
  95                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblemsBuilder.class));
  96
  97         } else if (path.getTargetType().equals(
  98                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.hybrid.mw.structure.pac.HybridMwStructureCurrentProblems.class)) {
  99             // MwHybridMwStructurePac
 100             System.out.println("Deliver " + path.getTargetType());
 101             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 102                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.hybrid.mw.structure.current.problems.g.CurrentProblemListBuilder.class,
 103                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.hybrid.mw.structure.pac.HybridMwStructureCurrentProblemsBuilder.class));
 104
 105         } else if (path.getTargetType().equals(
 106                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblems.class)) {
 107             // MwAirInterfaceDiversityPac
 108             System.out.println("Deliver " + path.getTargetType());
 109             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 110                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.air._interface.diversity.current.problems.g.CurrentProblemListBuilder.class,
 111                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.air._interface.diversity.pac.AirInterfaceDiversityCurrentProblemsBuilder.class));
 112
 113         } else if (path.getTargetType().equals(
 114                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.pure.ethernet.structure.pac.PureEthernetStructureCurrentProblems.class)) {
 115             // MwPureEthernetStructurePac
 116             System.out.println("Deliver " + path.getTargetType());
 117             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 118                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.pure.ethernet.structure.current.problems.g.CurrentProblemListBuilder.class,
 119                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.pure.ethernet.structure.pac.PureEthernetStructureCurrentProblemsBuilder.class));
 120
 121
 122         } else if (path.getTargetType().equals(
 123                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.ethernet.container.pac.EthernetContainerCurrentProblems.class)) {
 124             //EthernetContainerCurrentProblems
 125             System.out.println("Deliver " + path.getTargetType());
 126             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 127                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.ethernet.container.current.problems.g.CurrentProblemListBuilder.class,
 128                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.ethernet.container.pac.EthernetContainerCurrentProblemsBuilder.class));
 129
 130         } else if (path.getTargetType().equals(
 131                 org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.tdm.container.pac.TdmContainerCurrentProblems.class)) {
 132             // TdmContainerCurrentProblems
 133             System.out.println("Deliver " + path.getTargetType());
 134             res1 = (Optional<T>) Optional.of(mock.getCurrentProblems(
 135                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.tdm.container.current.problems.g.CurrentProblemListBuilder.class,
 136                     org.opendaylight.yang.gen.v1.urn.onf.params.xml.ns.yang.microwave.model.rev181010.mw.tdm.container.pac.TdmContainerCurrentProblemsBuilder.class));
 137
 138         } else {
 139             System.err.println("Nothing to deliver for" + path.getTargetType());
 140             res1 = Optional.empty();
 141         }
 142
 143         FluentFuture<Optional<T>> res = FluentFuture.from(com.google.common.util.concurrent.Futures.immediateFuture(res1));
 144         return res;
 145
 146     }
 147
 148
 149     @Override
 150     public void close() {}
 151
 152     @Override
 153     public <T extends NotificationListener> ListenerRegistration<T> registerNotificationListener(T listener) {
 154         this.modelListener = (MicrowaveModelListener)listener;
 155         return null;
 156     }
 157
 158
 159     public void sendProblemNotification() {
 160         System.out.println("Send out Problemnotification");
 161         modelListener.onProblemNotification(mock.getProblemNotification());
 162     }
 163
 164 }