request-signal.test.js — astro Source File

Source Code

import assert from 'node:assert/strict';
import { EventEmitter } from 'node:events';
import { after, before, describe, it } from 'node:test';
import { setTimeout as delay } from 'node:timers/promises';
import { loadFixture } from './test-utils.js';
import { createRequestAndResponse } from './units/test-utils.js';

const createMockSocket = () => {
	const socket = new EventEmitter();
	// @ts-expect-error - emulate shape of a Node socket for the adapter
	socket.encrypted = false;
	// @ts-expect-error - emulate shape of a Node socket for the adapter
	socket.remoteAddress = '127.0.0.1';
	// @ts-expect-error - emulate shape of a Node socket for the adapter
	socket.destroyed = false;
	// @ts-expect-error - emulate shape of a Node socket for the adapter
	socket.writable = true;
	// @ts-expect-error - emulate shape of a Node socket for the adapter
	socket.destroy = () => {
		socket.destroyed = true;
		socket.emit('close');
	};
	return socket;
};

const attachSocket = (socket, req, res) => {
	Object.defineProperty(req, 'socket', {
		configurable: true,
		value: socket,
		writable: true,
	});
	Object.defineProperty(res, 'socket', {
		configurable: true,
		value: socket,
		writable: true,
	});
};

describe('Node request abort integration', () => {
	/** @type {import('./test-utils').Fixture} */
	let fixture;
	/** @type {(req: import('node:http').IncomingMessage, res: import('node:http').ServerResponse) => Promise<void>} */
	let handle;

	const resetAbortState = async () => {
		const resetRequest = createRequestAndResponse({
			method: 'GET',
			url: '/status.json?reset=1',
		});
		handle(resetRequest.req, resetRequest.res);
		await resetRequest.done;
	};

	const readAbortState = async () => {
		const statusRequest = createRequestAndResponse({
			method: 'GET',
			url: '/status.json',
		});
		handle(statusRequest.req, statusRequest.res);
		return await statusRequest.json();
// ... (67 more lines)