G/jatddlZddlZddlZddlZddlZddlZddlmZddlm Z m Z m Z  ddl m Z ddlZddlZddlZddlmZddlmZddlmZddlmZdd lmZmZdd lmZGd d eZGd deZ Gdde!Z"GddZ# d"de e$e e e$e%fe e$e e$e%ffffde de$fde dee$fde de e$e e$e&fffde$de'de de(fde&de'de de e$e e$e&e(fffde dejRfde e$ej:ffdZ* d"de e$e e e$e%fe e$e e$e%ffffde de$fde dee$fde de e$e e$e&fffde$de'de de(fde&de'de de e$e e$e&e(fffd e dejVfde e$ejXffd!Z-y#e $r ddlm Z YwxYw)#N)deepcopy)castUnionDict)urlparse)default_backend)ec) serialization)partial)VapidVapid01)Responsec&eZdZdZdddZdefdZy)WebPushExceptionzCWeb Push failure. This may contain the requests.Response Nreturnc ||_||_yN)messageresponse)selfrrs P/var/www/html/maxservice/venv/lib/python3.12/site-packages/pywebpush/__init__.py__init__zWebPushException.__init__%s   cd}|j& dj|jj}d|j|S#t$rd|j}Y+wxYw)Nz , Response {}z , Response zWebPushException: )rformattextAttributeErrorr)rextras r__str__zWebPushException.__str__)sk == $ 6'..MM&& $DLL>%99" 6%dmm_5 6s%AA! A!rrN)__name__ __module__ __qualname____doc__rstrr rrrrs ! : :rrceZdZdZy)NoDataz0Message contained No Data, no encoding required.N)r"r#r$r%r'rrr)r)5s:rr)cJeZdZdZifd dZdefdZdZdZdZ d d Z d d Z y) CaseInsensitiveDictz+A dictionary that has case-insensitive keysrNc |D]*}tj||j||,|j|yr)dict __setitem__lowerupdate)rdatakwargskeys rrzCaseInsensitiveDict.__init__<s9 ;C   T399;S : ; FrcJtj||jSr)r- __contains__r/rr3s rr5z CaseInsensitiveDict.__contains__As  syy{33rcNtj||j|yr)r-r.r/)rr3values rr.zCaseInsensitiveDict.__setitem__Ds syy{E2rcJtj||jSr)r- __getitem__r/r6s rr:zCaseInsensitiveDict.__getitem__Gsciik22rcLtj||jyr)r- __delitem__r/r6s rr<zCaseInsensitiveDict.__delitem__Js syy{+rcH |j|S#t$r|cYSwxYwr)r:KeyError)rr3defaults rgetzCaseInsensitiveDict.getMs, ##C( ( N s  !!c<|D]}|j|||yr)r.)rr1r3s rr0zCaseInsensitiveDict.updateSs% -C   S$s) , -rr!r) r"r#r$r%rboolr5r.r:r<r@r0r'rrr+r+9s25 44433, -rr+c eZdZdZiZddgZdZ ddeee e ee feee ee ffffde de jfde de jjfd ed df d Zd ed dfd Zde d e fdZ dde ded efdZdede deeefd efdZ dde de fde deeeffdeded ef dZd e eeffdZd e e j8effdZy) WebPushera=WebPusher encrypts a data block using HTTP Encrypted Content Encoding for WebPush. See https://tools.ietf.org/html/draft-ietf-webpush-protocol-04 for the current specification, and https://developer.mozilla.org/en-US/docs/Web/API/Push_API for an overview of Web Push. Example of use: The javascript promise handler for PushManager.subscribe() receives a subscription_info object. subscription_info.getJSON() will return a JSON representation. (e.g. .. code-block:: javascript subscription_info.getJSON() == {"endpoint": "https://push.server.com/...", "keys":{"auth": "...", "p256dh": "..."} } ) This subscription_info block can be stored. To send a subscription update: .. code-block:: python # Optional # headers = py_vapid.sign({"aud": "https://push.server.com/", "sub": "mailto:your_admin@your.site.com"}) data = "Mary had a little lamb, with a nice mint jelly" WebPusher(subscription_info).send(data, headers) aesgcm aes128gcmFNsubscription_inforequests_sessionaiohttp_sessionverboserc ||_| t|_n||_||_d|vr t dt ||_dx|_|_d|vr7ttttttff|j d}dD]c}|j|t d|t||ts6ttt||j!d||<et#j$|j'tt|d}t)|d k7r|d d k7r t d ||_t#j$|j'tt|d |_yy)a-Initialize using the info provided by the client PushSubscription object (See https://developer.mozilla.org/en-US/docs/Web/API/PushManager/subscribe) :param subscription_info: a dict containing the subscription_info from the client. :type subscription_info: dict :param requests_session: a requests.Session object to optimize requests to the same client. :type requests_session: requests.Session :param verbose: provide verbose feedback :type verbose: bool Nendpointz&subscription_info missing endpoint URLkeys)p256dhauthzMissing keys value: utf8rNArzInvalid p256dh key specifiedrO)rJrequestsrequests_methodrIrrrGauth_key receiver_keyrrr&rbytesr@ isinstanceencodebase64urlsafe_b64decode_repadlen)rrGrHrIrJrMk receiver_raws rrzWebPusher.__init__s|4  ##+D #3D . . ."#KL L!)*;!<,00 ) & &15S%U ++,d.D.DV.L2D( G88A;&*-A!+EFFd1gs+#Dd1g$6$=$=f$EFDG  G "33 DX78L< B&<?f+D&'EFF ,D "44 DV 56DM 'rmsgch|jr&tj|j|i|yyr)rJlogginginfor)rr`argsr2s rverbzWebPusher.verbs* << LLT4V4 5 rr1c*|ddt|dzzS)z6Add base64 padding to the end of a string, if requireds====N)r])rr1s rr\zWebPusher._repadsgoD A ...rcontent_encodingc t}|s|jdt|jr |js t d|jdd}||j vr+t dtj|j z|dk(r>|jdtjd}tjd |tjtjt!}|j#j%t&j(j*t&j,j. }t1|t2rt5|j7d }|d k(rG|jd t9j:||||j|j|}||d<|S|jdt=j>|jAd}t9j:||||jC|j|j|}||d<||d<|r't=j>|jAd|d<|S)aEncrypt the data. :param data: A serialized block of byte data (String, JSON, bit array, etc.) Make sure that whatever you send, your client knows how to understand it. :type data: str :param content_encoding: The content_encoding type to use to encrypt the data. Defaults to RFC8188 "aes128gcm". The previous draft-01 is "aesgcm", however this format is now deprecated. :type content_encoding: enum("aesgcm", "aes128gcm") zNo data found...z&No keys specified in subscription infozEncoding data...Nz0Invalid content encoding specified. Select from rEzGenerating salt for aesgcm...zSalt: )encodingrrPrFzEncrypting to aes128gcm...)salt private_keydh auth_secretversionbodyzEncrypting to aesgcm...=)rlrmkeyidrnrorp crypto_keyrl)"r+rer)rUrVrvalid_encodingsjsondumpsosurandomrbdebugr generate_private_key SECP256R1r public_key public_bytesr EncodingX962 PublicFormatUncompressedPointrXr&rWrYhttp_eceencryptrZurlsafe_b64encodestripdecode)rr1rhreplyrl server_keyrt encrypteds rrYzWebPusher.encodes'$% II( )(N}}D$5$5"#KL L $% 4#7#7 7"!%D,@,@!AB  x ' II5 6::b>D MMF4&/ *,,R\\^_=NO **,99"++00 --??: dC V,-D { * II2 3 ((&$$ MM( I&E&M"  II/ 011*=CCDIJ ((& '')$$ MM(I#-E, %E&M & 8 8 > D DT Jf  rrL encoded_dataheadersc |jDcgc]\}}d|jd|d}}}d}|r(tdd5}|j|dddd}d |vr/|j d |j d t |dd j|dj|| Scc}}w#1swYgxYw)aReturn the send as a curl command. Useful for debugging. This will write out the encoded data to a local file named `encrypted.data` :param endpoint: Push service endpoint URL :type endpoint: basestring :param encoded_data: byte array of encoded data :type encoded_data: bytearray :param headers: Additional headers for the send :type headers: dict :returns string z-H "z: z" \ rzencrypted.datawbNz--data-binary @encrypted.datazcontent-lengthz#Generating content-length header...z-H "content-length: z%curl -vX POST {url} \ {headers}{data})urlrr1) itemsr/openwritereappendr]rjoin) rrLrrr3val header_listr1fs ras_curlzWebPusher.as_curl s @G}} 3;3d399;-r#g .   &- & % &2D 7 * II; <   &s<'8&9A =CC"''+"6TD    & &s!B:CC ttlcD| t}t}t|}|r|j||}d|vrF|jdd}|r|dz }|d|dj dzz }|j d|id|vr(|j dd |dj dzi|j d |i|jd }|j d }d |vs|r#|jdt|xsd|d <|jd||||||dS)aXEncode and send the data to the Push Service. :param data: A serialized block of data (see encode() ). :type data: str :param headers: A dictionary containing any additional HTTP headers. :type headers: dict :param ttl: The Time To Live in seconds for this message if the recipient is not online. (Defaults to "0", which discards the message immediately if the recipient is unavailable.) :type ttl: int :param content_encoding: ECE content encoding (defaults to "aes128gcm") :type content_encoding: str rtz crypto-keyr;zdh=rPrl encryptionzsalt=zcontent-encodingrqrLrzGenerating TTL of 0...rz4 Sending request to host: {} headers: {} data: {})rLr1r) r-r+rYr@rr0rGrer&) rr1rrrhencodedrtrrLs r_prepare_send_datazWebPusher._prepare_send_data-sB* ?fG%'%g. kk$(89Gw&$[[r:  #%Jegl&;&B&B6&JJJ  j9:  g8N8Nv8V.VWX NN&(8  {{6* ))*5  3 II. / ]GEN L     %lwOOrc|jdd}|jdd}|j|i|}|jd}|r|d}|d}|j|||S|jj|fd|i|} |j d | j | jxsd | jxsd | S) z,Encode and send the data to the Push Servicetimeout'curlFrLr1rrrz+ Response: code: {} body: {} headers: {}EmptyNone) poprrrTpostre status_coderr) rrdr2rrparamsrLrrresps rsendzWebPusher.sendls**Y.zz&%(((($9&9::j) !&>LY'G<<|W<U U(t##((     @    II  LL "F   rcK|jdd}|jdd}|j|i|}|jd}|r|d}|d}|j|||S|jr@|jj|fd|i|d{} | j d{} nbt j4d{} | j|fd|i|d{} | j d{} dddd{|jd  j xsd | S777p7U7?71#1d{7swYAxYww) NrrrFrLr1rrz Response: code: {} body: {} r) rrrrIrraiohttp ClientSessionrestatus) rrdr2rrrrLrrr resp_textsessions r send_asynczWebPusher.send_asyncsU**Y.zz&%(((($9&9::j) !&>LY'G<<|W<U U   2--228WWWPVWWD"iik)I,,. . .')W\\(NGNvNN"&))+-  . . 3 KK    X) .N- . . . .sBED;E0D=1ED?EE+E,EEE EE(E=E?EEEEE E EE)NNF)rF)NNrrF)r"r#r$r%rGrurJrr&rrWrSSessionrclientrrBrrer\r+rYrintr-rrrClientResponserr'rrrDrDXs D O G;?EI7 uS%Z($sE#u*4E/E*FFG G 7  h&6&6 67 7 tW^^%A%AAB 77 7r666/5/U/ 4?FF-0F FP  5 4S> VY D$(/3 + =PD%K =PtT#s(^+,=P =P  =P  =P~uXs]';459O9OQT9T3UrrDrGr1vapid_private_key vapid_claimsrhrrrrJrrHrc | t} n| j} d} |r|rtjd|j dsHt t t|j d} | jd| j} | |d<|j dr.>u.E.J*Kc IIKO + #&diik"2l"CL  ;BB(+ 2 9 9$$hoox}}    OrrIc K| t} n| j} d} |r|rtjd|j dsHt t t|j d} | jd| j} | |d<|j dr.>u.E.J*Kc IIKO + #&diik"2l"CL  3::<;NO!"#EF F ' 1 KL"B WW^^- . ;rs9  $$&!888#:y:.;Y;-$->EEX "15<@'"&>B6: U5e$d3c5j0A+A&BB CC c   T5#-.  d3c3h#7889  4;  4c5c5#99:: ;D("2"223 3!! !"L"15<@'"&>B:>I U5e$d3c5j0A+A&BB CCI c  I T5#-. I d3c3h#7889 II I4; I II4c5c5#99:: ;I4!6!667I 3&& &'Ie&%%&sF(( F76F7