BGPCEP-710: Create Network Topology Loader

[bgpcep.git] / config-loader / config-loader-impl / src / test / java / org / opendaylight / bgpcep / config / loader / impl / AbstractConfigLoader.java

diff --git a/config-loader/config-loader-impl/src/test/java/org/opendaylight/protocol/bgp/config/loader/impl/AbstractConfigLoader.java b/config-loader/config-loader-impl/src/test/java/org/opendaylight/bgpcep/config/loader/impl/AbstractConfigLoader.java
similarity index 68%
rename from config-loader/config-loader-impl/src/test/java/org/opendaylight/protocol/bgp/config/loader/impl/AbstractConfigLoader.java
rename to config-loader/config-loader-impl/src/test/java/org/opendaylight/bgpcep/config/loader/impl/AbstractConfigLoader.java
index 619b2d1b0175f5b874ed2e1f1cdda6c09b6f65c4..032e94a56a5b260dc1ff31cbe60ff5941f9ca81b 100644 (file)
--- a/config-loader/config-loader-impl/src/test/java/org/opendaylight/protocol/bgp/config/loader/impl/AbstractConfigLoader.java
+++ b/config-loader/config-loader-impl/src/test/java/org/opendaylight/bgpcep/config/loader/impl/AbstractConfigLoader.java
@@ -6,42 +6,37 @@
  * and is available at http://www.eclipse.org/legal/epl-v10.html
  */
 
-package org.opendaylight.protocol.bgp.config.loader.impl;
+package org.opendaylight.bgpcep.config.loader.impl;
 
 import static org.mockito.Matchers.any;
 import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.doReturn;
 
-import java.io.InputStream;
 import java.nio.file.WatchEvent;
 import java.nio.file.WatchKey;
 import java.nio.file.WatchService;
 import java.util.ArrayList;
-import java.util.Collections;
 import java.util.List;
 import javassist.ClassPool;
 import javax.annotation.concurrent.GuardedBy;
 import org.junit.After;
-import org.junit.Assert;
 import org.junit.Before;
 import org.mockito.Mock;
 import org.mockito.MockitoAnnotations;
+import org.opendaylight.bgpcep.config.loader.spi.ConfigFileProcessor;
+import org.opendaylight.controller.md.sal.binding.test.AbstractConcurrentDataBrokerTest;
 import org.opendaylight.mdsal.binding.dom.adapter.BindingToNormalizedNodeCodec;
 import org.opendaylight.mdsal.binding.dom.codec.gen.impl.StreamWriterGenerator;
 import org.opendaylight.mdsal.binding.dom.codec.impl.BindingNormalizedNodeCodecRegistry;
 import org.opendaylight.mdsal.binding.generator.impl.GeneratedClassLoadingStrategy;
 import org.opendaylight.mdsal.binding.generator.impl.ModuleInfoBackedContext;
 import org.opendaylight.mdsal.binding.generator.util.JavassistUtils;
-import org.opendaylight.protocol.bgp.config.loader.spi.ConfigFileProcessor;
-import org.opendaylight.protocol.bgp.config.loader.spi.ConfigLoader;
 import org.opendaylight.yangtools.yang.model.api.SchemaContext;
-import org.opendaylight.yangtools.yang.test.util.YangParserTestUtils;
 
-public abstract class AbstractConfigLoader {
+public abstract class AbstractConfigLoader extends AbstractConcurrentDataBrokerTest {
     @GuardedBy("this")
     private final List<WatchEvent<?>> eventList = new ArrayList<>();
-    protected BindingToNormalizedNodeCodec mappingService;
-    protected ConfigLoader configLoader;
+    protected ConfigLoaderImpl configLoader;
     @Mock
     protected WatchService watchService;
     @Mock
@@ -50,31 +45,35 @@ public abstract class AbstractConfigLoader {
     private WatchEvent<?> watchEvent;
     @Mock
     protected ConfigFileProcessor processor;
+    @Mock
+    private FileWatcher fileWatcher;
 
     @Before
     public void setUp() throws Exception {
         MockitoAnnotations.initMocks(this);
-        this.mappingService = new BindingToNormalizedNodeCodec(
+        final BindingToNormalizedNodeCodec mappingService = new BindingToNormalizedNodeCodec(
                 GeneratedClassLoadingStrategy.getTCCLClassLoadingStrategy(),
                 new BindingNormalizedNodeCodecRegistry(
                         StreamWriterGenerator.create(JavassistUtils.forClassPool(ClassPool.getDefault()))));
         final ModuleInfoBackedContext moduleInfoBackedContext = ModuleInfoBackedContext.create();
         registerModules(moduleInfoBackedContext);
-        this.mappingService.onGlobalContextUpdated(moduleInfoBackedContext.tryToCreateSchemaContext().get());
+        mappingService.onGlobalContextUpdated(moduleInfoBackedContext.tryToCreateSchemaContext().get());
         doAnswer(invocation -> true).when(this.watchKey).reset();
         doReturn(this.eventList).when(this.watchKey).pollEvents();
         doReturn(this.watchKey).when(this.watchService).take();
         doReturn("watchKey").when(this.watchKey).toString();
         doReturn("watchService").when(this.watchService).toString();
         doReturn("watchEvent").when(this.watchEvent).toString();
+        doReturn(getResourceFolder()).when(this.fileWatcher).getPathFile();
+        doReturn(this.watchService).when(this.fileWatcher).getWatchService();
         doAnswer(invocation -> {
             clearEvent();
             return null;
         }).when(this.processor).loadConfiguration(any());
-        final SchemaContext schemaContext = YangParserTestUtils.parseYangStreams(
-                getFilesAsStreams(getYangModelsPaths()));
+        final SchemaContext schemaContext = getSchemaContext();
         this.configLoader = new ConfigLoaderImpl(schemaContext,
-                this.mappingService, getResourceFolder(), this.watchService);
+                mappingService, this.fileWatcher);
+        this.configLoader.init();
     }
 
     private synchronized void clearEvent() {
@@ -87,28 +86,12 @@ public abstract class AbstractConfigLoader {
 
     protected abstract void registerModules(ModuleInfoBackedContext moduleInfoBackedContext) throws Exception;
 
-    protected abstract List<String> getYangModelsPaths();
-
-    private static List<InputStream> getFilesAsStreams(final List<String> paths) {
-        final List<InputStream> resources = new ArrayList<>();
-        final List<String> failedToFind = new ArrayList<>();
-        for (final String path : paths) {
-            final InputStream is = ConfigLoaderImplTest.class.getResourceAsStream(path);
-            if (is == null) {
-                failedToFind.add(path);
-            } else {
-                resources.add(is);
-            }
-        }
-        Assert.assertEquals("Some files were not found", Collections.emptyList(), failedToFind);
-        return resources;
-    }
-
     protected synchronized void triggerEvent(final String filename) {
         doReturn(filename).when(this.watchEvent).context();
         this.eventList.add(this.watchEvent);
     }
 
+
     @After
     public final void tearDown() throws Exception {
         ((ConfigLoaderImpl) this.configLoader).close();