
    yjG                         U d Z ddlmZ ddlZddlmZ ddlmZ ddlm	Z	m
Z
mZ dZeed<   d	Zedz  ed
<   dZeee         z  dz  ed<   dZeee         z  dz  ed<    e
            ZddZddZdS )zwstandardize_constraint_names

Revision ID: baa22cad81e2
Revises: 29ade7350c19
Create Date: 2025-11-15 01:16:40.937103

    )SequenceN)op)text)constraint_exists
get_schemaindex_existsbaa22cad81e2revision29ade7350c19down_revisionbranch_labels
depends_onreturnc            	         t          j                    } t          j        |           }t	          ddd|          r+|                     t          dt           d                     t	          ddd|          r+|                     t          dt           d                     t	          d	d
d|          r+|                     t          dt           d                     t	          ddd|          r+|                     t          dt           d                     t	          ddd|          r+|                     t          dt           d                     t	          ddd|          r+|                     t          dt           d                     t	          ddd|          r+|                     t          dt           d                     t          j        |           }t          dd|          r+|                     t          dt           d                     t          dd|          r+|                     t          dt           d                     t          dd|          r+|                     t          dt           d                      t          dd!|          r+|                     t          dt           d"                     t          dd#|          r+|                     t          dt           d$                     t          dd%|          r+|                     t          dt           d&                     t          dd'|          r+|                     t          dt           d(                     t          dd)|          r+|                     t          dt           d*                     t          dd+|          r+|                     t          dt           d,                     t          dd-|          r+|                     t          dt           d.                     t          dd/|          r+|                     t          dt           d0                     t          dd1|          r+|                     t          dt           d2                     t          dd3|          r+|                     t          dt           d4                     t          dd5|          r+|                     t          dt           d6                     t          d7d8|          r+|                     t          dt           d9                     t          dd:|          rt          j	        d:dt          ;           t          dd<|          rt          j	        d<dt          ;           t          d	d=|          rt          j	        d=d	t          ;           t          d	d>|          rt          j	        d>d	t          ;           t          dd?|          rt          j	        d?dt          ;           t          dd@|          rt          j	        d@dt          ;           t          dAdB|          rt          j	        dBdAt          ;           t          dAdC|          st          j
        dCdAdDgdEt          F           t          dAdG|          s t          j
        dGdAg dHdEt          F           t          ddI|          st          j
        dIddJgdEt          F           t	          ddKd|          rt          j        dKdt          dL           t          j        |           }t	          ddMd|          r`|                     t          dt           dN                     |                     t          dOt           dPt           dQ                     d S d S )RNactive_queue_sessionsunique_work_unit_keyuniqueALTER TABLE zk.active_queue_sessions RENAME CONSTRAINT "unique_work_unit_key" TO "uq_active_queue_sessions_work_unit_key"collections#unique_observer_observed_collectionzy.collections RENAME CONSTRAINT "unique_observer_observed_collection" TO "uq_collections_observer_observed_workspace_name"peersunique_name_workspace_peerzW.peers RENAME CONSTRAINT "unique_name_workspace_peer" TO "uq_peers_name_workspace_name"sessionsunique_session_namezV.sessions RENAME CONSTRAINT "unique_session_name" TO "uq_sessions_name_workspace_name"messagesuq_messages_session_seqzq.messages RENAME CONSTRAINT "uq_messages_session_seq" TO "uq_messages_workspace_name_session_name_seq_in_session"
workspacesuq_apps_namezD.workspaces RENAME CONSTRAINT "uq_apps_name" TO "uq_workspaces_name"message_embeddings"message_embeddings_message_id_fkey
foreignkeyzy.message_embeddings RENAME CONSTRAINT "message_embeddings_message_id_fkey" TO "fk_message_embeddings_message_id_messages"idx_collections_observedALTER INDEX z?."idx_collections_observed" RENAME TO "ix_collections_observed"idx_collections_observerz?."idx_collections_observer" RENAME TO "ix_collections_observer"	documentsidx_documents_embedding_hnswzG."idx_documents_embedding_hnsw" RENAME TO "ix_documents_embedding_hnsw"idx_documents_observedz;."idx_documents_observed" RENAME TO "ix_documents_observed"idx_documents_observerz;."idx_documents_observer" RENAME TO "ix_documents_observer"idx_documents_session_namezC."idx_documents_session_name" RENAME TO "ix_documents_session_name"!idx_message_embeddings_created_atzQ."idx_message_embeddings_created_at" RENAME TO "ix_message_embeddings_created_at"%idx_message_embeddings_embedding_hnswzY."idx_message_embeddings_embedding_hnsw" RENAME TO "ix_message_embeddings_embedding_hnsw"!idx_message_embeddings_message_idzQ."idx_message_embeddings_message_id" RENAME TO "ix_message_embeddings_message_id" idx_message_embeddings_peer_namezO."idx_message_embeddings_peer_name" RENAME TO "ix_message_embeddings_peer_name"#idx_message_embeddings_session_namezU."idx_message_embeddings_session_name" RENAME TO "ix_message_embeddings_session_name"%idx_message_embeddings_workspace_namezY."idx_message_embeddings_workspace_name" RENAME TO "ix_message_embeddings_workspace_name"idx_messages_content_ginz?."idx_messages_content_gin" RENAME TO "ix_messages_content_gin"idx_messages_session_lookupzE."idx_messages_session_lookup" RENAME TO "ix_messages_session_lookup"webhook_endpoints&idx_webhook_endpoints_workspace_lookupzY."idx_webhook_endpoints_workspace_lookup" RENAME TO "ix_webhook_endpoints_workspace_name"ix_messages_id
table_nameschemaix_messages_public_idix_peers_nameidx_peers_workspace_lookupix_workspaces_name&ix_active_queue_sessions_work_unit_keyqueue!ix_queue_workspace_name_processedix_queue_processed	processedFr   r7   #ix_queue_work_unit_key_processed_id)work_unit_keyr@   idix_sessions_workspace_nameworkspace_name%fk_messages_workspace_name_workspaces)r7   type_)fk_message_embeddings_message_id_messagesM.message_embeddings DROP CONSTRAINT fk_message_embeddings_message_id_messages
                ALTER TABLE .message_embeddings
                ADD CONSTRAINT fk_message_embeddings_message_id_messages
                FOREIGN KEY (message_id) REFERENCES zG.messages(public_id)
                ON DELETE CASCADE
                )r   get_bindsainspectr   executer   r7   r   
drop_indexcreate_indexdrop_constraintconn	inspectors     e/DATA/AppData/hermes/projects/honcho/migrations/versions/baa22cad81e2_standardize_constraint_names.pyupgraderX      s0
   ;==D
4  I !79  
 	 Sv  S  S  S 	
 	
 	
 <h	  
 	 av  a  a  a 	
 	
 	
 ">)TT 
~v~~~ 	
 	
 	
 %:HiPP 
}v}}} 	
 	
 	
 %>)TT 
 Yv  Y  Y  Y 	
 	
 	
 ~xKK 
kvkkk 	
 	
 	
 ,	  

 	 av  a  a  a 	
 	
 	
 
4  I M#=yII 
fvfff 	
 	
 	

 M#=yII 
fvfff 	
 	
 	
 K!?KK 
nvnnn 	
 	
 	

 K!99EE 
bvbbb 	
 	
 	

 K!99EE 
bvbbb 	
 	
 	

 K!=yII 
jvjjj 	
 	
 	
 A9  
 	xvxxx 	
 	
 	

 Ey  
 	 Av  A  A  A 	
 	
 	

 A9  
 	xvxxx 	
 	
 	

 @)  
 	vvvvv 	
 	
 	

 CY  
 	|v||| 	
 	
 	

 Ey  
 	 Av  A  A  A 	
 	
 	
 J :IFF 
fvfff 	
 	
 	

 J =yII 
lvlll 	
 	
 	
 Ey  
 	 Av  A  A  A 	
 	
 	
 J 0)<< N
&:fMMMMJ 7CC U
-*VTTTTG_i88 J
o'&IIIIG99EE W
2wvVVVVL"6	BB T
*|FSSSS !I9  
 	4.	
 	
 	
 	
 G@)LL 

/GF	
 	
 	
 	
 !5yAA 

 'K=v	
 	
 	
 	
 !F	RR 

1000	
 	
 	
 	
 
$@)LL 

(	
 	
 	
 	
 ;\9  
 	3		
 	
 	
 	
 
4  I 3	  
 	tvttt 	
 	
 	

 	#  6<   		
 		
 		
 		
 		

 
    c            	         t          j                    } t          j        |           }t	          ddd|          r^|                     t          dt           d                     |                     t          dt           dt           d                     t          j        d	d
ddgdgt          t                     t          j	        ddt                     t          j	        ddt                     t          j
        dddgdt                     t          j
        ddddgdt                     t          j
        dddgdt                     t          j
        ddddgdt                     t          j
        dddgdt                     t          j
        dd
d gdt                     t          j
        d!d
d"gdt                     |                     t          d#t           d$                     |                     t          d#t           d%                     |                     t          d#t           d&                     |                     t          d#t           d'                     |                     t          d#t           d(                     |                     t          d#t           d)                     |                     t          d#t           d*                     |                     t          d#t           d+                     |                     t          d#t           d,                     |                     t          d#t           d-                     |                     t          d#t           d.                     |                     t          d#t           d/                     |                     t          d#t           d0                     |                     t          d#t           d1                     |                     t          d#t           d2                     |                     t          dt           d3                     |                     t          dt           d4                     |                     t          dt           d5                     |                     t          dt           d6                     |                     t          dt           d7                     |                     t          dt           d8                     |                     t          dt           d9                     d S ):Nr   rI   r!   r   rJ   rK   rL   z%.messages(public_id)
                rG   r   r   rF   name)source_schemareferent_schemarE   r   r5   r?   r=   r<   r   rC   FrA   r>   r@   r;   r:   r   r9   r8   	public_idr4   rD   r#   zY."ix_webhook_endpoints_workspace_name" RENAME TO "idx_webhook_endpoints_workspace_lookup"zE."ix_messages_session_lookup" RENAME TO "idx_messages_session_lookup"z?."ix_messages_content_gin" RENAME TO "idx_messages_content_gin"zY."ix_message_embeddings_workspace_name" RENAME TO "idx_message_embeddings_workspace_name"zU."ix_message_embeddings_session_name" RENAME TO "idx_message_embeddings_session_name"zO."ix_message_embeddings_peer_name" RENAME TO "idx_message_embeddings_peer_name"zQ."ix_message_embeddings_message_id" RENAME TO "idx_message_embeddings_message_id"zY."ix_message_embeddings_embedding_hnsw" RENAME TO "idx_message_embeddings_embedding_hnsw"zQ."ix_message_embeddings_created_at" RENAME TO "idx_message_embeddings_created_at"zC."ix_documents_session_name" RENAME TO "idx_documents_session_name"z;."ix_documents_observer" RENAME TO "idx_documents_observer"z;."ix_documents_observed" RENAME TO "idx_documents_observed"zG."ix_documents_embedding_hnsw" RENAME TO "idx_documents_embedding_hnsw"z?."ix_collections_observer" RENAME TO "idx_collections_observer"z?."ix_collections_observed" RENAME TO "idx_collections_observed"zy.message_embeddings RENAME CONSTRAINT "fk_message_embeddings_message_id_messages" TO "message_embeddings_message_id_fkey"zD.workspaces RENAME CONSTRAINT "uq_workspaces_name" TO "uq_apps_name"zq.messages RENAME CONSTRAINT "uq_messages_workspace_name_session_name_seq_in_session" TO "uq_messages_session_seq"zV.sessions RENAME CONSTRAINT "uq_sessions_name_workspace_name" TO "unique_session_name"zW.peers RENAME CONSTRAINT "uq_peers_name_workspace_name" TO "unique_name_workspace_peer"zy.collections RENAME CONSTRAINT "uq_collections_observer_observed_workspace_name" TO "unique_observer_observed_collection"zk.active_queue_sessions RENAME CONSTRAINT "uq_active_queue_sessions_work_unit_key" TO "unique_work_unit_key")r   rM   rN   rO   r   rP   r   r7   create_foreign_keyrQ   rR   rT   s     rW   	downgrader`   @  s   ;==D
4  I 3	  
 	tvttt 	
 	
 	

 	#  6<   	
 	
 	
 /		    M.:fUUUUM&76JJJJ O0	    O+	;'    OlVHU6    O$	6"    OOWvhuVTTTTOk]5QW    O$j4&vVVVV 	LL|6|||	
 	
  
 	LLh6hhh	
 	
  
 	LLb6bbb	
 	
  
 	LL|6|||	
 	
  
 	LLx6xxx	
 	
  
 	LLr6rrr	
 	
  
 	LLt6ttt	
 	
  
 	LL|6|||	
 	
  
 	LLt6ttt	
 	
  
 	LLf6fff	
 	
  
 	LL^6^^^	
 	
  
 	LL^6^^^	
 	
  
 	LLj6jjj	
 	
  
 	LLb6bbb	
 	
  
 	LLb6bbb	
 	
   	LL ]6  ]  ]  ]	
 	
   	LLg6ggg	
 	
  
 	LL U6  U  U  U	
 	
  
 	LLy6yyy	
 	
  
 	LLz6zzz	
 	
  
 	LL ]6  ]  ]  ]	
 	
  
 	LL O6  O  O  O	
 	
    rY   )r   N)__doc__collections.abcr   
sqlalchemyrN   alembicr   r   migrations.utilsr   r   r   r
   str__annotations__r   r   r   r7   rX   r`    rY   rW   <module>ri      s      % $ $ $ $ $                 H H H H H H H H H H #   *sTz * * *,0sXc]"T) 0 0 0)-
C(3-$& - - -	c
 c
 c
 c
L	M M M M M MrY   