Built motion from commit 1ea47bf4.|2.6.34
[motion2.git] / server / services / agi / events.js
index 6ec0bb6..a425a7a 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xca74=['defaults','agi','error','E_AGI_SERVER_ERROR','message','parse','emit','exports','lodash','events','EventEmitter','ioredis','./error','../../config/environment','redis'];(function(_0x14fb34,_0x174afb){var _0x1ff44d=function(_0x2065a1){while(--_0x2065a1){_0x14fb34['push'](_0x14fb34['shift']());}};_0x1ff44d(++_0x174afb);}(_0xca74,0x1ac));var _0x4ca7=function(_0x208c01,_0x2dd63d){_0x208c01=_0x208c01-0x0;var _0x54a5fc=_0xca74[_0x208c01];return _0x54a5fc;};'use strict';var _=require(_0x4ca7('0x0'));var EventEmitter=require(_0x4ca7('0x1'))[_0x4ca7('0x2')];var Redis=require(_0x4ca7('0x3'));var AGIError=require(_0x4ca7('0x4'));var config=require(_0x4ca7('0x5'));config[_0x4ca7('0x6')]=_[_0x4ca7('0x7')](config[_0x4ca7('0x6')],{'host':'localhost','port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config[_0x4ca7('0x6')]);sub['subscribe'](_0x4ca7('0x8'),function(_0x5b6cfc){if(_0x5b6cfc)return eventEmitter['emit'](_0x4ca7('0x9'),new AGIError(_0x4ca7('0xa'),_0x5b6cfc));});sub['on'](_0x4ca7('0xb'),function(_0x566e00,_0x4851c4){if(_0x566e00!=='agi')return;try{var _0x4740d2=JSON[_0x4ca7('0xc')](_0x4851c4);eventEmitter[_0x4ca7('0xd')]('projectUpdate',_0x4740d2);}catch(_0x2c1eae){eventEmitter[_0x4ca7('0xd')]('error',new AGIError(_0x4ca7('0xa'),_0x2c1eae));}});module[_0x4ca7('0xe')]={'EventEmitter':eventEmitter};
\ No newline at end of file
+var _0x39d4=['emit','E_AGI_SERVER_ERROR','message','parse','projectUpdate','error','exports','events','EventEmitter','ioredis','./error','../../config/environment','redis','localhost','subscribe','agi'];(function(_0x2934b7,_0x3a094d){var _0x3f8313=function(_0x26ef7e){while(--_0x26ef7e){_0x2934b7['push'](_0x2934b7['shift']());}};_0x3f8313(++_0x3a094d);}(_0x39d4,0x187));var _0x439d=function(_0x16481d,_0x4958f4){_0x16481d=_0x16481d-0x0;var _0x31abbc=_0x39d4[_0x16481d];return _0x31abbc;};'use strict';var _=require('lodash');var EventEmitter=require(_0x439d('0x0'))[_0x439d('0x1')];var Redis=require(_0x439d('0x2'));var AGIError=require(_0x439d('0x3'));var config=require(_0x439d('0x4'));config[_0x439d('0x5')]=_['defaults'](config[_0x439d('0x5')],{'host':_0x439d('0x6'),'port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config[_0x439d('0x5')]);sub[_0x439d('0x7')](_0x439d('0x8'),function(_0x3f5ea2){if(_0x3f5ea2)return eventEmitter[_0x439d('0x9')]('error',new AGIError(_0x439d('0xa'),_0x3f5ea2));});sub['on'](_0x439d('0xb'),function(_0x1ff6ac,_0x126c92){if(_0x1ff6ac!==_0x439d('0x8'))return;try{var _0x5d1018=JSON[_0x439d('0xc')](_0x126c92);eventEmitter['emit'](_0x439d('0xd'),_0x5d1018);}catch(_0x2b893a){eventEmitter['emit'](_0x439d('0xe'),new AGIError(_0x439d('0xa'),_0x2b893a));}});module[_0x439d('0xf')]={'EventEmitter':eventEmitter};
\ No newline at end of file