
    2Bf                     .    d dl Z ddlmZ  G d de      Zy)    N   )packetc                   *    e Zd ZdZdZddZddZd Zy)	PayloadzEngine.IO payload.   Nc                 B    |xs g | _         || j                  |       y y N)packetsdecode)selfr
   encoded_payloads      P/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/engineio/payload.py__init__zPayload.__init__
   s$    }"&KK( '    c                     d}| j                   D ]  }|r|dz  }||j                  d      z  }  |'dt        |      z   dz   |j                  dd      z   d	z   }|S )
z$Encode the payload for transmission. T)b64z___eio[z](""z\"z");)r
   encodestrreplace)r   jsonp_indexr   pkts       r   r   zPayload.encode   s    << 	4C6)szzdz33O	4 "'!+./#$ .55c5AB $	$O
 r   c                 `   g | _         t        |      dk(  ry|j                  d      r%t        j                  j                  |      d   d   }|j                  d      }t        |      | j                  kD  rt        d      |D cg c]  }t        j                  |       c}| _         yc c}w )zDecode a transmitted payload.r   Nzd=dr   zToo many packets in payload)encoded_packet)r
   len
startswithurllibparseparse_qssplitmax_decode_packets
ValueErrorr   Packet)r   r   encoded_packetsr   s       r   r   zPayload.decode   s    1$ %%d+$ll33!!$&&')O *//7$"9"99:;;.=?* ^D ? ?s   B+)NNr	   )__name__
__module____qualname____doc__r$   r   r   r    r   r   r   r      s    )
?r   r   )r    r   r   objectr   r,   r   r   <module>r.      s     (?f (?r   