This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	indygreg	D3388 wireprotov2: add support for more response types
Closed	indygreg	D3387 wireprotov2: remove support for sending bytes response
Closed	indygreg	D3386 wireprotov2: change behavior of error frame
Closed	indygreg	D3385 wireprotov2: change command response protocol to include a leading map
Closed	indygreg	D3384 wireprotov2: change frame type and name for command response
Closed	indygreg	D3383 wireprotov2: change frame type value for command data
Closed	indygreg	D3382 wireprotov2: define response data as CBOR
Closed	indygreg	D3381 wireprotov2: decode responses to their expected types
Closed	indygreg	D3380 wireprotov2: establish a type for representing command response
Closed	indygreg	D3379 wireprotov2: move response handling out of httppeer
Closed	indygreg	D3378 debugcommands: ability to suppress logging of handshake
Closed	indygreg	D3377 hg: pass command intents to repo/peer creation (API)
Closed	indygreg	D3376 registrar: replace "cmdtype" with an intent-based mechanism (API)

Diff 8330

	res.setbodybytes(_('command in frame must match command in URL'))			res.setbodybytes(_('command in frame must match command in URL'))
	return True			return True

	rsp = wireproto.dispatch(repo, proto, command['command'])			rsp = wireproto.dispatch(repo, proto, command['command'])

	res.status = b'200 OK'			res.status = b'200 OK'
	res.headers[b'Content-Type'] = FRAMINGTYPE			res.headers[b'Content-Type'] = FRAMINGTYPE

	if isinstance(rsp, wireprototypes.bytesresponse):			if isinstance(rsp, wireprototypes.cborresponse):
	action, meta = reactor.oncommandresponseready(outstream,
	command['requestid'],
	rsp.data)
	elif isinstance(rsp, wireprototypes.cborresponse):
	encoded = cbor.dumps(rsp.value, canonical=True)			encoded = cbor.dumps(rsp.value, canonical=True)
	action, meta = reactor.oncommandresponseready(outstream,			action, meta = reactor.oncommandresponseready(outstream,
	command['requestid'],			command['requestid'],
	encoded)			encoded)
	else:			else:
	action, meta = reactor.onservererror(			action, meta = reactor.onservererror(
	_('unhandled response type from wire proto command'))			_('unhandled response type from wire proto command'))