+ iHj^RIHtRtRRltRRltRRltRR ltR R ltR R ltRRlt R#)) connectionsc0V^8dQhR\R\/#)namereturnstr)formats"IE:\live-kit-agent\livekit_voicebot\backend\apps\cluster\dynamic_tables.py __annotate__r +s**3*3*c.RVPRR4 R2#)`z``)replace)rs&r _q_identr+s t||C&'q ))r cfV^8dQhR\R\\\\\3,/#)rbidr)inttupler )r s"r r r /s( : :c :eCc3$67 :r c2V R2pV R2pV R2pV R2pWW43#)zS Returns: agents_table, bots_table, call_history_table, legacy_callhistory_table _agents_bots _call_history _callhistory)ragentsbots call_historylegacy_callhistorys& r _table_namesr /s> uG_FU%=DU-(L5 -  99r c(V^8dQhR\RR/#r business_idrNr)r s"r r r ;sPPcPdPr cVfR#\V4pV^8:dR#\V4wr#rE\R,pVP4;_uu_4pVP R\ V4 R24VP R\ V4 R24VP R\ V4 R24VP R\ V4 R24RRR4R# +'giR#;i)zs Drop per-business tables in the cluster DB (if they exist). Also drops the legacy `{bid}_callhistory` table name. NclusterzDROP TABLE IF EXISTS ;)rr rcursorexecuter)r#rrrrrconnr(s& r drop_business_cluster_tablesr+;s  k C ax5A#5F2F, y !D &.x/?.@BC.x~.>a@A.x /E.FaHI.x8J/K.LANO s A9C C" c(V^8dQhR\RR/#r"r$)r s"r r r Os"Q@Q@Q@Q@r c"VfR#\V4pV^8:dR#\V4wr#rEV R2pV R2pV R2pV R2p R\V4 R2p R\V4 R2p R\V4 R 2p R\V4 R 2p R\V4 R 2pR\V4 R 2pR\V 4 R 2p\R,pVP 4;_uu_4pVP V 4VP V 4VP V 4VP V 4VP V4VP V4VP V4\ VV4\VV4\VV4\VV4RRR4R# +'giR#;i)aB Create per-business tables in the `cluster` database: {business_id}_agents {business_id}_bots {business_id}_call_history {business_id}_knowledgebase {business_id}_audit_logs {business_id}_campaigns {business_id}_campaign_contacts These tables are created on demand when a Business is created in master DB. N_knowledgebase _audit_logs _campaigns_campaign_contactsz CREATE TABLE IF NOT EXISTS a ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, name VARCHAR(255) NOT NULL DEFAULT '', email VARCHAR(255) NOT NULL DEFAULT '', email_verified_at DATETIME NULL, password VARCHAR(255) NOT NULL DEFAULT '', role VARCHAR(50) NOT NULL DEFAULT 'agent', phone VARCHAR(64) NOT NULL DEFAULT '', department VARCHAR(255) NOT NULL DEFAULT '', status VARCHAR(50) NOT NULL DEFAULT '', reports_to BIGINT UNSIGNED NULL, last_login DATETIME NULL, remember_token VARCHAR(255) NULL, created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, business_id BIGINT UNSIGNED NOT NULL, permissions JSON NULL, PRIMARY KEY (id), KEY idx_business_id (business_id), KEY idx_email (email) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; a ( bot_id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, -- LiveKit Cloud agent IDs look like "sb_..." (string), so store as varchar. agent_id VARCHAR(128) NULL, agent_name VARCHAR(255) NULL, is_active TINYINT(1) NOT NULL DEFAULT 1, voice_name VARCHAR(255) NOT NULL DEFAULT '', llm_model VARCHAR(255) NOT NULL DEFAULT '', prompt LONGTEXT NULL, business_id BIGINT UNSIGNED NOT NULL, bot_name VARCHAR(255) NOT NULL DEFAULT '', default_language VARCHAR(32) NULL, platform_settings JSON NULL, concurrent_calls INT UNSIGNED NULL, voice JSON NULL, advanced_settings JSON NULL, conversation_behavior JSON NULL, extraction JSON NULL, detect_language TINYINT(1) NOT NULL DEFAULT 1, skip_turn TINYINT(1) NOT NULL DEFAULT 0, voicemail_detection TINYINT(1) NOT NULL DEFAULT 0, transfer_to_number VARCHAR(64) NULL, end_conversation TINYINT(1) NOT NULL DEFAULT 0, filler_keywords LONGTEXT NULL, transfer_enabled TINYINT(1) NOT NULL DEFAULT 0, skip_turn_prompt LONGTEXT NULL, detect_language_prompt LONGTEXT NULL, end_conversation_prompt LONGTEXT NULL, transfer_to_number_prompt LONGTEXT NULL, voicemail_detection_prompt LONGTEXT NULL, skip_turn_description TEXT NULL, detect_language_description TEXT NULL, end_conversation_description TEXT NULL, transfer_number_description TEXT NULL, voicemail_description TEXT NULL, end_conversation_timeout INT UNSIGNED NULL, transfer_destination_type VARCHAR(32) NULL, transfer_destinations JSON NULL, skip_turn_disable_interruptions TINYINT(1) NOT NULL DEFAULT 0, detect_language_disable_interruptions TINYINT(1) NOT NULL DEFAULT 0, end_conversation_disable_interruptions TINYINT(1) NOT NULL DEFAULT 0, transfer_to_number_disable_interruptions TINYINT(1) NOT NULL DEFAULT 0, voicemail_detection_disable_interruptions TINYINT(1) NOT NULL DEFAULT 0, stt_provider VARCHAR(50) NOT NULL DEFAULT 'deepgram', tts_provider VARCHAR(50) NOT NULL DEFAULT 'elevenlabs', llm_provider VARCHAR(255) NULL, mcube_exenumber VARCHAR(64) NOT NULL DEFAULT '', mcube_gid VARCHAR(64) NOT NULL DEFAULT '1', message_inbound LONGTEXT NULL, message_outbound LONGTEXT NULL, guardrails JSON NULL, system_tools JSON NULL, created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (bot_id), KEY idx_business_id (business_id), KEY idx_agent_id (agent_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; a% ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, conversation_id VARCHAR(255) NULL, agent_id VARCHAR(128) NULL, transcript LONGTEXT NULL, conversation_data JSON NULL, phone_number VARCHAR(64) NULL, agent_phone_number VARCHAR(64) NULL, customer_name VARCHAR(255) NULL, agent_name VARCHAR(255) NULL, call_start_time DATETIME NULL, call_end_time DATETIME NULL, call_duration_secs INT UNSIGNED NULL, call_successful TINYINT(1) NULL, call_status VARCHAR(50) NULL, ongoing TINYINT(1) NOT NULL DEFAULT 0, transferred TINYINT(1) NOT NULL DEFAULT 0, status VARCHAR(50) NOT NULL DEFAULT '', sentiment VARCHAR(50) NULL, summary LONGTEXT NULL, recording_url LONGTEXT NULL, dynamic_variables JSON NULL, campaign_id BIGINT UNSIGNED NULL, business_id BIGINT UNSIGNED NOT NULL, created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (id), KEY idx_business_id (business_id), KEY idx_conversation_id (conversation_id), KEY idx_agent_id (agent_id), KEY idx_campaign_id (campaign_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; a# ( id INT NOT NULL AUTO_INCREMENT, doc_id VARCHAR(255) NULL, doc_name VARCHAR(255) NULL, doc_url LONGTEXT NOT NULL, bot_id INT NULL, business_id INT NULL, created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (id), KEY idx_business_id (business_id), KEY idx_bot_id (bot_id), KEY idx_doc_id (doc_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; a ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, timestamp DATETIME NULL, user_id VARCHAR(64) NOT NULL DEFAULT '', user_name VARCHAR(255) NOT NULL DEFAULT '', user_role VARCHAR(64) NOT NULL DEFAULT '', action VARCHAR(64) NOT NULL DEFAULT '', module VARCHAR(64) NOT NULL DEFAULT '', resource_type VARCHAR(128) NOT NULL DEFAULT '', resource_name VARCHAR(255) NULL, description TEXT NULL, severity VARCHAR(16) NOT NULL DEFAULT 'low', status VARCHAR(16) NOT NULL DEFAULT 'success', ip_address VARCHAR(64) NULL, user_agent TEXT NULL, business_id BIGINT UNSIGNED NOT NULL, created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (id), KEY idx_business_id (business_id), KEY idx_timestamp (timestamp) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; a ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, name VARCHAR(255) NOT NULL DEFAULT '', description TEXT NULL, autodailer_id BIGINT UNSIGNED NULL, business_id BIGINT UNSIGNED NOT NULL, status VARCHAR(32) NOT NULL DEFAULT 'processing', call_status VARCHAR(32) NOT NULL DEFAULT 'pending', listname VARCHAR(255) NOT NULL DEFAULT '', total_count INT UNSIGNED NOT NULL DEFAULT 0, total_calls INT UNSIGNED NOT NULL DEFAULT 0, successful_calls INT UNSIGNED NOT NULL DEFAULT 0, failed_calls INT UNSIGNED NOT NULL DEFAULT 0, processing_count INT UNSIGNED NOT NULL DEFAULT 0, pending_count INT UNSIGNED NOT NULL DEFAULT 0, waiting_time INT UNSIGNED NOT NULL DEFAULT 0, waiting_time_count INT UNSIGNED NOT NULL DEFAULT 0, createdon DATETIME NULL, start_time DATETIME NULL, end_time DATETIME NULL, did VARCHAR(64) NOT NULL DEFAULT '', start_date DATE NULL, end_date DATE NULL, autodailer_type VARCHAR(64) NOT NULL DEFAULT '', retry_attempt INT UNSIGNED NOT NULL DEFAULT 0, retry_time INT UNSIGNED NOT NULL DEFAULT 0, bot_name VARCHAR(255) NOT NULL DEFAULT '', exeuctive_number VARCHAR(64) NOT NULL DEFAULT '', refurl LONGTEXT NULL, run_now TINYINT(1) NOT NULL DEFAULT 0, batch_size INT UNSIGNED NULL, batch_interval INT UNSIGNED NULL, no_of_attempt INT UNSIGNED NULL, total_attempts INT UNSIGNED NULL, interval_time INT UNSIGNED NULL, automated_callbacks_enabled TINYINT(1) NOT NULL DEFAULT 0, pending_callbacks_count INT UNSIGNED NOT NULL DEFAULT 0, callback_requested TINYINT(1) NOT NULL DEFAULT 0, created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (id), KEY idx_business_id (business_id), KEY idx_status (status) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; a ( id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT, business_id BIGINT UNSIGNED NOT NULL, campaign_id BIGINT UNSIGNED NOT NULL, status VARCHAR(32) NOT NULL DEFAULT 'pending', call_status VARCHAR(32) NOT NULL DEFAULT 'pending', contact_name VARCHAR(255) NOT NULL DEFAULT '', number VARCHAR(64) NOT NULL DEFAULT '', source VARCHAR(255) NOT NULL DEFAULT '', retry TINYINT(1) NOT NULL DEFAULT 0, retry_attempt INT UNSIGNED NOT NULL DEFAULT 0, callback_requested TINYINT(1) NOT NULL DEFAULT 0, callback_time DATETIME NULL, callback_status TINYINT(1) NOT NULL DEFAULT 0, callback_retry_attempts INT UNSIGNED NOT NULL DEFAULT 0, callback_last_attempt_time DATETIME NULL, callback_failure_reason TEXT NULL, created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (id), KEY idx_business_id (business_id), KEY idx_campaign_id (campaign_id), KEY idx_status (status) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; r&) rr rrr(r)_ensure_bots_table_columns_ensure_agent_id_varchar _ensure_knowledgebase_timestamps)r#rrrcalls_legacy_callhistory knowledgebase audit_logs campaignscampaign_contacts ddl_agentsddl_bots ddl_callsddl_knowledgebaseddl_audit_logs ddl_campaignsddl_campaign_contactsr*r(s& r ensure_business_cluster_tablesrBOs k C ax/;C/@,F%e>*M5 $J%z"I%12 ( 012J0 (/:0;Hz (0 1!IF ( 789" ( 456N0 ( 34,5-M^! (): ;<=6 y !D &z"x y!()~&}%,-"640 . /(? s B(E== F c(V^8dQhR\RR/#rtablerNr)r s"r r r cs!!C!D!r c VPR4VP4pV'dV^,'gR#V^,pRpVFmwrVVPRW1V.4VP4pV'gK3V^,eK@VPR\V4 R\V4 RV 24Ko R# \dKi;i)zULegacy `{bid}_knowledgebase` tables may define created_at/updated_at without DEFAULT.SELECT DATABASE()Nz SELECT COLUMN_DEFAULT FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = %s AND TABLE_NAME = %s AND COLUMN_NAME = %s ALTER TABLE z MODIFY COLUMN  )) created_atz,TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP) updated_atzHTIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP)r)fetchoner Exception)r(rErowdb_namefixescol_namecol_defrs&& r r4r4cs NN&' // C c!ff!fG E#  X &   OO   Q4    NNx/x?Q>RRST[S\] #$   s ,B;; C  C c(V^8dQhR\RR/#rDr)r s"r r r scdr c VPR4VP4pV'dV^,'gR#V^,pVPRW1.4VP4Uu0uF qD^,kK pp\F:wrgWe9dK VPR\ V4 R\ V4 RV 24K< R#uupi \ dKSi;i)zJALTER `{bid}_bots` to add API/legacy columns missing on older deployments.rGNzx SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = %s AND TABLE_NAME = %s rHz ADD COLUMN rI)r)rLfetchallCLUSTER_BOTS_EXTRA_COLUMNSrrM)r(rErNrOrSexistingrQrRs&& r r2r2s NN&' // C c!ff!fG NN   %oo/0/!/H07     NNx/|HXrs9!$N* :P(Q@h!H6% r