o "chx@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 @eZdZed6ddZed7ddZedeed d d ed d8ddZ edd d d ed d9d"d#Z eded d d ed$d:d%d&Z edeeeeed d d ed' d;d1d2Z edd d d ed 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']r3?Optional[Iterable[message_create_params.Attachment]] | NotGivenr4Optional[Metadata] | NotGivenr5Headers | Noner6 Query | Noner7 Body | Noner8'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=r3r4r5r6r7r8bodyoptionscast_to) ValueError_postrrMessageCreateParamsrr r(r9r;r=r3r4r5r6r7r8r)r)r*create3s$/  zMessages.createrL 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 rF9Expected a non-empty value for `message_id` but received rGrHrI /messages/rLrOrPrQ_getrrr(rVr9r5r6r7r8r)r)r*retrievevzMessages.retriever4r5r6r7r8c 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 rFrYrGrHrIrZr4rLrM)rQrRrrMessageUpdateParamsrrr(rVr9r4r5r6r7r8r)r)r*updates!zMessages.update afterbeforelimitorderrun_idr5r6r7r8rgstr | NotGivenrhriint | NotGivenrj!Literal['asc', 'desc'] | NotGivenrkSyncCursorPage[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 rFrGrHrIrJ)rgrhrirjrk)r5r6r7r8query)pagerOmodel)rQ _get_api_listrrrrrMessageListParams r(r9rgrhrirjrkr5r6r7r8r)r)r*list./ z Messages.listrcCrW) 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 rFrYrGrHrIrZrLr[rQ_deleterrr^r)r)r*deleter`zMessages.delete)r#r$)r#r-r9r:r;r<r=r>r3r?r4r@r5rAr6rBr7rCr8rDr#rrVr:r9r:r5rAr6rBr7rCr8rDr#rrVr:r9r:r4r@r5rAr6rBr7rCr8rDr#r)r9r:rgrlrhrlrirmrjrnrkrlr5rAr6rBr7rCr8rDr#rorVr:r9r:r5rAr6rBr7rCr8rDr#r__name__ __module__ __qualname__rr+r/typing_extensions deprecatedr rUr_rerxr}r)r)r)r*r V  B%.Gc @r")=r!r#AsyncMessagesWithRawResponsecCr%r&)rr'r)r)r*r+;r,zAsyncMessages.with_raw_response"AsyncMessagesWithStreamingResponsecCr%r.)rr'r)r)r*r/Er0z%AsyncMessages.with_streaming_responser1Nr2r9r:r;r<r=r>r3r?r4r@r5rAr6rBr7rCr8rDrc sh|s td|ddi|pi}|jd|dt||||dtjIdHt|||| dtd IdHS) rErFrGrHrIrJrKNrLrM)rQrRrrrSrrrTr)r)r*rUNs&/   zAsyncMessages.createrLrVcd|s td||std|ddi|pi}|jd|d|t||||dtdId HS) rXrFrYrGrHrIrZrLr[Nr\r^r)r)r*r_ zAsyncMessages.retrieverac sx|s td||std|ddi|pi}|jd|d|td|itjIdHt||||d td IdHS) rbrFrYrGrHrIrZr4NrLrM)rQrRrrrcrrrdr)r)r*res! zAsyncMessages.updaterfrgrlrhrirmrjrnrk1AsyncPaginator[Message, AsyncCursorPage[Message]]c Crprq)rQrurrrrrrvrwr)r)r*rxryzAsyncMessages.listrcr) rzrFrYrGrHrIrZrLr[Nr{r^r)r)r*r}.rzAsyncMessages.delete)r#r)r#rr~rr)r9r:rgrlrhrlrirmrjrnrkrlr5rAr6rBr7rCr8rDr#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_wrapperrUr_rerxr}r(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_wrapperrUr_rerxr}rr)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)rrrUr_rerxr}rr)r)r*r*z&MessagesWithStreamingResponse.__init__Nrrr)r)r)r*r-rr-c@r) rrr!r#rcCrr)rrrUr_rerxr}rr)r)r*rrz+AsyncMessagesWithStreamingResponse.__init__Nrrr)r)r)r*rrr)5 __future__rrtypingrrrrhttpxr_typesr r r r r _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: