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 _0x24be=['lodash','seq-queue','../../../../config/logger','routing','./strategy','string','timeout\x20is\x20a\x20number','info','format','[%s][AGENT][NAME:%s][STATUS:%s]','name','toLowerCase','consequence','length','error','message','join','stop','find','timeout','createQueue','atimeout','channel','START:%s','[%s][AGENT]\x20ROUTING\x20STOPPED','rules','[%s][AGENT]\x20ROUTING\x20END','close','next','agent','[%s][AGENT]\x20agent\x20not\x20found\x20%s','[%s][QUEUE]\x20%s','stack','validate'];(function(_0x33c280,_0xdc8c66){var _0x9b9da0=function(_0x2ef6e1){while(--_0x2ef6e1){_0x33c280['push'](_0x33c280['shift']());}};_0x9b9da0(++_0xdc8c66);}(_0x24be,0x65));var _0xe24b=function(_0x37bee7,_0x3c9abc){_0x37bee7=_0x37bee7-0x0;var _0x348bf4=_0x24be[_0x37bee7];return _0x348bf4;};'use strict';var schema=require(_0xe24b('0x0'));var _=require(_0xe24b('0x1'));var util=require('util');var seqqueue=require(_0xe24b('0x2'));var logger=require(_0xe24b('0x3'))(_0xe24b('0x4'));var strategy=require(_0xe24b('0x5'));var queue=schema({'name':{'type':_0xe24b('0x6'),'required':!![],'message':'name\x20is\x20a\x20string\x20and\x20it\x20is\x20required'},'timeout':{'type':'number','message':_0xe24b('0x7')}});function writeLog(_0x7a856e,_0x4b1de7,_0x1fe6c0){return logger[_0xe24b('0x8')](util[_0xe24b('0x9')](_0xe24b('0xa'),_0x7a856e,_0x4b1de7[_0xe24b('0xb')],_0x1fe6c0));}function handleFindAgent(_0x3d7b53){return function(_0x33b3ab){return _0x33b3ab['name'][_0xe24b('0xc')]()===_0x3d7b53[_0xe24b('0xc')]();};}exports[_0xe24b('0xd')]=function(_0x56f0de,_0x4198e3,_0x421d98,_0x269f62){return function(_0x57770a){try{var _0x4eaf71={'name':_0x4198e3[0x0],'timeout':_0x4198e3[0x1]};var _0x70a0a1=queue[_0xe24b('0x0')](_0x4eaf71,{'typecast':!![]});if(_0x70a0a1[_0xe24b('0xe')]){logger[_0xe24b('0xf')]('[%s][AGENT]\x20%s',_0x56f0de,_['map'](_0x70a0a1,_0xe24b('0x10'))[_0xe24b('0x11')](',\x20'));_0x57770a[_0xe24b('0x12')]();}else{var _0x17bbb8=_[_0xe24b('0x13')](_0x421d98['agents'],handleFindAgent(_0x4eaf71['name']));if(_0x17bbb8){var _0x338f5b=(_0x4eaf71[_0xe24b('0x14')]||0xa)*0x3e8;var _0x3755e8,_0x429e00;var _0x2f63a8=seqqueue[_0xe24b('0x15')](_0x338f5b);_0x2f63a8['id']=_0x56f0de;_0x2f63a8[_0xe24b('0x16')]=_0x338f5b;_0x2f63a8[_0xe24b('0x17')]=_0x269f62['channel'];writeLog(_0x56f0de,_0x17bbb8,util[_0xe24b('0x9')](_0xe24b('0x18'),_0x338f5b));_0x421d98['rules'][_0x56f0de]['on']('end',function(){logger[_0xe24b('0x8')](_0xe24b('0x19'),_0x56f0de);clearTimeout(_0x429e00);_0x429e00=undefined;_0x2f63a8['close']();if(_0x421d98[_0xe24b('0x1a')][_0x56f0de]){delete _0x421d98[_0xe24b('0x1a')][_0x56f0de];}_0x57770a[_0xe24b('0x12')]();});_0x421d98[_0xe24b('0x1a')][_0x56f0de]['on']('complete',function(){if(_0x421d98['rules'][_0x56f0de]){delete _0x421d98['rules'][_0x56f0de];}});_0x429e00=setTimeout(function(){logger[_0xe24b('0x8')](_0xe24b('0x1b'),_0x56f0de);clearTimeout(_0x429e00);_0x2f63a8[_0xe24b('0x1c')]();_0x57770a[_0xe24b('0x1d')]();},_0x338f5b);strategy[_0xe24b('0x1e')](_0x2f63a8,_0x17bbb8,_0x421d98,_0x269f62);}else{logger[_0xe24b('0xf')](_0xe24b('0x1f'),_0x56f0de,_0x4eaf71[_0xe24b('0xb')]);_0x57770a[_0xe24b('0x12')]();}}}catch(_0x4195da){console['log'](_0x4195da);logger['error'](_0xe24b('0x20'),_0x56f0de,_0x4195da[_0xe24b('0x21')]);_0x57770a[_0xe24b('0x12')]();}};};