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