queue.js

import Logger from "./logger/Logger";
import Promise from "bluebird";

/**
 * Created by Creeplays on 23.08.2016.
 */
let logger=new Logger('Queuer');
console.log('Queuer import');
export function queue(time){
    return function (target, key, descriptor) {
        let queued=[];
        let origFun=descriptor.value;
        let stopped=true;
        async function process() {
            try {
                if (queued.length == 0) {
                    stopped = true;
                    return;
                }
                stopped = false;
                let startTime = new Date().getTime();
                let q = queued.shift();
                try {
                    let result = await origFun(...q.args);
                    q.resolve(result);
                } catch (e) {
                    q.reject(e);
                }
                if (new Date().getTime() - startTime >= time) {
                    setTimeout(()=>process(), 1);
                } else {
                    setTimeout(()=>process(), time - (new Date().getTime() - startTime));
                }
            }catch (e){
                logger.error('Error on processing tasks for '+key,e);
            }
        }
        descriptor.value = function() {
            logger.log('Called');
            return new Promise((resolve,reject)=>{
                queued.push({
                    reject:reject,
                    resolve:resolve,
                    args:arguments
                });
                if(stopped)
                    process();
            });
        };
        return descriptor;
    }
}