Update deletepattern in redis lib to return the number of deleted keys

merge-requests/341/head
Thomas Lynch 6 months ago
parent 20d8085964
commit 76217710b0
  1. 4
      lib/redis/redis.js

@ -138,11 +138,13 @@ module.exports = {
deletePattern: (pattern) => {
return new Promise((resolve, reject) => {
let totalDeleted = 0;
const stream = sharedClient.scanStream({
match: pattern
});
stream.on('data', (keys) => {
if (keys.length > 0) {
totalDeleted += keys.length;
const pipeline = sharedClient.pipeline();
for (let i = 0; i < keys.length; i++) {
pipeline.del(keys[i]);
@ -151,7 +153,7 @@ module.exports = {
}
});
stream.on('end', () => {
resolve();
resolve(totalDeleted);
});
stream.on('error', (err) => {
reject(err);

Loading…
Cancel
Save