server/config/schedule/whatsapp.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 _0xada9=['../../config/environment','../../mysqldb','../logger','redis','socket.io-emitter','WhatsappInteraction','findAll','lastMsgAt','subtract','hours','then','length','map','info','join','timeout','format','[WHATSAPP]\x20Sending\x20updates\x20for\x20interactions:','whatsappInteraction:update','error','[WHATSAPP]\x20Error\x20closing\x20interactions','lodash','moment','ioredis','util'];(function(_0x5c5904,_0xa16eeb){var _0x1eb4b8=function(_0x103d25){while(--_0x103d25){_0x5c5904['push'](_0x5c5904['shift']());}};_0x1eb4b8(++_0xa16eeb);}(_0xada9,0xdd));var _0x9ada=function(_0xd724ba,_0x510b91){_0xd724ba=_0xd724ba-0x0;var _0x68fd78=_0xada9[_0xd724ba];return _0x68fd78;};'use strict';var _=require(_0x9ada('0x0'));var moment=require(_0x9ada('0x1'));var Redis=require(_0x9ada('0x2'));var util=require(_0x9ada('0x3'));var config=require(_0x9ada('0x4'));var db=require(_0x9ada('0x5'))['db'];var logger=require(_0x9ada('0x6'))('schedule');config[_0x9ada('0x7')]=_['defaults'](config[_0x9ada('0x7')],{'host':'localhost','port':0x18eb});var io=require(_0x9ada('0x8'))(new Redis(config[_0x9ada('0x7')]));function closeInteractions(){var _0x58e623=[];return db[_0x9ada('0x9')][_0x9ada('0xa')]({'raw':!![],'attributes':['id',_0x9ada('0xb')],'where':{'closed':![],'lastMsgDirection':'in','lastMsgAt':{'$lt':moment()[_0x9ada('0xc')](0x18,_0x9ada('0xd'))}}})[_0x9ada('0xe')](function(_0x1e47f4){if(_0x1e47f4&&_0x1e47f4[_0x9ada('0xf')]){_0x58e623=_[_0x9ada('0x10')](_0x1e47f4||[],'id');logger[_0x9ada('0x11')]('[WHATSAPP]\x20Interactions\x20to\x20close:',_0x58e623[_0x9ada('0x12')]());return db[_0x9ada('0x9')]['update']({'closeReason':'system','disposition':_0x9ada('0x13'),'closed':!![],'closedAt':moment()[_0x9ada('0x14')]('YYYY-MM-DD\x20HH:mm:ss')},{'where':{'id':_0x58e623}});}})[_0x9ada('0xe')](function(){if(_0x58e623&&_0x58e623[_0x9ada('0xf')]){logger['info'](_0x9ada('0x15'),_0x58e623[_0x9ada('0x12')]());for(var _0x5ba073=0x0;_0x5ba073<_0x58e623[_0x9ada('0xf')];_0x5ba073++){io['emit'](_0x9ada('0x16'),{'id':_0x58e623[_0x5ba073],'closed':!![]});}}})['catch'](function(_0x449a87){logger[_0x9ada('0x17')](_0x9ada('0x18'),_0x449a87?util['inspect'](_0x449a87,{'showHidden':![],'depth':null}):'');});}exports['start']=function(){setInterval(function(){return closeInteractions();},0x3c*0x3e8);return closeInteractions();};