checkinbox moved to worker #461

Merged
bernat merged 4 commits from 2579-worker_time_control into dev 2020-11-23 12:01:34 +00:00
7 changed files with 13 additions and 9 deletions

View File

@ -76,12 +76,6 @@
}, },
"UserLog": { "UserLog": {
"dataSource": "vn" "dataSource": "vn"
},
"WorkerTimeControlParams": {
"dataSource": "vn"
},
"WorkerTimeControlMail": {
"dataSource": "vn"
} }
} }

View File

@ -1,3 +0,0 @@
module.exports = Self => {
require('../methods/imap-time-control/checkInbox')(Self);
};

View File

@ -35,6 +35,10 @@ module.exports = Self => {
imap.once('ready', function() { imap.once('ready', function() {
openInbox(function(err, box) { openInbox(function(err, box) {
if (err) throw err; if (err) throw err;
const totalMessages = box.messages.total;
if (totalMessages == 0)
imap.end();
let f = imap.seq.fetch('1:*', { let f = imap.seq.fetch('1:*', {
bodies: ['HEADER.FIELDS (FROM SUBJECT)', '1'], bodies: ['HEADER.FIELDS (FROM SUBJECT)', '1'],
struct: true struct: true

View File

@ -55,6 +55,12 @@
}, },
"WorkerLog": { "WorkerLog": {
"dataSource": "vn" "dataSource": "vn"
},
"WorkerTimeControlParams": {
"dataSource": "vn"
},
"WorkerTimeControlMail": {
"dataSource": "vn"
} }
} }

View File

@ -0,0 +1,3 @@
module.exports = Self => {
require('../methods/worker-time-control-mail/checkInbox')(Self);
};