import sb from '../../sb';

export interface UserNotifications {
  created_at: string;
  updated_at: string;
  user_id: number;
  subscription: JSON;
  fingerprint: string;
}

export const getUserSubscription = async (userId: number) =>
  await sb.from('user_notifications').select('*').eq('user_id', userId);

export const getUserSubscriptions = async () => {
  const { data, error } = await sb.from('user_notifications').select('*');

  if (error) return [];

  return data as UserNotifications[];
};

export const deleteUserSubscription = async (userId: number, fingerprint: string) =>
  await sb.from('user_notifications').delete().eq('user_id', userId).eq('fingerprint', fingerprint);

export const setUserSubscription = async (
  userId: number,
  subscription: JSON,
  fingerprint: string
) =>
  await sb.from('user_notifications').upsert(
    {
      user_id: userId,
      updated_at: new Date().toISOString(),
      subscription: subscription,
      fingerprint
    },
    { onConflict: 'user_id' }
  );