Penerapaan ke database untuk token device

Add:
src/app/api/mobile/auth/device-tokens/[id]/

Fix:
modified:   src/app/api/mobile/auth/device-tokens/route.ts
modified:   src/app/api/mobile/notifications/route.ts

### No Issue
This commit is contained in:
2025-12-17 17:40:56 +08:00
parent 3e0d2743fb
commit 02b25ffc84
3 changed files with 95 additions and 18 deletions

View File

@@ -0,0 +1,44 @@
import { NextRequest, NextResponse } from "next/server";
import { prisma } from "@/lib";
export { DELETE };
async function DELETE(
request: NextRequest,
{ params }: { params: { id: string } }
) {
const { id } = params;
try {
const findFirst = await prisma.tokenUserDevice.findFirst({
where: {
userId: id,
},
});
if (!findFirst) {
return NextResponse.json({
success: false,
message: "User tidak ditemukan !",
});
}
const deleted = await prisma.tokenUserDevice.delete({
where: {
id: findFirst.id,
},
});
console.log("DEL", deleted);
return NextResponse.json({
success: true,
message: "Berhasil menghapus device token user",
});
} catch (error) {
console.log("ERROR", error);
return NextResponse.json(
{ error: (error as Error).message, message: "Terjadi error pada API" },
{ status: 500 }
);
}
}

View File

@@ -1,13 +1,14 @@
import { NextRequest, NextResponse } from "next/server";
import { prisma } from "@/lib";
export async function POST(request: NextRequest) {
export { POST, GET };
async function POST(request: NextRequest) {
const { data } = await request.json();
try {
console.log("Data >>", JSON.stringify(data, null, 2));
const { userId, platform, deviceId, model, appVersion, fcmToken } =
data;
const { userId, platform, deviceId, model, appVersion, fcmToken } = data;
if (!fcmToken) {
return NextResponse.json({ error: "Missing Token" }, { status: 400 });
@@ -62,3 +63,22 @@ export async function POST(request: NextRequest) {
);
}
}
async function GET(request: NextRequest) {
try {
const data = await prisma.tokenUserDevice.findMany({
where: {
isActive: true,
},
});
return NextResponse.json({ success: true, data });
} catch (error) {
return NextResponse.json(
{ error: (error as Error).message },
{ status: 500 }
);
}
}

View File

@@ -5,7 +5,7 @@ import { NextRequest, NextResponse } from "next/server";
export async function POST(request: NextRequest) {
try {
const { data } = await request.json();
const { fcmToken, title, body: notificationBody } = data;
const { fcmToken, title, body: notificationBody, userLoginId } = data;
console.log("Data Notifikasi >>", data);
@@ -16,8 +16,18 @@ export async function POST(request: NextRequest) {
);
}
const deviceToken = await prisma.tokenUserDevice.findMany({
where: {
isActive: true,
NOT: {
userId: userLoginId,
},
},
});
for (let i of deviceToken) {
const message = {
token: fcmToken,
token: i.token,
notification: {
title,
body: notificationBody || "",
@@ -27,13 +37,16 @@ export async function POST(request: NextRequest) {
// contoh: senderId, type, etc.
},
};
console.log("[MSG]", message);
const response = await adminMessaging.send(message);
console.log("✅ FCM sent:", response);
}
return NextResponse.json({ success: true, messageId: response });
return NextResponse.json({
success: true,
message: "Notification sent successfully",
});
} catch (error: any) {
console.error("❌ FCM error:", error);
return NextResponse.json(