a !fpK@s(ddlmZddlmZmZmZddlmZddlZddl m Z m Z m Z m Z ddlmZmZmZmZmZdd lmZdd lmZmZdd lmZmZdd lmZmZdd lm Z m!Z!ddl"m#Z#m$Z$m%Z%m&Z&erddl'm(Z(m)Z)ddgZ*GdddeZ+GdddeZ,GdddZ-GdddZ.dS)) annotations) TYPE_CHECKINGListOptional)LiteralN)Files AsyncFilesFilesWithRawResponseAsyncFilesWithRawResponse) NOT_GIVENBodyQueryHeadersNotGiven)maybe_transform)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperasync_to_raw_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options) ThreadMessagemessage_list_paramsmessage_create_paramsmessage_update_params)OpenAI AsyncOpenAIMessages AsyncMessagesc seZdZUded<ded<dddfdd Zeed d d ed d d d dddddddd ddZd d d edd d ddddddddZed d d edd d dddddddddZeeeed d d ed d d!d!d"d#ddddd$d% d&d'Z Z S)(r!rfilesMessagesWithRawResponsewith_raw_responserNoneclientreturncs$t|t||_t||_dSN)super__init__rr#r$r%selfr( __class__p/var/www/html/python-backend/venv/lib/python3.9/site-packages/openai/resources/beta/threads/messages/messages.pyr,"s  zMessages.__init__Nfile_idsmetadata extra_headers extra_query extra_bodytimeoutstrLiteral['user']List[str] | NotGivenOptional[object] | NotGivenHeaders | None Query | None Body | None'float | httpx.Timeout | None | NotGivenr thread_idcontentroler4r5r6r7r8r9r)c CsHddi|p i}|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 OpenAI-Beta assistants=v1 /threads/ /messagesrDrEr4r5r6r7r8r9bodyoptionscast_to_postrrZMessageCreateParamsrr r.rCrDrEr4r5r6r7r8r9r1r1r2create's *  zMessages.createrL message_idrCr6r7r8r9r)cCs8ddi|p i}|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 rGrHrI /messages/rLrOrP_getrrr.rVrCr6r7r8r9r1r1r2retrievecszMessages.retriever5r6r7r8r9rVrCr5r6r7r8r9r)c CsFddi|p i}|jd|d|td|itjt||||dtdS) 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 rGrHrIrXr5rLrMrRrrZMessageUpdateParamsrrr.rVrCr5r6r7r8r9r1r1r2updateszMessages.updateafterbeforelimitorderr6r7r8r9str | NotGivenint | NotGiven!Literal['asc', 'desc'] | NotGivenzSyncCursorPage[ThreadMessage] rCrerfrgrhr6r7r8r9r)c CsNddi|p i}|jd|dttt|||| t||||dtjdtdSa  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 rGrHrIrJ)rerfrgrh)r6r7r8r9query)pagerOmodel) _get_api_listrrrrrMessageListParams r.rCrerfrgrhr6r7r8r9r1r1r2lists(+ z Messages.list __name__ __module__ __qualname____annotations__r,r rTr]rcrt __classcell__r1r1r/r2r!s<  $C& ,c seZdZUded<ded<dddfdd Zeed d d ed d d d dddddddd ddZd d d edd d ddddddddZed d d edd d dddddddddZeeeed d d ed d d!d!d"d#ddddd$d% d&d'Z Z S)(r"r r#AsyncMessagesWithRawResponser%r r&r'cs$t|t||_t||_dSr*)r+r,r r#r{r%r-r/r1r2r,s  zAsyncMessages.__init__Nr3r:r;r<r=r>r?r@rArrBc sNddi|p i}|jd|dt||||dtjt|||| dtdIdHS) rFrGrHrIrJrKrLrMNrQrSr1r1r2rTs *  zAsyncMessages.createrLrUcs>ddi|p i}|jd|d|t||||dtdIdHS)rWrGrHrIrXrLrYNrZr\r1r1r2r]3szAsyncMessages.retriever^r_c sLddi|p i}|jd|d|td|itjt||||dtdIdHS) r`rGrHrIrXr5rLrMNrarbr1r1r2rcTszAsyncMessages.updaterdrirjrkz=AsyncPaginator[ThreadMessage, AsyncCursorPage[ThreadMessage]]rlc CsNddi|p i}|jd|dttt|||| t||||dtjdtdSrm)rqrrrrrrrrsr1r1r2rt|s(+ zAsyncMessages.listrur1r1r/r2r"s<  $C& ,c@seZdZdddddZdS)r$r!r&messagesr)cCs@t|j|_t|j|_t|j|_t|j|_t|j|_dSr*)r r#rrTr]rcrtr.r}r1r1r2r,s z MessagesWithRawResponse.__init__Nrvrwrxr,r1r1r1r2r$sr$c@seZdZdddddZdS)r{r"r&r|cCs@t|j|_t|j|_t|j|_t|j|_t|j|_dSr*)r r#rrTr]rcrtr~r1r1r2r,s z%AsyncMessagesWithRawResponse.__init__Nrr1r1r1r2r{sr{)/ __future__rtypingrrrZtyping_extensionsrZhttpxr#rr r r _typesr rrrr_utilsrZ _resourcerr _responserrZ paginationrrZ _base_clientrrZtypes.beta.threadsrrrrZ_clientrr __all__r!r"r$r{r1r1r1r2s(   QQ