import { Resource } from "@opencode/console-resource"

async function login() {
  const url = Resource.SALESFORCE_INSTANCE_URL.value.replace(/\/$/, "")
  const clientId = Resource.SALESFORCE_CLIENT_ID.value
  const clientSecret = Resource.SALESFORCE_CLIENT_SECRET.value

  const params = new URLSearchParams({
    grant_type: "client_credentials",
    client_id: clientId,
    client_secret: clientSecret,
  })

  const res = await fetch(`${url}/services/oauth2/token`, {
    method: "POST",
    headers: { "Content-Type": "application/x-www-form-urlencoded" },
    body: params.toString(),
  }).catch((err) => {
    console.error("Failed to fetch Salesforce access token:", err)
  })

  if (!res) return

  if (!res.ok) {
    console.error("Failed to fetch Salesforce access token:", res.status, await res.text())
    return
  }

  const data = (await res.json()) as { access_token?: string; instance_url?: string }
  if (!data.access_token) {
    console.error("Salesforce auth response did not include an access token")
    return
  }

  return {
    token: data.access_token,
    url: data.instance_url ?? url,
  }
}

export interface SalesforceLeadInput {
  name: string
  role: string
  company?: string
  email: string
  phone?: string
  inferenceSpend?: string
  message: string
}

export async function createLead(
  input: SalesforceLeadInput,
  submit?: (payload: Record<string, unknown>) => Promise<boolean>,
): Promise<boolean> {
  const payload = {
    LastName: input.name,
    Company: input.company?.trim() || "Website",
    Email: input.email,
    Phone: input.phone ?? null,
    Title: input.role,
    Description: input.message,
    Current_Monthly_Inference_Spend__c: input.inferenceSpend,
    LeadSource: "enterprise website form",
  }
  if (submit) return submit(payload)
  const auth = await login()
  if (!auth) return false

  const res = await fetch(`${auth.url}/services/data/v59.0/sobjects/Lead`, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${auth.token}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify(payload),
  }).catch((err) => {
    console.error("Failed to create Salesforce lead:", err)
  })

  if (!res) return false

  if (!res.ok) {
    console.error("Failed to create Salesforce lead:", res.status, await res.text())
    return false
  }

  return true
}