This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	indygreg	D4778 wireprotov2: client support for following content redirects
Closed	indygreg	D4777 wireprotov2: server support for sending content redirects
Closed	indygreg	D4776 wireprotov2: client support for advertising redirect targets
Closed	indygreg	D4775 wireprotov2: advertise redirect targets in capabilities
Closed	indygreg	D4774 wireprotov2: define semantics for content redirects
Closed	indygreg	D4773 wireprotov2: support response caching
Closed	indygreg	D4772 wireprotov2: define type to represent pre-encoded object
Closed	indygreg	D4771 wireprotov2: change name and behavior of readframe()
Closed	indygreg	D4770 url: move _wraphttpresponse() from httpeer
Closed	indygreg	D4769 debugcommands: print all CBOR objects

Diff 11623

	from .i18n import _			from .i18n import _
	from .thirdparty import (			from .thirdparty import (
	attr,			attr,
	)			)
	from . import (			from . import (
	encoding,			encoding,
	error,			error,
	util,			util,
				wireprototypes,
	)			)
	from .utils import (			from .utils import (
	cborutil,			cborutil,
	stringutil,			stringutil,
	)			)

	FRAME_HEADER_SIZE = 8			FRAME_HEADER_SIZE = 8
	DEFAULT_MAX_FRAME_SIZE = 32768			DEFAULT_MAX_FRAME_SIZE = 32768

	break			break

	try:			try:
	if not emitted:			if not emitted:
	yield createcommandresponseokframe(stream, requestid)			yield createcommandresponseokframe(stream, requestid)
	emitted = True			emitted = True

				# Objects emitted by command functions can be serializable
				# data structures or special types.
				# TODO consider extracting the content normalization to a
				# standalone function, as it may be useful for e.g. cachers.

				# A pre-encoded object is sent directly to the emitter.
				if isinstance(o, wireprototypes.encodedresponse):
				for frame in emitter.send(o.data):
				yield frame

				# A regular object is CBOR encoded.
				else:
	for chunk in cborutil.streamencode(o):			for chunk in cborutil.streamencode(o):
	for frame in emitter.send(chunk):			for frame in emitter.send(chunk):
	yield frame			yield frame

	except Exception as e:			except Exception as e:
	for frame in createerrorframe(stream, requestid,			for frame in createerrorframe(stream, requestid,
	'%s' % e,			'%s' % e,
	errtype='server'):			errtype='server'):
	yield frame			yield frame

	break			break

	# Copyright 2018 Gregory Szorc <gregory.szorc@gmail.com>			# Copyright 2018 Gregory Szorc <gregory.szorc@gmail.com>
	#			#
	# This software may be used and distributed according to the terms of the			# This software may be used and distributed according to the terms of the
	# GNU General Public License version 2 or any later version.			# GNU General Public License version 2 or any later version.

	from __future__ import absolute_import			from __future__ import absolute_import

	from .node import (			from .node import (
	bin,			bin,
	hex,			hex,
	)			)
	from .i18n import _			from .i18n import _
				from .thirdparty import (
				attr,
				)
	from . import (			from . import (
	error,			error,
	util,			util,
	)			)
	from .utils import (			from .utils import (
	interfaceutil,			interfaceutil,
	)			)


	if not compengines:			if not compengines:
	raise error.Abort(_('%s config option does not specify any known '			raise error.Abort(_('%s config option does not specify any known '
	'compression engines') % config,			'compression engines') % config,
	hint=_('usable compression engines: %s') %			hint=_('usable compression engines: %s') %
	', '.sorted(validnames))			', '.sorted(validnames))

	return compengines			return compengines

				@attr.s
				class encodedresponse(object):
				"""Represents response data that is already content encoded.

				Wire protocol version 2 only.

				Commands typically emit Python objects that are encoded and sent over the
				wire. If commands emit an object of this type, the encoding step is bypassed
				and the content from this object is used instead.
				"""
				data = attr.ib()