
    m<jO
                        d dl Z d dlZd dlZd dlZd dlZej
                  d   Zej
                  d   Zd Zd Z	d Z
 ee      Z ee      Z e	e      Z e	e      Zg dZd Z ee      \  ZZ ee      \  ZZ ed	 ej-                         D              Zi d
ej                  j1                  ej2                  j4                        j7                         dej9                  d      j;                         d    d ee      d ee      d ej>                   ej@                   e!e            jE                               jG                         d ej>                   ej@                   e!e            jE                               jG                         deek(  d e!eez
        d e!eez
        dedej9                  d      j;                         d    dej9                  d      j;                         d    d e$ej9                  d      jK                               d e$ej9                  d      jK                               d e$ej9                  d      jK                               dej9                  d       j;                         d    d!ej9                  d"      j;                         d    d#D  ci c].  } |  eej9                  d$| z   d%z         jK                               0 c}  e
ed&       e
ed&       e
ed'       e
ed'      d(Z& e' ej@                  e&d)*             ejQ                          ejQ                          yc c} w )+    N      c                 j    t        j                  d| z   dz   d      }t         j                  |_        |S )Nzfile:z?mode=ro&immutable=1T)uri)sqlite3connectRowrow_factory)pcs      /opt/struktur/AA-043-P35-gate.pycor      s,    
??71933=W[[q}abZb    c                 j    | j                  d      D ch c]  }|d   |d   |d   |d   f c}S c c}w )Nzpragma foreign_key_checkr   r   r      )execute)r   xs     r   fksr      s8    199=W3XYaQqT!A$qtAaD)YYYs   0c                 R    t        | j                  |      j                               S N)dictr   fetchall)r   qs     r   distr      s    d199Q<00233r   )	idknowledge_unit_identity	statementsource_identitysource_version_idcontent_version_hashreview_state
gold_statelegacy_placeholderc                    | j                  d      D ch c]  }|d   	 }}t        D cg c]	  }||v s| }}| j                  d      D ci c]  d   t        fd|D               c}|fS c c}w c c}w c c}w )Nz"pragma table_info(knowledge_units)r   zselect * from knowledge_unitsr   c              3   (   K   | ]	  }|     y wr    ).0r   rs     r   	<genexpr>zoldmap.<locals>.<genexpr>	   s1       DW  NO  EF  GH  EI  DWs   )r   oldcolstuple)r   r(   colsr   uses    `   r   oldmapr.      s    YYCDEqtEEW^KlRSbcgkbkAKlsKl  ab  aj  aj  kJ  aK  vL  \]vwx|v}  D  DW  SV  DW  W  wW  vL  MP  vP  oPEKl  vLs   A3	A8A8A=c              #   R   K   | ]  \  }}t         j                  |      |k(   ! y wr   )pmget)r'   ivs      r   r)   r)   
   s      3WSQqBFF1IqL3Ws   %'
checked_at	integrityzpragma integrity_checkfk_countbackup_fk_countfk_fingerprintbackup_fingerprintfk_set_equalnew_fk_rowsremoved_fk_rowsexisting_ku_rows_unchangedku_totalz$select count(*) from knowledge_unitslegacyz?select count(*) from knowledge_units where legacy_placeholder=1reviewzGselect review_state,count(*) from knowledge_units group by review_stateevidencezKselect evidence_class,count(*) from knowledge_units group by evidence_classgoldzCselect gold_state,count(*) from knowledge_units group by gold_stateprovz.select count(*) from knowledge_unit_provenancereview_auditz0select count(*) from knowledge_unit_review_audit)knowledge_unit_provenanceknowledge_unit_review_auditzpragma foreign_key_check()zSselect graphiti_status,count(*) from graphiti_import_queue group by graphiti_statuszUselect graphiti_release,count(*) from graphiti_import_queue group by graphiti_release)new_table_fkqueue_statusbackup_queue_statusreleasebackup_releaseF)ensure_ascii))r   hashlibjsonsysdatetimeargvPBr   r   r   r   bpfbfr*   r.   r0   pcbmbcallitemsexisting_samenowtimezoneutc	isoformatr   fetchonelensha256dumpssortedencode	hexdigestr   r   outprintclose)ts   0r   <module>rm      st   ( ( (((1+!qc Y 3Q%2a5SV"AR  1KPQi2vayB3WBHHJ3W0W- K\(##''(9(9(=(=>HHJ  K;WXW`W`ayWz  XD  XD  XF  GH  XI  K  JT  UX  Y[  U\  K  ]n  or  su  ov  K  wG  HV  HO  HV  HV  Wa  W[  Wa  Wa  bh  ik  bl  Wm  Wt  Wt  Wv  Hw  HA  HA  HC  K  DX  Yg  Y`  Yg  Yg  hr  hl  hr  hr  sy  z|  s}  h~  hE  hE  hG  YH  YR  YR  YT  K  Uc  df  hj  dj  K  kx  y  @B  CE  @E  yF  K  GX  Y_  `b  ce  `e  Yf  K  gC  DQ  K  R\  ]^  ]f  ]f  gM  ]N  ]W  ]W  ]Y  Z[  ]\  K  ]e  fg  fo  fo  pq	  fr	  f{	  f{	  f}	  ~		  f@
  K  A
I
  J
N
  O
P
  O
X
  O
X
  Y
b  O
c  O
l  O
l  O
n  J
o  K  pz  {  @A  @I  @I  JW  @X  @a  @a  @c  {d  K  ek  lp  qr  qz  qz  {@  qA  qJ  qJ  qL  lM  K  NT  UV  U^  U^  _O  UP  UY  UY  U[  \]  U^  K  _m  no  nw  nw  xj  nk  nt  nt  nv  wx  ny  K  RM  IN  MN  JK  LO  PQ  PY  PY  Zu  vw  Zw  x{  Z{  P|  PE  PE  PG  LH  JH  IN  ^b  cd  ez  ^{  RV  WX  Yn  Ro  z~  @  AX  zY  ko  pq  rI  kJ  K jdjj%( )1779aggi INs   73M