import io from urllib.parse import urlencode from multidict import MultiDict, MultiDictProxy from . import hdrs, multipart, payload from .helpers import guess_filename __all__ = ('FormData',) class FormData: """Helper class for multipart/form-data and application/x-www-form-urlencoded body generation.""" def __init__(self, fields=(), quote_fields=True, charset=None): self._writer = multipart.MultipartWriter('form-data') self._fields = [] self._is_multipart = False self._quote_fields = quote_fields self._charset = charset if isinstance(fields, dict): fields = list(fields.items()) elif not isinstance(fields, (list, tuple)): fields = (fields,) self.add_fields(*fields) @property def is_multipart(self): return self._is_multipart def add_field(self, name, value, *, content_type=None, filename=None, content_transfer_encoding=None): if isinstance(value, io.IOBase): self._is_multipart = True elif isinstance(value, (bytes, bytearray, memoryview)): if filename is None and content_transfer_encoding is None: filename = name type_options = MultiDict({'name': name}) if filename is not None and not isinstance(filename, str): raise TypeError('filename must be an instance of str. ' 'Got: %s' % filename) if filename is None and isinstance(value, io.IOBase): filename = guess_filename(value, name) if filename is not None: type_options['filename'] = filename self._is_multipart = True headers = {} if content_type is not None: if not isinstance(content_type, str): raise TypeError('content_type must be an instance of str. ' 'Got: %s' % content_type) headers[hdrs.CONTENT_TYPE] = content_type self._is_multipart = True if content_transfer_encoding is not None: if not isinstance(content_transfer_encoding, str): raise TypeError('content_transfer_encoding must be an instance' ' of str. Got: %s' % content_transfer_encoding) headers[hdrs.CONTENT_TRANSFER_ENCODING] = content_transfer_encoding self._is_multipart = True self._fields.append((type_options, headers, value)) def add_fields(self, *fields): to_add = list(fields) while to_add: rec = to_add.pop(0) if isinstance(rec, io.IOBase): k = guess_filename(rec, 'unknown') self.add_field(k, rec) elif isinstance(rec, (MultiDictProxy, MultiDict)): to_add.extend(rec.items()) elif isinstance(rec, (list, tuple)) and len(rec) == 2: k, fp = rec self.add_field(k, fp) else: raise TypeError('Only io.IOBase, multidict and (name, file) ' 'pairs allowed, use .add_field() for passing ' 'more complex parameters, got {!r}' .format(rec)) def _gen_form_urlencoded(self): # form data (x-www-form-urlencoded) data = [] for type_options, _, value in self._fields: data.append((type_options['name'], value)) charset = self._charset if self._charset is not None else 'utf-8' if charset == 'utf-8': content_type = 'application/x-www-form-urlencoded' else: content_type = ('application/x-www-form-urlencoded; ' 'charset=%s' % charset) return payload.BytesPayload( urlencode(data, doseq=True, encoding=charset).encode(), content_type=content_type) def _gen_form_data(self): """Encode a list of fields using the multipart/form-data MIME format""" for dispparams, headers, value in self._fields: try: if hdrs.CONTENT_TYPE in headers: part = payload.get_payload( value, content_type=headers[hdrs.CONTENT_TYPE], headers=headers, encoding=self._charset) else: part = payload.get_payload( value, headers=headers, encoding=self._charset) except Exception as exc: raise TypeError( 'Can not serialize value type: %r\n ' 'headers: %r\n value: %r' % ( type(value), headers, value)) from exc if dispparams: part.set_content_disposition( 'form-data', quote_fields=self._quote_fields, **dispparams ) # FIXME cgi.FieldStorage doesn't likes body parts with # Content-Length which were sent via chunked transfer encoding part.headers.popall(hdrs.CONTENT_LENGTH, None) self._writer.append_payload(part) return self._writer def __call__(self): if self._is_multipart: return self._gen_form_data() else: return self._gen_form_urlencoded()
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
__pycache__ | Folder | 0755 |
|
|
__init__.py | File | 1.35 KB | 0644 |
|
_cparser.pxd | File | 3.87 KB | 0644 |
|
_frozenlist.c | File | 279.05 KB | 0644 |
|
_frozenlist.cpython-35m-x86_64-linux-gnu.so | File | 63.73 KB | 0755 |
|
_frozenlist.pyx | File | 2.54 KB | 0644 |
|
_http_parser.c | File | 592.13 KB | 0644 |
|
_http_parser.cpython-35m-x86_64-linux-gnu.so | File | 155.33 KB | 0755 |
|
_http_parser.pyx | File | 20.6 KB | 0644 |
|
_websocket.c | File | 125.34 KB | 0644 |
|
_websocket.cpython-35m-x86_64-linux-gnu.so | File | 24.38 KB | 0755 |
|
_websocket.pyx | File | 1.52 KB | 0644 |
|
abc.py | File | 3.31 KB | 0644 |
|
client.py | File | 31.81 KB | 0644 |
|
client_exceptions.py | File | 5.28 KB | 0644 |
|
client_proto.py | File | 5.74 KB | 0644 |
|
client_reqrep.py | File | 27.95 KB | 0644 |
|
client_ws.py | File | 8.69 KB | 0644 |
|
connector.py | File | 31.81 KB | 0644 |
|
cookiejar.py | File | 9.99 KB | 0644 |
|
formdata.py | File | 5.22 KB | 0644 |
|
frozenlist.py | File | 1.73 KB | 0644 |
|
hdrs.py | File | 3.28 KB | 0644 |
|
helpers.py | File | 22.36 KB | 0644 |
|
http.py | File | 1.26 KB | 0644 |
|
http_exceptions.py | File | 1.93 KB | 0644 |
|
http_parser.py | File | 23.77 KB | 0644 |
|
http_websocket.py | File | 21.49 KB | 0644 |
|
http_writer.py | File | 3.91 KB | 0644 |
|
locks.py | File | 946 B | 0644 |
|
log.py | File | 326 B | 0644 |
|
multipart.py | File | 28.89 KB | 0644 |
|
payload.py | File | 8.2 KB | 0644 |
|
payload_streamer.py | File | 1.49 KB | 0644 |
|
pytest_plugin.py | File | 9.54 KB | 0644 |
|
resolver.py | File | 3.23 KB | 0644 |
|
signals.py | File | 933 B | 0644 |
|
streams.py | File | 16.31 KB | 0644 |
|
tcp_helpers.py | File | 1.38 KB | 0644 |
|
test_utils.py | File | 15.75 KB | 0644 |
|
tracing.py | File | 9.32 KB | 0644 |
|
web.py | File | 7.03 KB | 0644 |
|
web_app.py | File | 9.88 KB | 0644 |
|
web_exceptions.py | File | 8.38 KB | 0644 |
|
web_fileresponse.py | File | 7.51 KB | 0644 |
|
web_middlewares.py | File | 2.6 KB | 0644 |
|
web_protocol.py | File | 17.57 KB | 0644 |
|
web_request.py | File | 20.42 KB | 0644 |
|
web_response.py | File | 20.97 KB | 0644 |
|
web_runner.py | File | 8.05 KB | 0644 |
|
web_server.py | File | 1.29 KB | 0644 |
|
web_urldispatcher.py | File | 32.67 KB | 0644 |
|
web_ws.py | File | 14.34 KB | 0644 |
|
worker.py | File | 6.92 KB | 0644 |
|