| durin42 |
| hg-reviewers |
The docstring isn't completely accurate for the current state
of the world. But it does describe the direction future patches
will be taking things.
| Lint Skipped |
| Unit Tests Skipped |
| HGERRTYPE = 'application/hg-error' | HGERRTYPE = 'application/hg-error' | ||||
| # Names of the SSH protocol implementations. | # Names of the SSH protocol implementations. | ||||
| SSHV1 = 'ssh-v1' | SSHV1 = 'ssh-v1' | ||||
| # This is advertised over the wire. Incremental the counter at the end | # This is advertised over the wire. Incremental the counter at the end | ||||
| # to reflect BC breakages. | # to reflect BC breakages. | ||||
| SSHV2 = 'exp-ssh-v2-0001' | SSHV2 = 'exp-ssh-v2-0001' | ||||
| class abstractserverproto(object): | class baseprotocolhandler(object): | ||||
| """abstract class that summarizes the protocol API | """Abstract base class for wire protocol handlers. | ||||
| Used as reference and documentation. | A wire protocol handler serves as an interface between protocol command | ||||
| handlers and the wire protocol transport layer. Protocol handlers provide | |||||
| methods to read command arguments, redirect stdio for the duration of | |||||
| the request, handle response types, etc. | |||||
| """ | """ | ||||
| __metaclass__ = abc.ABCMeta | __metaclass__ = abc.ABCMeta | ||||
| @abc.abstractproperty | @abc.abstractproperty | ||||
| def name(self): | def name(self): | ||||
| """The name of the protocol implementation. | """The name of the protocol implementation. | ||||
| v = req.env.get(r'HTTP_%s_%d' % (prefix, i)) | v = req.env.get(r'HTTP_%s_%d' % (prefix, i)) | ||||
| if v is None: | if v is None: | ||||
| break | break | ||||
| chunks.append(pycompat.bytesurl(v)) | chunks.append(pycompat.bytesurl(v)) | ||||
| i += 1 | i += 1 | ||||
| return ''.join(chunks) | return ''.join(chunks) | ||||
| class webproto(abstractserverproto): | class webproto(baseprotocolhandler): | ||||
| def __init__(self, req, ui): | def __init__(self, req, ui): | ||||
| self._req = req | self._req = req | ||||
| self._ui = ui | self._ui = ui | ||||
| @property | @property | ||||
| def name(self): | def name(self): | ||||
| return 'http' | return 'http' | ||||
| req.headers.append((r'Connection', r'Close')) | req.headers.append((r'Connection', r'Close')) | ||||
| # TODO This response body assumes the failed command was | # TODO This response body assumes the failed command was | ||||
| # "unbundle." That assumption is not always valid. | # "unbundle." That assumption is not always valid. | ||||
| req.respond(e, HGTYPE, body='0\n%s\n' % e) | req.respond(e, HGTYPE, body='0\n%s\n' % e) | ||||
| return '' | return '' | ||||
| class sshserver(abstractserverproto): | class sshserver(baseprotocolhandler): | ||||
| def __init__(self, ui, repo): | def __init__(self, ui, repo): | ||||
| self._ui = ui | self._ui = ui | ||||
| self._repo = repo | self._repo = repo | ||||
| self._fin = ui.fin | self._fin = ui.fin | ||||
| self._fout = ui.fout | self._fout = ui.fout | ||||
| hook.redirect(True) | hook.redirect(True) | ||||
| ui.fout = repo.ui.fout = ui.ferr | ui.fout = repo.ui.fout = ui.ferr | ||||