// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xd204=['format','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','[%s][AGENT]\x20ROUTING\x20END','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','lodash','util','seq-queue','../../../../config/logger','routing','./strategy','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','info','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','validate','length','error','[%s][AGENT]\x20%s','map','message','join','stop','find','agents','timeout','createQueue','atimeout','channel'];(function(_0x3d2ea0,_0x222b08){var _0x983816=function(_0xbce49f){while(--_0xbce49f){_0x3d2ea0['push'](_0x3d2ea0['shift']());}};_0x983816(++_0x222b08);}(_0xd204,0x17d));var _0x4d20=function(_0x297053,_0x5cb31f){_0x297053=_0x297053-0x0;var _0xd9e6c0=_0xd204[_0x297053];return _0xd9e6c0;};'use strict';var schema=require('validate');var _=require(_0x4d20('0x0'));var util=require(_0x4d20('0x1'));var seqqueue=require(_0x4d20('0x2'));var logger=require(_0x4d20('0x3'))(_0x4d20('0x4'));var strategy=require(_0x4d20('0x5'));var queue=schema({'name':{'type':'string','required':!![],'message':_0x4d20('0x6')},'timeout':{'type':_0x4d20('0x7'),'message':'timeout\x20is\x20a\x20number'}});function writeLog(_0x565f6e,_0x5437d3,_0x35c791){return logger[_0x4d20('0x8')](util['format'](_0x4d20('0x9'),_0x565f6e,_0x5437d3['name'],_0x35c791));}function handleFindAgent(_0x3ba3d2){return function(_0x130b30){return _0x130b30[_0x4d20('0xa')]['toLowerCase']()===_0x3ba3d2[_0x4d20('0xb')]();};}exports['consequence']=function(_0x53cb6c,_0x4b4460,_0x8f39c0,_0x3b7641){return function(_0x570096){try{var _0xc2c8ce={'name':_0x4b4460[0x0],'timeout':_0x4b4460[0x1]};var _0x16f08a=queue[_0x4d20('0xc')](_0xc2c8ce,{'typecast':!![]});if(_0x16f08a[_0x4d20('0xd')]){logger[_0x4d20('0xe')](_0x4d20('0xf'),_0x53cb6c,_[_0x4d20('0x10')](_0x16f08a,_0x4d20('0x11'))[_0x4d20('0x12')](',\x20'));_0x570096[_0x4d20('0x13')]();}else{var _0x3843b2=_[_0x4d20('0x14')](_0x8f39c0[_0x4d20('0x15')],handleFindAgent(_0xc2c8ce[_0x4d20('0xa')]));if(_0x3843b2){var _0x26ddc0=(_0xc2c8ce[_0x4d20('0x16')]||0xa)*0x3e8;var _0x3af72e,_0x174fa8;var _0x1b8dd2=seqqueue[_0x4d20('0x17')](_0x26ddc0);_0x1b8dd2['id']=_0x53cb6c;_0x1b8dd2[_0x4d20('0x18')]=_0x26ddc0;_0x1b8dd2[_0x4d20('0x19')]=_0x3b7641[_0x4d20('0x19')];writeLog(_0x53cb6c,_0x3843b2,util[_0x4d20('0x1a')]('START:%s',_0x26ddc0));_0x8f39c0[_0x4d20('0x1b')][_0x53cb6c]['on'](_0x4d20('0x1c'),function(){logger[_0x4d20('0x8')](_0x4d20('0x1d'),_0x53cb6c);clearTimeout(_0x174fa8);_0x174fa8=undefined;_0x1b8dd2[_0x4d20('0x1e')]();if(_0x8f39c0[_0x4d20('0x1b')][_0x53cb6c]){delete _0x8f39c0[_0x4d20('0x1b')][_0x53cb6c];}_0x570096[_0x4d20('0x13')]();});_0x8f39c0[_0x4d20('0x1b')][_0x53cb6c]['on']('complete',function(){if(_0x8f39c0['rules'][_0x53cb6c]){delete _0x8f39c0[_0x4d20('0x1b')][_0x53cb6c];}});_0x174fa8=setTimeout(function(){logger[_0x4d20('0x8')](_0x4d20('0x1f'),_0x53cb6c);clearTimeout(_0x174fa8);_0x1b8dd2[_0x4d20('0x1e')]();_0x570096[_0x4d20('0x20')]();},_0x26ddc0);strategy[_0x4d20('0x21')](_0x1b8dd2,_0x3843b2,_0x8f39c0,_0x3b7641);}else{logger[_0x4d20('0xe')](_0x4d20('0x22'),_0x53cb6c,_0xc2c8ce['name']);_0x570096[_0x4d20('0x13')]();}}}catch(_0x2c6ec9){console[_0x4d20('0x23')](_0x2c6ec9);logger['error'](_0x4d20('0x24'),_0x53cb6c,_0x2c6ec9['stack']);_0x570096['stop']();}};};
\ No newline at end of file
+var _0xa31b=['channel','START:%s','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','[%s][AGENT]\x20ROUTING\x20END','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','seq-queue','routing','./strategy','string','number','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','error','[%s][AGENT]\x20%s','map','stop','find','agents','timeout','createQueue','atimeout'];(function(_0x1583d8,_0x1209dd){var _0x41a103=function(_0x18fbc3){while(--_0x18fbc3){_0x1583d8['push'](_0x1583d8['shift']());}};_0x41a103(++_0x1209dd);}(_0xa31b,0x10c));var _0xba31=function(_0x160057,_0x217377){_0x160057=_0x160057-0x0;var _0x396c10=_0xa31b[_0x160057];return _0x396c10;};'use strict';var schema=require(_0xba31('0x0'));var _=require('lodash');var util=require('util');var seqqueue=require(_0xba31('0x1'));var logger=require('../../../../config/logger')(_0xba31('0x2'));var strategy=require(_0xba31('0x3'));var queue=schema({'name':{'type':_0xba31('0x4'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0xba31('0x5'),'message':_0xba31('0x6')}});function writeLog(_0xec561,_0x125ac0,_0x4ffd8f){return logger[_0xba31('0x7')](util[_0xba31('0x8')](_0xba31('0x9'),_0xec561,_0x125ac0[_0xba31('0xa')],_0x4ffd8f));}function handleFindAgent(_0x151e0c){return function(_0x5ae390){return _0x5ae390['name']['toLowerCase']()===_0x151e0c['toLowerCase']();};}exports['consequence']=function(_0x33eb14,_0x3528de,_0x1e72f3,_0x12a1e4){return function(_0x12deec){try{var _0x2b363c={'name':_0x3528de[0x0],'timeout':_0x3528de[0x1]};var _0x53f72c=queue[_0xba31('0x0')](_0x2b363c,{'typecast':!![]});if(_0x53f72c['length']){logger[_0xba31('0xb')](_0xba31('0xc'),_0x33eb14,_[_0xba31('0xd')](_0x53f72c,'message')['join'](',\x20'));_0x12deec[_0xba31('0xe')]();}else{var _0x5b6d54=_[_0xba31('0xf')](_0x1e72f3[_0xba31('0x10')],handleFindAgent(_0x2b363c[_0xba31('0xa')]));if(_0x5b6d54){var _0x5b2bf2=(_0x2b363c[_0xba31('0x11')]||0xa)*0x3e8;var _0x4c1aa3,_0x88ec01;var _0x3ea34d=seqqueue[_0xba31('0x12')](_0x5b2bf2);_0x3ea34d['id']=_0x33eb14;_0x3ea34d[_0xba31('0x13')]=_0x5b2bf2;_0x3ea34d[_0xba31('0x14')]=_0x12a1e4[_0xba31('0x14')];writeLog(_0x33eb14,_0x5b6d54,util[_0xba31('0x8')](_0xba31('0x15'),_0x5b2bf2));_0x1e72f3[_0xba31('0x16')][_0x33eb14]['on'](_0xba31('0x17'),function(){logger[_0xba31('0x7')](_0xba31('0x18'),_0x33eb14);clearTimeout(_0x88ec01);_0x88ec01=undefined;_0x3ea34d[_0xba31('0x19')]();if(_0x1e72f3[_0xba31('0x16')][_0x33eb14]){delete _0x1e72f3[_0xba31('0x16')][_0x33eb14];}_0x12deec[_0xba31('0xe')]();});_0x1e72f3[_0xba31('0x16')][_0x33eb14]['on']('complete',function(){if(_0x1e72f3[_0xba31('0x16')][_0x33eb14]){delete _0x1e72f3[_0xba31('0x16')][_0x33eb14];}});_0x88ec01=setTimeout(function(){logger['info'](_0xba31('0x1a'),_0x33eb14);clearTimeout(_0x88ec01);_0x3ea34d['close']();_0x12deec['next']();},_0x5b2bf2);strategy[_0xba31('0x1b')](_0x3ea34d,_0x5b6d54,_0x1e72f3,_0x12a1e4);}else{logger['error'](_0xba31('0x1c'),_0x33eb14,_0x2b363c[_0xba31('0xa')]);_0x12deec['stop']();}}}catch(_0x54a566){console[_0xba31('0x1d')](_0x54a566);logger[_0xba31('0xb')](_0xba31('0x1e'),_0x33eb14,_0x54a566[_0xba31('0x1f')]);_0x12deec['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff