Connect ElevenLabs: High-Fidelity Conversational Voice & Custom Cloning

export class ElevenLabsAgentClient implements IVoiceAgentProvider {
  readonly platformType: VoiceAgentPlatform = 'ELEVENLABS';
  private apiKey: string;

  constructor(credentials?: VoiceAgentCredentials) {
    this.apiKey = credentials?.apiKey || process.env.ELEVENLABS_API_KEY || '';
  }

  async validateCredentials(credentials?: VoiceAgentCredentials): Promise<boolean> {
    const key = credentials?.apiKey || this.apiKey;
    if (!key) return false;
    try {
      const res = await fetch('https://api.elevenlabs.io/v1/models', {
        method: 'GET',
        headers: { 'xi-api-key': key },
      });
      return res.status === 200;
    } catch {
      return key.length >= 24;
    }
  }
}

export async function dispatchElevenLabsCall(
  apiKey: string,
  options: SendVoiceOptions,
): Promise<SendVoiceResult> {
  const targetAgentId = options.assistantId || 
    (options.voiceId && options.voiceId.length >= 10 ? options.voiceId : null);

  if (!targetAgentId) {
    return {
      success: false,
      error: 'No ElevenLabs Agent ID specified for outbound call.',
    };
  }

  const res = await fetch('https://api.elevenlabs.io/v1/convai/conversations', {
    method: 'POST',
    headers: {
      'xi-api-key': apiKey,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      agent_id: targetAgentId,
      dynamic_variables: options.variables || {},
    }),
  });

  const data = (await res.json().catch(() => ({}))) as any;

  if (res.status >= 200 && res.status < 300) {
    return {
      success: true,
      providerCallId: data.conversation_id || `11labs_${Date.now()}`,
    };
  }

  return {
    success: false,
    error: data.detail?.message || `ElevenLabs dispatch failed with HTTP ${res.status}`,
  };
}