pollo/src/server/actions/room.ts

"use server";

import { createId } from "@paralleldrive/cuid2";
import { db } from "../db";
import { logs, rooms, votes } from "../schema";
import { auth } from "@clerk/nextjs";
import { fetchCache, invalidateCache, setCache } from "../redis";
import { publishToChannel } from "../ably";
import { EventTypes } from "@/utils/types";
import { eq } from "drizzle-orm";

/**
 * Creates a new room.
 *
 * @param {string} name - The name of the room.
 * @returns {Promise<boolean>} - A promise that resolves to a boolean indicating the success of room creation.
 */
export const createRoom = async (name: string) => {
  const { userId } = auth();

  if (!userId) {
    return false;
  }

  const room = await db
    .insert(rooms)
    .values({
      id: `room_${createId()}`,
      userId,
      roomName: name,
      storyName: "First Story!",
      scale: "0.5,1,2,3,5,8",
      visible: false,
    })
    .returning();

  const success = room.length > 0;
  if (room) {
    await invalidateCache(`kv_roomlist_${userId}`);

    await publishToChannel(
      `${userId}`,
      EventTypes.ROOM_LIST_UPDATE,
      JSON.stringify(room)
    );
  }
  return success;
};

/**
 * Deletes a room with the specified ID.
 *
 * @param {string} id - The ID of the room to delete.
 * @returns {Promise<boolean>} - A promise that resolves to a boolean indicating the success of room deletion.
 */
export const deleteRoom = async (id: string) => {
  const { userId } = auth();

  if (!userId) {
    return false;
  }

  const deletedRoom = await db
    .delete(rooms)
    .where(eq(rooms.id, id))
    .returning();

  const success = deletedRoom.length > 0;

  if (success) {
    await publishToChannel(
      `${userId}`,
      EventTypes.ROOM_LIST_UPDATE,
      JSON.stringify(deletedRoom)
    );

    await publishToChannel(
      `${id}`,
      EventTypes.ROOM_UPDATE,
      JSON.stringify(deletedRoom)
    );

    await invalidateCache(`kv_roomlist_${userId}`);

    await publishToChannel(
      `${userId}`,
      EventTypes.ROOM_LIST_UPDATE,
      JSON.stringify(deletedRoom)
    );
  }

  return success;
};

/**
 * Retrieves a room with the specified ID.
 *
 * @param {string} id - The ID of the room to retrieve.
 * @returns {Promise<object|null>} - A promise that resolves to the retrieved room object or null if not found.
 */
export const getRoom = async (id: string) => {
  const { userId } = auth();

  if (!userId) {
    return null;
  }

  const roomFromDb = await db.query.rooms.findFirst({
    where: eq(rooms.id, id),
    with: {
      logs: true,
    },
  });
  return roomFromDb || null;
};

/**
 * Retrieves a list of rooms.
 *
 * @returns {Promise<object[]|null>} - A promise that resolves to an array of room objects or null if not found.
 */
export const getRooms = async () => {
  const { userId } = auth();

  if (!userId) {
    return null;
  }

  const cachedResult = await fetchCache<
    {
      id: string;
      createdAt: Date;
      roomName: string;
    }[]
  >(`kv_roomlist_${userId}`);

  if (cachedResult) {
    return cachedResult;
  } else {
    const roomList = await db.query.rooms.findMany({
      where: eq(rooms.userId, userId),
    });

    await setCache(`kv_roomlist_${userId}`, roomList);

    return roomList;
  }
};

/**
 * Sets the properties of a room.
 *
 * @param {string} name - The new name of the room.
 * @param {boolean} visible - Indicates if the room is visible.
 * @param {string} scale - The scale values for the room.
 * @param {string} roomId - The ID of the room to update.
 * @param {boolean} reset - Indicates whether to reset room data.
 * @param {boolean} log - Indicates whether to log changes.
 * @returns {Promise<boolean>} - A promise that resolves to a boolean indicating the success of the room update.
 */
export const setRoom = async (
  name: string,
  visible: boolean,
  scale: string,
  roomId: string,
  reset: boolean,
  log: boolean
) => {
  const { userId } = auth();

  if (!userId) {
    return false;
  }

  if (reset) {
    if (log) {
      const oldRoom = await db.query.rooms.findFirst({
        where: eq(rooms.id, roomId),
        with: {
          votes: true,
          logs: true,
        },
      });

      oldRoom &&
        (await db.insert(logs).values({
          id: `log_${createId()}`,
          userId: userId,
          roomId: roomId,
          scale: oldRoom.scale,
          votes: oldRoom.votes.map((vote) => {
            return {
              name: vote.userId,
              value: vote.value,
            };
          }),
          roomName: oldRoom.roomName,
          storyName: oldRoom.storyName,
        }));
    }

    await db.delete(votes).where(eq(votes.roomId, roomId));

    await invalidateCache(`kv_votes_${roomId}`);
  }

  const newRoom = await db
    .update(rooms)
    .set({
      storyName: name,
      visible: visible,
      scale: [...new Set(scale.split(","))]
        .filter((item) => item !== "")
        .toString(),
    })
    .where(eq(rooms.id, roomId))
    .returning();

  const success = newRoom.length > 0;

  if (success) {
    await publishToChannel(
      `${roomId}`,
      EventTypes.ROOM_UPDATE,
      JSON.stringify(newRoom)
    );
  }

  return success;
};