Built motion from commit 980b26c3.|2.6.29
[motion2.git] / server / services / agi / events.js
index cbd359b..eb61fe0 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xcebc=['lodash','events','EventEmitter','ioredis','./error','defaults','redis','localhost','subscribe','agi','emit','error','E_AGI_SERVER_ERROR','message','parse','projectUpdate'];(function(_0x40c1a8,_0x3bd2fa){var _0x124915=function(_0xc45ba9){while(--_0xc45ba9){_0x40c1a8['push'](_0x40c1a8['shift']());}};_0x124915(++_0x3bd2fa);}(_0xcebc,0x120));var _0xcceb=function(_0x22c92e,_0xba0d7a){_0x22c92e=_0x22c92e-0x0;var _0xaf6b94=_0xcebc[_0x22c92e];return _0xaf6b94;};'use strict';var _=require(_0xcceb('0x0'));var EventEmitter=require(_0xcceb('0x1'))[_0xcceb('0x2')];var Redis=require(_0xcceb('0x3'));var AGIError=require(_0xcceb('0x4'));var config=require('../../config/environment');config['redis']=_[_0xcceb('0x5')](config[_0xcceb('0x6')],{'host':_0xcceb('0x7'),'port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config[_0xcceb('0x6')]);sub[_0xcceb('0x8')](_0xcceb('0x9'),function(_0x462d5a){if(_0x462d5a)return eventEmitter[_0xcceb('0xa')](_0xcceb('0xb'),new AGIError(_0xcceb('0xc'),_0x462d5a));});sub['on'](_0xcceb('0xd'),function(_0x23cb3c,_0x1d94f8){if(_0x23cb3c!==_0xcceb('0x9'))return;try{var _0x1ba2c2=JSON[_0xcceb('0xe')](_0x1d94f8);eventEmitter[_0xcceb('0xa')](_0xcceb('0xf'),_0x1ba2c2);}catch(_0x5f0229){eventEmitter[_0xcceb('0xa')](_0xcceb('0xb'),new AGIError(_0xcceb('0xc'),_0x5f0229));}});module['exports']={'EventEmitter':eventEmitter};
\ No newline at end of file
+var _0x6f9d=['events','./error','../../config/environment','defaults','redis','subscribe','message','agi','projectUpdate','emit','E_AGI_SERVER_ERROR','exports'];(function(_0x321ac6,_0x3870a2){var _0x50c357=function(_0x1c37b){while(--_0x1c37b){_0x321ac6['push'](_0x321ac6['shift']());}};_0x50c357(++_0x3870a2);}(_0x6f9d,0x120));var _0xd6f9=function(_0x155f22,_0x30422c){_0x155f22=_0x155f22-0x0;var _0x569d57=_0x6f9d[_0x155f22];return _0x569d57;};'use strict';var _=require('lodash');var EventEmitter=require(_0xd6f9('0x0'))['EventEmitter'];var Redis=require('ioredis');var AGIError=require(_0xd6f9('0x1'));var config=require(_0xd6f9('0x2'));config['redis']=_[_0xd6f9('0x3')](config[_0xd6f9('0x4')],{'host':'localhost','port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config['redis']);sub[_0xd6f9('0x5')]('agi',function(_0x53d6cc){if(_0x53d6cc)return eventEmitter['emit']('error',new AGIError('E_AGI_SERVER_ERROR',_0x53d6cc));});sub['on'](_0xd6f9('0x6'),function(_0x50c1e6,_0x163f82){if(_0x50c1e6!==_0xd6f9('0x7'))return;try{var _0x4eda09=JSON['parse'](_0x163f82);eventEmitter['emit'](_0xd6f9('0x8'),_0x4eda09);}catch(_0x5e3dbc){eventEmitter[_0xd6f9('0x9')]('error',new AGIError(_0xd6f9('0xa'),_0x5e3dbc));}});module[_0xd6f9('0xb')]={'EventEmitter':eventEmitter};
\ No newline at end of file