deleter.js

'use strict';
(function() {
/** @type{SetupModule} */
var setup = require('./setup'),
    Q = require('q');

var logger = setup.logger,
    BtUser = setup.BtUser,
    BlockBatch = setup.BlockBatch,
    Action = setup.Action;

/**
 * Find users who deactivated more than thirty days ago and delete them from the
 * DB. In theory we could just delete the user and the foreign key constraints
 * would take care of deleting the rest.  We do it this way (deleting the
 * associated tables first), because users who have really large numbers of
 * Actions or Blocks cause the BtUsers table to be locked for a super long time
 * while deleting those. We do rely on foreign key constraints to delete the
 * blocks associated with the BlockBatches.
 */
function findAndDeleteOneOldUser() {
  return BtUser
    .findOne({
      where: {
        deactivatedAt: {
          lt: new Date(Date.now() - 30 * 86400 * 1000)
        }
      },
      order: [['deactivatedAt', 'ASC']]
    }).then(function(user) {
      if (user) {
        return deleteOneOldUser(user);
      } else {
        return Q.resolve(null);
      }
    }).catch(function(err) {
      logger.error(err);
    });
}

function deleteOneOldUser(user) {
  logger.info(user, user.dataValues);
  return Action.destroy({
    where: {
      source_uid: user.uid
    }
  }).then(function() {
    return BlockBatch.destroy({
      where: {
        source_uid: user.uid
      }
    });
  }).then(function() {
    return user.destroy();
  }).catch(function(err) {
    logger.error(err);
  });
}

if (require.main === module) {
  setInterval(findAndDeleteOneOldUser, 10000);
}

})();