[sling-org-apache-sling-testing-clients] branch master updated: SLING-8710: IndexingClient should have configurable lanes

[dulvac]

This is an automated email from the ASF dual-hosted git repository.

dulvac pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/sling-org-apache-sling-testing-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 2dfaecd  SLING-8710: IndexingClient should have configurable lanes
2dfaecd is described below

commit 2dfaecd95e58c87385d8f26d1e8c60072990e54f
Author: Vikas Saurabh <vsaur...@adobe.com>
AuthorDate: Tue Sep 17 20:28:50 2019 +0530

    SLING-8710: IndexingClient should have configurable lanes
    
    Was storing lane names incorrectly which got missed in the test case
    because test lanes names was incorrectly set to an array of single
    string with comma in the string while it should have been an array of
    two separate strings.
---
 .../sling/testing/clients/indexing/IndexingClient.java      |  2 +-
 .../sling/testing/clients/indexing/IndexingClientTest.java  | 13 ++++++++++++-
 2 files changed, 13 insertions(+), 2 deletions(-)

diff --git 
a/src/main/java/org/apache/sling/testing/clients/indexing/IndexingClient.java 
b/src/main/java/org/apache/sling/testing/clients/indexing/IndexingClient.java
index 2bbea26..1af1e4a 100644
--- 
a/src/main/java/org/apache/sling/testing/clients/indexing/IndexingClient.java
+++ 
b/src/main/java/org/apache/sling/testing/clients/indexing/IndexingClient.java
@@ -182,7 +182,7 @@ public class IndexingClient extends SlingClient {
      * @param laneNames lane names to work on
      */
     public void setLaneNames(String ... laneNames) {
-        getValues().put(INDEX_LANES_CSV_CONFIG_NAME, 
StringUtils.join(laneNames));
+        getValues().put(INDEX_LANES_CSV_CONFIG_NAME, 
StringUtils.join(laneNames, ','));
     }
 
     /**
diff --git 
a/src/test/java/org/apache/sling/testing/clients/indexing/IndexingClientTest.java
 
b/src/test/java/org/apache/sling/testing/clients/indexing/IndexingClientTest.java
index 6346afc..2bbae1d 100644
--- 
a/src/test/java/org/apache/sling/testing/clients/indexing/IndexingClientTest.java
+++ 
b/src/test/java/org/apache/sling/testing/clients/indexing/IndexingClientTest.java
@@ -27,6 +27,7 @@ import org.apache.http.protocol.HttpRequestHandler;
 import org.apache.sling.testing.clients.ClientException;
 import org.apache.sling.testing.clients.HttpServerRule;
 import org.apache.sling.testing.clients.query.servlet.QueryServlet;
+import org.hamcrest.CoreMatchers;
 import org.junit.Assert;
 import org.junit.ClassRule;
 import org.junit.Test;
@@ -46,7 +47,7 @@ public class IndexingClientTest {
     private static final String EXPLAIN_RESPONSE = "{\"plan\": \"random plan 
with testIndexingLane-async and testIndexingLane-fulltext-async\",\"time\": 1}";
     private static final String QUERY_RESPONSE = "{\"total\": 1234,\"time\": 
1}";
 
-    private static final String [] PRE_DEFINED_INDEXING_LANES = new 
String[]{"async, fulltext-async"};
+    private static final String [] PRE_DEFINED_INDEXING_LANES = new 
String[]{"async", "fulltext-async"};
 
     private static final AtomicInteger NUM_INDEXING_LANE_CONSOLE_CALLS = new 
AtomicInteger();
 
@@ -210,9 +211,19 @@ public class IndexingClientTest {
     @Test
     public void testWaitForAsyncIndexingConfiguredLanes() throws 
ClientException, TimeoutException, InterruptedException {
         client.setLaneNames(PRE_DEFINED_INDEXING_LANES);
+
+        List<String> retrievedLaneNames = client.getLaneNames();
+        Assert.assertEquals("Mismatched number of lanes", 
PRE_DEFINED_INDEXING_LANES.length, retrievedLaneNames.size());
+        Assert.assertThat(retrievedLaneNames, 
CoreMatchers.hasItems(PRE_DEFINED_INDEXING_LANES));
+
         client.waitForAsyncIndexing();
 
         IndexingClient otherClient = client.adaptTo(IndexingClient.class);
+
+        retrievedLaneNames = otherClient.getLaneNames();
+        Assert.assertEquals("Mismatched number of lanes", 
PRE_DEFINED_INDEXING_LANES.length, retrievedLaneNames.size());
+        Assert.assertThat(retrievedLaneNames, 
CoreMatchers.hasItems(PRE_DEFINED_INDEXING_LANES));
+
         otherClient.waitForAsyncIndexing();
 
         Assert.assertEquals("Must not get indexing lanes from /system/console",