// * treaties. The SOFTWARE PRODUCT is licensed, not sold. *
// * *
// *************************************************************************
-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
+var _0xc5f8=['client','request','info','request\x20sent','stringify','error','%s,\x20%s,\x20%s','message','result','catch','user','get','readAt','format','YYYY-MM-DD\x20HH:mm:ss','UserId','getAcceptParams','capitalize','then','Message\x20with\x20id\x20','\x20not\x20found','update','updateMessageById','findOne','Interaction\x20with\x20id\x20','read1stAt','updateInteractionById','query','SELECT','length','Contact\x20with\x20id\x20','findContactById','User','name','email','findAgentById','Message','chat','ChatInteractionId','fax','FaxInteractionId','mail','MailInteractionId','openchannel','OpenchannelInteractionId','sms','SmsInteractionId','whatsapp','WhatsappInteractionId','sequelize','min','isNewInteraction','parse','interaction','formData','EventManager','sendAmiAcceptEvent','AcceptMessage','acceptMessage','sendRoutingAcceptEvent','newinteraction','assign','opened','sendInteractionOpenedEvent','lodash','moment','jayson/promise','APINotFoundError','../../config/logger','api','http'];(function(_0x11e7b5,_0x43842b){var _0x16b415=function(_0x391d44){while(--_0x391d44){_0x11e7b5['push'](_0x11e7b5['shift']());}};_0x16b415(++_0x43842b);}(_0xc5f8,0x115));var _0x8c5f=function(_0x3dd15e,_0x1f0015){_0x3dd15e=_0x3dd15e-0x0;var _0x231fd0=_0xc5f8[_0x3dd15e];return _0x231fd0;};'use strict';var _=require(_0x8c5f('0x0'));var moment=require(_0x8c5f('0x1'));var jayson=require(_0x8c5f('0x2'));var db=require('../../mysqldb')['db'];var APINotFoundError=require('../../errors/api')[_0x8c5f('0x3')];var logger=require(_0x8c5f('0x4'))(_0x8c5f('0x5'));var rpcAmiClient=jayson['client'][_0x8c5f('0x6')]({'port':0x232a});var rpcRoutingClient=jayson[_0x8c5f('0x7')][_0x8c5f('0x6')]({'port':0x232c});function respondWithRpcPromise(_0x481fc7,_0x166903,_0x1111a8,_0xf704d8,_0x565410){return new Promise(function(_0x50404a,_0x4cb359){return _0x565410[_0x8c5f('0x8')](_0x166903,_0xf704d8)['then'](function(_0x554703){logger[_0x8c5f('0x9')]('%s,\x20%s,\x20%s',_0x481fc7,_0x1111a8,_0x8c5f('0xa'));logger['debug']('%s,\x20%s,\x20%s,\x20%s',_0x481fc7,_0x1111a8,'request\x20sent',JSON[_0x8c5f('0xb')](_0x554703));if(_0x554703['error']){if(_0x554703[_0x8c5f('0xc')]['code']===0x1f4){logger[_0x8c5f('0xc')](_0x8c5f('0xd'),_0x481fc7,_0x1111a8,_0x554703[_0x8c5f('0xc')][_0x8c5f('0xe')]);return _0x4cb359(_0x554703['error'][_0x8c5f('0xe')]);}logger[_0x8c5f('0xc')]('%s,\x20%s,\x20%s',_0x481fc7,_0x1111a8,_0x554703['error'][_0x8c5f('0xe')]);return _0x50404a(_0x554703[_0x8c5f('0xc')][_0x8c5f('0xe')]);}else{logger['info'](_0x8c5f('0xd'),_0x481fc7,_0x1111a8,_0x8c5f('0xa'));_0x50404a(_0x554703[_0x8c5f('0xf')][_0x8c5f('0xe')]);}})[_0x8c5f('0x10')](function(_0x3dfb54){logger[_0x8c5f('0xc')](_0x8c5f('0xd'),_0x481fc7,_0x1111a8,_0x3dfb54);_0x4cb359(_0x3dfb54);});});}function getAcceptParams(_0x7976ac){var _0x283bb1=_0x7976ac['params']['id'];var _0x281296=_0x7976ac['body'];delete _0x281296['id'];var _0x1b1ab1=_0x7976ac[_0x8c5f('0x11')][_0x8c5f('0x12')]({'plain':!![]});_0x281296['read']=!![];_0x281296[_0x8c5f('0x13')]=moment()[_0x8c5f('0x14')](_0x8c5f('0x15'));_0x281296[_0x8c5f('0x16')]=_0x281296['UserId']||_0x1b1ab1['id'];return{'messageId':_0x283bb1,'payload':_0x281296,'user':_0x1b1ab1};}exports[_0x8c5f('0x17')]=getAcceptParams;function updateMessageById(_0x36c214,_0x526d53,_0x5e35e6){var _0x3b3ec2=_[_0x8c5f('0x18')](_0x36c214)+'Message';return db[_0x3b3ec2]['findOne']({'where':{'id':_0x526d53,'UserId':null}})[_0x8c5f('0x19')](function(_0x46ce20){if(!_0x46ce20){throw new APINotFoundError(_0x8c5f('0x1a')+_0x526d53+_0x8c5f('0x1b'));}return _0x46ce20[_0x8c5f('0x1c')](_0x5e35e6);})[_0x8c5f('0x19')](function(_0x2a541e){return _0x2a541e['get']({'plain':!![]});});}exports[_0x8c5f('0x1d')]=updateMessageById;function updateInteractionById(_0x8ede84,_0xfa31ed,_0xe39db9){var _0x374264=_[_0x8c5f('0x18')](_0x8ede84)+'Interaction';return db[_0x374264][_0x8c5f('0x1e')]({'where':{'id':_0xfa31ed}})[_0x8c5f('0x19')](function(_0xb65ac4){if(!_0xb65ac4){throw new APINotFoundError(_0x8c5f('0x1f')+_0xfa31ed+'\x20not\x20found');}var _0x331735=_0xb65ac4[_0x8c5f('0x20')]||moment()[_0x8c5f('0x14')](_0x8c5f('0x15'));return _0xb65ac4['update']({'UserId':_0xe39db9,'read1stAt':_0x331735});})[_0x8c5f('0x19')](function(_0x2a3abe){return _0x2a3abe['get']({'plain':!![]});});}exports[_0x8c5f('0x21')]=updateInteractionById;function findContactById(_0x3af116){var _0x1a88ba='SELECT\x20*\x20FROM\x20cm_contacts\x20WHERE\x20id\x20=\x20'+_0x3af116;return db['sequelize'][_0x8c5f('0x22')](_0x1a88ba,{'type':db['sequelize']['QueryTypes'][_0x8c5f('0x23')],'raw':!![]})['then'](function(_0x5ba21c){if(_0x5ba21c[_0x8c5f('0x24')]===0x0){throw new APINotFoundError(_0x8c5f('0x25')+_0x3af116+_0x8c5f('0x1b'));}return _0x5ba21c[0x0];});}exports[_0x8c5f('0x26')]=findContactById;function findAgentById(_0x5a2ca6){return db[_0x8c5f('0x27')]['findOne']({'where':{'id':_0x5a2ca6,'role':'agent'},'attributes':['id',_0x8c5f('0x28'),'fullname',_0x8c5f('0x29'),'internal'],'raw':!![]});}exports[_0x8c5f('0x2a')]=findAgentById;function isNewInteraction(_0x46ecd9,_0x4dd2e4,_0x594a8c){var _0xd2cb77=_[_0x8c5f('0x18')](_0x46ecd9)+_0x8c5f('0x2b');var _0x51d6e5={};switch(_0x46ecd9){case _0x8c5f('0x2c'):_0x51d6e5[_0x8c5f('0x2d')]=_0x4dd2e4;break;case _0x8c5f('0x2e'):_0x51d6e5[_0x8c5f('0x2f')]=_0x4dd2e4;break;case _0x8c5f('0x30'):_0x51d6e5[_0x8c5f('0x31')]=_0x4dd2e4;break;case _0x8c5f('0x32'):_0x51d6e5[_0x8c5f('0x33')]=_0x4dd2e4;break;case _0x8c5f('0x34'):_0x51d6e5[_0x8c5f('0x35')]=_0x4dd2e4;break;case _0x8c5f('0x36'):_0x51d6e5[_0x8c5f('0x37')]=_0x4dd2e4;break;}return db[_0xd2cb77][_0x8c5f('0x1e')]({'where':_0x51d6e5,'attributes':[[db[_0x8c5f('0x38')]['fn'](_0x8c5f('0x39'),db[_0x8c5f('0x38')]['col']('id')),'id']],'raw':!![]})[_0x8c5f('0x19')](function(_0x57ff35){return _0x594a8c===_0x57ff35['id'];});}exports[_0x8c5f('0x3a')]=isNewInteraction;function sendAmiAcceptEvent(_0x3bcb79,_0x55f263){var _0x43d965=_[_0x8c5f('0x18')](_0x3bcb79)+_0x8c5f('0x2b');var _0x557758=_0x55f263['message'];if(_0x3bcb79==='chat'){Object['assign'](_0x557758,JSON[_0x8c5f('0x3b')](_0x55f263[_0x8c5f('0x3c')][_0x8c5f('0x3d')]));}return respondWithRpcPromise(_0x43d965,'EventManager',_0x8c5f('0x3e'),{'event':'acceptmessage','message':_0x557758},rpcAmiClient);}exports[_0x8c5f('0x3f')]=sendAmiAcceptEvent;function sendRoutingAcceptEvent(_0x11a2f1,_0x1fc8a1){var _0x323121=_[_0x8c5f('0x18')](_0x11a2f1)+'Message';return respondWithRpcPromise(_0x323121,_0x8c5f('0x40'),_0x8c5f('0x41'),_0x1fc8a1,rpcRoutingClient);}exports[_0x8c5f('0x42')]=sendRoutingAcceptEvent;function sendInteractionOpenedEvent(_0x2eb297,_0x38572d){var _0xfede95=_['capitalize'](_0x2eb297)+'Message';return respondWithRpcPromise(_0xfede95,_0x8c5f('0x3e'),_0x8c5f('0x3e'),{'event':_0x8c5f('0x43'),'message':Object[_0x8c5f('0x44')]({},_0x38572d,{'event':_0x8c5f('0x45')})},rpcAmiClient);}exports[_0x8c5f('0x46')]=sendInteractionOpenedEvent;
\ No newline at end of file
git://repos.xcallymotion.com / motion2.git / blobdiff