finished header notifications

2026-04-04 16:14:56 +07:00
parent b6c5278282
commit 27ca7ddf8e
10 changed files with 346 additions and 162 deletions
@@ -0,0 +1,130 @@
+'use server'
+
+import { getSessionData } from '@/app/actions/session';
+import { API_BASE_URL } from '@/app/actions/definitions';
+
+export interface NotificationBody {
+	createdAt: string | null,
+	id: number,
+	message: string,
+	status: string | null,
+	type: string | null
+}
+
+export async function fetchActiveNotifications() {
+	const token = await getSessionData('token');
+
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
+			method: 'POST',
+			body: JSON.stringify({
+				version: 1,
+				msg_id: 30015,
+				message_body: {
+					action: 'active',
+					authToken: token,
+				}
+			}),
+			headers: {
+				'Content-Type': 'application/json',
+				'Accept': 'application/json'
+			}
+		});
+
+		if (response.ok) {
+			let parsed = await response.json();
+
+			if (parsed?.message_body) {
+				return parsed?.message_body
+			} else {
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+	} catch (error) {
+		return false
+	}
+}
+
+export async function fetchAllNotifications() {
+	const token = await getSessionData('token');
+
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
+			method: 'POST',
+			body: JSON.stringify({
+				version: 1,
+				msg_id: 30015,
+				message_body: {
+					action: 'list',
+					authToken: token,
+					page: 0,
+					size: 10,
+					sortBy: "createdAt",
+					sortDirection: "DESC",
+					types: [], //"SEARCH_RESULT", "MONITORING_RESULT"
+					statuses: [] //"NEW"
+				}
+			}),
+			headers: {
+				'Content-Type': 'application/json',
+				'Accept': 'application/json'
+			}
+		});
+
+		if (response.ok) {
+			let parsed = await response.json();
+
+			if (parsed?.message_body) {
+				return parsed?.message_body
+			} else {
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+	} catch (error) {
+		return false
+	}
+}
+
+export async function notificationsMarkAsRead(ids: number[]) {
+	const token = await getSessionData('token');
+
+	try {
+		const response = await fetch(`${API_BASE_URL}/api/v1/data`, {
+			method: 'POST',
+			body: JSON.stringify({
+				version: 1,
+				msg_id: 30015,
+				message_body: {
+					action: 'markRead',
+					authToken: token,
+					notificationIds: ids
+				}
+			}),
+			headers: {
+				'Content-Type': 'application/json',
+				'Accept': 'application/json'
+			}
+		});
+
+
+		if (response.ok) {
+			let parsed = await response.json();
+
+			if (parsed?.message_body) {
+				return parsed?.message_body
+			} else {
+				throw parsed;
+			}
+		} else {
+			throw (`${response.status}`);
+		}
+	} catch (error) {
+		return {
+			success: false
+		}
+	}
+}