Ë
    Èêj%  ã                   ó˜   — d dl Z d dlZd dlZd dlmZ  ee«      j                  «       j                  d   Z G d„ dej                  «      Z
y)é    N)ÚPathé   c                   ó$   — e Zd Zd„ Zd„ Zd„ Zd„ Zy)ÚFixturesc                 ó(  — t         dz  j                  d«      D ]w  }t        j                  |j	                  «       «      }| j                  t        j                  |d   j                  «       «      j                  «       |d   |j                  «       Œy y )NÚfixturesú*.jsonÚpayload_jsonÚcontent_hash)ÚROOTÚglobÚjsonÚloadsÚ	read_textÚassertEqualÚhashlibÚsha256ÚencodeÚ	hexdigestÚname)ÚselfÚfÚes      úa/var/www/app.yachtmemory.net/YM-Source-Catalog-v2-Concurrency-0.1.0-REVIEW/tests/test_fixtures.pyÚtest_envelope_hasheszFixtures.test_envelope_hashes   sŒ   € Ü�z‘/×'Ñ'¨Ó1ò 	JˆAÜ�j‰j˜Ÿ™›Ó'ˆA¨×(8Ñ(8¼¿¹ÈÈ.ÑHY×H`ÑH`ÓHbÓ9c×9mÑ9mÓ9oÐpqð  sAñ  qBð  CD÷  CIñ  CIõ  )Jñ	Jó    c                 ó   — t         dz  j                  d«      D ]³  }t        j                  |j	                  «       «      }t        j                  |d   «      }|j                  d|j                  d|«      «      }| j                  |d   |d   |j                  «       | j                  |d   j                  |d   «      |j                  «       Œµ y )	Nr   r	   r
   ÚheaderÚchunkÚ	vessel_idÚ
entity_keyÚsnapshot_id)
r   r   r   r   r   Úgetr   r   Ú
assertTrueÚ
startswith)r   r   r   ÚpÚinners        r   Útest_all_vessel_and_snapshotz%Fixtures.test_all_vessel_and_snapshot   s­   € Ü�z‘/×'Ñ'¨Ó1ò 	UˆAÜ�j‰j˜Ÿ™›Ó'ˆA¬$¯*©*°Q°~Ñ5FÓ*G¨ÈaÏeÉeÐT\Ð]^×]bÑ]bÐcjÐklÓ]mÓNnÈØ×Ñ˜Q˜{™^¨E°+Ñ,>¸q¿v¹vÔFØ�O‰O˜A˜l™O×6Ñ6°u¸]Ñ7KÓLÈQÏVÉVÕTñ	Ur   c                 óz   — t         dz  j                  «       }| j                  d|«       | j                  d|«       y )Nz-receiver/ym-sync-catalog-v2-atomic-review.phpz.const DB_NAME = 'yachtmemory_catalog_v2_test';zDSELECT vessel_id FROM telemetry_vessels WHERE vessel_id=? FOR UPDATE)r   r   ÚassertIn)r   Úcodes     r   Útest_review_only_targetz Fixtures.test_review_only_target   s5   € ÜÐBÑB×MÑMÓOˆØ�‰ÐFÀtÔLØ�‰Ð\Ð]aÕbr   c                 ó  — t        j                  t        dz  j                  «       «      }t        j                  t        dz  j                  «       «      }| j	                  |d   |d   «       | j                  |d   |d   «       y )Nzfixtures/conflict-header-a.jsonzfixtures/conflict-header-b.jsonÚseq_nor   )r   r   r   r   r   ÚassertNotEqual)r   ÚaÚbs      r   Útest_conflicting_same_sequencez'Fixtures.test_conflicting_same_sequence   so   € Ü
�*‰*”dÐ<Ñ<×GÑGÓIÓ
JˆÜ
�*‰*”dÐ<Ñ<×GÑGÓIÓ
JˆØ×Ñ˜˜8™ Q x¡[Ô1°$×2EÑ2EÀaÈÑFWÐXYÐZhÑXiÕ2jr   N)Ú__name__Ú
__module__Ú__qualname__r   r(   r,   r2   © r   r   r   r      s   „ òJòUò
cókr   r   )r   r   ÚunittestÚpathlibr   Ú__file__ÚresolveÚparentsr   ÚTestCaser   r6   r   r   ú<module>r=      s?   ðß Ó Ý Ù	ˆ(ƒ^×ÑÓ×%Ñ% aÑ(€ôkˆx× Ñ õ kr   