#!/usr/bin/env node

'use strict';

require('supererror')({ splatchError: true });

// remove timestamp from debug() based output
require('debug').formatArgs = function formatArgs() {
    arguments[0] = this.namespace + ' ' + arguments[0];
    return arguments;
};

var assert = require('assert'),
    debug = require('debug')('box:janitor'),
    async = require('async'),
    tokendb = require('./src/tokendb.js'),
    authcodedb = require('./src/authcodedb.js'),
    database = require('./src/database.js');

function initialize(callback) {
    assert.strictEqual(typeof callback, 'function');

    async.series([
        database.initialize
    ], callback);
}

function cleanupExpiredTokens(callback) {
    assert.strictEqual(typeof callback, 'function');

    tokendb.delExpired(function (error, result) {
        if (error) return callback(error);

        debug('Cleaned up %s expired tokens.', result);

        callback(null);
    });
}

function cleanupExpiredAuthCodes(callback) {
    assert.strictEqual(typeof callback, 'function');

    authcodedb.delExpired(function (error, result) {
        if (error) return callback(error);

        debug('Cleaned up %s expired authcodes.', result);

        callback(null);
    });
}

function run() {
    cleanupExpiredTokens(function (error) {
        if (error) console.error(error);

        cleanupExpiredAuthCodes(function (error) {
            if (error) console.error(error);

            process.exit(0);
        });
    });
}

if (require.main === module) {
    initialize(function (error) {
        if (error) {
            console.error('janitor task exiting with error', error);
            process.exit(1);
        }

        run();
    });
}