Function createWorkspaceWithInit

tests/ipc/helpers.ts:255–306

(
  env: TestEnvironment,
  projectPath: string,
  branchName: string,
  runtimeConfig?: RuntimeConfig,
  waitForInit: boolean = false,
  isSSH: boolean = false
)

 * Enhanced version that can wait for init hook completion (needed for runtime tests)
 */
export async function createWorkspaceWithInit(
  env: TestEnvironment,
  projectPath: string,
  branchName: string,
  runtimeConfig?: RuntimeConfig,
  waitForInit: boolean = false,
  isSSH: boolean = false
): Promise<{ workspaceId: string; workspacePath: string; cleanup: () => Promise<void> }> {
  const trunkBranch = await detectDefaultTrunkBranch(projectPath);

  // Trust the project so hooks and scripts can run during workspace creation
  await trustProject(env, projectPath);

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

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

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

  // Wait for init hook to complete if requested
  if (waitForInit) {
    const initTimeout = isSSH ? SSH_INIT_WAIT_MS : INIT_HOOK_WAIT_MS;

    const collector = createStreamCollector(env.orpc, workspaceId);
    collector.start();
    try {
      await collector.waitForEvent("init-end", initTimeout);
    } catch (err) {
      // Init hook might not exist or might have already completed before we started waiting
      // This is not necessarily an error - just log it
      console.log(
        `Note: init-end event not detected within ${initTimeout}ms (may have completed early)`
      );
    } finally {
      collector.stop();
    }
  }

  const cleanup = async () => {
    await env.orpc.workspace.remove({ workspaceId });
  };

  return { workspaceId, workspacePath, cleanup };
}

/**
 * Send message and wait for stream completion