design.actions.ts

"use server";

import { revalidatePath } from "next/cache";
import { FilterQuery, SortOrder, UpdateQuery } from "mongoose";

import { connectToDatabase } from "@/lib/mongoose";
import Design, { IDesign } from "@/lib/models/design.model";
import User from "@/lib/models/user.model";

export const registerDesign = async ({ title, description = "", userId }: RegisterDesignParams) => {
  const response: ActionsResponse<IDesign> = {
    status: false,
    message: "",
    data: null,
  };

  if (!title || !userId) {
    response.message = "Please enter all the fields.";
    return response;
  }

  try {
    await connectToDatabase();

    const newDesign = await Design.create({
      title,
      description,
      creator: userId,
    });

    if (newDesign) {
      revalidatePath(`/dashboard/recently-viewed`);

      response.status = true;
      response.message = "Design registered successfully.";
      response.data = JSON.parse(JSON.stringify(newDesign));
    } else {
      response.message = "Unable to register new design.";
    }
  } catch (error) {
    console.error("[REGISTER_DESIGN_ERROR] :>> ", error);
    response.message = "Somethng went wrong. Please try again!";
  }

  return response;
};

export const fetchDesign = async ({ designId, populate = true }: FetchDesignParams) => {
  const response: ActionsResponse<IDesign> = {
    status: false,
    message: "",
    data: null,
  };

  try {
    await connectToDatabase();

    let design = await Design.findById(designId);

    if (design && populate) {
      design = await design.populate([
        {
          path: "creator",
          model: User,
          select: "name photo",
        },
        {
          path: "collaborators",
          model: User,
          select: "name photo",
        },
      ]);
    }

    if (design) {
      response.status = true;
      response.message = "Design fetched successfully.";
      response.data = JSON.parse(JSON.stringify(design));
    } else {
      response.message = "Unable to fetch design or design not found.";
    }
  } catch (error) {
    console.error("[FETCH_DESIGN_ERROR] :>> ", error);
    response.message = "Somethng went wrong. Please try again!";
  }

  return response;
};

export const updateDesignMetadata = async ({ designId, title, description, path }: UpdateDesignMetadataParams) => {
  const response: ActionsResponse<IDesign> = {
    status: false,
    message: "",
    data: null,
  };

  if (!designId || !title || !path) {
    response.message = "Invalid request.";
    return response;
  }

  try {
    await connectToDatabase();

    let design = await Design.findById(designId);

    if (design) {
      const updatedDesign = await Design.findByIdAndUpdate(designId, {
        title,
        description,
      });

      if (updatedDesign) {
        revalidatePath(path);

        response.status = true;
        response.message = "Design metadata updated successfully.";
      } else {
        response.message = "Unable to update design metadata.";
      }
    } else {
      response.message = "Design not found.";
    }
  } catch (error) {
    console.error("[UPDATE_DESIGN_METADATA_ERROR] :>> ", error);
    response.message = "Somethng went wrong. Please try again!";
  }

  return response;
};

export const updateCollaborators = async ({ designId, userId, action, path }: UpdateCollaboratorsParams) => {
  const response: ActionsResponse<IDesign> = {
    status: false,
    message: "",
    data: null,
  };

  if (!designId || !userId || !action || !path) {
    response.message = "Invalid request.";
    return response;
  }

  try {
    await connectToDatabase();

    const data: UpdateQuery<IDesign> =
      action === "add"
        ? {
            $push: { collaborators: userId },
          }
        : {
            $pull: { collaborators: userId },
          };

    const design = await Design.findByIdAndUpdate(designId, data);
    if (design) {
      revalidatePath(path);

      response.status = true;
      response.message = "Design collaborators updated successfully.";
    } else {
      response.message = "Unable to update design collaborators.";
    }
  } catch (error) {
    console.error("[UPDATE_DESIGN_COLLABORATORS_ERROR] :>> ", error);
    response.message = "Somethng went wrong. Please try again!";
  }

  return response;
};

export const fetchDesigns = async ({
  userId,
  limit = 8,
  page = 1,
  search = "",
  order = "updatedAt",
  sort = "desc",
  type = "recently-viewed",
}: FetchDesignsParams) => {
  const response: ActionsResponse<IDesign[]> = {
    status: false,
    message: "",
    data: null,
    totalPages: 1,
  };

  if (!userId) {
    response.message = "Invalid request.";
    return response;
  }

  const skip = (page - 1) * limit;
  const sortBy = { [order as string]: sort };

  let query: FilterQuery<IDesign> = {};

  if (type === "recently-viewed") {
    query.creator = userId;
  } else if (type === "shared") {
    query.collaborators = { $in: [userId] };
  }

  if (search.trim() !== "") {
    const regex = new RegExp(search, "i");
    query.$or = [{ title: { $regex: regex } }, { description: { $regex: regex } }];
  }

  try {
    connectToDatabase();

    const designs = await Design.find(query)
      .limit(limit)
      .skip(skip)
      .sort(sortBy)
      .populate([
        {
          path: "creator",
          model: User,
          select: "name photo",
        },
        {
          path: "collaborators",
          model: User,
          select: "name photo",
        },
      ]);

    const totalDesigns = await Design.countDocuments(query);

    if (designs.length > 0) {
      response.status = true;
      response.message = "Designs fetched successfully.";
      response.data = JSON.parse(JSON.stringify(designs));
      response.totalPages = Math.ceil(totalDesigns / limit);
    } else {
      response.message = "No designs found.";
    }
  } catch (error) {
    console.error("[FETCH_DESIGNS_ERROR] :>> ", error);
    response.message = "Somethng went wrong. Please try again!";
  }

  return response;
};

export const deleteDesign = async (designId: string) => {
  const response: ActionsResponse<IDesign> = {
    status: false,
    message: "",
    data: null,
  };

  if (!designId) {
    response.message = "Invalid request.";
    return response;
  }

  try {
    await connectToDatabase();

    const deletedDesign = await Design.findByIdAndDelete(designId);

    if (deletedDesign) {
      revalidatePath("/dashboard/recently-viewed");

      response.status = true;
      response.message = "Design deleted successfully.";
    } else {
      response.message = "Design not found.";
    }
  } catch (error) {
    console.error("[DELETE_DESIGN_ERROR] :>> ", error);
    response.message = "Somethng went wrong. Please try again!";
  }
  return response;
};