server/services/routing/server/interval.js

   1 'use strict';const a1412_0x222c=['all','http','@utils/console-logger','info','iftime\x20%s','jayson/promise','then','message','2CFMJRg','client','214zuuMOt','674046ROfkRv','1PogUEA','[%s][INTERVAL]\x20%s\x20%s','routing','result','indexOf','when','stop','646CKeBzh','true','275881XTZqLG','rpcAmiIp','2njBWkX','[%s][INTERVAL]\x20ROUTING\x20STOPPED','format','Command','join','1070PhTDfF','304555YpcMYO','catch','\x20|\x20','1AHVHDT','rules','lodash','request','75351nutVcv','error','411DSnCfX','some','length','236415XraSKk','rpcAmiPort'];const a1412_0x6dd1=function(_0x4fef3a,_0x9ba084){_0x4fef3a=_0x4fef3a-0x159;let _0x222ce7=a1412_0x222c[_0x4fef3a];return _0x222ce7;};const a1412_0x1d683b=a1412_0x6dd1;(function(_0x51a2b5,_0x3a2141){const _0x27df27=a1412_0x6dd1;while(!![]){try{const _0x998eba=parseInt(_0x27df27(0x168))*-parseInt(_0x27df27(0x177))+parseInt(_0x27df27(0x17a))+parseInt(_0x27df27(0x15b))*-parseInt(_0x27df27(0x161))+parseInt(_0x27df27(0x164))*-parseInt(_0x27df27(0x16d))+parseInt(_0x27df27(0x159))*parseInt(_0x27df27(0x17b))+-parseInt(_0x27df27(0x182))*-parseInt(_0x27df27(0x179))+-parseInt(_0x27df27(0x160))*-parseInt(_0x27df27(0x16a));if(_0x998eba===_0x3a2141)break;else _0x51a2b5['push'](_0x51a2b5['shift']());}catch(_0x443344){_0x51a2b5['push'](_0x51a2b5['shift']());}}}(a1412_0x222c,0x81d02));const util=require('util'),jayson=require(a1412_0x1d683b(0x174)),_=require(a1412_0x1d683b(0x166)),{consoleLogger}=require(a1412_0x1d683b(0x171)),logger=require('@config/logger')(a1412_0x1d683b(0x17d)),{getConfig}=require('@config/get-config'),config=getConfig(),rpcAmiClient=jayson[a1412_0x1d683b(0x178)][a1412_0x1d683b(0x170)]({'host':config[a1412_0x1d683b(0x15a)],'port':config[a1412_0x1d683b(0x16e)]});function request(_0x3e24b3,_0x3ff2d5){return new Promise(function(_0x29463d,_0x1f7221){const _0xb13840=a1412_0x6dd1;return rpcAmiClient[_0xb13840(0x167)](_0x3e24b3,_0x3ff2d5)[_0xb13840(0x175)](function(_0x5b2071){const _0x15e1ca=_0xb13840;return _0x5b2071['error']?_0x1f7221(_0x5b2071[_0x15e1ca(0x169)][_0x15e1ca(0x176)]):_0x29463d(_0x5b2071[_0x15e1ca(0x17e)]);})[_0xb13840(0x162)](function(_0x52cac0){return _0x1f7221(_0x52cac0);});});}exports['condition']=function(_0x318b49,_0x118e8f,_0x523dd5){return function(_0x5962dd){const _0x113ddd=a1412_0x6dd1;if(_0x523dd5[_0x113ddd(0x165)]&&!_0x523dd5[_0x113ddd(0x165)][_0x318b49])return logger[_0x113ddd(0x172)](_0x113ddd(0x15c),_0x318b49),_0x5962dd[_0x113ddd(0x181)]();const _0x56bc4=[];for(let _0x4fd732=0x0;_0x4fd732<_0x118e8f[_0x113ddd(0x16c)];_0x4fd732+=0x1){_0x56bc4['push'](request(_0x113ddd(0x15e),{'command':util[_0x113ddd(0x15d)](_0x113ddd(0x173),_0x118e8f[_0x4fd732])})[_0x113ddd(0x175)](function(_0x3c3320){const _0x12ea1c=_0x113ddd;return _0x3c3320&&_0x3c3320[_0x12ea1c(0x176)]&&_0x3c3320['message'][_0x12ea1c(0x17f)](_0x12ea1c(0x183))>=0x0?!![]:![];})[_0x113ddd(0x162)](function(){logger['error']('[%s][INTERVAL]\x20%s',_0x318b49,_0x118e8f[_0x4fd732]);}));}Promise[_0x113ddd(0x16f)](_0x56bc4)[_0x113ddd(0x175)](function(_0x21f7a8){const _0x555642=_0x113ddd,_0x9ef71f=_[_0x555642(0x16b)](_0x21f7a8);logger[_0x555642(0x172)]('[%s][INTERVAL]\x20%s\x20%s',_0x318b49,_0x118e8f[_0x555642(0x15f)]('\x20|\x20'),_0x9ef71f),_0x5962dd[_0x555642(0x180)](_0x9ef71f);})['catch'](function(_0xc33827){const _0xa035e4=_0x113ddd;consoleLogger[_0xa035e4(0x169)](_0xc33827),logger[_0xa035e4(0x169)](_0xa035e4(0x17c),_0x318b49,_0x118e8f[_0xa035e4(0x15f)](_0xa035e4(0x163)),_0xc33827['stack']),_0x5962dd['stop']();});};};