server/services/routing/server/applications/queue.js

   1 // *************************************************************************
   2 // *                                                                       *
   3 // * xCALLY Motion -  The Omnichannel Contact Center                       *
   4 // * Copyright (c) Xenialab s.r.l. All Rights Reserved                     *
   5 // *                                                                       *
   6 // *************************************************************************
   7 // *                                                                       *
   8 // * Email: info@xcally.com                                                *
   9 // * Website: https://www.xcally.com                                       *
  10 // *                                                                       *
  11 // *************************************************************************
  12 // *                                                                       *
  13 // * The SOFTWARE PRODUCT is protected by copyright laws and international *
  14 // * copyright treaties, as well as other intellectual property laws and   *
  15 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                         *
  16 // *                                                                       *
  17 // *************************************************************************
  18 var _0xe5d0=['queue_id','queue','joinAt','emit','account','push','InteractionId','pick','format','%sQueuesWaitingInteractions','%s_queue_waiting_interaction:%s','../../rpc/openchannelQueueReport','../../rpc/mailQueueReport','../../rpc/faxQueueReport','../../rpc/chatInteraction','../../rpc/faxInteraction','../../rpc/mailInteraction','../../rpc/smsInteraction','../../rpc/whatsappInteraction','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','body','YYYY-MM-DD\x20HH:mm:ss','contact','list','upperFirst','channel','QueueId','interaction','MessageId','message','chat','AccountId','info','[%s][START:QUEUE][NAME:%s]','name','QueueReport','create','catch','error','create\x20queue\x20report','waiting','accepted','[%s][STOP:QUEUE][NAME:%s]','Interaction','then','update','update\x20queue\x20report','timeout','[%s][END:QUEUE][NAME:%s]','toLowerCase','validate','length','[%s][QUEUE]\x20%s','map','join','stop','find','Queues','createQueue','atimeout','qtimeout','end','[%s][QUEUE]\x20ROUTING\x20STOPPED','close','rules','complete','[%s][QUEUE]\x20APPLICATION\x20END','next','rrmemory','beepall','stack','lodash','util','moment','ioredis','../../../../config/environment','../../../../config/logger','routing','./strategy','defaults','redis','localhost'];(function(_0x57834a,_0xfac574){var _0x5788d9=function(_0x290392){while(--_0x290392){_0x57834a['push'](_0x57834a['shift']());}};_0x5788d9(++_0xfac574);}(_0xe5d0,0x19e));var _0x0e5d=function(_0x49eed8,_0x9aa73c){_0x49eed8=_0x49eed8-0x0;var _0x1b2667=_0xe5d0[_0x49eed8];return _0x1b2667;};'use strict';var schema=require('validate');var _=require(_0x0e5d('0x0'));var util=require(_0x0e5d('0x1'));var seqqueue=require('seq-queue');var moment=require(_0x0e5d('0x2'));var Redis=require(_0x0e5d('0x3'));var config=require(_0x0e5d('0x4'));var logger=require(_0x0e5d('0x5'))(_0x0e5d('0x6'));var strategy=require(_0x0e5d('0x7'));config['redis']=_[_0x0e5d('0x8')](config[_0x0e5d('0x9')],{'host':_0x0e5d('0xa'),'port':0x18eb});var io=require('socket.io-emitter')(new Redis(config[_0x0e5d('0x9')]));var attributes=['id',_0x0e5d('0xb'),'account',_0x0e5d('0xc'),'from',_0x0e5d('0xd')];function emit(_0x359e04,_0x2f6ff1,_0x271a58){io['to'](_0x359e04)[_0x0e5d('0xe')](_0x2f6ff1,_0x271a58);}function emitChannelQueueInteraction(_0x27612d,_0x1f4aef,_0xea4cf8,_0x5504ff,_0x108147,_0x363a93,_0x31d044,_0x5c45eb){var _0x23f491=_['clone'](_0xea4cf8);_0x23f491[_0x0e5d('0xb')]=_0x5c45eb;_0x23f491[_0x0e5d('0xc')]=_0x1f4aef;_0x23f491[_0x0e5d('0xf')]=_0x5504ff;_0x23f491['id']=_0x108147;if(_0x363a93){attributes[_0x0e5d('0x10')](_['capitalize'](_0x27612d)+_0x0e5d('0x11'));_0x31d044[util['format']('%sQueuesWaitingInteractions',_0x27612d)][_0x108147]=_[_0x0e5d('0x12')](_0x23f491,attributes);}else{delete _0x31d044[util[_0x0e5d('0x13')](_0x0e5d('0x14'),_0x27612d)][_0x108147];}emit(util['format']('%s:queue:%s',_0x27612d,_0x1f4aef),util[_0x0e5d('0x13')](_0x0e5d('0x15'),_0x27612d,_0x363a93?'save':'remove'),_[_0x0e5d('0x12')](_0x23f491,attributes));}var rpc={'openchannelQueueReport':require(_0x0e5d('0x16')),'mailQueueReport':require(_0x0e5d('0x17')),'chatQueueReport':require('../../rpc/chatQueueReport'),'smsQueueReport':require('../../rpc/smsQueueReport'),'faxQueueReport':require(_0x0e5d('0x18')),'whatsappQueueReport':require('../../rpc/whatsappQueueReport'),'chatInteraction':require(_0x0e5d('0x19')),'faxInteraction':require(_0x0e5d('0x1a')),'mailInteraction':require(_0x0e5d('0x1b')),'openchannelInteraction':require('../../rpc/openchannelInteraction'),'smsInteraction':require(_0x0e5d('0x1c')),'whatsappInteraction':require(_0x0e5d('0x1d'))};var queue=schema({'name':{'type':_0x0e5d('0x1e'),'required':!![],'message':_0x0e5d('0x1f')},'timeout':{'type':_0x0e5d('0x20'),'message':_0x0e5d('0x21')}});function startRouting(_0x5c2c73,_0x4c9ae6,_0x5a3760,_0x2ed63c){if(_0x5c2c73&&_0x4c9ae6&&_0x5a3760){_0x4c9ae6['waiting']+=0x1;var _0x404c0d={'uniqueid':_0x5c2c73,'from':_0x5a3760[_0x0e5d('0x22')]?_0x5a3760[_0x0e5d('0x22')]['from']:'','joinAt':moment()[_0x0e5d('0x13')](_0x0e5d('0x23')),'ContactId':_0x5a3760[_0x0e5d('0x24')]?_0x5a3760[_0x0e5d('0x24')]['id']:null,'ListId':_0x5a3760['list']?_0x5a3760[_0x0e5d('0x25')]['id']:null};_0x404c0d[_[_0x0e5d('0x26')](_0x5a3760[_0x0e5d('0x27')])+_0x0e5d('0x28')]=_0x4c9ae6['id']||null;_0x404c0d[_[_0x0e5d('0x26')](_0x5a3760['channel'])+'InteractionId']=_0x5a3760[_0x0e5d('0x29')]?_0x5a3760[_0x0e5d('0x29')]['id']:null;_0x404c0d[_[_0x0e5d('0x26')](_0x5a3760['channel'])+_0x0e5d('0x2a')]=_0x5a3760[_0x0e5d('0x2b')]?_0x5a3760['message']['id']:null;_0x404c0d[_[_0x0e5d('0x26')](_0x5a3760[_0x0e5d('0x27')])+(_0x5a3760['channel']!==_0x0e5d('0x2c')?_0x0e5d('0x2d'):'WebsiteId')]=_0x5a3760[_0x0e5d('0xf')]?_0x5a3760['account']['id']:null;logger[_0x0e5d('0x2e')](util[_0x0e5d('0x13')](_0x0e5d('0x2f'),_0x5c2c73,_0x4c9ae6[_0x0e5d('0x30')]));emitChannelQueueInteraction(_0x5a3760[_0x0e5d('0x27')],_0x4c9ae6['name'],_0x404c0d,_0x5a3760[_0x0e5d('0xf')][_0x0e5d('0x30')],_0x5a3760[_0x0e5d('0x2b')]['id'],!![],_0x2ed63c,_0x4c9ae6['id']);if(rpc[_0x5a3760['channel']+_0x0e5d('0x31')]){return rpc[_0x5a3760[_0x0e5d('0x27')]+_0x0e5d('0x31')][_0x0e5d('0x32')](_0x404c0d)[_0x0e5d('0x33')](function(_0x2290ff){logger[_0x0e5d('0x34')](_0x0e5d('0x35'),_0x2290ff);});}}}function stopRouting(_0x589113,_0x40400e,_0x404db8,_0x1a0c9a){if(_0x589113&&_0x40400e){_0x40400e[_0x0e5d('0x36')]-=0x1;var _0x482d7d={'leaveAt':moment()[_0x0e5d('0x13')](_0x0e5d('0x23')),'acceptAt':moment()[_0x0e5d('0x13')](_0x0e5d('0x23')),'reason':_0x0e5d('0x37')};logger[_0x0e5d('0x2e')](util[_0x0e5d('0x13')](_0x0e5d('0x38'),_0x589113,_0x40400e[_0x0e5d('0x30')]));emitChannelQueueInteraction(_0x404db8[_0x0e5d('0x27')],_0x40400e[_0x0e5d('0x30')],_0x404db8[_0x0e5d('0x22')],_0x404db8[_0x0e5d('0xf')][_0x0e5d('0x30')],_0x404db8[_0x0e5d('0x2b')]['id'],![],_0x1a0c9a,_0x40400e['id']);return rpc[_0x404db8[_0x0e5d('0x27')]+_0x0e5d('0x39')]['update'](_0x404db8[_0x0e5d('0x29')]['id'],{'queueId':_0x40400e['id']})[_0x0e5d('0x3a')](function(){if(rpc[_0x404db8['channel']+_0x0e5d('0x31')]){return rpc[_0x404db8[_0x0e5d('0x27')]+_0x0e5d('0x31')][_0x0e5d('0x3b')](_0x589113,_0x482d7d)[_0x0e5d('0x33')](function(_0x53eb35){logger[_0x0e5d('0x34')](_0x0e5d('0x3c'),_0x53eb35);});}});}}function endRouting(_0xdb9974,_0x3fc3b,_0x40ea9c,_0x2948c4){if(_0xdb9974&&_0x3fc3b){_0x3fc3b[_0x0e5d('0x36')]-=0x1;var _0xadd1e3={'leaveAt':moment()[_0x0e5d('0x13')](_0x0e5d('0x23')),'exitAt':moment()['format']('YYYY-MM-DD\x20HH:mm:ss'),'reason':_0x0e5d('0x3d')};logger['info'](util['format'](_0x0e5d('0x3e'),_0xdb9974,_0x3fc3b[_0x0e5d('0x30')]));emitChannelQueueInteraction(_0x40ea9c[_0x0e5d('0x27')],_0x3fc3b[_0x0e5d('0x30')],_0x40ea9c['body'],_0x40ea9c[_0x0e5d('0xf')][_0x0e5d('0x30')],_0x40ea9c['message']['id'],![],_0x2948c4);if(rpc[_0x40ea9c['channel']+_0x0e5d('0x31')]){return rpc[_0x40ea9c[_0x0e5d('0x27')]+_0x0e5d('0x31')][_0x0e5d('0x3b')](_0xdb9974,_0xadd1e3)[_0x0e5d('0x33')](function(_0x262734){logger[_0x0e5d('0x34')](_0x0e5d('0x3c'),_0x262734);});}}}function handleFindQueue(_0x37b544){return function(_0x58d524){return _0x58d524[_0x0e5d('0x30')][_0x0e5d('0x3f')]()===_0x37b544[_0x0e5d('0x3f')]();};}exports['consequence']=function(_0x418f2a,_0x30d699,_0x58f689,_0xcdec19){return function(_0x325fd1){try{var _0x930820={'name':_0x30d699[0x0],'timeout':_0x30d699[0x1]};var _0x339f08=queue[_0x0e5d('0x40')](_0x930820,{'typecast':!![]});if(_0x339f08[_0x0e5d('0x41')]){logger[_0x0e5d('0x34')](_0x0e5d('0x42'),_0x418f2a,_[_0x0e5d('0x43')](_0x339f08,'message')[_0x0e5d('0x44')](',\x20'));_0x325fd1[_0x0e5d('0x45')]();}else{var _0x317e0d=_[_0x0e5d('0x46')](_0x58f689[_0xcdec19[_0x0e5d('0x27')]+_0x0e5d('0x47')],handleFindQueue(_0x930820['name']));if(_0x317e0d){startRouting(_0x418f2a,_0x317e0d,_0xcdec19,_0x58f689);var _0x34ba40=(_0x317e0d[_0x0e5d('0x3d')]||0xa)*0x3e8;var _0x46b992=(_0x930820[_0x0e5d('0x3d')]||0x14)*0x3e8;var _0xa63146;if(_0x34ba40>_0x46b992){_0x46b992=_0x34ba40;}var _0x946c46=seqqueue[_0x0e5d('0x48')](_0x34ba40);_0x946c46['id']=_0x418f2a;_0x946c46[_0x0e5d('0x49')]=_0x34ba40;_0x946c46[_0x0e5d('0x4a')]=_0x46b992;_0x946c46[_0x0e5d('0x27')]=_0xcdec19[_0x0e5d('0x27')];_0x58f689['rules'][_0x418f2a]['on'](_0x0e5d('0x4b'),function(){logger['info'](_0x0e5d('0x4c'),_0x418f2a);stopRouting(_0x418f2a,_0x317e0d,_0xcdec19,_0x58f689);clearTimeout(_0xa63146);_0xa63146=undefined;_0x946c46[_0x0e5d('0x4d')](!![]);if(_0x58f689[_0x0e5d('0x4e')][_0x418f2a]){delete _0x58f689[_0x0e5d('0x4e')][_0x418f2a];}_0x325fd1[_0x0e5d('0x45')]();});_0x58f689[_0x0e5d('0x4e')][_0x418f2a]['on'](_0x0e5d('0x4f'),function(){if(_0x58f689[_0x0e5d('0x4e')][_0x418f2a]){delete _0x58f689['rules'][_0x418f2a];}});_0xa63146=setTimeout(function(){logger[_0x0e5d('0x2e')](_0x0e5d('0x50'),_0x418f2a);endRouting(_0x418f2a,_0x317e0d,_0xcdec19,_0x58f689);clearTimeout(_0xa63146);_0x946c46[_0x0e5d('0x4d')](!![]);_0x325fd1[_0x0e5d('0x51')]();},_0x46b992);switch(_0x317e0d['strategy']){case _0x0e5d('0x52'):strategy['rrmemory'](_0x946c46,_0x317e0d,_0x58f689,_0xcdec19);break;default:strategy[_0x0e5d('0x53')](_0x946c46,_0x317e0d,_0x58f689,_0xcdec19);}}else{logger[_0x0e5d('0x34')]('[%s][QUEUE]\x20queue\x20not\x20found\x20%s',_0x418f2a,_0x930820[_0x0e5d('0x30')]);_0x325fd1[_0x0e5d('0x45')]();}}}catch(_0x15be9a){logger[_0x0e5d('0x34')]('[%s][QUEUE]\x20%s',_0x418f2a,_0x15be9a[_0x0e5d('0x54')]);_0x325fd1[_0x0e5d('0x45')]();}};};