File: /var/www/elite/node_modules/wreck/test/index.js
// Load modules
var Http = require('http');
var Https = require('https');
var Path = require('path');
var Fs = require('fs');
var Events = require('events');
var Stream = require('stream');
var Code = require('code');
var Hoek = require('hoek');
var Lab = require('lab');
var Wreck = require('../');
// Declare internals
var internals = {
payload: new Array(1640).join('0123456789') // make sure we have a payload larger than 16384 bytes for chunking coverage
};
// Test shortcuts
var lab = exports.lab = Lab.script();
var describe = lab.describe;
var it = lab.it;
var expect = Code.expect;
describe('request()', function () {
it('requests a resource with callback', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(Buffer.isBuffer(body)).to.equal(true);
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('requests a POST resource', function (done) {
var server = Http.createServer(function (req, res) {
expect(req.headers['content-length']).to.equal('16390');
res.writeHead(200, { 'Content-Type': 'text/plain' });
req.pipe(res);
});
server.listen(0, function () {
Wreck.request('post', 'http://localhost:' + server.address().port, { payload: internals.payload }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('requests a POST resource with unicode characters in payload', function (done) {
var server = Http.createServer(function (req, res) {
expect(req.headers['content-length']).to.equal('14');
res.writeHead(200, { 'Content-Type': 'text/plain' });
req.pipe(res);
});
server.listen(0, function () {
var unicodePayload = JSON.stringify({ field: 'ć' });
Wreck.request('post', 'http://localhost:' + server.address().port, { payload: unicodePayload }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(unicodePayload);
server.close();
done();
});
});
});
});
it('requests a POST resource with headers', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
req.pipe(res);
});
server.listen(0, function () {
Wreck.request('post', 'http://localhost:' + server.address().port, { headers: { 'user-agent': 'wreck' }, payload: internals.payload }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('requests a POST resource with stream payload', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
req.pipe(res);
});
server.listen(0, function () {
Wreck.request('post', 'http://localhost:' + server.address().port, { payload: Wreck.toReadableStream(internals.payload) }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('requests a resource without callback', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
server.close();
done();
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {});
});
});
it('cannot set agent and rejectUnauthorized at the same time', function (done) {
var fn = function () {
Wreck.request('get', 'https://google.com', { rejectUnauthorized: true, agent: new Https.Agent() }, function (err, res) { });
};
expect(fn).to.throw();
done();
});
it('cannot set a false agent and rejectUnauthorized at the same time', function (done) {
var fn = function () {
Wreck.request('get', 'https://google.com', { rejectUnauthorized: false, agent: false }, function (err, res) { });
};
expect(fn).to.throw();
done();
});
it('can set a null agent and rejectUnauthorized at the same time', function (done) {
var fn = function () {
Wreck.request('get', 'https://google.com', { rejectUnauthorized: false, agent: null }, function (err, res) { });
};
expect(fn).to.not.throw();
done();
});
it('requests an https resource', function (done) {
Wreck.request('get', 'https://google.com', { rejectUnauthorized: true }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.contain('<HTML>');
done();
});
});
});
it('requests an https resource with secure protocol set', function (done) {
Wreck.request('get', 'https://google.com', { rejectUnauthorized: true, secureProtocol: 'SSLv23_method' }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.contain('<HTML>');
done();
});
});
});
it('fails when an https resource has invalid certs and the default rejectUnauthorized', function (done) {
var httpsOptions = {
key: '-----BEGIN RSA PRIVATE KEY-----\nMIIEpAIBAAKCAQEA0UqyXDCqWDKpoNQQK/fdr0OkG4gW6DUafxdufH9GmkX/zoKz\ng/SFLrPipzSGINKWtyMvo7mPjXqqVgE10LDI3VFV8IR6fnART+AF8CW5HMBPGt/s\nfQW4W4puvBHkBxWSW1EvbecgNEIS9hTGvHXkFzm4xJ2e9DHp2xoVAjREC73B7JbF\nhc5ZGGchKw+CFmAiNysU0DmBgQcac0eg2pWoT+YGmTeQj6sRXO67n2xy/hA1DuN6\nA4WBK3wM3O4BnTG0dNbWUEbe7yAbV5gEyq57GhJIeYxRvveVDaX90LoAqM4cUH06\n6rciON0UbDHV2LP/JaH5jzBjUyCnKLLo5snlbwIDAQABAoIBAQDJm7YC3pJJUcxb\nc8x8PlHbUkJUjxzZ5MW4Zb71yLkfRYzsxrTcyQA+g+QzA4KtPY8XrZpnkgm51M8e\n+B16AcIMiBxMC6HgCF503i16LyyJiKrrDYfGy2rTK6AOJQHO3TXWJ3eT3BAGpxuS\n12K2Cq6EvQLCy79iJm7Ks+5G6EggMZPfCVdEhffRm2Epl4T7LpIAqWiUDcDfS05n\nNNfAGxxvALPn+D+kzcSF6hpmCVrFVTf9ouhvnr+0DpIIVPwSK/REAF3Ux5SQvFuL\njPmh3bGwfRtcC5d21QNrHdoBVSN2UBLmbHUpBUcOBI8FyivAWJhRfKnhTvXMFG8L\nwaXB51IZAoGBAP/E3uz6zCyN7l2j09wmbyNOi1AKvr1WSmuBJveITouwblnRSdvc\nsYm4YYE0Vb94AG4n7JIfZLKtTN0xvnCo8tYjrdwMJyGfEfMGCQQ9MpOBXAkVVZvP\ne2k4zHNNsfvSc38UNSt7K0HkVuH5BkRBQeskcsyMeu0qK4wQwdtiCoBDAoGBANF7\nFMppYxSW4ir7Jvkh0P8bP/Z7AtaSmkX7iMmUYT+gMFB5EKqFTQjNQgSJxS/uHVDE\nSC5co8WGHnRk7YH2Pp+Ty1fHfXNWyoOOzNEWvg6CFeMHW2o+/qZd4Z5Fep6qCLaa\nFvzWWC2S5YslEaaP8DQ74aAX4o+/TECrxi0z2lllAoGAdRB6qCSyRsI/k4Rkd6Lv\nw00z3lLMsoRIU6QtXaZ5rN335Awyrfr5F3vYxPZbOOOH7uM/GDJeOJmxUJxv+cia\nPQDflpPJZU4VPRJKFjKcb38JzO6C3Gm+po5kpXGuQQA19LgfDeO2DNaiHZOJFrx3\nm1R3Zr/1k491lwokcHETNVkCgYBPLjrZl6Q/8BhlLrG4kbOx+dbfj/euq5NsyHsX\n1uI7bo1Una5TBjfsD8nYdUr3pwWltcui2pl83Ak+7bdo3G8nWnIOJ/WfVzsNJzj7\n/6CvUzR6sBk5u739nJbfgFutBZBtlSkDQPHrqA7j3Ysibl3ZIJlULjMRKrnj6Ans\npCDwkQKBgQCM7gu3p7veYwCZaxqDMz5/GGFUB1My7sK0hcT7/oH61yw3O8pOekee\nuctI1R3NOudn1cs5TAy/aypgLDYTUGQTiBRILeMiZnOrvQQB9cEf7TFgDoRNCcDs\nV/ZWiegVB/WY7H0BkCekuq5bHwjgtJTpvHGqQ9YD7RhE8RSYOhdQ/Q==\n-----END RSA PRIVATE KEY-----\n',
cert: '-----BEGIN CERTIFICATE-----\nMIIDBjCCAe4CCQDvLNml6smHlTANBgkqhkiG9w0BAQUFADBFMQswCQYDVQQGEwJV\nUzETMBEGA1UECAwKU29tZS1TdGF0ZTEhMB8GA1UECgwYSW50ZXJuZXQgV2lkZ2l0\ncyBQdHkgTHRkMB4XDTE0MDEyNTIxMjIxOFoXDTE1MDEyNTIxMjIxOFowRTELMAkG\nA1UEBhMCVVMxEzARBgNVBAgMClNvbWUtU3RhdGUxITAfBgNVBAoMGEludGVybmV0\nIFdpZGdpdHMgUHR5IEx0ZDCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB\nANFKslwwqlgyqaDUECv33a9DpBuIFug1Gn8Xbnx/RppF/86Cs4P0hS6z4qc0hiDS\nlrcjL6O5j416qlYBNdCwyN1RVfCEen5wEU/gBfAluRzATxrf7H0FuFuKbrwR5AcV\nkltRL23nIDRCEvYUxrx15Bc5uMSdnvQx6dsaFQI0RAu9weyWxYXOWRhnISsPghZg\nIjcrFNA5gYEHGnNHoNqVqE/mBpk3kI+rEVzuu59scv4QNQ7jegOFgSt8DNzuAZ0x\ntHTW1lBG3u8gG1eYBMquexoSSHmMUb73lQ2l/dC6AKjOHFB9Ouq3IjjdFGwx1diz\n/yWh+Y8wY1Mgpyiy6ObJ5W8CAwEAATANBgkqhkiG9w0BAQUFAAOCAQEAoSc6Skb4\ng1e0ZqPKXBV2qbx7hlqIyYpubCl1rDiEdVzqYYZEwmst36fJRRrVaFuAM/1DYAmT\nWMhU+yTfA+vCS4tql9b9zUhPw/IDHpBDWyR01spoZFBF/hE1MGNpCSXXsAbmCiVf\naxrIgR2DNketbDxkQx671KwF1+1JOMo9ffXp+OhuRo5NaGIxhTsZ+f/MA4y084Aj\nDI39av50sTRTWWShlN+J7PtdQVA5SZD97oYbeUeL7gI18kAJww9eUdmT0nEjcwKs\nxsQT1fyKbo7AlZBY4KSlUMuGnn0VnAsB9b+LxtXlDfnjyM8bVQx1uAfRo0DO8p/5\n3J5DTjAU55deBQ==\n-----END CERTIFICATE-----\n'
};
var server = Https.createServer(httpsOptions, function (req, res) {
res.writeHead(200);
res.end();
});
server.listen(0, function (err) {
expect(err).to.not.exist();
Wreck.request('get', 'https://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.exist();
done();
});
});
});
it('succeeds when an https resource has unauthorized certs and rejectUnauthorized is false', function (done) {
var httpsOptions = {
key: '-----BEGIN RSA PRIVATE KEY-----\nMIIEpAIBAAKCAQEA0UqyXDCqWDKpoNQQK/fdr0OkG4gW6DUafxdufH9GmkX/zoKz\ng/SFLrPipzSGINKWtyMvo7mPjXqqVgE10LDI3VFV8IR6fnART+AF8CW5HMBPGt/s\nfQW4W4puvBHkBxWSW1EvbecgNEIS9hTGvHXkFzm4xJ2e9DHp2xoVAjREC73B7JbF\nhc5ZGGchKw+CFmAiNysU0DmBgQcac0eg2pWoT+YGmTeQj6sRXO67n2xy/hA1DuN6\nA4WBK3wM3O4BnTG0dNbWUEbe7yAbV5gEyq57GhJIeYxRvveVDaX90LoAqM4cUH06\n6rciON0UbDHV2LP/JaH5jzBjUyCnKLLo5snlbwIDAQABAoIBAQDJm7YC3pJJUcxb\nc8x8PlHbUkJUjxzZ5MW4Zb71yLkfRYzsxrTcyQA+g+QzA4KtPY8XrZpnkgm51M8e\n+B16AcIMiBxMC6HgCF503i16LyyJiKrrDYfGy2rTK6AOJQHO3TXWJ3eT3BAGpxuS\n12K2Cq6EvQLCy79iJm7Ks+5G6EggMZPfCVdEhffRm2Epl4T7LpIAqWiUDcDfS05n\nNNfAGxxvALPn+D+kzcSF6hpmCVrFVTf9ouhvnr+0DpIIVPwSK/REAF3Ux5SQvFuL\njPmh3bGwfRtcC5d21QNrHdoBVSN2UBLmbHUpBUcOBI8FyivAWJhRfKnhTvXMFG8L\nwaXB51IZAoGBAP/E3uz6zCyN7l2j09wmbyNOi1AKvr1WSmuBJveITouwblnRSdvc\nsYm4YYE0Vb94AG4n7JIfZLKtTN0xvnCo8tYjrdwMJyGfEfMGCQQ9MpOBXAkVVZvP\ne2k4zHNNsfvSc38UNSt7K0HkVuH5BkRBQeskcsyMeu0qK4wQwdtiCoBDAoGBANF7\nFMppYxSW4ir7Jvkh0P8bP/Z7AtaSmkX7iMmUYT+gMFB5EKqFTQjNQgSJxS/uHVDE\nSC5co8WGHnRk7YH2Pp+Ty1fHfXNWyoOOzNEWvg6CFeMHW2o+/qZd4Z5Fep6qCLaa\nFvzWWC2S5YslEaaP8DQ74aAX4o+/TECrxi0z2lllAoGAdRB6qCSyRsI/k4Rkd6Lv\nw00z3lLMsoRIU6QtXaZ5rN335Awyrfr5F3vYxPZbOOOH7uM/GDJeOJmxUJxv+cia\nPQDflpPJZU4VPRJKFjKcb38JzO6C3Gm+po5kpXGuQQA19LgfDeO2DNaiHZOJFrx3\nm1R3Zr/1k491lwokcHETNVkCgYBPLjrZl6Q/8BhlLrG4kbOx+dbfj/euq5NsyHsX\n1uI7bo1Una5TBjfsD8nYdUr3pwWltcui2pl83Ak+7bdo3G8nWnIOJ/WfVzsNJzj7\n/6CvUzR6sBk5u739nJbfgFutBZBtlSkDQPHrqA7j3Ysibl3ZIJlULjMRKrnj6Ans\npCDwkQKBgQCM7gu3p7veYwCZaxqDMz5/GGFUB1My7sK0hcT7/oH61yw3O8pOekee\nuctI1R3NOudn1cs5TAy/aypgLDYTUGQTiBRILeMiZnOrvQQB9cEf7TFgDoRNCcDs\nV/ZWiegVB/WY7H0BkCekuq5bHwjgtJTpvHGqQ9YD7RhE8RSYOhdQ/Q==\n-----END RSA PRIVATE KEY-----\n',
cert: '-----BEGIN CERTIFICATE-----\nMIIDBjCCAe4CCQDvLNml6smHlTANBgkqhkiG9w0BAQUFADBFMQswCQYDVQQGEwJV\nUzETMBEGA1UECAwKU29tZS1TdGF0ZTEhMB8GA1UECgwYSW50ZXJuZXQgV2lkZ2l0\ncyBQdHkgTHRkMB4XDTE0MDEyNTIxMjIxOFoXDTE1MDEyNTIxMjIxOFowRTELMAkG\nA1UEBhMCVVMxEzARBgNVBAgMClNvbWUtU3RhdGUxITAfBgNVBAoMGEludGVybmV0\nIFdpZGdpdHMgUHR5IEx0ZDCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB\nANFKslwwqlgyqaDUECv33a9DpBuIFug1Gn8Xbnx/RppF/86Cs4P0hS6z4qc0hiDS\nlrcjL6O5j416qlYBNdCwyN1RVfCEen5wEU/gBfAluRzATxrf7H0FuFuKbrwR5AcV\nkltRL23nIDRCEvYUxrx15Bc5uMSdnvQx6dsaFQI0RAu9weyWxYXOWRhnISsPghZg\nIjcrFNA5gYEHGnNHoNqVqE/mBpk3kI+rEVzuu59scv4QNQ7jegOFgSt8DNzuAZ0x\ntHTW1lBG3u8gG1eYBMquexoSSHmMUb73lQ2l/dC6AKjOHFB9Ouq3IjjdFGwx1diz\n/yWh+Y8wY1Mgpyiy6ObJ5W8CAwEAATANBgkqhkiG9w0BAQUFAAOCAQEAoSc6Skb4\ng1e0ZqPKXBV2qbx7hlqIyYpubCl1rDiEdVzqYYZEwmst36fJRRrVaFuAM/1DYAmT\nWMhU+yTfA+vCS4tql9b9zUhPw/IDHpBDWyR01spoZFBF/hE1MGNpCSXXsAbmCiVf\naxrIgR2DNketbDxkQx671KwF1+1JOMo9ffXp+OhuRo5NaGIxhTsZ+f/MA4y084Aj\nDI39av50sTRTWWShlN+J7PtdQVA5SZD97oYbeUeL7gI18kAJww9eUdmT0nEjcwKs\nxsQT1fyKbo7AlZBY4KSlUMuGnn0VnAsB9b+LxtXlDfnjyM8bVQx1uAfRo0DO8p/5\n3J5DTjAU55deBQ==\n-----END CERTIFICATE-----\n'
};
var server = Https.createServer(httpsOptions, function (req, res) {
res.writeHead(200);
res.end();
});
server.listen(0, function (err) {
expect(err).to.not.exist();
Wreck.request('get', 'https://localhost:' + server.address().port, { rejectUnauthorized: false }, function (err, res) {
expect(err).to.not.exist();
done();
});
});
});
it('applies rejectUnauthorized when redirected', function (done) {
var httpsOptions = {
key: '-----BEGIN RSA PRIVATE KEY-----\nMIIEpAIBAAKCAQEA0UqyXDCqWDKpoNQQK/fdr0OkG4gW6DUafxdufH9GmkX/zoKz\ng/SFLrPipzSGINKWtyMvo7mPjXqqVgE10LDI3VFV8IR6fnART+AF8CW5HMBPGt/s\nfQW4W4puvBHkBxWSW1EvbecgNEIS9hTGvHXkFzm4xJ2e9DHp2xoVAjREC73B7JbF\nhc5ZGGchKw+CFmAiNysU0DmBgQcac0eg2pWoT+YGmTeQj6sRXO67n2xy/hA1DuN6\nA4WBK3wM3O4BnTG0dNbWUEbe7yAbV5gEyq57GhJIeYxRvveVDaX90LoAqM4cUH06\n6rciON0UbDHV2LP/JaH5jzBjUyCnKLLo5snlbwIDAQABAoIBAQDJm7YC3pJJUcxb\nc8x8PlHbUkJUjxzZ5MW4Zb71yLkfRYzsxrTcyQA+g+QzA4KtPY8XrZpnkgm51M8e\n+B16AcIMiBxMC6HgCF503i16LyyJiKrrDYfGy2rTK6AOJQHO3TXWJ3eT3BAGpxuS\n12K2Cq6EvQLCy79iJm7Ks+5G6EggMZPfCVdEhffRm2Epl4T7LpIAqWiUDcDfS05n\nNNfAGxxvALPn+D+kzcSF6hpmCVrFVTf9ouhvnr+0DpIIVPwSK/REAF3Ux5SQvFuL\njPmh3bGwfRtcC5d21QNrHdoBVSN2UBLmbHUpBUcOBI8FyivAWJhRfKnhTvXMFG8L\nwaXB51IZAoGBAP/E3uz6zCyN7l2j09wmbyNOi1AKvr1WSmuBJveITouwblnRSdvc\nsYm4YYE0Vb94AG4n7JIfZLKtTN0xvnCo8tYjrdwMJyGfEfMGCQQ9MpOBXAkVVZvP\ne2k4zHNNsfvSc38UNSt7K0HkVuH5BkRBQeskcsyMeu0qK4wQwdtiCoBDAoGBANF7\nFMppYxSW4ir7Jvkh0P8bP/Z7AtaSmkX7iMmUYT+gMFB5EKqFTQjNQgSJxS/uHVDE\nSC5co8WGHnRk7YH2Pp+Ty1fHfXNWyoOOzNEWvg6CFeMHW2o+/qZd4Z5Fep6qCLaa\nFvzWWC2S5YslEaaP8DQ74aAX4o+/TECrxi0z2lllAoGAdRB6qCSyRsI/k4Rkd6Lv\nw00z3lLMsoRIU6QtXaZ5rN335Awyrfr5F3vYxPZbOOOH7uM/GDJeOJmxUJxv+cia\nPQDflpPJZU4VPRJKFjKcb38JzO6C3Gm+po5kpXGuQQA19LgfDeO2DNaiHZOJFrx3\nm1R3Zr/1k491lwokcHETNVkCgYBPLjrZl6Q/8BhlLrG4kbOx+dbfj/euq5NsyHsX\n1uI7bo1Una5TBjfsD8nYdUr3pwWltcui2pl83Ak+7bdo3G8nWnIOJ/WfVzsNJzj7\n/6CvUzR6sBk5u739nJbfgFutBZBtlSkDQPHrqA7j3Ysibl3ZIJlULjMRKrnj6Ans\npCDwkQKBgQCM7gu3p7veYwCZaxqDMz5/GGFUB1My7sK0hcT7/oH61yw3O8pOekee\nuctI1R3NOudn1cs5TAy/aypgLDYTUGQTiBRILeMiZnOrvQQB9cEf7TFgDoRNCcDs\nV/ZWiegVB/WY7H0BkCekuq5bHwjgtJTpvHGqQ9YD7RhE8RSYOhdQ/Q==\n-----END RSA PRIVATE KEY-----\n',
cert: '-----BEGIN CERTIFICATE-----\nMIIDBjCCAe4CCQDvLNml6smHlTANBgkqhkiG9w0BAQUFADBFMQswCQYDVQQGEwJV\nUzETMBEGA1UECAwKU29tZS1TdGF0ZTEhMB8GA1UECgwYSW50ZXJuZXQgV2lkZ2l0\ncyBQdHkgTHRkMB4XDTE0MDEyNTIxMjIxOFoXDTE1MDEyNTIxMjIxOFowRTELMAkG\nA1UEBhMCVVMxEzARBgNVBAgMClNvbWUtU3RhdGUxITAfBgNVBAoMGEludGVybmV0\nIFdpZGdpdHMgUHR5IEx0ZDCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB\nANFKslwwqlgyqaDUECv33a9DpBuIFug1Gn8Xbnx/RppF/86Cs4P0hS6z4qc0hiDS\nlrcjL6O5j416qlYBNdCwyN1RVfCEen5wEU/gBfAluRzATxrf7H0FuFuKbrwR5AcV\nkltRL23nIDRCEvYUxrx15Bc5uMSdnvQx6dsaFQI0RAu9weyWxYXOWRhnISsPghZg\nIjcrFNA5gYEHGnNHoNqVqE/mBpk3kI+rEVzuu59scv4QNQ7jegOFgSt8DNzuAZ0x\ntHTW1lBG3u8gG1eYBMquexoSSHmMUb73lQ2l/dC6AKjOHFB9Ouq3IjjdFGwx1diz\n/yWh+Y8wY1Mgpyiy6ObJ5W8CAwEAATANBgkqhkiG9w0BAQUFAAOCAQEAoSc6Skb4\ng1e0ZqPKXBV2qbx7hlqIyYpubCl1rDiEdVzqYYZEwmst36fJRRrVaFuAM/1DYAmT\nWMhU+yTfA+vCS4tql9b9zUhPw/IDHpBDWyR01spoZFBF/hE1MGNpCSXXsAbmCiVf\naxrIgR2DNketbDxkQx671KwF1+1JOMo9ffXp+OhuRo5NaGIxhTsZ+f/MA4y084Aj\nDI39av50sTRTWWShlN+J7PtdQVA5SZD97oYbeUeL7gI18kAJww9eUdmT0nEjcwKs\nxsQT1fyKbo7AlZBY4KSlUMuGnn0VnAsB9b+LxtXlDfnjyM8bVQx1uAfRo0DO8p/5\n3J5DTjAU55deBQ==\n-----END CERTIFICATE-----\n'
};
var gen = 0;
var server = Https.createServer(httpsOptions, function (req, res) {
if (!gen++) {
res.writeHead(301, { 'Location': '/' });
res.end();
}
else {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end();
}
});
server.listen(0, function (err) {
expect(err).to.not.exist();
Wreck.request('get', 'https://localhost:' + server.address().port, { redirects: 1, rejectUnauthorized: false }, function (err, res) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
server.close();
done();
});
});
});
it('requests a resource with downstream dependency', function (done) {
var up = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
});
up.listen(0, function () {
var down = Http.createServer(function (req, res1) {
res1.writeHead(200, { 'Content-Type': 'text/plain' });
Wreck.request('get', 'http://localhost:' + up.address().port, { downstreamRes: res1 }, function (err, res2) {
expect(err).to.not.exist();
res2.pipe(res1);
});
});
down.listen(0, function () {
Wreck.request('get', 'http://localhost:' + down.address().port, {}, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
up.close();
down.close();
done();
});
});
});
});
});
it('does not follow redirections by default', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (!gen++) {
res.writeHead(301, { 'Location': 'http://localhost:' + server.address().port });
res.end();
}
else {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
}
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(301);
server.close();
done();
});
});
});
});
it('handles redirections', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (!gen++) {
res.writeHead(301, { 'Location': 'http://localhost:' + server.address().port });
res.end();
}
else {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
}
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { redirects: 1, beforeRedirect: null, redirected: null }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('handles redirections from http to https', function (done) {
var httpsOptions = {
key: '-----BEGIN RSA PRIVATE KEY-----\nMIIEpAIBAAKCAQEA0UqyXDCqWDKpoNQQK/fdr0OkG4gW6DUafxdufH9GmkX/zoKz\ng/SFLrPipzSGINKWtyMvo7mPjXqqVgE10LDI3VFV8IR6fnART+AF8CW5HMBPGt/s\nfQW4W4puvBHkBxWSW1EvbecgNEIS9hTGvHXkFzm4xJ2e9DHp2xoVAjREC73B7JbF\nhc5ZGGchKw+CFmAiNysU0DmBgQcac0eg2pWoT+YGmTeQj6sRXO67n2xy/hA1DuN6\nA4WBK3wM3O4BnTG0dNbWUEbe7yAbV5gEyq57GhJIeYxRvveVDaX90LoAqM4cUH06\n6rciON0UbDHV2LP/JaH5jzBjUyCnKLLo5snlbwIDAQABAoIBAQDJm7YC3pJJUcxb\nc8x8PlHbUkJUjxzZ5MW4Zb71yLkfRYzsxrTcyQA+g+QzA4KtPY8XrZpnkgm51M8e\n+B16AcIMiBxMC6HgCF503i16LyyJiKrrDYfGy2rTK6AOJQHO3TXWJ3eT3BAGpxuS\n12K2Cq6EvQLCy79iJm7Ks+5G6EggMZPfCVdEhffRm2Epl4T7LpIAqWiUDcDfS05n\nNNfAGxxvALPn+D+kzcSF6hpmCVrFVTf9ouhvnr+0DpIIVPwSK/REAF3Ux5SQvFuL\njPmh3bGwfRtcC5d21QNrHdoBVSN2UBLmbHUpBUcOBI8FyivAWJhRfKnhTvXMFG8L\nwaXB51IZAoGBAP/E3uz6zCyN7l2j09wmbyNOi1AKvr1WSmuBJveITouwblnRSdvc\nsYm4YYE0Vb94AG4n7JIfZLKtTN0xvnCo8tYjrdwMJyGfEfMGCQQ9MpOBXAkVVZvP\ne2k4zHNNsfvSc38UNSt7K0HkVuH5BkRBQeskcsyMeu0qK4wQwdtiCoBDAoGBANF7\nFMppYxSW4ir7Jvkh0P8bP/Z7AtaSmkX7iMmUYT+gMFB5EKqFTQjNQgSJxS/uHVDE\nSC5co8WGHnRk7YH2Pp+Ty1fHfXNWyoOOzNEWvg6CFeMHW2o+/qZd4Z5Fep6qCLaa\nFvzWWC2S5YslEaaP8DQ74aAX4o+/TECrxi0z2lllAoGAdRB6qCSyRsI/k4Rkd6Lv\nw00z3lLMsoRIU6QtXaZ5rN335Awyrfr5F3vYxPZbOOOH7uM/GDJeOJmxUJxv+cia\nPQDflpPJZU4VPRJKFjKcb38JzO6C3Gm+po5kpXGuQQA19LgfDeO2DNaiHZOJFrx3\nm1R3Zr/1k491lwokcHETNVkCgYBPLjrZl6Q/8BhlLrG4kbOx+dbfj/euq5NsyHsX\n1uI7bo1Una5TBjfsD8nYdUr3pwWltcui2pl83Ak+7bdo3G8nWnIOJ/WfVzsNJzj7\n/6CvUzR6sBk5u739nJbfgFutBZBtlSkDQPHrqA7j3Ysibl3ZIJlULjMRKrnj6Ans\npCDwkQKBgQCM7gu3p7veYwCZaxqDMz5/GGFUB1My7sK0hcT7/oH61yw3O8pOekee\nuctI1R3NOudn1cs5TAy/aypgLDYTUGQTiBRILeMiZnOrvQQB9cEf7TFgDoRNCcDs\nV/ZWiegVB/WY7H0BkCekuq5bHwjgtJTpvHGqQ9YD7RhE8RSYOhdQ/Q==\n-----END RSA PRIVATE KEY-----\n',
cert: '-----BEGIN CERTIFICATE-----\nMIIDBjCCAe4CCQDvLNml6smHlTANBgkqhkiG9w0BAQUFADBFMQswCQYDVQQGEwJV\nUzETMBEGA1UECAwKU29tZS1TdGF0ZTEhMB8GA1UECgwYSW50ZXJuZXQgV2lkZ2l0\ncyBQdHkgTHRkMB4XDTE0MDEyNTIxMjIxOFoXDTE1MDEyNTIxMjIxOFowRTELMAkG\nA1UEBhMCVVMxEzARBgNVBAgMClNvbWUtU3RhdGUxITAfBgNVBAoMGEludGVybmV0\nIFdpZGdpdHMgUHR5IEx0ZDCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB\nANFKslwwqlgyqaDUECv33a9DpBuIFug1Gn8Xbnx/RppF/86Cs4P0hS6z4qc0hiDS\nlrcjL6O5j416qlYBNdCwyN1RVfCEen5wEU/gBfAluRzATxrf7H0FuFuKbrwR5AcV\nkltRL23nIDRCEvYUxrx15Bc5uMSdnvQx6dsaFQI0RAu9weyWxYXOWRhnISsPghZg\nIjcrFNA5gYEHGnNHoNqVqE/mBpk3kI+rEVzuu59scv4QNQ7jegOFgSt8DNzuAZ0x\ntHTW1lBG3u8gG1eYBMquexoSSHmMUb73lQ2l/dC6AKjOHFB9Ouq3IjjdFGwx1diz\n/yWh+Y8wY1Mgpyiy6ObJ5W8CAwEAATANBgkqhkiG9w0BAQUFAAOCAQEAoSc6Skb4\ng1e0ZqPKXBV2qbx7hlqIyYpubCl1rDiEdVzqYYZEwmst36fJRRrVaFuAM/1DYAmT\nWMhU+yTfA+vCS4tql9b9zUhPw/IDHpBDWyR01spoZFBF/hE1MGNpCSXXsAbmCiVf\naxrIgR2DNketbDxkQx671KwF1+1JOMo9ffXp+OhuRo5NaGIxhTsZ+f/MA4y084Aj\nDI39av50sTRTWWShlN+J7PtdQVA5SZD97oYbeUeL7gI18kAJww9eUdmT0nEjcwKs\nxsQT1fyKbo7AlZBY4KSlUMuGnn0VnAsB9b+LxtXlDfnjyM8bVQx1uAfRo0DO8p/5\n3J5DTjAU55deBQ==\n-----END CERTIFICATE-----\n'
};
var httpsServer = Https.createServer(httpsOptions, function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end();
});
httpsServer.listen(0, function (err) {
expect(err).to.not.exist();
var httpServer = Http.createServer(function (req, res) {
res.writeHead(302, { 'Location': 'https://127.0.0.1:' + httpsServer.address().port });
res.end();
});
httpServer.listen(0, function (err) {
expect(err).to.not.exist();
Wreck.request('get', 'http://localhost:' + httpServer.address().port, { redirects: 1, rejectUnauthorized: false }, function (err, res) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
httpServer.close();
httpsServer.close();
done();
});
});
});
});
it('handles redirections with relative location', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (!gen++) {
res.writeHead(301, { 'Location': '/' });
res.end();
}
else {
expect(req.url).to.equal('/');
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
}
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { redirects: 1 }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('reaches max redirections count', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (gen++ < 2) {
res.writeHead(301, { 'Location': 'http://localhost:' + server.address().port });
res.end();
}
else {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
}
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { redirects: 1 }, function (err, res) {
expect(err.message).to.equal('Maximum redirections reached');
server.close();
done();
});
});
});
it('handles malformed redirection response', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(301);
res.end();
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { redirects: 1 }, function (err, res) {
expect(err.message).to.equal('Received redirection without location');
server.close();
done();
});
});
});
it('handles redirections with POST stream payload', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (!gen++) {
res.writeHead(307, { 'Location': '/' });
res.end();
}
else {
res.writeHead(200, { 'Content-Type': 'text/plain' });
Wreck.read(req, null, function (err, res2) {
res.end(res2);
});
}
});
server.listen(0, function () {
var payload = new Array(1639).join('0123456789');
var stream = Wreck.toReadableStream(payload);
Wreck.request('post', 'http://localhost:' + server.address().port, { redirects: 1, payload: stream }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(payload);
server.close();
done();
});
});
});
});
it('calls beforeRedirect option callback before redirections', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (gen++ < 2) {
res.writeHead(301, { 'Location': 'http://localhost:' + server.address().port + '/redirected/' });
res.end();
}
else {
expect(req.url).to.equal('/redirected/');
expect(req.headers['x-test']).to.equal('Modified');
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
}
});
var beforeRedirectCallback = function (redirectMethod, statusCode, location, redirectOptions) {
expect(redirectMethod).to.equal('GET');
expect(statusCode).to.equal(301);
expect(location).to.equal('http://localhost:' + server.address().port + '/redirected/');
expect(redirectOptions).to.exist();
redirectOptions.headers = {
'x-test': 'Modified'
};
};
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { redirects: 5, beforeRedirect: beforeRedirectCallback }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('calls redirected option callback on redirections', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (gen++ < 2) {
res.writeHead(301, { 'Location': 'http://localhost:' + server.address().port + '/redirected/' });
res.end();
}
else {
expect(req.url).to.equal('/redirected/');
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(internals.payload);
}
});
var redirects = 0;
var redirectedCallback = function (statusCode, location, req) {
expect(statusCode).to.equal(301);
expect(location).to.equal('http://localhost:' + server.address().port + '/redirected/');
expect(req).to.exist();
redirects++;
};
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { redirects: 5, redirected: redirectedCallback }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
expect(redirects).to.equal(2);
server.close();
done();
});
});
});
});
it('rejects non-function value for redirected option', function (done) {
var fn = function () {
Wreck.request('get', 'https://google.com', { redirects: 1, redirected: true }, function (err, res) { });
};
expect(fn).to.throw();
done();
});
it('handles request errors with a boom response', function (done) {
var server = Http.createServer(function (req, res) {
req.destroy();
res.end();
});
server.once('listening', function () {
Wreck.request('get', 'http://127.0.0.1:' + server.address().port, { payload: '' }, function (err) {
expect(err.code).to.equal('ECONNRESET');
done();
});
});
server.listen(0);
});
it('handles request errors with a boom response when payload is being sent', function (done) {
var server = Http.createServer(function (req, res) {
req.destroy();
res.end();
});
server.once('listening', function () {
Wreck.request('get', 'http://127.0.0.1:' + server.address().port, { payload: '' }, function (err) {
expect(err.code).to.equal('ECONNRESET');
done();
});
});
server.listen(0);
});
it('handles response errors with a boom response', function (done) {
var server = Http.createServer(function (req, res) {
res.destroy();
});
server.once('listening', function () {
Wreck.request('get', 'http://127.0.0.1:' + server.address().port, { payload: '' }, function (err) {
expect(err.code).to.equal('ECONNRESET');
done();
});
});
server.listen(0);
});
it('handles errors when remote server is unavailable', function (done) {
Wreck.request('get', 'http://127.0.0.1:10', { payload: '' }, function (err) {
expect(err).to.exist();
done();
});
});
it('handles a timeout during a socket close', function (done) {
var server = Http.createServer(function (req, res) {
req.once('error', function () { });
res.once('error', function () { });
setTimeout(function () {
req.destroy();
}, 5);
});
server.once('error', function () { });
server.once('listening', function () {
Wreck.request('get', 'http://127.0.0.1:' + server.address().port, { payload: '', timeout: 5 }, function (err) {
expect(err).to.exist();
server.close();
setTimeout(done, 5);
});
});
server.listen(0);
});
it('handles an error after a timeout', function (done) {
var server = Http.createServer(function (req, res) {
req.once('error', function () { });
res.once('error', function () { });
setTimeout(function () {
res.socket.write('ERROR');
}, 5);
});
server.once('error', function () { });
server.once('listening', function () {
Wreck.request('get', 'http://127.0.0.1:' + server.address().port, { payload: '', timeout: 5 }, function (err) {
expect(err).to.exist();
server.close();
setTimeout(done, 5);
});
});
server.listen(0);
});
it('allows request without a callback', function (done) {
var server = Http.createServer(function (req, res) {
res.end('ok');
});
server.once('listening', function () {
Wreck.request('get', 'http://127.0.0.1:' + server.address().port);
done();
});
server.listen(0);
});
it('requests can be aborted', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end();
});
server.listen(0, function () {
var req = Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err) {
expect(err).to.exist();
expect(err.code).to.equal('ECONNRESET');
done();
});
req.abort();
});
});
it('request shortcuts can be aborted', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end();
});
server.listen(0, function () {
var req = Wreck.get('http://localhost:' + server.address().port, function (err) {
expect(err).to.exist();
expect(err.code).to.equal('ECONNRESET');
done();
});
req.abort();
});
});
it('in-progress requests can be aborted', function (done) {
var wreck;
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end();
wreck.abort();
});
server.listen(0, function () {
wreck = Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err) {
expect(err).to.exist();
expect(err.code).to.equal('ECONNRESET');
done();
});
});
});
it('uses agent option', function (done) {
var agent = new Http.Agent();
expect(Object.keys(agent.sockets).length).to.equal(0);
Wreck.request('get', 'http://localhost/', { agent: agent }, function (err, res) {
expect(Object.keys(agent.sockets).length).to.equal(1);
done();
});
});
it('applies agent option when redirected', function (done) {
var gen = 0;
var server = Http.createServer(function (req, res) {
if (!gen++) {
res.writeHead(301, { 'Location': '/' });
res.end();
}
else {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end();
}
});
var agent = new Http.Agent();
var requestCount = 0;
var addRequest = agent.addRequest;
agent.addRequest = function () {
requestCount++;
addRequest.apply(agent, arguments);
};
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { redirects: 1, agent: agent }, function (err, res) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(requestCount).to.equal(2);
server.close();
done();
});
});
});
it('pooling can be disabled by setting agent to false', function (done) {
var complete;
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.write('foo');
complete = complete || function () {
res.end();
};
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { agent: false, timeout: 15 }, function (err, res) {
expect(err).to.not.exist();
expect(Object.keys(Wreck.agents.http.sockets).length).to.equal(0);
expect(Object.keys(Wreck.agents.http.requests).length).to.equal(0);
Wreck.request('get', 'http://localhost:' + server.address().port + '/thatone', { agent: false, timeout: 15 }, function (err, innerRes) {
expect(err).to.not.exist();
expect(Object.keys(Wreck.agents.http.sockets).length).to.equal(0);
expect(Object.keys(Wreck.agents.http.requests).length).to.equal(0);
complete();
Wreck.read(res, null, function () {
setTimeout(function () {
expect(Object.keys(Wreck.agents.http.sockets).length).to.equal(0);
expect(Object.keys(Wreck.agents.http.requests).length).to.equal(0);
done();
}, 100);
});
});
});
});
});
it('requests payload in buffer', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
req.pipe(res);
});
server.listen(0, function () {
var buf = new Buffer(internals.payload, 'ascii');
Wreck.request('post', 'http://localhost:' + server.address().port, { payload: buf }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal(internals.payload);
server.close();
done();
});
});
});
});
it('requests head method', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
req.pipe(res);
});
server.listen(0, function () {
var buf = new Buffer(internals.payload, 'ascii');
Wreck.request('head', 'http://localhost:' + server.address().port, { payload: null }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal('');
server.close();
done();
});
});
});
});
it('post null payload', function (done) {
var server = Http.createServer(function (req, res) {
res.statusCode = 500;
res.end();
});
server.listen(0, function () {
Wreck.request('post', 'http://localhost:' + server.address().port, { headers: { connection: 'close' }, payload: null }, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, null, function (err, body) {
expect(err).to.not.exist();
expect(body.toString()).to.equal('');
server.close();
done();
});
});
});
});
it('handles read timeout', function (done) {
var server = Http.createServer(function (req, res) {
setTimeout(function () {
res.writeHead(200);
res.write(internals.payload);
res.end();
}, 2000);
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { timeout: 100 }, function (err, res) {
expect(err).to.exist();
expect(err.output.statusCode).to.equal(504);
done();
});
});
});
it('cleans socket on agent deferred read timeout', function (done) {
var complete;
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.write('foo');
complete = complete || function () {
res.end();
};
});
server.listen(0, function () {
var agent = new Http.Agent({ maxSockets: 1 });
expect(Object.keys(agent.sockets).length).to.equal(0);
Wreck.request('get', 'http://localhost:' + server.address().port, { agent: agent, timeout: 15 }, function (err, res) {
expect(err).to.not.exist();
expect(Object.keys(agent.sockets).length).to.equal(1);
expect(Object.keys(agent.requests).length).to.equal(0);
Wreck.request('get', 'http://localhost:' + server.address().port + '/thatone', { agent: agent, timeout: 15 }, function (err, innerRes) {
expect(err).to.exist();
expect(err.output.statusCode).to.equal(504);
expect(Object.keys(agent.sockets).length).to.equal(1);
expect(Object.keys(agent.requests).length).to.equal(1);
complete();
Wreck.read(res, null, function () {
setTimeout(function () {
expect(Object.keys(agent.sockets).length).to.equal(0);
expect(Object.keys(agent.requests).length).to.equal(0);
done();
}, 100);
});
});
});
});
});
it('defaults maxSockets to Infinity', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.write(internals.payload);
res.end();
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, { timeout: 100 }, function (err, res) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(Wreck.agents.http.maxSockets).to.equal(Infinity);
done();
});
});
});
it('maxSockets on default agents can be changed', function (done) {
var complete;
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.write('foo');
complete = complete || function () {
res.end();
};
});
server.listen(0, function () {
Wreck.agents.http.maxSockets = 1;
Wreck.request('get', 'http://localhost:' + server.address().port, { timeout: 15 }, function (err, res) {
expect(err).to.not.exist();
Wreck.request('get', 'http://localhost:' + server.address().port + '/thatone', { timeout: 15 }, function (err, innerRes) {
expect(err).to.exist();
expect(err.output.statusCode).to.equal(504);
complete();
Wreck.read(res, null, function () {
Wreck.agents.http.maxSockets = Infinity;
done();
});
});
});
});
});
});
describe('options.baseUrl', function () {
it('uses baseUrl option with trailing slash and uri is prefixed with a slash', function (done) {
var r = Wreck.request('get', '/foo', { baseUrl: 'http://localhost/' }, function (err, res) {
expect(r._headers.host).to.equal('localhost');
done();
});
});
it('uses baseUrl option without trailing slash and uri is prefixed with a slash', function (done) {
var request = Wreck.request('get', '/foo', { baseUrl: 'http://localhost' }, Hoek.ignore);
expect(request._headers.host).to.equal('localhost');
expect(request.path).to.equal('/foo');
done();
});
it('uses baseUrl option with trailing slash and uri is prefixed without a slash', function (done) {
var request = Wreck.request('get', 'foo', { baseUrl: 'http://localhost/' }, Hoek.ignore);
expect(request._headers.host).to.equal('localhost');
expect(request.path).to.equal('/foo');
done();
});
it('uses baseUrl option without trailing slash and uri is prefixed without a slash', function (done) {
var request = Wreck.request('get', 'foo', { baseUrl: 'http://localhost' }, Hoek.ignore);
expect(request._headers.host).to.equal('localhost');
expect(request.path).to.equal('/foo');
done();
});
it('uses baseUrl option when uri is an empty string', function (done) {
var request = Wreck.request('get', '', { baseUrl: 'http://localhost' }, Hoek.ignore);
expect(request._headers.host).to.equal('localhost');
expect(request.path).to.equal('/');
done();
});
it('uses baseUrl option with a path', function (done) {
var request = Wreck.request('get', '/bar', { baseUrl: 'http://localhost/foo' }, Hoek.ignore);
expect(request._headers.host).to.equal('localhost');
expect(request.path).to.equal('/foo/bar');
done();
});
it('uses baseUrl option with a path and removes extra slashes', function (done) {
var request = Wreck.request('get', '/bar', { baseUrl: 'http://localhost/foo/' }, Hoek.ignore);
expect(request._headers.host).to.equal('localhost');
expect(request.path).to.equal('/foo/bar');
done();
});
it('uses baseUrl option with a url that has a querystring', function (done) {
var request = Wreck.request('get', '/bar?test=hello', { baseUrl: 'http://localhost/foo' }, Hoek.ignore);
expect(request._headers.host).to.equal('localhost');
expect(request.path).to.equal('/foo/bar?test=hello');
done();
});
});
describe('read()', function () {
it('handles errors with a boom response', function (done) {
var res = new Events.EventEmitter();
res.pipe = function () { };
Wreck.read(res, null, function (err) {
expect(err.isBoom).to.equal(true);
done();
});
res.emit('error', new Error('my error'));
});
it('handles responses that close early', function (done) {
var res = new Events.EventEmitter();
res.pipe = function () { };
Wreck.read(res, null, function (err) {
expect(err.isBoom).to.equal(true);
done();
});
res.emit('close');
});
it('times out when stream read takes too long', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.write(internals.payload);
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, { timeout: 100 }, function (err, body) {
expect(err).to.exist();
expect(err.output.statusCode).to.equal(408);
expect(body).to.not.exist();
server.close();
done();
});
});
});
});
it('errors when stream is too big', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.write(internals.payload);
res.end(internals.payload);
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.not.exist();
Wreck.read(res, { maxBytes: 120 }, function (err, body) {
expect(err).to.exist();
expect(err.output.statusCode).to.equal(400);
expect(body).to.not.exist();
server.close();
done();
});
});
});
});
it('reads a file streamed via HTTP', function (done) {
var path = Path.join(__dirname, '../images/wreck.png');
var stats = Fs.statSync(path);
var fileStream = Fs.createReadStream(path);
var server = Http.createServer(function (req, res) {
res.writeHead(200);
fileStream.pipe(res);
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
Wreck.read(res, null, function (err, body) {
expect(body.length).to.equal(stats.size);
server.close();
done();
});
});
});
});
it('reads a multiple buffers response', function (done) {
var path = Path.join(__dirname, '../images/wreck.png');
var stats = Fs.statSync(path);
var file = Fs.readFileSync(path);
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.write(file);
setTimeout(function () {
res.write(file);
res.end();
}, 100);
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
Wreck.read(res, null, function (err, body) {
expect(body.length).to.equal(stats.size * 2);
server.close();
done();
});
});
});
});
it('writes a file streamed via HTTP', function (done) {
var path = Path.join(__dirname, '../images/wreck.png');
var stats = Fs.statSync(path);
var fileStream = Fs.createReadStream(path);
var server = Http.createServer(function (req, res) {
res.writeHead(200);
Wreck.read(req, null, function (err, body) {
res.end(body);
});
});
server.listen(0, function () {
Wreck.request('post', 'http://localhost:' + server.address().port, { payload: fileStream }, function (err, res) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
Wreck.read(res, null, function (err, body) {
expect(body.length).to.equal(stats.size);
server.close();
done();
});
});
});
});
it('handles responses with no headers', function (done) {
var res = Wreck.toReadableStream(internals.payload);
Wreck.read(res, { json: true }, function (err) {
expect(err).to.equal(null);
done();
});
});
it('skips destroy when not available', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.write(internals.payload);
res.end(internals.payload);
});
server.listen(0, function () {
Wreck.request('get', 'http://localhost:' + server.address().port, {}, function (err, res) {
expect(err).to.not.exist();
res.destroy = null;
Wreck.read(res, { maxBytes: 120 }, function (err, body) {
expect(err).to.exist();
expect(err.output.statusCode).to.equal(400);
expect(body).to.not.exist();
server.close();
done();
});
});
});
});
});
describe('parseCacheControl()', function () {
it('parses valid header', function (done) {
var header = Wreck.parseCacheControl('must-revalidate, max-age=3600');
expect(header).to.exist();
expect(header['must-revalidate']).to.equal(true);
expect(header['max-age']).to.equal(3600);
done();
});
it('parses valid header with quoted string', function (done) {
var header = Wreck.parseCacheControl('must-revalidate, max-age="3600"');
expect(header).to.exist();
expect(header['must-revalidate']).to.equal(true);
expect(header['max-age']).to.equal(3600);
done();
});
it('errors on invalid header', function (done) {
var header = Wreck.parseCacheControl('must-revalidate, b =3600');
expect(header).to.not.exist();
done();
});
it('errors on invalid max-age', function (done) {
var header = Wreck.parseCacheControl('must-revalidate, max-age=a3600');
expect(header).to.not.exist();
done();
});
});
describe('Shortcut', function () {
it('get request', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
server.listen(0, function () {
Wreck.get('http://localhost:' + server.address().port, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload.toString()).to.equal('ok');
server.close();
done();
});
});
});
it('post request', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
server.listen(0, function () {
Wreck.post('http://localhost:' + server.address().port, { payload: '123' }, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload.toString()).to.equal('ok');
server.close();
done();
});
});
});
it('patch request', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
server.listen(0, function () {
Wreck.patch('http://localhost:' + server.address().port, { payload: '123' }, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload.toString()).to.equal('ok');
server.close();
done();
});
});
});
it('put request', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
server.listen(0, function () {
Wreck.put('http://localhost:' + server.address().port, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload.toString()).to.equal('ok');
server.close();
done();
});
});
});
it('delete request', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
server.listen(0, function () {
Wreck.delete('http://localhost:' + server.address().port, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload.toString()).to.equal('ok');
server.close();
done();
});
});
});
it('errors on bad request', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
server.listen(0, function () {
var port = server.address().port;
server.close();
Wreck.get('http://localhost:' + port, function (err, res, payload) {
expect(err).to.exist();
done();
});
});
});
});
describe('json', function () {
it('json requested and received', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({ foo: 'bar' }));
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: true
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload).to.not.equal(null);
expect(payload.foo).to.exist();
server.close();
done();
});
});
});
it('json-based type requested and received', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'application/vnd.api+json' });
res.end(JSON.stringify({ foo: 'bar' }));
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: true
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload).to.not.equal(null);
expect(payload.foo).to.exist();
server.close();
done();
});
});
});
it('json requested but not received - flag is ignored', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: true
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload).to.not.equal(null);
server.close();
done();
});
});
});
it('invalid json received', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end('ok');
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: true
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.exist();
server.close();
done();
});
});
});
it('json not requested but received as string', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({ foo: 'bar' }));
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: false
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload).to.not.equal(null);
server.close();
done();
});
});
});
it('should not be parsed on empty buffer', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(204, { 'Content-Type': 'application/json' });
res.end();
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: 'SMART'
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(204);
expect(payload).to.equal(null);
server.close();
done();
});
});
});
it('will try to parse json in "force" mode, regardless of the header', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end(JSON.stringify({ foo: 'bar' }));
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: 'force'
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload).to.not.equal(null);
expect(payload).to.deep.equal({
foo: 'bar'
});
server.close();
done();
});
});
});
it('will error on invalid json received in "force" mode', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200, { 'Content-Type': 'text/plain' });
res.end('ok');
});
server.listen(0, function () {
var port = server.address().port;
var options = {
json: 'force'
};
Wreck.get('http://localhost:' + port, options, function (err, res, payload) {
expect(err).to.exist();
server.close();
done();
});
});
});
});
describe('toReadableStream()', function () {
it('handle empty payload', function (done) {
var stream = Wreck.toReadableStream();
expect(stream instanceof Stream).to.be.true();
var read = stream.read(); // Make sure read has no problems
expect(read).to.be.null();
done();
});
it('handle explicit encoding', function (done) {
var data = 'Hello';
var buf = new Buffer(data, 'ascii');
var stream = Wreck.toReadableStream(data, 'ascii');
expect(stream instanceof Stream).to.be.true();
var read = stream.read();
expect(read.toString()).to.equal(data);
done();
});
it('chunks to requested size', function (done) {
var buf;
var data = new Array(101).join('0123456789');
var stream = Wreck.toReadableStream(data);
buf = stream.read(100);
expect(buf.length).to.equal(100);
buf = stream.read(400);
expect(buf.length).to.equal(400);
buf = stream.read();
expect(buf.length).to.equal(500);
buf = stream.read();
expect(buf).to.equal(null);
done();
});
});
describe('Events', function () {
it('emits response event when wreck is finished', function (done) {
var server = Http.createServer(function (req, res) {
res.writeHead(200);
res.end('ok');
});
Wreck.once('response', function (err, req, res, start, uri) {
expect(err).to.not.exist();
expect(req).to.exist();
expect(res).to.exist();
expect(typeof start).to.equal('number');
expect(uri.href).to.equal('http://localhost:' + server.address().port + '/');
done();
});
server.listen(0, function () {
Wreck.put('http://localhost:' + server.address().port, function (err, res, payload) {
expect(err).to.not.exist();
expect(res.statusCode).to.equal(200);
expect(payload.toString()).to.equal('ok');
server.close();
});
});
});
it('response event includes error when it occurs', { timeout: 2500 }, function (done) {
Wreck.once('response', function (err, req, res) {
expect(err).to.exist();
expect(req).to.exist();
expect(res).to.not.exist();
done();
});
Wreck.get('http://0', function (err) {
expect(err).to.exist();
});
});
it('multiple requests execute the same response handler', { timeout: 5000 }, function (done) {
var count = 0;
var handler = function (err, req, res) {
expect(err).to.exist();
expect(req).to.exist();
expect(res).to.not.exist();
count++;
};
Wreck.on('response', handler);
Wreck.get('http://0', function (err) {
expect(err).to.exist();
Wreck.get('http://0', function (err) {
expect(err).to.exist();
expect(count).to.equal(2);
Wreck.removeListener('response', handler);
done();
});
});
});
it('rejects attempts to use defaults without an options hash', function (done) {
var fn = function () {
Wreck.defaults();
};
expect(fn).to.throw();
done();
});
it('respects defaults without bleeding across instances', function (done) {
var optionsA = { headers: { foo: 123 } };
var optionsB = { headers: { bar: 321 } };
var wreckA = Wreck.defaults(optionsA);
var wreckB = Wreck.defaults(optionsB);
var wreckAB = wreckA.defaults(optionsB);
// var agent = new Http.Agent();
// expect(Object.keys(agent.sockets).length).to.equal(0);
var req1 = wreckA.request('get', 'http://localhost/', { headers: { banana: 911 } }, function (err) {
expect(req1._headers.banana).to.exist();
expect(req1._headers.foo).to.exist();
expect(req1._headers.bar).to.not.exist();
var req2 = wreckB.request('get', 'http://localhost/', { headers: { banana: 911 } }, function (err) {
expect(req2._headers.banana).to.exist();
expect(req2._headers.foo).to.not.exist();
expect(req2._headers.bar).to.exist();
var req3 = wreckAB.request('get', 'http://localhost/', { headers: { banana: 911 } }, function (err) {
expect(req3._headers.banana).to.exist();
expect(req3._headers.foo).to.exist();
expect(req3._headers.bar).to.exist();
done();
});
});
});
});
});