// Python example: Bulk enrichment workflow
import requests
import os

def enrich_leads(leads_list):
    """
    Enrich inbound leads with LeadContact API
    """
    api_key = os.getenv('LEADCONTACT_API_KEY')
    enriched_leads = []

    for lead in leads_list:
        # Search for contact by company domain
        response = requests.post(
            'https://api.leadcontact.ai/v1/contacts/search',
            headers={
                'Authorization': f'Bearer {api_key}',
                'Content-Type': 'application/json'
            },
            json={
                'company': lead['company'],
                'decision_maker_only': True,
                'include_phone': True,
                'departments': ['Executive']
            },
            timeout=10
        )

        if response.status_code == 200:
            data = response.json()
            if data.get('success'):
                contacts = data['data']['contacts']
                if contacts:
                    # Add best contact to lead
                    best_contact = contacts[0]  # Highest confidence
                    lead.update({
                        'email': best_contact.get('email'),
                        'phone': best_contact.get('phone'),
                        'title': best_contact.get('title'),
                        'email_confidence': best_contact.get('email_confidence')
                    })

        enriched_leads.append(lead)

    return enriched_leads

# Usage
inbound_leads = [
    {'company': 'TechCorp', 'name': 'John Doe', 'email': 'john@techcorp.com'},
    {'company': 'InnovateInc', 'name': 'Jane Smith', 'email': 'jane@innovateinc.com'}
]

enriched = enrich_leads(inbound_leads)
print(f"Enriched {len(enriched)} leads")

// Node.js example: HubSpot integration
const hubspot = require('@hubspot/api-client');
const axios = require('axios');

const API_KEY = process.env.LEADCONTACT_API_KEY;
const HUBSPOT_API_KEY = process.env.HUBSPOT_API_KEY;

async function addContactToHubSpot(contact) {
  // Create contact in HubSpot
  const hubspotClient = new hubspot.Client({ apiKey: HUBSPOT_API_KEY });

  const contactObj = {
    properties: [
      { property: 'email', value: contact.email },
      { property: 'firstname', value: contact.first_name },
      { property: 'lastname', value: contact.last_name },
      { property: 'phone', value: contact.phone },
      { property: 'jobtitle', value: contact.title },
      { property: 'company', value: contact.company },
      { property: 'leadsource', value: 'LeadContact API' }
    ]
  };

  try {
    await hubspotClient.contacts.create(contactObj);
    console.log(`Added ${contact.email} to HubSpot`);
  } catch (error) {
    console.error('HubSpot error:', error);
  }
}

async function syncLeadContacts() {
  // Search for contacts from target companies
  const companies = ['Acme Corp', 'Globex Inc', 'TechStart'];

  for (const company of companies) {
    const response = await axios.post(
      'https://api.leadcontact.ai/v1/contacts/search',
      {
        headers: {
          'Authorization': `Bearer ${API_KEY}`,
          'Content-Type': 'application/json'
        },
        data: {
          company: company,
          decision_maker_only: true,
          include_phone: true,
          limit: 5
        }
      }
    );

    if (response.data.success) {
      const contacts = response.data.data.contacts;

      // Add each contact to HubSpot
      for (const contact of contacts) {
        await addContactToHubSpot(contact);
      }
    }
  }
}

syncLeadContacts();

// Go example: Pre-outreach verification
package main

import (
    "bytes"
    "encoding/json"
    "net/http"
    "os"
)

func verifyEmailBeforeOutreach(email string) (bool, error) {
    api_key := os.Getenv("LEADCONTACT_API_KEY")

    payload := map[string]interface{}{
        "email": email,
        "smtp_check": true,
        "format_check": true,
    }

    jsonData, _ := json.Marshal(payload)

    req, _ := http.NewRequest("POST",
        "https://api.leadcontact.ai/v1/contacts/verify",
        bytes.NewBuffer(jsonData))
    req.Header.Set("Authorization", "Bearer " + api_key)
    req.Header.Set("Content-Type", "application/json")

    client := &http.Client{Timeout: 10 * time.Second}
    resp, err := client.Do(req)

    if err != nil {
        return false, err
    }
    defer resp.Body.Close()

    var result map[string]interface{}
    json.NewDecoder(resp.Body).Decode(&result)

    if result["success"].(bool) {
        data := result["data"].(map[string]interface{})
        is_valid := data["is_deliverable"].(bool)
        confidence := data["confidence_score"].(float64)

        // Only outreach if high confidence
        if is_valid && confidence >= 0.90 {
            return true, nil  // Email verified, safe to outreach
        }
        return false, nil  // Low confidence, skip outreach
    }

    return false, nil
}