// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-var _0xa45c=['map','model','ShowMailQueue','catch','lodash','util','randomstring','../../mysqldb','../../config/logger','jayson/promise','client','http','redis','localhost','socket.io-emitter','./mailQueue.socket','request','then','info','MailQueue,\x20%s,\x20%s','request\x20sent','debug','stringify','error','code','message','result','GetMailQueue','MailQueue','options','raw','where','attributes','limit','include'];(function(_0x6131cd,_0x4c26a1){var _0x47e916=function(_0x1f2bce){while(--_0x1f2bce){_0x6131cd['push'](_0x6131cd['shift']());}};_0x47e916(++_0x4c26a1);}(_0xa45c,0x6d));var _0xca45=function(_0x472823,_0x155c4a){_0x472823=_0x472823-0x0;var _0x33151c=_0xa45c[_0x472823];return _0x33151c;};'use strict';var _=require(_0xca45('0x0'));var util=require(_0xca45('0x1'));var moment=require('moment');var BPromise=require('bluebird');var rs=require(_0xca45('0x2'));var fs=require('fs');var Redis=require('ioredis');var db=require(_0xca45('0x3'))['db'];var utils=require('../../config/utils');var logger=require(_0xca45('0x4'))('rpc');var config=require('../../config/environment');var jayson=require(_0xca45('0x5'));var client=jayson[_0xca45('0x6')][_0xca45('0x7')]({'port':0x232a});config[_0xca45('0x8')]=_['defaults'](config[_0xca45('0x8')],{'host':_0xca45('0x9'),'port':0x18eb});var socket=require(_0xca45('0xa'))(new Redis(config[_0xca45('0x8')]));require(_0xca45('0xb'))['register'](socket);function respondWithRpcPromise(_0xeb0cd9,_0x342542,_0x32afdc){return new BPromise(function(_0x151691,_0x3a551){return client[_0xca45('0xc')](_0xeb0cd9,_0x32afdc)[_0xca45('0xd')](function(_0x4a8692){logger[_0xca45('0xe')](_0xca45('0xf'),_0x342542,_0xca45('0x10'));logger[_0xca45('0x11')]('MailQueue,\x20%s,\x20%s,\x20%s',_0x342542,_0xca45('0x10'),JSON[_0xca45('0x12')](_0x4a8692));if(_0x4a8692[_0xca45('0x13')]){if(_0x4a8692['error'][_0xca45('0x14')]===0x1f4){logger['error'](_0xca45('0xf'),_0x342542,_0x4a8692[_0xca45('0x13')][_0xca45('0x15')]);return _0x3a551(_0x4a8692[_0xca45('0x13')][_0xca45('0x15')]);}logger[_0xca45('0x13')](_0xca45('0xf'),_0x342542,_0x4a8692['error'][_0xca45('0x15')]);return _0x151691(_0x4a8692['error']['message']);}else{logger[_0xca45('0xe')](_0xca45('0xf'),_0x342542,'request\x20sent');_0x151691(_0x4a8692[_0xca45('0x16')][_0xca45('0x15')]);}})['catch'](function(_0x40540f){logger[_0xca45('0x13')](_0xca45('0xf'),_0x342542,_0x40540f);_0x3a551(_0x40540f);});});}exports[_0xca45('0x17')]=function(_0x5a231d){var _0x3e396b=this;return new Promise(function(_0x295d4b,_0x1a16f1){return db[_0xca45('0x18')]['findAll']({'raw':_0x5a231d[_0xca45('0x19')]?_0x5a231d[_0xca45('0x19')][_0xca45('0x1a')]===undefined?!![]:![]:!![],'where':_0x5a231d[_0xca45('0x19')]?_0x5a231d[_0xca45('0x19')][_0xca45('0x1b')]||null:null,'attributes':_0x5a231d[_0xca45('0x19')]?_0x5a231d[_0xca45('0x19')][_0xca45('0x1c')]||null:null,'limit':_0x5a231d['options']?_0x5a231d[_0xca45('0x19')][_0xca45('0x1d')]||null:null,'include':_0x5a231d[_0xca45('0x19')]?_0x5a231d[_0xca45('0x19')][_0xca45('0x1e')]?_['map'](_0x5a231d['options']['include'],function(_0x28d9f1){return{'model':db[_0x28d9f1['model']],'as':_0x28d9f1['as'],'attributes':_0x28d9f1['attributes'],'include':_0x28d9f1[_0xca45('0x1e')]?_[_0xca45('0x1f')](_0x28d9f1[_0xca45('0x1e')],function(_0x23f67a){return{'model':db[_0x23f67a[_0xca45('0x20')]],'as':_0x23f67a['as'],'attributes':_0x23f67a['attributes'],'include':_0x23f67a[_0xca45('0x1e')]?_[_0xca45('0x1f')](_0x23f67a[_0xca45('0x1e')],function(_0x4d546c){return{'model':db[_0x4d546c['model']],'as':_0x4d546c['as'],'attributes':_0x4d546c['attributes']};}):[]};}):[]};}):[]:[]})[_0xca45('0xd')](function(_0x2e51b1){logger['info'](_0xca45('0x17'),_0x5a231d);logger[_0xca45('0x11')](_0xca45('0x17'),_0x5a231d,JSON[_0xca45('0x12')](_0x2e51b1));_0x295d4b(_0x2e51b1);})['catch'](function(_0x4fb7be){logger['error'](_0xca45('0x17'),_0x4fb7be['message'],_0x5a231d);_0x1a16f1(_0x3e396b['error'](0x1f4,_0x4fb7be['message']));});});};exports[_0xca45('0x21')]=function(_0x4945d5){var _0x50d882=this;return new Promise(function(_0x119244,_0x1444bd){return db[_0xca45('0x18')]['find']({'raw':_0x4945d5[_0xca45('0x19')]?_0x4945d5[_0xca45('0x19')]['raw']===undefined?!![]:![]:!![],'where':_0x4945d5[_0xca45('0x19')]?_0x4945d5[_0xca45('0x19')][_0xca45('0x1b')]||null:null,'attributes':_0x4945d5[_0xca45('0x19')]?_0x4945d5[_0xca45('0x19')][_0xca45('0x1c')]||null:null,'include':_0x4945d5[_0xca45('0x19')]?_0x4945d5[_0xca45('0x19')][_0xca45('0x1e')]?_[_0xca45('0x1f')](_0x4945d5[_0xca45('0x19')][_0xca45('0x1e')],function(_0x1d594c){return{'model':db[_0x1d594c['model']],'as':_0x1d594c['as'],'attributes':_0x1d594c['attributes'],'include':_0x1d594c['include']?_[_0xca45('0x1f')](_0x1d594c[_0xca45('0x1e')],function(_0x4d846e){return{'model':db[_0x4d846e['model']],'as':_0x4d846e['as'],'attributes':_0x4d846e[_0xca45('0x1c')],'include':_0x4d846e['include']?_[_0xca45('0x1f')](_0x4d846e['include'],function(_0x4de1d0){return{'model':db[_0x4de1d0[_0xca45('0x20')]],'as':_0x4de1d0['as'],'attributes':_0x4de1d0[_0xca45('0x1c')]};}):[]};}):[]};}):[]:[]})[_0xca45('0xd')](function(_0x32e959){logger['info'](_0xca45('0x21'),_0x4945d5);logger['debug'](_0xca45('0x21'),_0x4945d5,JSON[_0xca45('0x12')](_0x32e959));_0x119244(_0x32e959);})[_0xca45('0x22')](function(_0x370b6e){logger['error'](_0xca45('0x21'),_0x370b6e[_0xca45('0x15')],_0x4945d5);_0x1444bd(_0x50d882[_0xca45('0x13')](0x1f4,_0x370b6e['message']));});});};
\ No newline at end of file
+var _0xd506=['catch','GetMailQueue','findAll','options','limit','include','map','model','attributes','ShowMailQueue','raw','lodash','util','randomstring','ioredis','../../mysqldb','../../config/utils','../../config/logger','rpc','../../config/environment','jayson/promise','redis','defaults','localhost','socket.io-emitter','./mailQueue.socket','register','request','then','info','MailQueue,\x20%s,\x20%s','request\x20sent','debug','stringify','error','message','result'];(function(_0x1e909d,_0x4a8f3d){var _0x4762cd=function(_0x30cc4e){while(--_0x30cc4e){_0x1e909d['push'](_0x1e909d['shift']());}};_0x4762cd(++_0x4a8f3d);}(_0xd506,0x7a));var _0x6d50=function(_0x1d24eb,_0x12295b){_0x1d24eb=_0x1d24eb-0x0;var _0x1dc576=_0xd506[_0x1d24eb];return _0x1dc576;};'use strict';var _=require(_0x6d50('0x0'));var util=require(_0x6d50('0x1'));var moment=require('moment');var BPromise=require('bluebird');var rs=require(_0x6d50('0x2'));var fs=require('fs');var Redis=require(_0x6d50('0x3'));var db=require(_0x6d50('0x4'))['db'];var utils=require(_0x6d50('0x5'));var logger=require(_0x6d50('0x6'))(_0x6d50('0x7'));var config=require(_0x6d50('0x8'));var jayson=require(_0x6d50('0x9'));var client=jayson['client']['http']({'port':0x232a});config[_0x6d50('0xa')]=_[_0x6d50('0xb')](config['redis'],{'host':_0x6d50('0xc'),'port':0x18eb});var socket=require(_0x6d50('0xd'))(new Redis(config['redis']));require(_0x6d50('0xe'))[_0x6d50('0xf')](socket);function respondWithRpcPromise(_0xc5030,_0x577f10,_0x245d36){return new BPromise(function(_0x3b5bca,_0x1c471a){return client[_0x6d50('0x10')](_0xc5030,_0x245d36)[_0x6d50('0x11')](function(_0x34e756){logger[_0x6d50('0x12')](_0x6d50('0x13'),_0x577f10,_0x6d50('0x14'));logger[_0x6d50('0x15')]('MailQueue,\x20%s,\x20%s,\x20%s',_0x577f10,'request\x20sent',JSON[_0x6d50('0x16')](_0x34e756));if(_0x34e756['error']){if(_0x34e756[_0x6d50('0x17')]['code']===0x1f4){logger[_0x6d50('0x17')](_0x6d50('0x13'),_0x577f10,_0x34e756[_0x6d50('0x17')][_0x6d50('0x18')]);return _0x1c471a(_0x34e756[_0x6d50('0x17')][_0x6d50('0x18')]);}logger[_0x6d50('0x17')](_0x6d50('0x13'),_0x577f10,_0x34e756[_0x6d50('0x17')]['message']);return _0x3b5bca(_0x34e756[_0x6d50('0x17')][_0x6d50('0x18')]);}else{logger[_0x6d50('0x12')](_0x6d50('0x13'),_0x577f10,'request\x20sent');_0x3b5bca(_0x34e756[_0x6d50('0x19')][_0x6d50('0x18')]);}})[_0x6d50('0x1a')](function(_0x39fafb){logger[_0x6d50('0x17')](_0x6d50('0x13'),_0x577f10,_0x39fafb);_0x1c471a(_0x39fafb);});});}exports[_0x6d50('0x1b')]=function(_0x49da8a){var _0x4f2423=this;return new Promise(function(_0x17cb78,_0xbb26ef){return db['MailQueue'][_0x6d50('0x1c')]({'raw':_0x49da8a[_0x6d50('0x1d')]?_0x49da8a[_0x6d50('0x1d')]['raw']===undefined?!![]:![]:!![],'where':_0x49da8a[_0x6d50('0x1d')]?_0x49da8a[_0x6d50('0x1d')]['where']||null:null,'attributes':_0x49da8a[_0x6d50('0x1d')]?_0x49da8a[_0x6d50('0x1d')]['attributes']||null:null,'limit':_0x49da8a[_0x6d50('0x1d')]?_0x49da8a['options'][_0x6d50('0x1e')]||null:null,'include':_0x49da8a[_0x6d50('0x1d')]?_0x49da8a[_0x6d50('0x1d')][_0x6d50('0x1f')]?_[_0x6d50('0x20')](_0x49da8a[_0x6d50('0x1d')][_0x6d50('0x1f')],function(_0x2986ce){return{'model':db[_0x2986ce[_0x6d50('0x21')]],'as':_0x2986ce['as'],'attributes':_0x2986ce[_0x6d50('0x22')],'include':_0x2986ce['include']?_['map'](_0x2986ce[_0x6d50('0x1f')],function(_0x382845){return{'model':db[_0x382845[_0x6d50('0x21')]],'as':_0x382845['as'],'attributes':_0x382845['attributes'],'include':_0x382845['include']?_[_0x6d50('0x20')](_0x382845[_0x6d50('0x1f')],function(_0x572706){return{'model':db[_0x572706[_0x6d50('0x21')]],'as':_0x572706['as'],'attributes':_0x572706['attributes']};}):[]};}):[]};}):[]:[]})[_0x6d50('0x11')](function(_0x401201){logger[_0x6d50('0x12')](_0x6d50('0x1b'),_0x49da8a);logger[_0x6d50('0x15')](_0x6d50('0x1b'),_0x49da8a,JSON['stringify'](_0x401201));_0x17cb78(_0x401201);})[_0x6d50('0x1a')](function(_0x2cd546){logger['error']('GetMailQueue',_0x2cd546[_0x6d50('0x18')],_0x49da8a);_0xbb26ef(_0x4f2423[_0x6d50('0x17')](0x1f4,_0x2cd546['message']));});});};exports[_0x6d50('0x23')]=function(_0x41f0b3){var _0x274153=this;return new Promise(function(_0x573583,_0x28e123){return db['MailQueue']['find']({'raw':_0x41f0b3['options']?_0x41f0b3[_0x6d50('0x1d')][_0x6d50('0x24')]===undefined?!![]:![]:!![],'where':_0x41f0b3[_0x6d50('0x1d')]?_0x41f0b3['options']['where']||null:null,'attributes':_0x41f0b3['options']?_0x41f0b3[_0x6d50('0x1d')][_0x6d50('0x22')]||null:null,'include':_0x41f0b3[_0x6d50('0x1d')]?_0x41f0b3[_0x6d50('0x1d')][_0x6d50('0x1f')]?_[_0x6d50('0x20')](_0x41f0b3[_0x6d50('0x1d')][_0x6d50('0x1f')],function(_0x4f1b30){return{'model':db[_0x4f1b30['model']],'as':_0x4f1b30['as'],'attributes':_0x4f1b30[_0x6d50('0x22')],'include':_0x4f1b30[_0x6d50('0x1f')]?_[_0x6d50('0x20')](_0x4f1b30['include'],function(_0x45c3a0){return{'model':db[_0x45c3a0[_0x6d50('0x21')]],'as':_0x45c3a0['as'],'attributes':_0x45c3a0[_0x6d50('0x22')],'include':_0x45c3a0['include']?_['map'](_0x45c3a0[_0x6d50('0x1f')],function(_0x59ddfd){return{'model':db[_0x59ddfd['model']],'as':_0x59ddfd['as'],'attributes':_0x59ddfd[_0x6d50('0x22')]};}):[]};}):[]};}):[]:[]})['then'](function(_0xaa1b58){logger[_0x6d50('0x12')](_0x6d50('0x23'),_0x41f0b3);logger[_0x6d50('0x15')](_0x6d50('0x23'),_0x41f0b3,JSON['stringify'](_0xaa1b58));_0x573583(_0xaa1b58);})[_0x6d50('0x1a')](function(_0x5c67d7){logger['error'](_0x6d50('0x23'),_0x5c67d7[_0x6d50('0x18')],_0x41f0b3);_0x28e123(_0x274153[_0x6d50('0x17')](0x1f4,_0x5c67d7[_0x6d50('0x18')]));});});};
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff