o jX@sPddlmZddlmZmZddlmZddlZddlm Z ddl m Z m Z m Z mZmZmZdd lmZmZmZmZmZdd lmZmZdd lmZdd lmZmZdd lm Z m!Z!ddl"m#Z#m$Z$ddl%m&Z&m'Z'ddl(m)Z)m*Z*m+Z+m,Z,ddgZ-GdddeZ.GdddeZ/GdddZ0GdddZ1GdddZ2GdddZ3dS)) annotations)ListOptional)LiteralN)_legacy_response)Files AsyncFilesFilesWithRawResponseAsyncFilesWithRawResponseFilesWithStreamingResponseAsyncFilesWithStreamingResponse) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options)Messagemessage_list_paramsmessage_create_paramsmessage_update_paramsMessages AsyncMessagesc @eZdZed3ddZed4ddZed5d d Zeed d d ed d6dd Zd d d ed!d7d#d$Z ed d d ed%d8d&d'Z eeeed d d ed(d9d1d2Z d S):r#returnr cC t|jSN)r _clientselfr,u/var/www/html/fyndo/pharma/fyndo/venv/lib/python3.10/site-packages/openai/resources/beta/threads/messages/messages.pyfiles& zMessages.filesMessagesWithRawResponsecCt|Sr()r0r*r,r,r-with_raw_response*zMessages.with_raw_responseMessagesWithStreamingResponsecCr1r()r4r*r,r,r-with_streaming_response.r3z Messages.with_streaming_responseNfile_idsmetadata extra_headers extra_query extra_bodytimeout thread_idstrcontentroleLiteral['user']r7List[str] | NotGivenr8Optional[object] | NotGivenr9Headers | Noner: Query | Noner; Body | Noner<'float | httpx.Timeout | None | NotGivenrc CsZ|s td|ddi|pi}|jd|dt||||dtjt|||| dtdS) ` Create a message. Args: content: The content of the message. role: The role of the entity that is creating the message. Currently only `user` is supported. file_ids: A list of [File](https://platform.openai.com/docs/api-reference/files) IDs that the message should use. There can be a maximum of 10 files attached to a message. Useful for tools like `retrieval` and `code_interpreter` that can access and use files. 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=v1 /threads/ /messagesr?r@r7r8r9r:r;r<bodyoptionscast_to) ValueError_postrr!MessageCreateParamsrr r+r=r?r@r7r8r9r:r;r<r,r,r-create2s$*  zMessages.createrO message_idcCs\|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 rI9Expected a non-empty value for `message_id` but received rJrKrL /messages/rOrRrSrT_getrrr+rYr=r9r:r;r<r,r,r-retrievepszMessages.retriever8r9r:r;r<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. 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 rIr[rJrKrLr\r8rOrP)rTrUrr"MessageUpdateParamsrrr+rYr=r8r9r:r;r<r,r,r-updateszMessages.updateafterbeforelimitorderr9r:r;r<rhstr | NotGivenrirjint | NotGivenrk!Literal['asc', 'desc'] | NotGivenSyncCursorPage[Message]c C`|s td|ddi|pi}|jd|dttt|||| t||||dtjdtdS a  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. 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 rIrJrKrLrM)rhrirjrk)r9r:r;r<query)pagerRmodel)rT _get_api_listrrrrr MessageListParams r+r=rhrirjrkr9r:r;r<r,r,r-list,+ z Messages.list)r&r )r&r0)r&r4r=r>r?r>r@rAr7rBr8rCr9rDr:rEr;rFr<rGr&rrYr>r=r>r9rDr:rEr;rFr<rGr&rrYr>r=r>r8rCr9rDr:rEr;rFr<rGr&r)r=r>rhrlrirlrjrmrkrnr9rDr:rEr;rFr<rGr&ro __name__ __module__ __qualname__rr.r2r5rrXrarfrxr,r,r,r-r#%D    E*0c @r%):r$r&r cCr'r()r r)r*r,r,r-r.r/zAsyncMessages.filesAsyncMessagesWithRawResponsecCr1r()rr*r,r,r-r2 r3zAsyncMessages.with_raw_response"AsyncMessagesWithStreamingResponsecCr1r()rr*r,r,r-r5r3z%AsyncMessages.with_streaming_responseNr6r=r>r?r@rAr7rBr8rCr9rDr:rEr;rFr<rGrc sh|s td|ddi|pi}|jd|dt||||dtjIdHt|||| dtd IdHS) rHrIrJrKrLrMrNNrOrP)rTrUrr!rVrrrWr,r,r-rXs&*   zAsyncMessages.createrOrYcsd|s td||std|ddi|pi}|jd|d|t||||dtdId HS) rZrIr[rJrKrLr\rOr]Nr^r`r,r,r-raPs zAsyncMessages.retrieverbc sx|s td||std|ddi|pi}|jd|d|td|itjIdHt||||d td IdHS) rcrIr[rJrKrLr\r8NrOrP)rTrUrr"rdrrrer,r,r-rfus zAsyncMessages.updatergrhrlrirjrmrkrn1AsyncPaginator[Message, AsyncCursorPage[Message]]c Crprq)rTrurrrrr rvrwr,r,r-rxryzAsyncMessages.list)r&r )r&r)r&rrzr{r|)r=r>rhrlrirlrjrmrkrnr9rDr:rEr;rFr<rGr&rr}r,r,r,r-r$rc@$eZdZd ddZed dd Zd S) r0messagesr#r&NonecCB||_t|j|_t|j|_t|j|_t|j|_dSr() _messagesrto_raw_response_wrapperrXrarfrxr+rr,r,r-__init__ z MessagesWithRawResponse.__init__r cC t|jjSr()r rr.r*r,r,r-r. zMessagesWithRawResponse.filesNrr#r&r)r&r r~rrrrr.r,r,r,r-r0 r0c@r) rrr$r&rcCrr()rrasync_to_raw_response_wrapperrXrarfrxrr,r,r-rrz%AsyncMessagesWithRawResponse.__init__r cCrr()r rr.r*r,r,r-r. rz"AsyncMessagesWithRawResponse.filesNrr$r&r)r&r rr,r,r,r-rrrc@r) r4rr#r&rcC:||_t|j|_t|j|_t|j|_t|j|_dSr()rrrXrarfrxrr,r,r-r z&MessagesWithStreamingResponse.__init__r cCrr()r rr.r*r,r,r-r."rz#MessagesWithStreamingResponse.filesNr)r&r rr,r,r,r-r4rr4c@r) rrr$r&rcCrr()rrrXrarfrxrr,r,r-r(rz+AsyncMessagesWithStreamingResponse.__init__rcCrr()rrr.r*r,r,r-r.8rz(AsyncMessagesWithStreamingResponse.filesNr)r&rrr,r,r,r-r'rr)4 __future__rtypingrrtyping_extensionsrhttpxrr.r r r r r r_typesrrrrr_utilsrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.beta.threadsrr r!r"__all__r#r$r0rr4rr,r,r,r-s.     aa