Software: Apache/2.4.41 (Ubuntu). PHP/8.0.30 

uname -a: Linux apirnd 5.4.0-204-generic #224-Ubuntu SMP Thu Dec 5 13:38:28 UTC 2024 x86_64 

uid=33(www-data) gid=33(www-data) groups=33(www-data) 

Safe-mode: OFF (not secure)

/var/www/html/wincloud_gateway/api/service/controllers/   drwxr-xr-x
Free 13.27 GB of 57.97 GB (22.89%)
                            Encoder    Tools    Proc.    FTP brute    Sec.    SQL    PHP-code    Update    Self remove    Logout    

Viewing file:     service.js (1.16 KB)      -rw-r--r--

'use strict';

const Queue = require('bull');
const getReturn = require('../../../checking/getReturn');
var uuid = require('uuid-random');
require('events').EventEmitter.prototype._maxListeners = 0;

var myRateLimitedQueue = new Queue("header", {
  
  limiter: {
      max: 100,
      duration: 1000
    }
});

myRateLimitedQueue.process(1,async (job) => {
            
  var return_data= await getReturn.get_result(job.data.header,job.data.api_name,job.data.request_method,job.data.request_ip,job.data.query);
  return Promise.resolve(return_data);
  
});

 
module.exports = {  

  async find(ctx)  {

    var header = ctx.request.header.replace(/Bearer /g,'');
    var request_method = ctx.request.method;
    var api_name = ctx.request.path;
    var request_ip = ctx.request.ip;
    var query = ctx.request.query;

    console.log(query);

    // return await getReturn.get_result(header,api_name,request_method,request_ip,query);

    const queue =await myRateLimitedQueue.add({header,api_name,request_method,request_ip,query},{
            removeOnFail: true,
            removeOnComplete: true,
          });
    const result = await queue.finished();
    return result;    
    },
}