Built motion from commit f74363e9.|2.6.34
[motion2.git] / server / components / interaction / accept-message.js
index d09dc94..3357b4c 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0xd709=['AcceptMessage','acceptMessage','sendRoutingAcceptEvent','newinteraction','opened','sendInteractionOpenedEvent','../../mysqldb','../../errors/api','APINotFoundError','../../config/logger','api','client','http','request','then','info','request\x20sent','debug','error','code','%s,\x20%s,\x20%s','message','result','catch','read','readAt','format','YYYY-MM-DD\x20HH:mm:ss','UserId','getAcceptParams','capitalize','Message','findOne','Message\x20with\x20id\x20','\x20not\x20found','update','get','updateMessageById','Interaction','Interaction\x20with\x20id\x20','updateInteractionById','SELECT\x20*\x20FROM\x20cm_contacts\x20WHERE\x20id\x20=\x20','sequelize','query','QueryTypes','SELECT','length','Contact\x20with\x20id\x20','findContactById','User','fullname','email','internal','findAgentById','chat','ChatInteractionId','fax','mail','MailInteractionId','openchannel','OpenchannelInteractionId','sms','SmsInteractionId','min','col','isNewInteraction','assign','parse','interaction','formData','EventManager'];(function(_0x321bb2,_0x202794){var _0x9c12ed=function(_0x263dd3){while(--_0x263dd3){_0x321bb2['push'](_0x321bb2['shift']());}};_0x9c12ed(++_0x202794);}(_0xd709,0x1b0));var _0x9d70=function(_0x2f6e44,_0x64c11){_0x2f6e44=_0x2f6e44-0x0;var _0x1b912e=_0xd709[_0x2f6e44];return _0x1b912e;};'use strict';var _=require('lodash');var moment=require('moment');var jayson=require('jayson/promise');var db=require(_0x9d70('0x0'))['db'];var APINotFoundError=require(_0x9d70('0x1'))[_0x9d70('0x2')];var logger=require(_0x9d70('0x3'))(_0x9d70('0x4'));var rpcAmiClient=jayson[_0x9d70('0x5')]['http']({'port':0x232a});var rpcRoutingClient=jayson['client'][_0x9d70('0x6')]({'port':0x232c});function respondWithRpcPromise(_0x56f6ff,_0x283ba8,_0x2d3b21,_0x37c90f,_0x16c5da){return new Promise(function(_0x1faa48,_0x305c80){return _0x16c5da[_0x9d70('0x7')](_0x283ba8,_0x37c90f)[_0x9d70('0x8')](function(_0x489a9f){logger[_0x9d70('0x9')]('%s,\x20%s,\x20%s',_0x56f6ff,_0x2d3b21,_0x9d70('0xa'));logger[_0x9d70('0xb')]('%s,\x20%s,\x20%s,\x20%s',_0x56f6ff,_0x2d3b21,_0x9d70('0xa'),JSON['stringify'](_0x489a9f));if(_0x489a9f['error']){if(_0x489a9f[_0x9d70('0xc')][_0x9d70('0xd')]===0x1f4){logger[_0x9d70('0xc')](_0x9d70('0xe'),_0x56f6ff,_0x2d3b21,_0x489a9f[_0x9d70('0xc')][_0x9d70('0xf')]);return _0x305c80(_0x489a9f[_0x9d70('0xc')][_0x9d70('0xf')]);}logger[_0x9d70('0xc')](_0x9d70('0xe'),_0x56f6ff,_0x2d3b21,_0x489a9f[_0x9d70('0xc')][_0x9d70('0xf')]);return _0x1faa48(_0x489a9f[_0x9d70('0xc')][_0x9d70('0xf')]);}else{logger[_0x9d70('0x9')](_0x9d70('0xe'),_0x56f6ff,_0x2d3b21,_0x9d70('0xa'));_0x1faa48(_0x489a9f[_0x9d70('0x10')]['message']);}})[_0x9d70('0x11')](function(_0x2af5b3){logger[_0x9d70('0xc')](_0x9d70('0xe'),_0x56f6ff,_0x2d3b21,_0x2af5b3);_0x305c80(_0x2af5b3);});});}function getAcceptParams(_0x29ff4b){var _0x58ea54=_0x29ff4b['params']['id'];var _0x400c92=_0x29ff4b['body'];delete _0x400c92['id'];var _0x3b6980=_0x29ff4b['user']['get']({'plain':!![]});_0x400c92[_0x9d70('0x12')]=!![];_0x400c92[_0x9d70('0x13')]=moment()[_0x9d70('0x14')](_0x9d70('0x15'));_0x400c92[_0x9d70('0x16')]=_0x400c92[_0x9d70('0x16')]||_0x3b6980['id'];return{'messageId':_0x58ea54,'payload':_0x400c92,'user':_0x3b6980};}exports[_0x9d70('0x17')]=getAcceptParams;function updateMessageById(_0x3286e8,_0xa26d75,_0x3e1993){var _0x1fc8ae=_[_0x9d70('0x18')](_0x3286e8)+_0x9d70('0x19');return db[_0x1fc8ae][_0x9d70('0x1a')]({'where':{'id':_0xa26d75,'UserId':null}})[_0x9d70('0x8')](function(_0xac17ea){if(!_0xac17ea){throw new APINotFoundError(_0x9d70('0x1b')+_0xa26d75+_0x9d70('0x1c'));}return _0xac17ea[_0x9d70('0x1d')](_0x3e1993);})['then'](function(_0x90d37f){return _0x90d37f[_0x9d70('0x1e')]({'plain':!![]});});}exports[_0x9d70('0x1f')]=updateMessageById;function updateInteractionById(_0x2dff68,_0x5f2495,_0x4eb6e5){var _0x175d88=_[_0x9d70('0x18')](_0x2dff68)+_0x9d70('0x20');return db[_0x175d88]['findOne']({'where':{'id':_0x5f2495}})['then'](function(_0x1c7291){if(!_0x1c7291){throw new APINotFoundError(_0x9d70('0x21')+_0x5f2495+_0x9d70('0x1c'));}var _0x313925=_0x1c7291['read1stAt']||moment()[_0x9d70('0x14')](_0x9d70('0x15'));return _0x1c7291[_0x9d70('0x1d')]({'UserId':_0x4eb6e5,'read1stAt':_0x313925});})[_0x9d70('0x8')](function(_0x439fae){return _0x439fae['get']({'plain':!![]});});}exports[_0x9d70('0x22')]=updateInteractionById;function findContactById(_0x192103){var _0x2da948=_0x9d70('0x23')+_0x192103;return db[_0x9d70('0x24')][_0x9d70('0x25')](_0x2da948,{'type':db['sequelize'][_0x9d70('0x26')][_0x9d70('0x27')],'raw':!![]})['then'](function(_0x4d204f){if(_0x4d204f[_0x9d70('0x28')]===0x0){throw new APINotFoundError(_0x9d70('0x29')+_0x192103+_0x9d70('0x1c'));}return _0x4d204f[0x0];});}exports[_0x9d70('0x2a')]=findContactById;function findAgentById(_0x4e498c){return db[_0x9d70('0x2b')][_0x9d70('0x1a')]({'where':{'id':_0x4e498c,'role':'agent'},'attributes':['id','name',_0x9d70('0x2c'),_0x9d70('0x2d'),_0x9d70('0x2e')],'raw':!![]});}exports[_0x9d70('0x2f')]=findAgentById;function isNewInteraction(_0x45e6d9,_0x5c7d43,_0x36c16a){var _0x1b3922=_[_0x9d70('0x18')](_0x45e6d9)+_0x9d70('0x19');var _0x309aa0={};switch(_0x45e6d9){case _0x9d70('0x30'):_0x309aa0[_0x9d70('0x31')]=_0x5c7d43;break;case _0x9d70('0x32'):_0x309aa0['FaxInteractionId']=_0x5c7d43;break;case _0x9d70('0x33'):_0x309aa0[_0x9d70('0x34')]=_0x5c7d43;break;case _0x9d70('0x35'):_0x309aa0[_0x9d70('0x36')]=_0x5c7d43;break;case _0x9d70('0x37'):_0x309aa0[_0x9d70('0x38')]=_0x5c7d43;break;case'whatsapp':_0x309aa0['WhatsappInteractionId']=_0x5c7d43;break;}return db[_0x1b3922]['findOne']({'where':_0x309aa0,'attributes':[[db[_0x9d70('0x24')]['fn'](_0x9d70('0x39'),db[_0x9d70('0x24')][_0x9d70('0x3a')]('id')),'id']],'raw':!![]})[_0x9d70('0x8')](function(_0x203029){return _0x36c16a===_0x203029['id'];});}exports[_0x9d70('0x3b')]=isNewInteraction;function sendAmiAcceptEvent(_0x2fbb11,_0x421d50){var _0x2adace=_['capitalize'](_0x2fbb11)+_0x9d70('0x19');var _0x324f7c=_0x421d50['message'];if(_0x2fbb11===_0x9d70('0x30')){Object[_0x9d70('0x3c')](_0x324f7c,JSON[_0x9d70('0x3d')](_0x421d50[_0x9d70('0x3e')][_0x9d70('0x3f')]));}return respondWithRpcPromise(_0x2adace,_0x9d70('0x40'),'EventManager',{'event':'acceptmessage','message':_0x324f7c},rpcAmiClient);}exports['sendAmiAcceptEvent']=sendAmiAcceptEvent;function sendRoutingAcceptEvent(_0x2f6a3e,_0x4ffb3d){var _0x11186d=_[_0x9d70('0x18')](_0x2f6a3e)+'Message';return respondWithRpcPromise(_0x11186d,_0x9d70('0x41'),_0x9d70('0x42'),_0x4ffb3d,rpcRoutingClient);}exports[_0x9d70('0x43')]=sendRoutingAcceptEvent;function sendInteractionOpenedEvent(_0x5d4cad,_0x3ded0a){var _0x42e8bd=_['capitalize'](_0x5d4cad)+_0x9d70('0x19');return respondWithRpcPromise(_0x42e8bd,_0x9d70('0x40'),_0x9d70('0x40'),{'event':_0x9d70('0x44'),'message':Object['assign']({},_0x3ded0a,{'event':_0x9d70('0x45')})},rpcAmiClient);}exports[_0x9d70('0x46')]=sendInteractionOpenedEvent;
\ No newline at end of file
+var _0x2c73=['mail','MailInteractionId','openchannel','sms','SmsInteractionId','WhatsappInteractionId','min','col','isNewInteraction','assign','parse','interaction','formData','EventManager','acceptmessage','sendAmiAcceptEvent','acceptMessage','newinteraction','opened','sendInteractionOpenedEvent','moment','jayson/promise','../../mysqldb','APINotFoundError','api','client','http','request','then','info','%s,\x20%s,\x20%s','request\x20sent','debug','%s,\x20%s,\x20%s,\x20%s','stringify','error','code','message','result','catch','params','body','user','get','read','readAt','format','YYYY-MM-DD\x20HH:mm:ss','getAcceptParams','capitalize','Message','Message\x20with\x20id\x20','\x20not\x20found','update','updateMessageById','Interaction','findOne','Interaction\x20with\x20id\x20','read1stAt','updateInteractionById','SELECT\x20*\x20FROM\x20cm_contacts\x20WHERE\x20id\x20=\x20','sequelize','query','QueryTypes','SELECT','length','Contact\x20with\x20id\x20','findContactById','User','agent','name','fullname','email','findAgentById','chat','FaxInteractionId'];(function(_0x45735b,_0x15bf2f){var _0x1c7553=function(_0x2e9713){while(--_0x2e9713){_0x45735b['push'](_0x45735b['shift']());}};_0x1c7553(++_0x15bf2f);}(_0x2c73,0xac));var _0x32c7=function(_0x31e15e,_0x23c377){_0x31e15e=_0x31e15e-0x0;var _0x1aea0d=_0x2c73[_0x31e15e];return _0x1aea0d;};'use strict';var _=require('lodash');var moment=require(_0x32c7('0x0'));var jayson=require(_0x32c7('0x1'));var db=require(_0x32c7('0x2'))['db'];var APINotFoundError=require('../../errors/api')[_0x32c7('0x3')];var logger=require('../../config/logger')(_0x32c7('0x4'));var rpcAmiClient=jayson[_0x32c7('0x5')][_0x32c7('0x6')]({'port':0x232a});var rpcRoutingClient=jayson[_0x32c7('0x5')]['http']({'port':0x232c});function respondWithRpcPromise(_0x4956d2,_0x2ad87b,_0x505933,_0x1f4589,_0x52b736){return new Promise(function(_0xd2cca0,_0x3fed8a){return _0x52b736[_0x32c7('0x7')](_0x2ad87b,_0x1f4589)[_0x32c7('0x8')](function(_0x3d7156){logger[_0x32c7('0x9')](_0x32c7('0xa'),_0x4956d2,_0x505933,_0x32c7('0xb'));logger[_0x32c7('0xc')](_0x32c7('0xd'),_0x4956d2,_0x505933,_0x32c7('0xb'),JSON[_0x32c7('0xe')](_0x3d7156));if(_0x3d7156[_0x32c7('0xf')]){if(_0x3d7156[_0x32c7('0xf')][_0x32c7('0x10')]===0x1f4){logger[_0x32c7('0xf')](_0x32c7('0xa'),_0x4956d2,_0x505933,_0x3d7156[_0x32c7('0xf')][_0x32c7('0x11')]);return _0x3fed8a(_0x3d7156[_0x32c7('0xf')][_0x32c7('0x11')]);}logger['error'](_0x32c7('0xa'),_0x4956d2,_0x505933,_0x3d7156['error'][_0x32c7('0x11')]);return _0xd2cca0(_0x3d7156[_0x32c7('0xf')]['message']);}else{logger[_0x32c7('0x9')]('%s,\x20%s,\x20%s',_0x4956d2,_0x505933,'request\x20sent');_0xd2cca0(_0x3d7156[_0x32c7('0x12')][_0x32c7('0x11')]);}})[_0x32c7('0x13')](function(_0x490a82){logger[_0x32c7('0xf')](_0x32c7('0xa'),_0x4956d2,_0x505933,_0x490a82);_0x3fed8a(_0x490a82);});});}function getAcceptParams(_0x1dea1b){var _0x5d0069=_0x1dea1b[_0x32c7('0x14')]['id'];var _0x18c6c0=_0x1dea1b[_0x32c7('0x15')];delete _0x18c6c0['id'];var _0x272b9d=_0x1dea1b[_0x32c7('0x16')][_0x32c7('0x17')]({'plain':!![]});_0x18c6c0[_0x32c7('0x18')]=!![];_0x18c6c0[_0x32c7('0x19')]=moment()[_0x32c7('0x1a')](_0x32c7('0x1b'));_0x18c6c0['UserId']=_0x18c6c0['UserId']||_0x272b9d['id'];return{'messageId':_0x5d0069,'payload':_0x18c6c0,'user':_0x272b9d};}exports[_0x32c7('0x1c')]=getAcceptParams;function updateMessageById(_0x1ba0b1,_0x44afef,_0x2c9ea3){var _0x51b206=_[_0x32c7('0x1d')](_0x1ba0b1)+_0x32c7('0x1e');return db[_0x51b206]['findOne']({'where':{'id':_0x44afef,'UserId':null}})['then'](function(_0x4fa71d){if(!_0x4fa71d){throw new APINotFoundError(_0x32c7('0x1f')+_0x44afef+_0x32c7('0x20'));}return _0x4fa71d[_0x32c7('0x21')](_0x2c9ea3);})[_0x32c7('0x8')](function(_0x2858d1){return _0x2858d1[_0x32c7('0x17')]({'plain':!![]});});}exports[_0x32c7('0x22')]=updateMessageById;function updateInteractionById(_0xea555a,_0x57aaa7,_0x5884da){var _0x31fac6=_[_0x32c7('0x1d')](_0xea555a)+_0x32c7('0x23');return db[_0x31fac6][_0x32c7('0x24')]({'where':{'id':_0x57aaa7}})['then'](function(_0x3c8faa){if(!_0x3c8faa){throw new APINotFoundError(_0x32c7('0x25')+_0x57aaa7+_0x32c7('0x20'));}var _0x5de5bf=_0x3c8faa[_0x32c7('0x26')]||moment()[_0x32c7('0x1a')]('YYYY-MM-DD\x20HH:mm:ss');return _0x3c8faa[_0x32c7('0x21')]({'UserId':_0x5884da,'read1stAt':_0x5de5bf});})[_0x32c7('0x8')](function(_0x593a9a){return _0x593a9a[_0x32c7('0x17')]({'plain':!![]});});}exports[_0x32c7('0x27')]=updateInteractionById;function findContactById(_0x3d3f97){var _0x380734=_0x32c7('0x28')+_0x3d3f97;return db[_0x32c7('0x29')][_0x32c7('0x2a')](_0x380734,{'type':db[_0x32c7('0x29')][_0x32c7('0x2b')][_0x32c7('0x2c')],'raw':!![]})[_0x32c7('0x8')](function(_0x4135f8){if(_0x4135f8[_0x32c7('0x2d')]===0x0){throw new APINotFoundError(_0x32c7('0x2e')+_0x3d3f97+_0x32c7('0x20'));}return _0x4135f8[0x0];});}exports[_0x32c7('0x2f')]=findContactById;function findAgentById(_0xcddd24){return db[_0x32c7('0x30')][_0x32c7('0x24')]({'where':{'id':_0xcddd24,'role':_0x32c7('0x31')},'attributes':['id',_0x32c7('0x32'),_0x32c7('0x33'),_0x32c7('0x34'),'internal'],'raw':!![]});}exports[_0x32c7('0x35')]=findAgentById;function isNewInteraction(_0x354c93,_0x18881f,_0x3b7f7c){var _0x116749=_[_0x32c7('0x1d')](_0x354c93)+'Message';var _0x4dab9b={};switch(_0x354c93){case _0x32c7('0x36'):_0x4dab9b['ChatInteractionId']=_0x18881f;break;case'fax':_0x4dab9b[_0x32c7('0x37')]=_0x18881f;break;case _0x32c7('0x38'):_0x4dab9b[_0x32c7('0x39')]=_0x18881f;break;case _0x32c7('0x3a'):_0x4dab9b['OpenchannelInteractionId']=_0x18881f;break;case _0x32c7('0x3b'):_0x4dab9b[_0x32c7('0x3c')]=_0x18881f;break;case'whatsapp':_0x4dab9b[_0x32c7('0x3d')]=_0x18881f;break;}return db[_0x116749][_0x32c7('0x24')]({'where':_0x4dab9b,'attributes':[[db[_0x32c7('0x29')]['fn'](_0x32c7('0x3e'),db[_0x32c7('0x29')][_0x32c7('0x3f')]('id')),'id']],'raw':!![]})[_0x32c7('0x8')](function(_0x17e8bf){return _0x3b7f7c===_0x17e8bf['id'];});}exports[_0x32c7('0x40')]=isNewInteraction;function sendAmiAcceptEvent(_0x1b8ded,_0x51b53a){var _0x588749=_[_0x32c7('0x1d')](_0x1b8ded)+_0x32c7('0x1e');var _0x363368=_0x51b53a[_0x32c7('0x11')];if(_0x1b8ded===_0x32c7('0x36')){Object[_0x32c7('0x41')](_0x363368,JSON[_0x32c7('0x42')](_0x51b53a[_0x32c7('0x43')][_0x32c7('0x44')]));}return respondWithRpcPromise(_0x588749,'EventManager',_0x32c7('0x45'),{'event':_0x32c7('0x46'),'message':_0x363368},rpcAmiClient);}exports[_0x32c7('0x47')]=sendAmiAcceptEvent;function sendRoutingAcceptEvent(_0x29792a,_0x2ab749){var _0x3059de=_[_0x32c7('0x1d')](_0x29792a)+_0x32c7('0x1e');return respondWithRpcPromise(_0x3059de,'AcceptMessage',_0x32c7('0x48'),_0x2ab749,rpcRoutingClient);}exports['sendRoutingAcceptEvent']=sendRoutingAcceptEvent;function sendInteractionOpenedEvent(_0x321b71,_0x30198d){var _0x10f9e3=_[_0x32c7('0x1d')](_0x321b71)+_0x32c7('0x1e');return respondWithRpcPromise(_0x10f9e3,_0x32c7('0x45'),_0x32c7('0x45'),{'event':_0x32c7('0x49'),'message':Object[_0x32c7('0x41')]({},_0x30198d,{'event':_0x32c7('0x4a')})},rpcAmiClient);}exports[_0x32c7('0x4b')]=sendInteractionOpenedEvent;
\ No newline at end of file