
    mohU                        d dl mZ d dlmZ d dlmZmZ d dlmZ d dl	m
Z
mZ  e            Ze                    de          dd
            ZdS )    )annotations)defaultdict)	APIRouterRequest)HTMLResponse)	templatessbz/sync)response_classrequestr   c           	       K   t          j        d                              d                              dd                              d                                          j        pg }|st          j        d| g i i d          S d	 |D             }t          j        d
                              d          	                    d|                                          j        pg }t          d           }|D ]$}||d                  |d         xx         dz  cc<   %t          j        d                              d          	                    d|                                          j        pg }t          t                    }|D ]1}|                    d          dk    r||d         xx         dz  cc<   2t          j        d| |t          |          t          |          d          S )Ningest_batches*
started_atT)desc   zsync_index.html)r   rowsevent_statspending_statsc                H    g | ]}|                     d           |d           S )batch_id)get).0bs     -/var/www/html/bot/app/web/pages/sync/index.py
<listcomp>zsync_index.<locals>.<listcomp>   s-    EEE11553D3DE:EEE    gov_staff_eventszbatch_id,event_typer   c                 *    t          t                    S )N)r   int r   r   <lambda>zsync_index.<locals>.<lambda>   s    k#&6&6 r   
event_type   match_decisionszbatch_id,decisiondecisionPENDINGzsync/index.html)r	   tableselectorderlimitexecutedatar   TemplateResponsein_r   r   r   dict)	r   batches	batch_idsevr   edecr   ds	            r   
sync_indexr6   	   s     h'((//44::<d:SSYYZ\]]eegglrprG )*;2PR>
 >
   	 FEEEEI	$	%	%	,	,-B	C	C	G	G
T]	^	^	f	f	h	h	m	sqsB6677K 9 9AjM"1\?333q83333
($
%
%
,
,-@
A
A
E
EjR[
\
\
d
d
f
f
k
qoqC$$M . .55	))!J-(((A-(((%&7GK((4;N;N: :   r   N)r   r   )
__future__r   collectionsr   fastapir   r   fastapi.responsesr   app.web.depsr   r	   routerr   r6   r    r   r   <module>r=      s    " " " " " " # # # # # # & & & & & & & & * * * * * * & & & & & & & &	GL11   21  r   