o
    Ѱi2                     @  s  d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm	Z	 ddl
mZmZmZmZ ddlmZ ddlmZmZmZmZmZ dd	lmZmZ dd
lmZmZ er`ddl
mZmZ ddlmZ G dd dZ e  Z!e!j"Z"e!j#Z#e!j$Z$e!j%Z%e!j&Z&e!j'Z'e!j(Z(dS )    )annotationsN)Sequence)TYPE_CHECKINGAny   )	Algorithmget_default_algorithms
has_cryptorequires_cryptography)PyJWK)DecodeErrorInvalidAlgorithmErrorInvalidKeyErrorInvalidSignatureErrorInvalidTokenError)base64url_decodebase64url_encode)InsecureKeyLengthWarningRemovedInPyjwt3Warning)AllowedPrivateKeysAllowedPublicKeys)
SigOptionsc                   @  s   e Zd ZdZ		dJdKd	d
ZedLddZdMddZdNddZdOddZ	dPddZ
					dQdRd,d-Z	.			dSdTd6d7Z	.			dSdUd9d:ZdVd;d<ZdWd>d?Z	.	dXdYdCdDZdZdEdFZd[dHdIZdS )\PyJWSJWTN
algorithmsSequence[str] | NoneoptionsSigOptions | NonereturnNonec                 C  st   t  | _|d urt|nt| j| _t| j D ]}|| jvr$| j|= q|  | _|d ur8i | j|| _d S d S )N)r   _algorithmsset_valid_algslistkeys_get_default_optionsr   )selfr   r   key r(   ?/home/ubuntu/.local/lib/python3.10/site-packages/jwt/api_jws.py__init__"   s   

zPyJWS.__init__r   c                   C  s
   dddS )NTF)verify_signatureenforce_minimum_key_lengthr(   r(   r(   r(   r)   r%   5   s   
zPyJWS._get_default_optionsalg_idstralg_objr   c                 C  s>   || j v r	tdt|tstd|| j |< | j| dS )z
        Registers a new Algorithm for use when creating and verifying tokens.

        :param str alg_id: the ID of the Algorithm
        :param alg_obj: the Algorithm object
        :type alg_obj: Algorithm
        z Algorithm already has a handler.z!Object is not of type `Algorithm`N)r    
ValueError
isinstancer   	TypeErrorr"   add)r&   r-   r/   r(   r(   r)   register_algorithm9   s   


zPyJWS.register_algorithmc                 C  s*   || j vr	td| j |= | j| dS )z
        Unregisters an Algorithm for use when creating and verifying tokens
        :param str alg_id: the ID of the Algorithm
        :raises KeyError: if algorithm is not registered.
        zJThe specified algorithm could not be removed because it is not registered.N)r    KeyErrorr"   remove)r&   r-   r(   r(   r)   unregister_algorithmJ   s   
zPyJWS.unregister_algorithm	list[str]c                 C  s
   t | jS )zh
        Returns a list of supported values for the `alg` parameter.

        :rtype: list[str]
        )r#   r"   )r&   r(   r(   r)   get_algorithmsY   s   
zPyJWS.get_algorithmsalg_namec              
   C  sN   z| j | W S  ty& } zts|tv rtd| d|td|d}~ww )a/  
        For a given string name, return the matching Algorithm object.

        Example usage:
        >>> jws_obj = PyJWS()
        >>> jws_obj.get_algorithm_by_name("RS256")

        :param alg_name: The name of the algorithm to retrieve
        :type alg_name: str
        :rtype: Algorithm
        zAlgorithm 'z9' could not be found. Do you have cryptography installed?Algorithm not supportedN)r    r5   r	   r
   NotImplementedError)r&   r:   er(   r(   r)   get_algorithm_by_namea   s   

zPyJWS.get_algorithm_by_nameHS256FTpayloadbytesr'   (AllowedPrivateKeys | PyJWK | str | bytes	algorithm
str | Noneheadersdict[str, Any] | Nonejson_encodertype[json.JSONEncoder] | Noneis_payload_detachedboolsort_headersc                 C  s  g }|d u rt |tr|j}	nd}	n|}	|r,|d}
|
r!|d }	|d}|du r,d}| j|	d}|r>| | || |d sE|d= |rLd|d< nd|v rS|d= tj|d||d		 }|
t| |rj|}nt|}|
| d
|}| |	}t |tr|j}||}||}|r| jddrt|tj|tdd |||}|
t| |rd|d< d
|}|dS )Nnonealgb64FT)typrM   rO   ),:)
separatorscls	sort_keys   .r,      
stacklevel    r   utf-8)r1   r   algorithm_nameget
header_typ_validate_headersupdatejsondumpsencodeappendr   joinr>   r'   prepare_keycheck_key_lengthr   r   warningswarnr   signdecode)r&   r@   r'   rC   rE   rG   rI   rK   segments
algorithm_headers_algheaders_b64headerjson_headermsg_payloadsigning_inputr/   key_length_msg	signatureencoded_stringr(   r(   r)   rb   v   sb   














zPyJWS.encode jwtstr | bytes'AllowedPublicKeys | PyJWK | str | bytesdetached_payloadbytes | Nonekwargsdict[str, Any]c                 K  s   |rt jdt|  tdd |d u r| j}ni | j|}|d }|r1|s1t|ts1td| 	|\}	}
}}|
dddu rY|d u rJtd	|}	d
|
d
dd |	g}
|rd| |
|||| |	||dS )Nzypassing additional kwargs to decode_complete() is deprecated and will be removed in pyjwt version 3. Unsupported kwargs: rV   rW   r+   z\It is required that you pass in a value for the "algorithms" argument when calling decode().rN   TFzIt is required that you pass in a value for the "detached_payload" argument to decode a message having the b64 header set to false.rU   r   r   )r@   ro   rt   )rg   rh   tupler$   r   r   r1   r   r   _loadr\   rd   rsplit_verify_signature)r&   rw   r'   r   r   rz   r|   merged_optionsr+   r@   rr   ro   rt   r(   r(   r)   decode_complete   s<   	
zPyJWS.decode_completer   c                 K  s>   |rt jdt|  tdd | j|||||d}|d S )Nzppassing additional kwargs to decode() is deprecated and will be removed in pyjwt version 3. Unsupported kwargs: rV   rW   )rz   r@   )rg   rh   r~   r$   r   r   )r&   rw   r'   r   r   rz   r|   decodedr(   r(   r)   rj      s   	

zPyJWS.decodec                 C  s   |  |d }| | |S )zReturns back the JWT header parameters as a `dict`

        Note: The signature is not verified so the header parameters
        should not be fully trusted until signature verification is complete
        rV   )r   r^   )r&   rw   rE   r(   r(   r)   get_unverified_header  s   
zPyJWS.get_unverified_header*tuple[bytes, bytes, dict[str, Any], bytes]c              
   C  sl  t |tr
|d}t |tstdt z|dd\}}|dd\}}W n ty9 } ztd|d }~ww zt|}W n t	t
jfyT } ztd|d }~ww zt|}W n typ }	 ztd|	 |	d }	~	ww t |tsztdzt|}
W n t	t
jfy } ztd	|d }~ww zt|}W n t	t
jfy } ztd
|d }~ww |
|||fS )NrZ   z$Invalid token type. Token must be a rU   r   zNot enough segmentszInvalid header paddingzInvalid header string: z,Invalid header string: must be a json objectzInvalid payload paddingzInvalid crypto padding)r1   r.   rb   rA   r   r   splitr0   r   r2   binasciiErrorr`   loadsdict)r&   rw   rr   crypto_segmentheader_segmentpayload_segmenterrheader_dataro   r=   r@   rt   r(   r(   r)   r     sL   







zPyJWS._loadrr   ro   rt   c              
   C  s   |d u rt |tr|jg}z|d }W n ty   tdd w |r*|d ur.||vr.tdt |tr:|j}|j}nz| |}W n tyR }	 ztd|	d }	~	ww |	|}|
|}
|
rr| jddrjt|
tj|
tdd ||||s}td	d S )
NrM   zAlgorithm not specifiedz&The specified alg value is not allowedr;   r,   F   rW   zSignature verification failed)r1   r   r[   r5   r   r   r'   r>   r<   re   rf   r   r\   r   rg   rh   r   verifyr   )r&   rr   ro   rt   r'   r   rM   r/   prepared_keyr=   rs   r(   r(   r)   r   C  s6   




zPyJWS._verify_signaturec                 C  s   d|v r|  |d  d S d S )Nkid)_validate_kid)r&   rE   r(   r(   r)   r^   i  s   zPyJWS._validate_headersr   c                 C  s   t |ts	tdd S )Nz(Key ID header parameter must be a string)r1   r.   r   )r&   r   r(   r(   r)   r   m  s   
zPyJWS._validate_kid)NN)r   r   r   r   r   r   )r   r   )r-   r.   r/   r   r   r   )r-   r.   r   r   )r   r8   )r:   r.   r   r   )r?   NNFT)r@   rA   r'   rB   rC   rD   rE   rF   rG   rH   rI   rJ   rK   rJ   r   r.   )rv   NNN)rw   rx   r'   ry   r   r   r   r   rz   r{   r|   r}   r   r}   )rw   rx   r'   ry   r   r   r   r   rz   r{   r|   r}   r   r   )rw   rx   r   r}   )rw   rx   r   r   )rv   N)rr   rA   ro   r}   rt   rA   r'   ry   r   r   r   r   )rE   r}   r   r   )r   r   r   r   )__name__
__module____qualname__r]   r*   staticmethodr%   r4   r7   r9   r>   rb   r   rj   r   r   r   r^   r   r(   r(   r(   r)   r      sD    



X4

+
&r   ))
__future__r   r   r`   rg   collections.abcr   typingr   r   r   r   r   r	   r
   api_jwkr   
exceptionsr   r   r   r   r   utilsr   r   r   r   r   r   typesr   r   _jws_global_objrb   r   rj   r4   r7   r>   r   r(   r(   r(   r)   <module>   s2      U
