Abort errors are not caught from response.text()

[flevi29]

meilisearch-js/src/http-requests.ts

Lines 192 to 272 in 9e43b62

	/**
	* Sends a request with {@link fetch} or a custom HTTP client, combining
	* parameters and class properties.
	*
	* @returns A promise containing the response
	*/
	async #request<T = unknown>({
	path,
	method,
	params,
	contentType,
	body,
	extraRequestInit,
	}: MainRequestOptions): Promise<T> {
	const url = new URL(path, this.#url);
	if (params !== undefined) {
	appendRecordToURLSearchParams(url.searchParams, params);
	}
	const requestInit: RequestInit = {
	method,
	body:
	contentType === undefined || typeof body !== "string"
	? JSON.stringify(body)
	: body,
	...extraRequestInit,
	...this.#requestInit,
	headers: this.#getHeaders(extraRequestInit?.headers, contentType),
	};
	const startTimeout =
	this.#requestTimeout !== undefined
	? getTimeoutFn(requestInit, this.#requestTimeout)
	: null;
	const getResponseAndHandleErrorAndTimeout = <
	U extends ReturnType<NonNullable<Config["httpClient"]> | typeof fetch>,
	>(
	responsePromise: U,
	stopTimeout?: ReturnType<NonNullable<typeof startTimeout>>,
	) =>
	responsePromise
	.catch((error: unknown) => {
	throw new MeiliSearchRequestError(
	url.toString(),
	Object.is(error, TIMEOUT_OBJECT)
	? new Error(`request timed out after ${this.#requestTimeout}ms`, {
	cause: requestInit,
	})
	: error,
	);
	})
	.finally(() => stopTimeout?.()) as U;
	const stopTimeout = startTimeout?.();
	if (this.#customRequestFn !== undefined) {
	const response = await getResponseAndHandleErrorAndTimeout(
	this.#customRequestFn(url, requestInit),
	stopTimeout,
	);
	// When using a custom HTTP client, the response should already be handled and ready to be returned
	return response as T;
	}
	const response = await getResponseAndHandleErrorAndTimeout(
	fetch(url, requestInit),
	stopTimeout,
	);
	const responseBody = await response.text();
	const parsedResponse =
	responseBody === "" ? undefined : JSON.parse(responseBody);
	if (!response.ok) {
	throw new MeiliSearchApiError(response, parsedResponse);
	}
	return parsedResponse as T;
	}