X-Git-Url: http://repos.xcallymotion.com/?a=blobdiff_plain;f=server%2Fservices%2Fagi%2Fevents.js;h=1778b58a067ab10a161a9c7335112f61f5059ff4;hb=5584754b2aa104a57907f7aa392d8c07dfdc6150;hp=7b84ae5d9714e9ea4d9238524723071c9b3a05a7;hpb=ece744b31d5c8c1b26913aafb50e0250a2a6b474;p=motion2.git diff --git a/server/services/agi/events.js b/server/services/agi/events.js index 7b84ae5..1778b58 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 _0xe515=['subscribe','emit','agi','parse','projectUpdate','error','exports','lodash','events','EventEmitter','ioredis','./error','redis','localhost'];(function(_0x354df3,_0x528300){var _0x53ac34=function(_0x345af1){while(--_0x345af1){_0x354df3['push'](_0x354df3['shift']());}};_0x53ac34(++_0x528300);}(_0xe515,0x1b9));var _0x5e51=function(_0x43edd1,_0xf14003){_0x43edd1=_0x43edd1-0x0;var _0x43bb9e=_0xe515[_0x43edd1];return _0x43bb9e;};'use strict';var _=require(_0x5e51('0x0'));var EventEmitter=require(_0x5e51('0x1'))[_0x5e51('0x2')];var Redis=require(_0x5e51('0x3'));var AGIError=require(_0x5e51('0x4'));var config=require('../../config/environment');config['redis']=_['defaults'](config[_0x5e51('0x5')],{'host':_0x5e51('0x6'),'port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config[_0x5e51('0x5')]);sub[_0x5e51('0x7')]('agi',function(_0x27fcc6){if(_0x27fcc6)return eventEmitter[_0x5e51('0x8')]('error',new AGIError('E_AGI_SERVER_ERROR',_0x27fcc6));});sub['on']('message',function(_0x592aac,_0x11fa8d){if(_0x592aac!==_0x5e51('0x9'))return;try{var _0x161a76=JSON[_0x5e51('0xa')](_0x11fa8d);eventEmitter[_0x5e51('0x8')](_0x5e51('0xb'),_0x161a76);}catch(_0x315165){eventEmitter[_0x5e51('0x8')](_0x5e51('0xc'),new AGIError('E_AGI_SERVER_ERROR',_0x315165));}});module[_0x5e51('0xd')]={'EventEmitter':eventEmitter}; \ No newline at end of file +var _0xaca3=['ioredis','./error','../../config/environment','redis','defaults','subscribe','agi','emit','error','parse','projectUpdate','E_AGI_SERVER_ERROR','exports','lodash','events','EventEmitter'];(function(_0x58db35,_0x1dbbb2){var _0x59df05=function(_0x4748bb){while(--_0x4748bb){_0x58db35['push'](_0x58db35['shift']());}};_0x59df05(++_0x1dbbb2);}(_0xaca3,0xad));var _0x3aca=function(_0x6507b2,_0x386743){_0x6507b2=_0x6507b2-0x0;var _0x5c4993=_0xaca3[_0x6507b2];return _0x5c4993;};'use strict';var _=require(_0x3aca('0x0'));var EventEmitter=require(_0x3aca('0x1'))[_0x3aca('0x2')];var Redis=require(_0x3aca('0x3'));var AGIError=require(_0x3aca('0x4'));var config=require(_0x3aca('0x5'));config[_0x3aca('0x6')]=_[_0x3aca('0x7')](config[_0x3aca('0x6')],{'host':'localhost','port':0x18eb});var eventEmitter=new EventEmitter();var sub=new Redis(config['redis']);sub[_0x3aca('0x8')](_0x3aca('0x9'),function(_0x1bba16){if(_0x1bba16)return eventEmitter[_0x3aca('0xa')](_0x3aca('0xb'),new AGIError('E_AGI_SERVER_ERROR',_0x1bba16));});sub['on']('message',function(_0x414d53,_0x540759){if(_0x414d53!==_0x3aca('0x9'))return;try{var _0x3843cb=JSON[_0x3aca('0xc')](_0x540759);eventEmitter[_0x3aca('0xa')](_0x3aca('0xd'),_0x3843cb);}catch(_0x38cd40){eventEmitter[_0x3aca('0xa')](_0x3aca('0xb'),new AGIError(_0x3aca('0xe'),_0x38cd40));}});module[_0x3aca('0xf')]={'EventEmitter':eventEmitter}; \ No newline at end of file