Function spawnOpenOwnedChild

apps/local/src/db/owned-database.test.ts:345–387

(input: {
  readonly dataDir: string;
  readonly tenantId: string;
  readonly pauseAt: string;
  readonly pauseFile: string;
})

}

const spawnOpenOwnedChild = (input: {
  readonly dataDir: string;
  readonly tenantId: string;
  readonly pauseAt: string;
  readonly pauseFile: string;
}): OwnedChild => {
  const code = `
    import { collectTables } from "@executor-js/api/server";
    import { openOwnedLocalDatabase } from "./src/db/owned-database.ts";
    const owned = await openOwnedLocalDatabase({
      dataDir: process.env.EXECUTOR_TEST_DATA_DIR,
      tables: collectTables(),
      namespace: "executor_local",
      tenantId: process.env.EXECUTOR_TEST_TENANT,
    });
    console.log("OPENED");
    await owned.close();
  `;
  const child = spawn(process.execPath, ["-e", code], {
    cwd: appRoot,
    env: {
      ...process.env,
      NODE_ENV: "test",
      EXECUTOR_TEST_DATA_DIR: input.dataDir,
      EXECUTOR_TEST_TENANT: input.tenantId,
      EXECUTOR_V1_V2_MIGRATION_PAUSE_AT: input.pauseAt,
      EXECUTOR_V1_V2_MIGRATION_PAUSE_FILE: input.pauseFile,
    },
    stdio: "pipe",
  });
  child.unref();

  const owned: OwnedChild = { child, stdout: "", stderr: "" };
  child.stdout.setEncoding("utf-8");
  child.stderr.setEncoding("utf-8");
  child.stdout.on("data", (chunk: string) => {
    owned.stdout += chunk;
  });
  child.stderr.on("data", (chunk: string) => {
    owned.stderr += chunk;
  });
  return owned;
};

const waitForMarker = async (
  markerPath: string,