Something went wrong. Try again.
Mirror: A Node.js fetch shim using built-in Request, Response, and Headers (but without native fetch)
Something went wrong. Try again.
12 kB · 498 lines
JavaScript
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499// See: https://github.com/remix-run/web-std-io/blob/7a8596e/packages/fetch/test/utils/server.js
import http from 'http';import zlib from 'zlib';import Busboy from 'busboy';import { once } from 'events';
export default class TestServer { constructor() { this.server = http.createServer(this.router); // Node 8 default keepalive timeout is 5000ms // make it shorter here as we want to close server quickly at the end of tests this.server.keepAliveTimeout = 1000; this.server.on('error', err => { console.log(err.stack); }); this.server.on('connection', socket => { socket.setTimeout(1500); }); }
async start() { this.server.listen(0, 'localhost'); return once(this.server, 'listening'); }
async stop() { this.server.close(); return once(this.server, 'close'); }
get port() { return this.server.address().port; }
get hostname() { return 'localhost'; }
mockResponse(responseHandler) { this.server.nextResponseHandler = responseHandler; return `http://${this.hostname}:${this.port}/mocked`; }
mock(handler) { this.server.nextResponseHandler = handler; return `http://${this.hostname}:${this.port}/mocked`; }
router(request, res) { const p = request.url;
if (p === '/mocked') { if (this.nextResponseHandler) { this.nextResponseHandler(request, res); this.nextResponseHandler = undefined; } else { throw new Error("No mocked response. Use 'TestServer.mockResponse()'."); } }
if (p === '/hello') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.end('world'); }
if (p.includes('question')) { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.end('ok'); }
if (p === '/plain') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.end('text'); }
if (p === '/no-status-text') { res.writeHead(200, '', {}).end(); }
if (p === '/options') { res.statusCode = 200; res.setHeader('Allow', 'GET, HEAD, OPTIONS'); res.end('hello world'); }
if (p === '/html') { res.statusCode = 200; res.setHeader('Content-Type', 'text/html'); res.end('<html></html>'); }
if (p === '/json') { res.statusCode = 200; res.setHeader('Content-Type', 'application/json'); res.end( JSON.stringify({ name: 'value', }) ); }
if (p === '/gzip') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.setHeader('Content-Encoding', 'gzip'); zlib.gzip('hello world', (err, buffer) => { if (err) { throw err; }
res.end(buffer); }); }
if (p === '/gzip-truncated') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.setHeader('Content-Encoding', 'gzip'); zlib.gzip('hello world', (err, buffer) => { if (err) { throw err; }
// Truncate the CRC checksum and size check at the end of the stream res.end(buffer.slice(0, -8)); }); }
if (p === '/gzip-capital') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.setHeader('Content-Encoding', 'GZip'); zlib.gzip('hello world', (err, buffer) => { if (err) { throw err; }
res.end(buffer); }); }
if (p === '/deflate') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.setHeader('Content-Encoding', 'deflate'); zlib.deflate('hello world', (err, buffer) => { if (err) { throw err; }
res.end(buffer); }); }
if (p === '/brotli') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); if (typeof zlib.createBrotliDecompress === 'function') { res.setHeader('Content-Encoding', 'br'); zlib.brotliCompress('hello world', (err, buffer) => { if (err) { throw err; }
res.end(buffer); }); } }
if (p === '/deflate-raw') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.setHeader('Content-Encoding', 'deflate'); zlib.deflateRaw('hello world', (err, buffer) => { if (err) { throw err; }
res.end(buffer); }); }
if (p === '/sdch') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.setHeader('Content-Encoding', 'sdch'); res.end('fake sdch string'); }
if (p === '/invalid-content-encoding') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.setHeader('Content-Encoding', 'gzip'); res.end('fake gzip string'); }
if (p === '/timeout') { setTimeout(() => { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.end('text'); }, 1000); }
if (p === '/slow') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.write('test'); setTimeout(() => { res.end('test'); }, 1000); }
if (p === '/cookie') { res.statusCode = 200; res.setHeader('Set-Cookie', ['a=1', 'b=1']); res.end('cookie'); }
if (p === '/size/chunk') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); setTimeout(() => { res.write('test'); }, 10); setTimeout(() => { res.end('test'); }, 20); }
if (p === '/size/long') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.end('testtest'); }
if (p === '/redirect/301') { res.statusCode = 301; res.setHeader('Location', '/inspect'); res.end(); }
if (p === '/redirect/301/file') { res.statusCode = 301; res.setHeader('Location', 'file://inspect'); res.end(); }
if (p === '/redirect/301/rn') { res.statusCode = 301; res.setHeader('Location', '/403'); res.write('301 Permanently moved.\r\n'); res.end(); }
if (p === '/403') { res.statusCode = 403; res.write('403 Forbidden'); res.end(); }
if (p === '/redirect/302') { res.statusCode = 302; res.setHeader('Location', '/inspect'); res.end(); }
if (p === '/redirect/303') { res.statusCode = 303; res.setHeader('Location', '/inspect'); res.end(); }
if (p === '/redirect/307') { res.statusCode = 307; res.setHeader('Location', '/inspect'); res.end(); }
if (p === '/redirect/308') { res.statusCode = 308; res.setHeader('Location', '/inspect'); res.end(); }
if (p === '/redirect/chain') { res.statusCode = 301; res.setHeader('Location', '/redirect/301'); res.end(); }
if (p === '/redirect/no-location') { res.statusCode = 301; res.end(); }
if (p === '/redirect/slow') { res.statusCode = 301; res.setHeader('Location', '/redirect/301'); setTimeout(() => { res.end(); }, 1000); }
if (p === '/redirect/slow-chain') { res.statusCode = 301; res.setHeader('Location', '/redirect/slow'); setTimeout(() => { res.end(); }, 10); }
if (p === '/redirect/slow-stream') { res.statusCode = 301; res.setHeader('Location', '/slow'); res.end(); }
if (p === '/redirect/bad-location') { res.socket.write('HTTP/1.1 301\r\nLocation: ☃\r\nContent-Length: 0\r\n'); res.socket.end('\r\n'); }
if (p === '/redirect/chunked') { res.writeHead(301, { Location: '/inspect', 'Transfer-Encoding': 'chunked', }); setTimeout(() => res.end(), 10); }
if (p === '/error/400') { res.statusCode = 400; res.setHeader('Content-Type', 'text/plain'); res.end('client error'); }
if (p === '/error/404') { res.statusCode = 404; res.setHeader('Content-Encoding', 'gzip'); res.end(); }
if (p === '/error/500') { res.statusCode = 500; res.setHeader('Content-Type', 'text/plain'); res.end('server error'); }
if (p === '/error/reset') { res.destroy(); }
if (p === '/error/premature') { res.writeHead(200, { 'content-length': 50 }); res.write('foo'); setTimeout(() => { res.destroy(); }, 100); }
if (p === '/error/premature/chunked') { res.writeHead(200, { 'Content-Type': 'application/json', 'Transfer-Encoding': 'chunked', });
res.write(`${JSON.stringify({ data: 'hi' })}\n`);
setTimeout(() => { res.write(`${JSON.stringify({ data: 'bye' })}\n`); }, 50);
setTimeout(() => { res.destroy(); }, 100); }
if (p === '/chunked/split-ending') { res.socket.write('HTTP/1.1 200\r\nTransfer-Encoding: chunked\r\n\r\n'); res.socket.write('3\r\nfoo\r\n3\r\nbar\r\n');
setTimeout(() => { res.socket.write('0\r\n'); }, 10);
setTimeout(() => { res.socket.end('\r\n'); }, 20); }
if (p === '/chunked/multiple-ending') { res.socket.write('HTTP/1.1 200\r\nTransfer-Encoding: chunked\r\n\r\n'); res.socket.write('3\r\nfoo\r\n3\r\nbar\r\n0\r\n\r\n'); res.end(); }
if (p === '/error/json') { res.statusCode = 200; res.setHeader('Content-Type', 'application/json'); res.end('invalid json'); }
if (p === '/no-content') { res.statusCode = 204; res.end(); }
if (p === '/no-content/gzip') { res.statusCode = 204; res.setHeader('Content-Encoding', 'gzip'); res.end(); }
if (p === '/no-content/brotli') { res.statusCode = 204; res.setHeader('Content-Encoding', 'br'); res.end(); }
if (p === '/not-modified') { res.statusCode = 304; res.end(); }
if (p === '/not-modified/gzip') { res.statusCode = 304; res.setHeader('Content-Encoding', 'gzip'); res.end(); }
if (p === '/inspect') { res.statusCode = 200; res.setHeader('Content-Type', 'application/json'); res.setHeader('X-Inspect', 'inspect'); let body = ''; request.on('data', c => { body += c; }); request.on('end', () => { // Convert rawHeaders array to an object preserving original casing const rawHeadersObj = {}; for (let i = 0; i < request.rawHeaders.length; i += 2) { rawHeadersObj[request.rawHeaders[i]] = request.rawHeaders[i + 1]; } res.end( JSON.stringify({ inspect: true, method: request.method, url: request.url, headers: request.headers, rawHeaders: rawHeadersObj, body, }) ); }); }
if (p === '/multipart') { res.statusCode = 200; res.setHeader('Content-Type', 'application/json'); const busboy = new Busboy({ headers: request.headers }); let body = ''; busboy.on('file', async (fieldName, file, fileName) => { body += `${fieldName}=${fileName}`; // consume file data // eslint-disable-next-line no-empty, no-unused-vars for await (const c of file) { } });
busboy.on('field', (fieldName, value) => { body += `${fieldName}=${value}`; }); busboy.on('finish', () => { res.end( JSON.stringify({ method: request.method, url: request.url, headers: request.headers, body, }) ); }); request.pipe(busboy); }
if (p === '/m%C3%B6bius') { res.statusCode = 200; res.setHeader('Content-Type', 'text/plain'); res.end('ok'); } }}