Merge "Removed unused fields"

[openflowplugin.git] / openflowplugin-impl / src / test / java / org / opendaylight / openflowplugin / impl / services / SalMeterServiceImplTest.java

diff --git a/openflowplugin-impl/src/test/java/org/opendaylight/openflowplugin/impl/services/SalMeterServiceImplTest.java b/openflowplugin-impl/src/test/java/org/opendaylight/openflowplugin/impl/services/SalMeterServiceImplTest.java
index a0b0299e614a24dc3095350f6533e9b378204758..faf1d13f50d601d7c4a4b56606a96f916919a2f9 100644 (file)
--- a/openflowplugin-impl/src/test/java/org/opendaylight/openflowplugin/impl/services/SalMeterServiceImplTest.java
+++ b/openflowplugin-impl/src/test/java/org/opendaylight/openflowplugin/impl/services/SalMeterServiceImplTest.java
@@ -1,61 +1,131 @@
 package org.opendaylight.openflowplugin.impl.services;
 
-import junit.framework.TestCase;
+import static org.mockito.Matchers.eq;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.ListenableFuture;
 import org.junit.Test;
+import org.mockito.Matchers;
 import org.mockito.Mock;
-import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
-import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
+import org.mockito.Mockito;
 import org.opendaylight.openflowplugin.api.openflow.registry.meter.DeviceMeterRegistry;
+import org.opendaylight.openflowplugin.api.openflow.rpc.listener.ItemLifecycleListener;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.meters.Meter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.meters.MeterKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.AddGroupOutput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.GroupKey;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.*;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.meter.update.OriginalMeter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.meter.update.OriginalMeterBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.meter.update.UpdatedMeter;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.service.rev130918.meter.update.UpdatedMeterBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.types.rev130918.MeterId;
-
-import static org.mockito.Matchers.any;
-import static org.mockito.Matchers.eq;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
+import org.opendaylight.yangtools.yang.common.RpcResult;
+import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
 
 public class SalMeterServiceImplTest extends ServiceMocking {
 
     private static final Long DUMMY_METER_ID = 15L;
-    public SalMeterService salMeterService;
+    private static final Long DUMMY_METTER_ID = 2000L;
 
     @Mock
     DeviceMeterRegistry mockedDeviceMeterRegistry;
 
+    SalMeterServiceImpl salMeterService;
+
     @Override
     public void initialization() {
         super.initialization();
-        salMeterService = new SalMeterServiceImpl(mockedRequestContextStack, mockedDeviceContext);
         when(mockedDeviceContext.getDeviceMeterRegistry()).thenReturn(mockedDeviceMeterRegistry);
+        salMeterService = new SalMeterServiceImpl(mockedRequestContextStack, mockedDeviceContext);
     }
 
     @Test
     public void testAddMeter() throws Exception {
+        addMeter(null);
+    }
+
+    @Test
+    public void testAddMeterWithItemLifecycle() throws Exception {
+        addMeter(mock(ItemLifecycleListener.class));
+    }
+
+    private void addMeter(final ItemLifecycleListener itemLifecycleListener) {
         final MeterId dummyMeterId = new MeterId(DUMMY_METER_ID);
         AddMeterInput addMeterInput = new AddMeterInputBuilder().setMeterId(dummyMeterId).build();
 
+        this.<AddMeterOutput>mockSuccessfulFuture();
+
+        salMeterService.setItemLifecycleListener(itemLifecycleListener);
+
         salMeterService.addMeter(addMeterInput);
         verify(mockedRequestContextStack).createRequestContext();
         verify(mockedDeviceMeterRegistry).store(eq(dummyMeterId));
+
+        if (itemLifecycleListener != null) {
+            verify(itemLifecycleListener).onAdded(Matchers.<KeyedInstanceIdentifier<Meter, MeterKey>>any(),Matchers.<Meter>any());
+        }
     }
 
     @Test
     public void testUpdateMeter() throws Exception {
-        UpdatedMeter mockedUptatedMeter = mock(UpdatedMeter.class);
-        final UpdateMeterInput updateMeterInput = new UpdateMeterInputBuilder().setUpdatedMeter(mockedUptatedMeter).build();
+        updateMeter(null);
+    }
+
+    @Test
+    public void testUpdateMeterWithItemLifecycle() throws Exception {
+        updateMeter(mock(ItemLifecycleListener.class));
+    }
+
+    private void updateMeter(final ItemLifecycleListener itemLifecycleListener) throws Exception {
+        final UpdatedMeter dummyUpdatedMeter = new UpdatedMeterBuilder().setMeterId(new MeterId(DUMMY_METTER_ID)).build();
+        final OriginalMeter dummyOriginalMeter = new OriginalMeterBuilder().setMeterId(new MeterId(DUMMY_METTER_ID)).build();
+
+        final UpdateMeterInput updateMeterInput = new UpdateMeterInputBuilder().setUpdatedMeter(dummyUpdatedMeter).setOriginalMeter(dummyOriginalMeter).build();
+
+        this.<AddMeterOutput>mockSuccessfulFuture();
+
+        salMeterService.setItemLifecycleListener(itemLifecycleListener);
+
         salMeterService.updateMeter(updateMeterInput);
         verify(mockedRequestContextStack).createRequestContext();
+
+        if (itemLifecycleListener != null) {
+            verify(itemLifecycleListener).onAdded(Matchers.<KeyedInstanceIdentifier<Meter, MeterKey>>any(),Matchers.<Meter>any());
+            verify(itemLifecycleListener).onRemoved(Matchers.<KeyedInstanceIdentifier<Meter, MeterKey>>any());
+        }
     }
 
     @Test
     public void testRemoveMeter() throws Exception {
+        removeMeter(null);
+    }
+
+    @Test
+    public void testRemoveMeterWithItemLifecycle() throws Exception {
+        removeMeter(mock(ItemLifecycleListener.class));
+    }
+
+    private void removeMeter(final ItemLifecycleListener itemLifecycleListener) throws Exception {
         final MeterId dummyMeterId = new MeterId(DUMMY_METER_ID);
         RemoveMeterInput removeMeterInput = new RemoveMeterInputBuilder().setMeterId(dummyMeterId).build();
 
+        this.<RemoveMeterOutput>mockSuccessfulFuture();
+
+        salMeterService.setItemLifecycleListener(itemLifecycleListener);
+
         salMeterService.removeMeter(removeMeterInput);
         verify(mockedRequestContextStack).createRequestContext();
         verify(mockedDeviceMeterRegistry).markToBeremoved(eq(dummyMeterId));
+
+        if (itemLifecycleListener != null) {
+            verify(itemLifecycleListener).onRemoved(Matchers.<KeyedInstanceIdentifier<Meter, MeterKey>>any());
+        }
     }
 }
\ No newline at end of file