We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/noah-vh/mcp-server-clickup'
If you have feedback or need assistance with the MCP directory API, please join our Discord server
�
�MMg�# � �Z � d dl mZ d dlZd dlZd dlmZmZ d dlmZ d dl m
Z
mZ d dlm
Z
mZ d dlmZmZmZmZmZ ej* egej, e f Zej* eegej, e f Z ej2 d� Z G d � d
e� Z G d� d� Z G d
� de� Zy)� )�annotationsN)�ObjectReceiveStream�ObjectSendStream)�collapse_excgroups)�ClientDisconnect�Request)�AsyncContentStream�Response)�ASGIApp�Message�Receive�Scope�Send�Tc �, � � e Zd ZdZd� fd�Zdd�Z� xZS )�_CachedRequesta
If the user calls Request.body() from their dispatch function
we cache the entire request body in memory and pass that to downstream middlewares,
but if they call Request.stream() then all we do is send an
empty body so that downstream things don't hang forever.
c �l �� t �| � ||� d| _ d| _ | j � | _ y )NF)�super�__init__�_wrapped_rcv_disconnected�_wrapped_rcv_consumed�stream�_wrapped_rc_stream)�self�scope�receive� __class__s ��eC:\Users\noahv\Documents\GitHub\clickup-operator\.venv\Lib\site-packages\starlette/middleware/base.pyr z_CachedRequest.__init__ s0 �� �
�����(�).��&�%*��"�"&�+�+�-��� c � �0 K � | j rddiS | j rQ| j rd| _ ddiS | j � � d { ��� }|d dk7 rt d|d � �� �d| _ |S t | dd � �d| _ d| j dd�S | j r
d| _ dd dd�S | j � }|j � � d { ��� }| j | _ d|| j d�S 7 ��7 �(# t $ r d| _ ddicY S w xY w�w)
N�type�http.disconnectTzUnexpected message received: �_bodyzhttp.requestF�r! �body� more_bodyr )r r �_is_disconnectedr �RuntimeError�getattrr# �_stream_consumedr � __anext__r )r �msgr �chunks r �wrapped_receivez_CachedRequest.wrapped_receive s] � �� ��)�)� �-�.�.��%�%� �$�$� 26��.�� 1�2�2� ����&�C��6�{�/�/� #�%B�3�v�;�-�#P�Q�Q�-1�D�*��J� �4��$�'�3�)-�D�&�&��
�
�"��
�
�
"�
"� *.�D�&�&��"��
�
3������$�.�.�0�0��-1�-B�-B��*�*�!�%)�%:�%:�!:�� �C '��>