o aqe@sddlZddlZddlmZddlmZmZmZmZddl Z ddl m Z m Z ddl m Z ddlmZmZmZddlmZd d lmZd d lmZd d lmZGd ddZdS)N) SSLContext)DictUnionListOptional) BasicAuth ClientSession) SlackApiError)_debug_log_response_build_request_headers _build_body)WebhookResponse)get_user_agent) Attachment)Blockc@sHeZdZeeZ         ddededee deedee d e d ee d ee eefd eed eefddZdddddddeedeeee eefefdeeee eefefdeedee eefdef ddZ dde eefdee eefdefddZde eefde eefdefddZdS) AsyncWebhookClientNFurltimeoutsslproxysessiontrust_env_in_sessionauthdefault_headersuser_agent_prefixuser_agent_suffixc CsL||_||_||_||_||_||_||_|r|ni|_t| | |jd<dS)aAPI client for Incoming Webhooks and response_url :param url: a complete URL to send data (e.g., https://hooks.slack.com/XXX) :param timeout: request timeout (in seconds) :param ssl: ssl.SSLContext to use for requests :param proxy: proxy URL (e.g., localhost:9000, http://localhost:9000) :param session: a complete aiohttp.ClientSession :param trust_env_in_session: True/False for aiohttp.ClientSession :param auth: Basic auth info for aiohttp.ClientSession :param default_headers: request headers to add to all requests :param user_agent_prefix: prefix for User-Agent header value :param user_agent_suffix: suffix for User-Agent header value z User-AgentN) rrrrrrrrr) selfrrrrrrrrrrr [/var/www/html/humari/django-venv/lib/python3.10/site-packages/slack/webhook/async_client.py__init__szAsyncWebhookClient.__init__)text attachmentsblocks response_typeheadersr#r$r%r&r'returncs |j||||d|dIdHS)aPerforms a Slack API request and returns the result. :param text: the text message (even when having blocks, setting this as well is recommended as it works as fallback) :param attachments: a collection of attachments :param blocks: a collection of Block Kit UI components :param response_type: the type of message (either 'in_channel' or 'ephemeral') :param headers: request headers to append only for this request :return: API response )r#r$r%r&bodyr'N) send_dict)rr#r$r%r&r'r r r!send9s zAsyncWebhookClient.sendr*cs"|jt|t|j|dIdHS)a<Performs a Slack API request and returns the result. :param body: json data structure (it's still a dict at this point), if you give this argument, body_params and files will be skipped :param headers: request headers to append only for this request :return: API response r)N)_perform_http_requestr r r)rr*r'r r r!r+Ts    zAsyncWebhookClient.send_dictc st|}d|d<|jjtjkr!|jd|jd|d|d}|jo*|jj }|r1|j}nt j t j |j d|j|jd}z|||j|jd }|jd |jfi|4IdHc}i}z |IdH}Wn.t jyz|jd |jd Yntjjy}z d t|} t| |d}~wwt|j|j||jd} t|j| | WdIdHW|s|IdHSS1IdHswYW|s|IdHdSdS|s|IdHww)a Performs an HTTP request and parses the response. :param url: a complete URL to send data (e.g., https://hooks.slack.com/XXX) :param body: request body data :param headers: complete set of request headers :return: API response zapplication/json;charset=utf-8z Content-TypezSending a request - url: z, body: z , headers: N)total)rr trust_env)r'datarrPOSTz7No response data returned from the following API call: .z#Failed to parse the response body: )r status_coder*r')jsondumpsloggerlevelloggingDEBUGdebugrrclosedaiohttpr ClientTimeoutrrrrrrequestr#ContentTypeError_loggerdecoderJSONDecodeErrorstrr rstatusr'r close) rr*r'ruse_running_sessionrequest_kwargsres response_bodyemessagerespr r r!r-bsj      z(AsyncWebhookClient._perform_http_request) rNNNFNNNN)N)__name__ __module__ __qualname__r8 getLoggerr6rCintrrrboolrrr"rranyrrrr,r+r-r r r r!rs    (     r)r4r8rrtypingrrrrr<rr slack.errorsr internal_utilsr r r webhook_responserwebrweb.classes.attachmentsrweb.classes.blocksrrr r r r!s