o
    i                     @   sx   d dl mZ d dlZd dlmZ d dlmZmZmZ G dd de	Z
G dd de
ZG d	d
 d
e
ZG dd de
ZdS )    )IOBaseN)OrderedDict)MappingOptionalAsyncIterablec                   @   sl   e Zd ZU eed< eeef ed< dedeeef fddZede	e fddZ
ede	e fdd	Zd
S )StripeResponseBasecodeheadersc                 C   s   || _ || _d S N)r   r	   )selfr   r	    r   w/var/www/snowflake_co_dev_github/snow_flake_back_end_deploy/env/lib/python3.10/site-packages/stripe/_stripe_response.py__init__   s   
zStripeResponseBase.__init__returnc                 C   "   z| j d W S  ty   Y d S w )Nzidempotency-keyr	   KeyErrorr   r   r   r   idempotency_key   
   z"StripeResponseBase.idempotency_keyc                 C   r   )Nz
request-idr   r   r   r   r   
request_id   r   zStripeResponseBase.request_idN)__name__
__module____qualname__int__annotations__r   strr   propertyr   r   r   r   r   r   r   r      s   
 r   c                   @   s<   e Zd ZU eed< eed< dededeeef fddZdS )StripeResponsebodydatar   r	   c                 C   s(   t | || || _tj|td| _d S )N)object_pairs_hook)r   r   r   jsonloadsr   r    )r   r   r   r	   r   r   r   r   #   s   zStripeResponse.__init__N)	r   r   r   r   r   objectr   r   r   r   r   r   r   r      s   
 "r   c                   @   s4   e Zd ZU eed< dededeeef fddZdS )StripeStreamResponseior   r	   c                 C      t | || || _d S r
   )r   r   r&   )r   r&   r   r	   r   r   r   r   ,   s   
zStripeStreamResponse.__init__N)	r   r   r   r   r   r   r   r   r   r   r   r   r   r%   )   s   
 "r%   c                   @   s\   e Zd ZU ee ed< dee dedeeef fddZ	dee fdd	Z
defd
dZdS )StripeStreamResponseAsync_streamstreamr   r	   c                 C   r'   r
   )r   r   r)   )r   r*   r   r	   r   r   r   r   4   s   
z"StripeStreamResponseAsync.__init__r   c                 C   s   | j S r
   )r)   r   r   r   r   r*   =   s   z StripeStreamResponseAsync.streamc                    s   d dd | j2 I d H S )N    c                    s   g | z3 d H W }|q6 S r
   r   ).0chunkr   r   r   
<listcomp>A   s    z8StripeStreamResponseAsync.read_async.<locals>.<listcomp>)joinr)   r   r   r   r   
read_async@   s   z$StripeStreamResponseAsync.read_asyncN)r   r   r   r   bytesr   r   r   r   r   r*   r0   r   r   r   r   r(   1   s   
 

	r(   )r&   r   r"   collectionsr   typingr   r   r   r$   r   r   r%   r(   r   r   r   r   <module>   s   
