Built motion from commit 5fcd269f5146f10cf3129722d518881dfac64576. Version 3.0.0...
[motion-next.git] / server / services / routing / server / applications / queue.js
index 3db372b..c683b74 100644 (file)
@@ -1 +1 @@
-const a1210_0x5299=['%s:queue:%s','queue','string','from','create','../../rpc/whatsappQueueReport','../../rpc/smsQueueReport','account','info','emit','number','rrmemory','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','%sQueuesWaitingInteractions','next','[%s][START:QUEUE][NAME:%s]','../../../../config/logger','find','stop','Queues','list','MessageId','update','../../../../rediscache','close','pick','interaction','createQueue','upperFirst','[%s][QUEUE]\x20ROUTING\x20STOPPED','join','qtimeout','[%s][STOP:QUEUE][NAME:%s]','strategy','map','moment','format','joinAt','AccountId','create\x20queue\x20report','WebsiteId','timeout','rules','error','consequence','complete','validate','QueueReport','toLowerCase','../../rpc/faxQueueReport','channel','[%s][QUEUE]\x20APPLICATION\x20END','QueueId','body','lodash','length','contact','YYYY-MM-DD\x20HH:mm:ss','name','[%s][QUEUE]\x20%s','stack','util','[%s][END:QUEUE][NAME:%s]','../../rpc/chatQueueReport','message','clone','catch','log','save','timeout\x20is\x20a\x20number','seq-queue','remove','../../rpc/openchannelQueueReport','waiting'];(function(_0x1862f1,_0x529969){const _0x36b462=function(_0x4800b1){while(--_0x4800b1){_0x1862f1['push'](_0x1862f1['shift']());}};_0x36b462(++_0x529969);}(a1210_0x5299,0x14f));const a1210_0x36b4=function(_0x1862f1,_0x529969){_0x1862f1=_0x1862f1-0x0;let _0x36b462=a1210_0x5299[_0x1862f1];return _0x36b462;};const _0x49a013=a1210_0x36b4;'use strict';const schema=require(_0x49a013('0x7')),_=require(_0x49a013('0xf')),util=require(_0x49a013('0x16')),seqqueue=require(_0x49a013('0x1f')),moment=require(_0x49a013('0x46')),logger=require(_0x49a013('0x33'))('routing'),strategy=require('./strategy'),{getSocket}=require(_0x49a013('0x3a')),io=getSocket(),attributes=['id','queue_id',_0x49a013('0x2a'),'queue',_0x49a013('0x26'),_0x49a013('0x48')];function emit(_0x4800b1,_0x58d26f,_0x229977){const _0x427108=_0x49a013;io['to'](_0x4800b1)[_0x427108('0x2c')](_0x58d26f,_0x229977);}function emitChannelQueueInteraction(_0x50287a,_0xd801b1,_0x22bd20,_0x1a1d66,_0x80657b,_0x44cb6e,_0x272743,_0x2c3ff9){const _0x346ea9=_0x49a013,_0x1fa232=_[_0x346ea9('0x1a')](_0x22bd20);_0x1fa232['queue_id']=_0x2c3ff9,_0x1fa232[_0x346ea9('0x24')]=_0xd801b1,_0x1fa232[_0x346ea9('0x2a')]=_0x1a1d66,_0x1fa232['id']=_0x80657b,_0x44cb6e?_0x272743[util[_0x346ea9('0x47')]('%sQueuesWaitingInteractions',_0x50287a)][_0x80657b]=_[_0x346ea9('0x3c')](_0x1fa232,attributes):delete _0x272743[util[_0x346ea9('0x47')](_0x346ea9('0x30'),_0x50287a)][_0x80657b],emit(util[_0x346ea9('0x47')](_0x346ea9('0x23'),_0x50287a,_0xd801b1),util[_0x346ea9('0x47')]('%s_queue_waiting_interaction:%s',_0x50287a,_0x44cb6e?_0x346ea9('0x1d'):_0x346ea9('0x20')),_[_0x346ea9('0x3c')](_0x1fa232,attributes));}const rpc={'openchannelQueueReport':require(_0x49a013('0x21')),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require(_0x49a013('0x18')),'smsQueueReport':require(_0x49a013('0x29')),'faxQueueReport':require(_0x49a013('0xa')),'whatsappQueueReport':require(_0x49a013('0x28'))},queue=schema({'name':{'type':_0x49a013('0x25'),'required':!![],'message':_0x49a013('0x2f')},'timeout':{'type':_0x49a013('0x2d'),'message':_0x49a013('0x1e')}});function startRouting(_0x50199e,_0x3f06d9,_0x16a688,_0x49eb3e){const _0x3c42b8=_0x49a013;if(_0x50199e&&_0x3f06d9&&_0x16a688){_0x3f06d9[_0x3c42b8('0x22')]+=0x1;const _0x4de1d8={'uniqueid':_0x50199e,'from':_0x16a688['body']?_0x16a688['body'][_0x3c42b8('0x26')]:'','joinAt':moment()[_0x3c42b8('0x47')](_0x3c42b8('0x12')),'ContactId':_0x16a688['contact']?_0x16a688[_0x3c42b8('0x11')]['id']:null,'ListId':_0x16a688[_0x3c42b8('0x37')]?_0x16a688[_0x3c42b8('0x37')]['id']:null};_0x4de1d8[_[_0x3c42b8('0x3f')](_0x16a688[_0x3c42b8('0xb')])+_0x3c42b8('0xd')]=_0x3f06d9['id']||null,_0x4de1d8[_[_0x3c42b8('0x3f')](_0x16a688[_0x3c42b8('0xb')])+'InteractionId']=_0x16a688[_0x3c42b8('0x3d')]?_0x16a688[_0x3c42b8('0x3d')]['id']:null,_0x4de1d8[_[_0x3c42b8('0x3f')](_0x16a688[_0x3c42b8('0xb')])+_0x3c42b8('0x38')]=_0x16a688['message']?_0x16a688['message']['id']:null,_0x4de1d8[_[_0x3c42b8('0x3f')](_0x16a688[_0x3c42b8('0xb')])+(_0x16a688[_0x3c42b8('0xb')]!=='chat'?_0x3c42b8('0x49'):_0x3c42b8('0x1'))]=_0x16a688['account']?_0x16a688[_0x3c42b8('0x2a')]['id']:null,logger[_0x3c42b8('0x2b')](util[_0x3c42b8('0x47')](_0x3c42b8('0x32'),_0x50199e,_0x3f06d9['name'])),emitChannelQueueInteraction(_0x16a688[_0x3c42b8('0xb')],_0x3f06d9[_0x3c42b8('0x13')],_0x4de1d8,_0x16a688[_0x3c42b8('0x2a')][_0x3c42b8('0x13')],_0x16a688[_0x3c42b8('0x19')]['id'],!![],_0x49eb3e,_0x3f06d9['id']);if(rpc[_0x16a688[_0x3c42b8('0xb')]+'QueueReport'])return rpc[_0x16a688[_0x3c42b8('0xb')]+_0x3c42b8('0x8')][_0x3c42b8('0x27')](_0x4de1d8)['catch'](function(){const _0x509b8f=_0x3c42b8;logger[_0x509b8f('0x4')](_0x509b8f('0x0'));});}}function stopRouting(_0x1fe278,_0x296fe6,_0x3e6b6d,_0x126ad3){const _0x1dcb49=_0x49a013;if(_0x1fe278&&_0x296fe6){_0x296fe6['waiting']-=0x1;const _0x375995={'leaveAt':moment()[_0x1dcb49('0x47')](_0x1dcb49('0x12')),'acceptAt':moment()[_0x1dcb49('0x47')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':'accepted'};logger[_0x1dcb49('0x2b')](util[_0x1dcb49('0x47')](_0x1dcb49('0x43'),_0x1fe278,_0x296fe6['name'])),emitChannelQueueInteraction(_0x3e6b6d[_0x1dcb49('0xb')],_0x296fe6[_0x1dcb49('0x13')],_0x3e6b6d[_0x1dcb49('0xe')],_0x3e6b6d[_0x1dcb49('0x2a')]['name'],_0x3e6b6d[_0x1dcb49('0x19')]['id'],![],_0x126ad3,_0x296fe6['id']);if(rpc[_0x3e6b6d[_0x1dcb49('0xb')]+_0x1dcb49('0x8')])return rpc[_0x3e6b6d[_0x1dcb49('0xb')]+'QueueReport']['update'](_0x1fe278,_0x375995)[_0x1dcb49('0x1b')](function(){const _0x58c7c7=_0x1dcb49;logger[_0x58c7c7('0x4')]('update\x20queue\x20report');});}}function endRouting(_0x481883,_0x147773,_0x59ed9c,_0x5500f0){const _0x2c5a6d=_0x49a013;if(_0x481883&&_0x147773){_0x147773[_0x2c5a6d('0x22')]-=0x1;const _0x22f437={'leaveAt':moment()[_0x2c5a6d('0x47')](_0x2c5a6d('0x12')),'exitAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x2c5a6d('0x2')};logger[_0x2c5a6d('0x2b')](util[_0x2c5a6d('0x47')](_0x2c5a6d('0x17'),_0x481883,_0x147773['name'])),emitChannelQueueInteraction(_0x59ed9c[_0x2c5a6d('0xb')],_0x147773[_0x2c5a6d('0x13')],_0x59ed9c['body'],_0x59ed9c['account'][_0x2c5a6d('0x13')],_0x59ed9c['message']['id'],![],_0x5500f0);if(rpc[_0x59ed9c['channel']+_0x2c5a6d('0x8')])return rpc[_0x59ed9c[_0x2c5a6d('0xb')]+_0x2c5a6d('0x8')][_0x2c5a6d('0x39')](_0x481883,_0x22f437)['catch'](function(){const _0x12e05c=_0x2c5a6d;logger[_0x12e05c('0x4')]('update\x20queue\x20report');});}}function handleFindQueue(_0x5e6fd7){return function(_0x196b20){const _0x2c2253=a1210_0x36b4;return _0x196b20[_0x2c2253('0x13')][_0x2c2253('0x9')]()===_0x5e6fd7[_0x2c2253('0x9')]();};}exports[_0x49a013('0x5')]=function(_0xdd07ac,_0x296f26,_0x4493fd,_0x25647b){return function(_0x5dc297){const _0x5a1b92=a1210_0x36b4;try{const _0x568dee={'name':_0x296f26[0x0],'timeout':_0x296f26[0x1]},_0x493070=queue[_0x5a1b92('0x7')](_0x568dee,{'typecast':!![]});if(_0x493070[_0x5a1b92('0x10')])logger[_0x5a1b92('0x4')](_0x5a1b92('0x14'),_0xdd07ac,_[_0x5a1b92('0x45')](_0x493070,_0x5a1b92('0x19'))[_0x5a1b92('0x41')](',\x20')),_0x5dc297[_0x5a1b92('0x35')]();else{const _0x2cdcc5=_[_0x5a1b92('0x34')](_0x4493fd[_0x25647b['channel']+_0x5a1b92('0x36')],handleFindQueue(_0x568dee[_0x5a1b92('0x13')]));if(_0x2cdcc5){startRouting(_0xdd07ac,_0x2cdcc5,_0x25647b,_0x4493fd);const _0x2387b1=(_0x2cdcc5['timeout']||0xa)*0x3e8;let _0x361775=(_0x568dee[_0x5a1b92('0x2')]||0x14)*0x3e8,_0x387aee;_0x2387b1>_0x361775&&(_0x361775=_0x2387b1);const _0x1c78e1=seqqueue[_0x5a1b92('0x3e')](_0x2387b1);_0x1c78e1['id']=_0xdd07ac,_0x1c78e1['atimeout']=_0x2387b1,_0x1c78e1[_0x5a1b92('0x42')]=_0x361775,_0x1c78e1[_0x5a1b92('0xb')]=_0x25647b[_0x5a1b92('0xb')],_0x4493fd['rules'][_0xdd07ac]['on']('end',function(){const _0x17070e=_0x5a1b92;logger[_0x17070e('0x2b')](_0x17070e('0x40'),_0xdd07ac),stopRouting(_0xdd07ac,_0x2cdcc5,_0x25647b,_0x4493fd),clearTimeout(_0x387aee),_0x387aee=undefined,_0x1c78e1[_0x17070e('0x3b')](!![]),_0x4493fd[_0x17070e('0x3')][_0xdd07ac]&&delete _0x4493fd[_0x17070e('0x3')][_0xdd07ac],_0x5dc297[_0x17070e('0x35')]();}),_0x4493fd[_0x5a1b92('0x3')][_0xdd07ac]['on'](_0x5a1b92('0x6'),function(){const _0x589afa=_0x5a1b92;_0x4493fd['rules'][_0xdd07ac]&&delete _0x4493fd[_0x589afa('0x3')][_0xdd07ac];}),_0x387aee=setTimeout(function(){const _0x4290d2=_0x5a1b92;logger[_0x4290d2('0x2b')](_0x4290d2('0xc'),_0xdd07ac),endRouting(_0xdd07ac,_0x2cdcc5,_0x25647b,_0x4493fd),clearTimeout(_0x387aee),_0x1c78e1[_0x4290d2('0x3b')](!![]),_0x5dc297[_0x4290d2('0x31')]();},_0x361775);switch(_0x2cdcc5[_0x5a1b92('0x44')]){case'rrmemory':strategy[_0x5a1b92('0x2e')](_0x1c78e1,_0x2cdcc5,_0x4493fd,_0x25647b);break;default:strategy['beepall'](_0x1c78e1,_0x2cdcc5,_0x4493fd,_0x25647b);}}else logger['error']('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0xdd07ac,_0x568dee[_0x5a1b92('0x13')]),_0x5dc297[_0x5a1b92('0x35')]();}}catch(_0x538ed8){console[_0x5a1b92('0x1c')](_0x538ed8),logger['error'](_0x5a1b92('0x14'),_0xdd07ac,_0x538ed8[_0x5a1b92('0x15')]),_0x5dc297[_0x5a1b92('0x35')]();}};};
\ No newline at end of file
+const a1210_0x4d85=['remove','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','createQueue','queue','contact','[%s][QUEUE]\x20ROUTING\x20STOPPED','name','map','timeout\x20is\x20a\x20number','lodash','../../rpc/chatQueueReport','body','[%s][QUEUE]\x20%s','save','close','length','queue_id','%s_queue_waiting_interaction:%s','AccountId','[%s][START:QUEUE][NAME:%s]','format','number','list','account','qtimeout','./strategy','[%s][QUEUE]\x20APPLICATION\x20END','create\x20queue\x20report','clone','validate','find','../../rpc/whatsappQueueReport','message','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','stack','toLowerCase','strategy','routing','../../rpc/mailQueueReport','[%s][END:QUEUE][NAME:%s]','QueueReport','log','atimeout','update\x20queue\x20report','rules','../../rpc/openchannelQueueReport','waiting','info','stop','YYYY-MM-DD\x20HH:mm:ss','from','next','%sQueuesWaitingInteractions','QueueId','error','accepted','end','channel','InteractionId','string','util','../../../../rediscache','emit','../../../../config/logger','catch','../../rpc/smsQueueReport','update','beepall','timeout','upperFirst','joinAt','rrmemory','pick'];(function(_0x2932e5,_0x4d85bc){const _0x33abeb=function(_0x465742){while(--_0x465742){_0x2932e5['push'](_0x2932e5['shift']());}};_0x33abeb(++_0x4d85bc);}(a1210_0x4d85,0x159));const a1210_0x33ab=function(_0x2932e5,_0x4d85bc){_0x2932e5=_0x2932e5-0x0;let _0x33abeb=a1210_0x4d85[_0x2932e5];return _0x33abeb;};const _0x532b1a=a1210_0x33ab;'use strict';const schema=require('validate'),_=require(_0x532b1a('0x1d')),util=require(_0x532b1a('0x7')),seqqueue=require('seq-queue'),moment=require('moment'),logger=require(_0x532b1a('0xa'))(_0x532b1a('0x39')),strategy=require(_0x532b1a('0x2d')),{getSocket}=require(_0x532b1a('0x8')),io=getSocket(),attributes=['id',_0x532b1a('0x24'),_0x532b1a('0x2b'),_0x532b1a('0x17'),_0x532b1a('0x46'),_0x532b1a('0x11')];function emit(_0x465742,_0x36cb4f,_0x58311d){const _0x347576=_0x532b1a;io['to'](_0x465742)[_0x347576('0x9')](_0x36cb4f,_0x58311d);}function emitChannelQueueInteraction(_0x119f3f,_0x11f2ea,_0x22d803,_0x11b94a,_0x21d485,_0x3cf14e,_0x5068eb,_0x209db4){const _0xb70a51=_0x532b1a,_0x4615c7=_[_0xb70a51('0x30')](_0x22d803);_0x4615c7[_0xb70a51('0x24')]=_0x209db4,_0x4615c7[_0xb70a51('0x17')]=_0x11f2ea,_0x4615c7[_0xb70a51('0x2b')]=_0x11b94a,_0x4615c7['id']=_0x21d485,_0x3cf14e?_0x5068eb[util[_0xb70a51('0x28')]('%sQueuesWaitingInteractions',_0x119f3f)][_0x21d485]=_[_0xb70a51('0x13')](_0x4615c7,attributes):delete _0x5068eb[util['format'](_0xb70a51('0x48'),_0x119f3f)][_0x21d485],emit(util[_0xb70a51('0x28')]('%s:queue:%s',_0x119f3f,_0x11f2ea),util['format'](_0xb70a51('0x25'),_0x119f3f,_0x3cf14e?_0xb70a51('0x21'):_0xb70a51('0x14')),_[_0xb70a51('0x13')](_0x4615c7,attributes));}const rpc={'openchannelQueueReport':require(_0x532b1a('0x41')),'mailQueueReport':require(_0x532b1a('0x3a')),'chatQueueReport':require(_0x532b1a('0x1e')),'smsQueueReport':require(_0x532b1a('0xc')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require(_0x532b1a('0x33'))},queue=schema({'name':{'type':_0x532b1a('0x6'),'required':!![],'message':_0x532b1a('0x35')},'timeout':{'type':_0x532b1a('0x29'),'message':_0x532b1a('0x1c')}});function startRouting(_0x561655,_0x43b778,_0x4bd196,_0x5ac84a){const _0x280487=_0x532b1a;if(_0x561655&&_0x43b778&&_0x4bd196){_0x43b778[_0x280487('0x42')]+=0x1;const _0x5cd75b={'uniqueid':_0x561655,'from':_0x4bd196[_0x280487('0x1f')]?_0x4bd196['body'][_0x280487('0x46')]:'','joinAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x4bd196[_0x280487('0x18')]?_0x4bd196[_0x280487('0x18')]['id']:null,'ListId':_0x4bd196[_0x280487('0x2a')]?_0x4bd196[_0x280487('0x2a')]['id']:null};_0x5cd75b[_[_0x280487('0x10')](_0x4bd196['channel'])+_0x280487('0x0')]=_0x43b778['id']||null,_0x5cd75b[_[_0x280487('0x10')](_0x4bd196[_0x280487('0x4')])+_0x280487('0x5')]=_0x4bd196['interaction']?_0x4bd196['interaction']['id']:null,_0x5cd75b[_['upperFirst'](_0x4bd196[_0x280487('0x4')])+'MessageId']=_0x4bd196[_0x280487('0x34')]?_0x4bd196['message']['id']:null,_0x5cd75b[_[_0x280487('0x10')](_0x4bd196[_0x280487('0x4')])+(_0x4bd196[_0x280487('0x4')]!=='chat'?_0x280487('0x26'):'WebsiteId')]=_0x4bd196[_0x280487('0x2b')]?_0x4bd196[_0x280487('0x2b')]['id']:null,logger['info'](util[_0x280487('0x28')](_0x280487('0x27'),_0x561655,_0x43b778[_0x280487('0x1a')])),emitChannelQueueInteraction(_0x4bd196['channel'],_0x43b778[_0x280487('0x1a')],_0x5cd75b,_0x4bd196['account']['name'],_0x4bd196[_0x280487('0x34')]['id'],!![],_0x5ac84a,_0x43b778['id']);if(rpc[_0x4bd196['channel']+_0x280487('0x3c')])return rpc[_0x4bd196[_0x280487('0x4')]+_0x280487('0x3c')]['create'](_0x5cd75b)['catch'](function(){const _0x5b26d0=_0x280487;logger[_0x5b26d0('0x1')](_0x5b26d0('0x2f'));});}}function stopRouting(_0x397ad3,_0x151446,_0x2c32ce,_0x594774){const _0xdac256=_0x532b1a;if(_0x397ad3&&_0x151446){_0x151446['waiting']-=0x1;const _0x3a58c0={'leaveAt':moment()[_0xdac256('0x28')](_0xdac256('0x45')),'acceptAt':moment()[_0xdac256('0x28')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0xdac256('0x2')};logger[_0xdac256('0x43')](util['format']('[%s][STOP:QUEUE][NAME:%s]',_0x397ad3,_0x151446[_0xdac256('0x1a')])),emitChannelQueueInteraction(_0x2c32ce[_0xdac256('0x4')],_0x151446[_0xdac256('0x1a')],_0x2c32ce[_0xdac256('0x1f')],_0x2c32ce[_0xdac256('0x2b')]['name'],_0x2c32ce[_0xdac256('0x34')]['id'],![],_0x594774,_0x151446['id']);if(rpc[_0x2c32ce[_0xdac256('0x4')]+_0xdac256('0x3c')])return rpc[_0x2c32ce[_0xdac256('0x4')]+_0xdac256('0x3c')]['update'](_0x397ad3,_0x3a58c0)[_0xdac256('0xb')](function(){const _0x17a8c4=_0xdac256;logger[_0x17a8c4('0x1')](_0x17a8c4('0x3f'));});}}function endRouting(_0x2299b5,_0x34c084,_0x7836,_0x366363){const _0x24ecc6=_0x532b1a;if(_0x2299b5&&_0x34c084){_0x34c084['waiting']-=0x1;const _0x2cc61b={'leaveAt':moment()[_0x24ecc6('0x28')]('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()[_0x24ecc6('0x28')](_0x24ecc6('0x45')),'reason':_0x24ecc6('0xf')};logger[_0x24ecc6('0x43')](util[_0x24ecc6('0x28')](_0x24ecc6('0x3b'),_0x2299b5,_0x34c084[_0x24ecc6('0x1a')])),emitChannelQueueInteraction(_0x7836[_0x24ecc6('0x4')],_0x34c084[_0x24ecc6('0x1a')],_0x7836['body'],_0x7836[_0x24ecc6('0x2b')]['name'],_0x7836[_0x24ecc6('0x34')]['id'],![],_0x366363);if(rpc[_0x7836[_0x24ecc6('0x4')]+_0x24ecc6('0x3c')])return rpc[_0x7836[_0x24ecc6('0x4')]+'QueueReport'][_0x24ecc6('0xd')](_0x2299b5,_0x2cc61b)[_0x24ecc6('0xb')](function(){const _0x102d10=_0x24ecc6;logger[_0x102d10('0x1')](_0x102d10('0x3f'));});}}function handleFindQueue(_0x10f2f7){return function(_0x5b7e21){const _0x38b1d1=a1210_0x33ab;return _0x5b7e21[_0x38b1d1('0x1a')][_0x38b1d1('0x37')]()===_0x10f2f7[_0x38b1d1('0x37')]();};}exports['consequence']=function(_0x32ad18,_0x346527,_0x326c19,_0x3b7625){return function(_0x1f325b){const _0x10f002=a1210_0x33ab;try{const _0x33147b={'name':_0x346527[0x0],'timeout':_0x346527[0x1]},_0x1bd678=queue[_0x10f002('0x31')](_0x33147b,{'typecast':!![]});if(_0x1bd678[_0x10f002('0x23')])logger[_0x10f002('0x1')](_0x10f002('0x20'),_0x32ad18,_[_0x10f002('0x1b')](_0x1bd678,_0x10f002('0x34'))['join'](',\x20')),_0x1f325b[_0x10f002('0x44')]();else{const _0x29684c=_[_0x10f002('0x32')](_0x326c19[_0x3b7625[_0x10f002('0x4')]+'Queues'],handleFindQueue(_0x33147b['name']));if(_0x29684c){startRouting(_0x32ad18,_0x29684c,_0x3b7625,_0x326c19);const _0xba8a51=(_0x29684c[_0x10f002('0xf')]||0xa)*0x3e8;let _0x29560b=(_0x33147b[_0x10f002('0xf')]||0x14)*0x3e8,_0x4b22d9;_0xba8a51>_0x29560b&&(_0x29560b=_0xba8a51);const _0x37a603=seqqueue[_0x10f002('0x16')](_0xba8a51);_0x37a603['id']=_0x32ad18,_0x37a603[_0x10f002('0x3e')]=_0xba8a51,_0x37a603[_0x10f002('0x2c')]=_0x29560b,_0x37a603[_0x10f002('0x4')]=_0x3b7625['channel'],_0x326c19['rules'][_0x32ad18]['on'](_0x10f002('0x3'),function(){const _0x275e74=_0x10f002;logger[_0x275e74('0x43')](_0x275e74('0x19'),_0x32ad18),stopRouting(_0x32ad18,_0x29684c,_0x3b7625,_0x326c19),clearTimeout(_0x4b22d9),_0x4b22d9=undefined,_0x37a603[_0x275e74('0x22')](!![]),_0x326c19[_0x275e74('0x40')][_0x32ad18]&&delete _0x326c19[_0x275e74('0x40')][_0x32ad18],_0x1f325b[_0x275e74('0x44')]();}),_0x326c19['rules'][_0x32ad18]['on']('complete',function(){const _0x3401f4=_0x10f002;_0x326c19['rules'][_0x32ad18]&&delete _0x326c19[_0x3401f4('0x40')][_0x32ad18];}),_0x4b22d9=setTimeout(function(){const _0x39fdb9=_0x10f002;logger[_0x39fdb9('0x43')](_0x39fdb9('0x2e'),_0x32ad18),endRouting(_0x32ad18,_0x29684c,_0x3b7625,_0x326c19),clearTimeout(_0x4b22d9),_0x37a603[_0x39fdb9('0x22')](!![]),_0x1f325b[_0x39fdb9('0x47')]();},_0x29560b);switch(_0x29684c[_0x10f002('0x38')]){case _0x10f002('0x12'):strategy[_0x10f002('0x12')](_0x37a603,_0x29684c,_0x326c19,_0x3b7625);break;default:strategy[_0x10f002('0xe')](_0x37a603,_0x29684c,_0x326c19,_0x3b7625);}}else logger['error'](_0x10f002('0x15'),_0x32ad18,_0x33147b[_0x10f002('0x1a')]),_0x1f325b[_0x10f002('0x44')]();}}catch(_0x3720ad){console[_0x10f002('0x3d')](_0x3720ad),logger[_0x10f002('0x1')](_0x10f002('0x20'),_0x32ad18,_0x3720ad[_0x10f002('0x36')]),_0x1f325b[_0x10f002('0x44')]();}};};
\ No newline at end of file