var Eviction = require("../lib/eviction"); var nThen = require("nthen"); var Store = require("../lib/storage/file"); var BlobStore = require("../lib/storage/blob"); var Quota = require("../lib/commands/quota"); var Environment = require("../lib/env"); var Decrees = require("../lib/decrees"); var config = require("../lib/load-config"); var Env = Environment.create(config); var loadPremiumAccounts = function (Env, cb) { nThen(function (w) { // load premium accounts Quota.updateCachedLimits(Env, w(function (err) { if (err) { Env.Log.error('EVICT_LOAD_PREMIUM_ACCOUNTS', { error: err, }); } })); }).nThen(function (w) { // load and apply decrees Decrees.load(Env, w(function (err) { if (err) { Env.Log.error('EVICT_LOAD_DECREES', { error: err.code || err, message: err.message, }); } })); }).nThen(function () { //console.log(Env.limits); cb(); }); }; var prepareEnv = function (Env, cb) { //Quota.applyCustomLimits(Env); nThen(function (w) { /* Database adaptors */ // load the store which will be used for iterating over channels // and performing operations like archival and deletion Store.create(config, w(function (err, _) { if (err) { w.abort(); throw err; } Env.store = _; })); Store.create({ filePath: config.pinPath, // archive pin logs to their own subpath volumeId: 'pins', }, w(function (err, _) { if (err) { w.abort(); throw err; } Env.pinStore = _; })); // load the logging module so that you have a record of which // files were archived or deleted at what time var Logger = require("../lib/log"); Logger.create(config, w(function (_) { Env.Log = _; })); config.getSession = function () {}; BlobStore.create(config, w(function (err, _) { if (err) { w.abort(); return console.error(err); } Env.blobStore = _; })); }).nThen(function (w) { loadPremiumAccounts(Env, w(function (/* err */) { //if (err) { } })); }).nThen(function () { cb(); }); }; nThen(function (w) { // load database adaptors and configuration values into the environment prepareEnv(Env, w(function () { })); }).nThen(function (w) { Eviction(Env, w(function () { })); });