|
Server : LiteSpeed System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64 User : nandedex ( 1060) PHP Version : 8.1.33 Disable Function : NONE Directory : /opt/cppython/lib/python3.8/site-packages/proto/marshal/__pycache__/ |
U
O��g�. � @ s" d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dl m
Z
d d l m Z d d
l m
Z
d d l mZ d d lmZ d d
lmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlmZ G dd� de j�ZG dd� d�ZG dd� de�Z G dd� d�Z dZ dS ) � N)�message)� duration_pb2)�
timestamp_pb2)�field_mask_pb2)�
struct_pb2)� wrappers_pb2)�compat)� MapComposite)�Repeated)�RepeatedComposite)�bytes)�stringy_numbers)�dates)�struct)�wrappers)�
field_mask)� ProtoTypec @ s e Zd ZdZedd� �ZdS )�Rulez,Abstract class definition for marshal rules.c C s t |d�rt |d�rdS tS )N� to_python�to_protoT)�hasattr�NotImplemented)�cls�C� r �B/opt/cppython/lib/python3.8/site-packages/proto/marshal/marshal.py�__subclasshook__* s zRule.__subclasshook__N)�__name__�
__module__� __qualname__�__doc__� classmethodr r r r r r ' s r c @ sb e Zd ZdZdd� Zdeed�dd�Zdd � Zd
d � Z dd �e
d �d
d�Z dd�e
d�dd�Z dS )� BaseMarshala� The base class to translate between protobuf and Python classes.
Protocol buffers defines many common types (e.g. Timestamp, Duration)
which also exist in the Python standard library. The marshal essentially
translates between these: it keeps a registry of common protocol buffers
and their Python representations, and translates back and forth.
The protocol buffer class is always the "key" in this relationship; when
presenting a message, the declared field types are used to determine
whether a value should be transformed into another class. Similarly,
when accepting a Python value (when setting a field, for example),
the declared field type is still used. This means that, if appropriate,
multiple protocol buffer types may use the same Python type.
The primary implementation of this is :class:`Marshal`, which should
usually be used instead of this class directly.
c C s i | _ t� | _| �� d S �N)�_rules�NoopRule�_noop�reset)�selfr r r �__init__D s zBaseMarshal.__init__N)�
proto_type�rulec s< |r$t |t�std��|�j� < dS td�� �fdd� }|S )a� Register a rule against the given ``proto_type``.
This function expects a ``proto_type`` (the descriptor class) and
a ``rule``; an object with a ``to_python`` and ``to_proto`` method.
Each method should return the appropriate Python or protocol buffer
type, and be idempotent (e.g. accept either type as input).
This function can also be used as a decorator::
@marshal.register(timestamp_pb2.Timestamp)
class TimestampRule:
...
In this case, the class will be initialized for you with zero
arguments.
Args:
proto_type (type): A protocol buffer message type.
rule: A marshal object
zIMarshal rule instances must implement `to_proto` and `to_python` methods.N��
rule_classc s" t | t�std��| � �j� < | S )NzJMarshal rule subclasses must implement `to_proto` and `to_python` methods.)�
issubclassr � TypeErrorr$ r, �r* r( r r �register_rule_classm s
� z1BaseMarshal.register.<locals>.register_rule_class)�
isinstancer r/ r$ �type)r( r* r+ r1 r r0 r �registerI s
�
zBaseMarshal.registerc C sX | j �� | �tjt�� � | �tjt� � � | �t
j t �
� � | �tjt�� � | �tjt�� � | �tjt�� � | �tjt�� � | �tjt�� � | �tjt�� � | �tj t� � � | �tj t� � � | �tj t�!� � | �t"j#t$j%| d�� | �t"j&t$j'| d�� | �t"j(t$j)| d�� | �t*j+t,�-� � t.j/D ]}| �|j0|� � �q<dS )z(Reset the registry to its initial state.��marshalN)1r$ �clearr4 r � Timestampr Z
TimestampRuler ZDurationZ DurationRuler Z FieldMaskr Z
FieldMaskRuler Z BoolValuer Z
BoolValueRuleZ
BytesValueZBytesValueRuleZ DoubleValueZDoubleValueRuleZ
FloatValueZFloatValueRuleZ
Int32ValueZInt32ValueRuleZ
Int64ValueZInt64ValueRuleZ StringValueZStringValueRuleZ UInt32ValueZUInt32ValueRuleZ UInt64ValueZUInt64ValueRuler �Valuer Z ValueRule� ListValueZ
ListValueRule�StructZ
StructRuler ZBYTES�pb_bytesZ BytesRuler
ZSTRINGY_NUMBER_RULESZ _proto_type)r( r- r r r r' { s&
zBaseMarshal.resetc C sZ | j �|| j�}|| jkrVt| d�rV| j�� D ]&\}}|j �|| j�}|| jkr. qVq.|S )N�
_instances)r$ �getr& r r= �items)r( r* r+ �_�instancer r r �get_rule� s
zBaseMarshal.get_rule��absentc C s� t |�}|tjkr t|| d�S |tjkrLt|t �r@t|| |d�S t|| d�S |tjksb|jtj krnt
|| d�S | j |d�j ||d�S )Nr5 )r6 r* �r* rC )
r3 r Zrepeated_composite_typesr Zrepeated_scalar_typesr2 r
Zmap_composite_typesr Zmap_composite_type_namesr rB r )r( r* �valuerD Z
value_typer r r r � s
�
� zBaseMarshal.to_pythonF)�strictc s� � t jt jt jfkrRt|ttf�r(|jS t|tt f�rRt
|�� �fdd�|D ��S t|t �r�� j j
r�� j �� jr�t
� � j����fdd�|�� D �S �j� d��|�}|r�t|� �s�tdj� j|jjd���|S )Nc 3 s | ]}�� � |�V qd S r# �r )�.0�ir0 r r � <genexpr>� s z'BaseMarshal.to_proto.<locals>.<genexpr>c s i | ]\}}|�� � |��qS r rH )rI �k�v)�recursive_typer( r r �
<dictcomp>� s z(BaseMarshal.to_proto.<locals>.<dictcomp>rE zLParameter must be instance of the same class; expected {expected}, got {got})�expected�got)r r9 r: r; r2 r
r Zpb�list�tupler3 �dictZ
DESCRIPTORZ has_optionsZ
GetOptionsZ map_entryrF r? rB r r/ �formatr � __class__)r( r* rF rG �pb_valuer )r* rN r( r r � s2 �
�
� ��zBaseMarshal.to_proto)N)
r r r r r) r3 r r4 r' rB �boolr r r r r r r" 1 s 2'r" c s< e Zd ZdZi Zed�� fdd� Zed�� fdd� Z� ZS )�Marshala The translator between protocol buffer and Python instances.
The bulk of the implementation is in :class:`BaseMarshal`. This class
adds identity tracking: multiple instantiations of :class:`Marshal` with
the same name will provide the same instance.
)�namec s. | j �|�}|dkr*t� �| � }| j |< |S )z�Create a marshal instance.
Args:
name (str): The name of the marshal. Instantiating multiple
marshals with the same ``name`` argument will provide the
same marshal each time.
N)r= r> �super�__new__)r rZ �klass�rV r r r\ s zMarshal.__new__c s || _ t| d�st� �� dS )z�Instantiate a marshal.
Args:
name (str): The name of the marshal. Instantiating multiple
marshals with the same ``name`` argument will provide the
same marshal each time.
r$ N)�_namer r[ r) )r( rZ r^ r r r) s
zMarshal.__init__) r r r r r= �strr\ r) �
__classcell__r r r^ r rY � s rY c @ s, e Zd ZdZdd�ed�dd�Zdd� ZdS )r% z#A catch-all rule that does nothing.NrC c C s |S r# r )r( rW rD r r r r " s zNoopRule.to_pythonc C s |S r# r )r( rF r r r r % s zNoopRule.to_proto)r r r r rX r r r r r r r% s r% )rY ) �abc�enumZgoogle.protobufr r r r r r Z
proto.marshalr Zproto.marshal.collectionsr r
r Zproto.marshal.rulesr r< r
r r r r Zproto.primitivesr �ABCr r" rY r% �__all__r r r r �<module> s0
J%