Built motion from commit 52c8a02d.|2.6.29
[motion2.git] / server / services / agi / events.js
index d827d90..f4ad79d 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xed7c=['projectUpdate','E_AGI_SERVER_ERROR','exports','lodash','events','EventEmitter','./error','../../config/environment','redis','localhost','subscribe','agi','emit','error','parse'];(function(_0x597eab,_0xba46ae){var _0x51c2ca=function(_0x3f55ba){while(--_0x3f55ba){_0x597eab['push'](_0x597eab['shift']());}};_0x51c2ca(++_0xba46ae);}(_0xed7c,0x7b));var _0xced7=function(_0x53359b,_0x5f30f6){_0x53359b=_0x53359b-0x0;var _0x1d3171=_0xed7c[_0x53359b];return _0x1d3171;};'use strict';var _=require(_0xced7('0x0'));var EventEmitter=require(_0xced7('0x1'))[_0xced7('0x2')];var Redis=require('ioredis');var AGIError=require(_0xced7('0x3'));var config=require(_0xced7('0x4'));config[_0xced7('0x5')]=_['defaults'](config['redis'],{'host':_0xced7('0x6'),'port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config['redis']);sub[_0xced7('0x7')](_0xced7('0x8'),function(_0x537b09){if(_0x537b09)return eventEmitter[_0xced7('0x9')](_0xced7('0xa'),new AGIError('E_AGI_SERVER_ERROR',_0x537b09));});sub['on']('message',function(_0x31fefe,_0x1484d2){if(_0x31fefe!==_0xced7('0x8'))return;try{var _0x5e0cac=JSON[_0xced7('0xb')](_0x1484d2);eventEmitter['emit'](_0xced7('0xc'),_0x5e0cac);}catch(_0x10a66e){eventEmitter[_0xced7('0x9')]('error',new AGIError(_0xced7('0xd'),_0x10a66e));}});module[_0xced7('0xe')]={'EventEmitter':eventEmitter};
\ No newline at end of file
+var _0x0684=['agi','emit','error','E_AGI_SERVER_ERROR','message','parse','projectUpdate','exports','events','ioredis','../../config/environment','defaults','redis'];(function(_0x11cb6c,_0x582422){var _0x3e6894=function(_0x4aade5){while(--_0x4aade5){_0x11cb6c['push'](_0x11cb6c['shift']());}};_0x3e6894(++_0x582422);}(_0x0684,0x70));var _0x4068=function(_0x44aa8f,_0x36302f){_0x44aa8f=_0x44aa8f-0x0;var _0x4212fa=_0x0684[_0x44aa8f];return _0x4212fa;};'use strict';var _=require('lodash');var EventEmitter=require(_0x4068('0x0'))['EventEmitter'];var Redis=require(_0x4068('0x1'));var AGIError=require('./error');var config=require(_0x4068('0x2'));config['redis']=_[_0x4068('0x3')](config[_0x4068('0x4')],{'host':'localhost','port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config[_0x4068('0x4')]);sub['subscribe'](_0x4068('0x5'),function(_0x5390cb){if(_0x5390cb)return eventEmitter[_0x4068('0x6')](_0x4068('0x7'),new AGIError(_0x4068('0x8'),_0x5390cb));});sub['on'](_0x4068('0x9'),function(_0x496290,_0x50e70b){if(_0x496290!==_0x4068('0x5'))return;try{var _0x1c047b=JSON[_0x4068('0xa')](_0x50e70b);eventEmitter['emit'](_0x4068('0xb'),_0x1c047b);}catch(_0x422d4f){eventEmitter['emit'](_0x4068('0x7'),new AGIError('E_AGI_SERVER_ERROR',_0x422d4f));}});module[_0x4068('0xc')]={'EventEmitter':eventEmitter};
\ No newline at end of file