?h@ddlmZmZmZmZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZmZmZmZmZddlmZddlmZmZmZmZddlmZmZddlGdd eZy) )print_functionunicode_literalsabsolute_importdivisionN) ensure_text ensure_binaryvalidate_channelvalidate_socket_idvalidate_user_datachannel_name_re)Client)GETPOSTRequestrequest_method)signverify)*cJeZdZ dfd ZddZddZdZxZS)AuthenticationClientc Ftt| ||||||||| | | | | f i|yN)superr__init__)selfapp_idkeysecretsslhostporttimeoutclusterencryption_master_keyencryption_master_key_base64 json_encoder json_decoderbackendbackend_options __class__s ]/var/www/html/hubwallet-dev/venv/lib/python3.12/site-packages/pusher/authentication_client.pyrzAuthenticationClient.__init__"sF" "D2         ! (     ct|}tj|std|zt |}|r!t j ||j}|d|}|r|d|zz }t|j|}|jd|}d|i}t|r:tt|d|j}tj |} | |d<|r||d<|S) aUsed to generate delegated client subscription token. :param channel: name of the channel to authorize subscription to :param socket_id: id of the socket that requires authorization :param custom_data: used on presence channels to provide user info z*Channel should be a valid channel, got: %scls:z:%sauthchannel shared_secret channel_data)r r match ValueErrorr jsondumps _json_encoderrrris_encrypted_channelgenerate_shared_secretr_encryption_master_keybase64 b64encode) rr2 socket_id custom_datastring_to_sign signaturer1response_payloadr3shared_secret_b64s r+ authenticatez!AuthenticationClient.authenticateCs#7+$$W-IGST T&y1 **[d6H6HIK$-w7  ek1 1Nn5 ((I."D>  (2gy143N3NPM & 0 0 ? 0A _ - /: ^ ,r,ct|t|}tj||j}|d|}t |j |}|jd|}||d}|S)zCreates a user authentication signature. :param socket_id: id of the socket that requires authorization :param user_data: used to provide user info r.z::user::r0)r1 user_data)r r r7r8r9rrr)rr?rGuser_data_encodedrArB auth_responserCs r+authenticate_userz&AuthenticationClient.authenticate_userish 9%&y1  JJyd6H6HI+46GHn5 #'88Y7 $1@QRr,cvt|d}t|d}t|d}||jk7ryt|j||sy t j ||j }|jd}|syttjdz|z dkDry|S#t$rYywxYw) a<Used to validate incoming webhook messages. When used it guarantees that the sender is Pusher and not someone else impersonating it. :param key: key used to sign the body :param signature: signature that was given with the body :param body: content that needs to be verified rrBbodyNr.time_msii) rrrrr7loads _json_decoderr6getabstime)rrrBrL body_datarMs r+validate_webhookz%AuthenticationClient.validate_webhook}s#u% ;7 4( $((?dkk43  4T-?-?@I -- * tyy{T!G+ ,v 5  s!B,, B87B8) TNNNNNNNNr)__name__ __module__ __qualname__rrErJrT __classcell__)r*s@r+rr!s9   "%)B$ L (r,r) __future__rrrr collectionshashlibr7osresixrRr= pusher.utilrrr r r r pusher.clientr pusher.httprrrrpusher.signaturerr pusher.cryptorr,r+rfsR  !::){6{r,