deno.land / x / ky@v0.31.3 / test / main.ts
نووسراو ببینە
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703import {Buffer} from 'node:buffer';import test from 'ava';import delay from 'delay';import {expectTypeOf} from 'expect-type';import ky, {TimeoutError} from '../source/index.js';import {createHttpTestServer} from './helpers/create-http-test-server.js';import {parseRawBody} from './helpers/parse-body.js';
const fixture = 'fixture';
test('ky()', async t => { const server = await createHttpTestServer(); server.get('/', (_request, response) => { response.end(); });
const {ok} = await ky(server.url); t.true(ok);
await server.close();});
test('GET request', async t => { const server = await createHttpTestServer(); server.get('/', (request, response) => { response.end(request.method); });
t.is(await ky(server.url).text(), 'GET');
await server.close();});
test('POST request', async t => { const server = await createHttpTestServer(); server.post('/', (request, response) => { response.end(request.method); });
t.is(await ky.post(server.url).text(), 'POST');
await server.close();});
test('PUT request', async t => { const server = await createHttpTestServer(); server.put('/', (request, response) => { response.end(request.method); });
t.is(await ky.put(server.url).text(), 'PUT');
await server.close();});
test('PATCH request', async t => { const server = await createHttpTestServer(); server.patch('/', (request, response) => { response.end(request.method); });
t.is(await ky.patch(server.url).text(), 'PATCH');
await server.close();});
test('HEAD request', async t => { t.plan(2);
const server = await createHttpTestServer(); server.head('/', (request, response) => { response.end(request.method); t.pass(); });
t.is(await ky.head(server.url).text(), '');
await server.close();});
test('DELETE request', async t => { const server = await createHttpTestServer(); server.delete('/', (request, response) => { response.end(request.method); });
t.is(await ky.delete(server.url).text(), 'DELETE');
await server.close();});
test('POST JSON', async t => { t.plan(2);
const server = await createHttpTestServer(); server.post('/', async (request, response) => { t.is(request.headers['content-type'], 'application/json'); response.json(request.body); });
const json = { foo: true, };
const responseJson = await ky.post(server.url, {json}).json();
t.deepEqual(responseJson, json);
await server.close();});
test('cannot use `body` option with GET or HEAD method', t => { t.throws( () => { void ky.get('https://example.com', {body: 'foobar'}); }, { message: 'Request with GET/HEAD method cannot have body', }, );
t.throws( () => { void ky.head('https://example.com', {body: 'foobar'}); }, { message: 'Request with GET/HEAD method cannot have body', }, );});
test('cannot use `json` option with GET or HEAD method', t => { t.throws( () => { void ky.get('https://example.com', {json: {}}); }, { message: 'Request with GET/HEAD method cannot have body', }, );
t.throws( () => { void ky.head('https://example.com', {json: {}}); }, { message: 'Request with GET/HEAD method cannot have body', }, );});
test('`json` option overrides the `body` option', async t => { t.plan(2);
const server = await createHttpTestServer(); server.post('/', async (request, response) => { t.is(request.headers['content-type'], 'application/json'); response.json(request.body); });
const json = { foo: 'bar', };
const responseJson = await ky .post(server.url, { body: 'hello', json, }) .json();
t.deepEqual(responseJson, json);
await server.close();});
test('custom headers', async t => { const server = await createHttpTestServer(); server.get('/', (request, response) => { response.end(request.headers['unicorn']); });
t.is( await ky(server.url, { headers: { unicorn: fixture, }, }).text(), fixture, );
await server.close();});
test('JSON with custom Headers instance', async t => { t.plan(3);
const server = await createHttpTestServer(); server.post('/', async (request, response) => { t.is(request.headers['unicorn'], 'rainbow'); t.is(request.headers['content-type'], 'application/json'); response.json(request.body); });
const json = { foo: true, };
const responseJson = await ky .post(server.url, { headers: new Headers({unicorn: 'rainbow'}), json, }) .json();
t.deepEqual(responseJson, json);
await server.close();});
test('.json() with custom accept header', async t => { t.plan(2);
const server = await createHttpTestServer(); server.get('/', async (request, response) => { t.is(request.headers.accept, 'foo/bar'); response.json({}); });
const responseJson = await ky(server.url, { headers: {accept: 'foo/bar'}, }).json();
t.deepEqual(responseJson, {});
await server.close();});
test('.json() with 200 response and empty body', async t => { t.plan(2);
const server = await createHttpTestServer(); server.get('/', async (request, response) => { t.is(request.headers.accept, 'application/json'); response.status(200).end(); });
await t.throwsAsync(ky(server.url).json(), { message: /Unexpected end of JSON input/, });
await server.close();});
test('.json() with 204 response and empty body', async t => { t.plan(2);
const server = await createHttpTestServer(); server.get('/', async (request, response) => { t.is(request.headers.accept, 'application/json'); response.status(204).end(); });
const responseJson = await ky(server.url).json();
t.is(responseJson, '');
await server.close();});
test('timeout option', async t => { t.plan(2); let requestCount = 0;
const server = await createHttpTestServer(); server.get('/', async (_request, response) => { requestCount++; await delay(2000); response.end(fixture); });
await t.throwsAsync(ky(server.url, {timeout: 1000}).text(), { instanceOf: TimeoutError, });
t.is(requestCount, 1);
await server.close();});
test('timeout:false option', async t => { let requestCount = 0;
const server = await createHttpTestServer(); server.get('/', async (_request, response) => { requestCount++; await delay(1000); response.end(fixture); });
await t.notThrowsAsync(ky(server.url, {timeout: false}).text());
t.is(requestCount, 1);
await server.close();});
test('invalid timeout option', async t => { // #117 let requestCount = 0;
const server = await createHttpTestServer(); server.get('/', async (_request, response) => { requestCount++; await delay(1000); response.end(fixture); });
await t.throwsAsync(ky(server.url, {timeout: 21_474_836_470}).text(), { instanceOf: RangeError, message: 'The `timeout` option cannot be greater than 2147483647', });
t.is(requestCount, 0);
await server.close();});
test('timeout option is cancelled when the promise is resolved', async t => { const server = await createHttpTestServer();
server.get('/', (request, response) => { response.end(request.method); });
const start = Date.now();
await ky(server.url, {timeout: 2000});
const duration = start - Date.now();
t.true(duration < 10);
await server.close();});
test('searchParams option', async t => { const server = await createHttpTestServer();
server.get('/', (request, response) => { response.end(request.url.slice(1)); });
const arrayParameters = [ ['cats', 'meow'], ['dogs', 'true'], ['opossums', 'false'], ]; const objectParameters = { cats: 'meow', dogs: 'true', opossums: 'false', }; const searchParameters = new URLSearchParams(arrayParameters); const stringParameters = '?cats=meow&dogs=true&opossums=false'; const customStringParameters = '?cats&dogs[0]=true&dogs[1]=false';
t.is(await ky(server.url, {searchParams: arrayParameters}).text(), stringParameters); t.is(await ky(server.url, {searchParams: objectParameters}).text(), stringParameters); t.is(await ky(server.url, {searchParams: searchParameters}).text(), stringParameters); t.is(await ky(server.url, {searchParams: stringParameters}).text(), stringParameters); t.is(await ky(server.url, {searchParams: customStringParameters}).text(), customStringParameters);
await server.close();});
test('throwHttpErrors option', async t => { const server = await createHttpTestServer(); server.get('/', (_request, response) => { response.sendStatus(500); });
await t.notThrowsAsync(ky.get(server.url, {throwHttpErrors: false}).text());
await server.close();});
test('throwHttpErrors option with POST', async t => { const server = await createHttpTestServer(); server.post('/', (_request, response) => { response.sendStatus(500); });
await t.notThrowsAsync(ky.post(server.url, {throwHttpErrors: false}).text());
await server.close();});
test('throwHttpErrors:false does not suppress timeout errors', async t => { let requestCount = 0;
const server = await createHttpTestServer(); server.get('/', async (_request, response) => { requestCount++; await delay(1000); response.sendStatus(500); });
await t.throwsAsync( ky(server.url, {throwHttpErrors: false, timeout: 500}).text(), {instanceOf: TimeoutError}, );
t.is(requestCount, 1);
await server.close();});
test('ky.create()', async t => { const server = await createHttpTestServer(); server.get('/', (request, response) => { // eslint-disable-next-line @typescript-eslint/restrict-template-expressions response.end(`${request.headers['unicorn']} - ${request.headers['rainbow']}`); });
const extended = ky.create({ headers: { rainbow: 'rainbow', }, });
t.is( await extended(server.url, { headers: { unicorn: 'unicorn', }, }).text(), 'unicorn - rainbow', );
const {ok} = await extended.head(server.url); t.true(ok);
await server.close();});
test('ky.create() throws when given non-object argument', t => { // eslint-disable-next-line @typescript-eslint/no-empty-function const nonObjectValues = [true, 666, 'hello', [], null, () => {}, Symbol('ky')];
for (const value of nonObjectValues) { t.throws( () => { // @ts-expect-error ky.create(value); }, { instanceOf: TypeError, message: 'The `options` argument must be an object', }, ); }});
test('ky.create() with deep array', async t => { const server = await createHttpTestServer(); server.get('/', (_request, response) => { response.end(); });
let isOriginBeforeRequestTrigged = false; let isExtendBeforeRequestTrigged = false;
const extended = ky.create({ hooks: { beforeRequest: [ () => { isOriginBeforeRequestTrigged = true; }, ], }, });
await extended(server.url, { hooks: { beforeRequest: [ () => { isExtendBeforeRequestTrigged = true; }, ], }, });
t.is(isOriginBeforeRequestTrigged, true); t.is(isExtendBeforeRequestTrigged, true);
const {ok} = await extended.head(server.url); t.true(ok);
await server.close();});
test('ky.create() does not mangle search params', async t => { const server = await createHttpTestServer(); server.get('/', (request, response) => { response.end(request.url); });
const instance = ky.create({searchParams: {}}); t.is(await instance.get(server.url, {searchParams: {}}).text(), '/?');
await server.close();});
test('ky.extend()', async t => { const server = await createHttpTestServer(); server.get('/', (_request, response) => { response.end(); });
let isOriginBeforeRequestTrigged = false; let isExtendBeforeRequestTrigged = false;
const extended = ky .extend({ hooks: { beforeRequest: [ () => { isOriginBeforeRequestTrigged = true; }, ], }, }) .extend({ hooks: { beforeRequest: [ () => { isExtendBeforeRequestTrigged = true; }, ], }, });
await extended(server.url);
t.is(isOriginBeforeRequestTrigged, true); t.is(isExtendBeforeRequestTrigged, true);
const {ok} = await extended.head(server.url); t.true(ok);
await server.close();});
test('throws AbortError when aborted by user', async t => { const server = await createHttpTestServer(); // eslint-disable-next-line @typescript-eslint/no-empty-function server.get('/', () => {});
const abortController = new AbortController(); const {signal} = abortController; const response = ky(server.url, {signal}); abortController.abort();
await t.throwsAsync(response, {name: 'AbortError'});});
test('supports Request instance as input', async t => { const server = await createHttpTestServer(); const inputRequest = new Request(server.url, {method: 'POST'});
server.post('/', (request, response) => { response.end(request.method); });
t.is(await ky(inputRequest).text(), inputRequest.method);
await server.close();});
test('throws when input is not a string, URL, or Request', t => { t.throws( () => { // @ts-expect-error void ky.get(0); }, { message: '`input` must be a string, URL, or Request', }, );});
test('options override Request instance method', async t => { const server = await createHttpTestServer(); const inputRequest = new Request(server.url, {method: 'GET'});
server.post('/', (request, response) => { response.end(request.method); });
t.is(await ky(inputRequest, {method: 'POST'}).text(), 'POST');
await server.close();});
test('options override Request instance body', async t => { const server = await createHttpTestServer({bodyParser: false});
const requestBody = JSON.stringify({test: true}); const expectedBody = JSON.stringify({test: false});
const inputRequest = new Request(server.url, { method: 'POST', body: requestBody, });
server.post('/', (request, response) => { const body: Buffer[] = [];
request.on('data', (chunk: Buffer) => { body.push(chunk); });
request.on('end', () => { const bodyAsString = Buffer.concat(body).toString();
t.is(bodyAsString, expectedBody); response.end(); }); });
await ky(inputRequest, {body: expectedBody});
await server.close();});
test('POST JSON with falsey value', async t => { // #222 const server = await createHttpTestServer({bodyParser: false}); server.post('/', async (request, response) => { response.json(await parseRawBody(request)); });
const json = false; const responseJson = await ky.post(server.url, {json}).json();
t.deepEqual(responseJson, json.toString());
await server.close();});
test('parseJson option with response.json()', async t => { const json = {hello: 'world'};
const server = await createHttpTestServer(); server.get('/', async (_request, response) => { response.json(json); });
const response = await ky.get(server.url, { parseJson: text => ({ ...JSON.parse(text), extra: 'extraValue', }), });
const responseJson = await response.json<{hello: string; extra: string}>();
expectTypeOf(responseJson).toMatchTypeOf({hello: 'world', extra: 'extraValue'});
t.deepEqual(responseJson, { ...json, extra: 'extraValue', });
await server.close();});
test('parseJson option with promise.json() shortcut', async t => { const json = {hello: 'world'};
const server = await createHttpTestServer(); server.get('/', async (_request, response) => { response.json(json); });
const responseJson = await ky .get(server.url, { parseJson: text => ({ ...JSON.parse(text), extra: 'extraValue', }), }) .json();
t.deepEqual(responseJson, { ...json, extra: 'extraValue', });
await server.close();});
ky
Version Info
a year ago
