fix(javascript): allow async param on createIterablePromise (#4144)

Author: millotp

clients/algoliasearch-client-javascript/packages/algoliasearch/__tests__/tsconfig.json

@@ -0,0 +1,8 @@
+{
+  "extends": "../tsconfig.json",
+  "compilerOptions": {
+    "noEmit": true,
+    "skipLibCheck": true
+  },
+  "include": ["*.ts"]
+}

clients/algoliasearch-client-javascript/packages/client-common/package.json

@@ -30,7 +30,7 @@
   "scripts": {
     "build": "yarn clean && yarn tsup",
     "clean": "rm -rf ./dist || true",
-    "test": "vitest --run",
+    "test": "tsc --noEmit && vitest --run",
     "test:bundle": "publint . && attw --pack ."
   },
   "devDependencies": {

clients/algoliasearch-client-javascript/packages/client-common/src/__tests__/cache/browser-local-storage-cache.test.ts

@@ -91,7 +91,7 @@ describe('browser local storage cache', () => {
 
     await cache.clear();
 
-    const defaultValue = (): Promise<void> => Promise.resolve({ bar: 2 });
+    const defaultValue = (): Promise<{ bar: number }> => Promise.resolve({ bar: 2 });
 
     expect(localStorage.length).toBe(0);
 

clients/algoliasearch-client-javascript/packages/client-common/src/__tests__/create-iterable-promise.test.ts

@@ -53,6 +53,26 @@ describe('createIterablePromise', () => {
       await expect(promise).resolves.toEqual(3);
       expect(calls).toBe(3);
     });
+
+    test('allow async function', async () => {
+      createIterablePromise({
+        func: () => {
+          return Promise.resolve({
+            hits: [],
+            cursor: '',
+          });
+        },
+        validate: async () => {
+          return await Promise.resolve(true);
+        },
+        aggregator: async (res) => {
+          return await Promise.resolve(res);
+        },
+        timeout: async () => {
+          return await Promise.resolve(1000);
+        },
+      });
+    });
   });
 
   describe('aggregator', () => {

clients/algoliasearch-client-javascript/packages/client-common/src/createIterablePromise.ts

@@ -20,22 +20,25 @@ export function createIterablePromise<TResponse>({
   const retry = (previousResponse?: TResponse): Promise<TResponse> => {
     return new Promise<TResponse>((resolve, reject) => {
       func(previousResponse)
-        .then((response) => {
+        .then(async (response) => {
           if (aggregator) {
-            aggregator(response);
+            await aggregator(response);
           }
 
-          if (validate(response)) {
+          if (await validate(response)) {
             return resolve(response);
           }
 
-          if (error && error.validate(response)) {
-            return reject(new Error(error.message(response)));
+          if (error && (await error.validate(response))) {
+            return reject(new Error(await error.message(response)));
           }
 
-          return setTimeout(() => {
-            retry(response).then(resolve).catch(reject);
-          }, timeout());
+          return setTimeout(
+            () => {
+              retry(response).then(resolve).catch(reject);
+            },
+            await timeout(),
+          );
         })
         .catch((err) => {
           reject(err);

clients/algoliasearch-client-javascript/packages/client-common/src/types/createIterablePromise.ts

@@ -2,7 +2,7 @@ export type IterableOptions<TResponse> = Partial<{
   /**
    * The function that runs right after the API call has been resolved, allows you to do anything with the response before `validate`.
    */
-  aggregator: (response: TResponse) => void;
+  aggregator: (response: TResponse) => unknown | PromiseLike<unknown>;
 
   /**
    * The `validate` condition to throw an error and its message.
@@ -11,18 +11,18 @@ export type IterableOptions<TResponse> = Partial<{
     /**
      * The function to validate the error condition.
      */
-    validate: (response: TResponse) => boolean;
+    validate: (response: TResponse) => boolean | PromiseLike<boolean>;
 
     /**
      * The error message to throw.
      */
-    message: (response: TResponse) => string;
+    message: (response: TResponse) => string | PromiseLike<string>;
   };
 
   /**
    * The function to decide how long to wait between iterations.
    */
-  timeout: () => number;
+  timeout: () => number | PromiseLike<number>;
 }>;
 
 export type CreateIterablePromise<TResponse> = IterableOptions<TResponse> & {
@@ -36,5 +36,5 @@ export type CreateIterablePromise<TResponse> = IterableOptions<TResponse> & {
   /**
    * The validator function. It receive the resolved return of the API call.
    */
-  validate: (response: TResponse) => boolean;
+  validate: (response: TResponse) => boolean | PromiseLike<boolean>;
 };

clients/algoliasearch-client-javascript/packages/client-common/tsconfig.json

@@ -2,8 +2,9 @@
   "extends": "../../tsconfig.json",
   "compilerOptions": {
     "types": ["node", "vitest/globals"],
-    "outDir": "dist"
+    "outDir": "dist",
+    "skipLibCheck": true
   },
   "include": ["src"],
-  "exclude": ["dist", "node_modules", "src/__tests__"]
+  "exclude": ["dist", "node_modules"]
 }

clients/algoliasearch-client-javascript/packages/logger-console/package.json

@@ -30,7 +30,7 @@
   "scripts": {
     "build": "yarn clean && yarn tsup",
     "clean": "rm -rf ./dist || true",
-    "test": "vitest --run",
+    "test": "tsc --noEmit && vitest --run",
     "test:bundle": "publint . && attw --pack ."
   },
   "devDependencies": {

clients/algoliasearch-client-javascript/packages/logger-console/tsconfig.json

@@ -2,8 +2,9 @@
   "extends": "../../tsconfig.json",
   "compilerOptions": {
     "types": ["node", "vitest/globals"],
-    "outDir": "dist"
+    "outDir": "dist",
+    "skipLibCheck": true
   },
   "include": ["src", "index.ts"],
-  "exclude": ["dist", "node_modules", "src/__tests__"]
+  "exclude": ["dist", "node_modules"]
 }

clients/algoliasearch-client-javascript/packages/requester-browser-xhr/package.json

@@ -27,7 +27,7 @@
   "scripts": {
     "build": "yarn clean && yarn tsup",
     "clean": "rm -rf ./dist || true",
-    "test": "vitest --run",
+    "test": "tsc --noEmit && vitest --run",
     "test:bundle": "publint . && attw --pack . --ignore-rules cjs-resolves-to-esm"
   },
   "dependencies": {