2 * Copyright (c) 2015 Inocybe Technologies. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.ovsdb.southbound.ovsdb.transact;
10 import static org.junit.Assert.assertEquals;
11 import static org.junit.Assert.assertNotNull;
12 import static org.junit.Assert.assertTrue;
13 import static org.mockito.ArgumentMatchers.any;
14 import static org.mockito.Mockito.doReturn;
15 import static org.mockito.Mockito.mock;
16 import static org.mockito.Mockito.times;
17 import static org.mockito.Mockito.verify;
18 import static org.mockito.Mockito.when;
19 import static org.powermock.reflect.Whitebox.getField;
22 import java.util.Optional;
23 import org.junit.Before;
24 import org.junit.Test;
25 import org.junit.runner.RunWith;
26 import org.mockito.Mock;
27 import org.mockito.Mockito;
28 import org.mockito.junit.MockitoJUnitRunner;
29 import org.opendaylight.mdsal.binding.api.DataBroker;
30 import org.opendaylight.mdsal.binding.api.ReadTransaction;
31 import org.opendaylight.ovsdb.southbound.OvsdbOperGlobalListener;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntry;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ProtocolEntry;
36 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
37 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
38 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
39 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TpId;
40 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
41 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
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.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
45 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
46 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointBuilder;
47 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
49 @RunWith(MockitoJUnitRunner.class)
50 public class BridgeOperationalStateTest {
51 private final Node nd = new NodeBuilder().setNodeId(new NodeId("foo")).build();
52 private final InstanceIdentifier<Node> nodeIid = InstanceIdentifier.create(NetworkTopology.class)
53 .child(Topology.class).child(Node.class);
54 private final Node brNode = new NodeBuilder().setNodeId(new NodeId("bar")).build();
56 @Mock private BridgeOperationalState briOperationState;
57 @Mock private DataBroker db;
58 @Mock ReadTransaction mockReadTx;
59 private InstanceIdentifier<ProtocolEntry> protocolEntry;
60 private InstanceIdentifier<Node> iidNode;
61 private Map<InstanceIdentifier<Node>, Node> operationalNodes;
64 public void setUp() throws Exception {
65 iidNode = InstanceIdentifier.create(NetworkTopology.class)
66 .child(Topology.class, new TopologyKey(new TopologyId("foo")))
67 .child(Node.class, new NodeKey(nd.getNodeId()));
68 protocolEntry = InstanceIdentifier.create(NetworkTopology.class).child(Topology.class).child(Node.class)
69 .augmentation(OvsdbBridgeAugmentation.class).child(ProtocolEntry.class);
71 briOperationState = mock(BridgeOperationalState.class, Mockito.CALLS_REAL_METHODS);
73 getField(BridgeOperationalState.class,"db").set(briOperationState, db);
74 doReturn(mockReadTx).when(db).newReadOnlyTransaction();
75 OvsdbOperGlobalListener.OPER_NODE_CACHE.put(nodeIid, brNode);
79 public void testGetBridgeNode() {
80 assertEquals(Optional.of(brNode), briOperationState.getBridgeNode(nodeIid));
84 public void testGetOvsdbBridgeAugmentation() throws Exception {
85 Optional<OvsdbBridgeAugmentation> optOvsdbBri = briOperationState.getOvsdbBridgeAugmentation(nodeIid);
86 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
87 assertNotNull(optOvsdbBri);
88 assertTrue(optOvsdbBri.equals(Optional.empty()));
90 Node node = mock(Node.class);
91 Optional<Node> optNode = Optional.of(node);
92 doReturn(optNode).when(briOperationState).getBridgeNode(any(InstanceIdentifier.class));
93 OvsdbBridgeAugmentation ovsdbBriAug = mock(OvsdbBridgeAugmentation.class);
94 doReturn(ovsdbBriAug).when(node).augmentation(OvsdbBridgeAugmentation.class);
95 Optional<OvsdbBridgeAugmentation> ovsdbBriAugOptional = briOperationState.getOvsdbBridgeAugmentation(
96 InstanceIdentifier.create(NetworkTopology.class));
97 assertNotNull(ovsdbBriAugOptional);
98 assertTrue(ovsdbBriAugOptional.orElseThrow() instanceof OvsdbBridgeAugmentation);
102 public void testGetBridgeTerminationPoint() throws Exception {
103 Optional<TerminationPoint> optTerm = briOperationState.getBridgeTerminationPoint(nodeIid);
104 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
105 assertNotNull(optTerm);
106 assertTrue(optTerm.equals(Optional.empty()));
108 TerminationPoint termPnt = new TerminationPointBuilder().setTpId(new TpId("mockTp")).build();
110 Node node = mock(Node.class);
111 Optional<Node> optNode = Optional.of(node);
112 doReturn(optNode).when(briOperationState).getBridgeNode(any(InstanceIdentifier.class));
113 when(node.nonnullTerminationPoint()).thenCallRealMethod();
114 when(node.getTerminationPoint()).thenReturn(Map.of(termPnt.key(), termPnt));
116 Optional<TerminationPoint> optTermPnt = briOperationState.getBridgeTerminationPoint(
117 iidNode.child(TerminationPoint.class, termPnt.key()));
118 assertTrue(optTermPnt.isPresent());
122 public void testGetOvsdbTerminationPointAugmentation() {
123 Optional<OvsdbTerminationPointAugmentation> optOvsdbTermPoint = briOperationState
124 .getOvsdbTerminationPointAugmentation(nodeIid);
125 assertNotNull(optOvsdbTermPoint);
126 verify(briOperationState, times(1)).getBridgeTerminationPoint(any(InstanceIdentifier.class));
127 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
128 assertTrue(optOvsdbTermPoint.equals(Optional.empty()));
130 TerminationPoint termPoint = mock(TerminationPoint.class);
131 Optional<TerminationPoint> termPntOptional = Optional.of(termPoint);
132 doReturn(termPntOptional).when(briOperationState).getBridgeTerminationPoint(any(InstanceIdentifier.class));
133 OvsdbTerminationPointAugmentation ovsdbTermPntAug = mock(OvsdbTerminationPointAugmentation.class);
134 doReturn(ovsdbTermPntAug).when(termPoint).augmentation(OvsdbTerminationPointAugmentation.class);
135 Optional<OvsdbTerminationPointAugmentation> ovsdbTermPointOpt = briOperationState
136 .getOvsdbTerminationPointAugmentation(InstanceIdentifier.create(NetworkTopology.class));
137 assertNotNull(ovsdbTermPointOpt);
138 assertTrue(ovsdbTermPointOpt.orElseThrow() instanceof OvsdbTerminationPointAugmentation);
142 public void testGetControllerEntry() {
143 Optional<ControllerEntry> optController = briOperationState.getControllerEntry(nodeIid);
144 verify(briOperationState, times(1)).getOvsdbBridgeAugmentation(any(InstanceIdentifier.class));
145 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
146 assertNotNull(optController);
147 assertTrue(optController.equals(Optional.empty()));
151 public void testGetProtocolEntry() throws Exception {
152 Optional<ProtocolEntry> optProtocolEntry = briOperationState.getProtocolEntry(protocolEntry);
153 verify(briOperationState, times(1)).getOvsdbBridgeAugmentation(any(InstanceIdentifier.class));
154 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
155 assertNotNull(optProtocolEntry);
156 assertTrue(optProtocolEntry.equals(Optional.empty()));