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
9 package org.opendaylight.ovsdb.southbound.ovsdb.transact;
11 import static org.junit.Assert.assertEquals;
12 import static org.junit.Assert.assertNotNull;
13 import static org.junit.Assert.assertTrue;
14 import static org.mockito.ArgumentMatchers.any;
15 import static org.mockito.Mockito.doReturn;
16 import static org.mockito.Mockito.mock;
17 import static org.mockito.Mockito.times;
18 import static org.mockito.Mockito.verify;
19 import static org.mockito.Mockito.when;
20 import static org.powermock.reflect.Whitebox.getField;
23 import java.util.Optional;
24 import org.junit.Before;
25 import org.junit.Test;
26 import org.junit.runner.RunWith;
27 import org.mockito.Mock;
28 import org.mockito.Mockito;
29 import org.mockito.junit.MockitoJUnitRunner;
30 import org.opendaylight.mdsal.binding.api.DataBroker;
31 import org.opendaylight.mdsal.binding.api.ReadTransaction;
32 import org.opendaylight.ovsdb.southbound.OvsdbOperGlobalListener;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ControllerEntry;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.bridge.attributes.ProtocolEntry;
37 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
38 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
39 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
40 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TpId;
41 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
42 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
43 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
44 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeBuilder;
45 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
46 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
47 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPointBuilder;
48 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
50 @RunWith(MockitoJUnitRunner.class)
51 public class BridgeOperationalStateTest {
52 private final Node nd = new NodeBuilder().setNodeId(new NodeId("foo")).build();
53 private final InstanceIdentifier<?> iid = InstanceIdentifier.create(Topology.class);
55 private final InstanceIdentifier<Node> nodeIid = InstanceIdentifier.create(NetworkTopology.class)
56 .child(Topology.class).child(Node.class);
57 private final Node brNode = new NodeBuilder().build();
59 @Mock private BridgeOperationalState briOperationState;
60 @Mock private DataBroker db;
61 @Mock ReadTransaction mockReadTx;
62 private InstanceIdentifier<ProtocolEntry> protocolEntry;
63 private InstanceIdentifier<Node> iidNode;
64 private Map<InstanceIdentifier<Node>, Node> operationalNodes;
67 public void setUp() throws Exception {
68 iidNode = InstanceIdentifier.create(NetworkTopology.class)
69 .child(Topology.class, new TopologyKey(new TopologyId("foo")))
70 .child(Node.class, new NodeKey(nd.getNodeId()));
71 protocolEntry = InstanceIdentifier.create(NetworkTopology.class).child(Topology.class).child(Node.class)
72 .augmentation(OvsdbBridgeAugmentation.class).child(ProtocolEntry.class);
74 briOperationState = mock(BridgeOperationalState.class, Mockito.CALLS_REAL_METHODS);
76 getField(BridgeOperationalState.class,"db").set(briOperationState, db);
77 doReturn(mockReadTx).when(db).newReadOnlyTransaction();
78 OvsdbOperGlobalListener.OPER_NODE_CACHE.put(nodeIid, brNode);
82 public void testGetBridgeNode() {
83 Optional<Node> optNodes = briOperationState.getBridgeNode(nodeIid);
84 assertEquals(brNode, optNodes.get());
88 public void testGetOvsdbBridgeAugmentation() throws Exception {
89 Optional<OvsdbBridgeAugmentation> optOvsdbBri = briOperationState.getOvsdbBridgeAugmentation(nodeIid);
90 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
91 assertNotNull(optOvsdbBri);
92 assertTrue(optOvsdbBri.equals(Optional.empty()));
94 Node node = mock(Node.class);
95 Optional<Node> optNode = Optional.of(node);
96 doReturn(optNode).when(briOperationState).getBridgeNode(any(InstanceIdentifier.class));
97 OvsdbBridgeAugmentation ovsdbBriAug = mock(OvsdbBridgeAugmentation.class);
98 doReturn(ovsdbBriAug).when(node).augmentation(OvsdbBridgeAugmentation.class);
99 Optional<OvsdbBridgeAugmentation> ovsdbBriAugOptional = briOperationState.getOvsdbBridgeAugmentation(iid);
100 assertNotNull(ovsdbBriAugOptional);
101 assertTrue(ovsdbBriAugOptional.get() instanceof OvsdbBridgeAugmentation);
105 public void testGetBridgeTerminationPoint() throws Exception {
106 Optional<TerminationPoint> optTerm = briOperationState.getBridgeTerminationPoint(nodeIid);
107 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
108 assertNotNull(optTerm);
109 assertTrue(optTerm.equals(Optional.empty()));
111 TerminationPoint termPnt = new TerminationPointBuilder().setTpId(new TpId("mockTp")).build();
113 Node node = mock(Node.class);
114 Optional<Node> optNode = Optional.of(node);
115 doReturn(optNode).when(briOperationState).getBridgeNode(any(InstanceIdentifier.class));
116 when(node.nonnullTerminationPoint()).thenCallRealMethod();
117 when(node.getTerminationPoint()).thenReturn(Map.of(termPnt.key(), termPnt));
119 Optional<TerminationPoint> optTermPnt = briOperationState.getBridgeTerminationPoint(
120 iidNode.child(TerminationPoint.class, termPnt.key()));
121 assertTrue(optTermPnt.isPresent());
125 public void testGetOvsdbTerminationPointAugmentation() {
126 Optional<OvsdbTerminationPointAugmentation> optOvsdbTermPoint = briOperationState
127 .getOvsdbTerminationPointAugmentation(nodeIid);
128 assertNotNull(optOvsdbTermPoint);
129 verify(briOperationState, times(1)).getBridgeTerminationPoint(any(InstanceIdentifier.class));
130 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
131 assertTrue(optOvsdbTermPoint.equals(Optional.empty()));
133 TerminationPoint termPoint = mock(TerminationPoint.class);
134 Optional<TerminationPoint> termPntOptional = Optional.of(termPoint);
135 doReturn(termPntOptional).when(briOperationState).getBridgeTerminationPoint(any(InstanceIdentifier.class));
136 OvsdbTerminationPointAugmentation ovsdbTermPntAug = mock(OvsdbTerminationPointAugmentation.class);
137 doReturn(ovsdbTermPntAug).when(termPoint).augmentation(OvsdbTerminationPointAugmentation.class);
138 Optional<OvsdbTerminationPointAugmentation> ovsdbTermPointOpt = briOperationState
139 .getOvsdbTerminationPointAugmentation(iid);
140 assertNotNull(ovsdbTermPointOpt);
141 assertTrue(ovsdbTermPointOpt.get() instanceof OvsdbTerminationPointAugmentation);
145 public void testGetControllerEntry() {
146 Optional<ControllerEntry> optController = briOperationState.getControllerEntry(nodeIid);
147 verify(briOperationState, times(1)).getOvsdbBridgeAugmentation(any(InstanceIdentifier.class));
148 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
149 assertNotNull(optController);
150 assertTrue(optController.equals(Optional.empty()));
154 public void testGetProtocolEntry() throws Exception {
155 Optional<ProtocolEntry> optProtocolEntry = briOperationState.getProtocolEntry(protocolEntry);
156 verify(briOperationState, times(1)).getOvsdbBridgeAugmentation(any(InstanceIdentifier.class));
157 verify(briOperationState, times(1)).getBridgeNode(any(InstanceIdentifier.class));
158 assertNotNull(optProtocolEntry);
159 assertTrue(optProtocolEntry.equals(Optional.empty()));