Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
TarGz.prototype.createParseStream = function() {
var stream1 = zlib.createGunzip(this._options.zlib);
var stream2 = tar.Parse();
this._bubble(stream1, stream2);
// Capture the entry event
stream2.on('entry', function(entry) {
stream1.emit('entry', entry);
});
stream1.pipe(stream2);
return stream1;
};
return new Promise((resolve, reject) => {
if (this.opts.gzip) {
// we're in gzipped mode - GZip the buffer
recordBuffer = zlib.gzipSync(recordBuffer)
}
if (!this._warcOutStream.write(recordBuffer, 'utf8')) {
this._warcOutStream.once('drain', resolve)
} else {
resolve()
}
})
}
server.request('*', (icapReq, icapRes, req, res, next) => {
icapRes.setIcapStatusCode(200);
icapRes.setIcapHeaders(icapReq.headers);
icapRes.setHttpMethod(req);
icapRes.setHttpHeaders(req.headers);
icapRes.writeHeaders(icapReq.hasBody());
const unzipper = zlib.createUnzip();
unzipper.pipe(icapRes);
icapReq.pipe(unzipper);
});
var fs = require('fs');
var tar = require('tar-fs')
var request = require('request');
var zlib = require('zlib');
request('https://www.dropbox.com/s/4h5iuryd3myfha8/asset.tar.gz?dl=1')
.pipe(zlib.createGunzip())
.pipe(tar.extract('./static_assets'));
function main() {
extractValues(
fs.createReadStream(__dirname + '/ucd.all.flat.xml.gz').pipe(zlib.createGunzip()),
propertiesToExtract,
writeFile);
function writeFile(validRanges) {
var code = generateCode(validRanges);
try {
fs.lstatSync(__dirname + '/../../../src/ngParseExt');
} catch (e) {
fs.mkdirSync(__dirname + '/../../../src/ngParseExt');
}
fs.writeFile(__dirname + '/../../../src/ngParseExt/ucd.js', code);
}
}
req.on('response', resp => {
if (resp.statusCode === 200)
req.pipe(zlib.createGunzip()).pipe(fs.createWriteStream(ipFile))
.on('finish', () => {
loadFile(resolve)
})
else
loadFile(resolve)
})
} else
replicator.replicateFromSnapShotStream = function (readStream, indexes, callback) {
var indexesws = levelws(indexes);
readStream.pipe(zlib.createGunzip())
.pipe(JSONStream.parse())
.pipe(indexesws.createWriteStream())
.on('close', callback);
};
return new Promise((resolve, reject) => {
zlib.gunzip(body, (err, buffer) => {
if (err) {
reject(new Error(err.message || err));
} else {
resolve(buffer);
}
});
});
}
function inflate(strdata, onData) {
var data = new Buffer(strdata);
zlib.inflate(data, function (error, buffer) {
if (error) throw new Error('Invalid compressed data. ' + error);
onData(buffer);
});
};
res.on('end', function() {
var buffer = Buffer.concat(chunks);
var compression = res.headers['content-encoding'];
var callback = _createRequestCallback(address, encoding, done);
var location = res.headers.location;
if (location) return _request(location, encoding, done, n + 1 || 1);
if (compression === 'gzip') {
return zlib.gunzip(buffer, callback);
} else if (compression === 'deflate') {
return zlib.inflateRaw(buffer, callback);
} else {
callback(undefined, buffer);
}
});
}).on('error', function(err) {