o >h @sddlZddlZddlZddlZddlZz ddlmZmZWn ey+dZZYnwGddde Z Gdddej Z Gddde Z Gd d d e ZzddlZWneymZzGd d d e ZWYdZ[n dZ[wwGd d d e ZGdddZeZedeededS)N)Fernet MultiFernetc@seZdZdZdS)SerializerDoesNotExistz'The requested serializer was not found.N)__name__ __module__ __qualname____doc__r r z/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/channels_redis/serializers.pyr rc@sXeZdZ   dddZddZddZejd d Zejd d Z d dZ ddZ dS)BaseMessageSerializerNrcCs||_||_||dSN)random_prefix_lengthexpiry_setup_encryption)selfsymmetric_encryption_keysrrr r r __init__szBaseMessageSerializer.__init__csT|r%t|ttfr tdtdurtdfdd|D}t|_dSd_dS)Nz9symmetric_encryption_keys must be a list of possible keys(sz;BaseMessageSerializer._setup_encryption..) isinstancestrbytes ValueErrorrcrypter)rr sub_fernetsr rr rs z'BaseMessageSerializer._setup_encryptioncCs@tdurtdt|tr|d}tt| }t|S)zT Given a single encryption key, returns a Fernet instance using it. Nrutf-8) rrrrencodebase64urlsafe_b64encodehashlibsha256digest)rr formatted_keyr r r r-s  z!BaseMessageSerializer.make_fernetcOtr NotImplementedErrorrmessageargskwargsr r r as_bytes;zBaseMessageSerializer.as_bytescOr(r r)r+r r r from_bytes?r0z BaseMessageSerializer.from_bytescCsH||}|jr|j|}|jdkr"td|j|jd|}|S)z6 Serializes message to a byte string. rbig)r/rencryptrrandom getrandbitsto_bytes)rr,r r r serializeCs   zBaseMessageSerializer.serializecCsP|jdkr ||jd}|jr#|jdur|jn|jd}|j||}||S)z2 Deserializes from a byte string. rN )rrrdecryptr1)rr,ttlr r r deserializeUs  z!BaseMessageSerializer.deserialize)NrN) rrrrrrabcabstractmethodr/r1r8r<r r r r r s     r c@seZdZdZddZdS)MissingSerializerNcOs|jr ) exception)rr-r.r r r rfszMissingSerializer.__init__)rrrr@rr r r r r?cs r?c@seZdZddZeejZdS)JSONSerializercOs"tj|g|Ri|}|dS)Nr )jsondumpsr!r+r r r r/os zJSONSerializer.as_bytesN)rrrr/ staticmethodrBloadsr1r r r r rAjsrAc@seZdZeZdSMsgPackSerializerN)rrrexcr@r r r r rG{r rGc@s eZdZeejZeejZdSrF) rrrrDmsgpackpackbr/unpackbr1r r r r rGs c@s(eZdZdZddZddZddZdS) SerializersRegistryzO Serializers registry inspired by that of ``django.core.serializers``. cCs i|_dSr ) _registryrr r r rs zSerializersRegistry.__init__cCs>t|trt|tst|drt|dsJd||j|<dS)z< Register a new serializer for given format r8r<z `serializer_class` should be a class which implements `serialize` and `deserialize` method or a subclass of `channels_redis.serializers.BaseMessageSerializer` N)rtype issubclassr hasattrrM)rformatserializer_classr r r register_serializers  z'SerializersRegistry.register_serializercOs4z|j|}Wn tyt|w||i|Sr )rMKeyErrorr)rrQr-r.rRr r r get_serializers  z"SerializersRegistry.get_serializerN)rrrrrrSrUr r r r rLs  rLrBrI)r=r"r$rBr5cryptography.fernetrr ImportErrorrTrABCr r?rArIrHrGrLregistryrSr r r r s2  R "