i dZiddddddddd d d d d ddddddddddddddddddd d!d"d#d$d%Zd&d'd(d)d*d+Zd,ed-efd.Zd,ed-efd/Zd0ed-efd1Zd0ed-efd2Zy3)4z Database Constants for Test Utilities Centralized definitions for indexes and triggers to avoid duplication across test modules. ix_sessions_user_id)sessionsuser_idFix_sessions_expires_at)r expires_atFix_streams_status)streamsstatusFix_streams_created_by)r created_byFix_comments_stream_id)comments stream_idFix_comments_user_id)r rFix_comments_parent_id)r parent_idFix_processing_jobs_stream_id)processing_jobsrFix_processing_jobs_status)rr Fix_activity_log_user_id) activity_logrFix_activity_log_created_at)r created_atFix_watch_history_user_id) watch_historyrFix_watch_history_stream_id)rrF ix_watch_history_last_watched_at)rlast_watched_atFix_twitch_oauth_user_id) twitch_oauthrTix_chapters_stream_id)chaptersrFix_chapters_game_display_name)r!game_display_nameF) chat_messagesrF) site_settingskeyT)ix_chat_messages_stream_idix_site_settings_keyusersrr rr%)update_users_updated_atupdate_streams_updated_atupdate_comments_updated_atupdate_twitch_oauth_updated_atupdate_site_settings_updated_at index_namereturnc X|tvryt|\}}}|rdnd}d|d|d|d|d S)z0Generate CREATE INDEX SQL for a given index namezUNIQUE z" op.execute(""" CREATE zINDEX IF NOT EXISTS  ON (z ); """) INDEX_DEFINITIONS)r/tablecolumnunique unique_strs 7/home/factor_ks/STREAMA2026/tests/utils/db_constants.py get_index_sqlr<)sS**-j9E66$"J 0 zl- XXr= trigger_namec D|tvryt|}d|d|d|d|d S)z4Generate CREATE TRIGGER SQL for a given trigger namer22 op.execute(""" DROP TRIGGER IF EXISTS r3z; CREATE TRIGGER z BEFORE UPDATE ON zL FOR EACH ROW EXECUTE FUNCTION update_updated_at_column(); """) TRIGGER_DEFINITIONSrAr7s r;get_trigger_sqlrG:sK..  -E ,~T%9$~&! r=c8|tvryt|}d|d|dS)z2Generate DROP TRIGGER SQL for a given trigger namer2rCr3r?rDrFs r;get_trigger_downgrade_sqlrIIs0..  -E @dSXRYYf ggr=N)__doc__r6rEstrr<r@rGrIr=r;rMsg9?5=  =  9 =#$K !EA!"G C!"G'(S@ =!"$%M#$#H:'0 '!*",&4'6 @c@c@YYY # # hChChr=