TCjH^dZddlmZmZmZmZddlmZmZm Z ddl m Z m Z ddlm Z mZmZmZddlmZmZddlmZmZddlmZd d lZd d lmZmZmZmZmZmZm Z m!Z!m"Z"Gd d e Z#GddZ$GddZ%Gdde Z&GddZ'GddZ(d S)zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.)errorsmodelstypesutils)AfterParseErrorContext HookContextResponseContext) AsyncBaseSDKBaseSDK) BaseModelOptionalNullableUNSET interactions)get_security_from_envresponse_helpers) AsyncStreamStream)unmarshal_json_responseN) AnyDictListLiteralMappingOptionalUnioncastoverloadc5ReZdZedZedZeddddddeej ej fde e e e fde e e efde e e efd e eeejfd eejeejff d Zedd d d d d d d d d d d d d d dd d d ddddd de e dede de dejdejdejdee e fdejde dejde deejdeej dej!dedee"ddfd e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd ejf2d#Zedd d d d d d d d d d d d d d d d d ddddd$de e dede de dejdejdejdee e fdejde dejde deejdeej dej!dede"d%d e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd eejf2d&Zedd d d d d d d d d d d d d dd d d ddddd'de e d(ej%d)ej&dede dej'dejdee e fde dej(de deejdeej dej!dedee"ddfd e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd ejf0d*Zedd d d d d d d d d d d d d d d d ddddd+de e d(ej%d)ej&dede dej'dejdee e fde dej(de deejdeej dej!dede"d%d e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd eejf0d,Zee)e)ddddd-de*eej ej fde*e de e e e fde e e efde e e efd e eeejfd.ed eejeejffd/Ze)e)ddddd-de*eej ej fde*e de e e e fde e e efde e e efd e eeejfd.ed eejeejffd0Zddddd1d2e de e de e e e fde e e efd e eeejff d3Z+edddddddd4d2e de e d5e ed6e e dee"ddfde e e e fde e e efd e eeejfd ejfd7Z,eddddddd8d2e de e d5e ed6e e de"d%de e e e fde e e efd e eeejfd eejfd9Z,eddddddd8d2e de e d5e ed6e e dede e e e fde e e efd e eeejfd eejeejffd:Z,dddddddd4d2e de e d5e ed6e e de ede e e e fde e e efd e eeejfd eejeejffd;Z,ddddd1d2e de e de e e e fde e e efd e eeejfd ejf d<Z-dS)= Interactionsc t|SN)InteractionsWithRawResponseselfs cC:\Projects\Historical\FacebookAutoPoster\venv\Lib\site-packages\google/genai/_gaos/interactions.pywith_raw_responsezInteractions.with_raw_response s*4000c t|Sr")!InteractionsWithStreamingResponser$s r&with_streaming_responsez$Interactions.with_streaming_response$s0666r(N extra_headers extra_query extra_bodytimeoutrequestr-r.r/r0returncdSaCreates a new interaction. :param body: The request body. :param api_version: API version for request routing. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param extra_body: Additional JSON object fields to merge into request bodies. :param timeout: Override the default request timeout configuration for this method in seconds Nr%r1r-r.r/r0s r&createzInteractions.create(r(. api_version backgroundcached_contentcontinuation_token environmentgeneration_configinputlabelsprevious_interaction_idresponse_formatresponse_mime_typeresponse_modalitiessafety_settings service_tierstorestreamsystem_instructiontoolswebhook_configr-r.r/r0r:r;r<r=r>r?r@rAmodelrBrCrDrErFrGrHrIFrJrKrLcdSay Creates a new interaction. :param api_version: API version for request routing. :param background: Input only. Whether to run the model interaction in the background. :param cached_content: The name of the cached content used as context to serve the prediction. Note: only used in explicit caching, where users can have control over caching (e.g. what content to cache) and enjoy guaranteed cost savings. Format: cachedContents/{cachedContent} :param continuation_token: Opaque token to resume a long decode. Output: set when status is INCOMPLETE and decoding can be resumed. Input: pass the latest token back unchanged in CreateInteraction to continue decoding. :param environment: The environment configuration for the interaction. Can be an object specifying remote environment sources or a string referencing an existing environment ID. :param generation_config: Configuration parameters for model interactions. :param input: The input for the interaction. :param labels: The labels with user-defined metadata for the request. Label keys and values can be no longer than 63 characters (Unicode codepoints) and can only contain lowercase letters, numeric characters, underscores, and dashes. International characters are allowed. Label values are optional. Label keys must start with a letter. :param model: The model that will complete your prompt.\n\nSee [models](https://ai.google.dev/gemini-api/docs/models) for additional details. :param previous_interaction_id: The ID of the previous interaction, if any. :param response_format: Enforces that the generated response is a JSON object that complies with the JSON schema specified in this field. :param response_mime_type: The mime type of the response. This is required if response_format is set. :param response_modalities: The requested modalities of the response (TEXT, IMAGE, AUDIO). :param safety_settings: Safety settings for the interaction. :param service_tier: :param store: Input only. Whether to store the response and request for later retrieval. :param stream: Input only. Whether the interaction will be streamed. :param system_instruction: System instruction for the interaction. :param tools: A list of tool declarations the model may call during interaction. :param webhook_config: Message for configuring webhook events for a request. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param extra_body: Additional JSON object fields to merge into request bodies. :param timeout: Override the default request timeout configuration for this method in seconds Nr5r%r:r;r<r=r>r?r@rArMrBrCrDrErFrGrHrIrJrKrLr-r.r/r0s r&r7zInteractions.create>r8r(r:r;r<r=r>r?r@rArBrCrDrErFrGrHrJrKrLr-r.r/r0TcdSrOr5rPs r&r7zInteractions.creater8r(r: agent_configr;r=r>r@rArBrCrDrErFrGrHrIrJrKrLr-r.r/r0agentrTcdSa Creates a new interaction. :param api_version: API version for request routing. :param agent: The agent to interact with. :param agent_config: Configuration parameters for the agent interaction. :param background: Input only. Whether to run the model interaction in the background. :param continuation_token: Opaque token to resume a long decode. Output: set when status is INCOMPLETE and decoding can be resumed. Input: pass the latest token back unchanged in CreateInteraction to continue decoding. :param environment: The environment configuration for the interaction. Can be an object specifying remote environment sources or a string referencing an existing environment ID. :param input: The input for the interaction. :param labels: The labels with user-defined metadata for the request. Label keys and values can be no longer than 63 characters (Unicode codepoints) and can only contain lowercase letters, numeric characters, underscores, and dashes. International characters are allowed. Label values are optional. Label keys must start with a letter. :param previous_interaction_id: The ID of the previous interaction, if any. :param response_format: Enforces that the generated response is a JSON object that complies with the JSON schema specified in this field. :param response_mime_type: The mime type of the response. This is required if response_format is set. :param response_modalities: The requested modalities of the response (TEXT, IMAGE, AUDIO). :param safety_settings: Safety settings for the interaction. :param service_tier: :param store: Input only. Whether to store the response and request for later retrieval. :param stream: Input only. Whether the interaction will be streamed. :param system_instruction: System instruction for the interaction. :param tools: A list of tool declarations the model may call during interaction. :param webhook_config: Message for configuring webhook events for a request. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param extra_body: Additional JSON object fields to merge into request bodies. :param timeout: Override the default request timeout configuration for this method in seconds Nr5r%r:rUrTr;r=r>r@rArBrCrDrErFrGrHrIrJrKrLr-r.r/r0s r&r7zInteractions.creater8r(r:rTr;r=r>r@rArBrCrDrErFrGrHrJrKrLr-r.r/r0cdSrWr5rXs r&r7zInteractions.creater8r(r1r:r-r.r/r0 body_kwargsc dS Creates a new interaction. :param api_version: API version for request routing. :param background: Input only. Whether to run the model interaction in the background. :param cached_content: The name of the cached content used as context to serve the prediction. Note: only used in explicit caching, where users can have control over caching (e.g. what content to cache) and enjoy guaranteed cost savings. Format: cachedContents/{cachedContent} :param continuation_token: Opaque token to resume a long decode. Output: set when status is INCOMPLETE and decoding can be resumed. Input: pass the latest token back unchanged in CreateInteraction to continue decoding. :param environment: The environment configuration for the interaction. Can be an object specifying remote environment sources or a string referencing an existing environment ID. :param generation_config: Configuration parameters for model interactions. :param input: The input for the interaction. :param labels: The labels with user-defined metadata for the request. Label keys and values can be no longer than 63 characters (Unicode codepoints) and can only contain lowercase letters, numeric characters, underscores, and dashes. International characters are allowed. Label values are optional. Label keys must start with a letter. :param model: The model that will complete your prompt.\n\nSee [models](https://ai.google.dev/gemini-api/docs/models) for additional details. :param previous_interaction_id: The ID of the previous interaction, if any. :param response_format: Enforces that the generated response is a JSON object that complies with the JSON schema specified in this field. :param response_mime_type: The mime type of the response. This is required if response_format is set. :param response_modalities: The requested modalities of the response (TEXT, IMAGE, AUDIO). :param safety_settings: Safety settings for the interaction. :param service_tier: :param store: Input only. Whether to store the response and request for later retrieval. :param stream: Input only. Whether the interaction will be streamed. :param system_instruction: System instruction for the interaction. :param tools: A list of tool declarations the model may call during interaction. :param webhook_config: Message for configuring webhook events for a request. :param agent: The agent to interact with. :param agent_config: Configuration parameters for the agent interaction. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param extra_body: Additional JSON object fields to merge into request bodies. :param timeout: Override the default request timeout configuration for this method in seconds Nr5r%r1r:r-r.r/r0r\s r&r7zInteractions.createFr8r(c d|vrd|vrtdd|vrd|vrtdd|vrd|vrtdd|vrd|vrtdd |vrd|vrtd d |vrd|vrtd d }d } t} d } |} |} | jj} | | }n|| }turbt tjttrn1tj t ttjnt|}d |D}d|i}d|D}||d<t tjtj |tjt!j| \}} dd|| ddddt't'dd dddurdnd| |tjjjjjjfdd | }| tkrMjjtur jj} n-tjdtjdddd dd!"} d }t| tjr| gd#f}fd$}t7j|pd%d&d t9jjt:jd'gd t?|d()*} ||d+t't'dd dddup|d,k|-}|d.krtj!d/d0g|j"rl|# ||nK#tH$r>}t!j%jj&d1tO|||Yd }~nd }~wwxYw|d,kr t j(n t j)}t t|||t't'dd dddurd2nd3tO|jj&*d14S ||S#tH$r?}t!j%jj&d1tO|||Yd }~d Sd }~wwxYw)5r_r<rU0Cannot supply both 'cached_content' and 'agent'.rT7Cannot supply both 'cached_content' and 'agent_config'.r?3Cannot supply both 'generation_config' and 'agent'.:Cannot supply both 'generation_config' and 'agent_config'.rM'Cannot supply both 'model' and 'agent'..Cannot supply both 'model' and 'agent_config'.Nc,i|]\}}|tu||Sr5r.0kvs r& z'Interactions.create..#TTTTQQe^^Aq^^^r(r:c,i|]\}}|tu||Sr5rirjs r&rnz'Interactions.create..*AAUNN1NNNr(bodyPOST/{api_version}/interactionsT user-agentrIFtext/event-streamapplication/jsonr:cVtjjdddtjSNFjson)r/rserialize_request_bodyrrrCreateInteractionRequestBodyr/r1sr&z%Interactions.create..0(D 3% )))r(methodpathbase_url url_variablesr1request_body_requiredrequest_has_path_paramsrequest_has_query_paramsuser_agent_headeraccept_header_value http_headersextra_query_params_globalssecurityget_serialized_bodyallow_empty_value timeout_msattempt-count-backoff@0u max_retries4084094295XXcld}tjddr1tj}ttj|dStjddrt fddStjd drttj} ttj|}tj ||#tj $r}tj d ||d}~wwxYwtjd drttj} ttj |}tj ||#tj $r}tj d ||d}~wwxYwtj}tj d |) N200rwFvalidatervcHttj|djSNFrrrInteractionSSEStreamEventdatarawhttp_ress r&rzHInteractions.create.._speakeasy_parse_response... 7$> !& !!!  r([DONE]sentinel client_ref4XX1Error response body did not match expected schemarUnexpected response received)rmatch_responsestream_to_textrr Interactionrr CreateInteractionClientErrorDataCreateInteractionClientErrorResponseValidationErrorGenAiDefaultError CreateInteractionServerErrorDataCreateInteractionServerErrorr response_data http_res_texter%s` r&_speakeasy_parse_responsez6Interactions.create.._speakeasy_parse_responses-!%M#He5GHH  % 4X > > . ,h PU#He5HII  &#    #He5GHH  % 4X > >  $;?=%%M!=%x5 2K %  #He5GHH  % 4X > >  $;?=%%M!=%x5 2K % "0::M*.- 0#1CC?#C::C?-1EF -FF CreateInteractionrsyncmode executionconfigr operation_id oauth2_scopessecurity_sourcetags extensionsresponsec0tjddg|SNrrrmatch_status_codescs r&rz%Interactions.create..Y5+CUENTU+V+Vr( streaminghook_ctxr1is_error_status_coderI retry_configparsedrr_hooks event_streambufferedrparserrrrhooks)+ ValueErrorr_coerce_timeout_mssdk_configurationr_get_urlrrCreateInteractionRequest isinstancer r unmarshalrdictitemsrconsume_response_mode_build_requestgetattrCreateInteractionGlobalsglobalsr:rr RetryConfigBackoffStrategyrrrSecurityr do_requestr status_coderead Exceptionraise_parse_error__dict__rStreamedAPIResponse APIResponsegetr%r1r:r-r.r/r0r\rrretries server_urlrr _body_kwargs_request_kwargs_speakeasy_response_modereqrr_speakeasy_hook_ctxr parse_exc__speakeasy_response_clss`` ` r&r7zInteractions.create|s[h { * *w+/E/EOPP P { * *~/L/LVWW W + - -'[2H2HRSS S + - -.K2O2OL  k ! !g&<&<FGG G k ! !n &C&CMNN N 7< $ ,,W55  /:J  !!HH}}X}==H %  /gy11_g&&(G GG ,,LTT\-?-?-A-ATTTL/ e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL5 5 5 5 5 n*)^,1&/!!$*BfUUU    ??(!V!V77FD998UKKtS7';6% #   $x / /'8LMM  --h7777 $6.7A./BCC " ,{::!44%1 $ '' 4#77FD#A#A8USS  '(#34GHH09==hGG      ,,X66 6     .&/9&':;;           s0* N66 O>4O99O> R S&'4S!!S&r:r-r.r0idcd}d}t}d} |} ||} | |jj} | | }n|||}t j||} tj| \} } | dd||| ddddd| |t j |jj j |jj d| }|tkrM|jjtur |jj}n-tjd tjd d dddd}d}t%|tjr|gdf}d}t'|j|pdddt)|jj t*jdgdt/| d}|||d| dk|}| dkrtjddg|jrl| ||nK#t8$r>}tj|jjd t?|||Yd}~nd}~wwxYw| dkr tj n tj!}tEtF|||d!|t?||jj$d "S ||S#t8$r?}tj|jjd t?|||Yd}~dSd}~wwxYw)#Deletes the interaction by id. :param id: Required. The name of the interaction to delete. :param api_version: API version for request routing. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nr:r DELETE,/{api_version}/interactions/{interactionsId}FTrurwrxrrrrr1rrrrrrrrrrrrrrrrrrrcDd}tj|ddrdStj|ddrc ttj|}tj||#tj$r!}tjd||j|d}~wwxYwtj|ddrc ttj |}tj ||#tj$r!}tjd||j|d}~wwxYwtjd|Nr*rrwrrr rrrr DeleteInteractionClientErrorDataDeleteInteractionClientErrorrrtext DeleteInteractionServerErrorDataDeleteInteractionServerErrorrrrs r&rz6Interactions.delete.._speakeasy_parse_responses[!%M#HeS99 #He5GHH  $;?%%M!=mXVVV5 2K    #He5GHH  $;?%%M!=mXVVV5 2K   *+I8TT Ts//A!!B0B  B+/CD )DD rdeleteInteractionrrrrc0tjddg|Srrrs r&rz%Interactions.delete..rr(rrrrrrrr)%rrrrrrDeleteInteractionRequestrrrDeleteInteractionGlobalsrr:rrrrrrrrrrr rrrrrrrrrrrrrr%r r:r-r.r0rrrrrrr1rrrrrrrrs r&deletezInteractions.deletes" 7< $ ,,W55  /:J  !!HH}}X}==H1#    2B1W 2 2 . ,!!?'"'$(%)* 2%*4 2:F+4"!%"  * e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL U U U>*)^,1&/!!$*BfUUU    ??(!V!V+{:% #   $x / /'8LMM  --h7777 $6.7A./BCC " ,{::!44%1 $ '' 4##34GHH09==hGG     ,,X66 6     .&/9&':;;           0/ G;; I4H>>I3 J>> L4LLr: include_input last_event_idrIr-r.r0r"r#cdS:Retrieves the full details of a single interaction based on its `Interaction.id`. :param id: Required. The name of the interaction to retrieve. :param api_version: API version for request routing. :param include_input: If true, includes the input in the response. :param last_event_id: If set, resumes the interaction stream from the chunk after the event marked by the event id. Can only be used if `stream` is true. :param stream: If true, streams the interaction events as Server-Sent Events. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nr5 r%r r:r"r#rIr-r.r0s r&rzInteractions.get,r8r(r:r"r#r-r.r0cdSr%r5r's r&rzInteractions.getGr8r(cdSr%r5r's r&rzInteractions.getbr8r(c@d} d} t} d} |} |}| jj}| | } n| | } t j|||||}tj| \}} dd| | |dddd|durdnd | |t j jj j jj d| }| tkrMjjtur jj} n-tjd tjd ddddd} d}t%| tjr| gdf}fd}t'j| pdddt)jj t*jdgdt/|d}||d|dup|dk|}|dkrtjdd g|jrl| ||nK#t8$r>}tjjjd!t?|||Yd}~nd}~wwxYw|dkr tj n tj!}tEtF||||durd"nd#t?|jj$d!$S ||S#t8$r?}tjjjd!t?|||Yd}~dSd}~wwxYw)%r&Nr:r"r r#rIGETrFTrurvrwrxrrrrrrrrrcld}tjddr1tj}ttj|dStjddrt fddStjd drttj} ttj|}tj ||#tj $r}tj d ||d}~wwxYwtjd drttj} ttj |}tj ||#tj $r}tj d ||d}~wwxYwtj}tj d |) NrrwFrrvcHttj|djSrrrs r&rzEInteractions.get.._speakeasy_parse_response..rr(rrrrrr)rrrrrrrr!GetInteractionByIDClientErrorDataGetInteractionByIDClientErrorrr!GetInteractionByIDServerErrorDataGetInteractionByIDServerErrorrs` r&rz3Interactions.get.._speakeasy_parse_responses1!%M#He5GHH  % 4X > > . ,h PU#He5HII  &#    #He5GHH  % 4X > > $;@ %%%M !>%x5 2K %  #He5GHH  % 4X > > $;@ %%%M !>%x5 2K % "0::M*.- rrgetInteractionByIdrrrrc0tjddg|Srrrs r&rz"Interactions.get..rr(rrrrrrrrr)%rrrrrrGetInteractionByIDRequestrrrGetInteractionByIDGlobalsrr:rrrrrrrrrrr rrrrrrrrrrrrrr%r r:r"r#rIr-r.r0rrrrrrr1rrrrrrrrs` r&rzInteractions.get}s92 7< $ ,,W55  /:J  !!HH}}X}==H2#''    2B1W 2 2 . ,!!?'"'$(%)*~~!4 3#%*5 2:F+4"!)"  . e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL9 9 9 9 9 v*)^-1&/!!$*BfUUU    ??(!V!VT>L%=%L% #   $x / /'8LMM  --h7777 $6.7A./BCC " ,{::!44%1 $ '' 4,2dNN.. #34GHH09==hGG     ,,X66 6     .&/9&':;;           s0? H I4II K L4LLcd}d}t}d} |} ||} | |jj} | | }n|||}t j||} tj| \} } | dd||| ddddd| |t j |jj j |jj d| }|tkrM|jjtur |jj}n-tjd tjd d dddd}d}t%|tjr|gdf}d}t'|j|pdddt)|jj t*jdgdt/| d}|||d| dk|}| dkrtjddg|jrl| ||nK#t8$r>}tj|jjd t?|||Yd}~nd}~wwxYw| dkr tj n tj!}tEtF|||d!|t?||jj$d "S ||S#t8$r?}tj|jjd t?|||Yd}~dSd}~wwxYw)#Cancels an interaction by id. This only applies to background interactions that are still running. :param id: Required. The name of the interaction to cancel. :param api_version: API version for request routing. :param extra_headers: Additional headers to set or replace on requests. :param extra_query: Additional query parameters to append to requests. :param timeout: Override the default request timeout configuration for this method in seconds Nr rs3/{api_version}/interactions/{interactionsId}/cancelFTrurwrxrrrrrrrrrcxd}tj|ddrttj|dStj|ddrc tt j|}t j||#t j$r!}t j d||j |d}~wwxYwtj|ddrc tt j |}t j ||#t j$r!}t j d||j |d}~wwxYwt j d| NrrwFrrrrr rrrrrr$CancelInteractionByIDClientErrorData CancelInteractionByIDClientErrorrrr$CancelInteractionByIDServerErrorData CancelInteractionByIDServerErrorrs r&rz6Interactions.cancel.._speakeasy_parse_responses!%M#He5GHH . ,h#He5GHH  $;CX%%M!A%x5 2K    #He5GHH  $;CX%%M!A%x5 2K   *+I8TT Ts0 /A;;B+ B&&B+/C44D$DD$rcancelInteractionByIdrrrrc0tjddg|Srrrs r&rz%Interactions.cancel..rr(rrrrrrrr)%rrrrrrCancelInteractionByIDRequestrrrCancelInteractionByIDGlobalsrr:rrrrrrrrrrr rrrrrrrrrrrrrrs r&cancelzInteractions.cancelIs$ 7< $ ,,W55  /:J  !!HH}}X}==H5#    2B1W 2 2 . ,!!F'"'$(%)* 2%*8 2:F+4"!%"  * e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL# U# U# UJ*)^01&/!!$*BfUUU    ??(!V!V+{:% #   $x / /'8LMM  --h7777 $6.7A./BCC " ,{::!44%1 $ '' 4##34GHH09==hGG     ,,X66 6     .&/9&':;;           r ).__name__ __module__ __qualname__propertyr'r+rrrrCreateInteractionRequestParamrrstrrfloathttpxTimeoutrrrInteractionSSEEventr7bool&CreateModelInteractionEnvironmentParamGenerationConfigParamInteractionsInputParamrModel)CreateModelInteractionResponseFormatParamrResponseModalitySafetySettingParam ServiceTierr ToolParamWebhookConfigParam AgentOption&CreateAgentInteractionAgentConfigParam&CreateAgentInteractionEnvironmentParam)CreateAgentInteractionResponseFormatParamrr rrrGr5r(r&r r s 11X177X76:37269=     +V-Q Q   S 12  gc3h/0 WS#X./ %u} 456  |' 0P)QQ R   X *&*!"%KN@C58!$'*RU"%CFAD14.2"%.1:=5937269=5@ @ @ c]@  @  @  @ "H@ (=@ 2@ S#X@ !@ "%@ &O@  @ ","?@@ l=>!@ "#.#@ $%@ &gend*+'@ ( )@ *L*++@ ,%7-@ . S 12/@ 0gc3h/01@ 2WS#X./3@ 4%u} 4565@ 6  !7@ @ @ X@ D&*!"%KN@C58!$'*RU"%CFAD14"%.1:=5937269=5@ @ @ c]@  @  @  @ "H@ (=@ 2@ S#X@ !@ "%@ &O@  @ ","?@@ l=>!@ "#.#@ $%@ & '@ ( )@ *L*++@ ,%7-@ . S 12/@ 0gc3h/01@ 2WS#X./3@ 4%u} 4565@ 6  0 17@ @ @ X@ D&*LO"%KN58!$'*RU"%CFAD14.2"%.1:=5937269=3> > > c]> ' > #I >  >  > "H> 2> S#X> "%> &O>  > ","?@> l=>> #.!> "#> $gend*+%> & '> (L*+)> *%7+> , S 12-> .gc3h/0/> 0WS#X./1> 2%u} 4563> 4  !5> > > X> @&*LO"%KN58!$'*RU"%CFAD14"%.1:=5937269=3> > > c]> ' > #I >  >  > "H> 2> S#X> "%> &O>  > ","?@> l=>> #.!> "#> $ %> & '> (L*+)> *%7+> , S 12-> .gc3h/0/> 0WS#X./1> 2%u} 4563> 4  0 15> > > X> @ -25937269=3 3 3 " &163WW X 3 &c* 3  S 123 gc3h/03 WS#X./3 %u} 4563 3  |' 0P)QQ R3 3 3 X3 t -25937269=KKK" &163WW X K &c* K S 12Kgc3h/0KWS#X./K%u} 456KK |' 0P)QQ RKKKKb&*59379=aaa ac] a  S 12 a gc3h/0 a%u} 456aaaaF &*(,'+.259379=    c]   ~   }  gend*+  S 12 gc3h/0 %u} 456   !   X 4 &*(,'+59379=    c]   ~   }     S 12 gc3h/0 %u} 456   0 1   X 4 &*(,'+59379=    c]   ~   }    S 12 gc3h/0 %u} 456  |' 0P)QQ R   X <&*(,'+!%59379=JJJ Jc] J  ~ J  } JJ S 12Jgc3h/0J%u} 456J |' 0P)QQ RJJJJ`&*59379=hhh hc] h  S 12 h gc3h/0 h%u} 456h  !hhhhhhr(r ceZdZdeddfdZdS)r#sdkr2Nc ||_tj|jd|_tj|jd|_tj|jd|_tj|jd|_dSNr-)_sdkrto_raw_response_wrapperr7rrrGr%rbs r&__init__z$InteractionsWithRawResponse.__init__sx &> J   '> J   $;CG_UU&> J   r(rHrIrJr rhr5r(r&r#r#s6  L  T       r(r#ceZdZdeddfdZdS)r*rbr2Nc ||_tj|jd|_tj|jd|_tj|jd|_tj|jd|_dSrd)rerto_streamed_response_wrapperr7rrrGrgs r&rhz*InteractionsWithStreamingResponse.__init__s &C J   'C J   $@ G_  'C J   r(rir5r(r&r*r*s6  L  T       r(r*c5ReZdZedZedZeddddddeej ej fde e e e fde e e efde e e efd e eeejfd eejeejff d Zedd d d d d d d d d d d d d d dd d d ddddd de e dede de dejdejdejdee e fdejde dejde deejdeej dej!dedee"ddfd e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd ejf2d#Zedd d d d d d d d d d d d d d d d d ddddd$de e dede de dejdejdejdee e fdejde dejde deejdeej dej!dede"d%d e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd eejf2d&Zedd d d d d d d d d d d d d dd d d ddddd'de e d(ej%d)ej&dede dej'dejdee e fde dej(de deejdeej dej!dedee"ddfd e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd ejf0d*Zedd d d d d d d d d d d d d d d d ddddd+de e d(ej%d)ej&dede dej'dejdee e fde dej(de deejdeej dej!dede"d%d e d!eej#d"ej$de e e e fde e e efde e e efd e eeejfd eejf0d,Zee)e)ddddd-de*eej ej fde*e de e e e fde e e efde e e efd e eeejfd.ed eejeejffd/Ze)e)ddddd-de*eej ej fde*e de e e e fde e e efde e e efd e eeejfd.ed eejeejffd0Zddddd1d2e de e de e e e fde e e efd e eeejff d3Z+edddddddd4d2e de e d5e ed6e e dee"ddfde e e e fde e e efd e eeejfd ejfd7Z,eddddddd8d2e de e d5e ed6e e de"d%de e e e fde e e efd e eeejfd eejfd9Z,eddddddd8d2e de e d5e ed6e e dede e e e fde e e efd e eeejfd eejeejffd:Z,dddddddd4d2e de e d5e ed6e e de ede e e e fde e e efd e eeejfd eejeejffd;Z,ddddd1d2e de e de e e e fde e e efd e eeejfd ejf d<Z-dS)=AsyncInteractionsc t|Sr") AsyncInteractionsWithRawResponser$s r&r'z#AsyncInteractions.with_raw_responses/555r(c t|Sr")&AsyncInteractionsWithStreamingResponser$s r&r+z)AsyncInteractions.with_streaming_responses5d;;;r(Nr,r1r-r.r/r0r2c KdSr4r5r6s r&r7zAsyncInteractions.create r(.r9r:r;r<r=r>r?r@rArMrBrCrDrErFrGrHrIFrJrKrLc KdSrOr5rPs r&r7zAsyncInteractions.create3rtr(rQTc KdSrOr5rPs r&r7zAsyncInteractions.createvrtr(rSrUrTc KdSrWr5rXs r&r7zAsyncInteractions.creatertr(rYc KdSrWr5rXs r&r7zAsyncInteractions.creatertr(r[r\c KdSr^r5r`s r&r7zAsyncInteractions.create;rtr(c Kd|vrd|vrtdd|vrd|vrtdd|vrd|vrtdd|vrd|vrtdd |vrd|vrtd d |vrd|vrtd d }d } t} d } |} |} | jj} | | }n|| }turbt tjttrn1tj t ttjnt|}d |D}d|i}d|D}||d<t tjtj |tjt!j| \}} dd|| ddddt't'dd dddurdnd| |tjjjjjjfdd | }| tkrMjjtur jj} n-tjdtjdddd dd!"} d }t| tjr| gd#f}fd$}t7j|pd%d&d t9jjt:jd'gd t?|d()*} ||d+t't'dd dddup|d,k|-d {V}|d.krstj!d/d0g|j"r|#d {V ||d {Vn|#tH$ro}t!j%jj&'d1jj&'d2tQ|||d {VYd }~nd }~wwxYw|d,kr t j)n t j*}t t|||t't'dd dddurd3nd4tQ|jj&'d2jj&'d15S ||d {VS#tH$rp}t!j%jj&'d1jj&'d2tQ|||d {VYd }~d Sd }~wwxYw)6r_r<rUrbrTrcr?rdrerMrfrgNc,i|]\}}|tu||Sr5rirjs r&rnz,AsyncInteractions.create..ror(r:c,i|]\}}|tu||Sr5rirjs r&rnz,AsyncInteractions.create..rqr(rrrsrtTrurIFrvrwrxcVtjjdddtjSrzr|rsr&rz*AsyncInteractions.create..rr(rrrrrrrrrcKd}tjddr7tjd{V}ttj|dStjddrt fddStjd drztjd{V} ttj|}tj ||#tj $r}tj d ||d}~wwxYwtjd drztjd{V} ttj |}tj ||#tj $r}tj d ||d}~wwxYwtjd{V}tj d |) NrrwFrrvcHttj|djSrrrs r&rzMAsyncInteractions.create.._speakeasy_parse_response..rr(rrrrrr)rrstream_to_text_asyncrrrrrrrrrrrrs` r&rz;AsyncInteractions.create.._speakeasy_parse_responsesy!%M#He5GHH &+&@&J&J J J J J J J . ,h PU#He5HII " &#    #He5GHH &+&@&J&J J J J J J J  $;?=%%M!=%x5 2K %  #He5GHH &+&@&J&J J J J J J J  $;?=%%M!=%x5 2K % #(".Nrr(rrrrr _async_hooksrrrrrrrrr async_hooks)+rrrrrrrrrrr rrrrrrr_build_request_asyncrrrr:rrrrrrrrr do_request_asyncrrareadrraise_parse_error_asyncrrrAsyncStreamedAPIResponseAsyncAPIResponsers`` ` r&r7zAsyncInteractions.createqsKh { * *w+/E/EOPP P { * *~/L/LVWW W + - -'[2H2HRSS S + - -.K2O2OL  k ! !g&<&<FGG G k ! !n &C&CMNN N 7< $ ,,W55  /:J  !!HH}}X}==H %  /gy11_g&&(G GG ,,LTT\-?-?-A-ATTTL/ e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL5 5 5 5 5 n*)^,1&/!!$*BgVVV    ..(!V!V77FD998UKKtS7';6% /         $x / /'8LMM nn&&&&&&&&& 33H========== *B.7;;NKK.7;;HEE./BCC " ,{::!99%6 $ '' 4#77FD#A#A8USS  '(#34GHH09==hGG $ 6 ? C CN S S    " 228<<<<<<<< <   ":&/33NCC&/33H==&':;;               s28O QA%P>>Q5T VA%U;;Vrr cJKd}d}t}d} |} ||} | |jj} | | }n|||}t j||} tj| \} } | dd||| ddddd| |t j |jj j |jj d| }|tkrM|jjtur |jj}n-tjd tjd d dddd}d}t%|tjr|gdf}d}t'|j|pdddt)|jj t*jdgdt/| d}|||d| dk|d{V}| dkrOtjddg|jr|d{V ||d{Vn|#t8$ro}tj|jjd |jjd!tA|||d{VYd}~nd}~wwxYw| dkr tj!n tj"}tGtH|||d"|tA||jjd!|jjd #S ||d{VS#t8$rp}tj|jjd |jjd!tA|||d{VYd}~dSd}~wwxYw)$r Nr r rFTrurwrxrrrrrrrrrcHKd}tj|ddrdStj|ddrc ttj|}tj||#tj$r!}tjd||j|d}~wwxYwtj|ddrc ttj |}tj ||#tj$r!}tjd||j|d}~wwxYwtjd|rrrs r&rz;AsyncInteractions.delete.._speakeasy_parse_responses_!%M#HeS99 #He5GHH  $;?%%M!=mXVVV5 2K    #He5GHH  $;?%%M!=mXVVV5 2K   *+I8TT Ts//A##B2BB-/CD +DD rrrrrrc0tjddg|Srrrs r&rz*AsyncInteractions.delete..rr(rrrrrrrrr)%rrrrrrrrrrrrr:rrrrrrrrrrr rrrrrrrrrrrrrrs r&rzAsyncInteractions.deletes" 7< $ ,,W55  /:J  !!HH}}X}==H1#    2B1W 2 2 . ,''?'"'$(%)* 2%*4 2:F+4"!%(  * e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL U U U>*)^,1&/!!$*BgVVV    ..(!V!V+{:% /         $x / /'8LMM nn&&&&&&&&& 33H========== *B.7;;NKK.7;;HEE./BCC " ,{::!99%6 $ '' 4##34GHH09==hGG $ 6 ? C CN S S    228<<<<<<<< <   ":&/33NCC&/33H==&':;;               2>H J A%JJ L(( N"2A%NN"r!r"r#c KdSr%r5r's r&rzAsyncInteractions.get'rtr(r(c KdSr%r5r's r&rzAsyncInteractions.getBrtr(c KdSr%r5r's r&rzAsyncInteractions.get]rtr(cvKd} d} t} d} |} |}| jj}| | } n| | } t j|||||}tj| \}} dd| | |dddd|durdnd | |t j jj j jj d| }| tkrMjjtur jj} n-tjd tjd ddddd} d}t%| tjr| gdf}fd}t'j| pdddt)jj t*jdgdt/|d}||d|dup|dk|d{V}|dkrUtjdd g|jr|d{V ||d{Vn|#t8$ro}tjjjd!jjd"tA|||d{VYd}~nd}~wwxYw|dkr tj!n tj"}tGtH||||durd#nd$tA|jjd"jjd!%S ||d{VS#t8$rp}tjjjd!jjd"tA|||d{VYd}~dSd}~wwxYw)&r&Nr,r-rFTrurvrwrxrrrrrrrrrcKd}tjddr7tjd{V}ttj|dStjddrt fddStjd drztjd{V} ttj|}tj ||#tj $r}tj d ||d}~wwxYwtjd drztjd{V} ttj |}tj ||#tj $r}tj d ||d}~wwxYwtjd{V}tj d |) NrrwFrrvcHttj|djSrrrs r&rzJAsyncInteractions.get.._speakeasy_parse_response..rr(rrrrrr)rrrrrrrrr0r1rrr2r3rs` r&rz8AsyncInteractions.get.._speakeasy_parse_responses}!%M#He5GHH &+&@&J&J J J J J J J . ,h PU#He5HII " &#    #He5GHH &+&@&J&J J J J J J J $;@ %%%M !>%x5 2K %  #He5GHH &+&@&J&J J J J J J J $;@ %%%M !>%x5 2K % #(". rr(rrrrrrrrrr)%rrrrrrr6rrrr7rr:rrrrrrrrrrr rrrrrrrrrrrrrr8s` r&rzAsyncInteractions.getxs)2 7< $ ,,W55  /:J  !!HH}}X}==H2#''    2B1W 2 2 . ,''?'"'$(%)*~~!4 3#%*5 2:F+4"!)(  . e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL9 9 9 9 9 v*)^-1&/!!$*BgVVV    ..(!V!VT>L%=%L% /         $x / /'8LMM nn&&&&&&&&& 33H========== *B.7;;NKK.7;;HEE./BCC " ,{::!99%6 $ '' 4,2dNN.. #34GHH09==hGG $ 6 ? C CN S S    228<<<<<<<< <   ":&/33NCC&/33H==&':;;               s2H J*A%JJ-L>> N8A%N33N8cJKd}d}t}d} |} ||} | |jj} | | }n|||}t j||} tj| \} } | dd||| ddddd| |t j |jj j |jj d| }|tkrM|jjtur |jj}n-tjd tjd d dddd}d}t%|tjr|gdf}d}t'|j|pdddt)|jj t*jdgdt/| d}|||d| dk|d{V}| dkrOtjddg|jr|d{V ||d{Vn|#t8$ro}tj|jjd |jjd!tA|||d{VYd}~nd}~wwxYw| dkr tj!n tj"}tGtH|||d"|tA||jjd!|jjd #S ||d{VS#t8$rp}tj|jjd |jjd!tA|||d{VYd}~dSd}~wwxYw)$r:Nr rsr;FTrurwrxrrrrrrrrrc|Kd}tj|ddrttj|dStj|ddrc tt j|}t j||#t j$r!}t j d||j |d}~wwxYwtj|ddrc tt j |}t j ||#t j$r!}t j d||j |d}~wwxYwt j d|r=r>rs r&rz;AsyncInteractions.cancel.._speakeasy_parse_response s!%M#He5GHH . ,h#He5GHH  $;CX%%M!A%x5 2K    #He5GHH  $;CX%%M!A%x5 2K   *+I8TT Ts0/A==B- B((B-/C66D&D!!D&rrCrrrrc0tjddg|Srrrs r&rz*AsyncInteractions.cancel.. rr(rrrrrrrrr)%rrrrrrrErrrrFrr:rrrrrrrrrrr rrrrrrrrrrrrrrs r&rGzAsyncInteractions.cancelG s$ 7< $ ,,W55  /:J  !!HH}}X}==H5#    2B1W 2 2 . ,''F'"'$(%)* 2%*8 2:F+4"!%(  * e  %2%??0=++)#tQ>> !  gu0 1 1 C#%A%A%ABL# U# U# UJ*)^01&/!!$*BgVVV    ..(!V!V+{:% /         $x / /'8LMM nn&&&&&&&&& 33H========== *B.7;;NKK.7;;HEE./BCC " ,{::!99%6 $ '' 4##34GHH09==hGG $ 6 ? C CN S S    228<<<<<<<< <   ":&/33NCC&/33H==&':;;               r).rHrIrJrKr'r+rrrrrLrrrMrrNrOrPrrrrQr7rRrSrTrUrrVrWrrXrYrZrr[r\r]r^r_r`rr rrrGr5r(r&rnrns 66X6<<X<6:37269=     +V-Q Q   S 12  gc3h/0 WS#X./ %u} 456  |'\5U)VV W   X *&*!"%KN@C58!$'*RU"%CFAD14.2"%.1:=5937269=5@ @ @ c]@  @  @  @ "H@ (=@ 2@ S#X@ !@ "%@ &O@  @ ","?@@ l=>!@ "#.#@ $%@ &gend*+'@ ( )@ *L*++@ ,%7-@ . S 12/@ 0gc3h/01@ 2WS#X./3@ 4%u} 4565@ 6  !7@ @ @ X@ D&*!"%KN@C58!$'*RU"%CFAD14"%.1:=5937269=5@ @ @ c]@  @  @  @ "H@ (=@ 2@ S#X@ !@ "%@ &O@  @ ","?@@ l=>!@ "#.#@ $%@ & '@ ( )@ *L*++@ ,%7-@ . S 12/@ 0gc3h/01@ 2WS#X./3@ 4%u} 4565@ 6 \5 67@ @ @ X@ D&*LO"%KN58!$'*RU"%CFAD14.2"%.1:=5937269=3> > > c]> ' > #I >  >  > "H> 2> S#X> "%> &O>  > ","?@> l=>> #.!> "#> $gend*+%> & '> (L*+)> *%7+> , S 12-> .gc3h/0/> 0WS#X./1> 2%u} 4563> 4  !5> > > X> @&*LO"%KN58!$'*RU"%CFAD14"%.1:=5937269=3> > > c]> ' > #I >  >  > "H> 2> S#X> "%> &O>  > ","?@> l=>> #.!> "#> $ %> & '> (L*+)> *%7+> , S 12-> .gc3h/0/> 0WS#X./1> 2%u} 4563> 4 \5 65> > > X> @ -25937269=3 3 3 " &163WW X 3 &c* 3  S 123 gc3h/03 WS#X./3 %u} 4563 3  |'\5U)VV W3 3 3 X3 t -25937269=NNN" &163WW X N &c* N S 12Ngc3h/0NWS#X./N%u} 456NN |'\5U)VV WNNNNh&*59379=ddd dc] d  S 12 d gc3h/0 d%u} 456ddddL &*(,'+.259379=    c]   ~   }  gend*+  S 12 gc3h/0 %u} 456   !   X 4 &*(,'+59379=    c]   ~   }     S 12 gc3h/0 %u} 456  \5 6   X 4 &*(,'+59379=    c]   ~   }    S 12 gc3h/0 %u} 456  |'\5U)VV W   X <&*(,'+!%59379=MMM Mc] M  ~ M  } MM S 12Mgc3h/0M%u} 456M |'\5U)VV WMMMMf&*59379=kkk kc] k  S 12 k gc3h/0 k%u} 456k  !kkkkkkr(rnceZdZdeddfdZdS)rprbr2Nc ||_tj|jd|_tj|jd|_tj|jd|_tj|jd|_dSrd)rerasync_to_raw_response_wrapperr7rrrGrgs r&rhz)AsyncInteractionsWithRawResponse.__init__ s &D J   'D J   $A G_  'D J   r(rHrIrJrnrhr5r(r&rprp 7  -  $       r(rpceZdZdeddfdZdS)rrrbr2Nc ||_tj|jd|_tj|jd|_tj|jd|_tj|jd|_dSrd)rer"async_to_streamed_response_wrapperr7rrrGrgs r&rhz/AsyncInteractionsWithStreamingResponse.__init__ s &I J   'I J   $F G_  'I J   r(rr5r(r&rrrr rr(rr))__doc__rrrrrrrrr basesdkr r r r rrrrutils.eventstreamingrrutils.unmarshal_json_responserrOtypingrrrrrrrrrr r#r*rnrprrr5r(r&rs)$HG************HHHHHHHHHH********CCCCCCCCCCCC::::::::55555555BBBBBB UUUUUUUUUUUUUUUUUUUUUURRRRR7RRRj&                 "^^^^^ ^^^B'        "          r(