a ff@sTddlmZddlmZmZmZddlmZddlZddl 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+ddgZ,GdddeZ-GdddeZ.GdddZ/GdddZ0GdddZ1GdddZ2dS)) annotations)UnionIterableOptional)LiteralN)_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)MessageDeleted)MessageContentPartParamMessages AsyncMessagesc @seZdZeddddZeddddZeeddded d d d d ddddddd ddZdddedd d ddddddddZedddedd d dddddddddZ eeeeeddded d d d d!d"d ddddd#d$ d%d&Z dddedd d ddddd'dd(d)Z dS)*rMessagesWithRawResponsereturncCst|SN)r!selfr'_/var/www/ai-form-bot/venv/lib/python3.9/site-packages/openai/resources/beta/threads/messages.pywith_raw_response!szMessages.with_raw_responseMessagesWithStreamingResponsecCst|Sr$)r*r%r'r'r(with_streaming_response%sz Messages.with_streaming_responseN attachmentsmetadata extra_headers extra_query extra_bodytimeoutstr-Union[str, Iterable[MessageContentPartParam]]Literal['user', 'assistant']?Optional[Iterable[message_create_params.Attachment]] | NotGivenOptional[object] | NotGivenHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenr thread_idcontentroler-r.r/r0r1r2r#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. Keys can be a maximum of 64 characters long and values can be a maxium of 512 characters long. 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?r-r.r/r0r1r2bodyoptionscast_to) ValueError_postrrMessageCreateParamsrr r&r=r>r?r-r.r/r0r1r2r'r'r(create)s$,  zMessages.createrG message_idr=r/r0r1r2r#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 rA9Expected a non-empty value for `message_id` but received rBrCrD /messages/rGrJrKrL_getrrr&rRr=r/r0r1r2r'r'r(retrieveiszMessages.retriever.r/r0r1r2rRr=r.r/r0r1r2r#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. Keys can be a maximum of 64 characters long and values can be a maxium of 512 characters long. 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 rArTrBrCrDrUr.rGrH)rLrMrrMessageUpdateParamsrrr&rRr=r.r/r0r1r2r'r'r(updateszMessages.update afterbeforelimitorderrun_idr/r0r1r2str | NotGivenint | NotGiven!Literal['asc', 'desc'] | NotGivenzSyncCursorPage[Message] r=rbrcrdrerfr/r0r1r2r#c Csb|std|ddi|pi}|jd|dttt||| | t|||||dtjdtdS af 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, ending 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 rArBrCrDrE)rbrcrdrerf)r/r0r1r2query)pagerJmodel)rL _get_api_listrrrrrMessageListParams r&r=rbrcrdrerfr/r0r1r2r'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 rArTrBrCrDrUrGrVrL_deleterrrYr'r'r(deleteszMessages.delete __name__ __module__ __qualname__rr)r+r rPrZr`rrrvr'r'r'r(r sJ $G* 0&Nc @seZdZeddddZeddddZeeddded d d d d ddddddd ddZdddedd d ddddddddZedddedd d dddddddddZ eeeeeddded d d d d!d"d ddddd#d$ d%d&Z dddedd d ddddd'dd(d)Z dS)*r AsyncMessagesWithRawResponser"cCst|Sr$)r{r%r'r'r(r)(szAsyncMessages.with_raw_response"AsyncMessagesWithStreamingResponsecCst|Sr$)r|r%r'r'r(r+,sz%AsyncMessages.with_streaming_responseNr,r3r4r5r6r7r8r9r:r;rr<c sf|std|ddi|pi}|jd|dt||||dtjIdHt|||| dtd IdHS) r@rArBrCrDrErFNrGrH)rLrMrrrNrrrOr'r'r(rP0s$,  zAsyncMessages.createrGrQcsb|std||s$td|ddi|p0i}|jd|d|t||||dtdId HS) rSrArTrBrCrDrUrGrVNrWrYr'r'r(rZpszAsyncMessages.retriever[r\c sv|std||s$td|ddi|p0i}|jd|d|td|itjIdHt||||d td IdHS) r]rArTrBrCrDrUr.NrGrH)rLrMrrr^rrr_r'r'r(r`szAsyncMessages.updaterargrhriz1AsyncPaginator[Message, AsyncCursorPage[Message]]rjc Csb|std|ddi|pi}|jd|dttt||| | t|||||dtjdtdSrk)rLrorrrrrrprqr'r'r(rrs.. zAsyncMessages.listrcsb|std||s$td|ddi|p0i}|jd|d|t||||dtdId HS) rsrArTrBrCrDrUrGrVNrtrYr'r'r(rvszAsyncMessages.deleterwr'r'r'r(r 'sJ $G* 0&Nc@seZdZdddddZdS)r!rNonemessagesr#cCsP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr$) _messagesrZto_raw_response_wrapperrPrZr`rrrvr&rr'r'r(__init__/s z MessagesWithRawResponse.__init__Nrxryrzrr'r'r'r(r!.sr!c@seZdZdddddZdS)r{r r}r~cCsP||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr$)rrZasync_to_raw_response_wrapperrPrZr`rrrvrr'r'r(rDs z%AsyncMessagesWithRawResponse.__init__Nrr'r'r'r(r{Csr{c@seZdZdddddZdS)r*rr}r~cCsF||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr$)rrrPrZr`rrrvrr'r'r(rYs z&MessagesWithStreamingResponse.__init__Nrr'r'r'r(r*Xsr*c@seZdZdddddZdS)r|r r}r~cCsF||_t|j|_t|j|_t|j|_t|j|_t|j|_dSr$)rrrPrZr`rrrvrr'r'r(rns z+AsyncMessagesWithStreamingResponse.__init__Nrr'r'r'r(r|msr|)3 __future__rtypingrrrtyping_extensionsrZhttpxr_typesr r r r r Z_utilsrr_compatrZ _resourcerr _responserrZ paginationrrZ _base_clientrrZtypes.beta.threadsrrrZtypes.beta.threads.messagerZ"types.beta.threads.message_deletedrZ-types.beta.threads.message_content_part_paramr__all__rr r!r{r*r|r'r'r'r(s4