From 2d9235070856c0a5032ddf47f7b1dc7cc5cceb60 Mon Sep 17 00:00:00 2001 From: Fuwn Date: Thu, 25 Jul 2024 00:19:44 -0700 Subject: refactor(Database): separate providers --- src/lib/Database/Supabase/userNotifications.ts | 32 ++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 src/lib/Database/Supabase/userNotifications.ts (limited to 'src/lib/Database/Supabase/userNotifications.ts') diff --git a/src/lib/Database/Supabase/userNotifications.ts b/src/lib/Database/Supabase/userNotifications.ts new file mode 100644 index 00000000..48cd73c9 --- /dev/null +++ b/src/lib/Database/Supabase/userNotifications.ts @@ -0,0 +1,32 @@ +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 deleteUserSubscription = async (userId: number) => + await supabase.from('user_notifications').delete().eq('user_id', userId); + +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' } + ); -- cgit v1.2.3