feat: background notifications

3 files changed, 74 insertions, 0 deletions

diff --git a/src/lib/Database/user.ts b/src/lib/Database/user.ts
new file mode 100644
index 00000000..df68bc91
--- /dev/null
+++ b/src/lib/Database/user.ts
@@ -0,0 +1,23 @@
+import { type AniListAuthorisation } from '$lib/Data/AniList/identity';
+import Dexie, { type Table } from 'dexie';
+
+export interface User {
+	id: number;
+	user: AniListAuthorisation;
+	lastNotificationID: number | null;
+}
+
+export class UserDatabase extends Dexie {
+	users: Table<User>;
+
+	constructor() {
+		super('users');
+		this.version(1).stores({
+			users: 'id, user, lastNotificationID'
+		});
+
+		this.users = this.table('users');
+	}
+}
+
+export const database = new UserDatabase();
diff --git a/src/lib/Database/userNotifications.ts b/src/lib/Database/userNotifications.ts
new file mode 100644
index 00000000..c61c2aa7
--- /dev/null
+++ b/src/lib/Database/userNotifications.ts
@@ -0,0 +1,29 @@
+import supabase from './supabase';
+
+export interface UserNotifications {
+	created_at: string;
+	updated_at: string;
+	user_id: number;
+	subscription: JSON;
+}
+
+export const getUserSubscription = async (userId: number) =>
+	await supabase.from('user_notifications').select('*').eq('user_id', userId);
+
+export const getUserSubscriptions = async () => {
+	const { data, error } = await supabase.from('user_notifications').select('*');
+
+	if (error) return [];
+
+	return data as UserNotifications[];
+};
+
+export const setUserSubscription = async (userId: number, subscription: JSON) =>
+	await supabase.from('user_notifications').upsert(
+		{
+			user_id: userId,
+			updated_at: new Date().toISOString(),
+			subscription: subscription
+		},
+		{ onConflict: 'user_id' }
+	);
diff --git a/src/lib/Utility/notifications.ts b/src/lib/Utility/notifications.ts
new file mode 100644
index 00000000..fe174bd6
--- /dev/null
+++ b/src/lib/Utility/notifications.ts
@@ -0,0 +1,22 @@
+import { env } from '$env/dynamic/public';
+import root from './root';
+
+export const requestNotifications = async () => {
+	if ('Notification' in window && navigator.serviceWorker)
+		if ((await Notification.requestPermission()) === 'granted') {
+			const pushSubscription = await (
+				await navigator.serviceWorker.ready
+			).pushManager.subscribe({
+				userVisibleOnly: true,
+				applicationServerKey: env.PUBLIC_VAPID_PUBLIC_KEY
+			});
+
+			await fetch(root('/api/notifications/subscribe'), {
+				method: 'POST',
+				headers: {
+					'Content-Type': 'application/json'
+				},
+				body: JSON.stringify(pushSubscription)
+			});
+		}
+};