chatIM/src/service/publishService.js

import { pubClient } from "../connection/redis.js";

const prefix = process.env.REDIS_PREFIX || "chat";

const getInKey = (realKey) => {
  return `${prefix}:${realKey}`;
};

const publishEnterRoom = (userId, roomId) => {
  const payLoad = {
    userId,
    roomId,
  };
  pubClient.publish("enterRoom", JSON.stringify(payLoad));
};
const publishExitRoom = (userId, roomId) => {
  const payLoad = {
    userId,
    roomId,
  };
  pubClient.publish("exitRoom", JSON.stringify(payLoad));
};

export { publishEnterRoom, publishExitRoom };