o سَ·i1م@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 refsN)عunpickleMethodع__name__ع__self__ع __class__)عmethod©r ْ^C:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-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} N)عgetattr)ZclassObjectع methodNameZmethodObjectr 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} NZMethodznot on classz'No recourse: no instance to guess from.r ) rrعAttributeErrorrعmsgrrعtypesع MethodType)Zim_nameZim_selfZim_classZmethodFunctionZ 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: ع.N)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)عnamedAnyN)Ztwisted.python.reflectr!)ZfullyQualifiedNamer!r r rrhsrcCst|jffS)z3support function for copy_reg to pickle module refsN)ع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عxN)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} N)عunpickleStringOعgetvalueعtell)Zstringor r rع pickleStringOڈs r+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. N)ع _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)) N)عunpickleStringIr)r*)Zstringir r rع pickleStringI²s r2cCst|ƒ}| |،|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. N)r,r.r/r r rr1آs r1c@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 N)r3)ع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عgcrr6)r4r7عrr r rع__getstate__هszEphemeral.__getstate__cCst d|j،t|_dS)Nz#WARNING: unserializing ephemeral %s)rrrr3©r4عstater r rع__setstate__ïs zEphemeral.__setstate__N)r rrع__doc__r5r9r<r r r rr3طs r3ع VersionedعversionedsToUpgradecCs&tt ،ƒD]}t|ƒqiaiadS©N)عlistr?عvaluesعrequireUpgradeعupgraded)Z versionedr r rع doUpgradeّs rEcCs4t|ƒ}|tvr|tvrdt|<| ،|SdSdS)z?Require that a Versioned instance be upgraded completely first.éN)عidr?rDعversionUpgrade)عobjZobjIDr r rrCs‎rCcCs@|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)r>عinspectعgetmroع issubclassعappend)عcعlعbr r rع_aybabtu s €rRc@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|ƒ<||_dSr@)r?rGع__dict__r:r r rr<3s 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.persistenceVersionN) عcopyrSrRrعreverserNrTrUrعqual)r4عdictعdctعbasesعbaseZslotr r rr97s" € ‏ے€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،} | r‌t dt |،t |j،t |ƒ|f،| |ƒn t d ||،،||ksuqDdS) z (internal) Do a version upgrade.rUrNz%s.persistenceVersionz"Sorry, can't go backwards in time.rFzupgradeToVersion%sz'Upgrading %s (of %s @ %s) to version %sz(Warning: cannot upgrade {} to version {})rRrrWrNrSrUrrXr>ع __bases__عgetrrrGعformat) r4r[ZpverZhighestVersionZhighestBaser\ZcurrentVersZpverNameZpersistVersrr r rrHHsl €‏ےے‏ üےے ےےٌ€َzVersioned.versionUpgrader@) r rrr=rUrTr<r9rHr r r rr>s ),r=rVعcopyregعcopy_regrKعpicklerعiorr,عtypingrZtwisted.pythonrrZtwisted.python.compatrrعstrع ModuleTypeع__annotations__ع PicklingErrorrrrrrr rعFunctionTyper$r"r+r(r2r1r3r?عintrDrErCrRr>r r r rعsB