Built motion from commit df3e9871f6bcc3432fec345b2f4facbd4dba8b5c. Version 3.0.0...
[motion-next.git] / server / services / routing / server / applications / queue.js
index 42fb059..79b6f39 100644 (file)
@@ -1 +1 @@
-const a1208_0x3f72=['chat','validate','contact','lodash','message','account','close','queue','../../rpc/smsQueueReport','Queues','toLowerCase','util','end','update','info','timeout\x20is\x20a\x20number','interaction','beepall','pick','format','QueueId','from','upperFirst','stack','stop','%s:queue:%s','consequence','length','[%s][START:QUEUE][NAME:%s]','InteractionId','rrmemory','../../../../rediscache','find','AccountId','next','rules','map','YYYY-MM-DD\x20HH:mm:ss','error','update\x20queue\x20report','[%s][QUEUE]\x20APPLICATION\x20END','QueueReport','%sQueuesWaitingInteractions','waiting','queue_id','[%s][QUEUE]\x20ROUTING\x20STOPPED','catch','%s_queue_waiting_interaction:%s','save','list','atimeout','joinAt','accepted','body','routing','WebsiteId','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','createQueue','name','create','create\x20queue\x20report','moment','qtimeout','timeout','../../rpc/whatsappQueueReport','../../rpc/chatQueueReport','channel','../../../../config/logger','remove','./strategy','../../rpc/openchannelQueueReport','strategy'];(function(_0x433753,_0x3f72d0){const _0xd855a9=function(_0x3d5e79){while(--_0x3d5e79){_0x433753['push'](_0x433753['shift']());}};_0xd855a9(++_0x3f72d0);}(a1208_0x3f72,0x127));const a1208_0xd855=function(_0x433753,_0x3f72d0){_0x433753=_0x433753-0x0;let _0xd855a9=a1208_0x3f72[_0x433753];return _0xd855a9;};const _0x35088c=a1208_0xd855;'use strict';const schema=require('validate'),_=require(_0x35088c('0x44')),util=require(_0x35088c('0x4')),seqqueue=require('seq-queue'),moment=require(_0x35088c('0x36')),logger=require(_0x35088c('0x3c'))(_0x35088c('0x2f')),strategy=require(_0x35088c('0x3e')),{getSocket}=require(_0x35088c('0x18')),io=getSocket(),attributes=['id',_0x35088c('0x25'),_0x35088c('0x46'),_0x35088c('0x0'),_0x35088c('0xe'),_0x35088c('0x2c')];function emit(_0x3d5e79,_0x48d52f,_0x1ea486){io['to'](_0x3d5e79)['emit'](_0x48d52f,_0x1ea486);}function emitChannelQueueInteraction(_0x4cf2b5,_0x2db16b,_0x48b207,_0x14c9c1,_0x180e41,_0x11bf9a,_0x5471d9,_0x21cdc8){const _0x225bbc=_0x35088c,_0x3d689f=_['clone'](_0x48b207);_0x3d689f[_0x225bbc('0x25')]=_0x21cdc8,_0x3d689f[_0x225bbc('0x0')]=_0x2db16b,_0x3d689f[_0x225bbc('0x46')]=_0x14c9c1,_0x3d689f['id']=_0x180e41,_0x11bf9a?_0x5471d9[util[_0x225bbc('0xc')](_0x225bbc('0x23'),_0x4cf2b5)][_0x180e41]=_[_0x225bbc('0xb')](_0x3d689f,attributes):delete _0x5471d9[util[_0x225bbc('0xc')](_0x225bbc('0x23'),_0x4cf2b5)][_0x180e41],emit(util[_0x225bbc('0xc')](_0x225bbc('0x12'),_0x4cf2b5,_0x2db16b),util[_0x225bbc('0xc')](_0x225bbc('0x28'),_0x4cf2b5,_0x11bf9a?_0x225bbc('0x29'):_0x225bbc('0x3d')),_[_0x225bbc('0xb')](_0x3d689f,attributes));}const rpc={'openchannelQueueReport':require(_0x35088c('0x3f')),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require(_0x35088c('0x3a')),'smsQueueReport':require(_0x35088c('0x1')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require(_0x35088c('0x39'))},queue=schema({'name':{'type':'string','required':!![],'message':_0x35088c('0x31')},'timeout':{'type':'number','message':_0x35088c('0x8')}});function startRouting(_0xc576e8,_0x41706e,_0x25b6c3,_0x1cacf1){const _0x3e53df=_0x35088c;if(_0xc576e8&&_0x41706e&&_0x25b6c3){_0x41706e[_0x3e53df('0x24')]+=0x1;const _0x5626af={'uniqueid':_0xc576e8,'from':_0x25b6c3['body']?_0x25b6c3[_0x3e53df('0x2e')]['from']:'','joinAt':moment()['format'](_0x3e53df('0x1e')),'ContactId':_0x25b6c3[_0x3e53df('0x43')]?_0x25b6c3[_0x3e53df('0x43')]['id']:null,'ListId':_0x25b6c3[_0x3e53df('0x2a')]?_0x25b6c3[_0x3e53df('0x2a')]['id']:null};_0x5626af[_['upperFirst'](_0x25b6c3['channel'])+_0x3e53df('0xd')]=_0x41706e['id']||null,_0x5626af[_[_0x3e53df('0xf')](_0x25b6c3['channel'])+_0x3e53df('0x16')]=_0x25b6c3[_0x3e53df('0x9')]?_0x25b6c3[_0x3e53df('0x9')]['id']:null,_0x5626af[_['upperFirst'](_0x25b6c3[_0x3e53df('0x3b')])+'MessageId']=_0x25b6c3[_0x3e53df('0x45')]?_0x25b6c3[_0x3e53df('0x45')]['id']:null,_0x5626af[_[_0x3e53df('0xf')](_0x25b6c3['channel'])+(_0x25b6c3[_0x3e53df('0x3b')]!==_0x3e53df('0x41')?_0x3e53df('0x1a'):_0x3e53df('0x30'))]=_0x25b6c3[_0x3e53df('0x46')]?_0x25b6c3[_0x3e53df('0x46')]['id']:null,logger[_0x3e53df('0x7')](util[_0x3e53df('0xc')](_0x3e53df('0x15'),_0xc576e8,_0x41706e['name'])),emitChannelQueueInteraction(_0x25b6c3[_0x3e53df('0x3b')],_0x41706e[_0x3e53df('0x33')],_0x5626af,_0x25b6c3[_0x3e53df('0x46')]['name'],_0x25b6c3['message']['id'],!![],_0x1cacf1,_0x41706e['id']);if(rpc[_0x25b6c3[_0x3e53df('0x3b')]+'QueueReport'])return rpc[_0x25b6c3[_0x3e53df('0x3b')]+_0x3e53df('0x22')][_0x3e53df('0x34')](_0x5626af)[_0x3e53df('0x27')](function(){const _0x1e64d5=_0x3e53df;logger[_0x1e64d5('0x1f')](_0x1e64d5('0x35'));});}}function stopRouting(_0x1a8360,_0x23c5e2,_0xbed743,_0x43ff3b){const _0x5af237=_0x35088c;if(_0x1a8360&&_0x23c5e2){_0x23c5e2[_0x5af237('0x24')]-=0x1;const _0x21b8bc={'leaveAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'acceptAt':moment()[_0x5af237('0xc')](_0x5af237('0x1e')),'reason':_0x5af237('0x2d')};logger['info'](util[_0x5af237('0xc')]('[%s][STOP:QUEUE][NAME:%s]',_0x1a8360,_0x23c5e2['name'])),emitChannelQueueInteraction(_0xbed743[_0x5af237('0x3b')],_0x23c5e2['name'],_0xbed743[_0x5af237('0x2e')],_0xbed743[_0x5af237('0x46')]['name'],_0xbed743[_0x5af237('0x45')]['id'],![],_0x43ff3b,_0x23c5e2['id']);if(rpc[_0xbed743['channel']+'QueueReport'])return rpc[_0xbed743['channel']+'QueueReport'][_0x5af237('0x6')](_0x1a8360,_0x21b8bc)[_0x5af237('0x27')](function(){const _0x3b5ea2=_0x5af237;logger[_0x3b5ea2('0x1f')](_0x3b5ea2('0x20'));});}}function endRouting(_0x512b8f,_0x3a6ee5,_0x50848b,_0x16c806){const _0x29ef57=_0x35088c;if(_0x512b8f&&_0x3a6ee5){_0x3a6ee5[_0x29ef57('0x24')]-=0x1;const _0x552935={'leaveAt':moment()[_0x29ef57('0xc')](_0x29ef57('0x1e')),'exitAt':moment()['format'](_0x29ef57('0x1e')),'reason':'timeout'};logger[_0x29ef57('0x7')](util[_0x29ef57('0xc')]('[%s][END:QUEUE][NAME:%s]',_0x512b8f,_0x3a6ee5[_0x29ef57('0x33')])),emitChannelQueueInteraction(_0x50848b[_0x29ef57('0x3b')],_0x3a6ee5[_0x29ef57('0x33')],_0x50848b['body'],_0x50848b[_0x29ef57('0x46')][_0x29ef57('0x33')],_0x50848b[_0x29ef57('0x45')]['id'],![],_0x16c806);if(rpc[_0x50848b[_0x29ef57('0x3b')]+_0x29ef57('0x22')])return rpc[_0x50848b[_0x29ef57('0x3b')]+_0x29ef57('0x22')]['update'](_0x512b8f,_0x552935)[_0x29ef57('0x27')](function(){const _0x56cdfc=_0x29ef57;logger[_0x56cdfc('0x1f')](_0x56cdfc('0x20'));});}}function handleFindQueue(_0x1a0e8c){return function(_0x5cc149){const _0x58445d=a1208_0xd855;return _0x5cc149[_0x58445d('0x33')][_0x58445d('0x3')]()===_0x1a0e8c[_0x58445d('0x3')]();};}exports[_0x35088c('0x13')]=function(_0x32b4e4,_0x5d4f0b,_0x34ada3,_0x4a8b2e){return function(_0x37fbda){const _0x54d21b=a1208_0xd855;try{const _0x25afc1={'name':_0x5d4f0b[0x0],'timeout':_0x5d4f0b[0x1]},_0x2166a9=queue[_0x54d21b('0x42')](_0x25afc1,{'typecast':!![]});if(_0x2166a9[_0x54d21b('0x14')])logger[_0x54d21b('0x1f')]('[%s][QUEUE]\x20%s',_0x32b4e4,_[_0x54d21b('0x1d')](_0x2166a9,_0x54d21b('0x45'))['join'](',\x20')),_0x37fbda[_0x54d21b('0x11')]();else{const _0x9d7a17=_[_0x54d21b('0x19')](_0x34ada3[_0x4a8b2e['channel']+_0x54d21b('0x2')],handleFindQueue(_0x25afc1[_0x54d21b('0x33')]));if(_0x9d7a17){startRouting(_0x32b4e4,_0x9d7a17,_0x4a8b2e,_0x34ada3);const _0x39236f=(_0x9d7a17[_0x54d21b('0x38')]||0xa)*0x3e8;let _0x576bf3=(_0x25afc1[_0x54d21b('0x38')]||0x14)*0x3e8,_0x3577a0;_0x39236f>_0x576bf3&&(_0x576bf3=_0x39236f);const _0x4daabb=seqqueue[_0x54d21b('0x32')](_0x39236f);_0x4daabb['id']=_0x32b4e4,_0x4daabb[_0x54d21b('0x2b')]=_0x39236f,_0x4daabb[_0x54d21b('0x37')]=_0x576bf3,_0x4daabb[_0x54d21b('0x3b')]=_0x4a8b2e[_0x54d21b('0x3b')],_0x34ada3[_0x54d21b('0x1c')][_0x32b4e4]['on'](_0x54d21b('0x5'),function(){const _0x3eeb0c=_0x54d21b;logger[_0x3eeb0c('0x7')](_0x3eeb0c('0x26'),_0x32b4e4),stopRouting(_0x32b4e4,_0x9d7a17,_0x4a8b2e,_0x34ada3),clearTimeout(_0x3577a0),_0x3577a0=undefined,_0x4daabb['close'](!![]),_0x34ada3['rules'][_0x32b4e4]&&delete _0x34ada3[_0x3eeb0c('0x1c')][_0x32b4e4],_0x37fbda[_0x3eeb0c('0x11')]();}),_0x34ada3[_0x54d21b('0x1c')][_0x32b4e4]['on']('complete',function(){const _0x652096=_0x54d21b;_0x34ada3['rules'][_0x32b4e4]&&delete _0x34ada3[_0x652096('0x1c')][_0x32b4e4];}),_0x3577a0=setTimeout(function(){const _0x478e02=_0x54d21b;logger['info'](_0x478e02('0x21'),_0x32b4e4),endRouting(_0x32b4e4,_0x9d7a17,_0x4a8b2e,_0x34ada3),clearTimeout(_0x3577a0),_0x4daabb[_0x478e02('0x47')](!![]),_0x37fbda[_0x478e02('0x1b')]();},_0x576bf3);switch(_0x9d7a17[_0x54d21b('0x40')]){case _0x54d21b('0x17'):strategy[_0x54d21b('0x17')](_0x4daabb,_0x9d7a17,_0x34ada3,_0x4a8b2e);break;default:strategy[_0x54d21b('0xa')](_0x4daabb,_0x9d7a17,_0x34ada3,_0x4a8b2e);}}else logger[_0x54d21b('0x1f')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x32b4e4,_0x25afc1['name']),_0x37fbda[_0x54d21b('0x11')]();}}catch(_0x4712df){console['log'](_0x4712df),logger[_0x54d21b('0x1f')]('[%s][QUEUE]\x20%s',_0x32b4e4,_0x4712df[_0x54d21b('0x10')]),_0x37fbda[_0x54d21b('0x11')]();}};};
\ No newline at end of file
+const a1208_0x1d1b=['strategy','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','name','timeout\x20is\x20a\x20number','body','from','stack','end','message','close','create\x20queue\x20report','[%s][QUEUE]\x20APPLICATION\x20END','WebsiteId','timeout','../../../../config/logger','routing','channel','list','queue','number','save','validate','joinAt','%s_queue_waiting_interaction:%s','%sQueuesWaitingInteractions','rules','util','../../rpc/whatsappQueueReport','interaction','upperFirst','rrmemory','../../rpc/smsQueueReport','./strategy','map','format','pick','%s:queue:%s','chat','update','[%s][QUEUE]\x20%s','beepall','contact','moment','catch','../../rpc/chatQueueReport','atimeout','AccountId','clone','error','queue_id','stop','update\x20queue\x20report','createQueue','join','YYYY-MM-DD\x20HH:mm:ss','create','waiting','InteractionId','account','../../rpc/mailQueueReport','emit','string','../../rpc/faxQueueReport','info','QueueId','lodash','../../../../rediscache','QueueReport','seq-queue','Queues','length','log','toLowerCase','accepted'];(function(_0x41ab65,_0x1d1b50){const _0x5bf690=function(_0x43d6f1){while(--_0x43d6f1){_0x41ab65['push'](_0x41ab65['shift']());}};_0x5bf690(++_0x1d1b50);}(a1208_0x1d1b,0x199));const a1208_0x5bf6=function(_0x41ab65,_0x1d1b50){_0x41ab65=_0x41ab65-0x0;let _0x5bf690=a1208_0x1d1b[_0x41ab65];return _0x5bf690;};const _0x3c1d61=a1208_0x5bf6;'use strict';const schema=require(_0x3c1d61('0x38')),_=require(_0x3c1d61('0x1a')),util=require(_0x3c1d61('0x3d')),seqqueue=require(_0x3c1d61('0x1d')),moment=require(_0x3c1d61('0x3')),logger=require(_0x3c1d61('0x31'))(_0x3c1d61('0x32')),strategy=require(_0x3c1d61('0x43')),{getSocket}=require(_0x3c1d61('0x1b')),io=getSocket(),attributes=['id',_0x3c1d61('0xa'),'account',_0x3c1d61('0x35'),_0x3c1d61('0x28'),_0x3c1d61('0x39')];function emit(_0x43d6f1,_0xfaed14,_0xe9db86){const _0x9f2a02=_0x3c1d61;io['to'](_0x43d6f1)[_0x9f2a02('0x15')](_0xfaed14,_0xe9db86);}function emitChannelQueueInteraction(_0xd46c6b,_0x4dc663,_0x3c4eea,_0x279670,_0x32bac1,_0x4053d1,_0x34e5e7,_0x76fa70){const _0x5b7870=_0x3c1d61,_0x46d2b9=_[_0x5b7870('0x8')](_0x3c4eea);_0x46d2b9[_0x5b7870('0xa')]=_0x76fa70,_0x46d2b9[_0x5b7870('0x35')]=_0x4dc663,_0x46d2b9[_0x5b7870('0x13')]=_0x279670,_0x46d2b9['id']=_0x32bac1,_0x4053d1?_0x34e5e7[util[_0x5b7870('0x45')](_0x5b7870('0x3b'),_0xd46c6b)][_0x32bac1]=_['pick'](_0x46d2b9,attributes):delete _0x34e5e7[util['format'](_0x5b7870('0x3b'),_0xd46c6b)][_0x32bac1],emit(util[_0x5b7870('0x45')](_0x5b7870('0x47'),_0xd46c6b,_0x4dc663),util[_0x5b7870('0x45')](_0x5b7870('0x3a'),_0xd46c6b,_0x4053d1?_0x5b7870('0x37'):'remove'),_[_0x5b7870('0x46')](_0x46d2b9,attributes));}const rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require(_0x3c1d61('0x14')),'chatQueueReport':require(_0x3c1d61('0x5')),'smsQueueReport':require(_0x3c1d61('0x42')),'faxQueueReport':require(_0x3c1d61('0x17')),'whatsappQueueReport':require(_0x3c1d61('0x3e'))},queue=schema({'name':{'type':_0x3c1d61('0x16'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x3c1d61('0x36'),'message':_0x3c1d61('0x26')}});function startRouting(_0x5e8bf1,_0x520823,_0x8b4334,_0xce09a4){const _0x3273b2=_0x3c1d61;if(_0x5e8bf1&&_0x520823&&_0x8b4334){_0x520823[_0x3273b2('0x11')]+=0x1;const _0x10cc23={'uniqueid':_0x5e8bf1,'from':_0x8b4334[_0x3273b2('0x27')]?_0x8b4334[_0x3273b2('0x27')][_0x3273b2('0x28')]:'','joinAt':moment()[_0x3273b2('0x45')](_0x3273b2('0xf')),'ContactId':_0x8b4334[_0x3273b2('0x2')]?_0x8b4334['contact']['id']:null,'ListId':_0x8b4334[_0x3273b2('0x34')]?_0x8b4334['list']['id']:null};_0x10cc23[_[_0x3273b2('0x40')](_0x8b4334[_0x3273b2('0x33')])+_0x3273b2('0x19')]=_0x520823['id']||null,_0x10cc23[_['upperFirst'](_0x8b4334[_0x3273b2('0x33')])+_0x3273b2('0x12')]=_0x8b4334[_0x3273b2('0x3f')]?_0x8b4334[_0x3273b2('0x3f')]['id']:null,_0x10cc23[_[_0x3273b2('0x40')](_0x8b4334[_0x3273b2('0x33')])+'MessageId']=_0x8b4334[_0x3273b2('0x2b')]?_0x8b4334['message']['id']:null,_0x10cc23[_[_0x3273b2('0x40')](_0x8b4334[_0x3273b2('0x33')])+(_0x8b4334[_0x3273b2('0x33')]!==_0x3273b2('0x48')?_0x3273b2('0x7'):_0x3273b2('0x2f'))]=_0x8b4334[_0x3273b2('0x13')]?_0x8b4334['account']['id']:null,logger[_0x3273b2('0x18')](util[_0x3273b2('0x45')]('[%s][START:QUEUE][NAME:%s]',_0x5e8bf1,_0x520823['name'])),emitChannelQueueInteraction(_0x8b4334[_0x3273b2('0x33')],_0x520823[_0x3273b2('0x25')],_0x10cc23,_0x8b4334['account'][_0x3273b2('0x25')],_0x8b4334[_0x3273b2('0x2b')]['id'],!![],_0xce09a4,_0x520823['id']);if(rpc[_0x8b4334[_0x3273b2('0x33')]+_0x3273b2('0x1c')])return rpc[_0x8b4334['channel']+_0x3273b2('0x1c')][_0x3273b2('0x10')](_0x10cc23)['catch'](function(){const _0x2299af=_0x3273b2;logger[_0x2299af('0x9')](_0x2299af('0x2d'));});}}function stopRouting(_0x4ab06b,_0x33b524,_0x4f2db9,_0x5e02de){const _0xa640c1=_0x3c1d61;if(_0x4ab06b&&_0x33b524){_0x33b524['waiting']-=0x1;const _0x588df4={'leaveAt':moment()[_0xa640c1('0x45')]('YYYY-MM-DD\x20HH:mm:ss'),'acceptAt':moment()[_0xa640c1('0x45')](_0xa640c1('0xf')),'reason':_0xa640c1('0x22')};logger[_0xa640c1('0x18')](util[_0xa640c1('0x45')]('[%s][STOP:QUEUE][NAME:%s]',_0x4ab06b,_0x33b524[_0xa640c1('0x25')])),emitChannelQueueInteraction(_0x4f2db9[_0xa640c1('0x33')],_0x33b524['name'],_0x4f2db9[_0xa640c1('0x27')],_0x4f2db9[_0xa640c1('0x13')][_0xa640c1('0x25')],_0x4f2db9['message']['id'],![],_0x5e02de,_0x33b524['id']);if(rpc[_0x4f2db9[_0xa640c1('0x33')]+'QueueReport'])return rpc[_0x4f2db9[_0xa640c1('0x33')]+_0xa640c1('0x1c')][_0xa640c1('0x49')](_0x4ab06b,_0x588df4)[_0xa640c1('0x4')](function(){const _0x5e7765=_0xa640c1;logger['error'](_0x5e7765('0xc'));});}}function endRouting(_0x529cab,_0x32deac,_0x5dcb24,_0x3b5c02){const _0x5c17d2=_0x3c1d61;if(_0x529cab&&_0x32deac){_0x32deac[_0x5c17d2('0x11')]-=0x1;const _0x376bc0={'leaveAt':moment()[_0x5c17d2('0x45')](_0x5c17d2('0xf')),'exitAt':moment()[_0x5c17d2('0x45')](_0x5c17d2('0xf')),'reason':_0x5c17d2('0x30')};logger['info'](util[_0x5c17d2('0x45')]('[%s][END:QUEUE][NAME:%s]',_0x529cab,_0x32deac[_0x5c17d2('0x25')])),emitChannelQueueInteraction(_0x5dcb24['channel'],_0x32deac['name'],_0x5dcb24[_0x5c17d2('0x27')],_0x5dcb24[_0x5c17d2('0x13')][_0x5c17d2('0x25')],_0x5dcb24[_0x5c17d2('0x2b')]['id'],![],_0x3b5c02);if(rpc[_0x5dcb24[_0x5c17d2('0x33')]+_0x5c17d2('0x1c')])return rpc[_0x5dcb24[_0x5c17d2('0x33')]+_0x5c17d2('0x1c')][_0x5c17d2('0x49')](_0x529cab,_0x376bc0)[_0x5c17d2('0x4')](function(){const _0x152058=_0x5c17d2;logger[_0x152058('0x9')](_0x152058('0xc'));});}}function handleFindQueue(_0x54359d){return function(_0x5896c8){const _0x4a726e=a1208_0x5bf6;return _0x5896c8[_0x4a726e('0x25')]['toLowerCase']()===_0x54359d[_0x4a726e('0x21')]();};}exports['consequence']=function(_0x11b15a,_0x4b58a8,_0x2b2c39,_0x1347c0){return function(_0xfb903d){const _0x4abdd0=a1208_0x5bf6;try{const _0x24e3a6={'name':_0x4b58a8[0x0],'timeout':_0x4b58a8[0x1]},_0xeb3faf=queue['validate'](_0x24e3a6,{'typecast':!![]});if(_0xeb3faf[_0x4abdd0('0x1f')])logger['error'](_0x4abdd0('0x0'),_0x11b15a,_[_0x4abdd0('0x44')](_0xeb3faf,_0x4abdd0('0x2b'))[_0x4abdd0('0xe')](',\x20')),_0xfb903d[_0x4abdd0('0xb')]();else{const _0x48ba7d=_['find'](_0x2b2c39[_0x1347c0[_0x4abdd0('0x33')]+_0x4abdd0('0x1e')],handleFindQueue(_0x24e3a6['name']));if(_0x48ba7d){startRouting(_0x11b15a,_0x48ba7d,_0x1347c0,_0x2b2c39);const _0xa8dcbe=(_0x48ba7d[_0x4abdd0('0x30')]||0xa)*0x3e8;let _0x3233ba=(_0x24e3a6['timeout']||0x14)*0x3e8,_0x441c5e;_0xa8dcbe>_0x3233ba&&(_0x3233ba=_0xa8dcbe);const _0x310e48=seqqueue[_0x4abdd0('0xd')](_0xa8dcbe);_0x310e48['id']=_0x11b15a,_0x310e48[_0x4abdd0('0x6')]=_0xa8dcbe,_0x310e48['qtimeout']=_0x3233ba,_0x310e48['channel']=_0x1347c0[_0x4abdd0('0x33')],_0x2b2c39['rules'][_0x11b15a]['on'](_0x4abdd0('0x2a'),function(){const _0x106503=_0x4abdd0;logger[_0x106503('0x18')]('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x11b15a),stopRouting(_0x11b15a,_0x48ba7d,_0x1347c0,_0x2b2c39),clearTimeout(_0x441c5e),_0x441c5e=undefined,_0x310e48[_0x106503('0x2c')](!![]),_0x2b2c39['rules'][_0x11b15a]&&delete _0x2b2c39[_0x106503('0x3c')][_0x11b15a],_0xfb903d[_0x106503('0xb')]();}),_0x2b2c39[_0x4abdd0('0x3c')][_0x11b15a]['on']('complete',function(){const _0x1e0238=_0x4abdd0;_0x2b2c39[_0x1e0238('0x3c')][_0x11b15a]&&delete _0x2b2c39[_0x1e0238('0x3c')][_0x11b15a];}),_0x441c5e=setTimeout(function(){const _0x3cf183=_0x4abdd0;logger[_0x3cf183('0x18')](_0x3cf183('0x2e'),_0x11b15a),endRouting(_0x11b15a,_0x48ba7d,_0x1347c0,_0x2b2c39),clearTimeout(_0x441c5e),_0x310e48['close'](!![]),_0xfb903d['next']();},_0x3233ba);switch(_0x48ba7d[_0x4abdd0('0x23')]){case _0x4abdd0('0x41'):strategy[_0x4abdd0('0x41')](_0x310e48,_0x48ba7d,_0x2b2c39,_0x1347c0);break;default:strategy[_0x4abdd0('0x1')](_0x310e48,_0x48ba7d,_0x2b2c39,_0x1347c0);}}else logger['error'](_0x4abdd0('0x24'),_0x11b15a,_0x24e3a6['name']),_0xfb903d['stop']();}}catch(_0x5d626d){console[_0x4abdd0('0x20')](_0x5d626d),logger[_0x4abdd0('0x9')](_0x4abdd0('0x0'),_0x11b15a,_0x5d626d[_0x4abdd0('0x29')]),_0xfb903d[_0x4abdd0('0xb')]();}};};
\ No newline at end of file