U ~fhx@shddlmZddlZddlmZmZmZddlmZddlZddl m Z ddl m Z m Z mZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd lm Z m!Z!ddl"m#Z#m$Z$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddl,m-Z-ddgZ.GdddeZ/GdddeZ0GdddZ1GdddZ2GdddZ3GdddZ4dS)) annotationsN)UnionIterableOptional)Literal)_legacy_response) NOT_GIVENBodyQueryHeadersNotGiven)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@s@eZdZeddddZeddddZedeed d d ed d d d dddddddd ddZ edd d d edd d ddddddddZ eded d d edd d dddddddddZ edeeeeed d d ed d d!d!d"d#d!ddddd$d% d&d'Z edd d d edd d ddddd(dd)d*Z d S)+r MessagesWithRawResponsereturncCst|Sa This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers )r"selfr(J/tmp/pip-unpacked-wheel-rjiviquo/openai/resources/beta/threads/messages.pywith_raw_response szMessages.with_raw_responseMessagesWithStreamingResponsecCst|Sz An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/openai/openai-python#with_streaming_response )r+r&r(r(r)with_streaming_response*sz Messages.with_streaming_response>The Assistants API is deprecated in favor of the Responses APIN attachmentsmetadata extra_headers extra_query extra_bodytimeoutstr-Union[str, Iterable[MessageContentPartParam]]Literal[('user', 'assistant')]?Optional[Iterable[message_create_params.Attachment]] | NotGivenOptional[Metadata] | NotGivenHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenr thread_idcontentroler0r1r2r3r4r5r$c CsZ|std|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/ /messagesrArBr0r1r2r3r4r5bodyoptionscast_to) ValueError_postrrMessageCreateParamsrr r'r@rArBr0r1r2r3r4r5r(r(r)create3s*/  zMessages.createrJ message_idr@r2r3r4r5r$cCs\|std||s$td|ddi|p0i}|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 rD9Expected a non-empty value for `message_id` but received rErFrG /messages/rJrMrNrO_getrrr'rUr@r2r3r4r5r(r(r)retrievevszMessages.retriever1r2r3r4r5rUr@r1r2r3r4r5r$c Csj|std||s$td|ddi|p0i}|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 rDrWrErFrGrXr1rJrK)rOrPrrMessageUpdateParamsrrr'rUr@r1r2r3r4r5r(r(r)updates !zMessages.update afterbeforelimitorderrun_idr2r3r4r5str | NotGivenint | NotGiven#Literal[('asc', 'desc')] | NotGivenzSyncCursorPage[Message] r@rerfrgrhrir2r3r4r5r$c Csb|std|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 rDrErFrGrH)rerfrgrhri)r2r3r4r5query)pagerMmodel)rO _get_api_listrrrrrMessageListParams r'r@rerfrgrhrir2r3r4r5r(r(r)lists./ z Messages.listrcCs\|std||s$td|ddi|p0i}|jd|d|t||||dtdS) 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 rDrWrErFrGrXrJrYrO_deleterrr\r(r(r)deleteszMessages.delete__name__ __module__ __qualname__rr*r-typing_extensions deprecatedr rSr]rcruryr(r(r(r)r sT &B %".(Gc@s@eZdZeddddZeddddZedeed d d ed d d d dddddddd ddZ edd d d edd d ddddddddZ eded d d edd d dddddddddZ edeeeeed d d ed d d!d!d"d#d!ddddd$d% d&d'Z edd d d edd d ddddd(dd)d*Z d S)+r!AsyncMessagesWithRawResponser#cCst|Sr%)rr&r(r(r)r*;szAsyncMessages.with_raw_response"AsyncMessagesWithStreamingResponsecCst|Sr,)rr&r(r(r)r-Esz%AsyncMessages.with_streaming_responser.Nr/r6r7r8r9r:r;r<r=r>rr?c sf|std|ddi|pi}|jd|dt||||dtjIdHt|||| dtd IdHS) rCrDrErFrGrHrINrJrK)rOrPrrrQrrrRr(r(r)rSNs*/  zAsyncMessages.createrJrTcsb|std||s$td|ddi|p0i}|jd|d|t||||dtdId HS) rVrDrWrErFrGrXrJrYNrZr\r(r(r)r]szAsyncMessages.retriever^r_c sv|std||s$td|ddi|p0i}|jd|d|td|itjIdHt||||d td IdHS) r`rDrWrErFrGrXr1NrJrK)rOrPrrrarrrbr(r(r)rcs !zAsyncMessages.updaterdrjrkrlz1AsyncPaginator[Message, AsyncCursorPage[Message]]rmc Csb|std|ddi|pi}|jd|dttt||| | t|||||dtjdtdSrn)rOrrrrrrrrsrtr(r(r)rus./ zAsyncMessages.listrcsb|std||s$td|ddi|p0i}|jd|d|t||||dtdId HS) rvrDrWrErFrGrXrJrYNrwr\r(r(r)ry.szAsyncMessages.deleterzr(r(r(r)r!:sT &B %".(Gc@seZdZdddddZdS)r"r Nonemessagesr$cCsP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSN) _messagesrZto_raw_response_wrapperrSr]rcruryr'rr(r(r)__init__Vs*z MessagesWithRawResponse.__init__Nr{r|r}rr(r(r(r)r"Usr"c@seZdZdddddZdS)rr!rrcCsP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr)rrZasync_to_raw_response_wrapperrSr]rcruryrr(r(r)rus*z%AsyncMessagesWithRawResponse.__init__Nrr(r(r(r)rtsrc@seZdZdddddZdS)r+r rrcCsF||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr)rrrSr]rcruryrr(r(r)rs*z&MessagesWithStreamingResponse.__init__Nrr(r(r(r)r+sr+c@seZdZdddddZdS)rr!rrcCsF||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr)rrrSr]rcruryrr(r(r)rs*z+AsyncMessagesWithStreamingResponse.__init__Nrr(r(r(r)rsr)5 __future__rr~typingrrrrZhttpxr_typesr r r r r _utilsrr_compatrZ _resourcerr _responserrZ paginationrrZ _base_clientrrZtypes.beta.threadsrrrZtypes.beta.threads.messagerZtypes.shared_params.metadatarZ"types.beta.threads.message_deletedrZ-types.beta.threads.message_content_part_paramr__all__r r!r"rr+rr(r(r(r)s8