Server : Apache/2.4.62 (Unix) OpenSSL/1.0.2k-fips System : Linux server1.richineiserver.com 3.10.0-1160.119.1.el7.x86_64 #1 SMP Tue Jun 4 14:43:51 UTC 2024 x86_64 User : fdshops ( 1003) PHP Version : 8.2.21 Disable Function : NONE Directory : /lib/python2.7/site-packages/requests_toolbelt/multipart/ |
�
ӵ Yc @ s d Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d e f d � � YZ d � Z
d e f d
� � YZ d � Z d � Z
d
� Z e j d � � Z d � Z d � Z d e f d � � YZ d e j f d � � YZ d e f d � � YZ d S( s�
requests_toolbelt.multipart.encoder
===================================
This holds all of the implementation details of the MultipartEncoder
i����N( t uuid4i ( t fieldst MultipartEncoderc B s� e Z d Z d d d � Z e d � � Z d � Z d � Z d � Z d � Z
d � Z d � Z d
� Z
d � Z d � Z d
� Z d � Z e d � � Z d � Z d d � Z RS( s
The ``MultipartEncoder`` oject is a generic interface to the engine that
will create a ``multipart/form-data`` body for you.
The basic usage is:
.. code-block:: python
import requests
from requests_toolbelt import MultipartEncoder
encoder = MultipartEncoder({'field': 'value',
'other_field', 'other_value'})
r = requests.post('https://httpbin.org/post', data=encoder,
headers={'Content-Type': encoder.content_type})
If you do not need to take advantage of streaming the post body, you can
also do:
.. code-block:: python
r = requests.post('https://httpbin.org/post',
data=encoder.to_string(),
headers={'Content-Type': encoder.content_type})
If you want the encoder to use a specific order, you can use an
OrderedDict or more simply, a list of tuples:
.. code-block:: python
encoder = MultipartEncoder([('field', 'value'),
('other_field', 'other_value')])
.. versionchanged:: 0.4.0
You can also provide tuples as part values as you would provide them to
requests' ``files`` parameter.
.. code-block:: python
encoder = MultipartEncoder({
'field': ('file_name', b'{"a": "b"}', 'application/json',
{'X-My-Header': 'my-value'})
])
.. warning::
This object will end up directly in :mod:`httplib`. Currently,
:mod:`httplib` has a hard-coded read size of **8192 bytes**. This
means that it will loop until the file has been read and your upload
could take a while. This is **not** a bug in requests. A feature is
being considered for this object to allow you, the user, to specify
what size should be returned on a read. If you have opinions on this,
please weigh in on `this issue`_.
.. _this issue:
https://github.com/sigmavirus24/requests-toolbelt/issues/75
s utf-8c C s� | p t � j | _ d j | j � | _ | | _ d j t | j | j � t d | j � g � | _ | | _ t
| _ g | _ t
g � | _ d | _ d | _ t d | � | _ | j � | j � d S( Ns --{0}t s
t encoding( R t hext boundary_valuet formatt boundaryR t joint encode_witht _encoded_boundaryR t Falset finishedt partst itert _iter_partst Nonet
_current_partt _lent
CustomBytesIOt _buffert _prepare_partst _write_boundary( t selfR R R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt __init__Q s
c C s | j p | j � S( sv Length of the multipart/form-data body.
requests will first attempt to get the length of the body by calling
``len(body)`` and then by checking for the ``len`` attribute.
On 32-bit systems, the ``__len__`` method cannot return anything
larger than an integer (in C) can hold. If the total size of the body
is even slightly larger than 4GB users will see an OverflowError. This
manifested itself in `bug #80`_.
As such, we now calculate the length lazily as a property.
.. _bug #80:
https://github.com/sigmavirus24/requests-toolbelt/issues/80
( R t _calculate_length( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt len| s c C s d j | j � S( Ns <MultipartEncoder: {0!r}>( R R ( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt __repr__� s c s@ t | j � � t � f d � | j D� � � d | _ | j S( s�
This uses the parts to calculate the length of the body.
This returns the calculated length so __len__ can be lazy.
c 3 s# | ] } � t | � d Vq d S( i N( t total_len( t .0t p( t boundary_len( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pys <genexpr>� s i ( R R t sumR R ( R ( ( R sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR � s *c C s' | t | j � } | d k r# | Sd S( s� This calculates how many bytes need to be added to the buffer.
When a consumer read's ``x`` from the buffer, there are two cases to
satisfy:
1. Enough data in the buffer to return the requested amount
2. Not enough data
This function uses the amount of unread bytes in the buffer and
determines how much the Encoder has to load before it can return the
requested amount of bytes.
:param int read_size: the number of bytes the consumer requests
:returns: int -- the number of bytes that must be loaded into the
buffer before the read can be satisfied. This will be strictly
non-negative
i ( R R ( R t read_sizet amount( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt _calculate_load_amount� s c C s� | j j � | j p | j � } x� | d k s= | d k r� d } | j � s� | | j d � 7} | | j � 7} | j � } n | s� | | j � 7} t | _ Pn | | j
| j | � 7} | d k r% | | 8} q% q% Wd S( s0 Load ``amount`` number of bytes into the buffer.i����i s
N( R t smart_truncateR t
_next_partt bytes_left_to_writet _writeR t _write_closing_boundaryt TrueR
t write_to( R R# t partt written( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt _load� s
c C s8 y t | j � } | _ Wn t k
r3 d } n X| S( N( t nextR R t
StopIterationR ( R R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR& � s
c
c s | j } t | j d � r3 t | j j � � } n x� | D]� \ } } d } d } d } t | t t f � r� t | � d k r� | \ } } q� t | � d k r� | \ } } } q� | \ } } } } n | } t j d | d | d | d | � } | j d | � | Vq: Wd S( Nt itemsi i t namet datat filenamet headerst content_type(
R t hasattrt listR1 R t
isinstancet tupleR t RequestFieldt make_multipart( R t _fieldst kt vt file_namet file_typet file_headerst file_pointert field( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt _iter_fields� s& c C sM | j } g | j � D] } t j | | � ^ q | _ t | j � | _ d S( s� This uses the fields provided by the user and creates Part objects.
It populates the `parts` attribute and uses that to create a
generator for iteration.
N( R RE t Partt
from_fieldR R R ( R t enct f( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR � s .c C s | j j | � S( s� Write the bytes to the end of the buffer.
:param bytes bytes_to_write: byte-string (or bytearray) to append to
the buffer
:returns: int -- the number of bytes written
( R t append( R t bytes_to_write( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR( � s c C s | j | j � S( s, Write the boundary to the end of the buffer.( R( R ( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR � s c C s= t | j � �( | j j d d � | j j d � Wd QXd S( s? Write the bytes necessary to finish a multipart/form-data body.i����i s --
N( t resetR t seekt write( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR) s c C s | j t | | j � � S( s/ Write the current part's headers to the buffer.( R( R
R ( R R5 ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt _write_headers s c C s t d j | j � � S( Ns! multipart/form-data; boundary={0}( t strR R ( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR6 s c C s
| j � S( s� Return the entirety of the data in the encoder.
.. note::
This simply reads all of the data it can. If you have started
streaming or reading data from the encoder, this method will only
return whatever data is left in the encoder.
.. note::
This method affects the internal state of the encoder. Calling
this method will exhaust the encoder.
:returns: the multipart message
:rtype: bytes
( t read( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt to_string s i����c C sl | j r | j j | � S| } | d k rO | d k rO | j t | � � } n | j | � | j j | � S( s� Read data from the streaming encoder.
:param int size: (optional), If provided, ``read`` will return exactly
that many bytes. If it is not provided, it will return the
remaining bytes.
:returns: bytes
i����N( R
R RQ R R$ t intR. ( R t sizet
bytes_to_load( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRQ % s
N( t __name__t
__module__t __doc__R R t propertyR R R R$ R. R& RE R R( R R) RO R6 RR RQ ( ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR s" =+
c C s | S( N( ( t monitor( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt IDENTITY8 s t MultipartEncoderMonitorc B sV e Z d Z d d � Z e d d d d � � Z e d � � Z d � Z d d � Z
RS( s�
An object used to monitor the progress of a :class:`MultipartEncoder`.
The :class:`MultipartEncoder` should only be responsible for preparing and
streaming the data. For anyone who wishes to monitor it, they shouldn't be
using that instance to manage that as well. Using this class, they can
monitor an encoder and register a callback. The callback receives the
instance of the monitor.
To use this monitor, you construct your :class:`MultipartEncoder` as you
normally would.
.. code-block:: python
from requests_toolbelt import (MultipartEncoder,
MultipartEncoderMonitor)
import requests
def callback(encoder, bytes_read):
# Do something with this information
pass
m = MultipartEncoder(fields={'field0': 'value0'})
monitor = MultipartEncoderMonitor(m, callback)
headers = {'Content-Type': montior.content_type}
r = requests.post('https://httpbin.org/post', data=monitor,
headers=headers)
Alternatively, if your use case is very simple, you can use the following
pattern.
.. code-block:: python
from requests_toolbelt import MultipartEncoderMonitor
import requests
def callback(encoder, bytes_read):
# Do something with this information
pass
monitor = MultipartEncoderMonitor.from_fields(
fields={'field0': 'value0'}, callback
)
headers = {'Content-Type': montior.content_type}
r = requests.post('https://httpbin.org/post', data=monitor,
headers=headers)
c C s4 | | _ | p t | _ d | _ | j j | _ d S( Ni ( t encoderR[ t callbackt
bytes_readR ( R R] R^ ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR o s s utf-8c C s t | | | � } | | | � S( N( R ( t clsR R R R^ R] ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt from_fields} s c C s
| j j S( N( R] R6 ( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR6 � s c C s
| j � S( N( RQ ( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRR � s i����c C s8 | j j | � } | j t | � 7_ | j | � | S( N( R] RQ R_ R R^ ( R RT t string( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRQ � s
N( RV RW RX R R t classmethodRa RY R6 RR RQ ( ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR\ < s 1 c C s, | d k p t | t � s( | j | � S| S( s6 Encoding ``string`` with ``encoding`` if necessary.
:param str string: If string is a bytes object, it will not encode it.
Otherwise, this function will encode it with the provided encoding.
:param str encoding: The encoding with which to encode string.
:returns: encoded bytes object
N( R R9 t bytest encode( Rb R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR
� s
c C s t | d � r | St | | � S( s4 Coerce the data to an object with a ``read`` method.RQ ( R7 R ( R3 R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt
readable_data� s c C s� t | d � r t | � St | d � r/ | j St | d � rx y | j � } Wn t j k
rd qx Xt j | � j Sn t | d � r� t | j � � Sd S( Nt __len__R t filenot getvalue( R7 R Rh t iot UnsupportedOperationt ost fstatt st_sizeRi ( t oRh ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR � s
c c s5 | j � } | j d d � d V| j | d � d S( s Keep track of the buffer's current position and write to the end.
This is a context manager meant to be used when adding data to the buffer.
It eliminates the need for every function to be concerned with the
position of the cursor in the buffer.
i i N( t tellRM ( t buffert original_position( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRL � s c C sm t | t � si t | d � r1 t | j � | � St | d � rJ t | � St | d � si t | | � Sn | S( s5 Ensure that every object's __len__ behaves uniformly.Ri Rh RQ ( R9 R R7 Ri t FileWrapper( R3 R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt coerce_data� s
c C s) t | d � r t | j � � St | � S( NR1 ( R7 R8 R1 ( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt to_list� s RF c B s2 e Z d � Z e d � � Z d � Z d � Z RS( c C s> | | _ | | _ t | _ t | j � t | j � | _ d S( N( R5 t bodyR* t headers_unreadR R ( R R5 Rv ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR � s c C s4 t | j � | � } t | j | � } | | | � S( s8 Create a part from a Request Field generated by urllib3.( R
t render_headersRt R3 ( R` RD R R5 Rv ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRG � s c C s< d } | j r% | t | j � 7} n | t | j � d k S( s� Determine if there are bytes left to write.
:returns: bool -- ``True`` if there are bytes left to write, otherwise
``False``
i ( Rw R R5 R Rv ( R t to_read( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR' � s c C s� d } | j r1 | | j | j � 7} t | _ n xo t | j � d k r� | d k sa | | k r� | } | d k r� | | } n | | j | j j | � � 7} q4 W| S( s� Write the requested amount of bytes to the buffer provided.
The number of bytes written may exceed size on the first read since we
load the headers ambitiously.
:param CustomBytesIO buffer: buffer we want to write bytes to
:param int size: number of bytes requested to be written to the buffer
:returns: int -- number of bytes actually written
i i����( Rw RJ R5 R R Rv RQ ( R Rq RT R- t amount_to_read( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR+ � s
0
#( RV RW R Rc RG R' R+ ( ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRF � s R c B sA e Z d d d � Z d � Z e d � � Z d � Z d � Z RS( s utf-8c C s) t | | � } t t | � j | � d S( N( R
t superR R ( R Rq R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR s c C s< | j � } | j d d � | j � } | j | d � | S( Ni i ( Rp RM ( R t current_post length( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt _get_end s
c C s | j � } | | j � S( N( R~ Rp ( R R} ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR s c C s& t | � � | j | � } Wd QX| S( N( RL RN ( R Rd R- ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRJ s
c C sr t | � } | j � | } | | k rn | j � } | j d d � | j � | j | � | j d d � n d S( Ni ( R R~ RQ RM t truncateRN ( R t
to_be_readt already_readt old_bytes( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR% % s
N( RV RW R R R~ RY R RJ R% ( ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR s
Rs c B s, e Z d � Z e d � � Z d d � Z RS( c C s
| | _ d S( N( t fd( R t file_object( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR 2 s c C s t | j � | j j � S( N( R R� Rp ( R ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyR 5 s i����c C s | j j | � S( N( R� RQ ( R R} ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRQ 9 s ( RV RW R RY R RQ ( ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyRs 1 s ( RX t
contextlibRj Rl t uuidR t _compatR t objectR R[ R\ R
Rf R t contextmanagerRL Rt Ru RF t BytesIOR Rs ( ( ( sG /usr/lib/python2.7/site-packages/requests_toolbelt/multipart/encoder.pyt <module> s$ � ' U
2"