#1109 fix chunking of custom objects (#1113)

Author: lojzatran

src/main/java/com/commercetools/sync/services/impl/CustomObjectServiceImpl.java

@@ -70,8 +70,7 @@ public CompletionStage<Optional<String>> fetchCachedCustomObjectId(
   @Override
   public CompletionStage<Set<CustomObject>> fetchMatchingCustomObjects(
       @Nonnull final Set<CustomObjectCompositeIdentifier> identifiers) {
-    return super.fetchMatchingResources(
-        getKeys(identifiers), this::keyMapper, (keysNotCached) -> createQuery(identifiers));
+    return super.fetchMatchingResources(getKeys(identifiers), this::keyMapper, this::createQuery);
   }
 
   @Nonnull
@@ -142,8 +141,10 @@ CompletionStage<Optional<CustomObject>> executeCreateCommand(
   }
 
   @Nonnull
-  private ByProjectKeyCustomObjectsGet createQuery(
-      @Nonnull final Set<CustomObjectCompositeIdentifier> identifiers) {
+  private ByProjectKeyCustomObjectsGet createQuery(@Nonnull final Set<String> keys) {
+    final Set<CustomObjectCompositeIdentifier> identifiers =
+        keys.stream().map(CustomObjectCompositeIdentifier::of).collect(Collectors.toSet());
+
     final String whereQuery =
         identifiers.stream()
             .map(

src/test/java/com/commercetools/sync/services/impl/CustomObjectServiceImplTest.java

@@ -40,6 +40,7 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.mockito.ArgumentCaptor;
 
 @SuppressWarnings("unchecked")
 class CustomObjectServiceImplTest {
@@ -234,6 +235,55 @@ void fetchCustomObject_WithKeyAndContainer_ShouldFetchCustomObject() {
     verify(byProjectKeyCustomObjectsByContainerByKeyGet).execute();
   }
 
+  @Test
+  void fetchMatchingCustomObjects_WithManyCustomObjects_ShouldChunkAndFetchCustomObjects() {
+    final ArgumentCaptor<String> requestArgumentCaptor = ArgumentCaptor.forClass(String.class);
+    final Set<CustomObjectCompositeIdentifier> customObjectCompositeIdentifiers = new HashSet<>();
+    for (int i = 0; i < 500; i++) {
+      final String key = RandomStringUtils.random(15, true, true);
+      final String container = RandomStringUtils.random(15, true, true);
+      customObjectCompositeIdentifiers.add(CustomObjectCompositeIdentifier.of(key, container));
+    }
+
+    final ByProjectKeyCustomObjectsGet byProjectKeyCustomObjectsGet =
+        mock(ByProjectKeyCustomObjectsGet.class);
+
+    when(client.customObjects()).thenReturn(mock(ByProjectKeyCustomObjectsRequestBuilder.class));
+    when(client.customObjects().get()).thenReturn(byProjectKeyCustomObjectsGet);
+    when(byProjectKeyCustomObjectsGet.withWhere(anyString()))
+        .thenReturn(byProjectKeyCustomObjectsGet);
+    when(byProjectKeyCustomObjectsGet.withPredicateVar(anyString(), anyString()))
+        .thenReturn(byProjectKeyCustomObjectsGet, byProjectKeyCustomObjectsGet);
+    when(byProjectKeyCustomObjectsGet.withLimit(anyInt())).thenReturn(byProjectKeyCustomObjectsGet);
+    when(byProjectKeyCustomObjectsGet.withWithTotal(anyBoolean()))
+        .thenReturn(byProjectKeyCustomObjectsGet);
+    when(byProjectKeyCustomObjectsGet.withSort(anyString()))
+        .thenReturn(byProjectKeyCustomObjectsGet);
+    when(byProjectKeyCustomObjectsGet.withSort(anyString()))
+        .thenReturn(byProjectKeyCustomObjectsGet);
+
+    final ApiHttpResponse<CustomObjectPagedQueryResponse> apiHttpResponse =
+        mock(ApiHttpResponse.class);
+    final CustomObjectPagedQueryResponse customObjectPagedQueryResponse =
+        mock(CustomObjectPagedQueryResponse.class);
+    when(byProjectKeyCustomObjectsGet.execute())
+        .thenReturn(CompletableFuture.completedFuture(apiHttpResponse));
+    when(apiHttpResponse.getBody()).thenReturn(customObjectPagedQueryResponse);
+    when(customObjectPagedQueryResponse.getResults()).thenReturn(Collections.emptyList());
+
+    // test
+    service
+        .fetchMatchingCustomObjects(customObjectCompositeIdentifiers)
+        .toCompletableFuture()
+        .join();
+
+    // assertions
+    verify(byProjectKeyCustomObjectsGet, times(2)).execute();
+    verify(byProjectKeyCustomObjectsGet, times(2)).withWhere(requestArgumentCaptor.capture());
+    assertThat(requestArgumentCaptor.getAllValues().get(0))
+        .isNotEqualTo(requestArgumentCaptor.getAllValues().get(1));
+  }
+
   @Test
   void createCustomObject_WithDraft_ShouldCreateCustomObject() {
     final CustomObject mock = mock(CustomObject.class);