server/api/smsQueue/smsQueue.rpc.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 _0x7fba=['raw','where','attributes','include','map','model','ShowSmsQueue','lodash','util','moment','bluebird','randomstring','ioredis','../../config/utils','../../config/logger','../../config/environment','client','http','defaults','redis','localhost','./smsQueue.socket','register','request','then','info','SmsQueue,\x20%s,\x20%s','debug','request\x20sent','stringify','error','message','result','catch','GetSmsQueue','SmsQueue','findAll','options'];(function(_0x290c34,_0x3758e6){var _0x383db3=function(_0x504c74){while(--_0x504c74){_0x290c34['push'](_0x290c34['shift']());}};_0x383db3(++_0x3758e6);}(_0x7fba,0x137));var _0xa7fb=function(_0x278380,_0x42ffbb){_0x278380=_0x278380-0x0;var _0x145f90=_0x7fba[_0x278380];return _0x145f90;};'use strict';var _=require(_0xa7fb('0x0'));var util=require(_0xa7fb('0x1'));var moment=require(_0xa7fb('0x2'));var BPromise=require(_0xa7fb('0x3'));var rs=require(_0xa7fb('0x4'));var fs=require('fs');var Redis=require(_0xa7fb('0x5'));var db=require('../../mysqldb')['db'];var utils=require(_0xa7fb('0x6'));var logger=require(_0xa7fb('0x7'))('rpc');var config=require(_0xa7fb('0x8'));var jayson=require('jayson/promise');var client=jayson[_0xa7fb('0x9')][_0xa7fb('0xa')]({'port':0x232a});config['redis']=_[_0xa7fb('0xb')](config[_0xa7fb('0xc')],{'host':_0xa7fb('0xd'),'port':0x18eb});var socket=require('socket.io-emitter')(new Redis(config[_0xa7fb('0xc')]));require(_0xa7fb('0xe'))[_0xa7fb('0xf')](socket);function respondWithRpcPromise(_0x5001d0,_0x4206d8,_0x4b5723){return new BPromise(function(_0x76fe1e,_0x309e81){return client[_0xa7fb('0x10')](_0x5001d0,_0x4b5723)[_0xa7fb('0x11')](function(_0x173f26){logger[_0xa7fb('0x12')](_0xa7fb('0x13'),_0x4206d8,'request\x20sent');logger[_0xa7fb('0x14')]('SmsQueue,\x20%s,\x20%s,\x20%s',_0x4206d8,_0xa7fb('0x15'),JSON[_0xa7fb('0x16')](_0x173f26));if(_0x173f26[_0xa7fb('0x17')]){if(_0x173f26[_0xa7fb('0x17')]['code']===0x1f4){logger['error'](_0xa7fb('0x13'),_0x4206d8,_0x173f26[_0xa7fb('0x17')][_0xa7fb('0x18')]);return _0x309e81(_0x173f26[_0xa7fb('0x17')][_0xa7fb('0x18')]);}logger[_0xa7fb('0x17')](_0xa7fb('0x13'),_0x4206d8,_0x173f26[_0xa7fb('0x17')]['message']);return _0x76fe1e(_0x173f26[_0xa7fb('0x17')][_0xa7fb('0x18')]);}else{logger[_0xa7fb('0x12')](_0xa7fb('0x13'),_0x4206d8,_0xa7fb('0x15'));_0x76fe1e(_0x173f26[_0xa7fb('0x19')][_0xa7fb('0x18')]);}})[_0xa7fb('0x1a')](function(_0x74efb2){logger[_0xa7fb('0x17')]('SmsQueue,\x20%s,\x20%s',_0x4206d8,_0x74efb2);_0x309e81(_0x74efb2);});});}exports[_0xa7fb('0x1b')]=function(_0x11b336){var _0x454023=this;return new Promise(function(_0x5def8a,_0x54d17d){return db[_0xa7fb('0x1c')][_0xa7fb('0x1d')]({'raw':_0x11b336[_0xa7fb('0x1e')]?_0x11b336['options'][_0xa7fb('0x1f')]===undefined?!![]:![]:!![],'where':_0x11b336['options']?_0x11b336[_0xa7fb('0x1e')][_0xa7fb('0x20')]||null:null,'attributes':_0x11b336[_0xa7fb('0x1e')]?_0x11b336['options'][_0xa7fb('0x21')]||null:null,'limit':_0x11b336[_0xa7fb('0x1e')]?_0x11b336[_0xa7fb('0x1e')]['limit']||null:null,'include':_0x11b336['options']?_0x11b336['options'][_0xa7fb('0x22')]?_[_0xa7fb('0x23')](_0x11b336[_0xa7fb('0x1e')][_0xa7fb('0x22')],function(_0x1a7f3c){return{'model':db[_0x1a7f3c[_0xa7fb('0x24')]],'as':_0x1a7f3c['as'],'attributes':_0x1a7f3c[_0xa7fb('0x21')],'include':_0x1a7f3c[_0xa7fb('0x22')]?_['map'](_0x1a7f3c[_0xa7fb('0x22')],function(_0x249285){return{'model':db[_0x249285[_0xa7fb('0x24')]],'as':_0x249285['as'],'attributes':_0x249285['attributes'],'include':_0x249285[_0xa7fb('0x22')]?_[_0xa7fb('0x23')](_0x249285[_0xa7fb('0x22')],function(_0x347463){return{'model':db[_0x347463[_0xa7fb('0x24')]],'as':_0x347463['as'],'attributes':_0x347463['attributes']};}):[]};}):[]};}):[]:[]})['then'](function(_0x4a4fa1){logger[_0xa7fb('0x12')](_0xa7fb('0x1b'),_0x11b336);logger['debug']('GetSmsQueue',_0x11b336,JSON[_0xa7fb('0x16')](_0x4a4fa1));_0x5def8a(_0x4a4fa1);})[_0xa7fb('0x1a')](function(_0xc0d362){logger['error']('GetSmsQueue',_0xc0d362[_0xa7fb('0x18')],_0x11b336);_0x54d17d(_0x454023['error'](0x1f4,_0xc0d362['message']));});});};exports[_0xa7fb('0x25')]=function(_0x4c3863){var _0x5d8176=this;return new Promise(function(_0x2522de,_0x1780a8){return db[_0xa7fb('0x1c')]['find']({'raw':_0x4c3863['options']?_0x4c3863['options'][_0xa7fb('0x1f')]===undefined?!![]:![]:!![],'where':_0x4c3863[_0xa7fb('0x1e')]?_0x4c3863[_0xa7fb('0x1e')]['where']||null:null,'attributes':_0x4c3863[_0xa7fb('0x1e')]?_0x4c3863[_0xa7fb('0x1e')][_0xa7fb('0x21')]||null:null,'include':_0x4c3863[_0xa7fb('0x1e')]?_0x4c3863['options'][_0xa7fb('0x22')]?_[_0xa7fb('0x23')](_0x4c3863[_0xa7fb('0x1e')][_0xa7fb('0x22')],function(_0x2557c0){return{'model':db[_0x2557c0[_0xa7fb('0x24')]],'as':_0x2557c0['as'],'attributes':_0x2557c0['attributes'],'include':_0x2557c0['include']?_['map'](_0x2557c0[_0xa7fb('0x22')],function(_0x346dc4){return{'model':db[_0x346dc4['model']],'as':_0x346dc4['as'],'attributes':_0x346dc4[_0xa7fb('0x21')],'include':_0x346dc4[_0xa7fb('0x22')]?_[_0xa7fb('0x23')](_0x346dc4[_0xa7fb('0x22')],function(_0x2fd439){return{'model':db[_0x2fd439[_0xa7fb('0x24')]],'as':_0x2fd439['as'],'attributes':_0x2fd439[_0xa7fb('0x21')]};}):[]};}):[]};}):[]:[]})[_0xa7fb('0x11')](function(_0x209960){logger[_0xa7fb('0x12')]('ShowSmsQueue',_0x4c3863);logger[_0xa7fb('0x14')]('ShowSmsQueue',_0x4c3863,JSON[_0xa7fb('0x16')](_0x209960));_0x2522de(_0x209960);})[_0xa7fb('0x1a')](function(_0x2ee10d){logger[_0xa7fb('0x17')](_0xa7fb('0x25'),_0x2ee10d[_0xa7fb('0x18')],_0x4c3863);_0x1780a8(_0x5d8176['error'](0x1f4,_0x2ee10d[_0xa7fb('0x18')]));});});};