// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x8526=['name','toLowerCase','length','map','message','find','agents','timeout','createQueue','atimeout','channel','format','START:%s','rules','[%s][AGENT]\x20ROUTING\x20STOPPED','close','[%s][AGENT]\x20ROUTING\x20END','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','stop','log','error','stack','validate','lodash','util','seq-queue','routing','./strategy','string','number','timeout\x20is\x20a\x20number','info','[%s][AGENT][NAME:%s][STATUS:%s]'];(function(_0x56ea12,_0x304238){var _0x4b9883=function(_0x5a0ffa){while(--_0x5a0ffa){_0x56ea12['push'](_0x56ea12['shift']());}};_0x4b9883(++_0x304238);}(_0x8526,0xe3));var _0x6852=function(_0x4125a7,_0x421f72){_0x4125a7=_0x4125a7-0x0;var _0x204ec6=_0x8526[_0x4125a7];return _0x204ec6;};'use strict';var schema=require(_0x6852('0x0'));var _=require(_0x6852('0x1'));var util=require(_0x6852('0x2'));var seqqueue=require(_0x6852('0x3'));var logger=require('../../../../config/logger')(_0x6852('0x4'));var strategy=require(_0x6852('0x5'));var queue=schema({'name':{'type':_0x6852('0x6'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':_0x6852('0x7'),'message':_0x6852('0x8')}});function writeLog(_0xe09783,_0x1ed521,_0x368a0f){return logger[_0x6852('0x9')](util['format'](_0x6852('0xa'),_0xe09783,_0x1ed521[_0x6852('0xb')],_0x368a0f));}function handleFindAgent(_0x1ec82c){return function(_0x1258fd){return _0x1258fd[_0x6852('0xb')][_0x6852('0xc')]()===_0x1ec82c[_0x6852('0xc')]();};}exports['consequence']=function(_0x558af7,_0xbd90c7,_0x5aca66,_0x11252a){return function(_0x3f02a8){try{var _0x2d1f45={'name':_0xbd90c7[0x0],'timeout':_0xbd90c7[0x1]};var _0x1bfa90=queue[_0x6852('0x0')](_0x2d1f45,{'typecast':!![]});if(_0x1bfa90[_0x6852('0xd')]){logger['error']('[%s][AGENT]\x20%s',_0x558af7,_[_0x6852('0xe')](_0x1bfa90,_0x6852('0xf'))['join'](',\x20'));_0x3f02a8['stop']();}else{var _0x18ff4c=_[_0x6852('0x10')](_0x5aca66[_0x6852('0x11')],handleFindAgent(_0x2d1f45[_0x6852('0xb')]));if(_0x18ff4c){var _0x272a77=(_0x2d1f45[_0x6852('0x12')]||0xa)*0x3e8;var _0x5ad558,_0x18215f;var _0x48e310=seqqueue[_0x6852('0x13')](_0x272a77);_0x48e310['id']=_0x558af7;_0x48e310[_0x6852('0x14')]=_0x272a77;_0x48e310[_0x6852('0x15')]=_0x11252a[_0x6852('0x15')];writeLog(_0x558af7,_0x18ff4c,util[_0x6852('0x16')](_0x6852('0x17'),_0x272a77));_0x5aca66[_0x6852('0x18')][_0x558af7]['on']('end',function(){logger[_0x6852('0x9')](_0x6852('0x19'),_0x558af7);clearTimeout(_0x18215f);_0x18215f=undefined;_0x48e310[_0x6852('0x1a')]();if(_0x5aca66[_0x6852('0x18')][_0x558af7]){delete _0x5aca66[_0x6852('0x18')][_0x558af7];}_0x3f02a8['stop']();});_0x5aca66[_0x6852('0x18')][_0x558af7]['on']('complete',function(){if(_0x5aca66[_0x6852('0x18')][_0x558af7]){delete _0x5aca66['rules'][_0x558af7];}});_0x18215f=setTimeout(function(){logger[_0x6852('0x9')](_0x6852('0x1b'),_0x558af7);clearTimeout(_0x18215f);_0x48e310[_0x6852('0x1a')]();_0x3f02a8['next']();},_0x272a77);strategy[_0x6852('0x1c')](_0x48e310,_0x18ff4c,_0x5aca66,_0x11252a);}else{logger['error'](_0x6852('0x1d'),_0x558af7,_0x2d1f45[_0x6852('0xb')]);_0x3f02a8[_0x6852('0x1e')]();}}}catch(_0x4dae50){console[_0x6852('0x1f')](_0x4dae50);logger[_0x6852('0x20')]('[%s][QUEUE]\x20%s',_0x558af7,_0x4dae50[_0x6852('0x21')]);_0x3f02a8[_0x6852('0x1e')]();}};};
\ No newline at end of file
+var _0xf4df=['name','toLowerCase','consequence','validate','length','error','[%s][AGENT]\x20%s','map','message','stop','find','agents','timeout','createQueue','atimeout','rules','end','info','[%s][AGENT]\x20ROUTING\x20STOPPED','close','complete','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','util','seq-queue','../../../../config/logger','routing','./strategy','string','timeout\x20is\x20a\x20number','format','[%s][AGENT][NAME:%s][STATUS:%s]'];(function(_0x4e7197,_0x552137){var _0x2e267c=function(_0xc117a1){while(--_0xc117a1){_0x4e7197['push'](_0x4e7197['shift']());}};_0x2e267c(++_0x552137);}(_0xf4df,0x83));var _0xff4d=function(_0x53d68a,_0x27d046){_0x53d68a=_0x53d68a-0x0;var _0x14f9f8=_0xf4df[_0x53d68a];return _0x14f9f8;};'use strict';var schema=require('validate');var _=require('lodash');var util=require(_0xff4d('0x0'));var seqqueue=require(_0xff4d('0x1'));var logger=require(_0xff4d('0x2'))(_0xff4d('0x3'));var strategy=require(_0xff4d('0x4'));var queue=schema({'name':{'type':_0xff4d('0x5'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':_0xff4d('0x6')}});function writeLog(_0x256874,_0x3226a7,_0x551695){return logger['info'](util[_0xff4d('0x7')](_0xff4d('0x8'),_0x256874,_0x3226a7[_0xff4d('0x9')],_0x551695));}function handleFindAgent(_0x40690f){return function(_0x4d9e73){return _0x4d9e73[_0xff4d('0x9')]['toLowerCase']()===_0x40690f[_0xff4d('0xa')]();};}exports[_0xff4d('0xb')]=function(_0x38dcc3,_0x335814,_0x38a3fe,_0x268be7){return function(_0x5b25f0){try{var _0x56f0d2={'name':_0x335814[0x0],'timeout':_0x335814[0x1]};var _0x5df747=queue[_0xff4d('0xc')](_0x56f0d2,{'typecast':!![]});if(_0x5df747[_0xff4d('0xd')]){logger[_0xff4d('0xe')](_0xff4d('0xf'),_0x38dcc3,_[_0xff4d('0x10')](_0x5df747,_0xff4d('0x11'))['join'](',\x20'));_0x5b25f0[_0xff4d('0x12')]();}else{var _0x2c5498=_[_0xff4d('0x13')](_0x38a3fe[_0xff4d('0x14')],handleFindAgent(_0x56f0d2[_0xff4d('0x9')]));if(_0x2c5498){var _0x4830da=(_0x56f0d2[_0xff4d('0x15')]||0xa)*0x3e8;var _0x2ec3a3,_0x150639;var _0x49a1fe=seqqueue[_0xff4d('0x16')](_0x4830da);_0x49a1fe['id']=_0x38dcc3;_0x49a1fe[_0xff4d('0x17')]=_0x4830da;_0x49a1fe['channel']=_0x268be7['channel'];writeLog(_0x38dcc3,_0x2c5498,util[_0xff4d('0x7')]('START:%s',_0x4830da));_0x38a3fe[_0xff4d('0x18')][_0x38dcc3]['on'](_0xff4d('0x19'),function(){logger[_0xff4d('0x1a')](_0xff4d('0x1b'),_0x38dcc3);clearTimeout(_0x150639);_0x150639=undefined;_0x49a1fe[_0xff4d('0x1c')]();if(_0x38a3fe[_0xff4d('0x18')][_0x38dcc3]){delete _0x38a3fe['rules'][_0x38dcc3];}_0x5b25f0['stop']();});_0x38a3fe['rules'][_0x38dcc3]['on'](_0xff4d('0x1d'),function(){if(_0x38a3fe[_0xff4d('0x18')][_0x38dcc3]){delete _0x38a3fe[_0xff4d('0x18')][_0x38dcc3];}});_0x150639=setTimeout(function(){logger['info']('[%s][AGENT]\x20ROUTING\x20END',_0x38dcc3);clearTimeout(_0x150639);_0x49a1fe['close']();_0x5b25f0[_0xff4d('0x1e')]();},_0x4830da);strategy[_0xff4d('0x1f')](_0x49a1fe,_0x2c5498,_0x38a3fe,_0x268be7);}else{logger[_0xff4d('0xe')](_0xff4d('0x20'),_0x38dcc3,_0x56f0d2['name']);_0x5b25f0[_0xff4d('0x12')]();}}}catch(_0x25c452){console[_0xff4d('0x21')](_0x25c452);logger['error'](_0xff4d('0x22'),_0x38dcc3,_0x25c452['stack']);_0x5b25f0[_0xff4d('0x12')]();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff