X-Git-Url: http://repos.xcallymotion.com/?a=blobdiff_plain;f=server%2Fservices%2Fagi%2Fevents.js;h=7c332d76b21781644caa161c11220f730a08772c;hb=0fe7d63fdd24ac799f5260a5b10b06097955b09f;hp=c8a774d0440cee184f84b0720839ab969162bed7;hpb=4f69ebcfd3a87338adde0f617720ee400a063456;p=motion2.git

diff --git a/server/services/agi/events.js b/server/services/agi/events.js
index c8a774d..7c332d7 100644
--- a/server/services/agi/events.js
+++ b/server/services/agi/events.js
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold. 		           *
 // *                                                                       *
 // *************************************************************************
-var _0x8a2a=['ioredis','./error','../../config/environment','redis','defaults','localhost','agi','emit','error','E_AGI_SERVER_ERROR','message','parse','projectUpdate','exports','lodash','events','EventEmitter'];(function(_0x19e35c,_0x29cd1e){var _0x3e1fe8=function(_0x17258b){while(--_0x17258b){_0x19e35c['push'](_0x19e35c['shift']());}};_0x3e1fe8(++_0x29cd1e);}(_0x8a2a,0x1ea));var _0xa8a2=function(_0x31a938,_0x4daec6){_0x31a938=_0x31a938-0x0;var _0x1bf341=_0x8a2a[_0x31a938];return _0x1bf341;};'use strict';var _=require(_0xa8a2('0x0'));var EventEmitter=require(_0xa8a2('0x1'))[_0xa8a2('0x2')];var Redis=require(_0xa8a2('0x3'));var AGIError=require(_0xa8a2('0x4'));var config=require(_0xa8a2('0x5'));config[_0xa8a2('0x6')]=_[_0xa8a2('0x7')](config[_0xa8a2('0x6')],{'host':_0xa8a2('0x8'),'port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config[_0xa8a2('0x6')]);sub['subscribe'](_0xa8a2('0x9'),function(_0x4971fd){if(_0x4971fd)return eventEmitter[_0xa8a2('0xa')](_0xa8a2('0xb'),new AGIError(_0xa8a2('0xc'),_0x4971fd));});sub['on'](_0xa8a2('0xd'),function(_0x192815,_0x1c1be3){if(_0x192815!=='agi')return;try{var _0x1af045=JSON[_0xa8a2('0xe')](_0x1c1be3);eventEmitter[_0xa8a2('0xa')](_0xa8a2('0xf'),_0x1af045);}catch(_0x1897be){eventEmitter[_0xa8a2('0xa')](_0xa8a2('0xb'),new AGIError(_0xa8a2('0xc'),_0x1897be));}});module[_0xa8a2('0x10')]={'EventEmitter':eventEmitter};
\ No newline at end of file
+var _0x3478=['projectUpdate','E_AGI_SERVER_ERROR','events','ioredis','./error','../../config/environment','redis','defaults','localhost','subscribe','agi','emit','error','message','parse'];(function(_0xa8f7f7,_0x10f3f5){var _0x5e5be3=function(_0x5730ab){while(--_0x5730ab){_0xa8f7f7['push'](_0xa8f7f7['shift']());}};_0x5e5be3(++_0x10f3f5);}(_0x3478,0xe3));var _0x8347=function(_0x4d77b8,_0x208e64){_0x4d77b8=_0x4d77b8-0x0;var _0x82da62=_0x3478[_0x4d77b8];return _0x82da62;};'use strict';var _=require('lodash');var EventEmitter=require(_0x8347('0x0'))['EventEmitter'];var Redis=require(_0x8347('0x1'));var AGIError=require(_0x8347('0x2'));var config=require(_0x8347('0x3'));config[_0x8347('0x4')]=_[_0x8347('0x5')](config['redis'],{'host':_0x8347('0x6'),'port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config[_0x8347('0x4')]);sub[_0x8347('0x7')](_0x8347('0x8'),function(_0x4e4be6){if(_0x4e4be6)return eventEmitter[_0x8347('0x9')](_0x8347('0xa'),new AGIError('E_AGI_SERVER_ERROR',_0x4e4be6));});sub['on'](_0x8347('0xb'),function(_0xfe8b6c,_0xf93eb9){if(_0xfe8b6c!==_0x8347('0x8'))return;try{var _0x3f9e73=JSON[_0x8347('0xc')](_0xf93eb9);eventEmitter['emit'](_0x8347('0xd'),_0x3f9e73);}catch(_0x359524){eventEmitter[_0x8347('0x9')]('error',new AGIError(_0x8347('0xe'),_0x359524));}});module['exports']={'EventEmitter':eventEmitter};
\ No newline at end of file