From 997d89bb9d26db9dc641a69cf8fa1c4f08e0a1b3 Mon Sep 17 00:00:00 2001
From: Piotr Popieluch <piotr1212@gmail.com>
Date: Wed, 2 Sep 2015 21:06:35 +0200
Subject: [PATCH] update stream-to-buffer to raw-body, stream-to-buffer is
deprecated
---
index.js | 6 +++---
package.json | 2 +-
test/test.js | 26 +++++++++++++-------------
3 files changed, 17 insertions(+), 17 deletions(-)
diff --git a/index.js b/index.js
index 1eb62fe..7b12101 100644
--- a/index.js
+++ b/index.js
@@ -31,7 +31,7 @@ var HttpProxyAgent = require('http-proxy-agent');
var HttpsProxyAgent = require('https-proxy-agent');
var SocksProxyAgent = require('socks-proxy-agent');
var PacResolver = require('pac-resolver');
-var toBuffer = require('stream-to-buffer');
+var getRawBody = require('raw-body');
var inherits = require('util').inherits;
var debug = require('debug')('pac-proxy-agent');
@@ -158,13 +158,13 @@ PacProxyAgent.prototype.loadPacFile = function (fn) {
if (err) return fn(err);
debug('got stream.Readable instance for URI');
self.cache = rs;
- toBuffer(rs, onbuffer);
+ getRawBody(rs, 'utf8', onbuffer);
}
function onbuffer (err, buf) {
if (err) return fn(err);
debug('read %o byte PAC file from URI', buf.length);
- fn(null, buf.toString('utf8'));
+ fn(null, buf);
}
};
diff --git a/package.json b/package.json
index f1dbff7..4345a82 100644
--- a/package.json
+++ b/package.json
@@ -35,7 +35,7 @@
"https-proxy-agent": "1",
"pac-resolver": "~1.2.1",
"socks-proxy-agent": "2",
- "stream-to-buffer": "0.1.0"
+ "raw-body": "2"
},
"devDependencies": {
"mocha": "2",
diff --git a/test/test.js b/test/test.js
index a58fcff..0fe5f52 100644
--- a/test/test.js
+++ b/test/test.js
@@ -8,7 +8,7 @@ var url = require('url');
var http = require('http');
var https = require('https');
var assert = require('assert');
-var toBuffer = require('stream-to-buffer');
+var getRawBody = require('raw-body');
var Proxy = require('proxy');
var socks = require('socksv5');
var PacProxyAgent = require('../');
@@ -144,9 +144,9 @@ describe('PacProxyAgent', function () {
opts.agent = agent;
var req = http.get(opts, function (res) {
- toBuffer(res, function (err, buf) {
+ getRawBody(res, 'utf8', function (err, buf) {
if (err) return done(err);
- var data = JSON.parse(buf.toString('utf8'));
+ var data = JSON.parse(buf);
assert.equal('127.0.0.1:' + httpPort, data.host);
assert('via' in data);
done();
@@ -173,9 +173,9 @@ describe('PacProxyAgent', function () {
opts.agent = agent;
var req = http.get(opts, function (res) {
- toBuffer(res, function (err, buf) {
+ getRawBody(res, 'utf8', function (err, buf) {
if (err) return done(err);
- var data = JSON.parse(buf.toString('utf8'));
+ var data = JSON.parse(buf);
assert.equal('127.0.0.1:' + httpPort, data.host);
assert('via' in data);
done();
@@ -200,9 +200,9 @@ describe('PacProxyAgent', function () {
opts.agent = agent;
var req = http.get(opts, function (res) {
- toBuffer(res, function (err, buf) {
+ getRawBody(res, 'utf8', function (err, buf) {
if (err) return done(err);
- var data = JSON.parse(buf.toString('utf8'));
+ var data = JSON.parse(buf);
assert.equal('127.0.0.1:' + httpPort, data.host);
done();
});
@@ -231,9 +231,9 @@ describe('PacProxyAgent', function () {
opts.rejectUnauthorized = false;
var req = https.get(opts, function (res) {
- toBuffer(res, function (err, buf) {
+ getRawBody(res, 'utf8', function (err, buf) {
if (err) return done(err);
- var data = JSON.parse(buf.toString('utf8'));
+ var data = JSON.parse(buf);
assert.equal('127.0.0.1:' + httpsPort, data.host);
done();
});
@@ -262,9 +262,9 @@ describe('PacProxyAgent', function () {
opts.rejectUnauthorized = false;
var req = https.get(opts, function (res) {
- toBuffer(res, function (err, buf) {
+ getRawBody(res, 'utf8', function (err, buf) {
if (err) return done(err);
- var data = JSON.parse(buf.toString('utf8'));
+ var data = JSON.parse(buf);
assert.equal('127.0.0.1:' + httpsPort, data.host);
assert(gotReq);
done();
@@ -292,9 +292,9 @@ describe('PacProxyAgent', function () {
opts.rejectUnauthorized = false;
var req = https.get(opts, function (res) {
- toBuffer(res, function (err, buf) {
+ getRawBody(res, 'utf8', function (err, buf) {
if (err) return done(err);
- var data = JSON.parse(buf.toString('utf8'));
+ var data = JSON.parse(buf);
assert.equal('127.0.0.1:' + httpsPort, data.host);
assert(gotReq);
done();
--
2.4.3