const rp = require('request-promise-native');
const Queue = require('./taskqueue');
const _ = require('lodash');

const processUrl = 'http://localhost:5000/process/';
const processBasicFields = ['overwrite', 'from', 'actions'];
const processFields = ['timestamp'].concat(processBasicFields);
const debug = false;

// Queue of scans to be processed
// Persistent storage using sqlite
const store = Queue.getCachedSqlStore({
 type: 'sql',
 dialect: 'sqlite',
 path: './data/process-queue.db'
});
const queue = new Queue(function (task, cb) {
 var url = processUrl + task.id;
 if (!debug) {
 var options = {
 uri: url,
 qs: _.pick(task, processFields)
 };
 console.log('Processing %s, connecting to url %s', task.id, url);
 rp(options)
 .then(function (resp) {
 // TODO: Process response...
 console.log('Response to %s: ', task.id, resp);
 cb(null, resp);
 })
 .catch(function (err) {
 // Processing failed...
 console.log('Processing %s FAILED: ', task.id, err);
 cb(err, null);
 });
 } else {
 console.log('Processing %s - debug mode', task.id);
 }
}, {
 stateFile: './data/process-queue.state.json',
 store: store,
 priority: function (task, cb) {
 cb(null, task.priority || 1);
 }
 }
);

module.exports = function() {
 const app = this;

 app.process_queue = queue;

 // custom population of scans from csv
 app.get('/queues/process/add', (req, res, next) => {
 // Add scan to process queue
 //var logger = app.logger.getContext('', { path: '/queues/process/add'});
 var opts = { id: req.query.scanId, timestamp: Date.now() };
 _.defaults(opts, _.pick(req.query, processBasicFields));
 if (req.query.priority != undefined) {
 var priority = req.query.priority;
 if (priority == 'max') {
 var p = queue.maxPriority();
 priority = p? p+1 : undefined;
 } else if (priority == 'min') {
 var p = queue.minPriority();
 priority = p? p-1 : undefined;
 }
 opts.priority = priority;
 }
 console.log(opts);
 var ticket = queue.push(opts);
 res.json({ status: 'ok', size: queue.size(), ticket: ticket });
 });

 app.get('/queues/process/remove', (req, res, next) => {
 // Remove scan from process queue
 //var logger = app.logger.getContext('', { path: '/queues/process/remove'});
 queue.cancel(req.query.scanId);
 res.json({ status: 'ok', size: queue.size() });
 });

 app.get('/queues/process/list', (req, res, next) => {
 // List scans in process queue
 //var logger = app.logger.getContext('', { path: '/queues/process/list'});
 var queued = queue.list();
 res.json({ status: 'ok', queue: queued });
 });

 app.get('/queues/process/clear', (req, res, next) => {
 // List scans in process queue
 //var logger = app.logger.getContext('', { path: '/queues/process/clear'});
 queue.clear();
 res.json({ status: 'ok', size: queue.size() });
 });

 app.get('/queues/process/status', (req, res, next) => {
 // Returns basic queue status
 res.json({ status: 'ok', status: queue.status() });
 });

 app.get('/queues/process/stats', (req, res, next) => {
 // Returns basic queue stats
 res.json({ status: 'ok', stats: queue.getStats(), size: queue.size(), isPaused: queue.isPaused() });
 });

 app.get('/queues/process/pause', (req, res, next) => {
 // Pauses process queue
 queue.pause();
 queue.saveState();
 res.json({ status: 'ok', size: queue.size(), isPaused: queue.isPaused() });
 });

 app.get('/queues/process/resume', (req, res, next) => {
 // Resumes process queue
 queue.resume();
 queue.saveState();
 res.json({ status: 'ok', size: queue.size(), isPaused: queue.isPaused() });
 });

};