o $iJx@spddlmZddlZddlmZmZmZddlmZddlZddl m Z ddl m Z m Z mZmZmZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZdd lmZm Z dd l!m"Z"m#Z#ddl$m%Z%m&Z&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-ddl.m/Z/ddgZ0GdddeZ1GdddeZ2GdddZ3GdddZ4GdddZ5GdddZ6dS)) annotationsN)UnionIterableOptional)Literal)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)message_list_paramsmessage_create_paramsmessage_update_params)Message)Metadata)MessageDeleted)MessageContentPartParamMessages AsyncMessagesc @eZdZed6ddZed7ddZedeed d d e d d8ddZ edd d d e d d9d"d#Z eded d d e d$d:d%d&Z edeeeeed d d e d' d;d1d2Z edd d d e d dThe Assistants API is deprecated in favor of the Responses APIN attachmentsmetadata extra_headers extra_query extra_bodytimeout thread_idstrcontent-Union[str, Iterable[MessageContentPartParam]]roleLiteral['user', 'assistant']r5;Optional[Iterable[message_create_params.Attachment]] | Omitr6Optional[Metadata] | Omitr7Headers | Noner8 Query | Noner9 Body | Noner:'float | httpx.Timeout | None | NotGivenrc CsZ|s td|ddi|pi}|jd|dt||||dtjt|||| dtdS) / Create a message. Args: content: The text contents of the message. role: The role of the entity that is creating the message. Allowed values include: - `user`: Indicates the message is sent by an actual user and should be used in most cases to represent user-generated messages. - `assistant`: Indicates the message is generated by the assistant. Use this value to insert messages from the assistant into the conversation. attachments: A list of files attached to the message, and the tools they should be added to. metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful for storing additional information about the object in a structured format, and querying for objects via API or the dashboard. Keys are strings with a maximum length of 64 characters. Values are strings with a maximum length of 512 characters. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds 8Expected a non-empty value for `thread_id` but received OpenAI-Beta assistants=v2 /threads/ /messagesr=r?r5r6r7r8r9r:bodyoptionscast_to) ValueError_postrrMessageCreateParamsrr r*r;r=r?r5r6r7r8r9r:r+r+r,create3s$/  zMessages.createrN message_idcC\|s td||std|ddi|pi}|jd|d|t||||dtdS) G Retrieve a message. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rH9Expected a non-empty value for `message_id` but received rIrJrK /messages/rNrQrRrS_getrrr*rXr;r7r8r9r:r+r+r,retrievevzMessages.retriever6r7r8r9r:c Csj|s td||std|ddi|pi}|jd|d|td|itjt||||dtd S)  Modifies a message. Args: metadata: Set of 16 key-value pairs that can be attached to an object. This can be useful for storing additional information about the object in a structured format, and querying for objects via API or the dashboard. Keys are strings with a maximum length of 64 characters. Values are strings with a maximum length of 512 characters. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rHr[rIrJrKr\r6rNrO)rSrTrrMessageUpdateParamsrrr*rXr;r6r7r8r9r:r+r+r,updates!zMessages.update afterbeforelimitorderrun_idr7r8r9r:ri str | Omitrjrk int | OmitrlLiteral['asc', 'desc'] | OmitrmSyncCursorPage[Message]c Cb|s td|ddi|pi}|jd|dttt||| | t|||||dtjdtdS ah Returns a list of messages for a given thread. Args: after: A cursor for use in pagination. `after` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include after=obj_foo in order to fetch the next page of the list. before: A cursor for use in pagination. `before` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, starting with obj_foo, your subsequent call can include before=obj_foo in order to fetch the previous page of the list. limit: A limit on the number of objects to be returned. Limit can range between 1 and 100, and the default is 20. order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending order and `desc` for descending order. run_id: Filter messages by the run ID that generated them. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rHrIrJrKrL)rirjrkrlrm)r7r8r9r:query)pagerQmodel)rS _get_api_listrrrrrMessageListParams r*r;rirjrkrlrmr7r8r9r:r+r+r,list./ z Messages.listr cCrY) F Deletes a message. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rHr[rIrJrKr\rNr]rS_deleterr r`r+r+r,deleterbzMessages.delete)r%r&)r%r/r;r<r=r>r?r@r5rAr6rBr7rCr8rDr9rEr:rFr%rrXr<r;r<r7rCr8rDr9rEr:rFr%rrXr<r;r<r6rBr7rCr8rDr9rEr:rFr%r)r;r<rirnrjrnrkrorlrprmrnr7rCr8rDr9rEr:rFr%rqrXr<r;r<r7rCr8rDr9rEr:rFr%r __name__ __module__ __qualname__rr-r1typing_extensions deprecatedrrrWrargrzrr+r+r+r,r"V  B%.Gc @r$)=r#r%AsyncMessagesWithRawResponsecCr'r()rr)r+r+r,r-;r.zAsyncMessages.with_raw_response"AsyncMessagesWithStreamingResponsecCr'r0)rr)r+r+r,r1Er2z%AsyncMessages.with_streaming_responser3Nr4r;r<r=r>r?r@r5rAr6rBr7rCr8rDr9rEr:rFrc sh|s td|ddi|pi}|jd|dt||||dtjIdHt|||| dtd IdHS) rGrHrIrJrKrLrMNrNrO)rSrTrrrUrrrVr+r+r,rWNs&/   zAsyncMessages.createrNrXcd|s td||std|ddi|pi}|jd|d|t||||dtdId HS) rZrHr[rIrJrKr\rNr]Nr^r`r+r+r,ra zAsyncMessages.retrievercc sx|s td||std|ddi|pi}|jd|d|td|itjIdHt||||d td IdHS) rdrHr[rIrJrKr\r6NrNrO)rSrTrrrerrrfr+r+r,rgs! zAsyncMessages.updaterhrirnrjrkrorlrprm1AsyncPaginator[Message, AsyncCursorPage[Message]]c Crrrs)rSrwrrrrrrxryr+r+r,rzr{zAsyncMessages.listr cr) r|rHr[rIrJrKr\rNr]Nr}r`r+r+r,r.rzAsyncMessages.delete)r%r)r%rrrr)r;r<rirnrjrnrkrorlrprmrnr7rCr8rDr9rEr:rFr%rrrr+r+r+r,r#:rc@eZdZdddZdS) r&messagesr"r%NonecCP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSN) _messagesrto_raw_response_wrapperrWrargrzrr*rr+r+r,__init__V*z MessagesWithRawResponse.__init__Nrr"r%rrrrrr+r+r+r,r&Ur&c@r) rrr#r%rcCrr)rrasync_to_raw_response_wrapperrWrargrzrrr+r+r,rurz%AsyncMessagesWithRawResponse.__init__Nrr#r%rrr+r+r+r,rtrrc@r) r/rr"r%rcCF||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr)rrrWrargrzrrr+r+r,r*z&MessagesWithStreamingResponse.__init__Nrrr+r+r+r,r/rr/c@r) rrr#r%rcCrr)rrrWrargrzrrr+r+r,rrz+AsyncMessagesWithStreamingResponse.__init__Nrrr+r+r+r,rrr)7 __future__rrtypingrrrrhttpxr_typesr r r r r rr_utilsrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.beta.threadsrrrtypes.beta.threads.messagertypes.shared_params.metadatar"types.beta.threads.message_deletedr -types.beta.threads.message_content_part_paramr!__all__r"r#r&rr/rr+r+r+r,s:   $