Compare commits
23 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 8f3f27122a | |||
| d84a1d84ff | |||
| 40ba31edec | |||
| a54f8599b4 | |||
| 09825756f3 | |||
| 2086692897 | |||
| 87515ae19f | |||
| 3552cf4f39 | |||
| d207b6feed | |||
| f1c8432fdc | |||
| 1cd4c3713e | |||
| 4307b383e3 | |||
| 0786d23336 | |||
| cb3511f973 | |||
| b4921c4e82 | |||
| a9325054eb | |||
| 819812149f | |||
| 75ba2b29ae | |||
| 54a4d15bdd | |||
| 1321f33da9 | |||
| fad0c33b9a | |||
| 565bab4998 | |||
| 7530a38c4d |
@@ -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.
|
||||
|
||||
## [1.5.34](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.33...v1.5.34) (2026-01-09)
|
||||
|
||||
## [1.5.33](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.32...v1.5.33) (2026-01-06)
|
||||
|
||||
## [1.5.32](https://wibugit.wibudev.com/wibu/hipmi/compare/v1.5.31...v1.5.32) (2026-01-05)
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "hipmi",
|
||||
"version": "1.5.33",
|
||||
"version": "1.5.34",
|
||||
"private": true,
|
||||
"prisma": {
|
||||
"seed": "bun prisma/seed.ts"
|
||||
|
||||
54
src/app/api/auth/mobile-eula/route.tsx
Normal file
54
src/app/api/auth/mobile-eula/route.tsx
Normal file
@@ -0,0 +1,54 @@
|
||||
import { prisma } from "@/lib";
|
||||
import { NextResponse } from "next/server";
|
||||
|
||||
export async function POST(req: Request) {
|
||||
try {
|
||||
const { nomor } = await req.json();
|
||||
|
||||
const user = await prisma.user.findUnique({
|
||||
where: {
|
||||
nomor: nomor,
|
||||
},
|
||||
});
|
||||
|
||||
if (!user)
|
||||
return NextResponse.json({
|
||||
success: false,
|
||||
message: "User belum terdaftar",
|
||||
status: 404,
|
||||
});
|
||||
|
||||
const updateTerms = await prisma.user.update({
|
||||
where: { nomor: nomor },
|
||||
data: {
|
||||
termsOfServiceAccepted: true,
|
||||
acceptedTermsAt: new Date(),
|
||||
},
|
||||
});
|
||||
|
||||
if (!updateTerms) {
|
||||
return NextResponse.json({
|
||||
success: false,
|
||||
message: "Gagal setujui syarat dan ketentuan",
|
||||
status: 400,
|
||||
});
|
||||
}
|
||||
|
||||
return NextResponse.json(
|
||||
{
|
||||
success: true,
|
||||
message: "Anda telah setujui syarat dan ketentuan",
|
||||
},
|
||||
{ status: 200 }
|
||||
);
|
||||
} catch (error) {
|
||||
return NextResponse.json(
|
||||
{
|
||||
success: false,
|
||||
message: "Terjadi masalah saat setujui syarat dan ketentuan",
|
||||
reason: error as Error,
|
||||
},
|
||||
{ status: 500 }
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -6,7 +6,6 @@ export async function POST(req: Request) {
|
||||
try {
|
||||
const codeOtp = randomOTP();
|
||||
const body = await req.json();
|
||||
console.log("[Masuk API]", body);
|
||||
const { nomor } = body;
|
||||
|
||||
const user = await prisma.user.findUnique({
|
||||
@@ -15,9 +14,6 @@ export async function POST(req: Request) {
|
||||
},
|
||||
});
|
||||
|
||||
console.log(["cek user", user]);
|
||||
console.log(["cek nomor", nomor]);
|
||||
|
||||
if (!user)
|
||||
return NextResponse.json({
|
||||
success: false,
|
||||
@@ -66,6 +62,7 @@ export async function POST(req: Request) {
|
||||
success: true,
|
||||
message: "Kode verifikasi terkirim",
|
||||
kodeId: createOtpId.id,
|
||||
isAcceptTerms: user.termsOfServiceAccepted,
|
||||
},
|
||||
{ status: 200 }
|
||||
);
|
||||
|
||||
@@ -85,9 +85,8 @@ export async function POST(req: Request) {
|
||||
// =========== START SEND NOTIFICATION =========== //
|
||||
|
||||
const findAllUserBySendTo = await prisma.user.findMany({
|
||||
where: {
|
||||
masterUserRoleId: "2",
|
||||
},
|
||||
where: { masterUserRoleId: "2" },
|
||||
select: { id: true },
|
||||
});
|
||||
|
||||
console.log("Users to notify:", findAllUserBySendTo);
|
||||
|
||||
@@ -1,6 +1,12 @@
|
||||
import { NextResponse } from "next/server";
|
||||
import prisma from "@/lib/prisma";
|
||||
import _ from "lodash";
|
||||
import {
|
||||
sendNotificationMobileToManyUser,
|
||||
sendNotificationMobileToOneUser,
|
||||
} from "@/lib/mobile/notification/send-notification";
|
||||
import { routeUserMobile } from "@/lib/mobile/route-page-mobile";
|
||||
import { NotificationMobileBodyType } from "../../../../../../../types/type-mobile-notification";
|
||||
|
||||
export { GET, PUT };
|
||||
|
||||
@@ -54,6 +60,9 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||
const { id } = params;
|
||||
const { data } = await request.json();
|
||||
|
||||
const { catatan, senderId } = data;
|
||||
|
||||
const { searchParams } = new URL(request.url);
|
||||
const status = searchParams.get("status");
|
||||
const fixStatus = _.startCase(status as string);
|
||||
@@ -83,7 +92,7 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||
},
|
||||
data: {
|
||||
masterStatusId: checkStatus.id,
|
||||
catatan: data,
|
||||
catatan: catatan,
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
@@ -97,6 +106,18 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||
},
|
||||
});
|
||||
|
||||
await sendNotificationMobileToOneUser({
|
||||
recipientId: updt.authorId as any,
|
||||
senderId: senderId,
|
||||
payload: {
|
||||
title: "Pengajuan Review",
|
||||
body: "Pengajuan data anda telah di tolak !",
|
||||
type: "announcement",
|
||||
kategoriApp: "JOB",
|
||||
deepLink: routeUserMobile.jobByStatus({ status: "reject" }),
|
||||
},
|
||||
});
|
||||
|
||||
fixData = updt;
|
||||
} else if (fixStatus === "Publish") {
|
||||
const updt = await prisma.job.update({
|
||||
@@ -118,6 +139,35 @@ async function PUT(request: Request, { params }: { params: { id: string } }) {
|
||||
},
|
||||
});
|
||||
|
||||
await sendNotificationMobileToOneUser({
|
||||
recipientId: updt.authorId as any,
|
||||
senderId: senderId,
|
||||
payload: {
|
||||
title: "Pengajuan Review",
|
||||
body: "Selamat data anda telah terpublikasi",
|
||||
type: "announcement",
|
||||
kategoriApp: "JOB",
|
||||
deepLink: routeUserMobile.jobByStatus({ status: "publish" }),
|
||||
},
|
||||
});
|
||||
|
||||
const adminUsers = await prisma.user.findMany({
|
||||
where: { masterUserRoleId: "1", NOT: { id: updt.authorId as any } },
|
||||
select: { id: true },
|
||||
});
|
||||
|
||||
await sendNotificationMobileToManyUser({
|
||||
recipientIds: adminUsers.map((user) => user.id),
|
||||
senderId: data.authorId,
|
||||
payload: {
|
||||
title: "Ada lowongan kerja baru",
|
||||
body: `${updt.title}` as NotificationMobileBodyType,
|
||||
type: "announcement",
|
||||
deepLink: routeUserMobile.jobDetailPublised({ id: id }),
|
||||
kategoriApp: "JOB",
|
||||
},
|
||||
});
|
||||
|
||||
fixData = updt;
|
||||
}
|
||||
|
||||
|
||||
@@ -13,6 +13,7 @@ async function GET(request: Request, { params }: { params: { id: string } }) {
|
||||
include: {
|
||||
Author: {
|
||||
select: {
|
||||
id: true,
|
||||
username: true,
|
||||
nomor: true,
|
||||
Profile: {
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
import { sendNotificationMobileToManyUser } from "@/lib/mobile/notification/send-notification";
|
||||
import { routeAdminMobile } from "@/lib/mobile/route-page-mobile";
|
||||
import prisma from "@/lib/prisma";
|
||||
import { NextResponse } from "next/server";
|
||||
|
||||
@@ -17,6 +19,25 @@ async function POST(request: Request) {
|
||||
},
|
||||
});
|
||||
|
||||
// kirim notifikasi ke semua admin untuk mengetahui ada job baru yang harus di review
|
||||
|
||||
const adminUsers = await prisma.user.findMany({
|
||||
where: { masterUserRoleId: "2", NOT: { id: data.authorId } },
|
||||
select: { id: true },
|
||||
});
|
||||
|
||||
await sendNotificationMobileToManyUser({
|
||||
recipientIds: adminUsers.map((user) => user.id),
|
||||
senderId: data.authorId,
|
||||
payload: {
|
||||
title: "Pengajuan Review",
|
||||
body: "Terdapat pengajuan baru yang perlu direview",
|
||||
type: "announcement",
|
||||
deepLink: routeAdminMobile.jobByStatus({ status: "review" }),
|
||||
kategoriApp: "JOB",
|
||||
},
|
||||
});
|
||||
|
||||
return NextResponse.json(
|
||||
{
|
||||
success: true,
|
||||
@@ -54,10 +75,10 @@ async function GET(request: Request) {
|
||||
MasterStatus: {
|
||||
name: "Publish",
|
||||
},
|
||||
// title: {
|
||||
// contains: search || "",
|
||||
// mode: "insensitive",
|
||||
// },
|
||||
// title: {
|
||||
// contains: search || "",
|
||||
// mode: "insensitive",
|
||||
// },
|
||||
},
|
||||
orderBy: {
|
||||
createdAt: "desc",
|
||||
@@ -90,46 +111,46 @@ async function GET(request: Request) {
|
||||
|
||||
fixData = data;
|
||||
} else if (category === "beranda") {
|
||||
const data = await prisma.job.findMany({
|
||||
where: {
|
||||
isActive: true,
|
||||
isArsip: false,
|
||||
MasterStatus: {
|
||||
name: "Publish",
|
||||
},
|
||||
title: {
|
||||
contains: search || "",
|
||||
mode: "insensitive",
|
||||
},
|
||||
},
|
||||
orderBy: {
|
||||
createdAt: "desc",
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
title: true,
|
||||
deskripsi: true,
|
||||
authorId: true,
|
||||
MasterStatus: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
Author: {
|
||||
select: {
|
||||
id: true,
|
||||
username: true,
|
||||
Profile: {
|
||||
select: {
|
||||
id: true,
|
||||
name: true,
|
||||
imageId: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
});
|
||||
const data = await prisma.job.findMany({
|
||||
where: {
|
||||
isActive: true,
|
||||
isArsip: false,
|
||||
MasterStatus: {
|
||||
name: "Publish",
|
||||
},
|
||||
title: {
|
||||
contains: search || "",
|
||||
mode: "insensitive",
|
||||
},
|
||||
},
|
||||
orderBy: {
|
||||
createdAt: "desc",
|
||||
},
|
||||
select: {
|
||||
id: true,
|
||||
title: true,
|
||||
deskripsi: true,
|
||||
authorId: true,
|
||||
MasterStatus: {
|
||||
select: {
|
||||
name: true,
|
||||
},
|
||||
},
|
||||
Author: {
|
||||
select: {
|
||||
id: true,
|
||||
username: true,
|
||||
Profile: {
|
||||
select: {
|
||||
id: true,
|
||||
name: true,
|
||||
imageId: true,
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
fixData = data;
|
||||
}
|
||||
|
||||
118
src/lib/mobile/notification/send-notification.ts
Normal file
118
src/lib/mobile/notification/send-notification.ts
Normal file
@@ -0,0 +1,118 @@
|
||||
// lib/notifications/send-notification.ts
|
||||
import { adminMessaging } from "@/lib/firebase-admin";
|
||||
import prisma from "@/lib/prisma";
|
||||
import { NotificationMobilePayload } from "../../../../types/type-mobile-notification";
|
||||
import _ from "lodash";
|
||||
|
||||
/**
|
||||
* Kirim notifikasi ke satu user (semua device aktifnya)
|
||||
* @param recipientId - ID penerima
|
||||
* @param senderId - ID pengirim
|
||||
* @param payload - Data notifikasi
|
||||
*/
|
||||
|
||||
export async function sendNotificationMobileToOneUser({
|
||||
recipientId,
|
||||
senderId,
|
||||
payload,
|
||||
}: {
|
||||
recipientId: string;
|
||||
senderId: string;
|
||||
payload: NotificationMobilePayload;
|
||||
}) {
|
||||
try {
|
||||
const kategoriToNormalCase = _.lowerCase(payload.kategoriApp);
|
||||
const titleFix = `${_.startCase(kategoriToNormalCase)}: ${payload.title}`;
|
||||
console.log("titleFix", titleFix);
|
||||
|
||||
// 1. Simpan notifikasi ke DB
|
||||
const notification = await prisma.notifikasi.create({
|
||||
data: {
|
||||
title: titleFix,
|
||||
pesan: payload.body,
|
||||
deepLink: payload.deepLink,
|
||||
kategoriApp: payload.kategoriApp,
|
||||
recipientId: recipientId,
|
||||
senderId: senderId,
|
||||
type: payload.type.trim(),
|
||||
},
|
||||
});
|
||||
|
||||
// 2. Ambil semua token aktif milik penerima
|
||||
const tokens = await prisma.tokenUserDevice.findMany({
|
||||
where: { userId: recipientId, isActive: true },
|
||||
select: { token: true, id: true },
|
||||
});
|
||||
|
||||
if (tokens.length === 0) {
|
||||
console.warn(`No active tokens found for user ${recipientId}`);
|
||||
return;
|
||||
}
|
||||
|
||||
// 3. Kirim FCM ke semua token
|
||||
|
||||
await Promise.allSettled(
|
||||
tokens.map(async ({ token, id }) => {
|
||||
try {
|
||||
await adminMessaging.send({
|
||||
token,
|
||||
notification: {
|
||||
title: titleFix,
|
||||
body: payload.body,
|
||||
},
|
||||
data: {
|
||||
sentAt: new Date().toISOString(), // ✅ Simpan metadata di data
|
||||
id: notification.id,
|
||||
deepLink: payload.deepLink,
|
||||
recipientId: recipientId,
|
||||
},
|
||||
android: {
|
||||
priority: "high" as const,
|
||||
notification: { channelId: "default" },
|
||||
ttl: 0 as const,
|
||||
},
|
||||
apns: {
|
||||
payload: { aps: { sound: "default" as const } },
|
||||
},
|
||||
});
|
||||
} catch (fcmError: any) {
|
||||
// Hapus token jika invalid
|
||||
console.log("fcmError", fcmError);
|
||||
if (fcmError.code === "messaging/invalid-registration-token") {
|
||||
await prisma.tokenUserDevice.delete({ where: { id: id } });
|
||||
console.log(`❌ Invalid token removed: ${token}`);
|
||||
}
|
||||
console.error(`FCM failed for token ${token}:`, fcmError.message);
|
||||
}
|
||||
})
|
||||
);
|
||||
|
||||
console.log(`✅ Notification sent to user ${recipientId}`);
|
||||
} catch (error) {
|
||||
console.error("Failed to send notification:", error);
|
||||
throw error; // biarkan caller handle error
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Kirim notifikasi ke banyak user
|
||||
*/
|
||||
export async function sendNotificationMobileToManyUser({
|
||||
recipientIds,
|
||||
senderId,
|
||||
payload,
|
||||
}: {
|
||||
recipientIds: string[];
|
||||
senderId: string;
|
||||
payload: NotificationMobilePayload;
|
||||
}) {
|
||||
await Promise.allSettled(
|
||||
recipientIds.map((id) =>
|
||||
sendNotificationMobileToOneUser({
|
||||
recipientId: id,
|
||||
senderId: senderId,
|
||||
payload: payload,
|
||||
})
|
||||
)
|
||||
);
|
||||
}
|
||||
20
src/lib/mobile/route-page-mobile.ts
Normal file
20
src/lib/mobile/route-page-mobile.ts
Normal file
@@ -0,0 +1,20 @@
|
||||
export { routeAdminMobile, routeUserMobile };
|
||||
|
||||
type StatusApp = "review" | "draft" | "reject" | "publish";
|
||||
|
||||
const routeAdminMobile = {
|
||||
userAccess: ({ id }: { id: string }) => `/admin/user-access/${id}`,
|
||||
// JOB
|
||||
jobDetail: ({ id, status }: { id: string; status: StatusApp }) =>
|
||||
`/admin/job/${id}/${status}`,
|
||||
jobByStatus: ({ status }: { status: StatusApp }) =>
|
||||
`/admin/job/${status}/status`,
|
||||
};
|
||||
|
||||
const routeUserMobile = {
|
||||
home: `/(user)/home`,
|
||||
// JOB
|
||||
jobDetailPublised: ({ id }: { id: string }) => `/job/${id}`,
|
||||
jobByStatus: ({ status }: { status?: StatusApp }) =>
|
||||
`/job/(tabs)/status?status=${status}`,
|
||||
};
|
||||
38
types/type-mobile-notification.ts
Normal file
38
types/type-mobile-notification.ts
Normal file
@@ -0,0 +1,38 @@
|
||||
// Jika semua custom type diawali "custom_"
|
||||
|
||||
export type NotificationMobilePayload = {
|
||||
title: NotificationMobileTitleType;
|
||||
body: NotificationMobileBodyType;
|
||||
userLoginId?: string;
|
||||
appId?: string;
|
||||
status?: string;
|
||||
type: "announcement" | "trigger";
|
||||
deepLink: string;
|
||||
kategoriApp: TypeNotificationCategoryApp;
|
||||
};
|
||||
|
||||
export type NotificationMobileTitleType =
|
||||
| (string & { __type: "NotificationMobileTitleType" })
|
||||
| "Pengajuan Review"
|
||||
| "Review Selesai"
|
||||
// to ALL user
|
||||
| "Ada lowongan kerja baru"
|
||||
|
||||
export type NotificationMobileBodyType =
|
||||
// USER
|
||||
| (string & { __type: "NotificationMobileBodyType" })
|
||||
| "Terdapat pengajuan baru yang perlu direview"
|
||||
|
||||
// ADMIN
|
||||
| "Pengajuan data anda telah di tolak !"
|
||||
| "Selamat data anda telah terpublikasi"
|
||||
|
||||
export type TypeNotificationCategoryApp =
|
||||
| "EVENT"
|
||||
| "JOB"
|
||||
| "VOTING"
|
||||
| "DONASI"
|
||||
| "INVESTASI"
|
||||
| "COLLABORATION"
|
||||
| "FORUM"
|
||||
| "OTHER";
|
||||
Reference in New Issue
Block a user