test-piped-redirect.js

'use strict'

var http = require('http')
  , request = require('../index')
  , tape = require('tape')

var port1 = 6767
  , port2 = 6768

var s1 = http.createServer(function(req, resp) {
  if (req.url === '/original') {
    resp.writeHeader(302, {
      'location': '/redirected'
    })
    resp.end()
  } else if (req.url === '/redirected') {
    resp.writeHeader(200, {
      'content-type': 'text/plain'
    })
    resp.write('OK')
    resp.end()
  }
})

var s2 = http.createServer(function(req, resp) {
  var x = request('http://localhost:' + port1 + '/original')
  req.pipe(x)
  x.pipe(resp)
})

tape('setup', function(t) {
  s1.listen(port1, function() {
    s2.listen(port2, function() {
      t.end()
    })
  })
})

tape('piped redirect', function(t) {
  request('http://localhost:' + port2 + '/original', function(err, res, body) {
    t.equal(err, null)
    t.equal(body, 'OK')
    t.end()
  })
})

tape('cleanup', function(t) {
  s1.close()
  s2.close()
  t.end()
})