Function withSharedWorkspace

tests/ipc/sendMessageTestHelpers.ts:93–170

(
  provider: string,
  testFn: (context: SharedWorkspaceContext) => Promise<void>
)

 * @param testFn - Test function to run with the workspace context
 */
export async function withSharedWorkspace(
  provider: string,
  testFn: (context: SharedWorkspaceContext) => Promise<void>
): Promise<void> {
  const env = getSharedEnv();
  const projectPath = getSharedRepoPath();

  // Generate unique branch name for this test
  const branchName = generateBranchName(`test-${provider}`);
  const trunkBranch = await detectDefaultTrunkBranch(projectPath);

  // Trust the project so workspace creation can run under the test trust gate.
  await trustProject(env, projectPath);

  // Create workspace
  const result = await env.orpc.workspace.create({
    projectPath,
    branchName,
    trunkBranch,
  });

  if (!result.success) {
    throw new Error(`Failed to create workspace: ${result.error}`);
  }

  const metadata = result.metadata;
  const workspaceId = metadata.id;

  // Setup provider with API key
  const apiKey = getApiKey(provider === "openai" ? "OPENAI_API_KEY" : "ANTHROPIC_API_KEY");
  await setupProviders(env, {
    [provider]: { apiKey },
  });

  // Create stream collector
  const collector = createStreamCollector(env.orpc, workspaceId);
  collector.start();

  // Wait for subscription to be ready
  await collector.waitForSubscription();

  // Wait for init to complete (if there's an init hook)
  try {
    await collector.waitForEvent("init-end", INIT_HOOK_WAIT_MS);
  } catch {
    // Init hook might not exist - that's OK
  }

  try {
    await testFn({ env, workspaceId, metadata, collector });
  } finally {
    const stopPromise = collector.waitForStop().catch((error) => {
      console.warn("Failed to stop StreamCollector during test cleanup:", error);
    });

    const stopTimedOut = await Promise.race([
      stopPromise.then(() => false),
      new Promise<boolean>((resolve) => setTimeout(() => resolve(true), 2000)),