mobile-notification event dan voting #42

Merged
bagasbanuna merged 4 commits from mobile-notification/15-jan-26 into staging 2026-01-15 17:41:58 +08:00
15 changed files with 399 additions and 171 deletions

View File

@@ -2,6 +2,8 @@
All notable changes to this project will be documented in this file. See [commit-and-tag-version](https://github.com/absolute-version/commit-and-tag-version) for commit guidelines. All notable changes to this project will be documented in this file. See [commit-and-tag-version](https://github.com/absolute-version/commit-and-tag-version) for commit guidelines.
## [1.5.36](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.35...v1.5.36) (2026-01-13)
## [1.5.35](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.34...v1.5.35) (2026-01-12) ## [1.5.35](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.34...v1.5.35) (2026-01-12)
## [1.5.34](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.33...v1.5.34) (2026-01-09) ## [1.5.34](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.33...v1.5.34) (2026-01-09)

View File

@@ -1,6 +1,6 @@
{ {
"name": "hipmi", "name": "hipmi",
"version": "1.5.35", "version": "1.5.36",
"private": true, "private": true,
"prisma": { "prisma": {
"seed": "bun prisma/seed.ts" "seed": "bun prisma/seed.ts"

View File

@@ -1,6 +1,15 @@
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import prisma from "@/lib/prisma"; import prisma from "@/lib/prisma";
import _ from "lodash"; import _ from "lodash";
import {
sendNotificationMobileToManyUser,
sendNotificationMobileToOneUser,
} from "@/lib/mobile/notification/send-notification";
import {
NotificationMobileBodyType,
NotificationMobileTitleType,
} from "../../../../../../../types/type-mobile-notification";
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
export { GET, PUT }; export { GET, PUT };
@@ -57,6 +66,8 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
async function PUT(request: Request, { params }: { params: { id: string } }) { async function PUT(request: Request, { params }: { params: { id: string } }) {
const { id } = params; const { id } = params;
const { data } = await request.json(); const { data } = await request.json();
const { catatan, senderId } = data;
const { searchParams } = new URL(request.url); const { searchParams } = new URL(request.url);
const status = searchParams.get("status"); const status = searchParams.get("status");
const fixStatus = _.startCase(status as string); const fixStatus = _.startCase(status as string);
@@ -89,11 +100,23 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
id: id, id: id,
}, },
data: { data: {
catatan: data, catatan: catatan,
eventMaster_StatusId: checkStatus.id, eventMaster_StatusId: checkStatus.id,
}, },
}); });
await sendNotificationMobileToOneUser({
recipientId: updateData.authorId as any,
senderId: senderId,
payload: {
title: "Pengajuan Review Ditolak",
body: "Mohon perbaiki data sesuai catatan penolakan !",
type: "announcement",
kategoriApp: "EVENT",
deepLink: routeUserMobile.eventByStatus({status: "reject"}),
},
});
fixData = updateData; fixData = updateData;
} else if (fixStatus === "Publish") { } else if (fixStatus === "Publish") {
const updateData = await prisma.event.update({ const updateData = await prisma.event.update({
@@ -105,6 +128,38 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
}, },
}); });
await sendNotificationMobileToOneUser({
recipientId: updateData.authorId as any,
senderId: senderId,
payload: {
title: "Review Selesai",
body: "Event kamu telah dipublikasikan !" as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "EVENT",
deepLink: routeUserMobile.eventByStatus({status: "publish"}),
},
});
const adminUsers = await prisma.user.findMany({
where: {
masterUserRoleId: "1",
NOT: { id: updateData.authorId as any },
},
select: { id: true },
});
await sendNotificationMobileToManyUser({
recipientIds: adminUsers.map((user) => user.id),
senderId: senderId,
payload: {
title: "Event Baru" as NotificationMobileTitleType,
body: `${updateData.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "EVENT",
deepLink: routeUserMobile.eventDetailPublised({ id: id }),
},
});
fixData = updateData; fixData = updateData;
} }

View File

@@ -6,7 +6,7 @@ import {
sendNotificationMobileToOneUser, sendNotificationMobileToOneUser,
} from "@/lib/mobile/notification/send-notification"; } from "@/lib/mobile/notification/send-notification";
import { routeUserMobile } from "@/lib/mobile/route-page-mobile"; import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
import { NotificationMobileBodyType } from "../../../../../../../types/type-mobile-notification"; import { NotificationMobileBodyType, NotificationMobileTitleType } from "../../../../../../../types/type-mobile-notification";
export { GET, PUT }; export { GET, PUT };
@@ -110,8 +110,8 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
recipientId: updt.authorId as any, recipientId: updt.authorId as any,
senderId: senderId, senderId: senderId,
payload: { payload: {
title: "Pengajuan Review", title: "Pengajuan Review Ditolak",
body: "Pengajuan data anda telah di tolak !", body: "Mohon perbaiki data sesuai catatan penolakan !",
type: "announcement", type: "announcement",
kategoriApp: "JOB", kategoriApp: "JOB",
deepLink: routeUserMobile.jobByStatus({ status: "reject" }), deepLink: routeUserMobile.jobByStatus({ status: "reject" }),
@@ -143,7 +143,7 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
recipientId: updt.authorId as any, recipientId: updt.authorId as any,
senderId: senderId, senderId: senderId,
payload: { payload: {
title: "Pengajuan Review", title: "Review Selesai",
body: "Selamat data anda telah terpublikasi", body: "Selamat data anda telah terpublikasi",
type: "announcement", type: "announcement",
kategoriApp: "JOB", kategoriApp: "JOB",
@@ -160,7 +160,7 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
recipientIds: adminUsers.map((user) => user.id), recipientIds: adminUsers.map((user) => user.id),
senderId: data.authorId, senderId: data.authorId,
payload: { payload: {
title: "Ada lowongan kerja baru", title: "Ada Lowongan Kerja Baru" as NotificationMobileTitleType,
body: `${updt.title}` as NotificationMobileBodyType, body: `${updt.title}` as NotificationMobileBodyType,
type: "announcement", type: "announcement",
deepLink: routeUserMobile.jobDetailPublised({ id: id }), deepLink: routeUserMobile.jobDetailPublised({ id: id }),

View File

@@ -1,8 +1,17 @@
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import { prisma } from "@/lib"; import { prisma } from "@/lib";
import _ from "lodash"; import _ from "lodash";
import {
sendNotificationMobileToManyUser,
sendNotificationMobileToOneUser,
} from "@/lib/mobile/notification/send-notification";
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
import {
NotificationMobileBodyType,
NotificationMobileTitleType,
} from "../../../../../../../types/type-mobile-notification";
export { GET , PUT}; export { GET, PUT };
async function GET(request: Request, { params }: { params: { id: string } }) { async function GET(request: Request, { params }: { params: { id: string } }) {
const { id } = params; const { id } = params;
@@ -41,12 +50,16 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
async function PUT(request: Request, { params }: { params: { id: string } }) { async function PUT(request: Request, { params }: { params: { id: string } }) {
const { id } = params; const { id } = params;
const { data } = await request.json(); const { data } = await request.json();
const { catatan, senderId } = data;
console.log("catatan", catatan);
console.log("senderId", senderId);
const { searchParams } = new URL(request.url); const { searchParams } = new URL(request.url);
const status = searchParams.get("status"); const status = searchParams.get("status");
const fixStatus = _.startCase(status as string); const fixStatus = _.startCase(status as string);
let fixData; let fixData;
try { try {
const checkStatus = await prisma.voting_Status.findFirst({ const checkStatus = await prisma.voting_Status.findFirst({
where: { where: {
@@ -71,9 +84,23 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
}, },
data: { data: {
voting_StatusId: checkStatus.id, voting_StatusId: checkStatus.id,
catatan: data, catatan: catatan,
}, },
}); });
// SEND NOTIFICATION
await sendNotificationMobileToOneUser({
recipientId: updateStatus.authorId as any,
senderId: senderId,
payload: {
title: "Pengajuan Review Ditolak",
body: "Mohon perbaiki data sesuai catatan penolakan !",
type: "announcement",
kategoriApp: "VOTING",
deepLink: routeUserMobile.votingByStatus({ status: "reject" }),
},
});
fixData = updateStatus; fixData = updateStatus;
} else if (fixStatus === "Publish") { } else if (fixStatus === "Publish") {
const updateStatus = await prisma.voting.update({ const updateStatus = await prisma.voting.update({
@@ -84,6 +111,39 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
voting_StatusId: checkStatus.id, voting_StatusId: checkStatus.id,
}, },
}); });
await sendNotificationMobileToOneUser({
recipientId: updateStatus.authorId as any,
senderId: senderId,
payload: {
title: "Review Selesai",
body: "Voting kamu telah dipublikasikan !" as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "VOTING",
deepLink: routeUserMobile.votingByStatus({ status: "publish" }),
},
});
const adminUsers = await prisma.user.findMany({
where: {
masterUserRoleId: "1",
NOT: { id: updateStatus.authorId as any },
},
select: { id: true },
});
await sendNotificationMobileToManyUser({
recipientIds: adminUsers.map((user) => user.id),
senderId: senderId,
payload: {
title: "Cek Voting Baru Terpublikasi" as NotificationMobileTitleType,
body: `${updateStatus.title}` as NotificationMobileBodyType,
type: "announcement",
kategoriApp: "VOTING",
deepLink: routeUserMobile.votingDetailPublised({ id: id }),
},
});
fixData = updateStatus; fixData = updateStatus;
} }

View File

@@ -1,5 +1,11 @@
import { sendNotificationMobileToOneUser } from "@/lib/mobile/notification/send-notification";
import prisma from "@/lib/prisma"; import prisma from "@/lib/prisma";
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import {
NotificationMobileBodyType,
NotificationMobileTitleType,
} from "../../../../../../../types/type-mobile-notification";
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
export { GET, POST }; export { GET, POST };
@@ -13,18 +19,28 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
eventId: id, eventId: id,
userId: userId, userId: userId,
}, },
// select: {
// Event: {
// select: {
// id: true,
// title: true,
// authorId: true,
// },
// },
// },
}); });
const findEvent = await prisma.event.findUnique({
where: { id: id },
select: { authorId: true, title: true },
});
// SEND NOTIFICATION
if (userId !== findEvent?.authorId) {
await sendNotificationMobileToOneUser({
recipientId: findEvent?.authorId as string,
senderId: userId,
payload: {
title: "Peserta Baru Join" as NotificationMobileTitleType,
body: `Ada peserta baru dalam event: ${findEvent?.title}` as NotificationMobileBodyType,
type: "announcement",
deepLink: routeUserMobile.eventDetailPublised({ id: id }),
kategoriApp: "EVENT",
},
});
}
return NextResponse.json( return NextResponse.json(
{ {
success: true, success: true,

View File

@@ -1,7 +1,10 @@
import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send-notification";
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
import prisma from "@/lib/prisma"; import prisma from "@/lib/prisma";
import _ from "lodash"; import _ from "lodash";
import moment from "moment"; import moment from "moment";
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import { NotificationMobileBodyType } from "../../../../../types/type-mobile-notification";
export { GET, POST }; export { GET, POST };
@@ -30,6 +33,24 @@ async function POST(request: Request) {
}, },
}); });
const adminUsers = await prisma.user.findMany({
where: { masterUserRoleId: "2", NOT: { id: data.authorId } },
select: { id: true },
});
// SEND NOTIFICATION
await sendNotificationMobileToManyUser({
recipientIds: adminUsers.map((user) => user.id),
senderId: data.authorId,
payload: {
title: "Pengajuan Review Baru",
body: create.title as NotificationMobileBodyType,
type: "announcement",
deepLink: routeAdminMobile.eventByStatus({ status: "review" }),
kategoriApp: "EVENT",
},
});
return NextResponse.json( return NextResponse.json(
{ {
success: true, success: true,

View File

@@ -2,6 +2,7 @@ import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile"; import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
import prisma from "@/lib/prisma"; import prisma from "@/lib/prisma";
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import { NotificationMobileBodyType } from "../../../../../types/type-mobile-notification";
export { POST, GET }; export { POST, GET };
@@ -30,8 +31,8 @@ async function POST(request: Request) {
recipientIds: adminUsers.map((user) => user.id), recipientIds: adminUsers.map((user) => user.id),
senderId: data.authorId, senderId: data.authorId,
payload: { payload: {
title: "Pengajuan Review", title: "Pengajuan Review Baru",
body: "Terdapat pengajuan baru yang perlu direview", body: `${create.title}` as NotificationMobileBodyType,
type: "announcement", type: "announcement",
deepLink: routeAdminMobile.jobByStatus({ status: "review" }), deepLink: routeAdminMobile.jobByStatus({ status: "review" }),
kategoriApp: "JOB", kategoriApp: "JOB",

View File

@@ -45,23 +45,38 @@ export async function PUT(
{ params }: { params: { id: string } } { params }: { params: { id: string } }
) { ) {
const { id } = params; const { id } = params;
const { searchParams } = new URL(request.url);
const category = searchParams.get("category");
try { try {
await prisma.notifikasi.update({ if (category === "one") {
where: { await prisma.notifikasi.update({
id: id, where: {
}, id: id,
data: { },
isRead: true, data: {
readAt: new Date(), isRead: true,
}, readAt: new Date(),
}); },
});
} else if (category === "all") {
await prisma.notifikasi.updateMany({
where: {
recipientId: id,
},
data: {
isRead: true,
readAt: new Date(),
},
});
}
return NextResponse.json({ return NextResponse.json({
success: true, success: true,
message: "Notifications marked as read", message: "Notifications marked as read",
}); });
} catch (error) { } catch (error) {
console.error("Error marking notifications as read:", error);
return NextResponse.json( return NextResponse.json(
{ error: (error as Error).message }, { error: (error as Error).message },
{ status: 500 } { status: 500 }
@@ -69,129 +84,129 @@ export async function PUT(
} }
} }
export async function POST( // export async function POST(
request: NextRequest, // request: NextRequest,
{ params }: { params: { id: string } } // { params }: { params: { id: string } }
) { // ) {
const { id } = params; // const { id } = params;
const { data } = await request.json(); // const { data } = await request.json();
const { // const {
title, // title,
body: notificationBody, // body: notificationBody,
userLoginId, // userLoginId,
type, // type,
kategoriApp, // kategoriApp,
appId, // appId,
status, // status,
deepLink, // deepLink,
} = data as NotificationProp; // } = data as NotificationProp;
console.log("Notification Send >>", data); // console.log("Notification Send >>", data);
try { // try {
// Cari user yang login // // Cari user yang login
const findUserLogin = await prisma.user.findUnique({ // const findUserLogin = await prisma.user.findUnique({
where: { // where: {
id: userLoginId, // id: userLoginId,
}, // },
}); // });
if (!findUserLogin) { // if (!findUserLogin) {
return NextResponse.json({ error: "User not found" }, { status: 404 }); // return NextResponse.json({ error: "User not found" }, { status: 404 });
} // }
// Cari token fcm user yang login // // Cari token fcm user yang login
const checkFcmToken = await prisma.tokenUserDevice.findFirst({ // const checkFcmToken = await prisma.tokenUserDevice.findFirst({
where: { // where: {
userId: findUserLogin.id, // userId: findUserLogin.id,
}, // },
}); // });
if (!checkFcmToken) { // if (!checkFcmToken) {
return NextResponse.json( // return NextResponse.json(
{ error: "FCM Token not found" }, // { error: "FCM Token not found" },
{ status: 404 } // { status: 404 }
); // );
} // }
const created = await prisma.notifikasi.create({ // const created = await prisma.notifikasi.create({
data: { // data: {
title, // title,
type, // type,
createdAt: new Date(), // createdAt: new Date(),
appId, // appId,
kategoriApp, // kategoriApp,
pesan: notificationBody || "", // pesan: notificationBody || "",
userRoleId: findUserLogin.masterUserRoleId, // userRoleId: findUserLogin.masterUserRoleId,
status, // status,
deepLink, // deepLink,
senderId: findUserLogin.id, // senderId: findUserLogin.id,
recipientId: id, // recipientId: id,
}, // },
}); // });
if (created) { // if (created) {
const deviceToken = await prisma.tokenUserDevice.findMany({ // const deviceToken = await prisma.tokenUserDevice.findMany({
where: { // where: {
userId: id, // userId: id,
isActive: true, // isActive: true,
}, // },
}); // });
for (let i of deviceToken) { // for (let i of deviceToken) {
const message = { // const message = {
token: i.token, // token: i.token,
notification: { // notification: {
title, // title,
body: notificationBody || "", // body: notificationBody || "",
}, // },
data: { // data: {
sentAt: new Date().toISOString(), // ✅ Simpan metadata di data // sentAt: new Date().toISOString(), // ✅ Simpan metadata di data
id: created.id, // id: created.id,
deepLink: deepLink || "", // deepLink: deepLink || "",
}, // },
// Konfigurasi Android untuk prioritas tinggi // // Konfigurasi Android untuk prioritas tinggi
android: { // android: {
priority: "high" as const, // Kirim secepatnya, bahkan di doze mode untuk notifikasi penting // priority: "high" as const, // Kirim secepatnya, bahkan di doze mode untuk notifikasi penting
notification: { // notification: {
channelId: "default", // Sesuaikan dengan channel yang kamu buat di Android // channelId: "default", // Sesuaikan dengan channel yang kamu buat di Android
}, // },
ttl: 0 as const, // Kirim secepatnya, jangan tunda // ttl: 0 as const, // Kirim secepatnya, jangan tunda
}, // },
// Opsional: tambahkan untuk iOS juga // // Opsional: tambahkan untuk iOS juga
apns: { // apns: {
payload: { // payload: {
aps: { // aps: {
sound: "default" as const, // sound: "default" as const,
// 'content-available': 1 as const, // jika butuh silent push // // 'content-available': 1 as const, // jika butuh silent push
}, // },
}, // },
}, // },
}; // };
try { // try {
const response = await adminMessaging.send(message); // const response = await adminMessaging.send(message);
console.log("✅ FCM sent successfully", "Response:", response); // console.log("✅ FCM sent successfully", "Response:", response);
} catch (error: any) { // } catch (error: any) {
console.error("❌ FCM send failed:", error); // console.error("❌ FCM send failed:", error);
// Lanjutkan ke token berikutnya meski satu gagal // // Lanjutkan ke token berikutnya meski satu gagal
} // }
} // }
} // }
return NextResponse.json({ // return NextResponse.json({
success: true, // success: true,
message: "Notification sent successfully", // message: "Notification sent successfully",
}); // });
} catch (error) { // } catch (error) {
console.error("❌ FCM error:", error); // console.error("❌ FCM error:", error);
return NextResponse.json( // return NextResponse.json(
{ error: (error as Error).message }, // { error: (error as Error).message },
{ status: 500 } // { status: 500 }
); // );
} // }
} // }

View File

@@ -1,6 +1,12 @@
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import prisma from "@/lib/prisma"; import prisma from "@/lib/prisma";
import _ from "lodash"; import _ from "lodash";
import { sendNotificationMobileToOneUser } from "@/lib/mobile/notification/send-notification";
import {
NotificationMobileBodyType,
NotificationMobileTitleType,
} from "../../../../../../types/type-mobile-notification";
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
export { GET, DELETE, PUT, POST }; export { GET, DELETE, PUT, POST };
@@ -39,7 +45,6 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
const listNamaVote = data?.Voting_DaftarNamaVote || []; const listNamaVote = data?.Voting_DaftarNamaVote || [];
for (let v of listNamaVote) { for (let v of listNamaVote) {
const kontributor = await prisma.voting_Kontributor.findMany({ const kontributor = await prisma.voting_Kontributor.findMany({
where: { where: {
voting_DaftarNamaVoteId: v.id, voting_DaftarNamaVoteId: v.id,
@@ -90,7 +95,6 @@ async function DELETE(
}, },
}); });
return NextResponse.json({ return NextResponse.json({
success: true, success: true,
message: "Berhasil menghapus data", message: "Berhasil menghapus data",
@@ -171,7 +175,6 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
}, },
}); });
if (!updateVoting) if (!updateVoting)
return NextResponse.json({ status: 400, message: "Gagal Update" }); return NextResponse.json({ status: 400, message: "Gagal Update" });
} }
@@ -193,11 +196,12 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
async function POST(request: Request, { params }: { params: { id: string } }) { async function POST(request: Request, { params }: { params: { id: string } }) {
const { id } = params; const { id } = params;
const { data } = await request.json(); const { data } = await request.json();
const { chooseId, userId } = data;
try { try {
const findData = await prisma.voting_DaftarNamaVote.findFirst({ const findDatapilihan = await prisma.voting_DaftarNamaVote.findFirst({
where: { where: {
id: data.chooseId, id: chooseId,
}, },
select: { select: {
jumlah: true, jumlah: true,
@@ -205,28 +209,32 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
}, },
}); });
if (!findData) if (!findDatapilihan)
return NextResponse.json({ return NextResponse.json({
success: false, success: false,
message: "Data tidak ditemukan", message: "Data tidak ditemukan",
}); });
const updateData = await prisma.voting_DaftarNamaVote.update({ const updateDataPilihan = await prisma.voting_DaftarNamaVote.update({
where: { where: {
id: data.chooseId, id: data.chooseId,
}, },
data: { data: {
jumlah: findData.jumlah + 1, jumlah: findDatapilihan.jumlah + 1,
}, },
}); });
if (!updateDataPilihan)
if (!updateData)
return NextResponse.json({ return NextResponse.json({
success: false, success: false,
message: "Gagal Update Data", message: "Gagal Update Data",
}); });
const findVotingData = await prisma.voting.findUnique({
where: { id: id },
select: { authorId: true, title: true },
});
const createKontributor = await prisma.voting_Kontributor.create({ const createKontributor = await prisma.voting_Kontributor.create({
data: { data: {
votingId: id, votingId: id,
@@ -250,6 +258,21 @@ async function POST(request: Request, { params }: { params: { id: string } }) {
message: "Gagal Menjadi Kontributor", message: "Gagal Menjadi Kontributor",
}); });
// SEND NOTIFICATION
if (userId !== findVotingData?.authorId) {
await sendNotificationMobileToOneUser({
recipientId: findVotingData?.authorId as string,
senderId: userId,
payload: {
title: "User Melakukan Vote" as NotificationMobileTitleType,
body: `Salah satu user telah melakukan voting pada: ${findVotingData?.title}` as NotificationMobileBodyType,
type: "announcement",
deepLink: routeUserMobile.votingDetailPublised({ id: id }),
kategoriApp: "VOTING",
},
});
}
return NextResponse.json({ return NextResponse.json({
success: true, success: true,
message: "Berhasil Voting", message: "Berhasil Voting",

View File

@@ -1,6 +1,9 @@
import { NextResponse } from "next/server"; import { NextResponse } from "next/server";
import prisma from "@/lib/prisma"; import prisma from "@/lib/prisma";
import _ from "lodash"; import _ from "lodash";
import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send-notification";
import { NotificationMobileBodyType } from "../../../../../types/type-mobile-notification";
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
export { POST, GET }; export { POST, GET };
@@ -41,6 +44,24 @@ async function POST(request: Request) {
}); });
} }
const adminUsers = await prisma.user.findMany({
where: { masterUserRoleId: "2", NOT: { id: data.authorId } },
select: { id: true },
});
// SEND NOTIFICATION
await sendNotificationMobileToManyUser({
recipientIds: adminUsers.map((user) => user.id),
senderId: data.authorId,
payload: {
title: "Pengajuan Review Baru",
body: create.title as NotificationMobileBodyType,
type: "announcement",
deepLink: routeAdminMobile.votingByStatus({ status: "review" }),
kategoriApp: "VOTING",
},
});
return NextResponse.json( return NextResponse.json(
{ {
success: true, success: true,
@@ -125,8 +146,6 @@ async function GET(request: Request) {
}); });
fixData = data; fixData = data;
} else if (category === "contribution") { } else if (category === "contribution") {
const data = await prisma.voting_Kontributor.findMany({ const data = await prisma.voting_Kontributor.findMany({
orderBy: { orderBy: {

View File

@@ -1,13 +1,13 @@
[ [
{ {
"name": "default_user", "name": "demo_user",
"nomor": "6282340374412", "nomor": "6282340374412",
"masterUserRoleId": "1", "masterUserRoleId": "1",
"active": true, "active": true,
"termsOfServiceAccepted": false "termsOfServiceAccepted": false
}, },
{ {
"name": "admin_911", "name": "demo_admin",
"nomor": "6281339158911", "nomor": "6281339158911",
"masterUserRoleId": "3", "masterUserRoleId": "3",
"active": true, "active": true,

View File

@@ -43,7 +43,7 @@ export async function sendNotificationMobileToOneUser({
// 2. Ambil semua token aktif milik penerima // 2. Ambil semua token aktif milik penerima
const tokens = await prisma.tokenUserDevice.findMany({ const tokens = await prisma.tokenUserDevice.findMany({
where: { userId: recipientId, isActive: true }, where: { userId: recipientId },
select: { token: true, id: true }, select: { token: true, id: true },
}); });
@@ -53,7 +53,6 @@ export async function sendNotificationMobileToOneUser({
} }
// 3. Kirim FCM ke semua token // 3. Kirim FCM ke semua token
await Promise.allSettled( await Promise.allSettled(
tokens.map(async ({ token, id }) => { tokens.map(async ({ token, id }) => {
try { try {
@@ -80,12 +79,11 @@ export async function sendNotificationMobileToOneUser({
}); });
} catch (fcmError: any) { } catch (fcmError: any) {
// Hapus token jika invalid // Hapus token jika invalid
console.log("fcmError", fcmError); if (fcmError.code === "messaging/registration-token-not-registered") {
if (fcmError.code === "messaging/invalid-registration-token") { // Hapus token dari DB
await prisma.tokenUserDevice.delete({ where: { id: id } }); await prisma.tokenUserDevice.delete({ where: { id } });
console.log(` Invalid token removed: ${token}`); console.log(`🗑️ Invalid token removed: ${id}`);
} }
console.error(`FCM failed for token ${token}:`, fcmError.message);
} }
}) })
); );

View File

@@ -5,16 +5,32 @@ type StatusApp = "review" | "draft" | "reject" | "publish";
const routeAdminMobile = { const routeAdminMobile = {
userAccess: ({ id }: { id: string }) => `/admin/user-access/${id}`, userAccess: ({ id }: { id: string }) => `/admin/user-access/${id}`,
// JOB // JOB
jobDetail: ({ id, status }: { id: string; status: StatusApp }) =>
`/admin/job/${id}/${status}`,
jobByStatus: ({ status }: { status: StatusApp }) => jobByStatus: ({ status }: { status: StatusApp }) =>
`/admin/job/${status}/status`, `/admin/job/${status}/status`,
// EVENT
eventByStatus: ({ status }: { status: StatusApp }) =>
`/admin/event/${status}/status`,
// VOTING
votingByStatus: ({ status }: { status: StatusApp }) =>
`/admin/voting/${status}/status`,
}; };
const routeUserMobile = { const routeUserMobile = {
home: `/(user)/home`, home: `/(user)/home`,
// JOB // JOB
jobDetailPublised: ({ id }: { id: string }) => `/job/${id}`,
jobByStatus: ({ status }: { status?: StatusApp }) => jobByStatus: ({ status }: { status?: StatusApp }) =>
`/job/(tabs)/status?status=${status}`, `/job/(tabs)/status?status=${status}`,
jobDetailPublised: ({ id }: { id: string }) => `/job/${id}`,
// EVENT
eventByStatus: ({ status }: { status?: StatusApp }) =>
`/event/(tabs)/status?status=${status}`,
eventDetailPublised: ({ id }: { id: string }) => `/event/${id}/publish`,
// VOTING
votingByStatus: ({ status }: { status?: StatusApp }) =>
`/voting/(tabs)/status?status=${status}`,
votingDetailPublised: ({ id }: { id: string }) => `/voting/${id}`,
}; };

View File

@@ -13,18 +13,20 @@ export type NotificationMobilePayload = {
export type NotificationMobileTitleType = export type NotificationMobileTitleType =
| (string & { __type: "NotificationMobileTitleType" }) | (string & { __type: "NotificationMobileTitleType" })
| "Pengajuan Review" // Admin
| "Pengajuan Review Baru"
// USER
| "Pengajuan Review Ditolak"
| "Review Selesai" | "Review Selesai"
// to ALL user // to ALL user
| "Ada lowongan kerja baru"
export type NotificationMobileBodyType = export type NotificationMobileBodyType =
// USER // USER
| (string & { __type: "NotificationMobileBodyType" }) | (string & { __type: "NotificationMobileBodyType" })
| "Terdapat pengajuan baru yang perlu direview" | "Ada pengajuan review" // tambah title
// ADMIN // ADMIN
| "Pengajuan data anda telah di tolak !" | "Mohon perbaiki data sesuai catatan penolakan !"
| "Selamat data anda telah terpublikasi" | "Selamat data anda telah terpublikasi"
export type TypeNotificationCategoryApp = export type TypeNotificationCategoryApp =