o ¯b1ã@sPUdZddlZddlZddlZddlZddlZddlmZ ddl mZddlm Z mZddlmZiZeeejfed<ejZdd „Zd d„Zdd „Ze eje¡dd„Zdd„Ze eje¡dd„Zdd„Ze eje¡dd„Z dd„Z!dd„Z"dd„Z#Gdd„dƒZ$ia%ee&d fed!<ia'd"d#„Z(d$d%„Z)d&d'„Z*Gd(d „d ƒZ+dS))z( Different styles of persisted objects. éN)ÚStringIO)ÚDict)ÚlogÚreflect)Ú_PYPYÚ oldModulescCst|j|j|jjffS)z3support function for copy_reg to pickle method refs)ÚunpickleMethodÚ__name__Ú__self__Ú __class__)Úmethod©r ú:/usr/lib/python3/dist-packages/twisted/persisted/styles.pyÚpickleMethodsþrcCst||ƒ}|S)a³ Retrieve the function object implementing a method name given the class it's on and a method name. @param classObject: A class to retrieve the method's function from. @type classObject: L{type} @param methodName: The name of the method whose function to retrieve. @type methodName: native L{str} @return: the function object corresponding to the given method name. @rtype: L{types.FunctionType} )Úgetattr)ÚclassObjectÚ methodNameÚmethodObjectr r rÚ_methodFunction"s rc CsŠ|dur t||ƒSzt||ƒ}Wn&ty6t d|d|¡|dus'Jdƒ‚|j|ur-‚t|||jƒYSwd}tj||g|¢RŽ}|S)aS Support function for copy_reg to unpickle method refs. @param im_name: The name of the method. @type im_name: native L{str} @param im_self: The instance that the method was present on. @type im_self: L{object} @param im_class: The class where the method was declared. @type im_class: L{type} or L{None} NÚMethodznot on classz'No recourse: no instance to guess from.r ) rrÚAttributeErrorrÚmsgrrÚtypesÚ MethodType)Úim_nameÚim_selfÚim_classÚmethodFunctionÚ maybeClassÚboundr r rr4s ø rcCs4|jdkrtd|›ƒ‚ttd |j|jg¡gƒfS)a— Reduce, in the sense of L{pickle}'s C{object.__reduce__} special method, a function object into its constituent parts. @param f: The function to reduce. @type f: L{types.FunctionType} @return: a 2-tuple of a reference to L{_unpickleFunction} and a tuple of its arguments, a 1-tuple of the function's fully qualified name. @rtype: 2-tuple of C{callable, native string} zzCannot pickle lambda function: Ú.)r Ú_UniversalPicklingErrorÚ_unpickleFunctionÚtupleÚjoinÚ __module__Ú__qualname__)Úfr r rÚ_pickleFunctionWs r(cCsddlm}||ƒS)aù Convert a function name into a function by importing it. This is a synonym for L{twisted.python.reflect.namedAny}, but imported locally to avoid circular imports, and also to provide a persistent name that can be stored (and deprecated) independently of C{namedAny}. @param fullyQualifiedName: The fully qualified name of a function. @type fullyQualifiedName: native C{str} @return: A function object imported from the given location. @rtype: L{types.FunctionType} r)ÚnamedAny)Útwisted.python.reflectr))ÚfullyQualifiedNamer)r r rr"hsr"cCst|jffS)z3support function for copy_reg to pickle module refs)ÚunpickleModuler )Úmoduler r rÚpickleModule~sr.cCs6|tvrt d|¡t|}t |¡t|iidƒS)z5support function for copy_reg to unpickle module refszModule has moved: %sÚx)rrrÚ __import__)Únamer r rr,ƒs r,cCs t| ¡| ¡ffS)zá Reduce the given cStringO. This is only called on Python 2, because the cStringIO module only exists on Python 2. @param stringo: The string output to pickle. @type stringo: C{cStringIO.OutputType} )ÚunpickleStringOÚgetvalueÚtell)Ústringor r rÚ pickleStringOs r6cCstƒ}| |¡| |¡|S)aÚ Convert the output of L{pickleStringO} into an appropriate type for the current python version. This may be called on Python 3 and will convert a cStringIO into an L{io.StringIO}. @param val: The content of the file. @type val: L{bytes} @param sek: The seek position of the file. @type sek: L{int} @return: a file-like object which you can write bytes to. @rtype: C{cStringIO.OutputType} on Python 2, L{io.StringIO} on Python 3. )Ú _cStringIOÚwriteÚseek©ÚvalÚsekr/r r rr2s r2cCst| ¡| ¡ffS)aQ Reduce the given cStringI. This is only called on Python 2, because the cStringIO module only exists on Python 2. @param stringi: The string input to pickle. @type stringi: C{cStringIO.InputType} @return: a 2-tuple of (C{unpickleStringI}, (bytes, pointer)) @rtype: 2-tuple of (function, (bytes, int)) )ÚunpickleStringIr3r4)Ústringir r rÚ pickleStringI²s r?cCst|ƒ}| |¡|S)aß Convert the output of L{pickleStringI} into an appropriate type for the current Python version. This may be called on Python 3 and will convert a cStringIO into an L{io.StringIO}. @param val: The content of the file. @type val: L{bytes} @param sek: The seek position of the file. @type sek: L{int} @return: a file-like object which you can read bytes from. @rtype: C{cStringIO.OutputType} on Python 2, L{io.StringIO} on Python 3. )r7r9r:r r rr=Âs r=c@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú Ephemeralzh This type of object is never persisted; if possible, even references to it are eliminated. cCstdfS)zu Serialize any subclass of L{Ephemeral} in a way which replaces it with L{Ephemeral} itself. r )r@)Úselfr r rÚ __reduce__ÞszEphemeral.__reduce__cCsJt d|¡ts#ddl}t|ddƒr#| |¡D] }t d|›¡qdS)Nz!WARNING: serializing ephemeral %srÚ get_referrersz referred to by )rrrÚgcrrC)rArDÚrr r rÚ__getstate__åszEphemeral.__getstate__cCst d|j¡t|_dS)Nz#WARNING: unserializing ephemeral %s)rrrr@©rAÚstater r rÚ__setstate__ïs zEphemeral.__setstate__N)r r%r&Ú__doc__rBrFrIr r r rr@Øs r@Ú VersionedÚversionedsToUpgradecCs&tt ¡ƒD]}t|ƒqiaiadS©N)ÚlistrLÚvaluesÚrequireUpgradeÚupgraded)Ú versionedr r rÚ doUpgradeøs rScCs4t|ƒ}|tvr|tvrdt|<| ¡|SdSdS)z?Require that a Versioned instance be upgraded completely first.éN)ÚidrLrQÚversionUpgrade)ÚobjÚobjIDr r rrPsýrPcCs@|tg}t |¡D]}||vrt|tƒr| |¡q |dd…S)z± Get all of the parent classes of C{c}, not including C{c} itself, which are strict subclasses of L{Versioned}. @param c: a class @returns: list of classes éN)rKÚinspectÚgetmroÚ issubclassÚappend)ÚcÚlÚbr r rÚ_aybabtu s €rac@s2eZdZdZdZdZdd„Zddd„Zd d „ZdS)rKa² This type of object is persisted with versioning information. I have a single class attribute, the int persistenceVersion. After I am unserialized (and styles.doUpgrade() is called), self.upgradeToVersionX() will be called for each version upgrade I must undergo. For example, if I serialize an instance of a Foo(Versioned) at version 4 and then unserialize it when the code is at version 9, the calls:: self.upgradeToVersion5() self.upgradeToVersion6() self.upgradeToVersion7() self.upgradeToVersion8() self.upgradeToVersion9() will be made. If any of these methods are undefined, a warning message will be printed. rr cCs|tt|ƒ<||_dSrM)rLrUÚ__dict__rGr r rrI3s zVersioned.__setstate__NcCs€t |p|j¡}t|jƒ}| ¡| |j¡|D]$}d|jvr-|jD] }||vr,||=q#d|jvr=|j|t |¡›d<q|S)z8Get state, adding a version number to it on its way out.ÚpersistenceForgetsÚpersistenceVersionz.persistenceVersion) ÚcopyrbrarÚreverser]rcrdrÚqual)rAÚdictÚdctÚbasesÚbaseÚslotr r rrF7s" € þÿ€zVersioned.__getstate__c CsZt|jƒ}| ¡| |j¡d|jvrB|jd}|jd=d}d}|D]}d|jvr+q#|j|kr5|}|j}q#|rB||jdt |¡<|D]f}t|j vrQd|jvrQqD|j}dt |¡}|j |¡pbd}|ri|j|=||ksqJdƒ‚||krª|d}|j d|d¡} | rt dt |¡t |j¡t |ƒ|f¡| |ƒn t d ||¡¡||ksuqDdS) z (internal) Do a version upgrade.rdrNz%s.persistenceVersionz"Sorry, can't go backwards in time.rTzupgradeToVersion%sz'Upgrading %s (of %s @ %s) to version %sz(Warning: cannot upgrade {} to version {})rarrfr]rbrdrrgrKÚ __bases__ÚgetrrrUÚformat) rArjÚpverÚhighestVersionÚhighestBaserkÚcurrentVersÚpverNameÚpersistVersrr r rrVHsh €þÿ üÿÿ ÿÿñ€ózVersioned.versionUpgraderM) r r%r&rJrdrcrIrFrVr r r rrKs ),rJreÚcopyregÚcopy_regrZÚpicklerÚiorr7ÚtypingrÚtwisted.pythonrrÚtwisted.python.compatrrÚstrÚ ModuleTypeÚ__annotations__Ú PicklingErrorr!rrrrr(r"ÚFunctionTyper.r,r6r2r?r=r@rLÚintrQrSrPrarKr r r rÚsB