import { createClient } from "@supabase/supabase-js"

// Supabase integration
export async function addToSupabase(data: {
  email: string
  packageType: string
  source: string
}) {
  const supabase = createClient(process.env.SUPABASE_URL!, process.env.SUPABASE_SERVICE_ROLE_KEY!)

  const { data: result, error } = await supabase
    .from("email_subscribers")
    .insert([
      {
        email: data.email,
        package_type: data.packageType,
        source: data.source,
      },
    ])
    .select()

  if (error) {
    throw new Error(`Supabase error: ${error.message}`)
  }

  return result
}

// Get all email subscribers (for admin use)
export async function getEmailSubscribers() {
  const supabase = createClient(process.env.SUPABASE_URL!, process.env.SUPABASE_SERVICE_ROLE_KEY!)

  const { data, error } = await supabase.from("email_subscribers").select("*").order("created_at", { ascending: false })

  if (error) {
    throw new Error(`Failed to fetch subscribers: ${error.message}`)
  }

  return data
}

// Get subscriber count
export async function getSubscriberCount() {
  const supabase = createClient(process.env.SUPABASE_URL!, process.env.SUPABASE_SERVICE_ROLE_KEY!)

  const { count, error } = await supabase.from("email_subscribers").select("*", { count: "exact", head: true })

  if (error) {
    throw new Error(`Failed to get subscriber count: ${error.message}`)
  }

  return count || 0
}

// Legacy functions for future use
export async function addToMailchimp(email: string, tags: string[] = []) {
  const response = await fetch(
    `https://${process.env.MAILCHIMP_DC}.api.mailchimp.com/3.0/lists/${process.env.MAILCHIMP_LIST_ID}/members`,
    {
      method: "POST",
      headers: {
        Authorization: `Bearer ${process.env.MAILCHIMP_API_KEY}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({
        email_address: email,
        status: "subscribed",
        tags: tags,
        merge_fields: {
          SOURCE: "Starter Kit Download",
        },
      }),
    },
  )

  return response.json()
}

export async function addToConvertKit(email: string) {
  const response = await fetch(`https://api.convertkit.com/v3/forms/${process.env.CONVERTKIT_FORM_ID}/subscribe`, {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      api_key: process.env.CONVERTKIT_API_KEY,
      email: email,
      tags: ["starter-kit-download"],
    }),
  })

  return response.json()
}