test: make event-store soak deterministic on windows

Author: Aitomates

universal-refiner/scripts/stress/event-store-soak-worker.mjs

@@ -2,13 +2,14 @@ import { EventStore } from "../../dist/src/history/event-store.js";
 
 const workerId = process.argv[2];
 const durationMs = Number.parseInt(process.argv[3] || "10000", 10);
+const minOperations = Number.parseInt(process.argv[4] || "0", 10);
 const deadline = Date.now() + durationMs;
 const counts = { events: 0, prompts: 0, executions: 0, operations: 0 };
 const store = EventStore.getInstance();
 let index = 0;
 let lastPromptId;
 
-while (Date.now() < deadline) {
+while (Date.now() < deadline || counts.operations < minOperations) {
   const id = `soak-${workerId}-${index}`;
   const operation = index % 3;
 

universal-refiner/scripts/stress/event-store-soak.mjs

@@ -25,13 +25,14 @@ export async function runEventStoreSoak(options = {}) {
   const workers = readPositiveInteger(options.workers, 4, "workers");
   const durationMs = readPositiveInteger(options.durationMs, 10_000, "durationMs");
   const minOperations = readPositiveInteger(options.minOperations, workers * 10, "minOperations");
+  const minOperationsPerWorker = Math.ceil(minOperations / workers);
   const maxLossRatio = readRatio(options.maxLossRatio, 0, "maxLossRatio");
   const directory = await mkdtemp(join(tmpdir(), "prompt-refiner-soak-"));
   const databasePath = join(directory, "events.db");
 
   try {
     const results = await Promise.all(Array.from({ length: workers }, async (_, index) => {
-      const result = await runProcess(process.execPath, [workerScript, String(index), String(durationMs)], {
+      const result = await runProcess(process.execPath, [workerScript, String(index), String(durationMs), String(minOperationsPerWorker)], {
         cwd: repoRoot,
         env: { ...process.env, PROMPT_REFINER_GLOBAL_DIR: directory, PROMPT_REFINER_LOG_LEVEL: "error" },
         timeoutMs: durationMs + 30_000,