Ë
    8ê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                   ó0   — e Zd Zd„ 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.1-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   «       | j	                  |d   |d   hddh«       ||fD ]3  }| j	                  t        j                  |d   «      d	   d
   |d   «       Œ5 y )Nzfixtures/conflict-header-a.jsonzfixtures/conflict-header-b.jsonÚseq_nor   Úentity_revisioné   é   r
   r   Úrevision)r   r   r   r   r   ÚassertNotEqual©r   ÚaÚbr   s       r   Útest_conflicting_same_sequencez'Fixtures.test_conflicting_same_sequence   sØ   € Ü
�*‰*”dÐ<Ñ<×GÑGÓIÓ
JˆÜ
�*‰*”dÐ<Ñ<×GÑGÓIÓ
JˆØ×Ñ˜˜8™ Q x¡[Ô1°$×2EÑ2EÀaÈÑFWÐXYÐZhÑXiÔ2jØ×Ñ˜!Ð-Ñ.¨qÐ1BÑ/CÐDÀaÈÀUÔKØ�A�ò 	gˆAØ×ÑœTŸZ™Z¨¨.Ñ(9Ó:¸8ÑDÀZÑPÐQRÐSdÑQeÕfñ	gr   c                 óˆ  — t        j                  t        dz  j                  «       «      }t        j                  t        dz  j                  «       «      }| j	                  |d   |d   «       | j                  |d   |d   hddh«       ||fD ]3  }| j                  t        j                  |d   «      d   d	   |d   «       Œ5 y )
Nzfixtures/parallel-header-a.jsonzfixtures/parallel-header-b.jsonr/   r0   é   é   r
   r   r3   )r   r   r   r   r4   r   r5   s       r   Ú%test_distinct_sequences_and_revisionsz.Fixtures.test_distinct_sequences_and_revisions   s½   € Ü
�*‰*”dÐ<Ñ<×GÑGÓIÓ
JˆÜ
�*‰*”dÐ<Ñ<×GÑGÓIÓ
JˆØ×Ñ˜A˜h™K¨¨(©Ô4Ø×Ñ˜!Ð-Ñ.¨qÐ1BÑ/CÐDÀaÈÀUÔKØ�A�ò 	gˆAØ×ÑœTŸZ™Z¨¨.Ñ(9Ó:¸8ÑDÀZÑPÐQRÐSdÑQeÕfñ	gr   c                 ó®   — t         dz  j                  d«      D ]:  }t        j                  |j	                  «       «      }| j                  |d   d«       Œ< y )Nr   r	   r!   z$a20b89f5-1fd9-42af-8919-7db720aa8c31)r   r   r   r   r   r   r   s      r   Útest_fresh_synthetic_identityz&Fixtures.test_fresh_synthetic_identity    sK   € Ü�z‘/×'Ñ'¨Ó1ò 	TˆAÜ�j‰j˜Ÿ™›Ó'ˆAØ×Ñ˜Q˜{™^Ð,RÕSñ	Tr   N)	Ú__name__Ú
__module__Ú__qualname__r   r)   r-   r8   r<   r>   © r   r   r   r      s&   „ òJòUò
cògògóTr   r   )r   r   ÚunittestÚpathlibr   Ú__file__ÚresolveÚparentsr   ÚTestCaser   rB   r   r   ú<module>rI      s?   ðß Ó Ý Ù	ˆ(ƒ^×ÑÓ×%Ñ% aÑ(€ôTˆx× Ñ õ Tr   