server/services/routing/server/applications/queue.js

   1 var _0xf6eb=["\x75\x73\x65\x20\x73\x74\x72\x69\x63\x74","\x76\x61\x6C\x69\x64\x61\x74\x65","\x6C\x6F\x64\x61\x73\x68","\x75\x74\x69\x6C","\x73\x65\x71\x2D\x71\x75\x65\x75\x65","\x6D\x6F\x6D\x65\x6E\x74","\x72\x6F\x75\x74\x69\x6E\x67","\x2E\x2E\x2F\x2E\x2E\x2F\x2E\x2E\x2F\x2E\x2E\x2F\x63\x6F\x6E\x66\x69\x67\x2F\x6C\x6F\x67\x67\x65\x72","\x2E\x2F\x73\x74\x72\x61\x74\x65\x67\x79","\x2E\x2E\x2F\x2E\x2E\x2F\x72\x70\x63\x2F\x6F\x70\x65\x6E\x63\x68\x61\x6E\x6E\x65\x6C\x51\x75\x65\x75\x65\x52\x65\x70\x6F\x72\x74","\x2E\x2E\x2F\x2E\x2E\x2F\x72\x70\x63\x2F\x6D\x61\x69\x6C\x51\x75\x65\x75\x65\x52\x65\x70\x6F\x72\x74","\x2E\x2E\x2F\x2E\x2E\x2F\x72\x70\x63\x2F\x63\x68\x61\x74\x51\x75\x65\x75\x65\x52\x65\x70\x6F\x72\x74","\x2E\x2E\x2F\x2E\x2E\x2F\x72\x70\x63\x2F\x73\x6D\x73\x51\x75\x65\x75\x65\x52\x65\x70\x6F\x72\x74","\x2E\x2E\x2F\x2E\x2E\x2F\x72\x70\x63\x2F\x66\x61\x78\x51\x75\x65\x75\x65\x52\x65\x70\x6F\x72\x74","\x73\x74\x72\x69\x6E\x67","\x6E\x61\x6D\x65\x20\x69\x73\x20\x61\x20\x73\x74\x72\x69\x6E\x67\x20\x61\x6E\x64\x20\x69\x74\x20\x69\x73\x20\x72\x65\x71\x75\x69\x72\x65\x64","\x6E\x75\x6D\x62\x65\x72","\x74\x69\x6D\x65\x6F\x75\x74\x20\x69\x73\x20\x61\x20\x6E\x75\x6D\x62\x65\x72","\x77\x61\x69\x74\x69\x6E\x67","\x62\x6F\x64\x79","\x66\x72\x6F\x6D","","\x59\x59\x59\x59\x2D\x4D\x4D\x2D\x44\x44\x20\x48\x48\x3A\x6D\x6D\x3A\x73\x73","\x66\x6F\x72\x6D\x61\x74","\x63\x6F\x6E\x74\x61\x63\x74","\x69\x64","\x6C\x69\x73\x74","\x63\x68\x61\x6E\x6E\x65\x6C","\x75\x70\x70\x65\x72\x46\x69\x72\x73\x74","\x51\x75\x65\x75\x65\x49\x64","\x49\x6E\x74\x65\x72\x61\x63\x74\x69\x6F\x6E\x49\x64","\x69\x6E\x74\x65\x72\x61\x63\x74\x69\x6F\x6E","\x4D\x65\x73\x73\x61\x67\x65\x49\x64","\x6D\x65\x73\x73\x61\x67\x65","\x63\x68\x61\x74","\x41\x63\x63\x6F\x75\x6E\x74\x49\x64","\x57\x65\x62\x73\x69\x74\x65\x49\x64","\x61\x63\x63\x6F\x75\x6E\x74","\x5B\x25\x73\x5D\x5B\x53\x54\x41\x52\x54\x3A\x51\x55\x45\x55\x45\x5D\x5B\x4E\x41\x4D\x45\x3A\x25\x73\x5D","\x6E\x61\x6D\x65","\x69\x6E\x66\x6F","\x51\x75\x65\x75\x65\x52\x65\x70\x6F\x72\x74","\x63\x72\x65\x61\x74\x65\x20\x71\x75\x65\x75\x65\x20\x72\x65\x70\x6F\x72\x74","\x65\x72\x72\x6F\x72","\x63\x61\x74\x63\x68","\x63\x72\x65\x61\x74\x65","\x61\x63\x63\x65\x70\x74\x65\x64","\x5B\x25\x73\x5D\x5B\x53\x54\x4F\x50\x3A\x51\x55\x45\x55\x45\x5D\x5B\x4E\x41\x4D\x45\x3A\x25\x73\x5D","\x75\x70\x64\x61\x74\x65\x20\x71\x75\x65\x75\x65\x20\x72\x65\x70\x6F\x72\x74","\x75\x70\x64\x61\x74\x65","\x74\x69\x6D\x65\x6F\x75\x74","\x5B\x25\x73\x5D\x5B\x45\x4E\x44\x3A\x51\x55\x45\x55\x45\x5D\x5B\x4E\x41\x4D\x45\x3A\x25\x73\x5D","\x74\x6F\x4C\x6F\x77\x65\x72\x43\x61\x73\x65","\x63\x6F\x6E\x73\x65\x71\x75\x65\x6E\x63\x65","\x6C\x65\x6E\x67\x74\x68","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x25\x73","\x2C\x20","\x6A\x6F\x69\x6E","\x6D\x61\x70","\x73\x74\x6F\x70","\x51\x75\x65\x75\x65\x73","\x66\x69\x6E\x64","\x63\x72\x65\x61\x74\x65\x51\x75\x65\x75\x65","\x61\x74\x69\x6D\x65\x6F\x75\x74","\x71\x74\x69\x6D\x65\x6F\x75\x74","\x72\x75\x6C\x65\x73","\x63\x6C\x6F\x73\x65","\x6E\x65\x78\x74","\x72\x72\x6D\x65\x6D\x6F\x72\x79","\x62\x65\x65\x70\x61\x6C\x6C","\x73\x74\x72\x61\x74\x65\x67\x79","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x71\x75\x65\x75\x65\x20\x6E\x6F\x74\x20\x66\x6F\x75\x6E\x64\x20\x25\x73","\x6C\x6F\x67","\x73\x74\x72\x69\x6E\x67\x69\x66\x79"];_0xf6eb[0];var schema=require(_0xf6eb[1]);var _=require(_0xf6eb[2]);var util=require(_0xf6eb[3]);var seqqueue=require(_0xf6eb[4]);var moment=require(_0xf6eb[5]);var logger=require(_0xf6eb[7])(_0xf6eb[6]);var strategy=require(_0xf6eb[8]);var rpc={openchannelQueueReport:require(_0xf6eb[9]),mailQueueReport:require(_0xf6eb[10]),chatQueueReport:require(_0xf6eb[11]),smsQueueReport:require(_0xf6eb[12]),faxQueueReport:require(_0xf6eb[13])};var queue=schema({name:{type:_0xf6eb[14],required:true,message:_0xf6eb[15]},timeout:{type:_0xf6eb[16],message:_0xf6eb[17]}});function startRouting(_0x6a70xb,queue,_0x6a70xc){if(_0x6a70xb&& queue&& _0x6a70xc){queue[_0xf6eb[18]]+= 1;var _0x6a70xd={uniqueid:_0x6a70xb,from:_0x6a70xc[_0xf6eb[19]]?_0x6a70xc[_0xf6eb[19]][_0xf6eb[20]]:_0xf6eb[21],joinAt:moment()[_0xf6eb[23]](_0xf6eb[22]),ContactId:_0x6a70xc[_0xf6eb[24]]?_0x6a70xc[_0xf6eb[24]][_0xf6eb[25]]:null,ListId:_0x6a70xc[_0xf6eb[26]]?_0x6a70xc[_0xf6eb[26]][_0xf6eb[25]]:null};_0x6a70xd[_[_0xf6eb[28]](_0x6a70xc[_0xf6eb[27]])+ _0xf6eb[29]]= queue[_0xf6eb[25]]|| null,_0x6a70xd[_[_0xf6eb[28]](_0x6a70xc[_0xf6eb[27]])+ _0xf6eb[30]]= _0x6a70xc[_0xf6eb[31]]?_0x6a70xc[_0xf6eb[31]][_0xf6eb[25]]:null;_0x6a70xd[_[_0xf6eb[28]](_0x6a70xc[_0xf6eb[27]])+ _0xf6eb[32]]= _0x6a70xc[_0xf6eb[33]]?_0x6a70xc[_0xf6eb[33]][_0xf6eb[25]]:null;_0x6a70xd[_[_0xf6eb[28]](_0x6a70xc[_0xf6eb[27]])+ (_0x6a70xc[_0xf6eb[27]]!== _0xf6eb[34]?_0xf6eb[35]:_0xf6eb[36])]= _0x6a70xc[_0xf6eb[37]]?_0x6a70xc[_0xf6eb[37]][_0xf6eb[25]]:null;logger[_0xf6eb[40]](util[_0xf6eb[23]](_0xf6eb[38],_0x6a70xb,queue[_0xf6eb[39]]));if(rpc[_0x6a70xc[_0xf6eb[27]]+ _0xf6eb[41]]){return rpc[_0x6a70xc[_0xf6eb[27]]+ _0xf6eb[41]][_0xf6eb[45]](_0x6a70xd)[_0xf6eb[44]](function(_0x6a70xe){logger[_0xf6eb[43]](_0xf6eb[42])})}}}function stopRouting(_0x6a70xb,queue,_0x6a70xc){if(_0x6a70xb&& queue){queue[_0xf6eb[18]]-= 1;var _0x6a70xd={leaveAt:moment()[_0xf6eb[23]](_0xf6eb[22]),acceptAt:moment()[_0xf6eb[23]](_0xf6eb[22]),reason:_0xf6eb[46]};logger[_0xf6eb[40]](util[_0xf6eb[23]](_0xf6eb[47],_0x6a70xb,queue[_0xf6eb[39]]));if(rpc[_0x6a70xc[_0xf6eb[27]]+ _0xf6eb[41]]){return rpc[_0x6a70xc[_0xf6eb[27]]+ _0xf6eb[41]][_0xf6eb[49]](_0x6a70xb,_0x6a70xd)[_0xf6eb[44]](function(_0x6a70xe){logger[_0xf6eb[43]](_0xf6eb[48])})}}}function endRouting(_0x6a70xb,queue,_0x6a70xc){if(_0x6a70xb&& queue){queue[_0xf6eb[18]]-= 1;var _0x6a70xd={leaveAt:moment()[_0xf6eb[23]](_0xf6eb[22]),exitAt:moment()[_0xf6eb[23]](_0xf6eb[22]),reason:_0xf6eb[50]};logger[_0xf6eb[40]](util[_0xf6eb[23]](_0xf6eb[51],_0x6a70xb,queue[_0xf6eb[39]]));if(rpc[_0x6a70xc[_0xf6eb[27]]+ _0xf6eb[41]]){return rpc[_0x6a70xc[_0xf6eb[27]]+ _0xf6eb[41]][_0xf6eb[49]](_0x6a70xb,_0x6a70xd)[_0xf6eb[44]](function(_0x6a70xe){logger[_0xf6eb[43]](_0xf6eb[48])})}}}function handleFindQueue(_0x6a70x12){return function(_0x6a70x13){return _0x6a70x13[_0xf6eb[39]][_0xf6eb[52]]()=== _0x6a70x12[_0xf6eb[52]]()}}exports[_0xf6eb[53]]= function(_0x6a70xb,_0x6a70x14,_0x6a70x15,_0x6a70xc){return function(_0x6a70x16){try{var _0x6a70x17={name:_0x6a70x14[0],timeout:_0x6a70x14[1]};var _0x6a70x18=queue[_0xf6eb[1]](_0x6a70x17,{typecast:true});if(_0x6a70x18[_0xf6eb[54]]){logger[_0xf6eb[43]](_0xf6eb[55],_0x6a70xb,_[_0xf6eb[58]](_0x6a70x18,_0xf6eb[33])[_0xf6eb[57]](_0xf6eb[56]));_0x6a70x16[_0xf6eb[59]]()}else {var _0x6a70x19=_[_0xf6eb[61]](_0x6a70x15[_0x6a70xc[_0xf6eb[27]]+ _0xf6eb[60]],handleFindQueue(_0x6a70x17[_0xf6eb[39]]));if(_0x6a70x19){startRouting(_0x6a70xb,_0x6a70x19,_0x6a70xc);var _0x6a70x1a=(_0x6a70x19[_0xf6eb[50]]|| 10)* 1000;var _0x6a70x1b=(_0x6a70x17[_0xf6eb[50]]|| 20)* 1000;var _0x6a70x1c,_0x6a70x1d;if(_0x6a70x1a> _0x6a70x1b){_0x6a70x1b= _0x6a70x1a};var _0x6a70x1e=seqqueue[_0xf6eb[62]](_0x6a70x1a);_0x6a70x1e[_0xf6eb[25]]= _0x6a70xb;_0x6a70x1e[_0xf6eb[63]]= _0x6a70x1a;_0x6a70x1e[_0xf6eb[64]]= _0x6a70x1b;_0x6a70x1e[_0xf6eb[27]]= _0x6a70xc[_0xf6eb[27]];_0x6a70x1d= setInterval(function(){if(_0x6a70x15[_0xf6eb[65]]&&  !_0x6a70x15[_0xf6eb[65]][_0x6a70xb]){stopRouting(_0x6a70xb,_0x6a70x19,_0x6a70xc);clearTimeout(_0x6a70x1c);clearInterval(_0x6a70x1d);_0x6a70x1c= undefined;_0x6a70x1e[_0xf6eb[66]](true);_0x6a70x16[_0xf6eb[59]]()}},1000);_0x6a70x1c= setTimeout(function(){endRouting(_0x6a70xb,_0x6a70x19,_0x6a70xc);clearInterval(_0x6a70x1d);_0x6a70x1d= undefined;_0x6a70x1e[_0xf6eb[66]](true);_0x6a70x16[_0xf6eb[67]]()},_0x6a70x1b);switch(_0x6a70x19[_0xf6eb[70]]){case _0xf6eb[68]:strategy[_0xf6eb[68]](_0x6a70x1e,_0x6a70x19,_0x6a70x15);break;default:strategy[_0xf6eb[69]](_0x6a70x1e,_0x6a70x19,_0x6a70x15)}}else {logger[_0xf6eb[43]](_0xf6eb[71],_0x6a70xb,_0x6a70x17[_0xf6eb[39]]);_0x6a70x16[_0xf6eb[59]]()}}}catch(e){console[_0xf6eb[72]](e);logger[_0xf6eb[43]](_0xf6eb[55],_0x6a70xb,JSON[_0xf6eb[73]](e));_0x6a70x16[_0xf6eb[59]]()}}}