class BusinessVoiceAgent:
  def __init__(self, api_key):
    self.assemblyai_client = RealtimeClient(api_key)
    self.business_context = {}
    self.workflow_state = "listening"

  async def initialize_stream(self):
    config = {
      "sample_rate": 16000,
      "word_boost": ["CRM", "quarterly", "revenue", "pipeline", "ROI"],
      "auto_highlights": True,
      "speaker_labels": True,
      "format_text": True
    }
    await self.assemblyai_client.connect(
      on_message=self.process_speech,
      on_error=self.handle_error,
      **config
    )

class BusinessWorkflowEngine:
  def __init__(self):
    self.sales_keywords = ["budget", "timeline", "decision maker", "requirements"]
    self.support_keywords = ["issue", "problem", "error", "bug", "broken"]
    self.scheduling_keywords = ["meeting", "appointment", "calendar", "available"]

  async def analyze_business_intent(self, transcript_text):
    if any(keyword in transcript_text.lower() for keyword in self.sales_keywords):
      return await self.handle_sales_interaction(transcript_text)
    elif any(keyword in transcript_text.lower() for keyword in self.support_keywords):
      return await self.handle_support_interaction(transcript_text)
    elif any(keyword in transcript_text.lower() for keyword in self.scheduling_keywords):
      return await self.handle_scheduling_interaction(transcript_text)

class CRMIntegration:
  def __init__(self, crm_api_key):
    self.crm_client = CRMClient(crm_api_key)

  async def real_time_crm_update(self, call_data):
    contact_data = {
      "transcript": call_data["full_transcript"],
      "sentiment": call_data["sentiment_analysis"],
      "lead_score": call_data["lead_score"],
      "next_actions": call_data["recommended_actions"],
      "call_duration": call_data["duration"],
      "key_topics": call_data["extracted_topics"]
    }
    await self.crm_client.update_contact(
      contact_id=call_data["contact_id"],
      data=contact_data,
      timestamp=call_data["timestamp"]
    )