Add /error/close and /error/reset endpoints

Author: pimterry

src/endpoints/http-index.ts

@@ -27,4 +27,6 @@ export * from './http/delay.js';
 export * from './http/cookies.js'
 export * from './http/basic-auth.js';
 export * from './http/json.js';
-export * from './http/trailers.js';
+export * from './http/trailers.js';
+export * from './http/error/close.js';
+export * from './http/error/reset.js';

src/endpoints/http/error/close.ts

@@ -0,0 +1,11 @@
+import { HttpHandler } from '../../http-index.js';
+const matchPath = (path: string) => path === '/error/close';
+
+const handle: HttpHandler = async (req) => {
+    req.socket.end();
+}
+
+export const closeEndpoint = {
+    matchPath,
+    handle
+};

src/endpoints/http/error/reset.ts

@@ -0,0 +1,12 @@
+import { HttpHandler } from '../../http-index.js';
+
+const matchPath = (path: string) => path === '/error/reset';
+
+const handle: HttpHandler = async (req) => {
+    req.socket.resetAndDestroy();
+}
+
+export const resetEndpoint = {
+    matchPath,
+    handle
+};

test/close.spec.ts

@@ -0,0 +1,36 @@
+import * as net from 'net';
+import * as http from 'http';
+
+import { expect } from 'chai';
+import { DestroyableServer, makeDestroyable } from 'destroyable-server';
+
+import { createServer } from '../src/server.js';
+
+describe("Close endpoint", () => {
+
+    let server: DestroyableServer;
+    let serverPort: number;
+
+    beforeEach(async () => {
+        server = makeDestroyable(await createServer());
+        await new Promise<void>((resolve) => server.listen(resolve));
+        serverPort = (server.address() as net.AddressInfo).port;
+    });
+
+    afterEach(async () => {
+        await server.destroy();
+    });
+
+    it("closes the connection", async () => {
+        const address = `http://localhost:${serverPort}/error/close`;
+        const request = http.request(address).end();
+        const result = await new Promise<any>((resolve, reject) => {
+            request.on('error', resolve);
+            request.on('response', () => reject(new Error('Expected an error')));
+        });
+
+        expect(result.code).to.equal('ECONNRESET');
+        expect(result.message).to.equal('socket hang up');
+    });
+
+});

test/reset.spec.ts

@@ -0,0 +1,36 @@
+import * as net from 'net';
+import * as http from 'http';
+
+import { expect } from 'chai';
+import { DestroyableServer, makeDestroyable } from 'destroyable-server';
+
+import { createServer } from '../src/server.js';
+
+describe("Reset endpoint", () => {
+
+    let server: DestroyableServer;
+    let serverPort: number;
+
+    beforeEach(async () => {
+        server = makeDestroyable(await createServer());
+        await new Promise<void>((resolve) => server.listen(resolve));
+        serverPort = (server.address() as net.AddressInfo).port;
+    });
+
+    afterEach(async () => {
+        await server.destroy();
+    });
+
+    it("resets the connection", async () => {
+        const address = `http://localhost:${serverPort}/error/reset`;
+        const request = http.request(address).end();
+        const result = await new Promise<any>((resolve, reject) => {
+            request.on('error', resolve);
+            request.on('response', () => reject(new Error('Expected an error')));
+        });
+
+        expect(result.code).to.equal('ECONNRESET');
+        expect(result.message).to.equal('read ECONNRESET');
+    });
+
+});