log4js-node/lib/streams/DateRollingFileStream.js

var BaseRollingFileStream = require('./BaseRollingFileStream'),
    format = require('../date_format'),
    async = require('async'),
    fs = require('fs'),
    util = require('util');

module.exports = DateRollingFileStream;

var debug;
if (process.env.NODE_DEBUG && /\blog4js\b/.test(process.env.NODE_DEBUG)) {
    debug = function(message) { console.error('LOG4JS: (DateRollingFileStream) %s', message); };
} else {
    debug = function() { };
}

function DateRollingFileStream(filename, pattern, alwaysIncludePattern, options, now) {
    debug("Now is " + now);
    if (pattern && typeof(pattern) === 'object') {
        now = options;
        options = pattern;
        pattern = null;
    }
    this.pattern = pattern || '.yyyy-MM-dd';
    this.now = now || Date.now;
    this.lastTimeWeWroteSomething = format.asString(this.pattern, new Date(this.now()));
    
    this.alwaysIncludePattern = alwaysIncludePattern;
    if (this.alwaysIncludePattern) {
        this.baseFilename = filename;
        filename = filename + this.lastTimeWeWroteSomething;
    }
    debug("this.now is " + this.now + ", now is " + now);

    DateRollingFileStream.super_.call(this, filename, options);
}
util.inherits(DateRollingFileStream, BaseRollingFileStream);

DateRollingFileStream.prototype.shouldRoll = function() {
    var lastTime = this.lastTimeWeWroteSomething,
        thisTime = format.asString(this.pattern, new Date(this.now()));

    debug("DateRollingFileStream.shouldRoll with now = " + this.now() + ", thisTime = " + thisTime + ", lastTime = " + lastTime);

    this.lastTimeWeWroteSomething = thisTime;
    this.previousTime = lastTime;

    return thisTime !== lastTime;
};

DateRollingFileStream.prototype.roll = function(filename, callback) {
    var that = this,
        newFilename = this.baseFilename + this.previousTime;

    debug("Starting roll");

    async.series([
      this.closeTheStream.bind(this),
      deleteAnyExistingFile,
      renameTheCurrentFile,
      this.openTheStream.bind(this)
    ], callback);

    function deleteAnyExistingFile(cb) {
        //on windows, you can get a EEXIST error if you rename a file to an existing file
        //so, we'll try to delete the file we're renaming to first
        fs.unlink(newFilename, function (err) {
            //ignore err: if we could not delete, it's most likely that it doesn't exist
            cb();
        });
    }

    function renameTheCurrentFile(cb) {
        debug("Renaming the " + filename + " -> " + newFilename);
        fs.rename(filename, newFilename, cb);
    }

};