Added: AATesting

algoliasearch-common/src/main/java/com/algolia/search/inputs/analytics/Variant.java

@@ -1,5 +1,6 @@
 package com.algolia.search.inputs.analytics;
 
+import com.algolia.search.objects.Query;
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
@@ -23,6 +24,7 @@ public class Variant implements Serializable {
   private int noResultCount;
   private int searchCount;
   private int userCount;
+  private Query customSearchParameters;
 
   public Variant() {}
 
@@ -135,4 +137,14 @@ public int getUserCount() {
   public void setUserCount(int userCount) {
     this.userCount = userCount;
   }
+
+  @JsonProperty
+  public Query getCustomSearchParameters() {
+    return customSearchParameters;
+  }
+
+  @JsonProperty
+  public void setCustomSearchParameters(Query customSearchParameters) {
+    this.customSearchParameters = customSearchParameters;
+  }
 }

algoliasearch-tests/src/test/java/com/algolia/search/integration/common/async/AsyncABTestingTest.java

@@ -9,6 +9,8 @@
 import com.algolia.search.inputs.analytics.ABTest;
 import com.algolia.search.inputs.analytics.Variant;
 import com.algolia.search.integration.common.ABTestingHelpersTest;
+import com.algolia.search.objects.IgnorePlurals;
+import com.algolia.search.objects.Query;
 import com.algolia.search.objects.tasks.async.AsyncTaskABTest;
 import com.algolia.search.responses.ABTests;
 import java.time.LocalDateTime;
@@ -64,7 +66,7 @@ public void createModifyAndDeleteABTests() throws Exception {
 
     waitForCompletion(analytics.addABTest(abtest));
 
-    Boolean found = false;
+    boolean found = false;
     while (!found) {
       abTests = analytics.getABTests(0, 10).get();
       found =
@@ -83,4 +85,35 @@ public void createModifyAndDeleteABTests() throws Exception {
     abTests = analytics.getABTests(0, 10).get();
     assertThat(abTests.getCount()).isEqualTo(0);
   }
+
+  @Test
+  public void TestAATesting() throws Exception {
+    AsyncAnalytics analytics = createAnalytics();
+    AsyncIndex<AlgoliaObject> index = createIndex(AlgoliaObject.class);
+    waitForCompletion(index.addObject(new AlgoliaObject("algolia", 1)));
+
+    LocalDateTime now = LocalDateTime.now();
+
+    Variant variantWithSearchParam = new Variant(index.getName(), 10, null);
+    variantWithSearchParam.setCustomSearchParameters(
+        new Query().setIgnorePlurals(IgnorePlurals.of(true)));
+
+    ABTest abtest =
+        new ABTest(
+            "AA_Testing",
+            Arrays.asList(
+                new Variant(index.getName(), 90, "a description"), variantWithSearchParam),
+            now.plus(1, ChronoUnit.DAYS));
+
+    AsyncTaskABTest abTestTask = analytics.addABTest(abtest).get();
+
+    index.waitTask(abTestTask.getTaskID());
+
+    ABTest inserted = analytics.getABTest(abTestTask.abTestID).get();
+
+    ABTestingHelpersTest.compareABTests(abtest, inserted);
+    assertThat(inserted.getVariants().get(1).getCustomSearchParameters().getIgnorePlurals())
+        .isEqualTo(variantWithSearchParam.getCustomSearchParameters().getIgnorePlurals());
+    waitForCompletion(analytics.deleteABTest(abTestTask.abTestID));
+  }
 }

algoliasearch-tests/src/test/java/com/algolia/search/integration/common/sync/SyncABTestingTest.java

@@ -10,6 +10,8 @@
 import com.algolia.search.inputs.analytics.ABTest;
 import com.algolia.search.inputs.analytics.Variant;
 import com.algolia.search.integration.common.ABTestingHelpersTest;
+import com.algolia.search.objects.IgnorePlurals;
+import com.algolia.search.objects.Query;
 import com.algolia.search.objects.tasks.sync.TaskABTest;
 import com.algolia.search.responses.ABTests;
 import java.time.LocalDateTime;
@@ -77,10 +79,41 @@ public void createModifyAndDeleteABTests() throws AlgoliaException, InterruptedE
     assertThat(inserted.getStatus()).isEqualTo("stopped");
 
     waitForCompletion(analytics.deleteABTest(inserted.getAbTestID()));
-    Boolean isEmpty = false;
+    boolean isEmpty = false;
     while (!isEmpty) {
       isEmpty = analytics.getABTests(0, 10).getCount() == 0;
       Thread.sleep(1000);
     }
   }
+
+  @Test
+  public void TestAATesting() throws Exception {
+    Analytics analytics = createAnalytics();
+    Index<AlgoliaObject> index = createIndex(AlgoliaObject.class);
+    waitForCompletion(index.addObject(new AlgoliaObject("algolia", 1)));
+
+    LocalDateTime now = LocalDateTime.now();
+
+    Variant variantWithSearchParam = new Variant(index.getName(), 10, null);
+    variantWithSearchParam.setCustomSearchParameters(
+        new Query().setIgnorePlurals(IgnorePlurals.of(true)));
+
+    ABTest abtest =
+        new ABTest(
+            "AA_Testing",
+            Arrays.asList(
+                new Variant(index.getName(), 90, "a description"), variantWithSearchParam),
+            now.plus(1, ChronoUnit.DAYS));
+
+    TaskABTest abTestTask = analytics.addABTest(abtest);
+
+    index.waitTask(abTestTask.getTaskID());
+
+    ABTest inserted = analytics.getABTest(abTestTask.abTestID);
+
+    ABTestingHelpersTest.compareABTests(abtest, inserted);
+    assertThat(inserted.getVariants().get(1).getCustomSearchParameters().getIgnorePlurals())
+        .isEqualTo(variantWithSearchParam.getCustomSearchParameters().getIgnorePlurals());
+    waitForCompletion(analytics.deleteABTest(abTestTask.abTestID));
+  }
 }