diff --git a/lib/wget.js b/lib/wget.js index 1b55d3e..a304dc9 100644 --- a/lib/wget.js +++ b/lib/wget.js @@ -8,8 +8,8 @@ var util = require('util'); var fs = require('fs'); var EventEmitter = require('events').EventEmitter; -function download(src, output, options) { - var downloader = new EventEmitter(), +function download(src, output, options, __parentevent) { + var downloader = __parentevent || new EventEmitter(), srcUrl, tunnelAgent, req; @@ -53,6 +53,15 @@ function download(src, output, options) { downloader.emit('end', output); }); } else { + req.abort(); // release resources to avoid EMFILE + if (res.header.location) { + try { + downloader(res.header.location, output, options, downloader) + return; + } catch (e) { + // invalid url, we don't care + } + } downloader.emit('error', 'Server respond ' + res.statusCode); } }); @@ -144,4 +153,4 @@ function cleanProtocol(str) { } exports.download = download; -exports.request = request; \ No newline at end of file +exports.request = request;