Built motion from commit 449495f6.|2.6.27
[motion2.git] / server / services / routing / server / applications / queue.js
index 7985bcf..3ff3b39 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x5e7f=['./strategy','redis','defaults','localhost','socket.io-emitter','account','queue','from','emit','clone','queue_id','push','InteractionId','format','%sQueuesWaitingInteractions','%s:queue:%s','%s_queue_waiting_interaction:%s','remove','pick','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/chatQueueReport','../../rpc/faxQueueReport','../../rpc/whatsappQueueReport','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction','string','number','waiting','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','interaction','MessageId','message','chat','AccountId','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','accepted','Interaction','update','then','error','timeout','info','[%s][END:QUEUE][NAME:%s]','update\x20queue\x20report','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','map','join','stop','find','atimeout','qtimeout','rules','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','complete','next','strategy','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s','stack','validate','lodash','util','seq-queue','moment','ioredis','../../../../config/environment','../../../../config/logger','routing'];(function(_0x48deaf,_0x91fc6a){var _0x35ba9b=function(_0x66a1ca){while(--_0x66a1ca){_0x48deaf['push'](_0x48deaf['shift']());}};_0x35ba9b(++_0x91fc6a);}(_0x5e7f,0xff));var _0xf5e7=function(_0x37d34c,_0x501153){_0x37d34c=_0x37d34c-0x0;var _0x11a0ba=_0x5e7f[_0x37d34c];return _0x11a0ba;};'use strict';var schema=require(_0xf5e7('0x0'));var _=require(_0xf5e7('0x1'));var util=require(_0xf5e7('0x2'));var seqqueue=require(_0xf5e7('0x3'));var moment=require(_0xf5e7('0x4'));var Redis=require(_0xf5e7('0x5'));var config=require(_0xf5e7('0x6'));var logger=require(_0xf5e7('0x7'))(_0xf5e7('0x8'));var strategy=require(_0xf5e7('0x9'));config[_0xf5e7('0xa')]=_[_0xf5e7('0xb')](config[_0xf5e7('0xa')],{'host':_0xf5e7('0xc'),'port':0x18eb});var io=require(_0xf5e7('0xd'))(new Redis(config[_0xf5e7('0xa')]));var attributes=['id','queue_id',_0xf5e7('0xe'),_0xf5e7('0xf'),_0xf5e7('0x10'),'joinAt'];function emit(_0x210b3b,_0x774f2a,_0x194e65){io['to'](_0x210b3b)[_0xf5e7('0x11')](_0x774f2a,_0x194e65);}function emitChannelQueueInteraction(_0x139f86,_0x4672a9,_0x3115eb,_0xbb55e6,_0x5c399d,_0x14c72,_0x42f970,_0x5151a1){var _0x5e5514=_[_0xf5e7('0x12')](_0x3115eb);_0x5e5514[_0xf5e7('0x13')]=_0x5151a1;_0x5e5514['queue']=_0x4672a9;_0x5e5514[_0xf5e7('0xe')]=_0xbb55e6;_0x5e5514['id']=_0x5c399d;if(_0x14c72){attributes[_0xf5e7('0x14')](_['capitalize'](_0x139f86)+_0xf5e7('0x15'));_0x42f970[util[_0xf5e7('0x16')]('%sQueuesWaitingInteractions',_0x139f86)][_0x5c399d]=_['pick'](_0x5e5514,attributes);}else{delete _0x42f970[util['format'](_0xf5e7('0x17'),_0x139f86)][_0x5c399d];}emit(util[_0xf5e7('0x16')](_0xf5e7('0x18'),_0x139f86,_0x4672a9),util[_0xf5e7('0x16')](_0xf5e7('0x19'),_0x139f86,_0x14c72?'save':_0xf5e7('0x1a')),_[_0xf5e7('0x1b')](_0x5e5514,attributes));}var rpc={'openchannelQueueReport':require(_0xf5e7('0x1c')),'mailQueueReport':require(_0xf5e7('0x1d')),'chatQueueReport':require(_0xf5e7('0x1e')),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require(_0xf5e7('0x1f')),'whatsappQueueReport':require(_0xf5e7('0x20')),'chatInteraction':require('../../rpc/chatInteraction'),'faxInteraction':require(_0xf5e7('0x21')),'mailInteraction':require(_0xf5e7('0x22')),'openchannelInteraction':require(_0xf5e7('0x23')),'smsInteraction':require(_0xf5e7('0x24')),'whatsappInteraction':require(_0xf5e7('0x25'))};var queue=schema({'name':{'type':_0xf5e7('0x26'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xf5e7('0x27'),'message':'timeout\x20is\x20a\x20number'}});function startRouting(_0x4ef266,_0x131a6b,_0x4876e3,_0x3a5f5f){if(_0x4ef266&&_0x131a6b&&_0x4876e3){_0x131a6b[_0xf5e7('0x28')]+=0x1;var _0x196772={'uniqueid':_0x4ef266,'from':_0x4876e3[_0xf5e7('0x29')]?_0x4876e3[_0xf5e7('0x29')][_0xf5e7('0x10')]:'','joinAt':moment()['format'](_0xf5e7('0x2a')),'ContactId':_0x4876e3[_0xf5e7('0x2b')]?_0x4876e3[_0xf5e7('0x2b')]['id']:null,'ListId':_0x4876e3[_0xf5e7('0x2c')]?_0x4876e3['list']['id']:null};_0x196772[_[_0xf5e7('0x2d')](_0x4876e3[_0xf5e7('0x2e')])+_0xf5e7('0x2f')]=_0x131a6b['id']||null;_0x196772[_[_0xf5e7('0x2d')](_0x4876e3['channel'])+_0xf5e7('0x15')]=_0x4876e3[_0xf5e7('0x30')]?_0x4876e3[_0xf5e7('0x30')]['id']:null;_0x196772[_['upperFirst'](_0x4876e3[_0xf5e7('0x2e')])+_0xf5e7('0x31')]=_0x4876e3[_0xf5e7('0x32')]?_0x4876e3[_0xf5e7('0x32')]['id']:null;_0x196772[_[_0xf5e7('0x2d')](_0x4876e3[_0xf5e7('0x2e')])+(_0x4876e3[_0xf5e7('0x2e')]!==_0xf5e7('0x33')?_0xf5e7('0x34'):'WebsiteId')]=_0x4876e3['account']?_0x4876e3[_0xf5e7('0xe')]['id']:null;logger['info'](util['format'](_0xf5e7('0x35'),_0x4ef266,_0x131a6b[_0xf5e7('0x36')]));emitChannelQueueInteraction(_0x4876e3[_0xf5e7('0x2e')],_0x131a6b['name'],_0x196772,_0x4876e3[_0xf5e7('0xe')][_0xf5e7('0x36')],_0x4876e3['message']['id'],!![],_0x3a5f5f,_0x131a6b['id']);if(rpc[_0x4876e3[_0xf5e7('0x2e')]+_0xf5e7('0x37')]){return rpc[_0x4876e3[_0xf5e7('0x2e')]+'QueueReport'][_0xf5e7('0x38')](_0x196772)[_0xf5e7('0x39')](function(_0x4e9eb1){logger['error']('create\x20queue\x20report',_0x4e9eb1);});}}}function stopRouting(_0xf446d,_0x1b22f8,_0x2df34c,_0x2bd551){if(_0xf446d&&_0x1b22f8){_0x1b22f8['waiting']-=0x1;var _0x25123d={'leaveAt':moment()['format'](_0xf5e7('0x2a')),'acceptAt':moment()[_0xf5e7('0x16')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0xf5e7('0x3a')};logger['info'](util[_0xf5e7('0x16')]('[%s][STOP:QUEUE][NAME:%s]',_0xf446d,_0x1b22f8[_0xf5e7('0x36')]));emitChannelQueueInteraction(_0x2df34c[_0xf5e7('0x2e')],_0x1b22f8[_0xf5e7('0x36')],_0x2df34c['body'],_0x2df34c[_0xf5e7('0xe')][_0xf5e7('0x36')],_0x2df34c[_0xf5e7('0x32')]['id'],![],_0x2bd551,_0x1b22f8['id']);return rpc[_0x2df34c[_0xf5e7('0x2e')]+_0xf5e7('0x3b')][_0xf5e7('0x3c')](_0x2df34c[_0xf5e7('0x30')]['id'],{'queueId':_0x1b22f8['id']})[_0xf5e7('0x3d')](function(){if(rpc[_0x2df34c[_0xf5e7('0x2e')]+_0xf5e7('0x37')]){return rpc[_0x2df34c[_0xf5e7('0x2e')]+'QueueReport'][_0xf5e7('0x3c')](_0xf446d,_0x25123d)[_0xf5e7('0x39')](function(_0x487fa8){logger[_0xf5e7('0x3e')]('update\x20queue\x20report',_0x487fa8);});}});}}function endRouting(_0x1bb628,_0x4dd40f,_0x13e49d,_0x157f41){if(_0x1bb628&&_0x4dd40f){_0x4dd40f[_0xf5e7('0x28')]-=0x1;var _0x19c1be={'leaveAt':moment()[_0xf5e7('0x16')](_0xf5e7('0x2a')),'exitAt':moment()['format'](_0xf5e7('0x2a')),'reason':_0xf5e7('0x3f')};logger[_0xf5e7('0x40')](util['format'](_0xf5e7('0x41'),_0x1bb628,_0x4dd40f[_0xf5e7('0x36')]));emitChannelQueueInteraction(_0x13e49d[_0xf5e7('0x2e')],_0x4dd40f[_0xf5e7('0x36')],_0x13e49d[_0xf5e7('0x29')],_0x13e49d[_0xf5e7('0xe')][_0xf5e7('0x36')],_0x13e49d[_0xf5e7('0x32')]['id'],![],_0x157f41);if(rpc[_0x13e49d[_0xf5e7('0x2e')]+_0xf5e7('0x37')]){return rpc[_0x13e49d[_0xf5e7('0x2e')]+'QueueReport'][_0xf5e7('0x3c')](_0x1bb628,_0x19c1be)[_0xf5e7('0x39')](function(_0x14a699){logger[_0xf5e7('0x3e')](_0xf5e7('0x42'),_0x14a699);});}}}function handleFindQueue(_0xba1bd0){return function(_0x3aa355){return _0x3aa355[_0xf5e7('0x36')][_0xf5e7('0x43')]()===_0xba1bd0[_0xf5e7('0x43')]();};}exports[_0xf5e7('0x44')]=function(_0x135f1b,_0x2036d3,_0x1317f8,_0x3ca53f){return function(_0x5894c2){try{var _0x1dd4f3={'name':_0x2036d3[0x0],'timeout':_0x2036d3[0x1]};var _0x41a85f=queue[_0xf5e7('0x0')](_0x1dd4f3,{'typecast':!![]});if(_0x41a85f[_0xf5e7('0x45')]){logger[_0xf5e7('0x3e')](_0xf5e7('0x46'),_0x135f1b,_[_0xf5e7('0x47')](_0x41a85f,_0xf5e7('0x32'))[_0xf5e7('0x48')](',\x20'));_0x5894c2[_0xf5e7('0x49')]();}else{var _0x49d70f=_[_0xf5e7('0x4a')](_0x1317f8[_0x3ca53f[_0xf5e7('0x2e')]+'Queues'],handleFindQueue(_0x1dd4f3['name']));if(_0x49d70f){startRouting(_0x135f1b,_0x49d70f,_0x3ca53f,_0x1317f8);var _0x5df3d5=(_0x49d70f['timeout']||0xa)*0x3e8;var _0x326082=(_0x1dd4f3[_0xf5e7('0x3f')]||0x14)*0x3e8;var _0x3e90be;if(_0x5df3d5>_0x326082){_0x326082=_0x5df3d5;}var _0x2be198=seqqueue['createQueue'](_0x5df3d5);_0x2be198['id']=_0x135f1b;_0x2be198[_0xf5e7('0x4b')]=_0x5df3d5;_0x2be198[_0xf5e7('0x4c')]=_0x326082;_0x2be198[_0xf5e7('0x2e')]=_0x3ca53f[_0xf5e7('0x2e')];_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]['on'](_0xf5e7('0x4e'),function(){logger['info'](_0xf5e7('0x4f'),_0x135f1b);stopRouting(_0x135f1b,_0x49d70f,_0x3ca53f,_0x1317f8);clearTimeout(_0x3e90be);_0x3e90be=undefined;_0x2be198[_0xf5e7('0x50')](!![]);if(_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]){delete _0x1317f8[_0xf5e7('0x4d')][_0x135f1b];}_0x5894c2['stop']();});_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]['on'](_0xf5e7('0x51'),function(){if(_0x1317f8[_0xf5e7('0x4d')][_0x135f1b]){delete _0x1317f8[_0xf5e7('0x4d')][_0x135f1b];}});_0x3e90be=setTimeout(function(){logger[_0xf5e7('0x40')]('[%s][QUEUE]\x20APPLICATION\x20END',_0x135f1b);endRouting(_0x135f1b,_0x49d70f,_0x3ca53f,_0x1317f8);clearTimeout(_0x3e90be);_0x2be198['close'](!![]);_0x5894c2[_0xf5e7('0x52')]();},_0x326082);switch(_0x49d70f[_0xf5e7('0x53')]){case'rrmemory':strategy[_0xf5e7('0x54')](_0x2be198,_0x49d70f,_0x1317f8,_0x3ca53f);break;default:strategy[_0xf5e7('0x55')](_0x2be198,_0x49d70f,_0x1317f8,_0x3ca53f);}}else{logger[_0xf5e7('0x3e')](_0xf5e7('0x56'),_0x135f1b,_0x1dd4f3[_0xf5e7('0x36')]);_0x5894c2['stop']();}}}catch(_0x5810f3){logger[_0xf5e7('0x3e')]('[%s][QUEUE]\x20%s',_0x135f1b,_0x5810f3[_0xf5e7('0x57')]);_0x5894c2['stop']();}};};
\ No newline at end of file
+var _0x40b6=['stack','validate','util','seq-queue','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','redis','defaults','queue_id','account','from','joinAt','emit','clone','queue','push','capitalize','format','%sQueuesWaitingInteractions','pick','%s:queue:%s','%s_queue_waiting_interaction:%s','save','../../rpc/chatQueueReport','../../rpc/smsQueueReport','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/openchannelInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','waiting','body','contact','list','upperFirst','channel','QueueId','InteractionId','interaction','MessageId','message','chat','WebsiteId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','error','YYYY-MM-DD\x20HH:mm:ss','[%s][STOP:QUEUE][NAME:%s]','Interaction','update','toLowerCase','consequence','length','[%s][QUEUE]\x20%s','map','join','stop','Queues','timeout','createQueue','atimeout','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','rules','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','rrmemory','beepall','[%s][QUEUE]\x20queue\x20not\x20found\x20%s'];(function(_0x3af384,_0x2b2160){var _0x194aad=function(_0x39c9e4){while(--_0x39c9e4){_0x3af384['push'](_0x3af384['shift']());}};_0x194aad(++_0x2b2160);}(_0x40b6,0xf7));var _0x640b=function(_0x397cfb,_0xb8f317){_0x397cfb=_0x397cfb-0x0;var _0x15fed9=_0x40b6[_0x397cfb];return _0x15fed9;};'use strict';var schema=require(_0x640b('0x0'));var _=require('lodash');var util=require(_0x640b('0x1'));var seqqueue=require(_0x640b('0x2'));var moment=require(_0x640b('0x3'));var Redis=require(_0x640b('0x4'));var config=require(_0x640b('0x5'));var logger=require(_0x640b('0x6'))(_0x640b('0x7'));var strategy=require(_0x640b('0x8'));config[_0x640b('0x9')]=_[_0x640b('0xa')](config['redis'],{'host':'localhost','port':0x18eb});var io=require('socket.io-emitter')(new Redis(config[_0x640b('0x9')]));var attributes=['id',_0x640b('0xb'),_0x640b('0xc'),'queue',_0x640b('0xd'),_0x640b('0xe')];function emit(_0x360ebf,_0x5676fa,_0x44d587){io['to'](_0x360ebf)[_0x640b('0xf')](_0x5676fa,_0x44d587);}function emitChannelQueueInteraction(_0xe0bce5,_0x36574a,_0x58beec,_0x176fd1,_0x24d939,_0x9b2b6d,_0x18b3d2,_0x5d04a9){var _0x666b54=_[_0x640b('0x10')](_0x58beec);_0x666b54['queue_id']=_0x5d04a9;_0x666b54[_0x640b('0x11')]=_0x36574a;_0x666b54[_0x640b('0xc')]=_0x176fd1;_0x666b54['id']=_0x24d939;if(_0x9b2b6d){attributes[_0x640b('0x12')](_[_0x640b('0x13')](_0xe0bce5)+'InteractionId');_0x18b3d2[util[_0x640b('0x14')](_0x640b('0x15'),_0xe0bce5)][_0x24d939]=_[_0x640b('0x16')](_0x666b54,attributes);}else{delete _0x18b3d2[util[_0x640b('0x14')](_0x640b('0x15'),_0xe0bce5)][_0x24d939];}emit(util[_0x640b('0x14')](_0x640b('0x17'),_0xe0bce5,_0x36574a),util[_0x640b('0x14')](_0x640b('0x18'),_0xe0bce5,_0x9b2b6d?_0x640b('0x19'):'remove'),_[_0x640b('0x16')](_0x666b54,attributes));}var rpc={'openchannelQueueReport':require('../../rpc/openchannelQueueReport'),'mailQueueReport':require('../../rpc/mailQueueReport'),'chatQueueReport':require(_0x640b('0x1a')),'smsQueueReport':require(_0x640b('0x1b')),'faxQueueReport':require('../../rpc/faxQueueReport'),'whatsappQueueReport':require('../../rpc/whatsappQueueReport'),'chatInteraction':require('../../rpc/chatInteraction'),'faxInteraction':require(_0x640b('0x1c')),'mailInteraction':require(_0x640b('0x1d')),'openchannelInteraction':require(_0x640b('0x1e')),'smsInteraction':require('../../rpc/smsInteraction'),'whatsappInteraction':require(_0x640b('0x1f'))};var queue=schema({'name':{'type':_0x640b('0x20'),'required':!![],'message':_0x640b('0x21')},'timeout':{'type':_0x640b('0x22'),'message':_0x640b('0x23')}});function startRouting(_0x20d150,_0x1f0663,_0x6991ed,_0x17717e){if(_0x20d150&&_0x1f0663&&_0x6991ed){_0x1f0663[_0x640b('0x24')]+=0x1;var _0x2439a7={'uniqueid':_0x20d150,'from':_0x6991ed[_0x640b('0x25')]?_0x6991ed['body'][_0x640b('0xd')]:'','joinAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'ContactId':_0x6991ed[_0x640b('0x26')]?_0x6991ed[_0x640b('0x26')]['id']:null,'ListId':_0x6991ed[_0x640b('0x27')]?_0x6991ed[_0x640b('0x27')]['id']:null};_0x2439a7[_[_0x640b('0x28')](_0x6991ed[_0x640b('0x29')])+_0x640b('0x2a')]=_0x1f0663['id']||null;_0x2439a7[_['upperFirst'](_0x6991ed[_0x640b('0x29')])+_0x640b('0x2b')]=_0x6991ed[_0x640b('0x2c')]?_0x6991ed[_0x640b('0x2c')]['id']:null;_0x2439a7[_[_0x640b('0x28')](_0x6991ed[_0x640b('0x29')])+_0x640b('0x2d')]=_0x6991ed[_0x640b('0x2e')]?_0x6991ed[_0x640b('0x2e')]['id']:null;_0x2439a7[_[_0x640b('0x28')](_0x6991ed[_0x640b('0x29')])+(_0x6991ed[_0x640b('0x29')]!==_0x640b('0x2f')?'AccountId':_0x640b('0x30'))]=_0x6991ed['account']?_0x6991ed['account']['id']:null;logger[_0x640b('0x31')](util[_0x640b('0x14')](_0x640b('0x32'),_0x20d150,_0x1f0663['name']));emitChannelQueueInteraction(_0x6991ed[_0x640b('0x29')],_0x1f0663[_0x640b('0x33')],_0x2439a7,_0x6991ed[_0x640b('0xc')]['name'],_0x6991ed[_0x640b('0x2e')]['id'],!![],_0x17717e,_0x1f0663['id']);if(rpc[_0x6991ed[_0x640b('0x29')]+_0x640b('0x34')]){return rpc[_0x6991ed[_0x640b('0x29')]+_0x640b('0x34')][_0x640b('0x35')](_0x2439a7)[_0x640b('0x36')](function(_0x313c6a){logger[_0x640b('0x37')]('create\x20queue\x20report',_0x313c6a);});}}}function stopRouting(_0x22b16e,_0x24e7cf,_0x39e17d,_0x14df43){if(_0x22b16e&&_0x24e7cf){_0x24e7cf[_0x640b('0x24')]-=0x1;var _0x4cfb7c={'leaveAt':moment()[_0x640b('0x14')](_0x640b('0x38')),'acceptAt':moment()[_0x640b('0x14')]('YYYY-MM-DD\x20HH:mm:ss'),'reason':'accepted'};logger['info'](util['format'](_0x640b('0x39'),_0x22b16e,_0x24e7cf[_0x640b('0x33')]));emitChannelQueueInteraction(_0x39e17d['channel'],_0x24e7cf[_0x640b('0x33')],_0x39e17d[_0x640b('0x25')],_0x39e17d['account'][_0x640b('0x33')],_0x39e17d[_0x640b('0x2e')]['id'],![],_0x14df43,_0x24e7cf['id']);return rpc[_0x39e17d[_0x640b('0x29')]+_0x640b('0x3a')]['update'](_0x39e17d['interaction']['id'],{'queueId':_0x24e7cf['id']})['then'](function(){if(rpc[_0x39e17d['channel']+_0x640b('0x34')]){return rpc[_0x39e17d[_0x640b('0x29')]+_0x640b('0x34')][_0x640b('0x3b')](_0x22b16e,_0x4cfb7c)[_0x640b('0x36')](function(_0x233885){logger['error']('update\x20queue\x20report',_0x233885);});}});}}function endRouting(_0x20d3c7,_0x147de9,_0x130936,_0x3a166e){if(_0x20d3c7&&_0x147de9){_0x147de9[_0x640b('0x24')]-=0x1;var _0x41f4e7={'leaveAt':moment()[_0x640b('0x14')](_0x640b('0x38')),'exitAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'reason':'timeout'};logger[_0x640b('0x31')](util[_0x640b('0x14')]('[%s][END:QUEUE][NAME:%s]',_0x20d3c7,_0x147de9[_0x640b('0x33')]));emitChannelQueueInteraction(_0x130936[_0x640b('0x29')],_0x147de9['name'],_0x130936[_0x640b('0x25')],_0x130936[_0x640b('0xc')][_0x640b('0x33')],_0x130936['message']['id'],![],_0x3a166e);if(rpc[_0x130936['channel']+'QueueReport']){return rpc[_0x130936['channel']+_0x640b('0x34')][_0x640b('0x3b')](_0x20d3c7,_0x41f4e7)[_0x640b('0x36')](function(_0x5dfe23){logger[_0x640b('0x37')]('update\x20queue\x20report',_0x5dfe23);});}}}function handleFindQueue(_0x36d840){return function(_0x677eab){return _0x677eab['name'][_0x640b('0x3c')]()===_0x36d840[_0x640b('0x3c')]();};}exports[_0x640b('0x3d')]=function(_0x1981fd,_0x54c354,_0x16a866,_0x5337d0){return function(_0x26e6f1){try{var _0x5a0ca0={'name':_0x54c354[0x0],'timeout':_0x54c354[0x1]};var _0x4d7232=queue['validate'](_0x5a0ca0,{'typecast':!![]});if(_0x4d7232[_0x640b('0x3e')]){logger[_0x640b('0x37')](_0x640b('0x3f'),_0x1981fd,_[_0x640b('0x40')](_0x4d7232,_0x640b('0x2e'))[_0x640b('0x41')](',\x20'));_0x26e6f1[_0x640b('0x42')]();}else{var _0x4a178d=_['find'](_0x16a866[_0x5337d0['channel']+_0x640b('0x43')],handleFindQueue(_0x5a0ca0['name']));if(_0x4a178d){startRouting(_0x1981fd,_0x4a178d,_0x5337d0,_0x16a866);var _0x4124f9=(_0x4a178d[_0x640b('0x44')]||0xa)*0x3e8;var _0x36c02e=(_0x5a0ca0['timeout']||0x14)*0x3e8;var _0x574fed;if(_0x4124f9>_0x36c02e){_0x36c02e=_0x4124f9;}var _0x201007=seqqueue[_0x640b('0x45')](_0x4124f9);_0x201007['id']=_0x1981fd;_0x201007[_0x640b('0x46')]=_0x4124f9;_0x201007['qtimeout']=_0x36c02e;_0x201007[_0x640b('0x29')]=_0x5337d0[_0x640b('0x29')];_0x16a866['rules'][_0x1981fd]['on'](_0x640b('0x47'),function(){logger[_0x640b('0x31')](_0x640b('0x48'),_0x1981fd);stopRouting(_0x1981fd,_0x4a178d,_0x5337d0,_0x16a866);clearTimeout(_0x574fed);_0x574fed=undefined;_0x201007[_0x640b('0x49')](!![]);if(_0x16a866[_0x640b('0x4a')][_0x1981fd]){delete _0x16a866[_0x640b('0x4a')][_0x1981fd];}_0x26e6f1['stop']();});_0x16a866['rules'][_0x1981fd]['on'](_0x640b('0x4b'),function(){if(_0x16a866[_0x640b('0x4a')][_0x1981fd]){delete _0x16a866[_0x640b('0x4a')][_0x1981fd];}});_0x574fed=setTimeout(function(){logger[_0x640b('0x31')](_0x640b('0x4c'),_0x1981fd);endRouting(_0x1981fd,_0x4a178d,_0x5337d0,_0x16a866);clearTimeout(_0x574fed);_0x201007['close'](!![]);_0x26e6f1[_0x640b('0x4d')]();},_0x36c02e);switch(_0x4a178d['strategy']){case _0x640b('0x4e'):strategy[_0x640b('0x4e')](_0x201007,_0x4a178d,_0x16a866,_0x5337d0);break;default:strategy[_0x640b('0x4f')](_0x201007,_0x4a178d,_0x16a866,_0x5337d0);}}else{logger[_0x640b('0x37')](_0x640b('0x50'),_0x1981fd,_0x5a0ca0[_0x640b('0x33')]);_0x26e6f1['stop']();}}}catch(_0x2fe464){logger['error'](_0x640b('0x3f'),_0x1981fd,_0x2fe464[_0x640b('0x51')]);_0x26e6f1[_0x640b('0x42')]();}};};
\ No newline at end of file