Function createTestExecutor

src/utils/test-common.ts:108–264

(
  executor: CommandExecutor = getDefaultCommandExecutor(),
  options: SharedTestExecutorOptions,
)

}

export function createTestExecutor(
  executor: CommandExecutor = getDefaultCommandExecutor(),
  options: SharedTestExecutorOptions,
): StreamingExecutor<SharedTestExecutorParams, TestResultDomainResult> {
  return async (params, ctx) => {
    log(
      'info',
      `Starting test run for scheme ${params.scheme} on platform ${params.platform} (executor)`,
    );

    const execOpts: CommandExecOptions | undefined = params.testRunnerEnv
      ? { env: normalizeTestRunnerEnv(params.testRunnerEnv) }
      : undefined;
    const shouldUseTwoPhaseSimulatorExecution =
      String(params.platform).includes('Simulator') && Boolean(options.preflight);
    const toolName = options.toolName ?? 'test_sim';
    const target = options.target ?? getBuildTarget(params.platform);
    const started = createDomainStreamingPipeline(toolName, 'TEST', ctx, 'test-result');
    const platformOptions = {
      platform: params.platform,
      simulatorName: params.simulatorName,
      simulatorId: params.simulatorId,
      deviceId: params.deviceId,
      useLatestOS: params.useLatestOS,
      packageCachePath: params.packageCachePath,
      logPrefix: 'Test Run',
    };
    const discoveryEvent = createTestDiscoveryFragment(options.preflight);

    if (discoveryEvent) {
      started.pipeline.emitFragment(discoveryEvent);
    }

    try {
      const parsedResultBundleArgs = parseResultBundlePathArgs(params.extraArgs);
      const shouldUseDefaultResultBundlePath = !parsedResultBundleArgs.resultBundlePath;
      const resultBundlePath =
        parsedResultBundleArgs.resultBundlePath ?? createDefaultResultBundlePath(toolName);

      if (shouldUseTwoPhaseSimulatorExecution) {
        const executionPlan = createSimulatorTwoPhaseExecutionPlan({
          extraArgs: params.extraArgs,
          preflight: options.preflight,
          resultBundlePath,
        });

        const buildForTestingResult = await executeXcodeBuildCommand(
          { ...params, extraArgs: executionPlan.buildArgs },
          platformOptions,
          params.preferXcodebuild,
          'build-for-testing',
          executor,
          execOpts,
          started.pipeline,
        );

        if (buildForTestingResult.isError) {
          return createTestDomainResult({