رفع خطای زمان انتظار و لغو درخواست وب

این فایل را با همین نام و بدون حذف سطرها کنار بقیهٔ فایل‌ها ذخیره کنید.

export async function fetchJson(url, {timeoutMs = 2000, signal} = {}) {
  if (!Number.isInteger(timeoutMs) || timeoutMs < 1 || timeoutMs > 60000) throw new RangeError('timeoutMs must be 1..60000');
  const deadline = AbortSignal.timeout(timeoutMs);
  const combined = signal ? AbortSignal.any([signal, deadline]) : deadline;
  const response = await fetch(url, {signal: combined});
  if (!response.ok) {
    await response.body?.cancel();
    const error = new Error(`HTTP ${response.status}`);
    error.status = response.status;
    throw error;
  }
  return response.json();
}

دستور اجرا، نتیجهٔ مورد انتظار و محدودیت این فایل در بخش اجرای مقاله توضیح داده شده است.

این فایل را با همین نام و بدون حذف سطرها کنار بقیهٔ فایل‌ها ذخیره کنید.

import {createServer} from 'node:http';
import {pathToFileURL} from 'node:url';

export function makeServer() {
  return createServer((req, res) => {
    const url = new URL(req.url, 'http://localhost');
    const delay = Math.max(0, Math.min(500, Number(url.searchParams.get('delay')) || 0));
    res.writeHead(url.pathname === '/fail' ? 500 : 200, {'Content-Type': 'application/json'});
    res.flushHeaders();
    setTimeout(() => { if (!res.destroyed) res.end('{"ready":true}'); }, delay);
  });
}
if (process.argv[1] && import.meta.url === pathToFileURL(process.argv[1]).href) {
  makeServer().listen(8089, '127.0.0.1', () => console.log('http://127.0.0.1:8089'));
}

دستور اجرا، نتیجهٔ مورد انتظار و محدودیت این فایل در بخش اجرای مقاله توضیح داده شده است.

این فایل را با همین نام و بدون حذف سطرها کنار بقیهٔ فایل‌ها ذخیره کنید.

import {fetchJson} from './fetch_deadline.mjs';
console.log(await fetchJson('http://127.0.0.1:8089/?delay=50', {timeoutMs: 1000}));

دستور اجرا، نتیجهٔ مورد انتظار و محدودیت این فایل در بخش اجرای مقاله توضیح داده شده است.

این فایل را با همین نام و بدون حذف سطرها کنار بقیهٔ فایل‌ها ذخیره کنید.

import {test} from 'node:test';
import assert from 'node:assert/strict';
import {once} from 'node:events';
import {fetchJson} from './fetch_deadline.mjs';
import {makeServer} from './server.mjs';

test('success, HTTP failure, body timeout and caller cancellation', async () => {
  const server = makeServer().listen(0, '127.0.0.1');
  await once(server, 'listening');
  const base = `http://127.0.0.1:${server.address().port}`;
  try {
    assert.deepEqual(await fetchJson(base), {ready: true});
    await assert.rejects(fetchJson(base + '/fail'), error => error.status === 500);
    await assert.rejects(fetchJson(base + '/?delay=200', {timeoutMs: 20}), error => ['AbortError', 'TimeoutError'].includes(error.name));
    const controller = new AbortController(); controller.abort();
    await assert.rejects(fetchJson(base, {signal: controller.signal}), error => error.name === 'AbortError');
  } finally {
    server.closeAllConnections(); await new Promise(resolve => server.close(resolve));
  }
});

دستور اجرا، نتیجهٔ مورد انتظار و محدودیت این فایل در بخش اجرای مقاله توضیح داده شده است.