'use strict';

var db = require('./db');
var taskQueue = db.tasks();
var settingsHandler = require('./settingsHandler');

function processTask(task) {
  console.log('processing task');
  switch (task.type) {
  case 'maintenance':
    settingsHandler.changeMaintenanceMode(task.value);
    break;
  }

}

exports.start = function() {

  var limitDate = new Date();

  var stream = taskQueue.find({}, {
    tailable : true,
    awaitdata : true
  }).stream();

  stream.on('data', function(document) {
    console.log('data');
    if (document.creation > limitDate) {
      processTask(document);
    }

  });

  stream.on('end', function() {
    console.log('ended');
  });

};