Temporarily turn on device sync and multiple client instances

Author: neekolas

forks/config.ts

@@ -12,6 +12,11 @@ export const workerNames = [
   "random3",
   "random4",
   "random5",
+  "random1",
+  "random2",
+  "random3",
+  "random4",
+  "random5",
 ] as string[];
 
 // Operations configuration - enable/disable specific operations

helpers/versions.ts

@@ -275,6 +275,8 @@ export const regressionClient = async (
       loggingLevel,
       apiUrl,
       appVersion: APP_VERSION,
+      historySyncUrl: "http://localhost:5558",
+      disableDeviceSync: false,
       codecs: [new ReactionCodec(), new ReplyCodec()],
     });
   } catch (error) {

multinode/docker-compose.yml

@@ -117,6 +117,12 @@ services:
     image: ghcr.io/xmtp/mls-validation-service:main
     platform: linux/amd64
 
+  history-server:
+    image: ghcr.io/xmtp/message-history-server:main
+    platform: linux/amd64
+    ports:
+      - 5558:5558
+
   db:
     image: postgres:13
     environment:

workers/manager.ts

@@ -516,7 +516,7 @@ export async function getWorkers(
       (v) => v.nodeBindings,
     );
   }
-  let workerPromises: Promise<Worker>[] = [];
+  let successfulResults: Worker[] = [];
   let descriptors: string[] = [];
 
   // Handle different input types
@@ -528,68 +528,75 @@ export async function getWorkers(
           : getFixedNames(workers)
         : workers;
     descriptors = names;
-    workerPromises = descriptors.map((descriptor) =>
-      manager.createWorker(
-        descriptor,
-        sdkVersions[Math.floor(Math.random() * sdkVersions.length)],
-      ),
-    );
+    for (const descriptor of descriptors) {
+      successfulResults.push(
+        await manager.createWorker(
+          descriptor,
+          sdkVersions[Math.floor(Math.random() * sdkVersions.length)],
+        ),
+      );
+    }
   } else {
     // Record input - apply versioning if requested
     let entries = Object.entries(workers);
 
     descriptors = entries.map(([descriptor]) => descriptor);
-    workerPromises = entries.map(([descriptor, apiUrl]) =>
-      manager.createWorker(descriptor, sdkVersions[0], apiUrl),
-    );
-  }
-
-  // Only use progress bar if there are more than 50 workers
-  const useProgressBar = workerPromises.length > 50;
-  let progressBar: ProgressBar | undefined;
-
-  if (useProgressBar) {
-    progressBar = new ProgressBar(
-      workerPromises.length,
-      `Initializing ${workerPromises.length} workers...`,
-    );
-    // Show initial progress immediately
-    progressBar.update(0);
-  }
-
-  // Track all workers in parallel and update progress as each completes
-  let completedCount = 0;
-  const results = await Promise.allSettled(
-    workerPromises.map(async (workerPromise) => {
-      try {
-        const worker = await workerPromise;
-        completedCount++;
-        if (useProgressBar && progressBar) {
-          progressBar.update(completedCount);
-        }
-        return worker;
-      } catch (error) {
-        completedCount++;
-        if (useProgressBar && progressBar) {
-          progressBar.update(completedCount);
-        }
-        throw error;
-      }
-    }),
-  );
-
-  // Check for any failures
-  const failedResults = results.filter(
-    (result) => result.status === "rejected",
-  );
-  if (failedResults.length > 0) {
-    throw failedResults[0].reason;
+    for (const descriptor of descriptors) {
+      successfulResults.push(
+        await manager.createWorker(
+          descriptor,
+          sdkVersions[Math.floor(Math.random() * sdkVersions.length)],
+        ),
+      );
+    }
   }
 
-  // Extract successful results
-  const successfulResults = results.map(
-    (result) => (result as PromiseFulfilledResult<Worker>).value,
-  );
+  // // Only use progress bar if there are more than 50 workers
+  // const useProgressBar = workerPromises.length > 50;
+  // let progressBar: ProgressBar | undefined;
+
+  // if (useProgressBar) {
+  //   progressBar = new ProgressBar(
+  //     workerPromises.length,
+  //     `Initializing ${workerPromises.length} workers...`,
+  //   );
+  //   // Show initial progress immediately
+  //   progressBar.update(0);
+  // }
+
+  // // Track all workers in parallel and update progress as each completes
+  // let completedCount = 0;
+  // const results = await Promise.allSettled(
+  //   workerPromises.map(async (workerPromise) => {
+  //     try {
+  //       const worker = await workerPromise;
+  //       completedCount++;
+  //       if (useProgressBar && progressBar) {
+  //         progressBar.update(completedCount);
+  //       }
+  //       return worker;
+  //     } catch (error) {
+  //       completedCount++;
+  //       if (useProgressBar && progressBar) {
+  //         progressBar.update(completedCount);
+  //       }
+  //       throw error;
+  //     }
+  //   }),
+  // );
+
+  // // Check for any failures
+  // const failedResults = results.filter(
+  //   (result) => result.status === "rejected",
+  // );
+  // if (failedResults.length > 0) {
+  //   throw failedResults[0].reason;
+  // }
+
+  // // Extract successful results
+  // const successfulResults = results.map(
+  //   (result) => (result as PromiseFulfilledResult<Worker>).value,
+  // );
 
   // Add all successful workers to the manager
   for (const worker of successfulResults) {
@@ -618,12 +625,11 @@ function getNextFolderName(): string {
   const dataPath = path.resolve(process.cwd(), ".data");
   let folder = "a";
   if (fs.existsSync(dataPath)) {
-    const existingFolders = fs
-      .readdirSync(dataPath)
-      .filter((f) => /^[a-z]$/.test(f));
-    folder = String.fromCharCode(
-      "a".charCodeAt(0) + (existingFolders.length % 26),
-    );
+    const chars = "abcdefghijklmnopqrstuvwxyz0123456789";
+    folder = Array.from(
+      { length: 32 },
+      () => chars[Math.floor(Math.random() * chars.length)],
+    ).join("");
   }
   return folder;
 }