Built motion from commit ac06311e.|2.6.28
[motion2.git] / server / config / schedule / whatsapp.js
index ac676d1..0eda127 100644 (file)
@@ -15,4 +15,4 @@
 // * treaties. The SOFTWARE PRODUCT is licensed, not sold.                        *
 // *                                                                       *
 // *************************************************************************
-var _0x975f=['join','WhatsappInteraction','update','timeout','YYYY-MM-DD\x20HH:mm:ss','then','length','[WHATSAPP]\x20Sending\x20updates\x20for\x20interactions:','emit','whatsappInteraction:update','catch','error','inspect','start','moment','ioredis','redis','defaults','socket.io-emitter','lastMsgAt','subtract','hours','info'];(function(_0x2dd0cf,_0x53a53f){var _0x578453=function(_0x22d324){while(--_0x22d324){_0x2dd0cf['push'](_0x2dd0cf['shift']());}};_0x578453(++_0x53a53f);}(_0x975f,0x167));var _0xf975=function(_0x26d6d9,_0x431cb8){_0x26d6d9=_0x26d6d9-0x0;var _0x1b4875=_0x975f[_0x26d6d9];return _0x1b4875;};'use strict';var _=require('lodash');var moment=require(_0xf975('0x0'));var Redis=require(_0xf975('0x1'));var util=require('util');var config=require('../../config/environment');var db=require('../../mysqldb')['db'];var logger=require('../logger')('schedule');config[_0xf975('0x2')]=_[_0xf975('0x3')](config['redis'],{'host':'localhost','port':0x18eb});var io=require(_0xf975('0x4'))(new Redis(config[_0xf975('0x2')]));function closeInteractions(){var _0x526ac0=[];return db['WhatsappInteraction']['findAll']({'raw':!![],'attributes':['id',_0xf975('0x5')],'where':{'closed':![],'lastMsgDirection':'in','lastMsgAt':{'$lt':moment()[_0xf975('0x6')](0x18,_0xf975('0x7'))}}})['then'](function(_0x71744b){if(_0x71744b&&_0x71744b['length']){_0x526ac0=_['map'](_0x71744b||[],'id');logger[_0xf975('0x8')]('[WHATSAPP]\x20Interactions\x20to\x20close:',_0x526ac0[_0xf975('0x9')]());return db[_0xf975('0xa')][_0xf975('0xb')]({'closeReason':'system','disposition':_0xf975('0xc'),'closed':!![],'closedAt':moment()['format'](_0xf975('0xd'))},{'where':{'id':_0x526ac0}});}})[_0xf975('0xe')](function(){if(_0x526ac0&&_0x526ac0[_0xf975('0xf')]){logger[_0xf975('0x8')](_0xf975('0x10'),_0x526ac0[_0xf975('0x9')]());for(var _0x8271c1=0x0;_0x8271c1<_0x526ac0['length'];_0x8271c1++){io[_0xf975('0x11')](_0xf975('0x12'),{'id':_0x526ac0[_0x8271c1],'closed':!![]});}}})[_0xf975('0x13')](function(_0x375d9f){logger[_0xf975('0x14')]('[WHATSAPP]\x20Error\x20closing\x20interactions',_0x375d9f?util[_0xf975('0x15')](_0x375d9f,{'showHidden':![],'depth':null}):'');});}exports[_0xf975('0x16')]=function(){setInterval(function(){return closeInteractions();},0x3c*0x3e8);return closeInteractions();};
\ No newline at end of file
+var _0x2a6f=['hours','then','length','map','[WHATSAPP]\x20Interactions\x20to\x20close:','WhatsappInteraction','update','timeout','format','YYYY-MM-DD\x20HH:mm:ss','info','[WHATSAPP]\x20Sending\x20updates\x20for\x20interactions:','join','emit','error','inspect','start','lodash','moment','ioredis','util','../../mysqldb','../logger','schedule','redis','defaults','localhost','socket.io-emitter','findAll','lastMsgAt'];(function(_0x2b2ab3,_0x386ce0){var _0x4f65b9=function(_0x1754f4){while(--_0x1754f4){_0x2b2ab3['push'](_0x2b2ab3['shift']());}};_0x4f65b9(++_0x386ce0);}(_0x2a6f,0x15b));var _0xf2a6=function(_0x56d04b,_0x459ce3){_0x56d04b=_0x56d04b-0x0;var _0x583d8f=_0x2a6f[_0x56d04b];return _0x583d8f;};'use strict';var _=require(_0xf2a6('0x0'));var moment=require(_0xf2a6('0x1'));var Redis=require(_0xf2a6('0x2'));var util=require(_0xf2a6('0x3'));var config=require('../../config/environment');var db=require(_0xf2a6('0x4'))['db'];var logger=require(_0xf2a6('0x5'))(_0xf2a6('0x6'));config[_0xf2a6('0x7')]=_[_0xf2a6('0x8')](config[_0xf2a6('0x7')],{'host':_0xf2a6('0x9'),'port':0x18eb});var io=require(_0xf2a6('0xa'))(new Redis(config[_0xf2a6('0x7')]));function closeInteractions(){var _0x2c3fae=[];return db['WhatsappInteraction'][_0xf2a6('0xb')]({'raw':!![],'attributes':['id',_0xf2a6('0xc')],'where':{'closed':![],'lastMsgDirection':'in','lastMsgAt':{'$lt':moment()['subtract'](0x18,_0xf2a6('0xd'))}}})[_0xf2a6('0xe')](function(_0x316d64){if(_0x316d64&&_0x316d64[_0xf2a6('0xf')]){_0x2c3fae=_[_0xf2a6('0x10')](_0x316d64||[],'id');logger['info'](_0xf2a6('0x11'),_0x2c3fae['join']());return db[_0xf2a6('0x12')][_0xf2a6('0x13')]({'closeReason':'system','disposition':_0xf2a6('0x14'),'closed':!![],'closedAt':moment()[_0xf2a6('0x15')](_0xf2a6('0x16'))},{'where':{'id':_0x2c3fae}});}})[_0xf2a6('0xe')](function(){if(_0x2c3fae&&_0x2c3fae['length']){logger[_0xf2a6('0x17')](_0xf2a6('0x18'),_0x2c3fae[_0xf2a6('0x19')]());for(var _0x1dc34f=0x0;_0x1dc34f<_0x2c3fae[_0xf2a6('0xf')];_0x1dc34f++){io[_0xf2a6('0x1a')]('whatsappInteraction:update',{'id':_0x2c3fae[_0x1dc34f],'closed':!![]});}}})['catch'](function(_0x3ed6d1){logger[_0xf2a6('0x1b')]('[WHATSAPP]\x20Error\x20closing\x20interactions',_0x3ed6d1?util[_0xf2a6('0x1c')](_0x3ed6d1,{'showHidden':![],'depth':null}):'');});}exports[_0xf2a6('0x1d')]=function(){setInterval(function(){return closeInteractions();},0x3c*0x3e8);return closeInteractions();};
\ No newline at end of file