test.js

var tape = require('tape')
var concat = require('concat-stream')
var http = require('http')
var docker = require('./')

var server = http.createServer(function (req, res) {
  if (req.method === 'POST') return req.pipe(res)

  if (req.url === '/error') {
    res.statusCode = 500
    res.end('error message')
    return
  }

  res.end(JSON.stringify({
    method: req.method,
    path: req.url
  }))
})

server.listen(0, function () {
  server.unref()

  var request = docker({ssl: false, host: server.address().port})

  tape('get json', function (t) {
    request.get('/', {json: true, qs: {foo: 'bar'}}, function (err, body) {
      t.ok(!err)
      t.same(body.method, 'GET')
      t.same(body.path, '/?foo=bar')
      t.end()
    })
  })

  tape('get stream', function (t) {
    request.get('/', function (err, response) {
      t.ok(!err)
      response.pipe(concat(function (buf) {
        t.same(buf.toString(), '{"method":"GET","path":"/"}')
        t.end()
      }))
    })
  })

  tape('post stream', function (t) {
    var post = request.post('/', function (err, response) {
      t.ok(!err)
      response.pipe(concat(function (buf) {
        t.same(buf.toString(), 'hello world')
        t.end()
      }))
    })

    post.write('hello')
    post.end(' world')
  })

  tape('post json', function (t) {
    request.post('/', {json: {method: 'GET', path: '/'}}, function (err, body) {
      t.ok(!err)
      t.same(body.method, 'GET')
      t.same(body.path, '/')
      t.end()
    })
  })

  tape('get error', function (t) {
    request.get('/error', function (err) {
      t.ok(err)
      t.same(err.message, 'error message')
      t.end()
    })
  })
})