chore: fix CouchbaseSettings.setUp()

Signed-off-by: Maximillian Arruda <[email protected]>

Author: dearrudam

jnosql-couchbase/src/main/java/org/eclipse/jnosql/databases/couchbase/communication/CouchbaseSettings.java

@@ -31,6 +31,7 @@
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 import static com.couchbase.client.java.manager.query.CreatePrimaryQueryIndexOptions.createPrimaryQueryIndexOptions;
 import static com.couchbase.client.java.manager.query.GetAllQueryIndexesOptions.getAllQueryIndexesOptions;
@@ -157,7 +158,7 @@ public void setUp(String database) {
 
         Objects.requireNonNull(database, "database is required");
 
-        CouchbaseSettings settings=this;
+        CouchbaseSettings settings = this;
 
         var collections = settings.getCollections().stream().map(String::trim)
                 .filter(index -> !index.isBlank()).toList();
@@ -170,15 +171,15 @@ public void setUp(String database) {
         var scope = settings.getScope();
 
         long start = System.currentTimeMillis();
-        LOGGER.log(Level.FINEST,"starting the setup with database: " + database);
+        LOGGER.log(Level.FINEST, "starting the setup with database: " + database);
 
         try (Cluster cluster = settings.getCluster()) {
 
             BucketManager buckets = cluster.buckets();
             try {
                 buckets.getBucket(database);
             } catch (BucketNotFoundException exp) {
-                LOGGER.log(Level.FINEST,"The database/bucket does not exist, creating it: " + database);
+                LOGGER.log(Level.FINEST, "The database/bucket does not exist, creating it: " + database);
                 buckets.createBucket(BucketSettings.create(database));
             }
 
@@ -193,7 +194,7 @@ public void setUp(String database) {
             ScopeSpec spec = scopes.stream().filter(s -> finalScope.equals(s.name()))
                     .findFirst().get();
 
-            collectionsToIndex.forEach(collection -> {
+            collections.forEach(collection -> {
                 if (spec.collections().stream().noneMatch(c -> collectionsToIndex.contains(c.name()))) {
                     manager.createCollection(CollectionSpec.create(collection, finalScope));
                 }
@@ -202,23 +203,26 @@ public void setUp(String database) {
             waitUntilReady(bucket);
 
             if (!collectionsToIndex.isEmpty()) {
+
                 QueryIndexManager queryIndexManager = cluster.queryIndexes();
-                collections.stream()
-                        .filter(collectionsToIndex::contains)
+
+                Stream.concat(collectionsToIndex.stream(), collectionsToIndex.stream())
+                        .distinct()
                         .forEach(collection -> {
                             var allIndexes = queryIndexManager.getAllIndexes(database, getAllQueryIndexesOptions()
                                     .scopeName(finalScope).collectionName(collection));
                             if (allIndexes.isEmpty()) {
-                                LOGGER.log(Level.FINEST,"Index for " + collection + " collection does not exist, creating primary key with scope "
+                                LOGGER.log(Level.FINEST, "Index for " + collection + " collection does not exist, creating primary key with scope "
                                         + finalScope + " collection " + collection + " at database " + database);
                                 queryIndexManager.createPrimaryIndex(database, createPrimaryQueryIndexOptions()
                                         .scopeName(finalScope).collectionName(collection));
                             }
                         });
+
             }
 
             long end = System.currentTimeMillis() - start;
-            LOGGER.log(Level.FINEST,"Finished the setup with database: " + database + " end with millis "
+            LOGGER.log(Level.FINEST, "Finished the setup with database: " + database + " end with millis "
                     + end);
         }