Function applyTextEdits

packages/shell/src/helpers.ts:300–353

(
  edits: { path: string; content: string }[],
  readFileIfExists: (path: string) => Promise<string | null>,
  writeFile: (path: string, content: string) => Promise<void>,
  deleteFile: (path: string) => Promise<void>,
  options: StateApplyEditsOptions = {}
)

}

export async function applyTextEdits(
  edits: { path: string; content: string }[],
  readFileIfExists: (path: string) => Promise<string | null>,
  writeFile: (path: string, content: string) => Promise<void>,
  deleteFile: (path: string) => Promise<void>,
  options: StateApplyEditsOptions = {}
): Promise<StateApplyEditsResult> {
  const results: StateAppliedEditResult[] = [];
  let totalChanged = 0;
  const appliedSnapshots: Array<{ path: string; previous: string | null }> = [];

  try {
    for (const edit of edits) {
      const previous = await readFileIfExists(edit.path);
      const nextContent = edit.content;
      const changed = previous !== nextContent;

      if (changed && !options.dryRun) {
        await writeFile(edit.path, nextContent);
        appliedSnapshots.push({ path: edit.path, previous });
      }

      results.push({
        path: edit.path,
        changed,
        content: nextContent,
        diff: changed
          ? diffContent(previous ?? "", nextContent, edit.path, edit.path)
          : ""
      });

      if (changed) {
        totalChanged++;
      }
    }
  } catch (error) {
    const rollback = options.rollbackOnError ?? true;
    const rollbackError = rollback
      ? await rollbackSnapshots(appliedSnapshots, writeFile, deleteFile)
      : undefined;
    throw new StateBatchOperationError({
      operation: "applyEdits",
      message: error instanceof Error ? error.message : String(error),
      rolledBack: rollback,
      rollbackError
    });
  }

  return {
    dryRun: options.dryRun ?? false,
    edits: results,
    totalChanged
  };
}

export async function planTextEdits(
  instructions: StateEditInstruction[],