/ var / www / html / events / node_modules / needle / test / [ HOME SHELL ]

Name	Size	Permission	Action
utils	[ DIR ]	drwxrwxr-x
basic_auth_spec.js	6 KB	-rw-rw-r--
compression_spec.js	2.96 KB	-rw-rw-r--
cookies_spec.js	9.9 KB	-rw-rw-r--
decoder_spec.js	2.18 KB	-rw-rw-r--
errors_spec.js	6.15 KB	-rw-rw-r--
headers_spec.js	5.67 KB	-rw-rw-r--
helpers.js	1.5 KB	-rw-rw-r--
long_string_spec.js	641 B	-rw-rw-r--
output_spec.js	7.12 KB	-rw-rw-r--
parsing_spec.js	13.25 KB	-rw-rw-r--
post_data_spec.js	32.34 KB	-rw-rw-r--
proxy_spec.js	4.86 KB	-rw-rw-r--
querystring_spec.js	2.27 KB	-rw-rw-r--
redirect_spec.js	10.74 KB	-rw-rw-r--
redirect_with_timeout.js	1.32 KB	-rw-rw-r--
request_stream_spec.js	5.22 KB	-rw-rw-r--
response_stream_spec.js	3.63 KB	-rw-rw-r--
socket_pool_spec.js	1.72 KB	-rw-rw-r--
url_spec.js	2.77 KB	-rw-rw-r--

Code Editor : errors_spec.js

var needle  = require('../'),
    sinon   = require('sinon'),
    should  = require('should'),
    http    = require('http'),
    Emitter = require('events').EventEmitter,
    helpers = require('./helpers');

var get_catch = function(url, opts) {
  var err;
  try {
    needle.get(url, opts);
  } catch(e) {
    err = e;
  }
  return err;
}

describe('errors', function() {

after(function(done) {
    setTimeout(done, 100)
  })

describe('when host does not exist', function() {

var url = 'http://unexistinghost/foo';

describe('with callback', function() {

it('does not throw', function() {
        var ex = get_catch(url);
        should.not.exist(ex);
      })

it('callbacks an error', function(done) {
        needle.get(url, function(err) {
          err.should.be.a.Error;
          done();
        })
      })

it('error should be ENOTFOUND or EADDRINFO or EAI_AGAIN', function(done) {
        needle.get(url, function(err) {
          err.code.should.match(/ENOTFOUND|EADDRINFO|EAI_AGAIN/)
          done();
        })
      })

it('does not callback a response', function(done) {
        needle.get(url, function(err, resp) {
          should.not.exist(resp);
          done();
        })
      })

it('does not emit an error event', function(done) {
        var emitted = false;
        var req = needle.get(url, function(err, resp) { })

req.on('error', function() {
          emitted = true;
        })

setTimeout(function() {
          emitted.should.eql(false);
          done();
        }, 100);
      })

})

describe('without callback', function() {

it('does not throw', function() {
        var ex = get_catch(url);
        should.not.exist(ex);
      })

it('emits end event once, with error', function(done) {
        var callcount = 0,
            stream = needle.get(url);

stream.on('done', function(err) {
          callcount++;
        })

setTimeout(function() {
          callcount.should.equal(1);
          done();
        }, 200)
      })

it('error should be ENOTFOUND or EADDRINFO or EAI_AGAIN', function(done) {
        var errorific,
            stream = needle.get(url);

stream.on('done', function(err) {
          errorific = err;
        })

setTimeout(function() {
          should.exist(errorific);
          errorific.code.should.match(/ENOTFOUND|EADDRINFO|EAI_AGAIN/)
          done();
        }, 200)
      })

it('does not emit a readable event', function(done) {
        var called = false,
            stream = needle.get(url);

stream.on('readable', function() {
          called = true;
        })

setTimeout(function() {
          called.should.be.false;
          done();
        }, 50)
      })

it('does not emit an error event', function(done) {
        var emitted = false,
            req = needle.get(url);

req.on('error', function() {
          emitted = true;
        })

setTimeout(function() {
          emitted.should.eql(false);
          done();
        }, 100);
      })

})

})

describe('when request times out waiting for response', function() {

var server,
        url = 'http://localhost:3333/foo';

var send_request = function(cb) {
      return needle.get(url, { response_timeout: 200 }, cb);
    }

before(function() {
      server = helpers.server({ port: 3333, wait: 1000 });
    })

after(function() {
      server.close();
    })

describe('with callback', function() {

it('aborts the request', function(done) {

var time = new Date();

send_request(function(err) {
          var timediff = (new Date() - time);
          timediff.should.be.within(200, 300);
          done();
        })

})

it('callbacks an error', function(done) {
        send_request(function(err) {
          err.should.be.a.Error;
          done();
        })
      })

it('error should be ECONNRESET', function(done) {
        send_request(function(err) {
          err.code.should.equal('ECONNRESET')
          done();
        })
      })

it('does not callback a response', function(done) {
        send_request(function(err, resp) {
          should.not.exist(resp);
          done();
        })
      })

it('does not emit an error event', function(done) {
        var emitted = false;

var req = send_request(function(err, resp) {
          should.not.exist(resp);
        })

req.on('error', function() {
          emitted = true;
        })

setTimeout(function() {
          emitted.should.eql(false);
          done();
        }, 350);
      })

})

describe('without callback', function() {

it('emits done event once, with error', function(done) {
        var called = 0,
            stream = send_request();

stream.on('done', function(err) {
          called++;
        })

setTimeout(function() {
          called.should.equal(1);
          done();
        }, 250)
      })

it('aborts the request', function(done) {

var time = new Date();
        var stream = send_request();

stream.on('done', function(err) {
          var timediff = (new Date() - time);
          timediff.should.be.within(200, 300);
          done();
        })

})

it('error should be ECONNRESET', function(done) {
        var error,
            stream = send_request();

stream.on('done', function(err) {
          error = err;
        })

setTimeout(function() {
          error.code.should.equal('ECONNRESET')
          done();
        }, 250)
      })

it('does not emit a readable event', function(done) {
        var called = false,
            stream = send_request();

stream.on('readable', function() {
          called = true;
        })

setTimeout(function() {
          called.should.be.false;
          done();
        }, 250)
      })

it('does not emit an error event', function(done) {
        var emitted = false;
        var req = send_request();

req.on('error', function() {
          emitted = true;
        })

setTimeout(function() {
          emitted.should.eql(false);
          done();
        }, 100);
      })

})

})

})

Urban Research Lab

Urban Research Lab

The Urban Research Lab (URL) at IIIT-Delhi was established in 2020, during a time when the pandemic brought the complexities of urban life more visible than ever. What started as an initiative by faculty and students has grown into a collaborative space for critically exploring and reimagining the urban questions through research, dialogue, and interdisciplinary engagement.