NodeBB/NodeBB

'use strict';


const async = require('async');
const winston = require('winston');
const db = require('../../database');

module.exports = {
    name: 'Creating users:notvalidated',
    timestamp: Date.UTC(2016, 0, 20),
    method: function (callback) {
        const batch = require('../../batch');
        const now = Date.now();
        batch.processSortedSet('users:joindate', (ids, next) => {
            async.eachSeries(ids, (id, next) => {
                db.getObjectFields(`user:${id}`, ['uid', 'email:confirmed'], (err, userData) => {
                    if (err) {
                        return next(err);
                    }
                    if (!userData || !parseInt(userData.uid, 10) || parseInt(userData['email:confirmed'], 10) === 1) {
                        return next();
                    }
                    winston.verbose(`processing uid: ${userData.uid} email:confirmed: ${userData['email:confirmed']}`);
                    db.sortedSetAdd('users:notvalidated', now, userData.uid, next);
                });
            }, next);
        }, callback);
    },
};