Built motion from commit 5ad77b03.|2.6.3
[motion2.git] / server / services / routing / server / applications / queue.js
index d300ae3..c062791 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xd3e7=['message','AccountId','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','create\x20queue\x20report','accepted','[%s][STOP:QUEUE][NAME:%s]','update\x20queue\x20report','timeout','error','consequence','length','[%s][QUEUE]\x20%s','map','join','stop','Queues','createQueue','atimeout','qtimeout','rules','end','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','strategy','rrmemory','beepall','log','stack','validate','util','ioredis','../../../../config/environment','../../../../config/logger','routing','redis','defaults','localhost','socket.io-emitter','queue_id','account','queue','joinAt','emit','clone','format','%s:queue:%s','%s_queue_waiting_interaction:%s','save','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','QueueId','channel','InteractionId','interaction','MessageId'];(function(_0x440f36,_0x22f849){var _0x3d49cd=function(_0x28e35f){while(--_0x28e35f){_0x440f36['push'](_0x440f36['shift']());}};_0x3d49cd(++_0x22f849);}(_0xd3e7,0xb9));var _0x7d3e=function(_0x122ef9,_0x451d2a){_0x122ef9=_0x122ef9-0x0;var _0x42fba0=_0xd3e7[_0x122ef9];return _0x42fba0;};'use strict';var schema=require(_0x7d3e('0x0'));var _=require('lodash');var util=require(_0x7d3e('0x1'));var seqqueue=require('seq-queue');var moment=require('moment');var Redis=require(_0x7d3e('0x2'));var config=require(_0x7d3e('0x3'));var logger=require(_0x7d3e('0x4'))(_0x7d3e('0x5'));var strategy=require('./strategy');config[_0x7d3e('0x6')]=_[_0x7d3e('0x7')](config['redis'],{'host':_0x7d3e('0x8'),'port':0x18eb});var io=require(_0x7d3e('0x9'))(new Redis(config['redis']));var attributes=['id',_0x7d3e('0xa'),_0x7d3e('0xb'),_0x7d3e('0xc'),'from',_0x7d3e('0xd')];function emit(_0x5d9d6c,_0x1cb227,_0x1dd6d2){io['to'](_0x5d9d6c)[_0x7d3e('0xe')](_0x1cb227,_0x1dd6d2);}function emitChannelQueueInteraction(_0x5ea419,_0x5a6b57,_0x589971,_0x342ced,_0x2983d9,_0x48c6e9,_0x3b7bf0,_0x1063d7){var _0x3dd748=_[_0x7d3e('0xf')](_0x589971);_0x3dd748['queue_id']=_0x1063d7;_0x3dd748[_0x7d3e('0xc')]=_0x5a6b57;_0x3dd748['account']=_0x342ced;_0x3dd748['id']=_0x2983d9;if(_0x48c6e9){_0x3b7bf0[util['format']('%sQueuesWaitingInteractions',_0x5ea419)][_0x2983d9]=_['pick'](_0x3dd748,attributes);}else{delete _0x3b7bf0[util[_0x7d3e('0x10')]('%sQueuesWaitingInteractions',_0x5ea419)][_0x2983d9];}emit(util[_0x7d3e('0x10')](_0x7d3e('0x11'),_0x5ea419,_0x5a6b57),util[_0x7d3e('0x10')](_0x7d3e('0x12'),_0x5ea419,_0x48c6e9?_0x7d3e('0x13'):'remove'),_['pick'](_0x3dd748,attributes));}var rpc={'openchannelQueueReport':require(_0x7d3e('0x14')),'mailQueueReport':require(_0x7d3e('0x15')),'chatQueueReport':require('../../rpc/chatQueueReport'),'smsQueueReport':require(_0x7d3e('0x16')),'faxQueueReport':require(_0x7d3e('0x17')),'whatsappQueueReport':require(_0x7d3e('0x18'))};var queue=schema({'name':{'type':_0x7d3e('0x19'),'required':!![],'message':_0x7d3e('0x1a')},'timeout':{'type':_0x7d3e('0x1b'),'message':_0x7d3e('0x1c')}});function startRouting(_0x12f191,_0x4af715,_0x324222,_0x7e1129){if(_0x12f191&&_0x4af715&&_0x324222){_0x4af715[_0x7d3e('0x1d')]+=0x1;var _0x1fe449={'uniqueid':_0x12f191,'from':_0x324222[_0x7d3e('0x1e')]?_0x324222[_0x7d3e('0x1e')]['from']:'','joinAt':moment()[_0x7d3e('0x10')](_0x7d3e('0x1f')),'ContactId':_0x324222[_0x7d3e('0x20')]?_0x324222['contact']['id']:null,'ListId':_0x324222[_0x7d3e('0x21')]?_0x324222[_0x7d3e('0x21')]['id']:null};_0x1fe449[_[_0x7d3e('0x22')](_0x324222['channel'])+_0x7d3e('0x23')]=_0x4af715['id']||null;_0x1fe449[_['upperFirst'](_0x324222[_0x7d3e('0x24')])+_0x7d3e('0x25')]=_0x324222[_0x7d3e('0x26')]?_0x324222[_0x7d3e('0x26')]['id']:null;_0x1fe449[_['upperFirst'](_0x324222['channel'])+_0x7d3e('0x27')]=_0x324222[_0x7d3e('0x28')]?_0x324222[_0x7d3e('0x28')]['id']:null;_0x1fe449[_[_0x7d3e('0x22')](_0x324222['channel'])+(_0x324222[_0x7d3e('0x24')]!=='chat'?_0x7d3e('0x29'):_0x7d3e('0x2a'))]=_0x324222[_0x7d3e('0xb')]?_0x324222['account']['id']:null;logger[_0x7d3e('0x2b')](util[_0x7d3e('0x10')](_0x7d3e('0x2c'),_0x12f191,_0x4af715[_0x7d3e('0x2d')]));emitChannelQueueInteraction(_0x324222[_0x7d3e('0x24')],_0x4af715[_0x7d3e('0x2d')],_0x1fe449,_0x324222['account'][_0x7d3e('0x2d')],_0x324222['message']['id'],!![],_0x7e1129,_0x4af715['id']);if(rpc[_0x324222[_0x7d3e('0x24')]+_0x7d3e('0x2e')]){return rpc[_0x324222[_0x7d3e('0x24')]+_0x7d3e('0x2e')][_0x7d3e('0x2f')](_0x1fe449)[_0x7d3e('0x30')](function(_0x425174){logger['error'](_0x7d3e('0x31'));});}}}function stopRouting(_0x2cecd0,_0x492986,_0x42192d,_0x2a8572){if(_0x2cecd0&&_0x492986){_0x492986['waiting']-=0x1;var _0x22b4e6={'leaveAt':moment()[_0x7d3e('0x10')](_0x7d3e('0x1f')),'acceptAt':moment()[_0x7d3e('0x10')](_0x7d3e('0x1f')),'reason':_0x7d3e('0x32')};logger[_0x7d3e('0x2b')](util['format'](_0x7d3e('0x33'),_0x2cecd0,_0x492986[_0x7d3e('0x2d')]));emitChannelQueueInteraction(_0x42192d[_0x7d3e('0x24')],_0x492986[_0x7d3e('0x2d')],_0x42192d[_0x7d3e('0x1e')],_0x42192d[_0x7d3e('0xb')][_0x7d3e('0x2d')],_0x42192d[_0x7d3e('0x28')]['id'],![],_0x2a8572,_0x492986['id']);if(rpc[_0x42192d[_0x7d3e('0x24')]+_0x7d3e('0x2e')]){return rpc[_0x42192d[_0x7d3e('0x24')]+_0x7d3e('0x2e')]['update'](_0x2cecd0,_0x22b4e6)['catch'](function(_0x73f96a){logger['error'](_0x7d3e('0x34'));});}}}function endRouting(_0x36afc8,_0x10ec8b,_0x56531e,_0x4ec01c){if(_0x36afc8&&_0x10ec8b){_0x10ec8b['waiting']-=0x1;var _0x22bc1f={'leaveAt':moment()[_0x7d3e('0x10')](_0x7d3e('0x1f')),'exitAt':moment()[_0x7d3e('0x10')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x7d3e('0x35')};logger[_0x7d3e('0x2b')](util[_0x7d3e('0x10')]('[%s][END:QUEUE][NAME:%s]',_0x36afc8,_0x10ec8b[_0x7d3e('0x2d')]));emitChannelQueueInteraction(_0x56531e[_0x7d3e('0x24')],_0x10ec8b['name'],_0x56531e[_0x7d3e('0x1e')],_0x56531e[_0x7d3e('0xb')][_0x7d3e('0x2d')],_0x56531e[_0x7d3e('0x28')]['id'],![],_0x4ec01c);if(rpc[_0x56531e[_0x7d3e('0x24')]+'QueueReport']){return rpc[_0x56531e[_0x7d3e('0x24')]+_0x7d3e('0x2e')]['update'](_0x36afc8,_0x22bc1f)[_0x7d3e('0x30')](function(_0x25c0d0){logger[_0x7d3e('0x36')]('update\x20queue\x20report');});}}}function handleFindQueue(_0xd583ec){return function(_0x3ccfd6){return _0x3ccfd6['name']['toLowerCase']()===_0xd583ec['toLowerCase']();};}exports[_0x7d3e('0x37')]=function(_0x410868,_0x45d0f0,_0x1afdd4,_0x4b6f12){return function(_0x2a23f1){try{var _0x574a6b={'name':_0x45d0f0[0x0],'timeout':_0x45d0f0[0x1]};var _0x2808e9=queue[_0x7d3e('0x0')](_0x574a6b,{'typecast':!![]});if(_0x2808e9[_0x7d3e('0x38')]){logger[_0x7d3e('0x36')](_0x7d3e('0x39'),_0x410868,_[_0x7d3e('0x3a')](_0x2808e9,_0x7d3e('0x28'))[_0x7d3e('0x3b')](',\x20'));_0x2a23f1[_0x7d3e('0x3c')]();}else{var _0x252a1d=_['find'](_0x1afdd4[_0x4b6f12[_0x7d3e('0x24')]+_0x7d3e('0x3d')],handleFindQueue(_0x574a6b['name']));if(_0x252a1d){startRouting(_0x410868,_0x252a1d,_0x4b6f12,_0x1afdd4);var _0x3c1d57=(_0x252a1d['timeout']||0xa)*0x3e8;var _0x3ae4cf=(_0x574a6b['timeout']||0x14)*0x3e8;var _0x466cd3,_0xe1187a;if(_0x3c1d57>_0x3ae4cf){_0x3ae4cf=_0x3c1d57;}var _0x3d2888=seqqueue[_0x7d3e('0x3e')](_0x3c1d57);_0x3d2888['id']=_0x410868;_0x3d2888[_0x7d3e('0x3f')]=_0x3c1d57;_0x3d2888[_0x7d3e('0x40')]=_0x3ae4cf;_0x3d2888[_0x7d3e('0x24')]=_0x4b6f12[_0x7d3e('0x24')];_0x1afdd4[_0x7d3e('0x41')][_0x410868]['on'](_0x7d3e('0x42'),function(){logger['info']('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x410868);stopRouting(_0x410868,_0x252a1d,_0x4b6f12,_0x1afdd4);clearTimeout(_0x466cd3);_0x466cd3=undefined;_0x3d2888[_0x7d3e('0x43')](!![]);if(_0x1afdd4[_0x7d3e('0x41')][_0x410868]){delete _0x1afdd4[_0x7d3e('0x41')][_0x410868];}_0x2a23f1[_0x7d3e('0x3c')]();});_0x1afdd4[_0x7d3e('0x41')][_0x410868]['on'](_0x7d3e('0x44'),function(){if(_0x1afdd4[_0x7d3e('0x41')][_0x410868]){delete _0x1afdd4['rules'][_0x410868];}});_0x466cd3=setTimeout(function(){logger['info'](_0x7d3e('0x45'),_0x410868);endRouting(_0x410868,_0x252a1d,_0x4b6f12,_0x1afdd4);clearTimeout(_0x466cd3);_0x3d2888[_0x7d3e('0x43')](!![]);_0x2a23f1['next']();},_0x3ae4cf);switch(_0x252a1d[_0x7d3e('0x46')]){case _0x7d3e('0x47'):strategy[_0x7d3e('0x47')](_0x3d2888,_0x252a1d,_0x1afdd4,_0x4b6f12);break;default:strategy[_0x7d3e('0x48')](_0x3d2888,_0x252a1d,_0x1afdd4,_0x4b6f12);}}else{logger[_0x7d3e('0x36')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x410868,_0x574a6b['name']);_0x2a23f1['stop']();}}}catch(_0x373cb4){console[_0x7d3e('0x49')](_0x373cb4);logger[_0x7d3e('0x36')](_0x7d3e('0x39'),_0x410868,_0x373cb4[_0x7d3e('0x4a')]);_0x2a23f1[_0x7d3e('0x3c')]();}};};
\ No newline at end of file
+var _0xa3de=['WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','create\x20queue\x20report','YYYY-MM-DD\x20HH:mm:ss','accepted','[%s][STOP:QUEUE][NAME:%s]','update','update\x20queue\x20report','timeout','error','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','join','find','createQueue','atimeout','qtimeout','rules','end','close','stop','complete','strategy','rrmemory','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','log','stack','validate','lodash','util','moment','../../../../config/logger','routing','./strategy','redis','localhost','socket.io-emitter','queue_id','account','queue','from','joinAt','emit','clone','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','timeout\x20is\x20a\x20number','waiting','body','contact','list','upperFirst','QueueId','channel','InteractionId','MessageId','message','chat','AccountId'];(function(_0x433dcc,_0x2ac9a9){var _0x1ff237=function(_0xfe5399){while(--_0xfe5399){_0x433dcc['push'](_0x433dcc['shift']());}};_0x1ff237(++_0x2ac9a9);}(_0xa3de,0x199));var _0xea3d=function(_0x252328,_0x4c22f0){_0x252328=_0x252328-0x0;var _0xaa85b7=_0xa3de[_0x252328];return _0xaa85b7;};'use strict';var schema=require(_0xea3d('0x0'));var _=require(_0xea3d('0x1'));var util=require(_0xea3d('0x2'));var seqqueue=require('seq-queue');var moment=require(_0xea3d('0x3'));var Redis=require('ioredis');var config=require('../../../../config/environment');var logger=require(_0xea3d('0x4'))(_0xea3d('0x5'));var strategy=require(_0xea3d('0x6'));config[_0xea3d('0x7')]=_['defaults'](config['redis'],{'host':_0xea3d('0x8'),'port':0x18eb});var io=require(_0xea3d('0x9'))(new Redis(config[_0xea3d('0x7')]));var attributes=['id',_0xea3d('0xa'),_0xea3d('0xb'),_0xea3d('0xc'),_0xea3d('0xd'),_0xea3d('0xe')];function emit(_0xe92c6e,_0xa070d4,_0x4e9440){io['to'](_0xe92c6e)[_0xea3d('0xf')](_0xa070d4,_0x4e9440);}function emitChannelQueueInteraction(_0x36f456,_0x31ee59,_0x32233e,_0x32188a,_0x544a51,_0x3e62da,_0x5518be,_0x4609ad){var _0x242f80=_[_0xea3d('0x10')](_0x32233e);_0x242f80[_0xea3d('0xa')]=_0x4609ad;_0x242f80[_0xea3d('0xc')]=_0x31ee59;_0x242f80[_0xea3d('0xb')]=_0x32188a;_0x242f80['id']=_0x544a51;if(_0x3e62da){_0x5518be[util[_0xea3d('0x11')](_0xea3d('0x12'),_0x36f456)][_0x544a51]=_[_0xea3d('0x13')](_0x242f80,attributes);}else{delete _0x5518be[util[_0xea3d('0x11')]('%sQueuesWaitingInteractions',_0x36f456)][_0x544a51];}emit(util[_0xea3d('0x11')](_0xea3d('0x14'),_0x36f456,_0x31ee59),util[_0xea3d('0x11')](_0xea3d('0x15'),_0x36f456,_0x3e62da?_0xea3d('0x16'):_0xea3d('0x17')),_[_0xea3d('0x13')](_0x242f80,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require(_0xea3d('0x18')),'smsQueueReport':require(_0xea3d('0x19')),'faxQueueReport':require(_0xea3d('0x1a')),'whatsappQueueReport':require('../../rpc/whatsappQueueReport')};var queue=schema({'name':{'type':'string','required':!![],'message':_0xea3d('0x1b')},'timeout':{'type':'number','message':_0xea3d('0x1c')}});function startRouting(_0x2a18a7,_0x85bcc7,_0x51e053,_0x1af60b){if(_0x2a18a7&&_0x85bcc7&&_0x51e053){_0x85bcc7[_0xea3d('0x1d')]+=0x1;var _0x10fa96={'uniqueid':_0x2a18a7,'from':_0x51e053[_0xea3d('0x1e')]?_0x51e053[_0xea3d('0x1e')][_0xea3d('0xd')]:'','joinAt':moment()[_0xea3d('0x11')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x51e053[_0xea3d('0x1f')]?_0x51e053['contact']['id']:null,'ListId':_0x51e053[_0xea3d('0x20')]?_0x51e053[_0xea3d('0x20')]['id']:null};_0x10fa96[_[_0xea3d('0x21')](_0x51e053['channel'])+_0xea3d('0x22')]=_0x85bcc7['id']||null;_0x10fa96[_[_0xea3d('0x21')](_0x51e053[_0xea3d('0x23')])+_0xea3d('0x24')]=_0x51e053['interaction']?_0x51e053['interaction']['id']:null;_0x10fa96[_[_0xea3d('0x21')](_0x51e053['channel'])+_0xea3d('0x25')]=_0x51e053[_0xea3d('0x26')]?_0x51e053[_0xea3d('0x26')]['id']:null;_0x10fa96[_[_0xea3d('0x21')](_0x51e053[_0xea3d('0x23')])+(_0x51e053[_0xea3d('0x23')]!==_0xea3d('0x27')?_0xea3d('0x28'):_0xea3d('0x29'))]=_0x51e053['account']?_0x51e053[_0xea3d('0xb')]['id']:null;logger[_0xea3d('0x2a')](util[_0xea3d('0x11')](_0xea3d('0x2b'),_0x2a18a7,_0x85bcc7[_0xea3d('0x2c')]));emitChannelQueueInteraction(_0x51e053[_0xea3d('0x23')],_0x85bcc7[_0xea3d('0x2c')],_0x10fa96,_0x51e053[_0xea3d('0xb')][_0xea3d('0x2c')],_0x51e053[_0xea3d('0x26')]['id'],!![],_0x1af60b,_0x85bcc7['id']);if(rpc[_0x51e053[_0xea3d('0x23')]+_0xea3d('0x2d')]){return rpc[_0x51e053[_0xea3d('0x23')]+'QueueReport'][_0xea3d('0x2e')](_0x10fa96)[_0xea3d('0x2f')](function(_0x214482){logger['error'](_0xea3d('0x30'));});}}}function stopRouting(_0x66deed,_0x5d6811,_0xb245d5,_0x180bff){if(_0x66deed&&_0x5d6811){_0x5d6811[_0xea3d('0x1d')]-=0x1;var _0x41a140={'leaveAt':moment()[_0xea3d('0x11')](_0xea3d('0x31')),'acceptAt':moment()[_0xea3d('0x11')](_0xea3d('0x31')),'reason':_0xea3d('0x32')};logger[_0xea3d('0x2a')](util['format'](_0xea3d('0x33'),_0x66deed,_0x5d6811[_0xea3d('0x2c')]));emitChannelQueueInteraction(_0xb245d5['channel'],_0x5d6811[_0xea3d('0x2c')],_0xb245d5[_0xea3d('0x1e')],_0xb245d5[_0xea3d('0xb')][_0xea3d('0x2c')],_0xb245d5[_0xea3d('0x26')]['id'],![],_0x180bff,_0x5d6811['id']);if(rpc[_0xb245d5[_0xea3d('0x23')]+_0xea3d('0x2d')]){return rpc[_0xb245d5[_0xea3d('0x23')]+'QueueReport'][_0xea3d('0x34')](_0x66deed,_0x41a140)[_0xea3d('0x2f')](function(_0xbfa186){logger['error'](_0xea3d('0x35'));});}}}function endRouting(_0x1fb12,_0x1d63e8,_0x5602e8,_0x1585f7){if(_0x1fb12&&_0x1d63e8){_0x1d63e8['waiting']-=0x1;var _0x526fe9={'leaveAt':moment()['format'](_0xea3d('0x31')),'exitAt':moment()[_0xea3d('0x11')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0xea3d('0x36')};logger[_0xea3d('0x2a')](util[_0xea3d('0x11')]('[%s][END:QUEUE][NAME:%s]',_0x1fb12,_0x1d63e8['name']));emitChannelQueueInteraction(_0x5602e8[_0xea3d('0x23')],_0x1d63e8[_0xea3d('0x2c')],_0x5602e8[_0xea3d('0x1e')],_0x5602e8['account'][_0xea3d('0x2c')],_0x5602e8['message']['id'],![],_0x1585f7);if(rpc[_0x5602e8[_0xea3d('0x23')]+_0xea3d('0x2d')]){return rpc[_0x5602e8[_0xea3d('0x23')]+_0xea3d('0x2d')]['update'](_0x1fb12,_0x526fe9)[_0xea3d('0x2f')](function(_0xc3d6f6){logger[_0xea3d('0x37')](_0xea3d('0x35'));});}}}function handleFindQueue(_0x432b8a){return function(_0x38ec53){return _0x38ec53[_0xea3d('0x2c')][_0xea3d('0x38')]()===_0x432b8a[_0xea3d('0x38')]();};}exports[_0xea3d('0x39')]=function(_0x45748e,_0x1a8eb2,_0x11ffaa,_0x17d2d2){return function(_0x53e7fb){try{var _0x2dcd53={'name':_0x1a8eb2[0x0],'timeout':_0x1a8eb2[0x1]};var _0x5d6203=queue[_0xea3d('0x0')](_0x2dcd53,{'typecast':!![]});if(_0x5d6203[_0xea3d('0x3a')]){logger['error'](_0xea3d('0x3b'),_0x45748e,_['map'](_0x5d6203,'message')[_0xea3d('0x3c')](',\x20'));_0x53e7fb['stop']();}else{var _0x4877ad=_[_0xea3d('0x3d')](_0x11ffaa[_0x17d2d2['channel']+'Queues'],handleFindQueue(_0x2dcd53[_0xea3d('0x2c')]));if(_0x4877ad){startRouting(_0x45748e,_0x4877ad,_0x17d2d2,_0x11ffaa);var _0x57ae8b=(_0x4877ad['timeout']||0xa)*0x3e8;var _0x121d72=(_0x2dcd53[_0xea3d('0x36')]||0x14)*0x3e8;var _0x38f64b,_0x2580f3;if(_0x57ae8b>_0x121d72){_0x121d72=_0x57ae8b;}var _0x540306=seqqueue[_0xea3d('0x3e')](_0x57ae8b);_0x540306['id']=_0x45748e;_0x540306[_0xea3d('0x3f')]=_0x57ae8b;_0x540306[_0xea3d('0x40')]=_0x121d72;_0x540306['channel']=_0x17d2d2['channel'];_0x11ffaa[_0xea3d('0x41')][_0x45748e]['on'](_0xea3d('0x42'),function(){logger[_0xea3d('0x2a')]('[%s][QUEUE]\x20ROUTING\x20STOPPED',_0x45748e);stopRouting(_0x45748e,_0x4877ad,_0x17d2d2,_0x11ffaa);clearTimeout(_0x38f64b);_0x38f64b=undefined;_0x540306[_0xea3d('0x43')](!![]);if(_0x11ffaa[_0xea3d('0x41')][_0x45748e]){delete _0x11ffaa[_0xea3d('0x41')][_0x45748e];}_0x53e7fb[_0xea3d('0x44')]();});_0x11ffaa[_0xea3d('0x41')][_0x45748e]['on'](_0xea3d('0x45'),function(){if(_0x11ffaa[_0xea3d('0x41')][_0x45748e]){delete _0x11ffaa[_0xea3d('0x41')][_0x45748e];}});_0x38f64b=setTimeout(function(){logger[_0xea3d('0x2a')]('[%s][QUEUE]\x20APPLICATION\x20END',_0x45748e);endRouting(_0x45748e,_0x4877ad,_0x17d2d2,_0x11ffaa);clearTimeout(_0x38f64b);_0x540306[_0xea3d('0x43')](!![]);_0x53e7fb['next']();},_0x121d72);switch(_0x4877ad[_0xea3d('0x46')]){case _0xea3d('0x47'):strategy[_0xea3d('0x47')](_0x540306,_0x4877ad,_0x11ffaa,_0x17d2d2);break;default:strategy['beepall'](_0x540306,_0x4877ad,_0x11ffaa,_0x17d2d2);}}else{logger[_0xea3d('0x37')](_0xea3d('0x48'),_0x45748e,_0x2dcd53[_0xea3d('0x2c')]);_0x53e7fb['stop']();}}}catch(_0x48ef3f){console[_0xea3d('0x49')](_0x48ef3f);logger[_0xea3d('0x37')]('[%s][QUEUE]\x20%s',_0x45748e,_0x48ef3f[_0xea3d('0x4a')]);_0x53e7fb[_0xea3d('0x44')]();}};};
\ No newline at end of file