// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0x7b54=['timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','validate','length','[%s][AGENT]\x20%s','map','message','agents','timeout','atimeout','channel','START:%s','rules','[%s][AGENT]\x20ROUTING\x20STOPPED','close','stop','next','error','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','stack','lodash','seq-queue','routing','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number'];(function(_0x2b8537,_0x42fca8){var _0x40d54d=function(_0x3bbb16){while(--_0x3bbb16){_0x2b8537['push'](_0x2b8537['shift']());}};_0x40d54d(++_0x42fca8);}(_0x7b54,0x1ba));var _0x47b5=function(_0x1b664d,_0x1d8695){_0x1b664d=_0x1b664d-0x0;var _0x43af6b=_0x7b54[_0x1b664d];return _0x43af6b;};'use strict';var schema=require('validate');var _=require(_0x47b5('0x0'));var util=require('util');var seqqueue=require(_0x47b5('0x1'));var logger=require('../../../../config/logger')(_0x47b5('0x2'));var strategy=require('./strategy');var queue=schema({'name':{'type':_0x47b5('0x3'),'required':!![],'message':_0x47b5('0x4')},'timeout':{'type':_0x47b5('0x5'),'message':_0x47b5('0x6')}});function writeLog(_0x53c1e5,_0x1aaf4a,_0x333cbd){return logger[_0x47b5('0x7')](util[_0x47b5('0x8')](_0x47b5('0x9'),_0x53c1e5,_0x1aaf4a[_0x47b5('0xa')],_0x333cbd));}function handleFindAgent(_0x1c0a82){return function(_0x4923c5){return _0x4923c5['name'][_0x47b5('0xb')]()===_0x1c0a82['toLowerCase']();};}exports[_0x47b5('0xc')]=function(_0x28f479,_0x4d4d92,_0x7fc4e1,_0x128b72){return function(_0xbc6627){try{var _0x4ceba0={'name':_0x4d4d92[0x0],'timeout':_0x4d4d92[0x1]};var _0x160825=queue[_0x47b5('0xd')](_0x4ceba0,{'typecast':!![]});if(_0x160825[_0x47b5('0xe')]){logger['error'](_0x47b5('0xf'),_0x28f479,_[_0x47b5('0x10')](_0x160825,_0x47b5('0x11'))['join'](',\x20'));_0xbc6627['stop']();}else{var _0x4351c4=_['find'](_0x7fc4e1[_0x47b5('0x12')],handleFindAgent(_0x4ceba0[_0x47b5('0xa')]));if(_0x4351c4){var _0x51e215=(_0x4ceba0[_0x47b5('0x13')]||0xa)*0x3e8;var _0x118be9,_0x61448b;var _0x17ac87=seqqueue['createQueue'](_0x51e215);_0x17ac87['id']=_0x28f479;_0x17ac87[_0x47b5('0x14')]=_0x51e215;_0x17ac87['channel']=_0x128b72[_0x47b5('0x15')];writeLog(_0x28f479,_0x4351c4,util[_0x47b5('0x8')](_0x47b5('0x16'),_0x51e215));_0x7fc4e1[_0x47b5('0x17')][_0x28f479]['on']('end',function(){logger['info'](_0x47b5('0x18'),_0x28f479);clearTimeout(_0x61448b);_0x61448b=undefined;_0x17ac87[_0x47b5('0x19')]();if(_0x7fc4e1[_0x47b5('0x17')][_0x28f479]){delete _0x7fc4e1[_0x47b5('0x17')][_0x28f479];}_0xbc6627[_0x47b5('0x1a')]();});_0x7fc4e1[_0x47b5('0x17')][_0x28f479]['on']('complete',function(){if(_0x7fc4e1[_0x47b5('0x17')][_0x28f479]){delete _0x7fc4e1['rules'][_0x28f479];}});_0x61448b=setTimeout(function(){logger['info']('[%s][AGENT]\x20ROUTING\x20END',_0x28f479);clearTimeout(_0x61448b);_0x17ac87[_0x47b5('0x19')]();_0xbc6627[_0x47b5('0x1b')]();},_0x51e215);strategy['agent'](_0x17ac87,_0x4351c4,_0x7fc4e1,_0x128b72);}else{logger[_0x47b5('0x1c')](_0x47b5('0x1d'),_0x28f479,_0x4ceba0['name']);_0xbc6627[_0x47b5('0x1a')]();}}}catch(_0xaeb447){console[_0x47b5('0x1e')](_0xaeb447);logger[_0x47b5('0x1c')]('[%s][QUEUE]\x20%s',_0x28f479,_0xaeb447[_0x47b5('0x1f')]);_0xbc6627[_0x47b5('0x1a')]();}};};
\ No newline at end of file
+var _0x6324=['routing','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','timeout\x20is\x20a\x20number','info','format','name','toLowerCase','consequence','validate','error','[%s][AGENT]\x20%s','map','message','join','stop','find','agents','timeout','channel','START:%s','rules','[%s][AGENT]\x20ROUTING\x20STOPPED','close','complete','[%s][AGENT]\x20ROUTING\x20END','next','[%s][AGENT]\x20agent\x20not\x20found\x20%s','stack','lodash','util','seq-queue'];(function(_0x281fb0,_0x3d97bf){var _0x432d42=function(_0x4318c4){while(--_0x4318c4){_0x281fb0['push'](_0x281fb0['shift']());}};_0x432d42(++_0x3d97bf);}(_0x6324,0xa2));var _0x4632=function(_0x377199,_0x1439fa){_0x377199=_0x377199-0x0;var _0x501155=_0x6324[_0x377199];return _0x501155;};'use strict';var schema=require('validate');var _=require(_0x4632('0x0'));var util=require(_0x4632('0x1'));var seqqueue=require(_0x4632('0x2'));var logger=require('../../../../config/logger')(_0x4632('0x3'));var strategy=require(_0x4632('0x4'));var queue=schema({'name':{'type':_0x4632('0x5'),'required':!![],'message':_0x4632('0x6')},'timeout':{'type':'number','message':_0x4632('0x7')}});function writeLog(_0x55b4c2,_0x24a291,_0x70a06e){return logger[_0x4632('0x8')](util[_0x4632('0x9')]('[%s][AGENT][NAME:%s][STATUS:%s]',_0x55b4c2,_0x24a291[_0x4632('0xa')],_0x70a06e));}function handleFindAgent(_0x2e1208){return function(_0x8a02b6){return _0x8a02b6[_0x4632('0xa')][_0x4632('0xb')]()===_0x2e1208[_0x4632('0xb')]();};}exports[_0x4632('0xc')]=function(_0x391c6b,_0x4538ea,_0x392848,_0x369a39){return function(_0x38f4e0){try{var _0x34342b={'name':_0x4538ea[0x0],'timeout':_0x4538ea[0x1]};var _0x205183=queue[_0x4632('0xd')](_0x34342b,{'typecast':!![]});if(_0x205183['length']){logger[_0x4632('0xe')](_0x4632('0xf'),_0x391c6b,_[_0x4632('0x10')](_0x205183,_0x4632('0x11'))[_0x4632('0x12')](',\x20'));_0x38f4e0[_0x4632('0x13')]();}else{var _0x5609f4=_[_0x4632('0x14')](_0x392848[_0x4632('0x15')],handleFindAgent(_0x34342b[_0x4632('0xa')]));if(_0x5609f4){var _0x428ea3=(_0x34342b[_0x4632('0x16')]||0xa)*0x3e8;var _0x48795c,_0x2bd43d;var _0x49b430=seqqueue['createQueue'](_0x428ea3);_0x49b430['id']=_0x391c6b;_0x49b430['atimeout']=_0x428ea3;_0x49b430[_0x4632('0x17')]=_0x369a39[_0x4632('0x17')];writeLog(_0x391c6b,_0x5609f4,util[_0x4632('0x9')](_0x4632('0x18'),_0x428ea3));_0x392848[_0x4632('0x19')][_0x391c6b]['on']('end',function(){logger['info'](_0x4632('0x1a'),_0x391c6b);clearTimeout(_0x2bd43d);_0x2bd43d=undefined;_0x49b430[_0x4632('0x1b')]();if(_0x392848['rules'][_0x391c6b]){delete _0x392848[_0x4632('0x19')][_0x391c6b];}_0x38f4e0[_0x4632('0x13')]();});_0x392848[_0x4632('0x19')][_0x391c6b]['on'](_0x4632('0x1c'),function(){if(_0x392848[_0x4632('0x19')][_0x391c6b]){delete _0x392848[_0x4632('0x19')][_0x391c6b];}});_0x2bd43d=setTimeout(function(){logger['info'](_0x4632('0x1d'),_0x391c6b);clearTimeout(_0x2bd43d);_0x49b430[_0x4632('0x1b')]();_0x38f4e0[_0x4632('0x1e')]();},_0x428ea3);strategy['agent'](_0x49b430,_0x5609f4,_0x392848,_0x369a39);}else{logger[_0x4632('0xe')](_0x4632('0x1f'),_0x391c6b,_0x34342b['name']);_0x38f4e0[_0x4632('0x13')]();}}}catch(_0x2cc2ff){console['log'](_0x2cc2ff);logger[_0x4632('0xe')]('[%s][QUEUE]\x20%s',_0x391c6b,_0x2cc2ff[_0x4632('0x20')]);_0x38f4e0['stop']();}};};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff