1 × AI Voice Agent(Outbound Calling Campaigns)

-- Create outbound campaigns table
CREATE TABLE outbound_campaigns (
  id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
  name TEXT NOT NULL,
  script TEXT NOT NULL,
  voice_id TEXT NOT NULL,
  status TEXT DEFAULT 'draft',
  created_at TIMESTAMPTZ DEFAULT NOW()
);

-- Create campaign leads table
CREATE TABLE campaign_leads (
  id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
  campaign_id UUID REFERENCES outbound_campaigns(id),
  phone_number TEXT NOT NULL,
  first_name TEXT,
  status TEXT DEFAULT 'pending',
  call_result JSON,
  called_at TIMESTAMPTZ
);

-- Create call logs table
CREATE TABLE call_logs (
  id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
  lead_id UUID REFERENCES campaign_leads(id),
  duration INTEGER,
  transcript TEXT,
  recording_url TEXT,
  disposition TEXT,
  created_at TIMESTAMPTZ DEFAULT NOW()
);

// Edge function: supabase/functions/voice-agent/index.ts
import { serve } from "https://deno.land/std@0.168.0/http/server.ts";

serve(async (req) => {
  const { leadId, campaignId } = await req.json();
  
  // Get campaign details
  const { data: campaign } = await supabase
    .from('outbound_campaigns')
    .select('*')
    .eq('id', campaignId)
    .single();
  
  // Initialize voice call with ElevenLabs
  const voiceResponse = await fetch(
    'https://api.elevenlabs.io/v1/convai/conversation/get_signed_url',
    {
      headers: {
        'xi-api-key': Deno.env.get('ELEVENLABS_API_KEY')
      }
    }
  );
  
  // Connect to OpenAI for conversation logic
  const completion = await openai.chat.completions.create({
    model: "gpt-4",
    messages: [
      { role: "system", content: campaign.script },
      { role: "user", content: "Start outbound call" }
    ]
  });
  
  return new Response(JSON.stringify({ success: true }));
});

// src/components/VoiceAgentCampaign.tsx
import { useState } from 'react';
import { supabase } from '@/integrations/supabase/client';

export const VoiceAgentCampaign = () => {
  const [campaign, setCampaign] = useState({
    name: '',
    script: '',
    voiceId: 'alloy'
  });

  const startCampaign = async () => {
    // Create campaign
    const { data } = await supabase
      .from('outbound_campaigns')
      .insert(campaign)
      .select()
      .single();

    // Trigger voice agent for each lead
    const { data: leads } = await supabase
      .from('campaign_leads')
      .select('*')
      .eq('campaign_id', data.id)
      .eq('status', 'pending');

    for (const lead of leads) {
      await supabase.functions.invoke('voice-agent', {
        body: { leadId: lead.id, campaignId: data.id }
      });
    }
  };

  return (
    <div className="p-6 bg-teal-50/30 rounded-xl">
      <h2 className="text-2xl font-bold text-gray-900 mb-4">
        Create Campaign
      </h2>
      {/* Campaign form UI */}
    </div>
  );
};

// Campaign analytics with Recharts
import { LineChart, Line, XAxis, YAxis } from 'recharts';

const CampaignAnalytics = ({ campaignId }) => {
  const [metrics, setMetrics] = useState([]);

  useEffect(() => {
    const subscription = supabase
      .channel('campaign-metrics')
      .on('postgres_changes', 
        { 
          event: '*', 
          schema: 'public', 
          table: 'call_logs',
          filter: `campaign_id=eq.${campaignId}`
        }, 
        (payload) => {
          // Update metrics in real-time
          updateMetrics(payload.new);
        }
      )
      .subscribe();
  }, [campaignId]);

  return (
    <LineChart data={metrics}>
      <Line type="monotone" dataKey="calls" stroke="#14b8a6" />
      <Line type="monotone" dataKey="conversions" stroke="#06b6d4" />
    </LineChart>
  );
};