
    [j                        d dl Zd dlZd dlmZ d dlZ ee      j                  Zej                  j                  dedz        Zerej                  sJ ej                  j                  e      Zej                  j                  e       d Zd Zej$                  j'                  dg d      d	        Zd
 Zd Zd Zd Zy)    N)Pathrczrecovery_controller.pyc                  ^    dddddidddd	d
it        t        j                        dddidS )N   10receipthandledstagereason_code9recovery_receiptbusiness_commit_reconciled@aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa)r   r   provenance_digestblocked_receipthandler_exception)versionreceiptsterminal_receiptsterminal_failures)strr   TARGET     Z.omo/evidence/task26/task26-telegram-poll-recovery-st_01a00d2c/test_recovery_controller.pysampler      s    qT9S\2],^tw  BT  c  TZ  y[  t\  ru  vx  v  v  r@  J[  j}  A~  q  @  @r   c                  >    t         j                  t                      y )N)r   validate_targetr   r   r   r   test_exact_targetr       s    **684r   kind)extraconflictreasonentryc                    t               }| dk(  rddd|d   d<   n[| dk(  r#dd	d|d
   t        t        j                        <   n3| dk(  r#d|d   t        t        j                           d<   ndd	d|d
   d<   t	        j
                  t        j                        5  t        j                  |       d d d        y # 1 sw Y   y xY w)Nr"   r   r   r
   r   1r#   r   r	   r   r$   otherr   badr   )r   r   r   r   pytestraisesClosedr   )r!   vs     r   test_fail_closedr.      s    	8'M7HWj.k!'(-
JiV_5`q}S^4
Hn7Q*+C		N;MJ#(yAa
mDmmBIIr11!4s   B99Cc                  p   t         j                  d      d   dk(  sJ t         j                  d      d   dk(  sJ t        j                  t         j                        5  t         j                  t        j                  i t               ddi      j                                d d d        y # 1 sw Y   y xY w)Ns   {"receipts":{},"version":1}r      s2   {"receipts":{},"terminal_receipts":{},"version":2}   r"   )	r   parse_receiptr*   r+   r,   jsondumpsr   encoder   r   r   test_versions_and_unknown_keysr6      s    
78CQFFF
NOPYZ\]]]]mmBIIr//

;Qfh;Qwq;Q0R0Y0Y0[\s   AB,,B5c                    | dz  }t         j                  |d       |j                         dk(  rt        |      dk(  sJ t	        j
                  t              5  t         j                  |d       d d d        y # 1 sw Y   y xY w)Nx   xi     y)r   create
read_bytes	stat_moder*   r+   FileExistsError)tmp_pathps     r   test_create_append_only_privaterA      sZ    C<		!D!)=)A,PUBU"U)UmmO$RYYq%6$$$s   A88Bc                 <    | j                         j                  dz  S )Ni  )statst_mode)r@   s    r   r=   r=      s    ((..r   c                    | dz  }|dz  j                  d       |dz  j                  d       |dz  j                  d       |dz  j                  d       |d	z  j                  d
       |dz  j                  d       |j                  t        d|       |j                  t        dd       |j                  t        d|dz         t        j	                         }d|v rd|v rt        d |D              sJ y )Nr@   	customersT)parentszcustomers/registry.jsonz{}zdata/customers/czdata/customers/c/x.jsonzdata/customers/c/x.lock zconfig.yamlzx: 1PROFILECUSTOMERcRECEIPTzdata/r.jsonc              3   @   K   | ]  }|j                  d          yw)z.lockN)endswith).0ks     r   	<genexpr>z0test_inventory_excludes_locks.<locals>.<genexpr>   sL       nR  PQ  KL  st  s}  s}  ~E  sF  oF  PQs   )mkdir
write_textsetattrr   	inventoryall)r?   monkeypatchr@   r8   s       r   test_inventory_excludes_locksrX      s   C<;%%d%3Q7P5P4\4\]a4bdefxdxcc  IMc  dN  PQ  Rk  Pk  Ow  Ow  x|  O}  @  AZ  Z  ~f  ~f  gi  ~j  lm  n{  l{  kG  kG  HN  kO  P[  Pc  Pc  df  gp  qr  Ps  t  tG  tG  HJ  KU  VY  tZ  [f  [n  [n  oq  r{  |}  ~K  |K  [L  OQ  O[  O[  O]  MN  e~  BC  eC  Ha  ef  Hf  kn  nR  PQ  nR  kR  ^R  eR  kRr   )importlib.util	importlibr3   pathlibr   r*   __file__parentHEREutilspec_from_file_locationSloadermodule_from_specr   exec_moduler   r    markparametrizer.   r6   rA   r=   rX   r   r   r   <module>rg      s      	(^Y^^CCDNfIfg1opuvu}u}h}o}>>""1%ahh&:&:2&> @ 4 EF5 G5]7 /Rr   