U }_i2@szdZddlZddlmZddlZddlmZmZmZddl m Z ddl m Z ddl m Z eeZGdd d ZeZdS) zm Bot Configuration Service for MCube Voice Bot Handles dynamic bot configuration based on DID number mapping N)Error)OptionalDictAny)datetime)Config)Logc@seZdZdZddZdedddZeeedd d Z ed d d Z eeedddZ eeee ee fdddZee ee fdddZeeee ee fdddZeeedddZe eefdddZdS)BotConfigurationServicez Service for managing dynamic bot configurations based on DID number mapping. Maps DID numbers to specific bot configurations stored in database. cCsHtjdtjtjtjdd|_tjtjtjtjtjdd|_t ddS)NZdevvoicelabs_masterT)hostZdatabaseuserpasswordcharsetZ autocommitu*🤖 Bot Configuration Service initialized) r DATABASE_HOST DATABASE_USERDATABASE_PASSWORDDATABASE_CHARSETmaster_db_config DATABASE_NAMEcluster_db_configrinfo)selfrG/var/www/html/live_calls/homebook/services/bot_configuration_service.py__init__s  z BotConfigurationService.__init__cluster) database_typec Cshz(|dkr|jn|j}tjjf|}|WStk rb}ztd|d|W5d}~XYnXdS)z Get database connection for master or cluster database. Args: database_type: 'master' or 'cluster' Returns: Database connection masteru❌ Error connecting to z database: N)rrmysqlZ connectorconnectrrerror)rrconfig connectionerrrget_connection,s z&BotConfigurationService.get_connection) did_numberreturnc Csd}d}zz|d}|jdd}d}|||f|}|rz|d}|d}td|d |d |||fWWfStd |WWNd SWnBtk r}z$t d |d|WYWd Sd}~XYnXW5|r||r|XdS)z Get bot_id from DID number mapping in master database. Args: did_number: DID number to lookup Returns: bot_id if found, None otherwise NrT dictionaryz SELECT bot_id, business_id FROM did_numbers WHERE did_no = %s AND status = '1' bot_id business_idu🔍 Found bot mapping - DID: z , Bot ID: z, Business ID: %⚠️ No bot mapping found for DID: )NNu❌ Error looking up DID : closer#cursorexecutefetchonerrwarningrr) rr$r!r.queryresultr(r)r"rrrget_bot_id_by_did>s,    z)BotConfigurationService.get_bot_id_by_did)r$cs0ddl}fdd}|}|d|IdHS)z5Async version of get_bot_id_by_did using thread pool.rNcs SN)r4rr$rrr_sync_get_bot_idnszIBotConfigurationService.get_bot_id_by_did_async.._sync_get_bot_idasyncioget_event_looprun_in_executor)rr$r9r7looprr6rget_bot_id_by_did_asyncjsz/BotConfigurationService.get_bot_id_by_did_async)r)r%c Csd}d}zzz|d}|jdd}d}|||f|}|rh|d}td|d||WWfStd |WWNdSWnBtk r}z$t d |d |WYWdSd}~XYnXW5|r||r|XdS) z Get business name from business table in master database. Args: business_id: Business ID to lookup Returns: Business name if found, None otherwise NrTr&z SELECT business_name FROM businesses WHERE business_id = %s AND status = 'active' business_nameu(🏢 Found business name - Business ID: z, Name: u*⚠️ No business found for Business ID: u❌ Error looking up business r+r,)rr)r!r.r2r3r>r"rrrget_business_name_by_idts*     z/BotConfigurationService.get_business_name_by_id)r)r(r%c Csd}d}zz|d}|jdd}|d}d|d}|||f|}|r|d|d |d d }td |d d ||WWfStd|WWNdSWnBtk r} z$t d|d| WYWdSd} ~ XYnXW5|r||r|XdS)z Get bot configuration from cluster database. Args: business_id: Business ID bot_id: Bot ID Returns: Bot configuration dictionary or None NrTr&Z_botszA SELECT bot_id, bot_name, agent_id FROM `z>` WHERE bot_id = %s AND is_active = 1 r(bot_nameagent_id)r(r@rAu&🤖 Loaded bot configuration - Name: z, ID: u5⚠️ No active bot configuration found for Bot ID: u0❌ Error fetching bot configuration for Bot ID r+r,) rr)r(r!r.Z table_namer2r3 bot_configr"rrrget_bot_configurations6      z-BotConfigurationService.get_bot_configurationc szzt}||IdH}|r8|ddks8|ddkr^td|dddddtjdWS|\}}ddl}g}|| ||}| d|f|| |} | d | f|j d d |Dd d iIdH} t | dts| dnd} t | dts| dnd} | s8td|ddd||| p0tjdWSt|} td| dd| | dd||| pvtjdWStk r}z0td|d|ddddtjdWYSd}~XYnXdS)a\ Get complete bot configuration by DID number - OPTIMIZED for separate databases. All database operations run in thread pool to avoid blocking event loop. Args: did_number: DID number to lookup Returns: Dictionary containing bot configuration and system message Nrr*z, using default configurationzDefault Assistant)rBr@r)r( company_namerBrEcSsg|] \}}|qSrr).0_taskrrr szHBotConfigurationService.get_bot_configuration_by_did..return_exceptionsTu.⚠️ No bot configuration found for Bot ID: z, using defaultu ⚡ Bot configuration loaded in z.2fz secondsname Assistantu,❌ Error getting bot configuration for DID r+)rnowr=rr1r COMPANY_NAMEr9 create_task_get_bot_config_asyncappend_get_company_name_asyncgather isinstance Exception total_secondsrgetr)rr$Z start_timer3r(r)r9tasksZbot_taskZ company_taskresultsrBrEZ total_timer"rrrget_bot_configuration_by_didsZ      z4BotConfigurationService.get_bot_configuration_by_didcs:ddl}ddl}fdd}|}|d|IdHS)z-Async version of bot configuration retrieval.rNcs Sr5)rCrr(r)rrr_sync_get_bot_config,szKBotConfigurationService._get_bot_config_async.._sync_get_bot_config)r9mysql.connectorr:r;)rr)r(r9rr\r<rr[rrP's z-BotConfigurationService._get_bot_config_asynccs0ddl}fdd}|}|d|IdHS)z(Async version of company name retrieval.rNcs Sr5)r?rr)rrr_sync_get_company_name7szOBotConfigurationService._get_company_name_async.._sync_get_company_namer8)rr)r9r_r<rr^rrR3sz/BotConfigurationService._get_company_name_async)r%c Cs ddd}zJ|d}|}|d|||d|d<tdWn2tk r}ztd|W5d}~XYnXzJ|d }|}|d|||d|d <td Wn4tk r}ztd |W5d}~XYnX|S) z Test connections to both master and cluster databases. Returns: Dictionary with connection test results F)rrrzSELECT 1Tu)✅ Master database connection successfulu'❌ Master database connection failed: Nru*✅ Cluster database connection successfulu(❌ Cluster database connection failed: ) r#r.r/r0r-rrrUr)rrYr!r.r"rrrtest_database_connections>s0   "  "z1BotConfigurationService.test_database_connectionsN)r)__name__ __module__ __qualname____doc__rstrr#rintr4r=r?rrrCrZrPrRboolr`rrrrr s, +4T  r )rdr]rrloggingtypingrrrrr rservices.log_utilsr getLoggerraloggerr bot_configuration_servicerrrrs     X