Function waitForFileEditOrAbort

src/node/services/tools/file_edit_operation.ts:65–101

(
  operationPromise: Promise<ExecuteFileEditReturn<TMetadata>>,
  abortSignal: AbortSignal | undefined,
  canReturnAbortBeforeWrite: () => boolean
)

}

async function waitForFileEditOrAbort<TMetadata>(
  operationPromise: Promise<ExecuteFileEditReturn<TMetadata>>,
  abortSignal: AbortSignal | undefined,
  canReturnAbortBeforeWrite: () => boolean
): Promise<ExecuteFileEditReturn<TMetadata>> {
  const abortedResult = getAbortedFileEditResult(abortSignal);
  if (abortedResult) {
    return abortedResult;
  }

  if (!abortSignal) {
    return operationPromise;
  }

  return new Promise<ExecuteFileEditReturn<TMetadata>>((resolve, reject) => {
    const onAbort = () => {
      if (!canReturnAbortBeforeWrite()) {
        return;
      }

      abortSignal.removeEventListener("abort", onAbort);
      resolve(getAbortedFileEditResult(abortSignal)!);
    };

    abortSignal.addEventListener("abort", onAbort, { once: true });
    operationPromise.then(
      (result) => {
        abortSignal.removeEventListener("abort", onAbort);
        resolve(result);
      },
      (error: unknown) => {
        abortSignal.removeEventListener("abort", onAbort);
        reject(error instanceof Error ? error : new Error(getErrorMessage(error)));
      }
    );
  });
}

/**
 * Shared execution pipeline for file edit tools.