fix problem with passing a dir that containts another dir for topolog…

…ies (#269)

src/main/java/com/purbon/kafka/topology/TopologyObjectBuilder.java

@@ -55,6 +55,7 @@ private static List<Topology> parseListOfTopologies(
     if (isDir) {
       Files.list(Paths.get(fileOrDir))
           .sorted()
+          .filter(p -> !Files.isDirectory(p))
           .map(path -> parser.deserialise(path.toFile()))
           .forEach(subTopology -> topologies.add(subTopology));
     } else {

src/test/java/com/purbon/kafka/topology/JulieOpsTest.java

@@ -212,4 +212,32 @@ public void buiderRunTest() throws Exception {
     verify(topicManager, times(1)).apply(anyObject(), anyObject());
     verify(accessControlManager, times(1)).apply(anyObject(), anyObject());
   }
+
+  @Test
+  public void builderRunTestAsFromDirectoryWithSchema() throws Exception {
+    String fileOrDirPath = TestUtils.getResourceFilename("/dir_with_subdir");
+
+    Configuration builderConfig = new Configuration(cliOps, props);
+
+    JulieOps builder =
+        JulieOps.build(
+            fileOrDirPath,
+            builderConfig,
+            topologyAdminClient,
+            accessControlProvider,
+            bindingsBuilderProvider);
+
+    builder.setTopicManager(topicManager);
+    builder.setAccessControlManager(accessControlManager);
+
+    doNothing().when(topicManager).apply(anyObject(), anyObject());
+
+    doNothing().when(accessControlManager).apply(anyObject(), anyObject());
+
+    builder.run();
+    builder.close();
+
+    verify(topicManager, times(1)).apply(anyObject(), anyObject());
+    verify(accessControlManager, times(1)).apply(anyObject(), anyObject());
+  }
 }

src/test/java/com/purbon/kafka/topology/integration/RBACPRoviderRbacIT.java

@@ -54,7 +54,6 @@
 import org.mockito.Mock;
 import org.mockito.Mockito;
 import org.mockito.runners.MockitoJUnitRunner;
-import org.testcontainers.shaded.com.google.common.eventbus.AllowConcurrentEvents;
 
 @RunWith(MockitoJUnitRunner.class)
 public class RBACPRoviderRbacIT extends MDSBaseTest {

src/test/resources/dir_with_subdir/descriptor-with-others.yml

@@ -0,0 +1,55 @@
+---
+context: "contextOrg"
+source: "source"
+foo: "foo"
+bar: "bar"
+zet: "zet"
+projects:
+  - name: "foo"
+    zookeepers: []
+    consumers:
+      - principal: "User:App0"
+      - principal: "User:App1"
+    producers: []
+    streams:
+      - principal: "User:App0"
+        topics:
+          read:
+            - "topicA"
+            - "topicB"
+          write:
+            - "topicC"
+            - "topicD"
+    connectors:
+      - principal: "User:Connect1"
+        topics:
+          read:
+            - "topicA"
+            - "topicB"
+      - principal: "User:Connect2"
+        topics:
+          write:
+            - "topicC"
+            - "topicD"
+    topics:
+      - name: "foo"
+        config:
+          replication.factor: "1"
+          num.partitions: "1"
+      - dataType: "avro"
+        name: "bar"
+        config:
+          replication.factor: "1"
+          num.partitions: "1"
+  - name: "bar"
+    zookeepers: []
+    consumers: []
+    producers: []
+    streams: []
+    connectors: []
+    topics:
+      - dataType: "avro"
+        name: "bar"
+        config:
+          replication.factor: "1"
+          num.partitions: "1"

src/test/resources/dir_with_subdir/descriptor.yaml

@@ -0,0 +1,61 @@
+---
+context: "contextOrg"
+source: "source"
+projects:
+  - name: "foo"
+    zookeepers: []
+    consumers:
+      - principal: "User:App0"
+      - principal: "User:App1"
+    producers: []
+    streams:
+      - principal: "User:App0"
+        topics:
+          read:
+            - "topicA"
+            - "topicB"
+          write:
+            - "topicC"
+            - "topicD"
+    connectors:
+      - principal: "User:Connect1"
+        topics:
+          read:
+            - "topicA"
+            - "topicB"
+      - principal: "User:Connect2"
+        topics:
+          write:
+            - "topicC"
+            - "topicD"
+    topics:
+      - name: "foo"
+        config:
+          replication.factor: "1"
+          num.partitions: "1"
+      - dataType: "avro"
+        name: "bar"
+        config:
+          replication.factor: "1"
+          num.partitions: "1"
+  - name: "bar"
+    zookeepers: []
+    consumers: []
+    producers: []
+    streams: []
+    connectors: []
+    topics:
+      - dataType: "avro"
+        name: "bar"
+        config:
+          replication.factor: "1"
+          num.partitions: "1"
+platform:
+  schema_registry:
+    instances:
+      - principal: "User:SchemaRegistry01"
+      - principal: "User:SchemaRegistry02"
+  control_center:
+    instances:
+      - principal: "User:ControlCenter"
+        appId: "controlcenter"

src/test/resources/dir_with_subdir/schemas/bar-key.avsc

@@ -0,0 +1 @@
+{"type": "string"}

src/test/resources/dir_with_subdir/schemas/bar-value.avsc

@@ -0,0 +1 @@
+{"type": "string"}