U
|
£ý°d%é ã @ s d Z dZddlmZ ddlZddlZddlZddlmZ ddlm Z ddlm
|
Z
|
ddlm Z dd lm Z dd
|
lm Z dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ejZdZe j Z G dd de Z dd Z dd Z dd Z!dd Z"d d Z#d d Z$d!d" Z%d#d$ Z&d%d& Z'd'd( Z(d)d* Z)d+d, Z*d-d. Z+d/d0 Z,d1d2 Z-G d3d4 d4e.Z/d5d6 Z0d7d8 Z1d9d: Z2d;d< Z3d=d> Z4d?d@ Z5dAdB Z6dCZ7dDZ8dEdF Z9dGdH Z:dIdJ Z;dKdL Z<dMdN Z=dOdP Z>dQdR Z?dSdT Z@dUdV ZAdWdX ZBdYdZ ZCd[d\ ZDd]d^ ZEd_d` ZFdadb ZGdcdd ZHdedf ZIdgdh ZJdidj ZKdkdl ZLdmdn ZMdodp ZNdqdr ZOdsdt ZPG dudv dveQZRG dwdx dxeRZSdS )ya Contains a metaclass and helper functions used to create
|
protocol message classes from Descriptor objects at runtime.
|
|
Recall that a metaclass is the "type" of a class.
|
(A class is to a metaclass what an instance is to a class.)
|
|
In this case, we use the GeneratedProtocolMessageType metaclass
|
to inject all the useful functionality into the classes
|
output by the protocol compiler at compile-time.
|
|
The upshot of all this is that the real implementation
|
details for ALL pure-Python protocol buffers are *here in
|
this file*.
|
z#robinson@google.com (Will Robinson)é )ÚBytesION)Úapi_implementation)Ú
|
containers)Údecoder)Úencoder)Úenum_type_wrapper)Úextension_dict)Úmessage_listener)Ú type_checkers)Úwell_known_types)Ú wire_format)Ú
|
descriptor©Úmessage)Ú text_formatzgoogle.protobuf.Anyc s0 e Zd ZdZdZ fddZ fddZ ZS )Ú GeneratedProtocolMessageTypeaQ Metaclass for protocol message classes created at runtime from Descriptors.
|
|
We add implementations for all methods described in the Message class. We
|
also create properties to allow getting/setting all fields in the protocol
|
message. Finally, we create slots to prevent users from accidentally
|
"setting" nonexistent fields in the protocol message, which then wouldn't get
|
serialized / deserialized properly.
|
|
The protocol compiler currently uses this metaclass to create protocol
|
message classes at runtime. Clients can also manually create their own
|
classes at runtime, as in this example:
|
|
mydescriptor = Descriptor(.....)
|
factory = symbol_database.Default()
|
factory.pool.AddDescriptor(mydescriptor)
|
MyProtoClass = factory.GetPrototype(mydescriptor)
|
myproto_instance = MyProtoClass()
|
myproto.foo_field = 23
|
...
|
Ú
|
DESCRIPTORc s |t j }t|tr tdt|dd}|r0|S |jtjkrN|tj|j f7 }t || t
|
|| t t | }| | |||¡}|S )ak Custom allocation for runtime-generated class types.
|
|
We override __new__ because this is apparently the only place
|
where we can meaningfully set __slots__ on the class we're creating(?).
|
(The interplay between metaclasses and slots is not very well-documented).
|
|
Args:
|
name: Name of the class (ignored, but required by the
|
metaclass protocol).
|
bases: Base classes of the class we're constructing.
|
(Should be message.Message). We ignore this field, but
|
it's required by the metaclass protocol
|
dictionary: The class dictionary of the class we're
|
constructing. dictionary[_DESCRIPTOR_KEY] must contain
|
a Descriptor object describing this protocol message
|
type.
|
|
Returns:
|
Newly-allocated class.
|
|
Raises:
|
RuntimeError: Generated code only work with python cpp extension.
|
z\The generated code only work with python cpp extension, but it is using pure python runtime.Ú_concrete_classN) r Ú_DESCRIPTOR_KEYÚ
|
isinstanceÚstrÚ RuntimeErrorÚgetattrÚ full_namer ZWKTBASESÚ&_AddClassAttributesForNestedExtensionsÚ _AddSlotsÚsuperÚ__new__)ÚclsÚnameÚbasesÚ
|
dictionaryr Ú new_classÚ
|
superclass©Ú __class__© ú^d:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\google/protobuf/internal/python_message.pyr h s
|
|
|
|
|
z$GeneratedProtocolMessageType.__new__c sÜ |t j }t|dd}|r4|| ks0td|j dS i | _|jr`| ¡ jr`t
|
|¡df| jt j < |j D ]}t | | qf| |_t|| t|| t|| t|| t| t|| t|| tt | }| |||¡ dS )a Here we perform the majority of our work on the class.
|
We add enum getters, an __init__ method, implementations
|
of all Message methods, and properties for all fields
|
in the protocol type.
|
|
Args:
|
name: Name of the class (ignored, but required by the
|
metaclass protocol).
|
bases: Base classes of the class we're constructing.
|
(Should be message.Message). We ignore this field, but
|
it's required by the metaclass protocol
|
dictionary: The class dictionary of the class we're
|
constructing. dictionary[_DESCRIPTOR_KEY] must contain
|
a Descriptor object describing this protocol message
|
type.
|
r NzBDuplicate `GeneratedProtocolMessageType` created for descriptor %r)r r r ÚAssertionErrorr Ú_decoders_by_tagÚ has_optionsÚ
|
GetOptionsÚmessage_set_wire_formatr ZMessageSetItemDecoderZMESSAGE_SET_ITEM_TAGÚfieldsÚ_AttachFieldHelpersr Ú_AddEnumValuesÚ_AddInitMethodÚ_AddPropertiesForFieldsÚ_AddPropertiesForExtensionsÚ_AddStaticMethodsÚ_AddMessageMethodsÚ_AddPrivateHelperMethodsr Ú__init__)r r r r! r Zexisting_classÚfieldr# r$ r& r' r6 s8
|
|
ÿÿÿ ÿ
|
|
|
|
|
|
|
|
z%GeneratedProtocolMessageType.__init__)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r r6 Ú __classcell__r& r& r$ r' r M s 5r c C s | S )a Returns the name of the public property attribute which
|
clients can use to get and (in some cases) set the value
|
of a protocol message field.
|
|
Args:
|
proto_field_name: The protocol message field name, exactly
|
as it appears (or would appear) in a .proto file.
|
r& ©Úproto_field_namer& r& r' Ú _PropertyNameØ s r? c
|
C s ddddddddd d
|
g
|
|d < d S ) a Adds a __slots__ entry to dictionary, containing the names of all valid
|
attributes for this message type.
|
|
Args:
|
message_descriptor: A Descriptor instance describing this message type.
|
dictionary: Class dictionary to which we'll add a '__slots__' entry.
|
Ú_cached_byte_sizeÚ_cached_byte_size_dirtyÚ_fieldsÚ_unknown_fieldsÚ_unknown_field_setÚ_is_present_in_parentÚ _listenerÚ_listener_for_childrenÚ __weakref__Ú_oneofsÚ __slots__Nr& )Úmessage_descriptorr! r& r& r' r õ s ÷r c C s2 | j o0| jjo0| j ¡ jo0| jtjko0| jtj kS ©N)
|
Ú is_extensionÚcontaining_typer* r+ r, ÚtypeÚ_FieldDescriptorÚ TYPE_MESSAGEÚlabelZLABEL_OPTIONAL©r7 r& r& r' Ú_IsMessageSetExtension s ÿ
|
þ
|
ý
|
ürT c C s | j tjko | jjo | j ¡ jS rL )rO rP rQ Ú message_typer* r+ Ú map_entryrS r& r& r' Ú _IsMapField s
|
ÿ
|
þrW c C s | j jd }|jtjkS )NÚvalue)rU Úfields_by_nameÚcpp_typerP ÚCPPTYPE_MESSAGE)r7 Z
|
value_typer& r& r' Ú_IsMessageMapField s r\ c sN j tjkot j¡}jjdk|s2d}nFjjdkrPjoL ¡ j
|
}n(jop ¡ d¡op ¡ j
|
dk}| }t r t ¡}t t¡}nNtrÂt j¡}t j¡}n,tjj j|}tjj j|}|_|_t_ fdd}|tj j d rJt j¡rJ|tj d d S )NÚproto3FZproto2Úpackedc sø t j| ¡}j}|tjkr.t ¡r.tj}d }d}j d k rF}nr^s^j
|
tj kr^d}r~t }t t|¡}nh|tjkr¢t j|j|¡}nDj
|
tj krÊtj| j|j}n tj| j|j|}||f j|< d S ©NFT)r ZTagBytesÚnumberrO rP Z TYPE_ENUMr
|
ZSupportsOpenEnumsZ
|
TYPE_INT32Úcontaining_oneofrZ r[ r\ r Z
|
MapDecoderÚ_GetInitializeDefaultForMapZ TYPE_STRINGZ StringDecoderÚ_default_constructorZTYPE_TO_DECODERr) )ZwiretypeÚ is_packedÚ tag_bytesZ decode_typeZoneof_descriptorZclear_if_defaultZis_message_mapÚ field_decoder©r Úfield_descriptorZ is_map_entryÚ is_proto3Z is_repeatedr& r' Ú
|
AddDecoder? s^
|
ÿ
|
|
ÿ þ
|
ý þ üz'_AttachFieldHelpers.<locals>.AddDecoderT) rR rP ÚLABEL_REPEATEDr ZIsTypePackablerO rN Úsyntaxr* r+ r^ ÚHasFieldrW r Z
|
MapEncoderZMapSizerr\ rT ZMessageSetItemEncoderr` ZMessageSetItemSizerr
|
ZTYPE_TO_ENCODERZ TYPE_TO_SIZERÚ_encoderÚ_sizerÚ _DefaultValueConstructorForFieldrc ZFIELD_TYPE_TO_WIRE_TYPEZWIRETYPE_LENGTH_DELIMITED)r rh Z is_packablerd Zhas_packed_falseZ field_encoderZsizerrj r& rg r' r. s^
|
ÿ ÿ ÿ þ
|
ÿ
|
ÿ
|
ÿÿ' ÿr. c C s0 | j }| ¡ D ] \}}||ks"t|||< qd S rL )Úextensions_by_nameÚitemsr( )r r! Ú
|
extensionsÚextension_nameÚextension_fieldr& r& r' r o s r c C s@ | j D ]4}t||jt |¡ |jD ]}t||j|j q$qdS )a Sets class-level attributes for all enum fields defined in this message.
|
|
Also exporting a class-level object that can name enum values.
|
|
Args:
|
descriptor: Descriptor object for this message type.
|
cls: Class we're constructing for this message type.
|
N)Ú
|
enum_typesÚsetattrr r ZEnumTypeWrapperÚvaluesr` )r r Ú enum_typeZ
|
enum_valuer& r& r' r/ v s
|
|
r/ c sv j tjkrtd j jj}t |d ¡|d t rT fdd}|S t ¡ fdd}|S d S )Nz&map_entry set on non-repeated field %sÚkeyrX c s t | jj j¡S rL )r Z
|
MessageMaprG rU r )r7 Ú key_checkerÚ value_fieldr& r' ÚMakeMessageMapDefault s þz:_GetInitializeDefaultForMap.<locals>.MakeMessageMapDefaultc s t | j j¡S rL )r Z ScalarMaprG rU r )r7 r{ Ú value_checkerr& r' ÚMakePrimitiveMapDefault s þz<_GetInitializeDefaultForMap.<locals>.MakePrimitiveMapDefault)
|
rR rP rk Ú
|
ValueErrorr rU rY r
|
ÚGetTypeCheckerr\ )r7 rY r} r r& )r7 r{ r~ r| r' rb
s ÿ
|
rb c sª t rt S jtjkrv jr: jg kr:td j jtj kr\ j
|
fdd}|S t ¡fdd}|S jtj kr j
|
fdd}|S fdd }|S )
|
a Returns a function which returns a default value for a field.
|
|
Args:
|
field: FieldDescriptor object for this field.
|
|
The returned function has one argument:
|
message: Message instance containing this field, or a weakref proxy
|
of same.
|
|
That function in turn returns a default value for this field. The default
|
value may refer back to |message| via a weak reference.
|
z/Repeated field default value not empty list: %sc s t | j j¡S rL )r Z RepeatedCompositeFieldContainerrG rU r rS r& r' ÚMakeRepeatedMessageDefault´ s ÿzD_DefaultValueConstructorForField.<locals>.MakeRepeatedMessageDefaultc s t | j ¡S rL )r Z RepeatedScalarFieldContainerrG r )Ú type_checkerr& r' ÚMakeRepeatedScalarDefaultº s ÿzC_DefaultValueConstructorForField.<locals>.MakeRepeatedScalarDefaultc sL t dd s td jjf ¡ }| jd k r@t| n| j¡ |S )Nr zAUninitialized concrete class found for field %r (message type %r))r r( r r Ú _SetListenerra Ú_OneofListenerrG )r Úresult)r7 rU r& r' ÚMakeSubMessageDefault s
|
ÿÿÿ ýz?_DefaultValueConstructorForField.<locals>.MakeSubMessageDefaultc s j S rL )Ú default_valuer rS r& r' ÚMakeScalarDefaultÎ s z;_DefaultValueConstructorForField.<locals>.MakeScalarDefault) rW rb rR rP rk Zhas_default_valuer r rZ r[ rU r
|
r )r7 r r r r r& )r7 rU r r' rp s( ÿ
|
|
rp c C sR t ¡ d }t|jdkr<t|tkr<tdt|| |f }| t ¡ d ¡dS )zCRe-raise the currently-handled TypeError with the field name added.é z%s for field %s.%sé N)ÚsysÚexc_infoÚlenÚargsrO Ú TypeErrorr Úwith_traceback)Z message_nameÚ
|
field_nameÚexcr& r& r' Ú _ReraiseTypeErrorWithFieldNameÕ s r c s, dd fdd}d|_ d|_||_dS )z Adds an __init__ method to cls.c S sD t |tr@z| j| jW S tk
|
r> td| j|f Y nX |S )a Convert a string or integer enum value to an integer.
|
|
If the value is a string, it is converted to the enum value in
|
enum_type with the same name. If the value is not a string, it's
|
returned as-is. (No conversion or bounds-checking is done.)
|
z Enum type %s: unknown label "%s")r r Zvalues_by_namer` ÚKeyErrorr r )ry rX r& r& r' Ú_GetIntegerEnumValueã s
|
ÿz,_AddInitMethod.<locals>._GetIntegerEnumValuec s d| _ t|dk| _i | _i | _d| _d | _d| _t ¡ | _
|
t | | _ | ¡ D ]Ä\}}t| d kr|tdj|f |d krqN jtjkrR | ¡} jtjkrt ræt rÚ|D ]}|| || ¡ qÀn
|
| |¡ n2|D ],}t|t r|j f | qê| ¡ |¡ qên, jtj kr< fdd|D }| |¡ || j < qN jtjkrÆ | ¡}|}t|t r j j!f |}z| |¡ W n" tk
|
r¸ t"j| Y nX || j < qN jtj krà j#|}zt$| || W qN tk
|
r t"j| Y qNX qNd S )Nr r& Fz,%s() got an unexpected keyword argument "%s"c s g | ]} j |qS r& )ry )Ú.0Úval)r r7 r& r' Ú
|
<listcomp> s ÿz0_AddInitMethod.<locals>.init.<locals>.<listcomp>)%r@ r rA rB rI rC rD rE Úmessage_listener_modÚNullMessageListenerrF Ú _ListenerrG rr Ú_GetFieldByNamer r rR rP rk rc rZ r[ rW r\ Ú MergeFromÚupdater ÚdictÚaddZ CPPTYPE_ENUMÚextendrU r r ry rw )ÚselfÚkwargsr Ú field_valueÚcopyrz r Únew_val©r rK rS r' Úinitò sf
|
|
|
ÿ
|
ÿ
|
|
z _AddInitMethod.<locals>.initN)r9 r; r6 )rK r rª r& r© r' r0 à s
|
@r0 c C s8 z | j | W S tk
|
r2 td| j|f Y nX dS )zóReturns a field descriptor by field name.
|
|
Args:
|
message_descriptor: A Descriptor describing all fields in message.
|
field_name: The name of the field to retrieve.
|
Returns:
|
The field descriptor associated with the field name.
|
ú&Protocol message %s has no "%s" field.N)rY r r r )rK r r& r& r' r 7 s ÿr c C s. | j D ]}t|| q| jr*tdd |_dS )ú=Adds properties for all fields in this protocol message type.c S s t | S rL )Ú_ExtensionDict©r¤ r& r& r' Ú<lambda>O ó z)_AddPropertiesForFields.<locals>.<lambda>N)r- Ú_AddPropertiesForFieldÚ is_extendableÚpropertyZ
|
Extensions)r r r7 r& r& r' r1 G s
|
r1 c C sh t jdkst| j ¡ d }t||| j | jt jkrBt | | n"| j
|
t j krZt | | n
|
t | | dS )a# Adds a public property for a protocol message field.
|
Clients can use this property to get and (in the case
|
of non-repeated scalar fields) directly set the value
|
of a protocol message field.
|
|
Args:
|
field: A FieldDescriptor for this field.
|
cls: The class we're constructing.
|
é
|
Ú _FIELD_NUMBERN)rP Z MAX_CPPTYPEr( r Úupperrw r` rR rk Ú _AddPropertiesForRepeatedFieldrZ r[ Ú*_AddPropertiesForNonRepeatedCompositeFieldÚ'_AddPropertiesForNonRepeatedScalarField)r7 r Ú constant_namer& r& r' r± R s r± c @ s e Zd ZdZdd ZdS )Ú_FieldProperty)r c C s t j| |||d || _d S )N©Údoc)r³ r6 r )r¤ r ÚgetterÚsetterr½ r& r& r' r6 n s z_FieldProperty.__init__N)r8 r9 r: rJ r6 r& r& r& r' r» k s r» c sZ j t} fdd}d|_d |_fdd}d }t||t |||d dS ) a Adds a public property for a "repeated" protocol message field. Clients
|
can use this property to get the value of the field, which will be either a
|
RepeatedScalarFieldContainer or RepeatedCompositeFieldContainer (see
|
below).
|
|
Note that when clients add values to these containers, we perform
|
type-checking in the case of repeated scalar fields, and we also set any
|
necessary "has" bits as a side-effect.
|
|
Args:
|
field: A FieldDescriptor for this field.
|
cls: The class we're constructing.
|
c s0 | j ¡}|d kr, | ¡}| j |¡}|S rL ©rB Úgetrc Ú
|
setdefault©r¤ r¦ rS r& r' r¾ s
|
|
z._AddPropertiesForRepeatedField.<locals>.getterNúGetter for %s.c s t d d S )NzIAssignment not allowed to repeated field "%s" in protocol message object.©ÚAttributeError©r¤ Ú new_valuer= r& r' r¿ s ÿz._AddPropertiesForRepeatedField.<locals>.setterú/Magic attribute generated for "%s" proto field.r¼ ©r r? r9 r; rw r» ©r7 r Ú property_namer¾ r¿ r½ r& ©r7 r> r' r· s s
|
r· c s² j }t|}t ¡jjjdk}fdd}d|_d| |_|oRj fddj rzfdd }n}d|_d
|
| |_d | }t
|
||t |||d dS ) a Adds a public property for a nonrepeated, scalar protocol message field.
|
Clients can use this property to get and directly set the value of the field.
|
Note that when the client sets the value of a field by using this property,
|
all necessary "has" bits are set as a side-effect, and we also perform
|
type-checking.
|
|
Args:
|
field: A FieldDescriptor for this field.
|
cls: The class we're constructing.
|
r] c s | j ¡S rL )rB rÁ r® )r r7 r& r' r¾ ° s z7_AddPropertiesForNonRepeatedScalarField.<locals>.getterNrÄ c
|
sz z |¡}W n6 tk
|
rD } ztdj||f W 5 d }~X Y nX r^|s^| j d ¡ n
|
|| j< | jsv| ¡ d S )Nz Cannot set %s to %.1024r: %s)Z
|
CheckValuer r rB ÚpoprA Ú _Modified)r¤ rÈ Úe)Úclear_when_set_to_defaultr7 r r& r' Ú field_setter¹ s ÿ
|
z=_AddPropertiesForNonRepeatedScalarField.<locals>.field_setterc s | | | ¡ d S rL )Ú_UpdateOneofStaterÇ )r7 rÒ r& r' r¿ Ì s
|
z7_AddPropertiesForNonRepeatedScalarField.<locals>.setterzSetter for %s.rÉ r¼ ) r r? r
|
r r rN rl r9 r; ra rw r» )r7 r r> rÌ ri r¾ r¿ r½ r& )rÑ r r7 rÒ r r' r¹ s"
|
|
|
r¹ c sZ j t} fdd}d|_d |_fdd}d }t||t |||d dS ) aN Adds a public property for a nonrepeated, composite protocol message field.
|
A composite field is a "group" or "message" field.
|
|
Clients can use this property to get the value of the field, but cannot
|
assign to the property directly.
|
|
Args:
|
field: A FieldDescriptor for this field.
|
cls: The class we're constructing.
|
c s0 | j ¡}|d kr, | ¡}| j |¡}|S rL rÀ rà rS r& r' r¾ ê s
|
|
z:_AddPropertiesForNonRepeatedCompositeField.<locals>.getterNrÄ c s t d d S )NzJAssignment not allowed to composite field "%s" in protocol message object.rÅ rÇ r= r& r' r¿ ý s ÿz:_AddPropertiesForNonRepeatedCompositeField.<locals>.setterrÉ r¼ rÊ rË r& rÍ r' r¸ Ú s
|
r¸ c C s` | j }| ¡ D ]"\}}| ¡ d }t|||j q| jdk r\| jj}|j| |_|j| |_dS )r¬ rµ N) rq rr r¶ rw r` ÚfileÚpoolZ_extensions_by_numberZ_extensions_by_name)r r rs rt ru rº rÕ r& r& r' r2 s
|
r2 c s0 fdd}t | _ fdd}t | _d S )Nc s& j | _ j jj | ¡ t | d S rL )r rN rÔ rÕ Z_AddExtensionDescriptorr. )Úextension_handle©r r& r' ÚRegisterExtension s z,_AddStaticMethods.<locals>.RegisterExtensionc s }| | ¡ |S rL )ÚMergeFromString)Úsr r× r& r' Ú
|
FromString s
|
z%_AddStaticMethods.<locals>.FromString)Ú staticmethodrØ rÛ )r rØ rÛ r& r× r' r3 s
|
r3 c C s> | d j tjkr t| d S | d jtjkr6| d jS dS dS )zGiven a (FieldDescriptor, value) tuple from _fields, return true if the
|
value should be included in the list returned by ListFields().r r TN)rR rP rk ÚboolrZ r[ rE ©Úitemr& r& r' Ú
|
_IsPresent& s
|
|
rà c C s dd }||_ dS )ú Helper for _AddMessageMethods().c S s( dd | j ¡ D }|jdd d |S )Nc S s g | ]}t |r|qS r& )rà )r rß r& r& r' r 6 s z<_AddListFieldsMethod.<locals>.ListFields.<locals>.<listcomp>c S s
|
| d j S )Nr )r` rÞ r& r& r' r¯ 7 r° z:_AddListFieldsMethod.<locals>.ListFields.<locals>.<lambda>)rz )rB rr Úsort)r¤ Z
|
all_fieldsr& r& r' Ú
|
ListFields5 s z(_AddListFieldsMethod.<locals>.ListFieldsN)rã )rK r rã r& r& r' Ú_AddListFieldsMethod2 s rä zTProtocol message %s has no non-repeated submessage field "%s" nor marked as optionalz2Protocol message %s has no non-repeated field "%s"c s j dk}|rtnti jD ]4}|jtjkr2q |rJ|jtjkrJ|j sJq ||j
|
< q j D ]}||j
|
< q\ fdd |_ dS )rá r] c s¢ z | }W n& t k
|
r2 tj|f Y nX t|tjrnz | | j| jW S t k
|
rj Y dS X n0|jt j
|
kr| j |¡}|d k o|j S || j kS d S )NF)r r r r Údescriptor_modZOneofDescriptorrI r rZ rP r[ rB rÁ rE )r¤ r r7 rX ©rm Ú error_msgZhassable_fieldsrK r& r' rm U s
|
z$_AddHasFieldMethod.<locals>.HasFieldN) rl Ú_PROTO3_ERROR_TEMPLATEÚ_PROTO2_ERROR_TEMPLATEr- rR rP rk rZ r[ ra r Zoneofsrm )rK r ri r7 Zoneofr& ræ r' Ú_AddHasFieldMethodA s
|
|
ÿ
|
rê c s fdd}||_ dS )rá c sÒ z j | }W nh tk
|
rv z, j| }|| jkr@| j| }nW Y d S W n& tk
|
rp td j|f Y nX Y nX || jkrÆt| j| dr | j| ¡ | j|= | j |j
|
d ¡|krÆ| j|j
|
= | ¡ d S )Nr« ÚInvalidateIterators) rY r Úoneofs_by_namerI r r rB Úhasattrrë rÁ ra rÏ )r¤ r r7 ©rK r& r' Ú
|
ClearFieldl s&
|
|
ÿ
|
|
z(_AddClearFieldMethod.<locals>.ClearFieldN)rï )rK r rï r& rî r' Ú_AddClearFieldMethodj s !rð c C s dd }|| _ dS )rá c S s* t | |¡ || jkr | j|= | ¡ d S rL )r Ú_VerifyExtensionHandlerB rÏ )r¤ rÖ r& r& r' ÚClearExtension s
|
z0_AddClearExtensionMethod.<locals>.ClearExtensionN)rò )r rò r& r& r' Ú_AddClearExtensionMethod s ró c C s dd }|| _ dS )rá c S sZ t | |¡ |jtjkr&td|j |jtjkrL| j
|
|¡}|d k oJ|j S || j kS d S )Nz"%s" is repeated.) r rñ rR rP rk r r rZ r[ rB rÁ rE )r¤ rÖ rX r& r& r' Ú HasExtension s z,_AddHasExtensionMethod.<locals>.HasExtensionN)rô )r rô r& r& r' Ú_AddHasExtensionMethod s
|
rõ c C sh ddl m} | ¡ }| j}|s"dS | d¡d }|j |¡}|dkrHdS | |¡}| }| | j ¡ |S )at Unpacks Any message and returns the unpacked message.
|
|
This internal method is different from public Any Unpack method which takes
|
the target message as argument. _InternalUnpackAny method does not have
|
target message type and need to find the message type in descriptor pool.
|
|
Args:
|
msg: An Any message to be unpacked.
|
|
Returns:
|
The unpacked message.
|
r )Úsymbol_databaseNú/éÿÿÿÿ)
|
Úgoogle.protobufrö ZDefaultÚtype_urlÚsplitrÕ ZFindMessageTypeByNameZ GetPrototypeZParseFromStringrX )Úmsgrö Úfactoryrú Z type_namer Z message_classr r& r& r' Ú_InternalUnpackAnyª s
|
rþ c C s dd }||_ dS )rá c S s t |tjr|j| jkr dS | |kr(dS | jjtkrTt| }t|}|rT|rT||kS | ¡ | ¡ kshdS t| j }|
|
¡ t|j }|
|
¡ ||kS r_ ) r Ú message_modÚMessager r Ú_AnyFullTypeNamerþ rã ÚlistrC râ )r¤ ÚotherZany_aZany_bZunknown_fieldsZother_unknown_fieldsr& r& r' Ú__eq__Ô s$
|
ÿ
|
|
z _AddEqualsMethod.<locals>.__eq__N)r )rK r r r& r& r' Ú_AddEqualsMethodÒ s r c C s dd }||_ dS )rá c S s
|
t | ¡S rL ©r ÚMessageToStringr® r& r& r' Ú__str__ò s z _AddStrMethod.<locals>.__str__N)r )rK r r r& r& r' Ú _AddStrMethodð s r c C s dd }||_ dS )rá c S s
|
t | ¡S rL r r® r& r& r' Ú__repr__ù s z _AddReprMethod.<locals>.__repr__N)r
|
)rK r r
|
r& r& r' Ú_AddReprMethod÷ s r c C s dd }||_ dS )rá c S s t j| dd d¡S )NT)Zas_utf8zutf-8)r r Údecoder® r& r& r' Ú __unicode__ s z&_AddUnicodeMethod.<locals>.__unicode__N)r )Zunused_message_descriptorr r r& r& r' Ú_AddUnicodeMethodþ s r c C s> zt j| }||| W S tk
|
r8 t d| ¡Y nX dS )a Returns the number of bytes needed to serialize a non-repeated element.
|
The returned byte count includes space for tag information and any
|
other additional space associated with serializing value.
|
|
Args:
|
value: Value we're serializing.
|
field_number: Field number of this value. (Since the field number
|
is stored as part of a varint-encoded tag, this has an impact
|
on the total bytes required to serialize the value).
|
field_type: The type of the field. One of the TYPE_* constants
|
within FieldDescriptor.
|
zUnrecognized field type: %dN)r
|
ZTYPE_TO_BYTE_SIZE_FNr rÿ Ú EncodeError)rX Ú field_numberZ
|
field_typeÚfnr& r& r' Ú_BytesForNonRepeatedElement s
|
|
r c C s dd }||_ dS )rá c S s¦ | j s | jS d}| j}| ¡ jrJ|jd | j¡}||jd | j¡7 }nD| ¡ D ]\}}|| |¡7 }qR| j
|
D ] \}}|t |t | 7 }qp|| _d| _ d| j _ |S )Nr rz rX F)rA r@ r r+ rV rY ro rz rX rã rC r rG Údirty)r¤ Úsizer rh r¦ re Ú value_bytesr& r& r' ÚByteSize s
|
z$_AddByteSizeMethod.<locals>.ByteSizeN)r )rK r r r& r& r' Ú_AddByteSizeMethod s r c C s dd }||_ dS )rá c [ s4 | ¡ s(t d| jjd | ¡ ¡f ¡| jf |S )Nz)Message %s is missing required fields: %sú,)Ú IsInitializedrÿ r r r ÚjoinÚFindInitializationErrorsÚSerializePartialToString)r¤ r¥ r& r& r' ÚSerializeToString8 s ÿÿz6_AddSerializeToStringMethod.<locals>.SerializeToStringN)r )rK r r r& r& r' Ú_AddSerializeToStringMethod5 s r c C s" dd }||_ ddd}||_dS )rá c [ s t }| j|jf| | ¡ S rL )r Ú_InternalSerializeÚwriteÚgetvalue)r¤ r¥ Úoutr& r& r' r E s zD_AddSerializePartialToStringMethod.<locals>.SerializePartialToStringNc S s |d krt ¡ }nt|}| j}| ¡ jrX|jd || j|¡ |jd || j |¡ n@|
|
¡ D ]\}}| |||¡ q`| j D ]\}}|| || q~d S )Nrz rX ) r Z)IsPythonDefaultSerializationDeterministicrÝ r r+ rV rY rn rz rX rã rC )r¤ Ú write_bytesZ deterministicr rh r¦ re r r& r& r' ÚInternalSerializeK s* ÿ
|
|
ÿ
|
ÿz=_AddSerializePartialToStringMethod.<locals>.InternalSerialize)N)r r )rK r r r$ r& r& r' Ú"_AddSerializePartialToStringMethodB s
|
r% c s: dd }||_ tjtj|j fdd}||_dS )rá c
|
S s t |}t|}z | |d|¡|kr.t d¡W nN ttfk
|
rR t d¡Y n. tjk
|
r~ } zt |¡W 5 d }~X Y nX |S )Nr zUnexpected end-group tag.zTruncated message.) Ú
|
memoryviewr Ú_InternalParserÿ Ú DecodeErrorÚ
|
IndexErrorr ÚstructÚerror)r¤ Z
|
serializedÚlengthrÐ r& r& r' rÙ d s z2_AddMergeFromStringMethod.<locals>.MergeFromStringc s8 t |tst| ¡ | j}| j}||kr4||\}} |d¡\}} |dkr| js`g | _|dkrxt ¡ | _| j}t
|
|d¡\}
|
} t |
|
¡\} } | dkr¨t d¡|}t
|
||| ¡\}}|dkrÊ|S | | | |¡ ||||}|dkrò|S | j ||||
¡ f¡ |}q"||||| |}| r"| | ¡ q"|S )a6 Create a message from serialized bytes.
|
|
Args:
|
self: Message, instance of the proto message object.
|
buffer: memoryview of the serialized data.
|
pos: int, position to start in the serialized data.
|
end: int, end position of the serialized data.
|
|
Returns:
|
Message object.
|
)NNNr zField number 0 is illegal.rø )r r& r( rÏ rB rD rÁ rC r ÚUnknownFieldSetr Z _DecodeVarintr Z UnpackTagrÿ r( Z_DecodeUnknownFieldZ_addÚappendÚtobytesrÓ )r¤ ÚbufferÚposÚendZ
|
field_dictZunknown_field_setre Únew_posrf Z
|
field_descÚtagÚ_r Z wire_typeZold_posÚdata©Zdecoders_by_tagZ local_ReadTagZlocal_SkipFieldr& r' Ú InternalParsex sJ
|
|
|
|
ÿÿ z0_AddMergeFromStringMethod.<locals>.InternalParseN)rÙ r ZReadTagZ SkipFieldr) r' )rK r rÙ r8 r& r7 r' Ú_AddMergeFromStringMethodb s 7r9 c s: dd | j D d fdd }||_ fdd}||_dS ) z[Adds the IsInitialized and FindInitializationError methods to the
|
protocol message class.c S s g | ]}|j tjkr|qS r& )rR rP ZLABEL_REQUIRED)r r7 r& r& r' r ¶ s ÿz+_AddIsInitializedMethod.<locals>.<listcomp>Nc sî D ]B}|| j ks*|jtjkr| j | js|dk r@| | ¡ ¡ dS qt| j ¡ D ]\}}|jtjkrV|j tj
|
kr¾|j j r|j ¡ jrqV|D ]*}| ¡ s|dk r²| | ¡ ¡ dS qqV|jrV| ¡ sV|dk râ| | ¡ ¡ dS qVdS )a Checks if all required fields of a message are set.
|
|
Args:
|
errors: A list which, if provided, will be populated with the field
|
paths of all missing required fields.
|
|
Returns:
|
True iff the specified message has all required fields set.
|
NFT)rB rZ rP r[ rE r£ r r rr rR rk rU r* r+ rV r )r¤ Úerrorsr7 rX Úelement©Zrequired_fieldsr& r' r ¹ s4
|
|
ÿ
|
þ
|
ÿ z._AddIsInitializedMethod.<locals>.IsInitializedc s( g }D ] }| |j¡s| |j¡ q| ¡ D ]ô\}}|jtjkr.|jrTd|j }n|j}t |rªt
|
|r¨|D ]6}|| }d||f | ¡ }| fdd|D 7 }qnn q.|j tj krütt|D ]6}|| }d||f | ¡ }| fdd|D 7 }qÂq.|d | ¡ }| fdd|D 7 }q.|S ) zÆFinds required fields which are not initialized.
|
|
Returns:
|
A list of strings. Each string is a path to an uninitialized field from
|
the top-level message, e.g. "foo.bar[5].baz".
|
z(%s)z%s[%s].c s g | ] } | qS r& r& ©r r+ ©Úprefixr& r' r ý s zM_AddIsInitializedMethod.<locals>.FindInitializationErrors.<locals>.<listcomp>z%s[%d].c s g | ] } | qS r& r& r= r> r& r' r s Ú.c s g | ] } | qS r& r& r= r> r& r' r
|
s )rm r r. rã rZ rP r[ rM r rW r\ r rR rk Úranger ) r¤ r: r7 rX r rz r; Z
|
sub_errorsÚir< r> r' r â s6 z9_AddIsInitializedMethod.<locals>.FindInitializationErrors)N)r- r r )rK r r r r& r< r' Ú_AddIsInitializedMethod² s
|
' ,rC c C s, | j }t| d| j}|dkr |S |d | S )Nr: )NÚbuiltinsÚ __builtin__r@ )r9 r r8 )ÚklassÚmoduler r& r& r' Ú_FullyQualifiedClassName s
|
rH c s& t jt j fdd}|_d S )Nc s0 t |s$tdtt|jf || k s0t| ¡ | j}|j ¡ D ]\}}|jkr| |¡}|d kr~|
|
| ¡}|||< | |¡ qH|j krÊ|j rä| |¡}|d kr¾|
|
| ¡}|||< | |¡ qH|| j|< |jrH| |¡ qH|jr,| jsúg | _| j |j¡ | jd kr t ¡ | _| j |j¡ d S )NzLParameter to MergeFrom() must be instance of same class: expected %s got %s.)r r rH r% r( rÏ rB rr rR rÁ rc r rZ rE ra rÓ rC r£ rD r r- Z_extend)r¤ rü r- r7 rX r¦ ©r[ rk r r& r' r sF
|
ÿÿÿ
|
|
|
|
|
|
|
|
z&_AddMergeFromMethod.<locals>.MergeFrom)rP rk r[ r )r r r& rI r' Ú_AddMergeFromMethod s *rJ c s fdd}||_ d S )Nc s` z j | }W n tk
|
r. td| Y nX | j |d¡}|dk rX| |j¡rX|jS dS dS )zDReturns the name of the currently set field inside a oneof, or None.z)Protocol message has no oneof "%s" field.N)rì r r rI rÁ rm r )r¤ Z
|
oneof_namer7 Z nested_fieldrî r& r' Ú
|
WhichOneofK s ÿ
|
z(_AddWhichOneofMethod.<locals>.WhichOneof)rK )rK r rK r& rî r' Ú_AddWhichOneofMethodJ s rL c C s8 i | _ d| _| jd k r&| j ¡ d | _i | _| ¡ d S )Nr& )rB rC rD Ú_clearrI rÏ r® r& r& r' Ú_Clear\ s
|
|
rN c C s | j d krt ¡ | _ | j S rL )rD r r- r® r& r& r' Ú_UnknownFieldsi s
|
|
rO c C s~ g | _ d | _| ¡ D ]d\}}|jtjkrt|rPt|rx|D ]}|| ¡ q<q|j tj
|
krp|D ] }| ¡ q`q| ¡ qd S rL ) rC rD rã rZ rP r[ rW r\ ÚDiscardUnknownFieldsrR rk )r¤ r7 rX rz Z sub_messager& r& r' Ú_DiscardUnknownFieldsp s rQ c C s |d krt ¡ | _n|| _d S rL )r r rF )r¤ Zlistenerr& r& r' r
s r
c C s¼ t | | t| | t| | | jr4t| t| t| | t| | t| | t | | t
|
| | t | | t | | t | | t| | t| t| | t|_t|_t|_t|_dS )z3Adds implementations of all Message methods to cls.N)rä rê rð r² ró rõ r r r r r r r% r9 rC rJ rL rN ZClearrO Z UnknownFieldsrQ rP r
)rK r r& r& r' r4 s*
|
|
|
|
|
|
|
|
|
|
|
|
|
r4 c C s& dd }dd }||_ ||_||_dS )z5Adds implementation of private helper methods to cls.c S s( | j s$d| _ d| j_d| _| j ¡ dS )zwSets the _cached_byte_size_dirty bit to true,
|
and propagates this to our listener iff this was a state change.
|
TN)rA rG r rE rF ÚModifiedr® r& r& r' rR ¤ s
|
z*_AddPrivateHelperMethods.<locals>.Modifiedc S s0 | j |j|¡}||k r,| j|= || j |j< dS )zÈSets field as the active field in its containing oneof.
|
|
Will also delete currently active field in the oneof, if it is different
|
from the argument. Does not mark the message as modified.
|
N)rI r ra rB )r¤ r7 Z other_fieldr& r& r' rÓ ³ s z3_AddPrivateHelperMethods.<locals>._UpdateOneofStateN)rÏ Z SetInParentrÓ )rK r rR rÓ r& r& r' r5 ¡ s
|
r5 c @ s e Zd ZdZdd Zdd ZdS )r a0 MessageListener implementation that a parent message registers with its
|
child message.
|
|
In order to support semantics like:
|
|
foo.bar.baz.qux = 23
|
assert foo.HasField('bar')
|
|
...child objects must have back references to their parents.
|
This helper class is at the heart of this support.
|
c C s* t |tjr|| _n t |¡| _d| _dS )zArgs:
|
parent_message: The message whose _Modified() method we should call when
|
we receive Modified() messages.
|
FN)r ÚweakrefÚ ProxyTypeÚ_parent_message_weakrefÚproxyr )r¤ Úparent_messager& r& r' r6 Ñ s z_Listener.__init__c C s2 | j r
|
d S z| j ¡ W n tk
|
r, Y nX d S rL )r rU rÏ ÚReferenceErrorr® r& r& r' rR ä s z_Listener.ModifiedN)r8 r9 r: r; r6 rR r& r& r& r' r à s r c s, e Zd ZdZ fddZ fddZ ZS )r zCSpecial listener implementation for setting composite oneof fields.c s t t| |¡ || _dS )zËArgs:
|
parent_message: The message whose _Modified() method we should call when
|
we receive Modified() messages.
|
field: The descriptor of the field being set in the parent message.
|
N)r r r6 Ú_field)r¤ rW r7 r$ r& r' r6 ô s z_OneofListener.__init__c s: z | j | j¡ tt| ¡ W n tk
|
r4 Y nX dS )zEAlso updates the state of the containing oneof in the parent message.N)rU rÓ rY r r rR rX r® r$ r& r' rR ý s
|
z_OneofListener.Modified)r8 r9 r: r; r6 rR r< r& r& r$ r' r ñ s r )Tr; Ú
|
__author__Úior r* r rS Zgoogle.protobuf.internalr r r r r r r r r
|
r r rù r rå r rÿ r ZFieldDescriptorrP r r rO r r? r rT rW r\ r. r r/ rb rp r r0 r r1 r± r³ r» r· r¹ r¸ r2 r3 rà rä rè ré rê rð ró rõ rþ r r r r r r r r% r9 rC rH rJ rL rN rO rQ r
r4 r5 Úobjectr r r& r& r& r' Ú<module>$ s S: W ,;, ÿ)& ( P_1 ".
|
