endpoints.cpython-312.pyc•7.85 kB
�
�MMg� � � � d dl mZ d dlZd dlZd dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
d dlmZmZ d d lmZmZmZmZ d d
lmZ G d � d � Z G d
� d� Zy)� )� annotationsN)�status)�is_async_callable)�run_in_threadpool)�
HTTPException)�Request)�PlainTextResponse�Response)�Message�Receive�Scope�Send)� WebSocketc �, � e Zd Zdd�Zdd�Zdd�Zd d�Zy)
� HTTPEndpointc � � |d dk( sJ �|| _ || _ || _ dD �cg c] }t | |j � d � �|��! c}| _ y c c}w )N�type�http)�GET�HEAD�POST�PUT�PATCH�DELETE�OPTIONS)�scope�receive�send�getattr�lower�_allowed_methods)�selfr r r �methods �_C:\Users\noahv\Documents\GitHub\clickup-operator\.venv\Lib\site-packages\starlette/endpoints.py�__init__zHTTPEndpoint.__init__ sf � ��V�}��&�&�&���
� �� ��� � W�!
�V���t�V�\�\�^�T�2�>�
�V�!
�� �� !
s �$Ac �> � | j � j � S �N��dispatch� __await__�r" s r$ r* zHTTPEndpoint.__await__ � � ��}�}��(�(�*�*� c � � K � t | j | j �� }|j dk( rt | d� sdn|j j � }t
| || j � }t |� }|r ||� � d { ��� }nt ||� � d { ��� } || j | j | j � � d { ��� y 7 �J7 �77 � �w)N)r r �head�get) r r r r# �hasattrr r �method_not_allowedr r r )r" �request� handler_name�handler�is_async�responses r$ r) zHTTPEndpoint.dispatch s� � �� ��$�*�*�d�l�l�;�� '���&� 8���v�AV�u�\c�\j�\j�\p�\p�\r� �:A�$� �VZ�Vm�Vm�:n��$�W�-�� � $�W� -�-�H� .�w�� @�@�H��t�z�z�4�<�<����;�;�;� .��@��;�s6 �BC�
C� C� C� /C�C�C�C�Cc � � K � ddj | j � i}d| j v r
t d|�� �t dd|�� S �w)N�Allowz, �appi� )� status_code�headerszMethod Not Allowed)�joinr! r r r )r" r3 r< s r$ r2 z HTTPEndpoint.method_not_allowed+ sK � �� � �D�I�I�d�&;�&;� <�=�� �D�J�J� � �C��A� A� �!5�3�PW�X�X�s �AA N�r r
r r r r �return�None�r? z(typing.Generator[typing.Any, None, None]�r? r@ )r3 r r? r
)�__name__�
__module__� __qualname__r% r* r) r2 � r- r$ r r s � �
�+�
<�Yr- r c �T � e Zd ZU dZded< d d�Zd d�Zd
d�Zdd�Zdd�Z dd �Z
dd
�Z y)�WebSocketEndpointNz
str | None�encodingc �B � |d dk( sJ �|| _ || _ || _ y )Nr � websocket)r r r )r" r r r s r$ r% zWebSocketEndpoint.__init__8 s) � ��V�}� �+�+�+���
� �� ��� r- c �> � | j � j � S r' r( r+ s r$ r* zWebSocketEndpoint.__await__> r, r- c � � K � t | j | j | j �� }| j |� � d { ��� t
j } |j � � d { ��� }|d dk( r5| j ||� � d { ��� }| j ||� � d { ��� n5|d dk( r-t |j d� xs t
j � }n�� | j ||� � d { ��� y 7 ��7 ��7 �u7 �]# t $ r}t
j }|�d }~ww xY w7 �0# | j ||� � d { ���7 w xY w�w)N)r r r zwebsocket.receivezwebsocket.disconnect�code)r r r r �
on_connectr �WS_1000_NORMAL_CLOSURE�decode�
on_receive�intr0 � Exception�WS_1011_INTERNAL_ERROR�
on_disconnect)r" rK �
close_code�message�data�excs r$ r) zWebSocketEndpoint.dispatchA s* � �� � �d�j�j�$�,�,�T�Y�Y�O� ��o�o�i�(�(�(��2�2�
�
<�� )� 1� 1� 3�3���6�?�&9�9�!%���Y��!@�@�D� �/�/�)�T�:�:�:� �V�_�(>�>�!$�W�[�[��%8�%Y�F�<Y�<Y�!Z�J�� � �
�$�$�Y�
�;� ;� ;�# )�� 4��@��:�� � � �6�6�J��I�� ��
<��$�$�$�Y�
�;� ;� ;�s� �AE�D�E�D �-D�.!D �D�D �)D�*;D �&E�;D,�<E�D �D �D � D)�D$�$D)�)D. �,E�.E �E�E � Ec � �� K � | j dk( r<d|vr3|j t j �� � d { ��� t d� �|d S | j dk( r<d|vr3|j t j �� � d { ��� t d� �|d S | j dk( rA|j d� �|d }n|d j
d� } t j |� S | j �J d | j � �� �|j d� r|d S |d S 7 ��7 ��# t j j $ r5 |j t j �� � d { ���7 t d� �w xY w�w)
N�text)rN z/Expected text websocket messages, but got bytes�bytesz/Expected bytes websocket messages, but got text�jsonzutf-8z Malformed JSON data received.z!Unsupported 'encoding' attribute ) rI �closer �WS_1003_UNSUPPORTED_DATA� RuntimeErrorr0 rQ r^ �loads�decoder�JSONDecodeError)r" rK rX r\ s r$ rQ zWebSocketEndpoint.decodeV sn � �� � �=�=�F� "��W�$� �o�o�6�+J�+J�o�K�K�K�"�#T�U�U��6�?� "�
�]�]�g�
%��g�%� �o�o�6�+J�+J�o�K�K�K�"�#T�U�U��7�#� #�
�]�]�f�
$��{�{�6�"�.� �v��� �w�'�.�.�w�7��
D��z�z�$�'�'�
�}�}�$�Y�(I�$�-�-� �&Y�Y�$�")�+�+�f�"5�w�v��K�7�7�;K�K�/ L�� L�� �<�<�/�/�
D� �o�o�6�+J�+J�o�K�K�K�"�#B�C�C�
D�sH �7E=�D$�A
E=�D&�AE=�D( �(=E=�&E=�(A E:�(E+�)E:�:E=c � �@ K � |j � � d{ ��� y7 ��w)z3Override to handle an incoming websocket connectionN)�accept)r" rK s r$ rO z WebSocketEndpoint.on_connectr s � �� �� � � � � �s � � � c � � K � y�w)z0Override to handle an incoming websocket messageNrF )r" rK rY s r$ rR z WebSocketEndpoint.on_receivev � � �� �� �c � � K � y�w)z,Override to handle a disconnecting websocketNrF )r" rK rW s r$ rV z WebSocketEndpoint.on_disconnecty rh ri r> rA rB )rK r rX r r? �
typing.Any)rK r r? r@ )rK r rY rk r? r@ )rK r rW rS r? r@ ) rC rD rE rI �__annotations__r% r* r) rQ rO rR rV rF r- r$ rH rH 5 s0 � � �H�j� �� +�<�*L�8!�?�;r- rH )�
__future__r r^ �typing� starletter �starlette._utilsr �starlette.concurrencyr �starlette.exceptionsr �starlette.requestsr �starlette.responsesr r
�starlette.typesr r r
r �starlette.websocketsr r rH rF r- r$ �<module>rw sB �� "� �
� � .� 3� .� &� ;� 9� 9� *�"Y� "Y�JE;� E;r-