o i{ @sUdZddlmZddlmZddlmZddlmZm Z m Z edZ edZ eGd d d Z gd d d gdggdgdgdddgdZeeeefed<GdddZddddddddd d!d" Zd#S)$u SERVICE METADATA REGISTRY - SOURCE OF TRUTH ⭐ THIS IS THE SOURCE OF TRUTH FOR ALL PIPECAT SERVICES ⭐ To add a new service: 1. Add a ServiceDefinition to the appropriate list below 2. Run: uv run scripts/imports/update_imports.py 3. Run: uv run scripts/configs/update_configs.py DO NOT edit _configs.py or _imports.py directly - they are auto-generated from this file. This module contains: - ServiceDefinition dataclass - Service lists (WEBRTC_TRANSPORTS, STT_SERVICES, LLM_SERVICES, etc.) - FEATURE_DEFINITIONS dict - MANUAL_SERVICE_CONFIGS for complex initialization For operations on services, use ServiceLoader from service_loader.py. ) dataclass)Literal)SERVICE_CONFIGS) BASE_IMPORTSFEATURE_IMPORTSIMPORTS) transportsttllmttsrealtime)web telephonyc@seZdZUdZeed<eed<eed<dZeedBed<dZedBed<dZ eedBed<d Z e ed <d Z e ed <dZ eedBed <d dZdS)ServiceDefinitionaService metadata definition. Required fields: value: Service identifier (e.g., "openai_llm") label: Human-readable name (e.g., "OpenAI") package: Python package requirement (e.g., "pipecat-ai[openai]") Optional fields: class_name: List of class names to import for this service env_prefix: Prefix for environment variables (e.g., "OPENAI" -> "OPENAI_API_KEY") include_params: Parameters to include in generated config even if they have defaults manual_config: If True, config must be manually written (not auto-generated) recommended: If True, this service is marked as recommended in prompts additional_imports: List of full import statements that can't be auto-discovered valuelabelpackageN class_name env_prefixinclude_paramsF manual_config recommendedadditional_importscCs.|jstd|jstd|jstddS)z1Validate service definition after initialization.zService must have a valuezService must have a labelzService must have a packageN)r ValueErrorrr)selfrY/home/ubuntu/.local/lib/python3.10/site-packages/pipecat_cli/registry/service_metadata.py __post_init__CszServiceDefinition.__post_init__)__name__ __module__ __qualname____doc__str__annotations__rlistrrrboolrrrrrrrr's    r)AudioBufferProcessordatetimeiowaveaiofilesAssistantTurnStoppedMessageUserTurnStoppedMessageSileroVADAnalyzer)PipelinePipelineRunnerPipelineParams PipelineTask) LLMContextLLMContextAggregatorPairLLMUserAggregatorParams) load_dotenv LLMRunFrameRunnerArguments BaseTransportWhiskerObserver TailObserver) recording transcriptionvadpipelinecontextrunner observabilityFEATURE_DEFINITIONSc!@s eZdZUdZeZeZeZeZeZe dddgdde ddd gd dgZ e e e d <e d d dgdddgde dddddgddgde dddddgddgde dddgdd gde d!d"dddgddgde d#d$dgd%dgde d&d'dgd(dgde d)d*dgd+dgdgZ e e e d,<e d-d.d/d0gd1d2gd3e d4d5d6d7gd8gd9d3e d:d;dd2d?gd3e d@dAdBdCgdDd2gd3e dEdFdGdHgdId2gd3e dJdKdGdLgdId2gd3e dMdNdOdPgdQd2gd3e dRdSdOdTgdQd2gd3e dUdVdWdXgdYd2gd3e dZd[d\d]gd^d2d?gd3e d_d`dadbgdcdddegd3e dfdgdhdigdjd2gd3e dkdldmdngdod2gd3e dpdqdrdsgdtd2gd3e dudvdwdxgdvd2gd3e dydzd{d|gd}d2gd3e d~dd{dgd}d2gd3e ddddgddd2gd3e ddddgddd2gd3e ddddgdd2gd3e ddddgdd2gd3e ddddgd}dgd3gZe e e d<e ddddgdd2dgd3e ddd6dgd8ddgdde dddgdd3e ddddgdd2dgd3e ddAdBdgdDd2dgd3e d dFdGd gdId2d gd3e d dNdOd gdQd2dgd3e ddddgdd2dgd3e dddadgdcdddgd3e dddadgdcdddgd3e dddhdgdjd2dgd3e dddmdgdod2dgd3e ddqdrd gdtd2dgd3e d!d"d#d$gd%d2dgd3e d&d'drd(gd)d2dgd3e d*d+d,d-gd.dgd3e d/d0d1d2gd0d2dgd3e d3d4drd5gd6gd7d3e d8d9d:d;gdgdvd2dgd3e d?d@d{dAgd}d2d gd3e dBdCdDdEgdFdgd3e dGdHdIdJgdKd2dgd3e dLdMdNdOgdPd2dgd3e dQddrdRgdgdSd3e dTdUdVdWgdXddYgd3gZe e e dZ<e d[d\d]d^gd8gdde d_d`d<dagdbgddcgdde dedfdadggdcgdde dhdidadjgdkgdde dldmdÐdndogdgdde dpdd{gdqd}gdde drdsdtdudvgdwd2gddxgddgZe e e dy<e dzd{d|d}gd~d2gddgdde ddddgdd2dgd3e ddddgdd2dgd3gZe e e d<dS(ServiceRegistrya Central registry for all Pipecat services and their configurations. This class contains only DATA - service definitions, import mappings, and feature configurations. All logic for querying and working with services has been moved to ServiceLoader for better separation of concerns. For operations like: - Finding services: use ServiceLoader.get_service_by_value() - Getting imports: use ServiceLoader.get_imports_for_services() - Extracting extras: use ServiceLoader.extract_extras_for_services() dailyzDaily (WebRTC)zpipecat-ai[daily])DailyTransport DailyParamsDailyRunnerArguments)rrrr smallwebrtc SmallWebRTCzpipecat-ai[webrtc])SmallWebRTCTransportTransportParamsSmallWebRTCConnectionSmallWebRTCRunnerArgumentsWEBRTC_TRANSPORTStwilioTwiliozpipecat-ai[websocket])FastAPIWebsocketTransportFastAPIWebsocketParamsTwilioFrameSerializerWebSocketRunnerArgumentszimport aiohttpz:from pipecat.runner.utils import parse_telephony_websocket)rrrrrtwilio_daily_sip_dialinzTwilio + Daily SIP (Dial-in)rGrFz%from server_utils import AgentRequestzfrom twilio.rest import Clienttwilio_daily_sip_dialoutzTwilio + Daily SIP (Dial-out)z6from server_utils import AgentRequest, DialoutSettingsz from typing import Any, Optionaldaily_pstn_dialinzDaily PSTN (Dial-in))rGDailyDialinSettingsrFz3from pipecat.runner.types import DailyDialinRequestdaily_pstn_dialoutzDaily PSTN (Dial-out)telnyxTelnyx)rRrSTelnyxFrameSerializerrUplivoPlivo)rRrSPlivoFrameSerializerrUexotelExotel)rRrSExotelFrameSerializerrUTELEPHONY_TRANSPORTSassemblyai_stt AssemblyAIzpipecat-ai[assemblyai]AssemblyAISTTService ASSEMBLYAIapi_key)rrrrrraws_transcribe_sttzAWS Transcribezpipecat-ai[aws]AWSTranscribeSTTServiceAWS)aws_access_key_idaws_session_tokenregion azure_sttz Azure Speechzpipecat-ai[azure]AzureSTTService AZURE_SPEECHro cartesia_sttCartesiazpipecat-ai[cartesia]CartesiaSTTServiceCARTESIA deepgram_sttDeepgramzpipecat-ai[deepgram]DeepgramSTTServiceDEEPGRAMdeepgram_flux_sttz Deepgram FluxDeepgramFluxSTTServiceelevenlabs_stt ElevenLabszpipecat-ai[elevenlabs]ElevenLabsSTTService ELEVENLABSelevenlabs_realtime_sttzElevenLabs RealtimeElevenLabsRealtimeSTTServicefal_sttz Fal (Wizper)zpipecat-ai[fal] FalSTTServiceFAL gladia_sttGladiazpipecat-ai[gladia]GladiaSTTServiceGLADIA google_sttzGoogle Speech-to-Textzpipecat-ai[google]GoogleSTTServiceGOOGLE credentialslocation gradium_sttGradiumzpipecat-ai[gradium]GradiumSTTServiceGRADIUMgroq_sttzGroq (Whisper)zpipecat-ai[groq]GroqSTTServiceGROQ hathora_sttHathoraz pipecat-aiHathoraSTTServiceHATHORA nvidia_sttNVIDIAzpipecat-ai[nvidia]NvidiaSTTService openai_sttzOpenAI (Whisper)zpipecat-ai[openai]OpenAISTTServiceOPENAIopenai_realtime_sttzOpenAI RealtimeOpenAIRealtimeSTTService sambanova_sttzSambaNova (Whisper)zpipecat-ai[sambanova]SambaNovaSTTService SAMBANOVAmodel sarvam_sttSarvamzpipecat-ai[sarvam]SarvamSTTServiceSARVAM soniox_sttSonioxzpipecat-ai[soniox]SonioxSTTServiceSONIOXspeechmatics_stt Speechmaticszpipecat-ai[speechmatics]SpeechmaticsSTTService SPEECHMATICS whisper_sttzWhisper (Local)zpipecat-ai[whisper]WhisperSTTService STT_SERVICES anthropic_llmzAnthropic Claudezpipecat-ai[anthropic]AnthropicLLMService ANTHROPICaws_bedrock_llmz AWS BedrockAWSBedrockLLMService aws_regionT)rrrrrrr azure_llmz Azure OpenAIAzureLLMService AZURE_CHATGPT)riendpointr cerebras_llmCerebraszpipecat-ai[cerebras]CerebrasLLMServiceCEREBRAS deepseek_llmDeepSeekzpipecat-ai[deepseek]DeepSeekLLMServiceDEEPSEEK fireworks_llmz Fireworks AIzpipecat-ai[fireworks]FireworksLLMService FIREWORKSgoogle_gemini_llmz Google GeminiGoogleLLMServicegoogle_vertex_llmzGoogle Vertex AIGoogleVertexLLMService)rr project_idgrok_llmGrokzpipecat-ai[grok]GrokLLMServiceGROKgroq_llmGroqGroqLLMService mistral_llmMistralzpipecat-ai[mistral]MistralLLMServiceMISTRAL nvidia_llmNvidiaLLMService ollama_llmOllamaOLLamaLLMServiceOLLAMA openai_llmOpenAIOpenAILLMService openpipe_llmOpenPipezpipecat-ai[openpipe]OpenPipeLLMServiceOPENPIPEopenpipe_api_keyopenrouter_llm OpenRouterzpipecat-ai[openrouter]OpenRouterLLMService OPENROUTERperplexity_llm Perplexityzpipecat-ai[perplexity]PerplexityLLMService PERPLEXITYqwen_llmQwenzpipecat-ai[qwen]QwenLLMServiceQWEN sambanova_llm SambaNovaSambaNovaLLMService together_llmz Together AIzpipecat-ai[together]TogetherLLMServiceTOGETHER LLM_SERVICES asyncai_ttsAsynczpipecat-ai[asyncai]AsyncAITTSServiceASYNCAIvoice_id aws_polly_ttsz AWS PollyAWSPollyTTSService azure_ttsz Azure TTSAzureTTSService)rirovoicecamb_ttsCambzpipecat-ai[camb]CambTTSServiceCAMB cartesia_ttsCartesiaTTSService deepgram_ttsDeepgramTTSServicerelevenlabs_ttsElevenLabsTTSServicefish_ttsFishzpipecat-ai[fish]FishAudioTTSServiceFISH gemini_ttsz Gemini TTSGeminiTTSService google_ttsz Google TTSGoogleTTSService gradium_ttsz Gradium TTSGradiumTTSServicegroq_ttszGroq TTSGroqTTSService hathora_ttsHathoraTTSServicehume_ttszHume TTSzpipecat-ai[hume]HumeTTSServiceHUME inworld_ttsInworldInworldTTSServiceINWORLD kokoro_ttsKokorozpipecat-ai[kokoro]KokoroTTSServiceKOKOROlmnt_ttsLMNTzpipecat-ai[lmnt]LmntTTSService minimax_ttsMiniMaxMiniMaxHttpTTSServiceMINIMAX)rigroup_idr neuphonic_tts Neuphoniczpipecat-ai[neuphonic]NeuphonicTTSService NEUPHONIC nvidia_ttsNvidiaTTSService openai_ttsz OpenAI TTSOpenAITTSService piper_ttsPiperzpipecat-ai[piper]PiperTTSServicePIPER resemble_ttsResemblezpipecat-ai[resembleai]ResembleAITTSServiceRESEMBLErime_ttsRimezpipecat-ai[rime]RimeTTSServiceRIME sarvam_ttsSarvamTTSService)rirrxtts_ttsz XTTS (Coqui)zpipecat-ai[xtts] XTTSServiceXTTSbase_url TTS_SERVICESaws_nova_realtimezAWS Nova Soniczpipecat-ai[aws-nova-sonic]AWSNovaSonicLLMServiceazure_realtimezAzure RealtimeAzureRealtimeLLMServiceAZUREz^from pipecat.services.openai.realtime.events import SessionProperties, InputAudioTranscription)rrrrrrrrgemini_live_realtimez Gemini LiveGeminiLiveLLMServicegemini_vertex_live_realtimezGemini Vertex LiveGeminiLiveVertexLLMService GOOGLE_VERTEX grok_realtimez Grok RealtimeGrokRealtimeLLMServiceSessionPropertiesopenai_realtime)OpenAIRealtimeLLMServicerWAudioConfiguration AudioInputInputAudioTranscriptionSemanticTurnDetectionInputAudioNoiseReductionultravoxUltravoxzpipecat-ai[ultravox]UltravoxRealtimeLLMServiceOneShotInputParamsULTRAVOXzimport datetimeREALTIME_SERVICES heygen_videoHeyGenzpipecat-ai[heygen]HeyGenVideoServiceHEYGENzHfrom pipecat.services.heygen.api import AvatarQuality, NewSessionRequest tavus_videoTavuszpipecat-ai[tavus]TavusVideoServiceTAVUS replica_id simli_videoSimlizpipecat-ai[simli]SimliVideoServiceSIMLIface_idVIDEO_SERVICESN)rr r!r"rrrrrCrrOr%r$rdrrrJrdrsrrrrrD_s     e6 ' W        R rDzAWSBedrockLLMService( aws_region=os.getenv("AWS_REGION"), model=os.getenv("AWS_BEDROCK_MODEL"), params=AWSBedrockLLMService.InputParams(temperature=0.8) )zAWSPollyTTSService( region=os.getenv("AWS_REGION"), voice_id=os.getenv("AWS_VOICE_ID"), params=AWSPollyTTSService.InputParams(engine="generative"), )atsession_properties = SessionProperties( input_audio_transcription=InputAudioTranscription(model="whisper-1"), instructions=os.getenv("AZURE_INSTRUCTIONS"), ) llm = AzureRealtimeLLMService( api_key=os.getenv("AZURE_REALTIME_API_KEY"), base_url=os.getenv("AZURE_REALTIME_BASE_URL"), session_properties=session_properties, start_audio_paused=False, )asession_properties = SessionProperties( audio=AudioConfiguration( input=AudioInput( transcription=InputAudioTranscription(), turn_detection=SemanticTurnDetection(), noise_reduction=InputAudioNoiseReduction(type="near_field"), ) ), instructions=os.getenv("OPENAI_INSTRUCTIONS"), ) llm = OpenAIRealtimeLLMService( api_key=os.getenv("OPENAI_API_KEY"), session_properties=session_properties, )zllm = GeminiLiveLLMService( api_key=os.getenv("GOOGLE_API_KEY"), model=os.getenv("GOOGLE_MODEL"), voice_id=os.getenv("GOOGLE_VOICE_ID"), system_instruction=os.getenv("GOOGLE_SYSTEM_INSTRUCTION"), )a8llm = GeminiLiveVertexLLMService( credentials=os.getenv("GOOGLE_APPLICATION_CREDENTIALS"), project_id=os.getenv("GOOGLE_PROJECT_ID"), location=os.getenv("GOOGLE_LOCATION"), voice_id=os.getenv("GOOGLE_VOICE_ID"), system_instruction=os.getenv("GOOGLE_SYSTEM_INSTRUCTION"), )zsession_properties = SessionProperties( voice=os.getenv("GROK_VOICE_ID"), instructions=os.getenv("GROK_INSTRUCTIONS"), ) llm = GrokRealtimeLLMService( api_key=os.getenv("GROK_API_KEY"), session_properties=session_properties, )a llm = AWSNovaSonicLLMService( secret_access_key=os.getenv("AWS_SECRET_ACCESS_KEY"), access_key_id=os.getenv("AWS_ACCESS_KEY_ID"), region=os.getenv("AWS_REGION"), session_token=os.getenv("AWS_SESSION_TOKEN"), voice_id=os.getenv("AWS_VOICE_ID"), )zHeyGenVideoService( api_key=os.getenv("HEYGEN_API_KEY"), session=session, session_request=NewSessionRequest( avatar_id="HEYGEN_AVATAR_ID", version="v2", quality=AvatarQuality.high ), )zllm =UltravoxRealtimeLLMService( params=OneShotInputParams( api_key=os.getenv("ULTRAVOX_API_KEY"), system_prompt=os.getenv("ULTRAVOX_SYSTEM_PROMPT"), temperature=0.3, max_duration=datetime.timedelta(minutes=3), ), )) rrrMrXrPrRrUrKrer_N)r" dataclassesrtypingr_configsr_importsrrr ServiceTypeBotTyperrCdictr#r%r$rDMANUAL_SERVICE_CONFIGSrrrrsF   (=