Redis Scan-Remove

gistfile1.js

function scanRemove(cursor, prefix, count) {
  return redis
    .scan(cursor, 'MATCH', `${prefix}*`, 'COUNT', count)
    .then(([cur, keys]) => redis.del(keys).then(() => Promise.resolve(cur)))
    .then(cur => (cur !== 0 && cur !== '0') ? scanRemove(cur, prefix, count) : Promise.resolve());
}

function removeAllMatching(prefix, count=10) {
  return scanRemove(0, prefix, count)
  .catch(err => {throw new Error(`Scan-remove failed: ${err.message}`);});
}