Built motion from commit a8c4dd89.|2.6.33
[motion2.git] / server / components / interaction / accept-message.js
index fd85d43..64787ec 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xc974=['sendAmiAcceptEvent','AcceptMessage','sendRoutingAcceptEvent','newinteraction','opened','jayson/promise','../../mysqldb','../../errors/api','../../config/logger','client','then','info','request\x20sent','debug','%s,\x20%s,\x20%s,\x20%s','error','message','%s,\x20%s,\x20%s','result','catch','params','body','user','get','read','readAt','format','UserId','capitalize','Message','findOne','Message\x20with\x20id\x20','\x20not\x20found','update','updateMessageById','Interaction','Interaction\x20with\x20id\x20','read1stAt','YYYY-MM-DD\x20HH:mm:ss','updateInteractionById','SELECT\x20*\x20FROM\x20cm_contacts\x20WHERE\x20id\x20=\x20','sequelize','SELECT','length','Contact\x20with\x20id\x20','findContactById','User','agent','email','internal','findAgentById','chat','ChatInteractionId','fax','FaxInteractionId','mail','openchannel','OpenchannelInteractionId','sms','whatsapp','WhatsappInteractionId','min','col','isNewInteraction','interaction','formData','EventManager','acceptmessage'];(function(_0x4bcb3c,_0x192122){var _0xfe09bb=function(_0xcd8ad2){while(--_0xcd8ad2){_0x4bcb3c['push'](_0x4bcb3c['shift']());}};_0xfe09bb(++_0x192122);}(_0xc974,0x1e1));var _0x4c97=function(_0xa3699f,_0x1d3aeb){_0xa3699f=_0xa3699f-0x0;var _0x4e8749=_0xc974[_0xa3699f];return _0x4e8749;};'use strict';var _=require('lodash');var moment=require('moment');var jayson=require(_0x4c97('0x0'));var db=require(_0x4c97('0x1'))['db'];var APINotFoundError=require(_0x4c97('0x2'))['APINotFoundError'];var logger=require(_0x4c97('0x3'))('api');var rpcAmiClient=jayson[_0x4c97('0x4')]['http']({'port':0x232a});var rpcRoutingClient=jayson['client']['http']({'port':0x232c});function respondWithRpcPromise(_0x29ffe6,_0x1d21ba,_0x159159,_0x127f70,_0x474f64){return new Promise(function(_0xf32e0f,_0x3b3591){return _0x474f64['request'](_0x1d21ba,_0x127f70)[_0x4c97('0x5')](function(_0x4112f5){logger[_0x4c97('0x6')]('%s,\x20%s,\x20%s',_0x29ffe6,_0x159159,_0x4c97('0x7'));logger[_0x4c97('0x8')](_0x4c97('0x9'),_0x29ffe6,_0x159159,_0x4c97('0x7'),JSON['stringify'](_0x4112f5));if(_0x4112f5[_0x4c97('0xa')]){if(_0x4112f5['error']['code']===0x1f4){logger[_0x4c97('0xa')]('%s,\x20%s,\x20%s',_0x29ffe6,_0x159159,_0x4112f5['error']['message']);return _0x3b3591(_0x4112f5['error'][_0x4c97('0xb')]);}logger['error'](_0x4c97('0xc'),_0x29ffe6,_0x159159,_0x4112f5[_0x4c97('0xa')][_0x4c97('0xb')]);return _0xf32e0f(_0x4112f5[_0x4c97('0xa')][_0x4c97('0xb')]);}else{logger[_0x4c97('0x6')]('%s,\x20%s,\x20%s',_0x29ffe6,_0x159159,_0x4c97('0x7'));_0xf32e0f(_0x4112f5[_0x4c97('0xd')][_0x4c97('0xb')]);}})[_0x4c97('0xe')](function(_0x2cb285){logger[_0x4c97('0xa')](_0x4c97('0xc'),_0x29ffe6,_0x159159,_0x2cb285);_0x3b3591(_0x2cb285);});});}function getAcceptParams(_0x2f13aa){var _0x4aebbb=_0x2f13aa[_0x4c97('0xf')]['id'];var _0x1a85f7=_0x2f13aa[_0x4c97('0x10')];delete _0x1a85f7['id'];var _0xe24d4a=_0x2f13aa[_0x4c97('0x11')][_0x4c97('0x12')]({'plain':!![]});_0x1a85f7[_0x4c97('0x13')]=!![];_0x1a85f7[_0x4c97('0x14')]=moment()[_0x4c97('0x15')]('YYYY-MM-DD\x20HH:mm:ss');_0x1a85f7[_0x4c97('0x16')]=_0x1a85f7['UserId']||_0xe24d4a['id'];return{'messageId':_0x4aebbb,'payload':_0x1a85f7,'user':_0xe24d4a};}exports['getAcceptParams']=getAcceptParams;function updateMessageById(_0x56c341,_0x3cd3b3,_0x292b88){var _0x8852e0=_[_0x4c97('0x17')](_0x56c341)+_0x4c97('0x18');return db[_0x8852e0][_0x4c97('0x19')]({'where':{'id':_0x3cd3b3,'UserId':null}})[_0x4c97('0x5')](function(_0xca9f8f){if(!_0xca9f8f){throw new APINotFoundError(_0x4c97('0x1a')+_0x3cd3b3+_0x4c97('0x1b'));}return _0xca9f8f[_0x4c97('0x1c')](_0x292b88);})[_0x4c97('0x5')](function(_0x34a75b){return _0x34a75b['get']({'plain':!![]});});}exports[_0x4c97('0x1d')]=updateMessageById;function updateInteractionById(_0x481afc,_0x2e8e91,_0x419d10){var _0x418e01=_['capitalize'](_0x481afc)+_0x4c97('0x1e');return db[_0x418e01][_0x4c97('0x19')]({'where':{'id':_0x2e8e91}})[_0x4c97('0x5')](function(_0x4278f0){if(!_0x4278f0){throw new APINotFoundError(_0x4c97('0x1f')+_0x2e8e91+_0x4c97('0x1b'));}var _0x381ade=_0x4278f0[_0x4c97('0x20')]||moment()[_0x4c97('0x15')](_0x4c97('0x21'));return _0x4278f0[_0x4c97('0x1c')]({'UserId':_0x419d10,'read1stAt':_0x381ade});})[_0x4c97('0x5')](function(_0x3a239a){return _0x3a239a['get']({'plain':!![]});});}exports[_0x4c97('0x22')]=updateInteractionById;function findContactById(_0x3b49fd){var _0xbf606b=_0x4c97('0x23')+_0x3b49fd;return db[_0x4c97('0x24')]['query'](_0xbf606b,{'type':db['sequelize']['QueryTypes'][_0x4c97('0x25')],'raw':!![]})[_0x4c97('0x5')](function(_0x1e2c29){if(_0x1e2c29[_0x4c97('0x26')]===0x0){throw new APINotFoundError(_0x4c97('0x27')+_0x3b49fd+_0x4c97('0x1b'));}return _0x1e2c29[0x0];});}exports[_0x4c97('0x28')]=findContactById;function findAgentById(_0x22b2f1){return db[_0x4c97('0x29')]['findOne']({'where':{'id':_0x22b2f1,'role':_0x4c97('0x2a')},'attributes':['id','name','fullname',_0x4c97('0x2b'),_0x4c97('0x2c')],'raw':!![]});}exports[_0x4c97('0x2d')]=findAgentById;function isNewInteraction(_0x24cb25,_0x315cf6,_0x5f0597){var _0x5b9ab1=_[_0x4c97('0x17')](_0x24cb25)+_0x4c97('0x18');var _0x310edf={};switch(_0x24cb25){case _0x4c97('0x2e'):_0x310edf[_0x4c97('0x2f')]=_0x315cf6;break;case _0x4c97('0x30'):_0x310edf[_0x4c97('0x31')]=_0x315cf6;break;case _0x4c97('0x32'):_0x310edf['MailInteractionId']=_0x315cf6;break;case _0x4c97('0x33'):_0x310edf[_0x4c97('0x34')]=_0x315cf6;break;case _0x4c97('0x35'):_0x310edf['SmsInteractionId']=_0x315cf6;break;case _0x4c97('0x36'):_0x310edf[_0x4c97('0x37')]=_0x315cf6;break;}return db[_0x5b9ab1]['findOne']({'where':_0x310edf,'attributes':[[db[_0x4c97('0x24')]['fn'](_0x4c97('0x38'),db[_0x4c97('0x24')][_0x4c97('0x39')]('id')),'id']],'raw':!![]})[_0x4c97('0x5')](function(_0x95cefe){return _0x5f0597===_0x95cefe['id'];});}exports[_0x4c97('0x3a')]=isNewInteraction;function sendAmiAcceptEvent(_0x240fd0,_0x32407c){var _0x42d13d=_[_0x4c97('0x17')](_0x240fd0)+_0x4c97('0x18');var _0x52b7a7=_0x32407c[_0x4c97('0xb')];if(_0x240fd0===_0x4c97('0x2e')){Object['assign'](_0x52b7a7,JSON['parse'](_0x32407c[_0x4c97('0x3b')][_0x4c97('0x3c')]));}return respondWithRpcPromise(_0x42d13d,_0x4c97('0x3d'),'EventManager',{'event':_0x4c97('0x3e'),'message':_0x52b7a7},rpcAmiClient);}exports[_0x4c97('0x3f')]=sendAmiAcceptEvent;function sendRoutingAcceptEvent(_0x595b6d,_0x1420c3){var _0x6dfc61=_['capitalize'](_0x595b6d)+_0x4c97('0x18');return respondWithRpcPromise(_0x6dfc61,_0x4c97('0x40'),'acceptMessage',_0x1420c3,rpcRoutingClient);}exports[_0x4c97('0x41')]=sendRoutingAcceptEvent;function sendInteractionOpenedEvent(_0x5d6419,_0x667974){var _0x592c20=_[_0x4c97('0x17')](_0x5d6419)+'Message';return respondWithRpcPromise(_0x592c20,_0x4c97('0x3d'),_0x4c97('0x3d'),{'event':_0x4c97('0x42'),'message':Object['assign']({},_0x667974,{'event':_0x4c97('0x43')})},rpcAmiClient);}exports['sendInteractionOpenedEvent']=sendInteractionOpenedEvent;
\ No newline at end of file
+var _0x88eb=['get','updateMessageById','Interaction','Interaction\x20with\x20id\x20','read1stAt','YYYY-MM-DD\x20HH:mm:ss','updateInteractionById','SELECT\x20*\x20FROM\x20cm_contacts\x20WHERE\x20id\x20=\x20','sequelize','query','QueryTypes','SELECT','length','Contact\x20with\x20id\x20','findContactById','User','name','ChatInteractionId','mail','MailInteractionId','openchannel','sms','SmsInteractionId','whatsapp','min','col','assign','parse','interaction','formData','EventManager','acceptmessage','sendAmiAcceptEvent','acceptMessage','sendRoutingAcceptEvent','newinteraction','opened','sendInteractionOpenedEvent','lodash','moment','jayson/promise','../../mysqldb','../../errors/api','APINotFoundError','../../config/logger','client','http','request','info','%s,\x20%s,\x20%s','debug','%s,\x20%s,\x20%s,\x20%s','error','code','message','request\x20sent','result','catch','body','user','read','readAt','format','UserId','getAcceptParams','capitalize','Message','findOne','\x20not\x20found','update','then'];(function(_0x3fb863,_0x485182){var _0x120b76=function(_0x209100){while(--_0x209100){_0x3fb863['push'](_0x3fb863['shift']());}};_0x120b76(++_0x485182);}(_0x88eb,0xb4));var _0xb88e=function(_0x3b08b7,_0x22d450){_0x3b08b7=_0x3b08b7-0x0;var _0x224515=_0x88eb[_0x3b08b7];return _0x224515;};'use strict';var _=require(_0xb88e('0x0'));var moment=require(_0xb88e('0x1'));var jayson=require(_0xb88e('0x2'));var db=require(_0xb88e('0x3'))['db'];var APINotFoundError=require(_0xb88e('0x4'))[_0xb88e('0x5')];var logger=require(_0xb88e('0x6'))('api');var rpcAmiClient=jayson[_0xb88e('0x7')][_0xb88e('0x8')]({'port':0x232a});var rpcRoutingClient=jayson[_0xb88e('0x7')]['http']({'port':0x232c});function respondWithRpcPromise(_0x30eb4b,_0x32caa1,_0xf961fc,_0xf0afd6,_0x3f8633){return new Promise(function(_0x1b09e8,_0x30089b){return _0x3f8633[_0xb88e('0x9')](_0x32caa1,_0xf0afd6)['then'](function(_0x480cd1){logger[_0xb88e('0xa')](_0xb88e('0xb'),_0x30eb4b,_0xf961fc,'request\x20sent');logger[_0xb88e('0xc')](_0xb88e('0xd'),_0x30eb4b,_0xf961fc,'request\x20sent',JSON['stringify'](_0x480cd1));if(_0x480cd1['error']){if(_0x480cd1[_0xb88e('0xe')][_0xb88e('0xf')]===0x1f4){logger[_0xb88e('0xe')](_0xb88e('0xb'),_0x30eb4b,_0xf961fc,_0x480cd1['error'][_0xb88e('0x10')]);return _0x30089b(_0x480cd1['error'][_0xb88e('0x10')]);}logger[_0xb88e('0xe')](_0xb88e('0xb'),_0x30eb4b,_0xf961fc,_0x480cd1[_0xb88e('0xe')]['message']);return _0x1b09e8(_0x480cd1['error'][_0xb88e('0x10')]);}else{logger[_0xb88e('0xa')](_0xb88e('0xb'),_0x30eb4b,_0xf961fc,_0xb88e('0x11'));_0x1b09e8(_0x480cd1[_0xb88e('0x12')][_0xb88e('0x10')]);}})[_0xb88e('0x13')](function(_0x13c9c2){logger[_0xb88e('0xe')](_0xb88e('0xb'),_0x30eb4b,_0xf961fc,_0x13c9c2);_0x30089b(_0x13c9c2);});});}function getAcceptParams(_0x4bca7c){var _0x176177=_0x4bca7c['params']['id'];var _0x29fd4a=_0x4bca7c[_0xb88e('0x14')];delete _0x29fd4a['id'];var _0x94b330=_0x4bca7c[_0xb88e('0x15')]['get']({'plain':!![]});_0x29fd4a[_0xb88e('0x16')]=!![];_0x29fd4a[_0xb88e('0x17')]=moment()[_0xb88e('0x18')]('YYYY-MM-DD\x20HH:mm:ss');_0x29fd4a[_0xb88e('0x19')]=_0x29fd4a[_0xb88e('0x19')]||_0x94b330['id'];return{'messageId':_0x176177,'payload':_0x29fd4a,'user':_0x94b330};}exports[_0xb88e('0x1a')]=getAcceptParams;function updateMessageById(_0x4d1b43,_0x51579c,_0xea2bdf){var _0x386822=_[_0xb88e('0x1b')](_0x4d1b43)+_0xb88e('0x1c');return db[_0x386822][_0xb88e('0x1d')]({'where':{'id':_0x51579c,'UserId':null}})['then'](function(_0x4e8b06){if(!_0x4e8b06){throw new APINotFoundError('Message\x20with\x20id\x20'+_0x51579c+_0xb88e('0x1e'));}return _0x4e8b06[_0xb88e('0x1f')](_0xea2bdf);})[_0xb88e('0x20')](function(_0x53542e){return _0x53542e[_0xb88e('0x21')]({'plain':!![]});});}exports[_0xb88e('0x22')]=updateMessageById;function updateInteractionById(_0x30c46b,_0x274da0,_0x50a17b){var _0x243163=_[_0xb88e('0x1b')](_0x30c46b)+_0xb88e('0x23');return db[_0x243163][_0xb88e('0x1d')]({'where':{'id':_0x274da0}})[_0xb88e('0x20')](function(_0x3c1dc9){if(!_0x3c1dc9){throw new APINotFoundError(_0xb88e('0x24')+_0x274da0+_0xb88e('0x1e'));}var _0x470045=_0x3c1dc9[_0xb88e('0x25')]||moment()[_0xb88e('0x18')](_0xb88e('0x26'));return _0x3c1dc9[_0xb88e('0x1f')]({'UserId':_0x50a17b,'read1stAt':_0x470045});})[_0xb88e('0x20')](function(_0x28381d){return _0x28381d[_0xb88e('0x21')]({'plain':!![]});});}exports[_0xb88e('0x27')]=updateInteractionById;function findContactById(_0x2b2c63){var _0x1f1e6d=_0xb88e('0x28')+_0x2b2c63;return db[_0xb88e('0x29')][_0xb88e('0x2a')](_0x1f1e6d,{'type':db['sequelize'][_0xb88e('0x2b')][_0xb88e('0x2c')],'raw':!![]})[_0xb88e('0x20')](function(_0x4616f2){if(_0x4616f2[_0xb88e('0x2d')]===0x0){throw new APINotFoundError(_0xb88e('0x2e')+_0x2b2c63+_0xb88e('0x1e'));}return _0x4616f2[0x0];});}exports[_0xb88e('0x2f')]=findContactById;function findAgentById(_0x54dcbc){return db[_0xb88e('0x30')][_0xb88e('0x1d')]({'where':{'id':_0x54dcbc,'role':'agent'},'attributes':['id',_0xb88e('0x31'),'fullname','email','internal'],'raw':!![]});}exports['findAgentById']=findAgentById;function isNewInteraction(_0x311810,_0x7a8b43,_0x235379){var _0x4e33ea=_[_0xb88e('0x1b')](_0x311810)+_0xb88e('0x1c');var _0x277d30={};switch(_0x311810){case'chat':_0x277d30[_0xb88e('0x32')]=_0x7a8b43;break;case'fax':_0x277d30['FaxInteractionId']=_0x7a8b43;break;case _0xb88e('0x33'):_0x277d30[_0xb88e('0x34')]=_0x7a8b43;break;case _0xb88e('0x35'):_0x277d30['OpenchannelInteractionId']=_0x7a8b43;break;case _0xb88e('0x36'):_0x277d30[_0xb88e('0x37')]=_0x7a8b43;break;case _0xb88e('0x38'):_0x277d30['WhatsappInteractionId']=_0x7a8b43;break;}return db[_0x4e33ea][_0xb88e('0x1d')]({'where':_0x277d30,'attributes':[[db[_0xb88e('0x29')]['fn'](_0xb88e('0x39'),db[_0xb88e('0x29')][_0xb88e('0x3a')]('id')),'id']],'raw':!![]})[_0xb88e('0x20')](function(_0x52b38b){return _0x235379===_0x52b38b['id'];});}exports['isNewInteraction']=isNewInteraction;function sendAmiAcceptEvent(_0x1b2b37,_0x9f3809){var _0x847b46=_[_0xb88e('0x1b')](_0x1b2b37)+_0xb88e('0x1c');var _0x4bd9b9=_0x9f3809[_0xb88e('0x10')];if(_0x1b2b37==='chat'){Object[_0xb88e('0x3b')](_0x4bd9b9,JSON[_0xb88e('0x3c')](_0x9f3809[_0xb88e('0x3d')][_0xb88e('0x3e')]));}return respondWithRpcPromise(_0x847b46,_0xb88e('0x3f'),_0xb88e('0x3f'),{'event':_0xb88e('0x40'),'message':_0x4bd9b9},rpcAmiClient);}exports[_0xb88e('0x41')]=sendAmiAcceptEvent;function sendRoutingAcceptEvent(_0x1b28de,_0x1de9d8){var _0x5b1c41=_['capitalize'](_0x1b28de)+_0xb88e('0x1c');return respondWithRpcPromise(_0x5b1c41,'AcceptMessage',_0xb88e('0x42'),_0x1de9d8,rpcRoutingClient);}exports[_0xb88e('0x43')]=sendRoutingAcceptEvent;function sendInteractionOpenedEvent(_0x3e8078,_0xbf54e7){var _0x442f34=_['capitalize'](_0x3e8078)+_0xb88e('0x1c');return respondWithRpcPromise(_0x442f34,'EventManager',_0xb88e('0x3f'),{'event':_0xb88e('0x44'),'message':Object[_0xb88e('0x3b')]({},_0xbf54e7,{'event':_0xb88e('0x45')})},rpcAmiClient);}exports[_0xb88e('0x46')]=sendInteractionOpenedEvent;
\ No newline at end of file