fix: assertion

Author: shortcuts

scripts/cts/testServer/replaceAllObjectsWithTransformation.ts

@@ -12,6 +12,7 @@ const raowtState: Record<
     copyCount: number;
     deleteCount: number;
     pushCount: number;
+    getEventCount: number;
     tmpIndexName: string;
     waitTaskCount: number;
     waitingForFinalWaitTask: boolean;
@@ -42,9 +43,10 @@ function addRoutes(app: Express): void {
       raowtState[lang] = {
         copyCount: 0,
         pushCount: 0,
+        getEventCount: 0,
         deleteCount: 1,
         waitTaskCount: 0,
-        tmpIndexName: req.body.destination,
+        tmpIndexName: req.params.indexName,
         waitingForFinalWaitTask: false,
         successful: false,
       };
@@ -69,6 +71,7 @@ function addRoutes(app: Express): void {
           raowtState[lang] = {
             copyCount: 1,
             pushCount: 0,
+            getEventCount: 0,
             deleteCount: 0,
             waitTaskCount: 0,
             tmpIndexName: req.body.destination,
@@ -89,6 +92,7 @@ function addRoutes(app: Express): void {
           copyCount: 2,
           pushCount: 10,
           deleteCount: 0,
+          getEventCount: 6,
           waitTaskCount: 2,
           tmpIndexName: req.params.indexName,
           waitingForFinalWaitTask: false,
@@ -121,18 +125,22 @@ function addRoutes(app: Express): void {
     raowtState[lang].pushCount += req.body.records.length;
 
     res.json({
-      runID: 'b1b7a982-524c-40d2-bb7f-48aab075abda',
+      runID: `b1b7a982-524c-40d2-bb7f-48aab075abda_${lang}`,
       eventID: `113b2068-6337-4c85-b5c2-e7b213d8292${raowtState[lang].pushCount}`,
       message: 'OK',
       createdAt: '2022-05-12T06:24:30.049Z',
     });
   });
 
   app.get('/1/runs/:runID/events/:eventID', (req, res) => {
+    const lang = req.params.runID.match(/^b1b7a982-524c-40d2-bb7f-48aab075abda_(.*)$/)?.[1] as string;
+
+    raowtState[lang].getEventCount++;
+
     res.json({
       status: 'succeeded',
-      eventID: '113b2068-6337-4c85-b5c2-e7b213d82921',
-      runID: 'b1b7a982-524c-40d2-bb7f-48aab075abda',
+      eventID: req.params.eventID,
+      runID: req.params.runID,
       type: 'fetch',
       batchSize: 1,
       publishedAt: '2022-05-12T06:24:30.049Z',
@@ -152,6 +160,7 @@ function addRoutes(app: Express): void {
       expect(raowtState[lang]).to.deep.equal({
         copyCount: 2,
         pushCount: 10,
+        getEventCount: 6,
         deleteCount: 0,
         waitTaskCount: 3,
         tmpIndexName: req.params.indexName,

templates/java/api_helpers.mustache

@@ -49,8 +49,10 @@ public <T> List<WatchResponse> chunkedPush(
     waitBatchSize = batchSize;
   }
 
-  for (T item : objects) {
-    if (records.size() == batchSize || !item.hasNext()) {
+  Iterator<T> it = objects.iterator();
+
+  while (true) {
+    if (records.size() == batchSize || !it.hasNext()) {
       WatchResponse watch =
         this.push(
             indexName,
@@ -63,9 +65,9 @@ public <T> List<WatchResponse> chunkedPush(
       records.clear();
     }
 
-    records.add(item);
+    records.add(it);
 
-    if (waitForTasks && (responses.size() % waitBatchSize == 0 || !item.hasNext())) {
+    if (waitForTasks && (responses.size() % waitBatchSize == 0 || !it.hasNext())) {
           responses.subList(Math.max(responses.size() - waitBatchSize, 0), responses.size()).forEach(response -> {
           TaskUtils.retryUntil(
             () -> {
@@ -88,6 +90,10 @@ public <T> List<WatchResponse> chunkedPush(
         }
       );
     }
+
+    if (!it.hasNext()) {
+      break;
+    }
   }
 
   return responses;

templates/php/api.mustache

@@ -356,7 +356,7 @@ use Algolia\AlgoliaSearch\Exceptions\NotFoundException;
             if ($waitForTasks && (0 === count($responses) % $waitBatchSize || $count === sizeof($objects) - 1)) {
                 $timeoutCalculation = 'Algolia\AlgoliaSearch\Support\Helpers::linearTimeout';
 
-                foreach (array_slice($responses, -waitBatchSize) as $response) {
+                foreach (array_slice($responses, -$waitBatchSize) as $response) {
                     $retry = 0;
 
                     while ($retry < 50) {

tests/CTS/client/search/replaceAllObjectsWithTransformation.json

@@ -74,25 +74,25 @@
             },
             "watchResponses": [
               {
-                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda",
+                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda_${{language}}",
                 "eventID": "113b2068-6337-4c85-b5c2-e7b213d82923",
                 "message": "OK",
                 "createdAt": "2022-05-12T06:24:30.049Z"
               },
               {
-                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda",
+                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda_${{language}}",
                 "eventID": "113b2068-6337-4c85-b5c2-e7b213d82926",
                 "message": "OK",
                 "createdAt": "2022-05-12T06:24:30.049Z"
               },
               {
-                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda",
+                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda_${{language}}",
                 "eventID": "113b2068-6337-4c85-b5c2-e7b213d82929",
                 "message": "OK",
                 "createdAt": "2022-05-12T06:24:30.049Z"
               },
               {
-                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda",
+                "runID": "b1b7a982-524c-40d2-bb7f-48aab075abda_${{language}}",
                 "eventID": "113b2068-6337-4c85-b5c2-e7b213d829210",
                 "message": "OK",
                 "createdAt": "2022-05-12T06:24:30.049Z"