destroy-sessions.js

/* eslint-disable prefer-destructuring */
const { promisify } = require("util");


function scanRedis(pattern) {
  const scan = promisify(redisClient.scan).bind(redisClient);
  const result = [];
  let cursor = "0";
  do {
    // eslint-disable-next-line no-await-in-loop
    const reply = await scan(cursor, "MATCH", pattern, "COUNT", 100);

    cursor = reply[0];
    result.push(...reply[1]);
  } while (cursor !== "0");
  return result;
}

function destroyUserSessions(userId) {
  const sessions = await scanRedis({
    pattern: `sess:${userId}-*`,
  });
  const unlinkSessions = sessions.map((session) => redisClient.unlink(session));
  await Promise.all(unlinkSessions);
  
}