fix: #7487
parent
962b7f73d3
commit
fddb783ee9
@ -0,0 +1,45 @@
|
||||
'use strict';
|
||||
|
||||
const async = require('async');
|
||||
const db = require('../../database');
|
||||
const user = require('../../user');
|
||||
|
||||
module.exports = {
|
||||
name: 'Delete username email history for deleted users',
|
||||
timestamp: Date.UTC(2019, 2, 25),
|
||||
method: async function (callback) {
|
||||
const progress = this.progress;
|
||||
var currentUid = 1;
|
||||
db.getObjectField('global', 'nextUid', function (err, nextUid) {
|
||||
if (err) {
|
||||
return callback(err);
|
||||
}
|
||||
progress.total = nextUid;
|
||||
async.whilst(function () {
|
||||
return currentUid < nextUid;
|
||||
},
|
||||
function (next) {
|
||||
progress.incr();
|
||||
user.exists(currentUid, function (err, exists) {
|
||||
if (err) {
|
||||
return next(err);
|
||||
}
|
||||
if (exists) {
|
||||
currentUid += 1;
|
||||
return next();
|
||||
}
|
||||
db.deleteAll(['user:' + currentUid + ':usernames', 'user:' + currentUid + ':emails'], function (err) {
|
||||
if (err) {
|
||||
return next(err);
|
||||
}
|
||||
currentUid += 1;
|
||||
next();
|
||||
});
|
||||
});
|
||||
},
|
||||
function (err) {
|
||||
callback(err);
|
||||
});
|
||||
});
|
||||
},
|
||||
};
|
Loading…
Reference in New Issue