+
    =i2                        ^ RI t ^ RIt^ RIHt ^ RIHt ^ RIt^ RIHt ^ RIH	t	 ^ RI
HtHt ^ RIHt ^ RIHt ^ R	IHtHtHt ^ R
IHt ] P.                  ! ]4      t]P4                  t ! R R4      t ! R R4      t ! R R4      t ! R R4      tR tR t R t!R t"R t#R R lt$]%3R R llt&R R lt'R t(R R  lt)R! R" lt*R# )#    N)partial)unpack)_DecodeVarint32)_VarintBytes)MessageToDict	ParseDict)EncodeError)NotImplementedError)ID_NAME_MAPNAME_CLASS_MAPNAME_ID_MAP)ArchiveInfoc                   f   a  ] tR t^t o R	V 3R lR llt]R	R l4       t]R 4       tR tR t	Rt
V tR# )
IWAFileNc                   < V ^8  d   QhRR/#    returnN )format__classdict__s   "y/Users/tonyclaw/.openclaw/workspace/scripts/youtube-playlists/venv/lib/python3.14/site-packages/numbers_parser/iwafile.py__annotate__IWAFile.__annotate__   s     ! ! !    c                    Wn         W n        R # Nchunksfilename)selfr   r    s   &&&r   __init__IWAFile.__init__   s     r   c                    . pV'       dA   \        R V\        V4      4       \        P                  W4      w  rAVP	                  V4       KH  V ! W24      #   \
         d"   pT'       d   \        RT,           4      Thh Rp?ii ; i)from_buffer: filename=%s len=%dzFailed to deserialize N)debuglenIWACompressedChunkfrom_bufferappend	Exception
ValueError)clsdatar    r   chunkes   &&&   r   r)   IWAFile.from_buffer   sr    	F73t9M0<<TLe$v(( 	 !9H!DE1L	s   	A AA B A;;B c                p    T ! VR ,           Uu. uF  p\         P                  V4      NK  	  up4      # u upi )r   )r(   	from_dict)r-   _dictr/   s   && r   r3   IWAFile.from_dict*   s/    U8_U_E&007_UVVU   3c                     R V P                    Uu. uF  qP                  4       NK  	  up/# u upi   \         d6   pT P                  '       d   \	        RT P                  ,           4      Thh Rp?ii ; i)r   zFailed to serialize N)r   to_dictr+   r    r,   )r!   r/   r0   s   &  r   r8   IWAFile.to_dict.   s_    	DKKHK5}}KHIIH 	}}} !7$--!GHaO	s    2 -2 2 A20A--A2c                |    R P                  V P                   Uu. uF  qP                  4       NK  	  up4      # u upi )r   )joinr   	to_buffer)r!   r/   s   & r   r<   IWAFile.to_buffer6   s,    xxDu*DEEDs   9r   r   )__name__
__module____qualname____firstlineno__r"   classmethodr)   r3   r8   r<   __static_attributes____classdictcell__r   s   @r   r   r      sJ     ! !   W WF Fr   r   c                   x   a  ] tR t^:t o V 3R lR ltR t]R 4       t]RR l4       t]R 4       t	R t
R	 tR
tV tR# )r(   c                   < V ^8  d   QhRR/# r   r   )r   r   s   "r   r   IWACompressedChunk.__annotate__;   s     ! !D !r   c                    Wn         R # r   archives)r!   rK   s   &&r   r"   IWACompressedChunk.__init__;   s     r   c                4    V P                   VP                   8H  # r   rJ   r!   others   &&r   __eq__IWACompressedChunk.__eq__>   s    }}..r   c              #  Z  "   V'       d   VR ,          pV^ ,          pV^ 8w  d   RVR R2p\        V4      h\        R\        VR,          4      R,           4      ^ ,          pV^^V,            pV^V,           R p \        P                  ! V4      x  K  R#   \
         d	    Tx   K  i ; i5i)N   Nz+IWA chunk does not start with 0x00! (found x)<I   NN    N)r,   r   bytessnappy
uncompressr+   )r-   r.   header
first_bytemsglengthr/   s   &&     r   _decompress_all"IWACompressedChunk._decompress_allA   s     "XFJT!CJq>QRS   D%r
"3g"=>qAFQZ(EF
%D''..     	s/   B+A-B+9B B+B($B+'B((B+Nc                    R P                  V P                  V4      4      p. pV'       dA   \        RV\        V4      4       \        P                  W4      w  rAVP                  V4       KH  V ! V4      R3# )r   r%   N)r;   rb   r&   r'   IWAArchiveSegmentr)   r*   )r-   r.   r    rK   archives   &&&  r   r)   IWACompressedChunk.from_bufferY   sa    xx++D123Xs4yI-99$IMGOOG$8}d""r   c                p    T ! VR ,           Uu. uF  p\         P                  V4      NK  	  up4      # u upi rJ   )re   r3   )r-   r4   ds   && r   r3   IWACompressedChunk.from_dictc   s2    E*<MN<Mq%//2<MNOONr6   c                b    R V P                    Uu. uF  qP                  4       NK  	  up/# u upi rJ   )rK   r8   )r!   rf   s   & r   r8   IWACompressedChunk.to_dictg   s(    dmmLm7__.mLMMLs   ,c                   R P                  V P                   Uu. uF  qP                  4       NK  	  up4      p. pV'       d8   VP                  \        P
                  ! VR,          4      4       VR,          pK?  R P                  V Uu. uF8  pR\        P                  ! R\        V4      4      R,          ,           V,           NK:  	  up4      # u upi u upi )r   :Ni   N:i   NNrZ   rW   :N   N)	r;   rK   r<   r*   r\   compressstructpackr'   )r!   rf   uncompressedpayloadspayloads   &    r   r<   IWACompressedChunk.to_bufferj   s    xxDMM RM!2!2!4M RSOOFOOL,@AB'/LxxT\]T\Wv{{4W6r::WDDT\]
 	
 !S ^s   C	>CrJ   r   )r>   r?   r@   rA   r"   rP   rB   rb   r)   r3   r8   r<   rC   rD   rE   s   @r   r(   r(   :   sb     ! !/  . # # P PN
 
r   r(   c                   f   a  ] tR t^ut o V 3R lR ltR tV 3R lR ltR t]R 4       t	R t
R	tV tR
# )ProtobufPatchc                   < V ^8  d   QhRR/# r   r   )r   r   s   "r   r   ProtobufPatch.__annotate__v   s       r   c                    Wn         R # r   r.   )r!   r.   s   &&r   r"   ProtobufPatch.__init__v   s    	r   c                4    V P                   VP                   8H  # r   r{   rN   s   &&r   rP   ProtobufPatch.__eq__y   s    yyEJJ&&r   c                    < V ^8  d   QhRS[ /# r   r   str)r   r   s   "r   r   ry   |   s     : :# :r   c                P    R V P                   P                   RV P                   R2# )< >)	__class__r>   r.   r!   s   &r   __repr__ProtobufPatch.__repr__|   s&    4>>**+1TYYKq99r   c                ,    \        V P                  4      # r   )message_to_dictr.   r   s   &r   r8   ProtobufPatch.to_dict   s    tyy))r   c                0    V ! VP                  V4      4      # r   )
FromString)r-   message_infoproto_klassr.   s   &&&&r   r   ProtobufPatch.FromString   s    
 ;))$/00r   c                6    V P                   P                  4       # r   )r.   SerializePartialToStringr   s   &r   SerializeToStringProtobufPatch.SerializeToString   s    yy1133r   r{   N)r>   r?   r@   rA   r"   rP   r   r8   rB   r   r   rC   rD   rE   s   @r   rw   rw   u   sA      ': :* 1 14 4r   rw   c                      a  ] tR t^t o V 3R lR ltR tV 3R lR lt]RR l4       t]R 4       t	R	 t
R
 tV 3R lR ltRtV tR# )re   c                   < V ^8  d   QhRR/# r   r   )r   r   s   "r   r   IWAArchiveSegment.__annotate__   s      4 r   c                    Wn         W n        R # r   r^   objects)r!   r^   r   s   &&&r   r"   IWAArchiveSegment.__init__   s    r   c                v    V P                   VP                   8H  ;'       d    V P                  VP                  8H  # r   r   rN   s   &&r   rP   IWAArchiveSegment.__eq__   s*    {{ell*LLt||u}}/LLr   c                    < V ^8  d   QhRS[ /# r   r   )r   r   s   "r   r   r      s     e e# er   c                    \        V P                  4      P                  R R4      P                  RR4      pRV P                  P                   RV P
                  P                   RV R2# )
r   z  r   z identifier=z	 objects=r   )reprr   replacer   r>   r^   
identifier)r!   self_strs   & r   r   IWAArchiveSegment.__repr__   s^    %--dC8@@sK4>>**+<8N8N7OyYaXbbcddr   Nc                Z   \        V4      w  r4\        V4      '       g   R p\        V4      h. p^ pVP                   F  p VP                  ^ 8X  di   VP
                  '       dW   V'       dO   VP                  VP                  ,          p	\        \        P                  V\        V	P                  ,          4      p
M\        VP                  ,          p
  WGWxP                  ,            p\        V
R4      '       d   V
P                  V4      pM	V
! V4      p VP#                  V4       WxP                  ,          pK  	  V ! W64      WGR 3#   \         d(    \        R\        TP                  4      ,           4      Rhi ; i  \          d%   p\        RYP                  T3,          4      RhRp?ii ; i)z2Segment doesn't seem to start with an ArchiveInfo!z.Don't know how to parse Protobuf message type Nr   z1Failed to deserialize %s payload of length %d: %s)get_archive_info_and_remainderr   r,   message_infostypeshould_mergebase_message_indexr   rw   r   r   KeyErrorr
   r   ra   hasattrr+   r*   )r-   bufr    archive_infort   r`   rs   nr   base_messageklassmessage_payloadoutputr0   s   &&&           r   r)   IWAArchiveSegment.from_buffer   s    >s CL!!FC  (66L$$)l.G.G.GH#/#=#=l>]>]#^L#%00$#L$5$56E ((9(9:E

")a2E2E.E"F5,//"--o>F"?3F OOF#$$$A7 7: <*GBK77%  )Ds<K\K\G]]   G11156 s=    "E#E+AE9E7E;
E;2E8;F*F%%F*c                    \        VR ,          4      p. p\        VP                  VR,          4       F  w  rEVP                  \	        V4      4       K!  	  V ! W#4      # r   )dict_to_headerzipr   r*   dict_to_message)r-   r4   r^   r   _message_infoos   &&    r   r3   IWAArchiveSegment.from_dict   sQ    h0 #F$8$8%	:J KMNN?1-. !L6##r   c           	         R \        V P                  4      RV P                   Uu. uF  p\        V4      NK  	  up/# u upi r   )header_to_dictr^   r   r   )r!   messages   & r   r8   IWAArchiveSegment.to_dict   s:    nT[[1MW0M
 	
Ms   =
c                $   \        V P                  V P                  P                  4       F9  w  r \	        VP                  4       4      pVP                  pW48w  d	   W2n        K9  K;  	  RP                  \        V P                  P                  4       4      V P                  P                  4       .V P                   Uu. uF  qP                  4       NK  	  up,           4      #   \         d   pR T RT: RT 2p\        T4      RhRp?ii ; iu upi )zFailed to encode object: z

Object: 'z'
Message info: Nr   )r   r   r^   r   r'   r   ra   r	   r,   r;   r   ByteSize)r!   objr   object_lengthprovided_lengthr0   r`   s   &      r   r<   IWAArchiveSegment.to_buffer   s    "%T\\4;;3L3L!MC #C$9$9$; <"."5"5 3*7' 4	 "N xx$++..014;;3P3P3RS26,,?,3$$&,?@
 	
  /s+cWDUVbUcd  !	 @s   1C"=D
"D
-DD
c                   < V ^8  d   QhRR/# r   r   )r   r   s   "r   r   r      s       r   c                V   aa ^ oVV3R loV P                    F  pS! V4       K  	  SpR# )r   c                   < \        V \        4      '       d   V P                  p V P                  4        F  w  rVP                  VP
                  8X  d0   VP                  '       d   V F  pS! V4       K  	  KE  S! V4       KO  VP                  VP                  8X  g   Kl  VP                  '       d.   \        \        V4      4       F  pS^,          oRS 2W$&   K  	  K  S^,          o\        WP                  RS 24       K  	  R# )rY   zREDACT-N)
isinstancerw   r.   
ListFieldsr   TYPE_MESSAGEis_repeatedTYPE_STRINGranger'   setattrname)r   fieldvalueitemiredact_message	str_indexs   &    r   r   8IWAArchiveSegment.redact_strings.<locals>.redact_message   s     '=11!,, ' 2 2 4::!3!33((($)D*40 %* 'u-ZZ5#4#44(((!&s5z!2A%NI)0'<EH "3 "Q	wyk5JK !5r   N)r   )r!   r   _r   r   s   &  @@r   redact_strings IWAArchiveSegment.redact_strings   s+    		L, <<C3  r   r   r   )r>   r?   r@   rA   r"   rP   r   rB   r)   r3   r8   r<   r   rC   rD   rE   s   @r   re   re      s^      Me e (8 (8T $ $

* r   re   c                     \        V R 4      '       d   V P                  4       # \        V RR7      p\        V 4      P                  P
                  VR&   V# )r8   T)preserving_proto_field_name_pbtype)r   r8   r   r   
DESCRIPTOR	full_name)r   r   s   & r   r   r     sG    w	""  7EFW00::F9Mr   c                 B    \        V 4      pVR ,           F  pVR K  	  V# r   ra   )r   )r   r   r   s   &  r   r   r     s+    W%F//" 0Mr   c                 V    V R ,          pV R  \        V \        V,          ! 4       RR7      # )r   T)ignore_unknown_fields)r   r   )r4   _types   & r   r   r     s+    )EiUN5134PPr   c                 B    V R ,           F  p^ VR&   K
  	  \        V 4      # r   )r   )r4   r   s   & r   r   r     s+    o..!"X / 5!!r   c                 z    \        V ^ 4      w  rTpWW1,            pW1,          p\        P                  ! V4      WR 3# r   N)r   r   r   )r   msg_lennew_posr   msg_bufs   &    r   r   r   !  sC    &sA.GAak"GLA!!'*CG33r   c                H    V ^8  d   QhR\         R\        R\        R\        /# )r   obj_idr-   object_dictr   )intobjectdict)r   s   "r   r   r   )  s(     5 5s 5 5d 5v 5r   c           
          VP                   P                  p\        V,          pR RR\        V 4      RRVR. RO/./pW2R &   RVRV./p\        P                  V4      # )	r   zTSP.ArchiveInfor   r   r   versionr^   r   )rY   r      )r   r   r   r   re   r3   )r   r-   r   r   type_idr^   archive_dicts   &&&    r   create_iwa_segmentr   )  ss    ((I)$G$c&k9
	F '	fi+?L&&|44r   c                    V ^8  d   QhRR/# r   r   )r   s   "r   r   r   <  s     / /T /r   c                    \        V R 4      '       g   R# \        V 4      P                  R8X  d   VP                  V P                  4       R# V P                  4        F  pVw  r4\        V4      P                  R8X  d   VP                  VP                  4       K>  R\        V4      P                  9   d   V F  p\        WQ4       K  	  Kn  \        VR 4      '       g   K  \        WA4       K  	  R# )r   N	ReferenceRepeated)r   r   r>   r*   r   r   find_references)r   
references
field_descr   r   r   s   &&    r   r   r   <  s    3%%Cy[(#..)nn&
;;.e../4;///1 UL))E. 'r   c                @    V ^8  d   QhR\         R\        R\        RR/# )r   iwa_filer   r   r   N)r   r   r   )r   s   "r   r   r   M  s.     A Ag AF AC AD Ar   c                    V P                   ^ ,          P                   F  pVP                  P                  V8X  g   K   VP                  ^ ,          P                  V4       . p\        VP                  ^ ,          V4       \        V4      ^ 8  g   Ks  VP                  P                  ^ ,          p\        VP                  4      ^ 8  d   VP                  P                  4       pK6  V F  pVP                  P                  V4       K   	  K  	  R# r   )r   rK   r^   r   r   CopyFromr   r'   r   object_referencespopr*   )r  r   r   rf   r   msg_infor   	references   &&&     r   copy_object_to_iwa_filer	  M  s    ??1%..>>$$.OOA'',JGOOA.
;:"">>77:(4459 22668A!+I..55i@ ", /r   c                     \        V 4      p^ pV '       dc   V R,          pV^ ,          pV^ 8w  d   R# \        R\        VR,          4      R,           4      ^ ,          pW%^,           ,          pV ^V,           R p Kj  W!8H  # )r   rS   FrW   rX   rZ   N)r'   r   r[   )r.   data_lengthra   r^   r_   segment_lengths   &     r   is_iwa_filer  [  sw    d)KF
bAY
eF2J&7'&AB1E1$$A&()  r   c                :    V ^8  d   QhR\         \        ,          /# r   )listr   )r   s   "r   r   r   k  s     Z ZtF| Zr   c                     V P                  4        UUu. uF,  w  rVP                  '       g   K  V P                  V,          NK.  	  upp# u uppi r   )r   is_extension
Extensions)r   r   r   s   &  r   
extensionsr  k  s<    25..2BY2BheeFXFX!CNN5!!2BYYYs
   A
A
c                0    V ^8  d   QhR\         R\        /# )r   r   r   )r   r   )r   s   "r   r   r   o  s      c f r   c                     \        V 4      pV Uu. uF  p\        W1R 4      f   K  \        W14      NK   	  ppV^ ,          # u upi r   )r  getattr)r   r   all_extensionsrU   filtereds   &&   r   find_extensionr  o  s@    _N*8_.QGAT<R  .H_A; `s   ??)+loggingrp   	functoolsr   r   r\    google.protobuf.internal.decoderr    google.protobuf.internal.encoderr   google.protobuf.json_formatr   r   google.protobuf.messager	   numbers_parser.exceptionsr
    numbers_parser.generated.mappingr   r   r   /numbers_parser.generated.TSPArchiveMessages_pb2r   	getLoggerr>   loggerr&   r   r(   rw   re   r   r   r   r   r   r   r  r   r	  r  r  r  r   r   r   <module>r%     s         < 9 @ / 9 U U G			8	$!F !FH8
 8
v4 40u upQ"45& %) /"A! Zr   