U P|j1ã@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 úzCannot 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)Ztwisted.python.reflectr")ZfullyQualifiedNamer"r r rrhsrcCst|jffS)z3support function for copy_reg to pickle module refs)ÚunpickleModuler )Úmoduler r rÚpickleModule~sr%cCs6|tkr(t 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#cCst| ¡| ¡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)Zstringor r rÚ pickleStringOsr,cCstƒ}| |¡| |¡|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©ÚvalZsekr&r r rr)s r)cCst| ¡| ¡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)) )ÚunpickleStringIr*r+)Zstringir r rÚ pickleStringI²s r3cCst|ƒ}| |¡|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. )r-r/r0r r rr2Âs r2c@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 )r4)Úselfr r rÚ __reduce__ÞszEphemeral.__reduce__cCsJt d|¡tsFddl}t|ddƒrF| |¡D]}t d|›¡q0dS)Nz!WARNING: serializing ephemeral %srÚ get_referrersz referred to by )rrrÚgcrr7)r5r8Úrr r rÚ__getstate__åszEphemeral.__getstate__cCst d|j¡t|_dS)Nz#WARNING: unserializing ephemeral %s)rrrr4©r5Ústater r rÚ__setstate__ïszEphemeral.__setstate__N)r rrÚ__doc__r6r:r=r r r rr4Øs r4Ú VersionedÚversionedsToUpgradecCs&tt ¡ƒD]}t|ƒqiaiadS©N)Úlistr@ÚvaluesÚrequireUpgradeÚupgraded)Z versionedr r rÚ doUpgradeøs rFcCs0t|ƒ}|tkr,|tkr,dt|<| ¡|SdS)z?Require that a Versioned instance be upgraded completely first.éN)Úidr@rEÚversionUpgrade)ÚobjZobjIDr r rrDs rDcCs@|tg}t |¡D] }||krt|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)r?ÚinspectÚgetmroÚ issubclassÚappend)ÚcÚlÚbr r rÚ_aybabtu s rSc@s2eZdZdZdZdZdd„Zddd„Zd d „ZdS)r?a² 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|ƒ<||_dSrA)r@rHÚ__dict__r;r r rr=3szVersioned.__setstate__NcCs€t |p|j¡}t|jƒ}| ¡| |j¡|D]H}d|jkrZ|jD]}||krF||=qFd|jkr2|j|t |¡›d<q2|S)z8Get state, adding a version number to it on its way out.ÚpersistenceForgetsÚpersistenceVersionz.persistenceVersion) ÚcopyrTrSrÚreverserOrUrVrÚqual)r5ÚdictÚdctÚbasesÚbaseZslotr r rr:7s þÿzVersioned.__getstate__c CsVt|jƒ}| ¡| |j¡d|jkr„|jd}|jd=d}d}|D]$}d|jkrVqF|j|krF|}|j}qF|r„||jdt |¡<|D]È}t|j kr¢d|jkr¢qˆ|j}dt |¡}|j |¡pÄd}|rÒ|j|=||ksâtdƒ‚||krˆ|d}|j d|d¡} | rrVrUr=r:rIr r r rr?s ),r>rWÚcopyregÚcopy_regrLÚpicklerÚiorr-ÚtypingrZtwisted.pythonrrZtwisted.python.compatrrÚstrÚ ModuleTypeÚ__annotations__Ú PicklingErrorrrrrrr!rÚFunctionTyper%r#r,r)r3r2r4r@ÚintrErFrDrSr?r r r rÚs@