File size: 1,828 Bytes
bf48b89 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 | diff --git a/lib/parser.js b/lib/parser.js
index 2852b5f9249a59adf8f51f3451181ac2c994bc54..50e16ca0a97c98d7048122d5427fe467058485fb 100644
--- a/lib/parser.js
+++ b/lib/parser.js
@@ -3,6 +3,7 @@ const http = require('http');
const https = require('https');
const xml2js = require('xml2js');
const url = require('url');
+const zlib = require('zlib');
const fields = require('./fields');
const utils = require('./utils');
@@ -88,14 +89,27 @@ class Parser {
return reject(new Error("Status code " + res.statusCode))
}
let encoding = utils.getEncodingFromContentType(res.headers['content-type']);
- res.setEncoding(encoding);
- res.on('data', (chunk) => {
- xml += chunk;
- });
- res.on('end', () => {
- return this.parseString(xml).then(resolve, reject);
- });
- })
+ const contentEncoding = (res.headers['content-encoding'] || '').toLowerCase();
+ if (contentEncoding === 'gzip') {
+ const gunzip = zlib.createGunzip();
+ const chunks = [];
+ gunzip.on('data', (chunk) => chunks.push(chunk));
+ gunzip.on('end', () => {
+ const decompressed = Buffer.concat(chunks).toString(encoding);
+ return this.parseString(decompressed).then(resolve, reject);
+ });
+ gunzip.on('error', reject);
+ res.pipe(gunzip);
+ } else {
+ res.setEncoding(encoding);
+ res.on('data', (chunk) => {
+ xml += chunk;
+ });
+ res.on('end', () => {
+ return this.parseString(xml).then(resolve, reject);
+ });
+ }
+ });
req.on('error', reject);
timeout = setTimeout(() => {
return reject(new Error("Request timed out after " + this.options.timeout + "ms"));
|