| // 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('../'); |
| |
| |
| // Test shortcuts |
| |
| var lab = exports.lab = Lab.script(); |
| var describe = lab.describe; |
| var it = lab.it; |
| var expect = Code.expect; |
| |
| |
| var payload = new Array(1640).join('0123456789'); // make sure we have a payload larger than 16384 bytes for chunking coverage |
| |
| 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(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(body.toString()).to.equal(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: 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(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: 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(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(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(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(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('requests a resource with downstream dependency', function (done) { |
| |
| var up = Http.createServer(function (req, res) { |
| |
| res.writeHead(200, { 'Content-Type': 'text/plain' }); |
| res.end(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(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(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(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(payload); |
| server.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 { |
| res.writeHead(200, { 'Content-Type': 'text/plain' }); |
| res.end(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(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(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 () { |
| |
| Wreck.request('post', 'http://localhost:' + server.address().port, { redirects: 1, payload: Wreck.toReadableStream(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(payload); |
| server.close(); |
| 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('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(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(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(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(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(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(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(payload); |
| res.end(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(payload); |
| Wreck.read(res, { json: true }, function (err) { |
| |
| expect(err).to.equal(null); |
| 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).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).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).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).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).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 req; |
| |
| 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); |
| |
| req = wreckA.request('get', 'http://localhost/', { headers: { banana: 911 } }, function (err, res) { |
| |
| expect(req._headers.banana).to.exist(); |
| expect(req._headers.foo).to.exist(); |
| expect(req._headers.bar).to.not.exist(); |
| |
| req = wreckB.request('get', 'http://localhost/', { headers: { banana: 911 } }, function (err, res) { |
| |
| expect(req._headers.banana).to.exist(); |
| expect(req._headers.foo).to.not.exist(); |
| expect(req._headers.bar).to.exist(); |
| |
| req = wreckAB.request('get', 'http://localhost/', { headers: { banana: 911 } }, function (err, res) { |
| |
| expect(req._headers.banana).to.exist(); |
| expect(req._headers.foo).to.exist(); |
| expect(req._headers.bar).to.exist(); |
| |
| done(); |
| }); |
| }); |
| }); |
| }); |
| }); |
