Function applyProjectPatch

src/node/services/tools/task_apply_git_patch.ts:1048–1485

(params: {
  taskId: string;
  workspaceId: string;
  runtime: ToolConfiguration["runtime"];
  runtimeTempDir: string;
  trusted: boolean;
  repoCwd: string;
  projectArtifact: SubagentGitProjectPatchArtifact;
  artifactWorkspaceId: string;
  artifactSessionDir: string;
  artifactLookupNote?: string;
  dryRun: boolean;
  threeWay: boolean;
  force: boolean;
  expectedHeadSha?: string;
  isReplay: boolean;
  abortSignal?: AbortSignal;
})

}

async function applyProjectPatch(params: {
  taskId: string;
  workspaceId: string;
  runtime: ToolConfiguration["runtime"];
  runtimeTempDir: string;
  trusted: boolean;
  repoCwd: string;
  projectArtifact: SubagentGitProjectPatchArtifact;
  artifactWorkspaceId: string;
  artifactSessionDir: string;
  artifactLookupNote?: string;
  dryRun: boolean;
  threeWay: boolean;
  force: boolean;
  expectedHeadSha?: string;
  isReplay: boolean;
  abortSignal?: AbortSignal;
}): Promise<{ success: boolean; projectResult: TaskApplyGitPatchProjectResult }> {
  const taskIdError = validatePatchRuntimePathComponent(params.taskId, "task_id");
  const storageKeyError = validatePatchRuntimePathComponent(
    params.projectArtifact.storageKey,
    "storageKey"
  );
  if (taskIdError != null || storageKeyError != null) {
    return {
      success: false,
      projectResult: {
        projectPath: params.projectArtifact.projectPath,
        projectName: params.projectArtifact.projectName,
        status: "failed",
        error: taskIdError ?? storageKeyError,
      },
    };
  }

  const remotePatchPath = buildRuntimeTempPath({
    runtimeTempDir: params.runtimeTempDir,
    filename: `mux-task-${params.taskId}-${params.projectArtifact.storageKey}-series.mbox`,
    purpose: "patch copy",
  });

  await cleanupRuntimePatchFile({
    runtime: params.runtime,
    repoCwd: params.repoCwd,
    remotePatchPath,
    taskId: params.taskId,
    workspaceId: params.workspaceId,
  });

  const patchResolution = await resolvePatchPath({
    taskId: params.taskId,
    artifactSessionDir: params.artifactSessionDir,
    projectArtifact: params.projectArtifact,
    artifactLookupNote: params.artifactLookupNote,
  });
  if ("error" in patchResolution) {
    return {
      success: false,