Try Fix UI & API Menu Ekonomi Sub Menu Pasar Desa

src/app/api/[[...slugs]]/_lib/ekonomi/pasar-desa/create.ts

@@ -0,0 +1,38 @@
+import prisma from "@/lib/prisma";
+import { Context } from "elysia";
+
+type FormCreate = {
+  nama: string;
+  harga: number;
+  satuan: string;
+  alamat: string;
+  imageId: string;
+  rating: number;
+  kategoriId: string; // Array of KategoriMakanan IDs
+};
+export default async function pasarDesaCreate(context: Context) {
+  const body = context.body as FormCreate;
+
+  // First, create the PasarDesa record
+  const pasarDesa = await prisma.pasarDesa.create({
+    data: {
+      nama: body.nama,
+      harga: Number(body.harga),
+      satuan: body.satuan,
+      alamat: body.alamat,
+      imageId: body.imageId,
+      rating: Number(body.rating),
+      kategoriId: body.kategoriId,
+    },
+    include: {
+      image: true,
+      kategori: true,
+    },
+  });
+
+    return {
+      success: true,
+      message: "Success create pasar desa",
+      data: pasarDesa,
+    };
+}

src/app/api/[[...slugs]]/_lib/ekonomi/pasar-desa/del.ts

@@ -0,0 +1,54 @@
+import prisma from "@/lib/prisma";
+import { Context } from "elysia";
+import fs from "fs/promises";
+import path from "path";
+
+const pasarDesaDelete = async (context: Context) => {
+  const id = context.params?.id as string;
+
+  if (!id) {
+    return {
+      status: 400,
+      body: "ID tidak diberikan",
+    };
+  }
+
+  const pasarDesa = await prisma.pasarDesa.findUnique({
+    where: { id },
+    include: {
+      image: true,
+      kategori: true,
+    },
+  });
+
+  if (!pasarDesa) {
+    return {
+      status: 404,
+      body: "Pasar desa tidak ditemukan",
+    };
+  }
+
+  if (pasarDesa.image) {
+    try {
+      const filePath = path.join(pasarDesa.image.path, pasarDesa.image.name);
+      await fs.unlink(filePath);
+      await prisma.fileStorage.delete({
+        where: { id: pasarDesa.image.id },
+      });
+    } catch (err) {
+      console.error("Gagal hapus file image:", err);
+    }
+  }
+  
+
+  await prisma.pasarDesa.delete({
+    where: { id },
+  });
+
+  return {
+    status: 200,
+    success: true,
+    message: "Pasar desa berhasil dihapus",
+  };
+};
+export default pasarDesaDelete;

src/app/api/[[...slugs]]/_lib/ekonomi/pasar-desa/findMany.ts

@@ -0,0 +1,25 @@
+import prisma from "@/lib/prisma";
+
+export default async function pasarDesaFindMany() {
+    try {
+        const data = await prisma.pasarDesa.findMany({
+            where: { isActive: true },
+            include: {
+                image: true,
+                kategori: true,
+            },
+        });
+
+        return {
+            success: true,
+            message: "Success fetch pasar desa",
+            data,
+        };
+    } catch (e) {
+        console.error("Find many error:", e);
+        return {
+            success: false,
+            message: "Failed fetch pasar desa",
+        };
+    }
+}

src/app/api/[[...slugs]]/_lib/ekonomi/pasar-desa/findUnique.ts

@@ -0,0 +1,54 @@
+import prisma from "@/lib/prisma";
+
+export default async function pasarDesaFindUnique(request: Request){
+    const url = new URL(request.url);
+    const pathSegments = url.pathname.split('/');
+    const id = pathSegments[pathSegments.length - 1];
+
+    if(!id){
+        return Response.json({
+            success: false,
+            message: "ID tidak boleh kosong",
+        }, { status: 400 });
+    }
+
+    try {
+        if (typeof id !== 'string') {
+            return Response.json({
+                success: false,
+                message: "ID tidak valid",
+            }, { status: 400 });
+        }
+
+        const data = await prisma.pasarDesa.findUnique({
+            where: { id },
+            include: {
+                image: true,
+                kategori: true,
+            },
+        });
+
+        if (!data) {
+            return Response.json({
+                success: false,
+                message: "Pasar desa tidak ditemukan",
+            }, { status: 404 });
+        }
+
+        return Response.json({
+            success: true,
+            message: "Success fetch pasar desa by ID",
+            data,
+        }, {
+            status: 200,
+        });
+    } catch (e) {
+        console.error("Find by ID error:", e);
+        return Response.json({
+            success: false,
+            message: "Gagal mengambil pasar desa: " + (e instanceof Error ? e.message : 'Unknown error'),
+        }, {
+            status: 500,
+        });
+    }
+}

src/app/api/[[...slugs]]/_lib/ekonomi/pasar-desa/index.ts

@@ -0,0 +1,48 @@
+import Elysia, { t } from "elysia";
+import pasarDesaCreate from "./create";
+import pasarDesaDelete from "./del";
+import pasarDesaFindMany from "./findMany";
+import pasarDesaUpdate from "./updt";
+import pasarDesaFindUnique from "./findUnique";
+
+const PasarDesa = new Elysia({
+  prefix: "/pasardesa",
+  tags: ["Ekonomi/Pasar Desa"],
+})
+  .get("/find-many", pasarDesaFindMany)
+  .get("/:id", async (context) => {
+    const response = await pasarDesaFindUnique(new Request(context.request));
+    return response;
+  })
+  .post("/create", pasarDesaCreate, {
+    body: t.Object({
+      nama: t.String(),
+      harga: t.Number(),
+      satuan: t.String(),
+      alamat: t.String(),
+      imageId: t.String(),
+      rating: t.Number(),
+      kategoriId:t.String(),
+    }),
+  })
+  .delete("/del/:id", pasarDesaDelete)
+  .put(
+    "/:id",
+    async (context) => {
+      const response = await pasarDesaUpdate(context);
+      return response;
+    },
+    {
+      body: t.Object({
+        nama: t.String(),
+        harga: t.Number(),
+        satuan: t.String(),
+        alamat: t.String(),
+        imageId: t.String(),
+        rating: t.Number(),
+        kategoriId: t.String(),
+      }),
+    }
+  );
+
+export default PasarDesa;

src/app/api/[[...slugs]]/_lib/ekonomi/pasar-desa/updt.ts

@@ -0,0 +1,98 @@
+import prisma from "@/lib/prisma";
+import { Context } from "elysia";
+import fs from "fs/promises";
+import path from "path";
+
+type FormUpdate = {
+    nama: string;
+    harga: number;
+    satuan: string;
+    alamat: string;
+    imageId: string;
+    rating: number;
+    kategoriId: string; // Array of KategoriMakanan IDs
+  };
+
+export default async function pasarDesaUpdate(context: Context){
+    try {
+        const id = context.params?.id;
+        const body = context.body as FormUpdate;
+
+        const { nama, harga, satuan, alamat, imageId, rating, kategoriId } = body;
+        
+        if (!id) {
+            return Response.json({
+                success: false,
+                message: "ID tidak boleh kosong",
+            }, { status: 400 });
+        }
+
+        const existing = await prisma.pasarDesa.findUnique({
+            where: { id },
+            include: {
+                image: true,
+                kategori: true,
+            },
+        })
+
+        if (!existing) {
+            return Response.json({
+                success: false,
+                message: "Pasar desa tidak ditemukan",
+            }, { status: 404 });
+        }
+
+        if (existing.imageId && existing.imageId !== imageId) {
+            const oldImage = existing.image;
+            if (oldImage) {
+              try {
+                const filePath = path.join(oldImage.path, oldImage.name);
+                await fs.unlink(filePath);
+                await prisma.fileStorage.delete({
+                  where: { id: oldImage.id },
+                });
+              } catch (err) {
+                console.error("Gagal hapus gambar lama:", err);
+              }
+            }
+          }
+
+        // First, update the main PasarDesa record
+        await prisma.pasarDesa.update({
+            where: { id },
+            data: {
+                nama,
+                harga,
+                satuan,
+                alamat,
+                imageId,
+                rating,
+                kategoriId,
+            },
+        });
+
+        // Fetch the updated record with all relations
+        const updated = await prisma.pasarDesa.findUnique({
+            where: { id },
+            include: {
+                image: true,
+                kategori: true,
+            }
+        });
+        return Response.json({
+            success: true,
+            message: "Success update pasar desa",
+            data: updated,
+        }, {
+            status: 200,
+        });
+    } catch (e) {
+        console.error("Update error:", e);
+        return Response.json({
+            success: false,
+            message: "Gagal mengupdate pasar desa: " + (e instanceof Error ? e.message : 'Unknown error'),
+        }, {
+            status: 500,
+        });
+    }
+}