server/api/mailQueue/mailQueue.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 _0x689e=['GetMailQueue','MailQueue','findAll','options','raw','where','attributes','limit','include','map','model','debug','ShowMailQueue','find','lodash','util','randomstring','ioredis','../../mysqldb','../../config/utils','../../config/logger','rpc','../../config/environment','jayson/promise','client','redis','defaults','localhost','socket.io-emitter','./mailQueue.socket','register','request','then','info','MailQueue,\x20%s,\x20%s','request\x20sent','stringify','error','code','message','result','catch'];(function(_0x4cf98e,_0xba4b79){var _0x1623ac=function(_0x459bc0){while(--_0x459bc0){_0x4cf98e['push'](_0x4cf98e['shift']());}};_0x1623ac(++_0xba4b79);}(_0x689e,0x15e));var _0xe689=function(_0x1bb4e4,_0x33231f){_0x1bb4e4=_0x1bb4e4-0x0;var _0x442ea5=_0x689e[_0x1bb4e4];return _0x442ea5;};'use strict';var _=require(_0xe689('0x0'));var util=require(_0xe689('0x1'));var moment=require('moment');var BPromise=require('bluebird');var rs=require(_0xe689('0x2'));var fs=require('fs');var Redis=require(_0xe689('0x3'));var db=require(_0xe689('0x4'))['db'];var utils=require(_0xe689('0x5'));var logger=require(_0xe689('0x6'))(_0xe689('0x7'));var config=require(_0xe689('0x8'));var jayson=require(_0xe689('0x9'));var client=jayson[_0xe689('0xa')]['http']({'port':0x232a});config[_0xe689('0xb')]=_[_0xe689('0xc')](config[_0xe689('0xb')],{'host':_0xe689('0xd'),'port':0x18eb});var socket=require(_0xe689('0xe'))(new Redis(config[_0xe689('0xb')]));require(_0xe689('0xf'))[_0xe689('0x10')](socket);function respondWithRpcPromise(_0x584f8d,_0x180ef8,_0x277cea){return new BPromise(function(_0x260e8e,_0x40a208){return client[_0xe689('0x11')](_0x584f8d,_0x277cea)[_0xe689('0x12')](function(_0x564dab){logger[_0xe689('0x13')](_0xe689('0x14'),_0x180ef8,_0xe689('0x15'));logger['debug']('MailQueue,\x20%s,\x20%s,\x20%s',_0x180ef8,_0xe689('0x15'),JSON[_0xe689('0x16')](_0x564dab));if(_0x564dab[_0xe689('0x17')]){if(_0x564dab['error'][_0xe689('0x18')]===0x1f4){logger[_0xe689('0x17')](_0xe689('0x14'),_0x180ef8,_0x564dab[_0xe689('0x17')][_0xe689('0x19')]);return _0x40a208(_0x564dab['error']['message']);}logger['error'](_0xe689('0x14'),_0x180ef8,_0x564dab[_0xe689('0x17')]['message']);return _0x260e8e(_0x564dab[_0xe689('0x17')][_0xe689('0x19')]);}else{logger[_0xe689('0x13')](_0xe689('0x14'),_0x180ef8,_0xe689('0x15'));_0x260e8e(_0x564dab[_0xe689('0x1a')][_0xe689('0x19')]);}})[_0xe689('0x1b')](function(_0x1ab1cf){logger[_0xe689('0x17')]('MailQueue,\x20%s,\x20%s',_0x180ef8,_0x1ab1cf);_0x40a208(_0x1ab1cf);});});}exports[_0xe689('0x1c')]=function(_0x2f53a8){var _0x136565=this;return new Promise(function(_0x45561f,_0x4eab03){return db[_0xe689('0x1d')][_0xe689('0x1e')]({'raw':_0x2f53a8[_0xe689('0x1f')]?_0x2f53a8[_0xe689('0x1f')][_0xe689('0x20')]===undefined?!![]:![]:!![],'where':_0x2f53a8[_0xe689('0x1f')]?_0x2f53a8[_0xe689('0x1f')][_0xe689('0x21')]||null:null,'attributes':_0x2f53a8[_0xe689('0x1f')]?_0x2f53a8[_0xe689('0x1f')][_0xe689('0x22')]||null:null,'limit':_0x2f53a8['options']?_0x2f53a8['options'][_0xe689('0x23')]||null:null,'include':_0x2f53a8[_0xe689('0x1f')]?_0x2f53a8[_0xe689('0x1f')][_0xe689('0x24')]?_['map'](_0x2f53a8[_0xe689('0x1f')][_0xe689('0x24')],function(_0x38c012){return{'model':db[_0x38c012['model']],'as':_0x38c012['as'],'attributes':_0x38c012[_0xe689('0x22')],'include':_0x38c012[_0xe689('0x24')]?_[_0xe689('0x25')](_0x38c012[_0xe689('0x24')],function(_0x4072bc){return{'model':db[_0x4072bc[_0xe689('0x26')]],'as':_0x4072bc['as'],'attributes':_0x4072bc['attributes'],'include':_0x4072bc['include']?_[_0xe689('0x25')](_0x4072bc[_0xe689('0x24')],function(_0x281985){return{'model':db[_0x281985['model']],'as':_0x281985['as'],'attributes':_0x281985['attributes']};}):[]};}):[]};}):[]:[]})[_0xe689('0x12')](function(_0x32d988){logger[_0xe689('0x13')](_0xe689('0x1c'),_0x2f53a8);logger[_0xe689('0x27')](_0xe689('0x1c'),_0x2f53a8,JSON[_0xe689('0x16')](_0x32d988));_0x45561f(_0x32d988);})[_0xe689('0x1b')](function(_0x284b49){logger[_0xe689('0x17')](_0xe689('0x1c'),_0x284b49[_0xe689('0x19')],_0x2f53a8);_0x4eab03(_0x136565[_0xe689('0x17')](0x1f4,_0x284b49['message']));});});};exports[_0xe689('0x28')]=function(_0x4cf84e){var _0x3f56c0=this;return new Promise(function(_0x1f106c,_0x324630){return db[_0xe689('0x1d')][_0xe689('0x29')]({'raw':_0x4cf84e['options']?_0x4cf84e[_0xe689('0x1f')][_0xe689('0x20')]===undefined?!![]:![]:!![],'where':_0x4cf84e[_0xe689('0x1f')]?_0x4cf84e[_0xe689('0x1f')]['where']||null:null,'attributes':_0x4cf84e['options']?_0x4cf84e[_0xe689('0x1f')][_0xe689('0x22')]||null:null,'include':_0x4cf84e[_0xe689('0x1f')]?_0x4cf84e[_0xe689('0x1f')][_0xe689('0x24')]?_['map'](_0x4cf84e['options'][_0xe689('0x24')],function(_0x4fee9c){return{'model':db[_0x4fee9c[_0xe689('0x26')]],'as':_0x4fee9c['as'],'attributes':_0x4fee9c[_0xe689('0x22')],'include':_0x4fee9c[_0xe689('0x24')]?_[_0xe689('0x25')](_0x4fee9c[_0xe689('0x24')],function(_0x5999d8){return{'model':db[_0x5999d8[_0xe689('0x26')]],'as':_0x5999d8['as'],'attributes':_0x5999d8[_0xe689('0x22')],'include':_0x5999d8['include']?_[_0xe689('0x25')](_0x5999d8[_0xe689('0x24')],function(_0x2e0dc9){return{'model':db[_0x2e0dc9[_0xe689('0x26')]],'as':_0x2e0dc9['as'],'attributes':_0x2e0dc9[_0xe689('0x22')]};}):[]};}):[]};}):[]:[]})['then'](function(_0x46e5c8){logger[_0xe689('0x13')](_0xe689('0x28'),_0x4cf84e);logger['debug'](_0xe689('0x28'),_0x4cf84e,JSON['stringify'](_0x46e5c8));_0x1f106c(_0x46e5c8);})[_0xe689('0x1b')](function(_0x1a69bd){logger[_0xe689('0x17')](_0xe689('0x28'),_0x1a69bd[_0xe689('0x19')],_0x4cf84e);_0x324630(_0x3f56c0['error'](0x1f4,_0x1a69bd[_0xe689('0x19')]));});});};