/ 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 : response_stream_spec.js

var should = require('should'),
    needle = require('./../'),
    http   = require('http'),
    stream = require('stream'),
    fs     = require('fs'),
    port   = 11111,
    server;

describe('response streams', function() {

describe('when the server sends back json', function(){

before(function() {
      server = http.createServer(function(req, res) {
        res.setHeader('Content-Type', 'application/json')
        res.end('{"foo":"bar"}')
      }).listen(port);
    });

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

describe('and the client uses streams', function(){

it('should create a proper streams2 stream', function(done) {
        var stream = needle.get('localhost:' + port)

// newer node versions set this to null instead of false
        var bool = !!stream._readableState.flowing;
        should.equal(false, bool);

var readableCalled = false;
        stream.on('readable', function() {
          readableCalled = true;
        })

stream.on('done', function() {
          readableCalled.should.be.true;
          done();
        });

stream.resume()

})

it('emits a single data item which is our JSON object', function(done) {
        var stream = needle.get('localhost:' + port)

var chunks = [];
        stream.on('readable', function () {
          while (chunk = this.read()) {
            chunk.should.be.an.Object;
            chunks.push(chunk);
          }
        })

stream.on('done', function () {
          chunks.should.have.length(1)
          chunks[0].should.have.property('foo', 'bar');
          done();
        });
      })

it('emits a raw buffer if we do not want to parse JSON', function(done) {
        var stream  = needle.get('localhost:' + port, { parse: false })

var chunks = [];
        stream.on('readable', function () {
          while (chunk = this.read()) {
            Buffer.isBuffer(chunk).should.be.true;
            chunks.push(chunk);
          }
        })

stream.on('done', function() {
          var body = Buffer.concat(chunks).toString();
          body.should.equal('{"foo":"bar"}')
          done();
        });
      })

})
  })

describe('when the server sends back what was posted to it', function () {
    var file = 'asdf.txt';

before(function(done){
      server = http.createServer(function(req, res) {
        res.setHeader('Content-Type', 'application/octet')
        req.pipe(res);
      }).listen(port);

fs.writeFile(file, 'contents of stream', done);
    });

after(function(done){
      server.close();
      fs.unlink(file, done);
    })

it('can PUT a stream', function (done) {
      var stream = needle.put('localhost:' + port, fs.createReadStream(file), { stream: true });

var chunks = [];
      stream.on('readable', function () {
        while (chunk = this.read()) {
          Buffer.isBuffer(chunk).should.be.true;
          chunks.push(chunk);
        }
      })

stream.on('end', function () {
        var body = Buffer.concat(chunks).toString();
          body.should.equal('contents of stream')
          done();
      });
    });

it('can PATCH a stream', function (done) {
      var stream = needle.patch('localhost:' + port, fs.createReadStream(file), { stream: true });

var chunks = [];
      stream.on('readable', function () {
        while (chunk = this.read()) {
          Buffer.isBuffer(chunk).should.be.true;
          chunks.push(chunk);
        }
      })

stream.on('end', function () {
        var body = Buffer.concat(chunks).toString();
          body.should.equal('contents of stream')
          done();
      });
    });
  })
})

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.