import { supabase } from "@/integrations/supabase/client";

export async function assignExistingTravelerToTrip(tripId: string, travelerId: string) {
  if (!tripId || !travelerId) throw new Error("Voyage ou voyageur manquant.");
  const { data, error } = await supabase.rpc("assign_existing_traveler", {
    p_trip_id: tripId,
    p_traveler_id: travelerId,
  });
  if (error) throw error;
  return data;
}

export const normalizeTravelerEmail = (email: string) => email.trim().toLowerCase();

export function isTravelerAlreadyLinked(email: string, linkedEmails: string[]) {
  const normalized = normalizeTravelerEmail(email);
  return linkedEmails.some((value) => normalizeTravelerEmail(value) === normalized);
}