§
    s�’jï  ã                  ól   — d dl mZ d dlZd dlmZ d dlmZ  ej        d¦  «        Z G d„ d¦  «        Z	dS )é    )ÚannotationsN)ÚAny)Ú
Connectionz'dscons.postgres.dossier_reviews.queriesc                  ó>   — e Zd ZdZ	 	 ddd„Zdd	œdd„Zdddœdd„ZdS )Ú DossierReviewSessionQueriesMixinzBQuery methods for Dossier Review sessions and associated findings.NÚproject_codeú
str | NoneÚ	review_idÚreturnúlist[dict[str, Any]]c                ó4  ‡ — ‰                       ¦   «         5 }|                     ¦   «         5 }|                     t          ||dœ¦  «         |                     ¦   «         }ddd¦  «         n# 1 swxY w Y   ddd¦  «         n# 1 swxY w Y   ˆ fd„|D ¦   «         S )zTFetch dossier review workflow sessions with nested findings, actions, and snapshots.©r   r
   Nc                ó:   •— g | ]}‰                      |¦  «        ‘ŒS © ©Ú%_normalize_dossier_review_session_row©Ú.0ÚrowÚselfs     €úGC:\Projects\DSCons\app\core\postgres\dossier_reviews\session_queries.pyú
<listcomp>zRDossierReviewSessionQueriesMixin.fetch_dossier_review_sessions.<locals>.<listcomp>   ó'   ø€ ÐPÐPÐPÀC�×:Ò:¸3Ñ?Ô?ÐPÐPÐPó    )Úget_connectionÚcursorÚexecuteÚDOSSIER_REVIEW_SESSIONS_QUERYÚfetchall)r   r   r
   Ú
connectionr   Úrowss   `     r   Úfetch_dossier_review_sessionsz>DossierReviewSessionQueriesMixin.fetch_dossier_review_sessions   s  ø€ ð × Ò Ñ"Ô"ð 	% j°*×2CÒ2CÑ2EÔ2Eð 	%ÈØ�NŠNÝ-Ø!-¸IÐFÐFñô ð ð —?’?Ñ$Ô$ˆDð	%ð 	%ð 	%ñ 	%ô 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%øøøð 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%ñ 	%ô 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%øøøð 	%ð 	%ð 	%ð 	%ð QÐPÐPÐPÈ4ÐPÑPÔPÐPs4   –B«3A*ÁBÁ*A.	Á.BÁ1A.	Á2BÂBÂB)r    Ústrr    úConnection[Any] | NoneÚerror_messageúdict[str, Any]c               ó’   — |�|                       ||¬¦  «        n|                      |¬¦  «        }|st          |¦  «        ‚|d         S )zMFetch one dossier review session, using the active transaction when provided.N)r
   r   )Ú._fetch_dossier_review_sessions_with_connectionr"   Ú
ValueError)r   r
   r    r%   Úsessionss        r   Ú$_fetch_single_dossier_review_sessionzEDossierReviewSessionQueriesMixin._fetch_single_dossier_review_session   sl   € ð Ð%ð ×?Ò?Ø ið @ñ ô ð ð ×3Ò3¸iÐ3ÑHÔHð 	ð ð 	,Ý˜]Ñ+Ô+Ð+Ø˜Œ{Ðr   r   úConnection[Any]c               óÜ   ‡ — |                      ¦   «         5 }|                     t          ||dœ¦  «         |                     ¦   «         }ddd¦  «         n# 1 swxY w Y   ˆ fd„|D ¦   «         S )zHFetch dossier review sessions inside an existing transaction connection.r   Nc                ó:   •— g | ]}‰                      |¦  «        ‘ŒS r   r   r   s     €r   r   zcDossierReviewSessionQueriesMixin._fetch_dossier_review_sessions_with_connection.<locals>.<listcomp>=   r   r   )r   r   r   r   )r   r    r   r
   r   r!   s   `     r   r(   zODossierReviewSessionQueriesMixin._fetch_dossier_review_sessions_with_connection/   s»   ø€ ð ×ÒÑ Ô ð 	% FØ�NŠNÝ-Ø!-¸IÐFÐFñô ð ð —?’?Ñ$Ô$ˆDð	%ð 	%ð 	%ñ 	%ô 	%ð 	%ð 	%ð 	%ð 	%ð 	%ð 	%øøøð 	%ð 	%ð 	%ð 	%ð QÐPÐPÐPÈ4ÐPÑPÔPÐPs   –3AÁAÁA)NN)r   r	   r
   r	   r   r   )r
   r#   r    r$   r%   r#   r   r&   )r    r,   r   r	   r
   r	   r   r   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__r"   r+   r(   r   r   r   r   r      s‘   € € € € € ØLÐLð $(Ø $ðQð Qð Qð Qð Qð$ .2ð	ð ð ð ð ð ð. $(Ø $ðQð Qð Qð Qð Qð Qð Qð Qr   r   )
Ú
__future__r   ÚloggingÚtypingr   Úpsycopg.connectionr   Ú	getLoggerÚloggerr   r   r   r   ú<module>r9      s“   ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø Ð Ð Ð Ð Ð à )Ð )Ð )Ð )Ð )Ð )à	ˆÔ	ÐDÑ	EÔ	E€ð2Qð 2Qð 2Qð 2Qð 2Qñ 2Qô 2Qð 2Qð 2Qð 2Qr   