server/services/routing/server/applications/agent.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 _0x5288=['consequence','length','error','map','message','join','stop','find','timeout','createQueue','atimeout','channel','format','rules','end','[%s][AGENT]\x20ROUTING\x20STOPPED','close','complete','[%s][AGENT]\x20ROUTING\x20END','next','[%s][AGENT]\x20agent\x20not\x20found\x20%s','log','[%s][QUEUE]\x20%s','stack','validate','lodash','util','seq-queue','routing','./strategy','string','name\x20is\x20a\x20string\x20and\x20it\x20is\x20required','number','timeout\x20is\x20a\x20number','info','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase'];(function(_0x287de0,_0x582703){var _0x22e4f1=function(_0x5a8c07){while(--_0x5a8c07){_0x287de0['push'](_0x287de0['shift']());}};_0x22e4f1(++_0x582703);}(_0x5288,0x64));var _0x8528=function(_0x278e3c,_0x1c9cfd){_0x278e3c=_0x278e3c-0x0;var _0x3e2d9b=_0x5288[_0x278e3c];return _0x3e2d9b;};'use strict';var schema=require(_0x8528('0x0'));var _=require(_0x8528('0x1'));var util=require(_0x8528('0x2'));var seqqueue=require(_0x8528('0x3'));var logger=require('../../../../config/logger')(_0x8528('0x4'));var strategy=require(_0x8528('0x5'));var queue=schema({'name':{'type':_0x8528('0x6'),'required':!![],'message':_0x8528('0x7')},'timeout':{'type':_0x8528('0x8'),'message':_0x8528('0x9')}});function writeLog(_0x1fab32,_0x42eae6,_0x395c01){return logger[_0x8528('0xa')](util['format'](_0x8528('0xb'),_0x1fab32,_0x42eae6[_0x8528('0xc')],_0x395c01));}function handleFindAgent(_0x136e1a){return function(_0x3010e4){return _0x3010e4[_0x8528('0xc')][_0x8528('0xd')]()===_0x136e1a['toLowerCase']();};}exports[_0x8528('0xe')]=function(_0x783610,_0x743feb,_0x19bba4,_0x4044b5){return function(_0x16d5e1){try{var _0xc28765={'name':_0x743feb[0x0],'timeout':_0x743feb[0x1]};var _0x2b63e7=queue[_0x8528('0x0')](_0xc28765,{'typecast':!![]});if(_0x2b63e7[_0x8528('0xf')]){logger[_0x8528('0x10')]('[%s][AGENT]\x20%s',_0x783610,_[_0x8528('0x11')](_0x2b63e7,_0x8528('0x12'))[_0x8528('0x13')](',\x20'));_0x16d5e1[_0x8528('0x14')]();}else{var _0x379bfe=_[_0x8528('0x15')](_0x19bba4['agents'],handleFindAgent(_0xc28765[_0x8528('0xc')]));if(_0x379bfe){var _0x3c33ce=(_0xc28765[_0x8528('0x16')]||0xa)*0x3e8;var _0x1a24c6,_0x29ee09;var _0x274591=seqqueue[_0x8528('0x17')](_0x3c33ce);_0x274591['id']=_0x783610;_0x274591[_0x8528('0x18')]=_0x3c33ce;_0x274591[_0x8528('0x19')]=_0x4044b5[_0x8528('0x19')];writeLog(_0x783610,_0x379bfe,util[_0x8528('0x1a')]('START:%s',_0x3c33ce));_0x19bba4[_0x8528('0x1b')][_0x783610]['on'](_0x8528('0x1c'),function(){logger['info'](_0x8528('0x1d'),_0x783610);clearTimeout(_0x29ee09);_0x29ee09=undefined;_0x274591[_0x8528('0x1e')]();if(_0x19bba4[_0x8528('0x1b')][_0x783610]){delete _0x19bba4[_0x8528('0x1b')][_0x783610];}_0x16d5e1['stop']();});_0x19bba4[_0x8528('0x1b')][_0x783610]['on'](_0x8528('0x1f'),function(){if(_0x19bba4[_0x8528('0x1b')][_0x783610]){delete _0x19bba4[_0x8528('0x1b')][_0x783610];}});_0x29ee09=setTimeout(function(){logger[_0x8528('0xa')](_0x8528('0x20'),_0x783610);clearTimeout(_0x29ee09);_0x274591[_0x8528('0x1e')]();_0x16d5e1[_0x8528('0x21')]();},_0x3c33ce);strategy['agent'](_0x274591,_0x379bfe,_0x19bba4,_0x4044b5);}else{logger[_0x8528('0x10')](_0x8528('0x22'),_0x783610,_0xc28765[_0x8528('0xc')]);_0x16d5e1[_0x8528('0x14')]();}}}catch(_0x3d44b6){console[_0x8528('0x23')](_0x3d44b6);logger[_0x8528('0x10')](_0x8528('0x24'),_0x783610,_0x3d44b6[_0x8528('0x25')]);_0x16d5e1[_0x8528('0x14')]();}};};