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