File size: 1,993 Bytes
f9f1a35 |
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 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
// Utility to orchestrate the rotating file system object and its triggers.
'use strict';
var RotatingFileStream = require('./lib/rotatingfilestream');
var PeriodTrigger = require('./lib/periodtrigger');
var InitialPeriodTrigger = require('./lib/initialperiodtrigger');
var ThresholdTrigger = require('./lib/thresholdtrigger');
var TriggerAdapter = require('./lib/triggeradapter');
var _ = require('lodash');
var path = require('path');
var existingFilesStreams = {};
function RotatingFileStreamFactory(options) {
// options_in might be readonly, copy so that we can modify as needed
var options_copy = _.extend({}, options);
if (typeof (options_copy.path) !== 'string') {
throw new Error('Must provide a string for path');
}
options_copy.path = path.resolve(options_copy.path);
var rfs = existingFilesStreams[options_copy.path];
if (!rfs) {
rfs = RotatingFileStream(options_copy);
existingFilesStreams[options_copy.path] = rfs;
rfs.once('shutdown', function () {
existingFilesStreams[options_copy.path] = null;
});
if (options_copy.period) {
var periodTrigger = PeriodTrigger(options_copy);
TriggerAdapter(periodTrigger, rfs);
}
if (options_copy.period && options_copy.rotateExisting) {
var initialPeriodTrigger = InitialPeriodTrigger(options_copy);
TriggerAdapter(initialPeriodTrigger, rfs);
}
if (options_copy.threshold) {
var thresholdTrigger = ThresholdTrigger(options_copy);
TriggerAdapter(thresholdTrigger, rfs);
}
rfs.initialise();
} else if (options_copy.shared !== true ||
existingFilesStreams[options_copy.path].shared !== true) {
throw new Error('You should not create multiple rotating file ' +
'streams against the same file: ' + options_copy.path);
}
return rfs;
}
module.exports = RotatingFileStreamFactory;
|