events_manager.py

import os
import typing
from typing import Optional

# Import all required utils
from utils.call_transcript_utils import add_transcript
from vocode.streaming.models.events import Event, EventType
from vocode.streaming.models.transcript import TranscriptCompleteEvent
from vocode.streaming.utils import events_manager

import httpx

class EventsManager(events_manager.EventsManager):

    def __init__(self):
        super().__init__(subscriptions=[EventType.TRANSCRIPT_COMPLETE])

    async def handle_event(self, event: Event):
        if event.type == EventType.TRANSCRIPT_COMPLETE:
            transcript_complete_event = typing.cast(TranscriptCompleteEvent, event)
            add_transcript(
                transcript_complete_event.conversation_id,
                1,  # demo user id
                transcript_complete_event.transcript.to_string(),
            )

            # Prepare the data to be sent
            data = {
                "conversation_id": transcript_complete_event.conversation_id,
                "user_id": 1,  # demo user id
                "transcript": transcript_complete_event.transcript.to_string()
            }

            # URL of the webhook endpoint you want to send the data to
            webhook_url = os.environ.get("TRANSCRIPT_CALLBACK_URL")

            # Make the async HTTP POST request
            async with httpx.AsyncClient() as client:
                response = await client.post(webhook_url, json=data)

                # Handle the response as needed (e.g., check for success or failure)
                if response.status_code == 200:
                    print("Transcript sent successfully.")
                else:
                    print("Failed to send transcript.")