Built motion from commit 08fb8613.|2.6.31
[motion2.git] / server / components / interaction / accept-message.js
index 6e5b0ad..de9611e 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xdd06=['debug','stringify','error','code','message','info','request\x20sent','result','catch','body','user','get','read','readAt','YYYY-MM-DD\x20HH:mm:ss','UserId','Message','findOne','Message\x20with\x20id\x20','\x20not\x20found','update','updateMessageById','Interaction','Interaction\x20with\x20id\x20','format','SELECT\x20*\x20FROM\x20cm_contacts\x20WHERE\x20id\x20=\x20','sequelize','query','QueryTypes','length','User','name','fullname','email','internal','findAgentById','capitalize','chat','ChatInteractionId','fax','mail','MailInteractionId','openchannel','OpenchannelInteractionId','SmsInteractionId','whatsapp','WhatsappInteractionId','min','col','isNewInteraction','parse','interaction','formData','EventManager','acceptmessage','sendAmiAcceptEvent','AcceptMessage','acceptMessage','assign','opened','lodash','moment','jayson/promise','../../mysqldb','../../errors/api','APINotFoundError','../../config/logger','api','http','client','request','then','%s,\x20%s,\x20%s'];(function(_0x59cd93,_0x53d49b){var _0x1e7de1=function(_0x176c94){while(--_0x176c94){_0x59cd93['push'](_0x59cd93['shift']());}};_0x1e7de1(++_0x53d49b);}(_0xdd06,0x85));var _0x6dd0=function(_0x570b67,_0x5d27d3){_0x570b67=_0x570b67-0x0;var _0x2bb6ce=_0xdd06[_0x570b67];return _0x2bb6ce;};'use strict';var _=require(_0x6dd0('0x0'));var moment=require(_0x6dd0('0x1'));var jayson=require(_0x6dd0('0x2'));var db=require(_0x6dd0('0x3'))['db'];var APINotFoundError=require(_0x6dd0('0x4'))[_0x6dd0('0x5')];var logger=require(_0x6dd0('0x6'))(_0x6dd0('0x7'));var rpcAmiClient=jayson['client'][_0x6dd0('0x8')]({'port':0x232a});var rpcRoutingClient=jayson[_0x6dd0('0x9')]['http']({'port':0x232c});function respondWithRpcPromise(_0x329a91,_0x812a53,_0x389a17,_0x3fb3ab,_0xb2e67f){return new Promise(function(_0x248509,_0x13ef22){return _0xb2e67f[_0x6dd0('0xa')](_0x812a53,_0x3fb3ab)[_0x6dd0('0xb')](function(_0x3fc816){logger['info'](_0x6dd0('0xc'),_0x329a91,_0x389a17,'request\x20sent');logger[_0x6dd0('0xd')]('%s,\x20%s,\x20%s,\x20%s',_0x329a91,_0x389a17,'request\x20sent',JSON[_0x6dd0('0xe')](_0x3fc816));if(_0x3fc816[_0x6dd0('0xf')]){if(_0x3fc816[_0x6dd0('0xf')][_0x6dd0('0x10')]===0x1f4){logger[_0x6dd0('0xf')](_0x6dd0('0xc'),_0x329a91,_0x389a17,_0x3fc816[_0x6dd0('0xf')][_0x6dd0('0x11')]);return _0x13ef22(_0x3fc816[_0x6dd0('0xf')][_0x6dd0('0x11')]);}logger[_0x6dd0('0xf')](_0x6dd0('0xc'),_0x329a91,_0x389a17,_0x3fc816[_0x6dd0('0xf')][_0x6dd0('0x11')]);return _0x248509(_0x3fc816[_0x6dd0('0xf')][_0x6dd0('0x11')]);}else{logger[_0x6dd0('0x12')](_0x6dd0('0xc'),_0x329a91,_0x389a17,_0x6dd0('0x13'));_0x248509(_0x3fc816[_0x6dd0('0x14')][_0x6dd0('0x11')]);}})[_0x6dd0('0x15')](function(_0x938d81){logger['error'](_0x6dd0('0xc'),_0x329a91,_0x389a17,_0x938d81);_0x13ef22(_0x938d81);});});}function getAcceptParams(_0x428fb2){var _0x5b4d3f=_0x428fb2['params']['id'];var _0x446e7e=_0x428fb2[_0x6dd0('0x16')];delete _0x446e7e['id'];var _0x4041ab=_0x428fb2[_0x6dd0('0x17')][_0x6dd0('0x18')]({'plain':!![]});_0x446e7e[_0x6dd0('0x19')]=!![];_0x446e7e[_0x6dd0('0x1a')]=moment()['format'](_0x6dd0('0x1b'));_0x446e7e['UserId']=_0x446e7e[_0x6dd0('0x1c')]||_0x4041ab['id'];return{'messageId':_0x5b4d3f,'payload':_0x446e7e,'user':_0x4041ab};}exports['getAcceptParams']=getAcceptParams;function updateMessageById(_0x147826,_0x472c11,_0x1cc00a){var _0x2a71de=_['capitalize'](_0x147826)+_0x6dd0('0x1d');return db[_0x2a71de][_0x6dd0('0x1e')]({'where':{'id':_0x472c11,'UserId':null}})[_0x6dd0('0xb')](function(_0x226846){if(!_0x226846){throw new APINotFoundError(_0x6dd0('0x1f')+_0x472c11+_0x6dd0('0x20'));}return _0x226846[_0x6dd0('0x21')](_0x1cc00a);})[_0x6dd0('0xb')](function(_0x54e0d7){return _0x54e0d7[_0x6dd0('0x18')]({'plain':!![]});});}exports[_0x6dd0('0x22')]=updateMessageById;function updateInteractionById(_0x1a9ca0,_0x50cb01,_0x542cc5){var _0x3cd35a=_['capitalize'](_0x1a9ca0)+_0x6dd0('0x23');return db[_0x3cd35a]['findOne']({'where':{'id':_0x50cb01}})[_0x6dd0('0xb')](function(_0x4ffa43){if(!_0x4ffa43){throw new APINotFoundError(_0x6dd0('0x24')+_0x50cb01+_0x6dd0('0x20'));}var _0x1ed6b7=_0x4ffa43['read1stAt']||moment()[_0x6dd0('0x25')](_0x6dd0('0x1b'));return _0x4ffa43[_0x6dd0('0x21')]({'UserId':_0x542cc5,'read1stAt':_0x1ed6b7});})[_0x6dd0('0xb')](function(_0x799d7c){return _0x799d7c[_0x6dd0('0x18')]({'plain':!![]});});}exports['updateInteractionById']=updateInteractionById;function findContactById(_0x27eed4){var _0x583d90=_0x6dd0('0x26')+_0x27eed4;return db[_0x6dd0('0x27')][_0x6dd0('0x28')](_0x583d90,{'type':db[_0x6dd0('0x27')][_0x6dd0('0x29')]['SELECT'],'raw':!![]})['then'](function(_0x2ddd47){if(_0x2ddd47[_0x6dd0('0x2a')]===0x0){throw new APINotFoundError('Contact\x20with\x20id\x20'+_0x27eed4+_0x6dd0('0x20'));}return _0x2ddd47[0x0];});}exports['findContactById']=findContactById;function findAgentById(_0x3f10af){return db[_0x6dd0('0x2b')][_0x6dd0('0x1e')]({'where':{'id':_0x3f10af,'role':'agent'},'attributes':['id',_0x6dd0('0x2c'),_0x6dd0('0x2d'),_0x6dd0('0x2e'),_0x6dd0('0x2f')],'raw':!![]});}exports[_0x6dd0('0x30')]=findAgentById;function isNewInteraction(_0x431972,_0x42ae1b,_0x3aec8c){var _0x5dfb36=_[_0x6dd0('0x31')](_0x431972)+'Message';var _0x22c984={};switch(_0x431972){case _0x6dd0('0x32'):_0x22c984[_0x6dd0('0x33')]=_0x42ae1b;break;case _0x6dd0('0x34'):_0x22c984['FaxInteractionId']=_0x42ae1b;break;case _0x6dd0('0x35'):_0x22c984[_0x6dd0('0x36')]=_0x42ae1b;break;case _0x6dd0('0x37'):_0x22c984[_0x6dd0('0x38')]=_0x42ae1b;break;case'sms':_0x22c984[_0x6dd0('0x39')]=_0x42ae1b;break;case _0x6dd0('0x3a'):_0x22c984[_0x6dd0('0x3b')]=_0x42ae1b;break;}return db[_0x5dfb36]['findOne']({'where':_0x22c984,'attributes':[[db[_0x6dd0('0x27')]['fn'](_0x6dd0('0x3c'),db[_0x6dd0('0x27')][_0x6dd0('0x3d')]('id')),'id']],'raw':!![]})[_0x6dd0('0xb')](function(_0x2ce3e0){return _0x3aec8c===_0x2ce3e0['id'];});}exports[_0x6dd0('0x3e')]=isNewInteraction;function sendAmiAcceptEvent(_0x5adddd,_0x55e067){var _0x851301=_[_0x6dd0('0x31')](_0x5adddd)+'Message';var _0x58b650=_0x55e067['message'];if(_0x5adddd===_0x6dd0('0x32')){Object['assign'](_0x58b650,JSON[_0x6dd0('0x3f')](_0x55e067[_0x6dd0('0x40')][_0x6dd0('0x41')]));}return respondWithRpcPromise(_0x851301,_0x6dd0('0x42'),_0x6dd0('0x42'),{'event':_0x6dd0('0x43'),'message':_0x58b650},rpcAmiClient);}exports[_0x6dd0('0x44')]=sendAmiAcceptEvent;function sendRoutingAcceptEvent(_0x50c7c1,_0x2d306d){var _0xcedbf3=_['capitalize'](_0x50c7c1)+'Message';return respondWithRpcPromise(_0xcedbf3,_0x6dd0('0x45'),_0x6dd0('0x46'),_0x2d306d,rpcRoutingClient);}exports['sendRoutingAcceptEvent']=sendRoutingAcceptEvent;function sendInteractionOpenedEvent(_0x23d702,_0x25d9be){var _0x28e881=_[_0x6dd0('0x31')](_0x23d702)+_0x6dd0('0x1d');return respondWithRpcPromise(_0x28e881,_0x6dd0('0x42'),'EventManager',{'event':'newinteraction','message':Object[_0x6dd0('0x47')]({},_0x25d9be,{'event':_0x6dd0('0x48')})},rpcAmiClient);}exports['sendInteractionOpenedEvent']=sendInteractionOpenedEvent;
\ No newline at end of file
+var _0x451e=['length','Contact\x20with\x20id\x20','findContactById','User','findOne','agent','name','internal','chat','fax','mail','MailInteractionId','openchannel','sms','SmsInteractionId','whatsapp','WhatsappInteractionId','min','col','isNewInteraction','parse','interaction','formData','EventManager','sendAmiAcceptEvent','acceptMessage','sendRoutingAcceptEvent','newinteraction','assign','opened','moment','jayson/promise','../../mysqldb','../../errors/api','APINotFoundError','api','http','request','then','info','%s,\x20%s,\x20%s','request\x20sent','debug','%s,\x20%s,\x20%s,\x20%s','stringify','error','message','result','params','body','user','get','read','readAt','format','YYYY-MM-DD\x20HH:mm:ss','UserId','getAcceptParams','capitalize','Message','Message\x20with\x20id\x20','update','updateMessageById','Interaction','Interaction\x20with\x20id\x20','read1stAt','SELECT\x20*\x20FROM\x20cm_contacts\x20WHERE\x20id\x20=\x20','sequelize','query','QueryTypes','SELECT'];(function(_0x417ce7,_0x1e8f2d){var _0x452857=function(_0x2e350b){while(--_0x2e350b){_0x417ce7['push'](_0x417ce7['shift']());}};_0x452857(++_0x1e8f2d);}(_0x451e,0x65));var _0xe451=function(_0x5c03b6,_0x10d437){_0x5c03b6=_0x5c03b6-0x0;var _0x553bb5=_0x451e[_0x5c03b6];return _0x553bb5;};'use strict';var _=require('lodash');var moment=require(_0xe451('0x0'));var jayson=require(_0xe451('0x1'));var db=require(_0xe451('0x2'))['db'];var APINotFoundError=require(_0xe451('0x3'))[_0xe451('0x4')];var logger=require('../../config/logger')(_0xe451('0x5'));var rpcAmiClient=jayson['client'][_0xe451('0x6')]({'port':0x232a});var rpcRoutingClient=jayson['client']['http']({'port':0x232c});function respondWithRpcPromise(_0x16047d,_0x7c2430,_0x33b945,_0x38efe3,_0x454954){return new Promise(function(_0x3e89d2,_0xa267b5){return _0x454954[_0xe451('0x7')](_0x7c2430,_0x38efe3)[_0xe451('0x8')](function(_0x24edde){logger[_0xe451('0x9')](_0xe451('0xa'),_0x16047d,_0x33b945,_0xe451('0xb'));logger[_0xe451('0xc')](_0xe451('0xd'),_0x16047d,_0x33b945,'request\x20sent',JSON[_0xe451('0xe')](_0x24edde));if(_0x24edde[_0xe451('0xf')]){if(_0x24edde[_0xe451('0xf')]['code']===0x1f4){logger[_0xe451('0xf')](_0xe451('0xa'),_0x16047d,_0x33b945,_0x24edde[_0xe451('0xf')]['message']);return _0xa267b5(_0x24edde[_0xe451('0xf')][_0xe451('0x10')]);}logger[_0xe451('0xf')]('%s,\x20%s,\x20%s',_0x16047d,_0x33b945,_0x24edde[_0xe451('0xf')][_0xe451('0x10')]);return _0x3e89d2(_0x24edde[_0xe451('0xf')][_0xe451('0x10')]);}else{logger[_0xe451('0x9')]('%s,\x20%s,\x20%s',_0x16047d,_0x33b945,'request\x20sent');_0x3e89d2(_0x24edde[_0xe451('0x11')][_0xe451('0x10')]);}})['catch'](function(_0x47eda2){logger[_0xe451('0xf')](_0xe451('0xa'),_0x16047d,_0x33b945,_0x47eda2);_0xa267b5(_0x47eda2);});});}function getAcceptParams(_0x5a0a39){var _0x4241ef=_0x5a0a39[_0xe451('0x12')]['id'];var _0x5c9ce4=_0x5a0a39[_0xe451('0x13')];delete _0x5c9ce4['id'];var _0x1afe04=_0x5a0a39[_0xe451('0x14')][_0xe451('0x15')]({'plain':!![]});_0x5c9ce4[_0xe451('0x16')]=!![];_0x5c9ce4[_0xe451('0x17')]=moment()[_0xe451('0x18')](_0xe451('0x19'));_0x5c9ce4[_0xe451('0x1a')]=_0x5c9ce4[_0xe451('0x1a')]||_0x1afe04['id'];return{'messageId':_0x4241ef,'payload':_0x5c9ce4,'user':_0x1afe04};}exports[_0xe451('0x1b')]=getAcceptParams;function updateMessageById(_0x1f63e4,_0x5bfd37,_0x7c8213){var _0x246418=_[_0xe451('0x1c')](_0x1f63e4)+_0xe451('0x1d');return db[_0x246418]['findOne']({'where':{'id':_0x5bfd37,'UserId':null}})['then'](function(_0x189536){if(!_0x189536){throw new APINotFoundError(_0xe451('0x1e')+_0x5bfd37+'\x20not\x20found');}return _0x189536[_0xe451('0x1f')](_0x7c8213);})['then'](function(_0x2e60ef){return _0x2e60ef[_0xe451('0x15')]({'plain':!![]});});}exports[_0xe451('0x20')]=updateMessageById;function updateInteractionById(_0x532d64,_0x547e8c,_0x26d550){var _0x3a7292=_[_0xe451('0x1c')](_0x532d64)+_0xe451('0x21');return db[_0x3a7292]['findOne']({'where':{'id':_0x547e8c}})[_0xe451('0x8')](function(_0x3831a4){if(!_0x3831a4){throw new APINotFoundError(_0xe451('0x22')+_0x547e8c+'\x20not\x20found');}var _0x512487=_0x3831a4[_0xe451('0x23')]||moment()['format'](_0xe451('0x19'));return _0x3831a4[_0xe451('0x1f')]({'UserId':_0x26d550,'read1stAt':_0x512487});})[_0xe451('0x8')](function(_0x42f012){return _0x42f012[_0xe451('0x15')]({'plain':!![]});});}exports['updateInteractionById']=updateInteractionById;function findContactById(_0x19c7c2){var _0x5431f6=_0xe451('0x24')+_0x19c7c2;return db[_0xe451('0x25')][_0xe451('0x26')](_0x5431f6,{'type':db[_0xe451('0x25')][_0xe451('0x27')][_0xe451('0x28')],'raw':!![]})[_0xe451('0x8')](function(_0x3db810){if(_0x3db810[_0xe451('0x29')]===0x0){throw new APINotFoundError(_0xe451('0x2a')+_0x19c7c2+'\x20not\x20found');}return _0x3db810[0x0];});}exports[_0xe451('0x2b')]=findContactById;function findAgentById(_0x59de16){return db[_0xe451('0x2c')][_0xe451('0x2d')]({'where':{'id':_0x59de16,'role':_0xe451('0x2e')},'attributes':['id',_0xe451('0x2f'),'fullname','email',_0xe451('0x30')],'raw':!![]});}exports['findAgentById']=findAgentById;function isNewInteraction(_0x26b68a,_0x647fbf,_0x4f7188){var _0x329433=_[_0xe451('0x1c')](_0x26b68a)+_0xe451('0x1d');var _0x21be6a={};switch(_0x26b68a){case _0xe451('0x31'):_0x21be6a['ChatInteractionId']=_0x647fbf;break;case _0xe451('0x32'):_0x21be6a['FaxInteractionId']=_0x647fbf;break;case _0xe451('0x33'):_0x21be6a[_0xe451('0x34')]=_0x647fbf;break;case _0xe451('0x35'):_0x21be6a['OpenchannelInteractionId']=_0x647fbf;break;case _0xe451('0x36'):_0x21be6a[_0xe451('0x37')]=_0x647fbf;break;case _0xe451('0x38'):_0x21be6a[_0xe451('0x39')]=_0x647fbf;break;}return db[_0x329433][_0xe451('0x2d')]({'where':_0x21be6a,'attributes':[[db[_0xe451('0x25')]['fn'](_0xe451('0x3a'),db[_0xe451('0x25')][_0xe451('0x3b')]('id')),'id']],'raw':!![]})[_0xe451('0x8')](function(_0x10e2d1){return _0x4f7188===_0x10e2d1['id'];});}exports[_0xe451('0x3c')]=isNewInteraction;function sendAmiAcceptEvent(_0x3f74a2,_0x285cdb){var _0x5b80c3=_[_0xe451('0x1c')](_0x3f74a2)+_0xe451('0x1d');var _0x1eda21=_0x285cdb[_0xe451('0x10')];if(_0x3f74a2==='chat'){Object['assign'](_0x1eda21,JSON[_0xe451('0x3d')](_0x285cdb[_0xe451('0x3e')][_0xe451('0x3f')]));}return respondWithRpcPromise(_0x5b80c3,_0xe451('0x40'),_0xe451('0x40'),{'event':'acceptmessage','message':_0x1eda21},rpcAmiClient);}exports[_0xe451('0x41')]=sendAmiAcceptEvent;function sendRoutingAcceptEvent(_0x2e6f7a,_0x43460f){var _0x1dcc97=_[_0xe451('0x1c')](_0x2e6f7a)+_0xe451('0x1d');return respondWithRpcPromise(_0x1dcc97,'AcceptMessage',_0xe451('0x42'),_0x43460f,rpcRoutingClient);}exports[_0xe451('0x43')]=sendRoutingAcceptEvent;function sendInteractionOpenedEvent(_0x325b02,_0x11ac2d){var _0x27784e=_[_0xe451('0x1c')](_0x325b02)+_0xe451('0x1d');return respondWithRpcPromise(_0x27784e,_0xe451('0x40'),'EventManager',{'event':_0xe451('0x44'),'message':Object[_0xe451('0x45')]({},_0x11ac2d,{'event':_0xe451('0x46')})},rpcAmiClient);}exports['sendInteractionOpenedEvent']=sendInteractionOpenedEvent;
\ No newline at end of file