fix job

deskripsi:
- fix server action to API notification to admin
- fix api created job

src/app/api/job/route.ts

@@ -1,8 +1,6 @@
+import { prisma } from "@/lib";
 import backendLogger from "@/util/backendLogger";
 import { NextResponse } from "next/server";
-import { prisma } from "@/lib";
-export const dynamic = "force-dynamic";
-
 
 export async function GET(request: Request) {
   try {
@@ -10,7 +8,7 @@ export async function GET(request: Request) {
     const { searchParams } = new URL(request.url);
     const search = searchParams.get("search");
     const page = searchParams.get("page");
-    const dataTake = 10
+    const dataTake = 10;
     const dataSkip = Number(page) * dataTake - dataTake;
 
     if (!page) {
@@ -83,3 +81,68 @@ export async function GET(request: Request) {
     });
   }
 }
+
+export async function POST(request: Request) {
+  if (request.method !== "POST") {
+    return NextResponse.json(
+      {
+        success: false,
+        message: "Method not allowed",
+      },
+      { status: 405 }
+    );
+  }
+
+  try {
+    const { data } = await request.json();
+
+    const fixData = await prisma.job.create({
+      data: {
+        title: data.title,
+        content: data.content,
+        deskripsi: data.deskripsi,
+        authorId: data.authorId,
+        imageId: data.imageId ?? null,
+      },
+      select: {
+        id: true,
+        authorId: true,
+        MasterStatus: {
+          select: {
+            name: true,
+          },
+        },
+        title: true,
+      },
+    });
+
+    if (!fixData) {
+      return NextResponse.json(
+        {
+          success: false,
+          message: "Failed created job",
+        },
+        { status: 400 }
+      );
+    }
+
+    return NextResponse.json(
+      {
+        success: true,
+        message: "Success created job",
+        data: fixData,
+      },
+      { status: 201 }
+    );
+  } catch (error) {
+    console.log("Error created job", error);
+    return NextResponse.json(
+      {
+        success: false,
+        message: "Error created job",
+        error: (error as Error).message || error,
+      },
+      { status: 500 }
+    );
+  }
+}

src/app/api/notifications/to-admin/route.ts

@@ -0,0 +1,72 @@
+import { NextResponse } from "next/server";
+import {prisma} from "@/lib"
+
+interface NotificationData {
+  userId: string;
+  appId: string;
+  status: string;
+  title: string;
+  pesan: string;
+  kategoriApp: string;
+}
+
+export async function POST(request: Request) {
+  try {
+    const { data }: { data: NotificationData } = await request.json();
+
+    // Validasi input
+    if (!data || !data.userId || !data.title || !data.pesan) {
+      return NextResponse.json(
+        {
+          success: false,
+          message: "Missing required fields",
+        },
+        { status: 400 }
+      );
+    }
+
+    // Ambil semua admin aktif
+    const getAdmin = await prisma.user.findMany({
+      where: {
+        active: true,
+        masterUserRoleId: "2",
+      },
+    });
+
+    // Buat notifikasi untuk semua admin secara paralel
+    const createPromises = getAdmin.map((a) =>
+      prisma.notifikasi.create({
+        data: {
+          adminId: a.id,
+          userId: data.userId,
+          appId: data.appId,
+          status: data.status,
+          title: data.title,
+          pesan: data.pesan,
+          kategoriApp: data.kategoriApp,
+          userRoleId: "2",
+        },
+      })
+    );
+
+    await Promise.all(createPromises);
+
+    return NextResponse.json(
+      {
+        success: true,
+        message: "Successfully created notifications for admins",
+      },
+      { status: 201 }
+    );
+  } catch (error) {
+    console.error("Error creating notification for admin:", error);
+    return NextResponse.json(
+      {
+        success: false,
+        message: "Error creating notification for admin",
+        error: (error as Error).message || "Unknown error",
+      },
+      { status: 500 }
+    );
+  }
+}

src/app/api/season/route.ts

@@ -0,0 +1,65 @@
+import { NextResponse } from "next/server";
+import { decrypt } from "../../../app/(auth)/_lib/decrypt";
+import { cookies } from "next/headers";
+export const dynamic = "force-dynamic";
+
+
+interface DecryptedUser {
+  id: string;
+  [key: string]: any;
+}
+
+export async function GET(request: Request) {
+  const SESSION_KEY = process.env.NEXT_PUBLIC_BASE_SESSION_KEY;
+  const TOKEN_KEY = process.env.NEXT_PUBLIC_BASE_TOKEN_KEY;
+
+  if (!SESSION_KEY || !TOKEN_KEY) {
+    return NextResponse.json(
+      { success: false, message: "Server configuration error" },
+      { status: 500 }
+    );
+  }
+
+  try {
+    const cookieStore = cookies();
+    const sessionCookie = cookieStore.get(SESSION_KEY);
+
+    if (!sessionCookie || !sessionCookie.value) {
+      return NextResponse.json(
+        { success: false, message: "Unauthorized: No session found" },
+        { status: 401 }
+      );
+    }
+
+    const cekUser = (await decrypt({
+      token: sessionCookie.value,
+      encodedKey: TOKEN_KEY,
+    })) as DecryptedUser | null;
+
+    if (!cekUser || !cekUser.id) {
+      return NextResponse.json(
+        { success: false, message: "Unauthorized: Invalid session" },
+        { status: 401 }
+      );
+    }
+
+    return NextResponse.json(
+      {
+        success: true,
+        message: "User session retrieved successfully",
+        data: { id: cekUser.id },
+      },
+      { status: 200 }
+    );
+  } catch (error) {
+    console.error("Error retrieving user session:", error);
+    return NextResponse.json(
+      {
+        success: false,
+        message: "Error retrieving user session",
+        error: (error as Error).message || "Unknown error",
+      },
+      { status: 500 }
+    );
+  }
+}