| 95 | |
| 96 | |
| 97 | class Request(dict, HeadersMixin): |
| 98 | |
| 99 | POST_METHODS = {hdrs.METH_PATCH, hdrs.METH_POST, hdrs.METH_PUT, |
| 100 | hdrs.METH_TRACE, hdrs.METH_DELETE} |
| 101 | |
| 102 | def __init__(self, app, message, payload, transport, reader, writer, *, |
| 103 | secure_proxy_ssl_header=None): |
| 104 | self._app = app |
| 105 | self._message = message |
| 106 | self._transport = transport |
| 107 | self._reader = reader |
| 108 | self._writer = writer |
| 109 | self._post = None |
| 110 | self._post_files_cache = None |
| 111 | |
| 112 | # matchdict, route_name, handler |
| 113 | # or information about traversal lookup |
| 114 | self._match_info = None # initialized after route resolving |
| 115 | |
| 116 | self._payload = payload |
| 117 | |
| 118 | self._read_bytes = None |
| 119 | self._has_body = not payload.at_eof() |
| 120 | |
| 121 | self._secure_proxy_ssl_header = secure_proxy_ssl_header |
| 122 | |
| 123 | @reify |
| 124 | def scheme(self): |
| 125 | """A string representing the scheme of the request. |
| 126 | |
| 127 | 'http' or 'https'. |
| 128 | """ |
| 129 | if self._transport.get_extra_info('sslcontext'): |
| 130 | return 'https' |
| 131 | secure_proxy_ssl_header = self._secure_proxy_ssl_header |
| 132 | if secure_proxy_ssl_header is not None: |
| 133 | header, value = secure_proxy_ssl_header |
| 134 | if self.headers.get(header) == value: |
| 135 | return 'https' |
| 136 | return 'http' |
| 137 | |
| 138 | @reify |
| 139 | def method(self): |
| 140 | """Read only property for getting HTTP method. |
| 141 | |
| 142 | The value is upper-cased str like 'GET', 'POST', 'PUT' etc. |
| 143 | """ |
| 144 | return self._message.method |
| 145 | |
| 146 | @reify |
| 147 | def version(self): |
| 148 | """Read only property for getting HTTP version of request. |
| 149 | |
| 150 | Returns aiohttp.protocol.HttpVersion instance. |
| 151 | """ |
| 152 | return self._message.version |
| 153 | |
| 154 | @reify |
no outgoing calls