| durin42 |
| hg-reviewers |
We need this so we can construct a new request instance
from the original dict.
| Lint Skipped |
| Unit Tests Skipped |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/hgweb/hgweb_mod.py (2 lines) | |||
| M | mercurial/hgweb/request.py (5 lines) |
| def _runwsgi(self, wsgireq, repo): | def _runwsgi(self, wsgireq, repo): | ||||
| req = wsgireq.req | req = wsgireq.req | ||||
| res = wsgireq.res | res = wsgireq.res | ||||
| rctx = requestcontext(self, repo, req, res) | rctx = requestcontext(self, repo, req, res) | ||||
| # This state is global across all threads. | # This state is global across all threads. | ||||
| encoding.encoding = rctx.config('web', 'encoding') | encoding.encoding = rctx.config('web', 'encoding') | ||||
| rctx.repo.ui.environ = wsgireq.env | rctx.repo.ui.environ = req.rawenv | ||||
| if rctx.csp: | if rctx.csp: | ||||
| # hgwebdir may have added CSP header. Since we generate our own, | # hgwebdir may have added CSP header. Since we generate our own, | ||||
| # replace it. | # replace it. | ||||
| res.headers['Content-Security-Policy'] = rctx.csp | res.headers['Content-Security-Policy'] = rctx.csp | ||||
| handled = wireprotoserver.handlewsgirequest( | handled = wireprotoserver.handlewsgirequest( | ||||
| rctx, req, res, self.check_perm) | rctx, req, res, self.check_perm) | ||||
| querystring = attr.ib() | querystring = attr.ib() | ||||
| # multidict of query string parameters. | # multidict of query string parameters. | ||||
| qsparams = attr.ib() | qsparams = attr.ib() | ||||
| # wsgiref.headers.Headers instance. Operates like a dict with case | # wsgiref.headers.Headers instance. Operates like a dict with case | ||||
| # insensitive keys. | # insensitive keys. | ||||
| headers = attr.ib() | headers = attr.ib() | ||||
| # Request body input stream. | # Request body input stream. | ||||
| bodyfh = attr.ib() | bodyfh = attr.ib() | ||||
| # WSGI environment dict, unmodified. | |||||
| rawenv = attr.ib() | |||||
| def parserequestfromenv(env, bodyfh, reponame=None, altbaseurl=None): | def parserequestfromenv(env, bodyfh, reponame=None, altbaseurl=None): | ||||
| """Parse URL components from environment variables. | """Parse URL components from environment variables. | ||||
| WSGI defines request attributes via environment variables. This function | WSGI defines request attributes via environment variables. This function | ||||
| parses the environment variables into a data structure. | parses the environment variables into a data structure. | ||||
| If ``reponame`` is defined, the leading path components matching that | If ``reponame`` is defined, the leading path components matching that | ||||
| remoteuser=env.get('REMOTE_USER'), | remoteuser=env.get('REMOTE_USER'), | ||||
| remotehost=env.get('REMOTE_HOST'), | remotehost=env.get('REMOTE_HOST'), | ||||
| apppath=apppath, | apppath=apppath, | ||||
| dispatchparts=dispatchparts, dispatchpath=dispatchpath, | dispatchparts=dispatchparts, dispatchpath=dispatchpath, | ||||
| reponame=reponame, | reponame=reponame, | ||||
| querystring=querystring, | querystring=querystring, | ||||
| qsparams=qsparams, | qsparams=qsparams, | ||||
| headers=headers, | headers=headers, | ||||
| bodyfh=bodyfh) | bodyfh=bodyfh, | ||||
| rawenv=env) | |||||
| class offsettrackingwriter(object): | class offsettrackingwriter(object): | ||||
| """A file object like object that is append only and tracks write count. | """A file object like object that is append only and tracks write count. | ||||
| Instances are bound to a callable. This callable is called with data | Instances are bound to a callable. This callable is called with data | ||||
| whenever a ``write()`` is attempted. | whenever a ``write()`` is attempted. | ||||
| Instances track the amount of written data so they can answer ``tell()`` | Instances track the amount of written data so they can answer ``tell()`` | ||||