; | |
var stream = require('stream'); | |
var util = require('util'); | |
var replace = require('./replace'); | |
var jsonExtRe = /\.json$/; | |
module.exports = function(rootEnv) { | |
rootEnv = rootEnv || process.env; | |
return function (file, trOpts) { | |
if (jsonExtRe.test(file)) { | |
return stream.PassThrough(); | |
} | |
var envs = trOpts ? [rootEnv, trOpts] : [rootEnv]; | |
return new LooseEnvify(envs); | |
}; | |
}; | |
function LooseEnvify(envs) { | |
stream.Transform.call(this); | |
this._data = ''; | |
this._envs = envs; | |
} | |
util.inherits(LooseEnvify, stream.Transform); | |
LooseEnvify.prototype._transform = function(buf, enc, cb) { | |
this._data += buf; | |
cb(); | |
}; | |
LooseEnvify.prototype._flush = function(cb) { | |
var replaced = replace(this._data, this._envs); | |
this.push(replaced); | |
cb(); | |
}; | |