X-Git-Url: http://repos.xcallymotion.com/?a=blobdiff_plain;f=server%2Fservices%2Frouting%2Fmodel%2FmailQueue.js;h=028dd27fb0cee4b9d323f7af8b80d47de4bfd352;hb=f6a4a6da2059d78b5a9307c96563cc0d2a15e915;hp=b4a9690b4edc111c0a6507be2d6ca3f8afd17509;hpb=43db2c329c99249300a38f3296ebfb46ac71947b;p=motion2.git diff --git a/server/services/routing/model/mailQueue.js b/server/services/routing/model/mailQueue.js index b4a9690..028dd27 100644 --- a/server/services/routing/model/mailQueue.js +++ b/server/services/routing/model/mailQueue.js @@ -15,4 +15,4 @@ // * treaties. The SOFTWARE PRODUCT is licensed, not sold. * // * * // ************************************************************************* -var _0x035b=['strategy','beepall','Agents','waiting','updateRouting','updateRealtime','mapAgentsId','_rr','loggedIn','length','online','mailPause','paused','available','stringify','mail:queue:%s','emit','lodash','md5','ioredis','../../../config/environment','redis','defaults','localhost','socket.io-emitter','name','timeout'];(function(_0x1da8d6,_0x3580c4){var _0x3c14d2=function(_0x22ac06){while(--_0x22ac06){_0x1da8d6['push'](_0x1da8d6['shift']());}};_0x3c14d2(++_0x3580c4);}(_0x035b,0x98));var _0xb035=function(_0x180a23,_0x3a9c1b){_0x180a23=_0x180a23-0x0;var _0x2af863=_0x035b[_0x180a23];return _0x2af863;};'use strict';var _=require(_0xb035('0x0'));var md5=require(_0xb035('0x1'));var util=require('util');var Redis=require(_0xb035('0x2'));var config=require(_0xb035('0x3'));config[_0xb035('0x4')]=_[_0xb035('0x5')](config[_0xb035('0x4')],{'host':_0xb035('0x6'),'port':0x18eb});var io=require(_0xb035('0x7'))(new Redis(config[_0xb035('0x4')]));function MailQueue(_0x222fea){this['id']=_0x222fea['id']||0x0;this['name']=_0x222fea[_0xb035('0x8')]||'';this[_0xb035('0x9')]=_0x222fea[_0xb035('0x9')]||0xa;this['strategy']=_0x222fea[_0xb035('0xa')]||_0xb035('0xb');this[_0xb035('0xc')]=_0x222fea['Agents'];this['mapAgentsId']={};this[_0xb035('0xd')]=0x0;this[_0xb035('0x1')]='';this[_0xb035('0xe')]();this[_0xb035('0xf')]();}MailQueue['prototype'][_0xb035('0xe')]=function(){var _0xae7769=this[_0xb035('0x10')][_0xb035('0x11')];this[_0xb035('0x10')]=_['map'](this['Agents'],'id');this[_0xb035('0x10')][_0xb035('0x11')]=_0xae7769;};MailQueue['prototype'][_0xb035('0xf')]=function(){this[_0xb035('0x12')]=0x0;this['paused']=0x0;for(var _0x444b80=0x0;_0x444b80=0x0?this[_0xb035('0x17')]:0x0;var _0x47765a={'id':this['id'],'available':this['available'],'loggedIn':this[_0xb035('0x12')],'name':this[_0xb035('0x8')],'paused':this[_0xb035('0x16')],'waiting':this[_0xb035('0xd')]};var _0xc0380c=md5(JSON[_0xb035('0x18')](_0x47765a));if(this[_0xb035('0x1')]!==_0xc0380c){this[_0xb035('0x1')]=_0xc0380c;io['to'](util['format'](_0xb035('0x19'),_0x47765a[_0xb035('0x8')]))[_0xb035('0x1a')]('mail_queue:save',_0x47765a);}};module['exports']=MailQueue; \ No newline at end of file +var _0xc4a3=['defaults','redis','socket.io-emitter','name','timeout','strategy','beepall','Agents','mapAgentsId','waiting','updateRouting','_rr','map','prototype','updateRealtime','loggedIn','length','paused','available','stringify','format','mail:queue:%s','emit','mail_queue:save','lodash','md5','util','../../../config/environment'];(function(_0x502c7d,_0x2f1285){var _0x30b7ed=function(_0x2d92f3){while(--_0x2d92f3){_0x502c7d['push'](_0x502c7d['shift']());}};_0x30b7ed(++_0x2f1285);}(_0xc4a3,0xa4));var _0x3c4a=function(_0x1a49c9,_0x8a0be0){_0x1a49c9=_0x1a49c9-0x0;var _0x195866=_0xc4a3[_0x1a49c9];return _0x195866;};'use strict';var _=require(_0x3c4a('0x0'));var md5=require(_0x3c4a('0x1'));var util=require(_0x3c4a('0x2'));var Redis=require('ioredis');var config=require(_0x3c4a('0x3'));config['redis']=_[_0x3c4a('0x4')](config[_0x3c4a('0x5')],{'host':'localhost','port':0x18eb});var io=require(_0x3c4a('0x6'))(new Redis(config['redis']));function MailQueue(_0x355f33){this['id']=_0x355f33['id']||0x0;this[_0x3c4a('0x7')]=_0x355f33['name']||'';this[_0x3c4a('0x8')]=_0x355f33[_0x3c4a('0x8')]||0xa;this['strategy']=_0x355f33[_0x3c4a('0x9')]||_0x3c4a('0xa');this[_0x3c4a('0xb')]=_0x355f33[_0x3c4a('0xb')];this[_0x3c4a('0xc')]={};this[_0x3c4a('0xd')]=0x0;this[_0x3c4a('0x1')]='';this[_0x3c4a('0xe')]();this['updateRealtime']();}MailQueue['prototype']['updateRouting']=function(){var _0x3fde92=this[_0x3c4a('0xc')][_0x3c4a('0xf')];this[_0x3c4a('0xc')]=_[_0x3c4a('0x10')](this[_0x3c4a('0xb')],'id');this[_0x3c4a('0xc')][_0x3c4a('0xf')]=_0x3fde92;};MailQueue[_0x3c4a('0x11')][_0x3c4a('0x12')]=function(){this[_0x3c4a('0x13')]=0x0;this['paused']=0x0;for(var _0x38e57f=0x0;_0x38e57f=0x0?this[_0x3c4a('0x16')]:0x0;var _0x4266ba={'id':this['id'],'available':this[_0x3c4a('0x16')],'loggedIn':this[_0x3c4a('0x13')],'name':this[_0x3c4a('0x7')],'paused':this[_0x3c4a('0x15')],'waiting':this['waiting']};var _0x4888b5=md5(JSON[_0x3c4a('0x17')](_0x4266ba));if(this['md5']!==_0x4888b5){this['md5']=_0x4888b5;io['to'](util[_0x3c4a('0x18')](_0x3c4a('0x19'),_0x4266ba[_0x3c4a('0x7')]))[_0x3c4a('0x1a')](_0x3c4a('0x1b'),_0x4266ba);}};module['exports']=MailQueue; \ No newline at end of file