server-actions/store.ts

"use server";

import { db } from "@/db/db";
import { stores, users } from "@/db/schema";
import { requireUser } from "@/lib/auth";
import { eq, or } from "drizzle-orm";
import { z } from "zod";
import { createSlug } from "@/lib/createSlug";

export async function createStore(storeName: string) {
  try {
    const user = await requireUser();

    if (user.storeId) {
      return {
        error: true,
        message: "Store already exists",
        action: "You already have a store linked to this account.",
      };
    }

    const existingStore = await db
      .select()
      .from(stores)
      .where(
        or(eq(stores.name, storeName), eq(stores.slug, createSlug(storeName)))
      );

    if (existingStore.length > 0) {
      const res = {
        error: true,
        message: "Sorry, a store with that name already exists.",
        action: "Please try again.",
      };
      return res;
    }

    const [{ insertId: storeId }] = await db.insert(stores).values({
      name: storeName,
      slug: createSlug(storeName),
    });

    await db.update(users).set({ storeId }).where(eq(users.id, user.id));

    const res = {
      error: false,
      message: "Store created",
      action: "Success, your store has been created",
    };

    return res;
  } catch (err) {
    console.log(err);
    const res = {
      error: true,
      message: "Sorry, an error occured creating your store. ",
      action: "Please try again.",
    };
    return res;
  }
}

export async function updateStore(args: {
  name: string | null;
  description: string | null;
  industry: string | null;
}) {
  const inputSchema = z.object({
    name: z.string(),
    description: z.string(),
    industry: z.string(),
  });

  try {
    const user = await requireUser();

    inputSchema.parse(args);

    await db
      .update(stores)
      .set(args)
      .where(eq(stores.id, Number(user.storeId)));

    const res = {
      error: false,
      message: "Store details updated",
      action: "Success, your store's details have been updated",
    };

    return res;
  } catch (err) {
    console.log(err);
    const res = {
      error: true,
      message: "Sorry, an error occured updating your details.",
      action: "Please try again.",
    };
    return res;
  }
}