integration-test.js

/*eslint-env mocha*/
'use strict';

const { assert, refute, match, sinon } = require('@sinonjs/referee-sinon');
const http = require('http');
const request = require('..');

/**
 * @typedef {import('http').IncomingMessage} IncomingMessage
 */

describe('integration', () => {
  let server;

  afterEach(() => {
    server.close();
  });

  it('request timeout', (done) => {
    server = http.createServer((_req, _res) => {});
    server.listen(() => {
      const onError = sinon.fake();
      const req = request({
        protocol: 'http:',
        hostname: 'localhost',
        port: server.address().port,
        timeout: 10
      }, (err) => {
        refute.isNull(err);
        assert.equals(/** @type {Error} */ (err).message, 'Request timeout');
        setTimeout(() => {
          assert.calledOnceWith(onError, match({ message: 'socket hang up' }));
          done();
        }, 10);
      });
      req.on('error', onError);
    });
  });

  it('request redirect', (done) => {
    server = http.createServer((req, res) => {
      if (req.url === '/') {
        res.statusCode = 302;
        res.setHeader('location', '/some-path');
      } else if (req.url === '/some-path') {
        res.statusCode = 200;
        res.setHeader('content-type', 'application/json');
        res.write(JSON.stringify({ hello: 'redirect' }));
      } else {
        res.statusCode = 500;
      }
      res.end();
    });
    server.listen(() => {
      request({
        protocol: 'http:',
        hostname: 'localhost',
        port: server.address().port,
        path: '/',
        expect: [200, 302]
      }, (err, json, res) => {
        assert.isNull(err);
        assert.equals(/** @type {IncomingMessage} */ (res).statusCode, 200);
        assert.equals(json, { hello: 'redirect' });
        done();
      });
    });
  });
});