Built motion from commit b0a9a629.|2.6.33
[motion2.git] / server / services / routing / server / applications / queue.js
index 59a42c1..29cfa7b 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x6368=['body','contact','list','upperFirst','QueueId','channel','interaction','MessageId','message','AccountId','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]','Interaction','update','then','error','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','validate','[%s][QUEUE]\x20%s','join','stop','Queues','createQueue','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','strategy','rrmemory','beepall','util','seq-queue','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','localhost','queue_id','account','queue','from','clone','push','capitalize','InteractionId','%sQueuesWaitingInteractions','pick','format','%s:queue:%s','%s_queue_waiting_interaction:%s','save','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/smsQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','waiting'];(function(_0x585221,_0xb7e318){var _0x17111b=function(_0x5c9de0){while(--_0x5c9de0){_0x585221['push'](_0x585221['shift']());}};_0x17111b(++_0xb7e318);}(_0x6368,0x187));var _0x8636=function(_0x44b43f,_0x45c0c2){_0x44b43f=_0x44b43f-0x0;var _0xb95bf1=_0x6368[_0x44b43f];return _0xb95bf1;};'use strict';var schema=require('validate');var _=require('lodash');var util=require(_0x8636('0x0'));var seqqueue=require(_0x8636('0x1'));var moment=require(_0x8636('0x2'));var Redis=require(_0x8636('0x3'));var config=require(_0x8636('0x4'));var logger=require(_0x8636('0x5'))(_0x8636('0x6'));var strategy=require(_0x8636('0x7'));config[_0x8636('0x8')]=_[_0x8636('0x9')](config['redis'],{'host':_0x8636('0xa'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config[_0x8636('0x8')]));var attributes=['id',_0x8636('0xb'),_0x8636('0xc'),_0x8636('0xd'),_0x8636('0xe'),'joinAt'];function emit(_0x3c0cf4,_0x3902a3,_0x59c89c){io['to'](_0x3c0cf4)['emit'](_0x3902a3,_0x59c89c);}function emitChannelQueueInteraction(_0x14ee0e,_0x34fdd4,_0xf19e76,_0x52f21d,_0x513b61,_0x8a5c08,_0x50d991,_0x414c6c){var _0x538b5b=_[_0x8636('0xf')](_0xf19e76);_0x538b5b[_0x8636('0xb')]=_0x414c6c;_0x538b5b[_0x8636('0xd')]=_0x34fdd4;_0x538b5b[_0x8636('0xc')]=_0x52f21d;_0x538b5b['id']=_0x513b61;if(_0x8a5c08){attributes[_0x8636('0x10')](_[_0x8636('0x11')](_0x14ee0e)+_0x8636('0x12'));_0x50d991[util['format'](_0x8636('0x13'),_0x14ee0e)][_0x513b61]=_[_0x8636('0x14')](_0x538b5b,attributes);}else{delete _0x50d991[util[_0x8636('0x15')](_0x8636('0x13'),_0x14ee0e)][_0x513b61];}emit(util[_0x8636('0x15')](_0x8636('0x16'),_0x14ee0e,_0x34fdd4),util['format'](_0x8636('0x17'),_0x14ee0e,_0x8a5c08?_0x8636('0x18'):_0x8636('0x19')),_['pick'](_0x538b5b,attributes));}var rpc={'openchannelQueueReport':require(_0x8636('0x1a')),'mailQueueReport':require(_0x8636('0x1b')),'chatQueueReport':require('../../rpc/chatQueueReport'),'smsQueueReport':require(_0x8636('0x1c')),'faxQueueReport':require(_0x8636('0x1d')),'whatsappQueueReport':require(_0x8636('0x1e')),'chatInteraction':require(_0x8636('0x1f')),'faxInteraction':require(_0x8636('0x20')),'mailInteraction':require(_0x8636('0x21')),'openchannelInteraction':require(_0x8636('0x22')),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require('../../rpc/whatsappInteraction')};var queue=schema({'name':{'type':_0x8636('0x23'),'required':!![],'message':_0x8636('0x24')},'timeout':{'type':_0x8636('0x25'),'message':'timeout\x20is\x20a\x20number'}});function startRouting(_0x454c58,_0x8ba13,_0x1d7d40,_0x256d79){if(_0x454c58&&_0x8ba13&&_0x1d7d40){_0x8ba13[_0x8636('0x26')]+=0x1;var _0x4e48e5={'uniqueid':_0x454c58,'from':_0x1d7d40[_0x8636('0x27')]?_0x1d7d40[_0x8636('0x27')]['from']:'','joinAt':moment()[_0x8636('0x15')]('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x1d7d40['contact']?_0x1d7d40[_0x8636('0x28')]['id']:null,'ListId':_0x1d7d40[_0x8636('0x29')]?_0x1d7d40[_0x8636('0x29')]['id']:null};_0x4e48e5[_[_0x8636('0x2a')](_0x1d7d40['channel'])+_0x8636('0x2b')]=_0x8ba13['id']||null;_0x4e48e5[_[_0x8636('0x2a')](_0x1d7d40[_0x8636('0x2c')])+_0x8636('0x12')]=_0x1d7d40[_0x8636('0x2d')]?_0x1d7d40[_0x8636('0x2d')]['id']:null;_0x4e48e5[_[_0x8636('0x2a')](_0x1d7d40[_0x8636('0x2c')])+_0x8636('0x2e')]=_0x1d7d40[_0x8636('0x2f')]?_0x1d7d40['message']['id']:null;_0x4e48e5[_[_0x8636('0x2a')](_0x1d7d40[_0x8636('0x2c')])+(_0x1d7d40[_0x8636('0x2c')]!=='chat'?_0x8636('0x30'):'WebsiteId')]=_0x1d7d40[_0x8636('0xc')]?_0x1d7d40[_0x8636('0xc')]['id']:null;logger[_0x8636('0x31')](util[_0x8636('0x15')](_0x8636('0x32'),_0x454c58,_0x8ba13[_0x8636('0x33')]));emitChannelQueueInteraction(_0x1d7d40[_0x8636('0x2c')],_0x8ba13[_0x8636('0x33')],_0x4e48e5,_0x1d7d40[_0x8636('0xc')][_0x8636('0x33')],_0x1d7d40['message']['id'],!![],_0x256d79,_0x8ba13['id']);if(rpc[_0x1d7d40[_0x8636('0x2c')]+_0x8636('0x34')]){return rpc[_0x1d7d40[_0x8636('0x2c')]+'QueueReport'][_0x8636('0x35')](_0x4e48e5)[_0x8636('0x36')](function(_0x22b202){logger['error'](_0x8636('0x37'),_0x22b202);});}}}function stopRouting(_0x1c2f3d,_0x4c2103,_0x5a1f4a,_0x11f35e){if(_0x1c2f3d&&_0x4c2103){_0x4c2103[_0x8636('0x26')]-=0x1;var _0x277270={'leaveAt':moment()[_0x8636('0x15')](_0x8636('0x38')),'acceptAt':moment()[_0x8636('0x15')](_0x8636('0x38')),'reason':_0x8636('0x39')};logger[_0x8636('0x31')](util[_0x8636('0x15')](_0x8636('0x3a'),_0x1c2f3d,_0x4c2103[_0x8636('0x33')]));emitChannelQueueInteraction(_0x5a1f4a['channel'],_0x4c2103['name'],_0x5a1f4a['body'],_0x5a1f4a[_0x8636('0xc')][_0x8636('0x33')],_0x5a1f4a['message']['id'],![],_0x11f35e,_0x4c2103['id']);return rpc[_0x5a1f4a[_0x8636('0x2c')]+_0x8636('0x3b')][_0x8636('0x3c')](_0x5a1f4a['interaction']['id'],{'queueId':_0x4c2103['id']})[_0x8636('0x3d')](function(){if(rpc[_0x5a1f4a[_0x8636('0x2c')]+_0x8636('0x34')]){return rpc[_0x5a1f4a['channel']+_0x8636('0x34')][_0x8636('0x3c')](_0x1c2f3d,_0x277270)[_0x8636('0x36')](function(_0x5a04fd){logger[_0x8636('0x3e')](_0x8636('0x3f'),_0x5a04fd);});}});}}function endRouting(_0x7d7e57,_0x808c03,_0x539053,_0x2ee3b3){if(_0x7d7e57&&_0x808c03){_0x808c03[_0x8636('0x26')]-=0x1;var _0x52551f={'leaveAt':moment()[_0x8636('0x15')]('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()[_0x8636('0x15')](_0x8636('0x38')),'reason':_0x8636('0x40')};logger['info'](util[_0x8636('0x15')](_0x8636('0x41'),_0x7d7e57,_0x808c03[_0x8636('0x33')]));emitChannelQueueInteraction(_0x539053[_0x8636('0x2c')],_0x808c03[_0x8636('0x33')],_0x539053[_0x8636('0x27')],_0x539053['account'][_0x8636('0x33')],_0x539053[_0x8636('0x2f')]['id'],![],_0x2ee3b3);if(rpc[_0x539053['channel']+_0x8636('0x34')]){return rpc[_0x539053[_0x8636('0x2c')]+_0x8636('0x34')][_0x8636('0x3c')](_0x7d7e57,_0x52551f)[_0x8636('0x36')](function(_0x520c91){logger[_0x8636('0x3e')](_0x8636('0x3f'),_0x520c91);});}}}function handleFindQueue(_0x53bdd4){return function(_0x2ba24e){return _0x2ba24e[_0x8636('0x33')][_0x8636('0x42')]()===_0x53bdd4[_0x8636('0x42')]();};}exports[_0x8636('0x43')]=function(_0x268559,_0x3b2c3d,_0x41d378,_0xbbb9ad){return function(_0x58f917){try{var _0x13d42b={'name':_0x3b2c3d[0x0],'timeout':_0x3b2c3d[0x1]};var _0x49bc6b=queue[_0x8636('0x44')](_0x13d42b,{'typecast':!![]});if(_0x49bc6b['length']){logger['error'](_0x8636('0x45'),_0x268559,_['map'](_0x49bc6b,_0x8636('0x2f'))[_0x8636('0x46')](',\x20'));_0x58f917[_0x8636('0x47')]();}else{var _0x3a7ce5=_['find'](_0x41d378[_0xbbb9ad[_0x8636('0x2c')]+_0x8636('0x48')],handleFindQueue(_0x13d42b[_0x8636('0x33')]));if(_0x3a7ce5){startRouting(_0x268559,_0x3a7ce5,_0xbbb9ad,_0x41d378);var _0x347841=(_0x3a7ce5[_0x8636('0x40')]||0xa)*0x3e8;var _0x34cec2=(_0x13d42b[_0x8636('0x40')]||0x14)*0x3e8;var _0x10d992;if(_0x347841>_0x34cec2){_0x34cec2=_0x347841;}var _0x367830=seqqueue[_0x8636('0x49')](_0x347841);_0x367830['id']=_0x268559;_0x367830[_0x8636('0x4a')]=_0x347841;_0x367830[_0x8636('0x4b')]=_0x34cec2;_0x367830[_0x8636('0x2c')]=_0xbbb9ad[_0x8636('0x2c')];_0x41d378[_0x8636('0x4c')][_0x268559]['on'](_0x8636('0x4d'),function(){logger[_0x8636('0x31')](_0x8636('0x4e'),_0x268559);stopRouting(_0x268559,_0x3a7ce5,_0xbbb9ad,_0x41d378);clearTimeout(_0x10d992);_0x10d992=undefined;_0x367830[_0x8636('0x4f')](!![]);if(_0x41d378[_0x8636('0x4c')][_0x268559]){delete _0x41d378[_0x8636('0x4c')][_0x268559];}_0x58f917['stop']();});_0x41d378['rules'][_0x268559]['on'](_0x8636('0x50'),function(){if(_0x41d378[_0x8636('0x4c')][_0x268559]){delete _0x41d378['rules'][_0x268559];}});_0x10d992=setTimeout(function(){logger[_0x8636('0x31')](_0x8636('0x51'),_0x268559);endRouting(_0x268559,_0x3a7ce5,_0xbbb9ad,_0x41d378);clearTimeout(_0x10d992);_0x367830[_0x8636('0x4f')](!![]);_0x58f917[_0x8636('0x52')]();},_0x34cec2);switch(_0x3a7ce5[_0x8636('0x53')]){case _0x8636('0x54'):strategy[_0x8636('0x54')](_0x367830,_0x3a7ce5,_0x41d378,_0xbbb9ad);break;default:strategy[_0x8636('0x55')](_0x367830,_0x3a7ce5,_0x41d378,_0xbbb9ad);}}else{logger['error']('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x268559,_0x13d42b[_0x8636('0x33')]);_0x58f917[_0x8636('0x47')]();}}}catch(_0x4ba745){logger[_0x8636('0x3e')](_0x8636('0x45'),_0x268559,_0x4ba745['stack']);_0x58f917[_0x8636('0x47')]();}};};
\ No newline at end of file
+var _0xfe3a=['number','timeout\x20is\x20a\x20number','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','QueueId','interaction','channel','MessageId','message','AccountId','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','QueueReport','create','error','waiting','accepted','[%s][STOP:QUEUE][NAME:%s]','name','Interaction','then','update\x20queue\x20report','[%s][END:QUEUE][NAME:%s]','toLowerCase','consequence','[%s][QUEUE]\x20%s','join','Queues','timeout','createQueue','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','stop','[%s][QUEUE]\x20APPLICATION\x20END','next','rrmemory','stack','validate','lodash','util','seq-queue','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','defaults','redis','localhost','socket.io-emitter','account','queue','from','joinAt','emit','capitalize','InteractionId','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','remove','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/whatsappQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction'];(function(_0x5093e9,_0x5154d0){var _0x4c9a22=function(_0x15176d){while(--_0x15176d){_0x5093e9['push'](_0x5093e9['shift']());}};_0x4c9a22(++_0x5154d0);}(_0xfe3a,0x7e));var _0xafe3=function(_0x3ad113,_0xb05731){_0x3ad113=_0x3ad113-0x0;var _0x19010d=_0xfe3a[_0x3ad113];return _0x19010d;};'use strict';var schema=require(_0xafe3('0x0'));var _=require(_0xafe3('0x1'));var util=require(_0xafe3('0x2'));var seqqueue=require(_0xafe3('0x3'));var moment=require('moment');var Redis=require(_0xafe3('0x4'));var config=require(_0xafe3('0x5'));var logger=require(_0xafe3('0x6'))(_0xafe3('0x7'));var strategy=require(_0xafe3('0x8'));config['redis']=_[_0xafe3('0x9')](config[_0xafe3('0xa')],{'host':_0xafe3('0xb'),'port':0x18eb});var io=require(_0xafe3('0xc'))(new Redis(config['redis']));var attributes=['id','queue_id',_0xafe3('0xd'),_0xafe3('0xe'),_0xafe3('0xf'),_0xafe3('0x10')];function emit(_0x47d601,_0x31e339,_0x53db9c){io['to'](_0x47d601)[_0xafe3('0x11')](_0x31e339,_0x53db9c);}function emitChannelQueueInteraction(_0x51a3f8,_0x484983,_0x6274c3,_0x55f4d1,_0x448415,_0x3006d7,_0x32a5d6,_0x374f6b){var _0x209fd3=_['clone'](_0x6274c3);_0x209fd3['queue_id']=_0x374f6b;_0x209fd3['queue']=_0x484983;_0x209fd3[_0xafe3('0xd')]=_0x55f4d1;_0x209fd3['id']=_0x448415;if(_0x3006d7){attributes['push'](_[_0xafe3('0x12')](_0x51a3f8)+_0xafe3('0x13'));_0x32a5d6[util[_0xafe3('0x14')](_0xafe3('0x15'),_0x51a3f8)][_0x448415]=_[_0xafe3('0x16')](_0x209fd3,attributes);}else{delete _0x32a5d6[util[_0xafe3('0x14')](_0xafe3('0x15'),_0x51a3f8)][_0x448415];}emit(util[_0xafe3('0x14')](_0xafe3('0x17'),_0x51a3f8,_0x484983),util[_0xafe3('0x14')](_0xafe3('0x18'),_0x51a3f8,_0x3006d7?'save':_0xafe3('0x19')),_['pick'](_0x209fd3,attributes));}var rpc={'openchannelQueueReport':require(_0xafe3('0x1a')),'mailQueueReport':require(_0xafe3('0x1b')),'chatQueueReport':require(_0xafe3('0x1c')),'smsQueueReport':require(_0xafe3('0x1d')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require(_0xafe3('0x1e')),'chatInteraction':require(_0xafe3('0x1f')),'faxInteraction':require(_0xafe3('0x20')),'mailInteraction':require(_0xafe3('0x21')),'openchannelInteraction':require('../../rpc/openchannelInteraction'),'smsInteraction':require(_0xafe3('0x22')),'whatsappInteraction':require(_0xafe3('0x23'))};var queue=schema({'name':{'type':'string','required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xafe3('0x24'),'message':_0xafe3('0x25')}});function startRouting(_0x15543c,_0x2fe80d,_0xff5750,_0x306cd3){if(_0x15543c&&_0x2fe80d&&_0xff5750){_0x2fe80d['waiting']+=0x1;var _0x5a6cc7={'uniqueid':_0x15543c,'from':_0xff5750[_0xafe3('0x26')]?_0xff5750[_0xafe3('0x26')]['from']:'','joinAt':moment()[_0xafe3('0x14')](_0xafe3('0x27')),'ContactId':_0xff5750['contact']?_0xff5750[_0xafe3('0x28')]['id']:null,'ListId':_0xff5750[_0xafe3('0x29')]?_0xff5750[_0xafe3('0x29')]['id']:null};_0x5a6cc7[_[_0xafe3('0x2a')](_0xff5750['channel'])+_0xafe3('0x2b')]=_0x2fe80d['id']||null;_0x5a6cc7[_[_0xafe3('0x2a')](_0xff5750['channel'])+_0xafe3('0x13')]=_0xff5750[_0xafe3('0x2c')]?_0xff5750['interaction']['id']:null;_0x5a6cc7[_[_0xafe3('0x2a')](_0xff5750[_0xafe3('0x2d')])+_0xafe3('0x2e')]=_0xff5750[_0xafe3('0x2f')]?_0xff5750[_0xafe3('0x2f')]['id']:null;_0x5a6cc7[_[_0xafe3('0x2a')](_0xff5750[_0xafe3('0x2d')])+(_0xff5750[_0xafe3('0x2d')]!=='chat'?_0xafe3('0x30'):_0xafe3('0x31'))]=_0xff5750['account']?_0xff5750['account']['id']:null;logger[_0xafe3('0x32')](util[_0xafe3('0x14')](_0xafe3('0x33'),_0x15543c,_0x2fe80d['name']));emitChannelQueueInteraction(_0xff5750[_0xafe3('0x2d')],_0x2fe80d['name'],_0x5a6cc7,_0xff5750[_0xafe3('0xd')]['name'],_0xff5750['message']['id'],!![],_0x306cd3,_0x2fe80d['id']);if(rpc[_0xff5750['channel']+_0xafe3('0x34')]){return rpc[_0xff5750['channel']+_0xafe3('0x34')][_0xafe3('0x35')](_0x5a6cc7)['catch'](function(_0x590ad4){logger[_0xafe3('0x36')]('create\x20queue\x20report',_0x590ad4);});}}}function stopRouting(_0x50e9e3,_0x16534a,_0x44876f,_0xe76d82){if(_0x50e9e3&&_0x16534a){_0x16534a[_0xafe3('0x37')]-=0x1;var _0x5594c4={'leaveAt':moment()['format'](_0xafe3('0x27')),'acceptAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0xafe3('0x38')};logger[_0xafe3('0x32')](util['format'](_0xafe3('0x39'),_0x50e9e3,_0x16534a[_0xafe3('0x3a')]));emitChannelQueueInteraction(_0x44876f[_0xafe3('0x2d')],_0x16534a['name'],_0x44876f['body'],_0x44876f[_0xafe3('0xd')]['name'],_0x44876f[_0xafe3('0x2f')]['id'],![],_0xe76d82,_0x16534a['id']);return rpc[_0x44876f[_0xafe3('0x2d')]+_0xafe3('0x3b')]['update'](_0x44876f[_0xafe3('0x2c')]['id'],{'queueId':_0x16534a['id']})[_0xafe3('0x3c')](function(){if(rpc[_0x44876f['channel']+_0xafe3('0x34')]){return rpc[_0x44876f[_0xafe3('0x2d')]+_0xafe3('0x34')]['update'](_0x50e9e3,_0x5594c4)['catch'](function(_0x57663f){logger['error'](_0xafe3('0x3d'),_0x57663f);});}});}}function endRouting(_0x50fc29,_0x2cd0c4,_0x2df343,_0x224c3f){if(_0x50fc29&&_0x2cd0c4){_0x2cd0c4[_0xafe3('0x37')]-=0x1;var _0x4fbaac={'leaveAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'exitAt':moment()[_0xafe3('0x14')](_0xafe3('0x27')),'reason':'timeout'};logger[_0xafe3('0x32')](util[_0xafe3('0x14')](_0xafe3('0x3e'),_0x50fc29,_0x2cd0c4[_0xafe3('0x3a')]));emitChannelQueueInteraction(_0x2df343['channel'],_0x2cd0c4[_0xafe3('0x3a')],_0x2df343[_0xafe3('0x26')],_0x2df343[_0xafe3('0xd')][_0xafe3('0x3a')],_0x2df343[_0xafe3('0x2f')]['id'],![],_0x224c3f);if(rpc[_0x2df343[_0xafe3('0x2d')]+'QueueReport']){return rpc[_0x2df343[_0xafe3('0x2d')]+_0xafe3('0x34')]['update'](_0x50fc29,_0x4fbaac)['catch'](function(_0x4d423){logger[_0xafe3('0x36')](_0xafe3('0x3d'),_0x4d423);});}}}function handleFindQueue(_0x2027a2){return function(_0xa852ec){return _0xa852ec[_0xafe3('0x3a')]['toLowerCase']()===_0x2027a2[_0xafe3('0x3f')]();};}exports[_0xafe3('0x40')]=function(_0x33e124,_0x2486f1,_0x4c3391,_0x53856c){return function(_0x28df66){try{var _0x273a09={'name':_0x2486f1[0x0],'timeout':_0x2486f1[0x1]};var _0x564b26=queue['validate'](_0x273a09,{'typecast':!![]});if(_0x564b26['length']){logger['error'](_0xafe3('0x41'),_0x33e124,_['map'](_0x564b26,'message')[_0xafe3('0x42')](',\x20'));_0x28df66['stop']();}else{var _0x481d07=_['find'](_0x4c3391[_0x53856c[_0xafe3('0x2d')]+_0xafe3('0x43')],handleFindQueue(_0x273a09[_0xafe3('0x3a')]));if(_0x481d07){startRouting(_0x33e124,_0x481d07,_0x53856c,_0x4c3391);var _0x2dc858=(_0x481d07[_0xafe3('0x44')]||0xa)*0x3e8;var _0x5d2a6c=(_0x273a09['timeout']||0x14)*0x3e8;var _0x21147b;if(_0x2dc858>_0x5d2a6c){_0x5d2a6c=_0x2dc858;}var _0x197fbd=seqqueue[_0xafe3('0x45')](_0x2dc858);_0x197fbd['id']=_0x33e124;_0x197fbd[_0xafe3('0x46')]=_0x2dc858;_0x197fbd[_0xafe3('0x47')]=_0x5d2a6c;_0x197fbd[_0xafe3('0x2d')]=_0x53856c['channel'];_0x4c3391[_0xafe3('0x48')][_0x33e124]['on'](_0xafe3('0x49'),function(){logger[_0xafe3('0x32')](_0xafe3('0x4a'),_0x33e124);stopRouting(_0x33e124,_0x481d07,_0x53856c,_0x4c3391);clearTimeout(_0x21147b);_0x21147b=undefined;_0x197fbd[_0xafe3('0x4b')](!![]);if(_0x4c3391[_0xafe3('0x48')][_0x33e124]){delete _0x4c3391[_0xafe3('0x48')][_0x33e124];}_0x28df66[_0xafe3('0x4c')]();});_0x4c3391[_0xafe3('0x48')][_0x33e124]['on']('complete',function(){if(_0x4c3391[_0xafe3('0x48')][_0x33e124]){delete _0x4c3391[_0xafe3('0x48')][_0x33e124];}});_0x21147b=setTimeout(function(){logger[_0xafe3('0x32')](_0xafe3('0x4d'),_0x33e124);endRouting(_0x33e124,_0x481d07,_0x53856c,_0x4c3391);clearTimeout(_0x21147b);_0x197fbd[_0xafe3('0x4b')](!![]);_0x28df66[_0xafe3('0x4e')]();},_0x5d2a6c);switch(_0x481d07['strategy']){case'rrmemory':strategy[_0xafe3('0x4f')](_0x197fbd,_0x481d07,_0x4c3391,_0x53856c);break;default:strategy['beepall'](_0x197fbd,_0x481d07,_0x4c3391,_0x53856c);}}else{logger[_0xafe3('0x36')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x33e124,_0x273a09[_0xafe3('0x3a')]);_0x28df66[_0xafe3('0x4c')]();}}}catch(_0x47eb04){logger[_0xafe3('0x36')](_0xafe3('0x41'),_0x33e124,_0x47eb04[_0xafe3('0x50')]);_0x28df66[_0xafe3('0x4c')]();}};};
\ No newline at end of file