Built motion from commit fe909640.|2.6.8
[motion2.git] / server / services / routing / server / interval.js
index ceb9313..9ec1d14 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xa402=['info','[%s][INTERVAL]\x20ROUTING\x20STOPPED','length','push','Command','iftime\x20%s','true','some','join','log','[%s][INTERVAL]\x20%s\x20%s','\x20|\x20','stack','stop','jayson/promise','../../../config/logger','request','then','error','message','result','catch','rules'];(function(_0x49996d,_0x3fcd8f){var _0x9c2f5c=function(_0x5c40aa){while(--_0x5c40aa){_0x49996d['push'](_0x49996d['shift']());}};_0x9c2f5c(++_0x3fcd8f);}(_0xa402,0x150));var _0x2a40=function(_0x4e1d03,_0x786f3a){_0x4e1d03=_0x4e1d03-0x0;var _0x362d4b=_0xa402[_0x4e1d03];return _0x362d4b;};'use strict';var util=require('util');var BPromise=require('bluebird');var jayson=require(_0x2a40('0x0'));var _=require('lodash');var logger=require(_0x2a40('0x1'))('routing');var client=jayson['client']['http']({'port':0x232a});function request(_0x4ec6a9,_0x173aef){return new BPromise(function(_0x3d0e8f,_0xa02703){return client[_0x2a40('0x2')](_0x4ec6a9,_0x173aef)[_0x2a40('0x3')](function(_0x39d296){if(_0x39d296[_0x2a40('0x4')]){return _0xa02703(_0x39d296[_0x2a40('0x4')][_0x2a40('0x5')]);}else{return _0x3d0e8f(_0x39d296[_0x2a40('0x6')]);}})[_0x2a40('0x7')](function(_0x15a257){return _0xa02703(_0x15a257);});});}exports['condition']=function(_0x4b3298,_0x581f25,_0x3c6105){return function(_0x10211f){if(_0x3c6105[_0x2a40('0x8')]&&!_0x3c6105['rules'][_0x4b3298]){logger[_0x2a40('0x9')](_0x2a40('0xa'),_0x4b3298);return _0x10211f['stop']();}var _0x434a01=[];for(var _0x590a3b=0x0;_0x590a3b<_0x581f25[_0x2a40('0xb')];_0x590a3b+=0x1){_0x434a01[_0x2a40('0xc')](request(_0x2a40('0xd'),{'command':util['format'](_0x2a40('0xe'),_0x581f25[_0x590a3b])})[_0x2a40('0x3')](function(_0x5438e5){return _0x5438e5&&_0x5438e5['message']&&_0x5438e5[_0x2a40('0x5')]['indexOf'](_0x2a40('0xf'))>=0x0?!![]:![];})['catch'](function(_0x3ea5f4){logger[_0x2a40('0x4')]('[%s][INTERVAL]\x20%s',_0x4b3298,_0x581f25[_0x590a3b]);}));}BPromise['all'](_0x434a01)[_0x2a40('0x3')](function(_0x140aac){var _0x40ac90=_[_0x2a40('0x10')](_0x140aac);logger['info']('[%s][INTERVAL]\x20%s\x20%s',_0x4b3298,_0x581f25[_0x2a40('0x11')]('\x20|\x20'),_0x40ac90);_0x10211f['when'](_0x40ac90);})[_0x2a40('0x7')](function(_0x3574d8){console[_0x2a40('0x12')](_0x3574d8);logger[_0x2a40('0x4')](_0x2a40('0x13'),_0x4b3298,_0x581f25[_0x2a40('0x11')](_0x2a40('0x14')),_0x3574d8[_0x2a40('0x15')]);_0x10211f[_0x2a40('0x16')]();});};};
\ No newline at end of file
+var _0x2a4b=['http','request','then','error','message','result','catch','condition','rules','length','push','Command','iftime\x20%s','indexOf','true','some','join','\x20|\x20','log','[%s][INTERVAL]\x20%s\x20%s','stack','stop','util','jayson/promise','lodash','../../../config/logger','routing','client'];(function(_0x3e2651,_0x4de6a4){var _0xb802ac=function(_0x2f851c){while(--_0x2f851c){_0x3e2651['push'](_0x3e2651['shift']());}};_0xb802ac(++_0x4de6a4);}(_0x2a4b,0x166));var _0xb2a4=function(_0xeef74f,_0x311788){_0xeef74f=_0xeef74f-0x0;var _0x20a64b=_0x2a4b[_0xeef74f];return _0x20a64b;};'use strict';var util=require(_0xb2a4('0x0'));var BPromise=require('bluebird');var jayson=require(_0xb2a4('0x1'));var _=require(_0xb2a4('0x2'));var logger=require(_0xb2a4('0x3'))(_0xb2a4('0x4'));var client=jayson[_0xb2a4('0x5')][_0xb2a4('0x6')]({'port':0x232a});function request(_0x31e910,_0x334263){return new BPromise(function(_0x446018,_0x1607c6){return client[_0xb2a4('0x7')](_0x31e910,_0x334263)[_0xb2a4('0x8')](function(_0x1ab86b){if(_0x1ab86b[_0xb2a4('0x9')]){return _0x1607c6(_0x1ab86b['error'][_0xb2a4('0xa')]);}else{return _0x446018(_0x1ab86b[_0xb2a4('0xb')]);}})[_0xb2a4('0xc')](function(_0x456259){return _0x1607c6(_0x456259);});});}exports[_0xb2a4('0xd')]=function(_0x3a3f7b,_0x204d24,_0x2eaa42){return function(_0x277173){if(_0x2eaa42[_0xb2a4('0xe')]&&!_0x2eaa42[_0xb2a4('0xe')][_0x3a3f7b]){logger['info']('[%s][INTERVAL]\x20ROUTING\x20STOPPED',_0x3a3f7b);return _0x277173['stop']();}var _0x30c550=[];for(var _0x153faf=0x0;_0x153faf<_0x204d24[_0xb2a4('0xf')];_0x153faf+=0x1){_0x30c550[_0xb2a4('0x10')](request(_0xb2a4('0x11'),{'command':util['format'](_0xb2a4('0x12'),_0x204d24[_0x153faf])})[_0xb2a4('0x8')](function(_0x398048){return _0x398048&&_0x398048[_0xb2a4('0xa')]&&_0x398048['message'][_0xb2a4('0x13')](_0xb2a4('0x14'))>=0x0?!![]:![];})[_0xb2a4('0xc')](function(_0x19f999){logger['error']('[%s][INTERVAL]\x20%s',_0x3a3f7b,_0x204d24[_0x153faf]);}));}BPromise['all'](_0x30c550)[_0xb2a4('0x8')](function(_0x2930fa){var _0x4a69e6=_[_0xb2a4('0x15')](_0x2930fa);logger['info']('[%s][INTERVAL]\x20%s\x20%s',_0x3a3f7b,_0x204d24[_0xb2a4('0x16')](_0xb2a4('0x17')),_0x4a69e6);_0x277173['when'](_0x4a69e6);})['catch'](function(_0x106f08){console[_0xb2a4('0x18')](_0x106f08);logger['error'](_0xb2a4('0x19'),_0x3a3f7b,_0x204d24[_0xb2a4('0x16')](_0xb2a4('0x17')),_0x106f08[_0xb2a4('0x1a')]);_0x277173[_0xb2a4('0x1b')]();});};};
\ No newline at end of file