Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
4.3.1.2-4.3 ▾
|
python3-tvault-contego
/
usr
/
lib
/
python3.6
/
site-packages
/
contego
/
objects
/
__pycache__
/
base.cpython-36.pyc
|
|---|
3
ÒƜeW. ã @ s8 d Z ddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z ddl
m
Z ddlZddlm
Z
ddlmZ ddlmZ ddlmZ G d d
d
e jZG d d d eZG d
d de jZe j Z e j Z e j Z e j Z G dd de j Z dd Z!G dd dej"Z#G dd de j$Z$dd Z%dd Z&d dd Z'dS ) z$Contego common internal object modelé N)Ú versionutils)Úbase)Ú exception)Úobjects)Úfields)Úutilsc @ s0 e Zd Zg Zdd Zedd Zedd ZdS )ÚContegoObjectRegistryc C s^ t j|j}tt|j s,tt|j | n.t jtt|j j}||krZtt|j | d S )N)r Zconvert_version_to_tupleÚVERSIONÚhasattrr Úobj_nameÚsetattrÚgetattr)ÚselfÚclsÚindexÚversionZ cur_version© r ú/usr/lib/python3.6/base.pyÚregistration_hook s z'ContegoObjectRegistry.registration_hookc C s | j d| | jj| |S )zµRegister a class as notification.
Use only to register concrete notification or payload classes,
do not register base classes intended for inheritance only.
F)Z register_ifÚnotification_classesÚappend)r Únotification_clsr r r Úregister_notification' s z+ContegoObjectRegistry.register_notificationc C s x| j D ]}| j| qW dS )z²Register previously decorated notification as normal ovos.
This is not intended for production use but only for testing and
document generation purposes.
N)r Úregister)r r r r r Ú register_notification_objects1 s z3ContegoObjectRegistry.register_notification_objectsN)Ú__name__Ú
__module__Ú __qualname__r r Ú classmethodr r r r r r r s
r c @ s> e Zd ZdZejddejddejddejdddZdS )ÚContegoPersistentObjectzuMixin class for Persistent objects.
This adds the fields that we use in common for most persistent objects.
T)ZnullableF)Údefault)Z
created_atZ
updated_atZ
deleted_atZdeletedN)r r r Ú__doc__Ú
obj_fieldsZ
DateTimeFieldZ BooleanFieldr r r r r r : s
r c @ s@ e Zd ZdZdZdZedd Zej dd Z
ej dd Z d
S ) Ú
ContegoObjecta\ Base class and object factory.
This forms the base of all objects that can be remoted or instantiated
via RPC. Simply defining a class that inherits from this base class
will make it remotely instantiatable. Objects should implement the
necessary "get" classmethod routines as well as "save" object methods
as appropriate.
Zcontego_objectÚcontegoc C s
t dS )zÊA check that can be used to inhibit online migration behavior
This is usually used to check if all services that will be accessing
the db directly are ready for the new format.
N)ÚNotImplementedErrorr r r r Úshould_migrate_dataS s z!ContegoObject.should_migrate_datac c s$ | j }|| _ z
d V W d || _ X d S )N)Ú_context)r ÚcontextÚoriginal_contextr r r Úobj_alternate_context\ s
z#ContegoObject.obj_alternate_contextc c sF | j dkr tjd| j d| j }| j j | _ z
dV W d|| _ X dS )a Context manager to make an object call as an admin.
This temporarily modifies the context embedded in an object to
be elevated() and restores it after the call completes. Example
usage:
with obj.obj_as_admin():
obj.save()
NÚ obj_as_admin)ÚmethodZobjtype)r' r ZOrphanedObjectErrorr Zelevated)r r) r r r r+ f s
zContegoObject.obj_as_adminN) r r r r! ZOBJ_SERIAL_NAMESPACEZOBJ_PROJECT_NAMESPACEÚ staticmethodr& Ú
contextlibÚcontextmanagerr* r+ r r r r r# F s
r# c @ s e Zd Zdd Zdd ZdS )ÚContegoObjectDictCompatc c s. x(| j D ] }| j|s || jkr|V qW d S )N)r" Zobj_attr_is_setZobj_extra_fields)r Únamer r r Ú__iter__ s
z ContegoObjectDictCompat.__iter__c C s t | S )N)Úlist)r r r r Úkeys s z ContegoObjectDictCompat.keysN)r r r r2 r4 r r r r r0 s r0 c C s d| S )z>Return the mangled name of the attribute's underlying storage.Z_obj_r )r1 r r r Ú get_attrname s r5 c @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S ) ÚContegoObjectSerializeraD A ContegoObject-aware Serializer.
This implements the Oslo Serializer interface and provides the
ability to serialize and deserialize ContegoObject entities. Any service
that needs to accept or return ContegoObjects as arguments or result values
should pass this to its RPCClient and RPCServer objects.
c C s yt j||d}W n tjk
r |d }|jddkrbdj|jdd d
|d< | j||S |d }tj |}||kr| j
j |||}n Y nX |S )N)r( zcontego_object.versionÚ.é zcontego_object.name) r# Zobj_from_primitiveÚovoo_excZIncompatibleObjectVersionÚcountÚjoinÚsplitÚ_process_objectÚ ovoo_baseZobj_tree_get_versionsZ conductorZobject_backport_versions)r r( ZobjprimZobjinstZobjverZobjnameZversion_manifestr r r r= s
z'ContegoObjectSerializer._process_objectc sZ |j }t|tr2|f fddt|j D S |tkr>t}| fdd|D S dS )ao Process an iterable, taking an action on each value.
:param:context: Request context
:param:action_fn: Action to take on each item in values
:param:values: Iterable container of things to take action on
:returns: A new container of the same type (except set) with
items from values having had action applied.
c s i | ]\}} ||qS r r )Ú.0ÚkÚv)Ú action_fnr( r r ú
<dictcomp>º s z=ContegoObjectSerializer._process_iterable.<locals>.<dictcomp>c s g | ]} |qS r r )r? Úvalue)rB r( r r ú
<listcomp>Ä s z=ContegoObjectSerializer._process_iterable.<locals>.<listcomp>N)Ú __class__Ú
issubclassÚdictr3 ÚitemsÚset)r r( rB ÚvaluesÚiterabler )rB r( r Ú_process_iterable° s
z)ContegoObjectSerializer._process_iterablec C sD t |dr t|jr |j }n"t|ttttfr@| j|| j |}|S )NÚobj_to_primitive)
r
ÚcallablerN Ú
isinstanceÚtupler3 rJ rH rM Úserialize_entity)r r( Úentityr r r rR Æ s
z(ContegoObjectSerializer.serialize_entityc C sF t |tr d|kr | j||}n"t |ttttfrB| j|| j|}|S )Nzcontego_object.name)rP rH r= rQ r3 rJ rM Údeserialize_entity)r r( rS r r r rT Ï s
z*ContegoObjectSerializer.deserialize_entityN)r r r r! r= rM rR rT r r r r r6 s
r6 c @ s* e Zd Zedd ZeejfddZdS )ÚObjectListBasec C s d| S )Nzcontego_object.%sr )r Úfieldr r r Ú_obj_primitive_keyÚ s z!ObjectListBase._obj_primitive_keyc C s, | j |}|tjkr || S |j||S d S )N)rW r" ÚUnspecifiedDefaultÚget)r Z primitiverV r Úkeyr r r Ú_obj_primitive_fieldÞ s
z#ObjectListBase._obj_primitive_fieldN)r r r r rW r" rX r[ r r r r rU × s rU c C sp i }xB|D ]:}t ||}||kr4| ||< g || _|| jj| q
W x"|D ]}| || _|| j qNW |S )a Construct a dictionary of object lists, keyed by item_key.
:param:context: Request context
:param:list_cls: The ObjectListBase class
:param:obj_list: The list of objects to place in the dictionary
:param:item_key: The object attribute name to use as a dictionary key
)r
r r r' Zobj_reset_changes)r( Zlist_clsZobj_listZitem_keyZ obj_listsÚobjrZ r r r Úobj_make_dict_of_listsç s
r] c s@ fdd}t dd|_ |_t dr8tj |S t|S )zCDecorator that will do the arguments serialization before remoting.c sº dd |D }x~t |j D ]n\}}|dkr@|r@tj|||< q |dkrp|rpt|tj rpdjtj|||< q t|t j r t
j |||< q W t dr¨ | f||S j
d | ||S )Nc S s& g | ] }t |tjr tj|n|qS r )rP Údatetimer Ústrtime)r? Úargr r r rE s z3serialize_args.<locals>.wrapper.<locals>.<listcomp>Zexc_valZexc_tbÚ Ú__call__)r3 rI ÚsixZ text_typerP Z string_typesr; Ú tracebackÚ format_tbr^ r r_ r
Ú__get__)r\ ÚargsÚkwargsr@ rA )Úfnr r Úwrapperÿ s
z serialize_args.<locals>.wrapperÚ remotableFrb )r
rk Z original_fnr
Ú functoolsÚwrapsr )ri rj r )ri r Úserialize_argsý s
rn c sJ fdd |dk r dg| }ndg} | j |} |j |}||kS )aD Compare two primitives for equivalence ignoring some keys.
This operation tests the primitives of two objects for equivalence.
Object primitives may contain a list identifying fields that have been
changed - this is ignored in the comparison. The ignore parameter lists
any other keys to be ignored.
:param:obj1: The first object in the comparison
:param:obj2: The second object in the comparison
:param:ignore: A list of fields to ignore
:returns: True if the primitives are equal ignoring changes
and specified fields, otherwise False.
c sj t | trDx|D ]}| j|d qW x t| j D ]} || q2W t | trfx| D ]} || qTW | S )N)rP rH Úpopr3 rK )Zprimr4 r@ rA )Ú_stripr r rp $ s
z obj_equal_prims.<locals>._stripNzcontego_object.changes)rN )Zobj_1Zobj_2Úignorer4 Zprim_1Zprim_2r )rp r Úobj_equal_prims s rr )N)(r! r. r^ rl rd ZnetaddrZoslo_messagingZ messagingZ
oslo_utilsr Zoslo_versionedobjectsr r> r r9 rc r$ r Zcontego.objectsr r" r ZVersionedObjectRegistryr Úobjectr ZVersionedObjectr# Zremotable_classmethodrk Z
obj_make_listZVersionedObjectDictCompatr0 r5 ZNoOpSerializerr6 rU r] rn rr r r r r Ú<module> s8 # 7
D