qi^ddlmZddlmZmZmZmZddlmZddl Z ddl m Z ddl m Z mZmZmZmZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZdd lm Z m!Z!dd l"m#Z#m$Z$ddl%m&Z&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddgZ3GddeZ4GddeZ5GddZ6GddZ7GddZ8GddZ9y) ) annotations)AnyListIterablecast)LiteralN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given)maybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncConversationCursorPageAsyncConversationCursorPage)AsyncPaginatormake_request_options)item_list_paramsitem_create_paramsitem_retrieve_params) Conversation)ResponseIncludable)ConversationItem)ResponseInputItemParam)ConversationItemListItems AsyncItemsc  eZdZdZed dZed dZeddded ddZ eddded ddZ eeeeddded dd Z ddded  dd Z y)r%,Manage conversations and conversation items.ct|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 )ItemsWithRawResponseselfs V/opt/pipecat/venv/lib/python3.12/site-packages/openai/resources/conversations/items.pywith_raw_responsezItems.with_raw_responses$D))ct|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 )ItemsWithStreamingResponser,s r.with_streaming_responsezItems.with_streaming_response)s*$//r0Ninclude extra_headers extra_query extra_bodytimeoutc|std||jd|dtd|itjt ||||td|itjt S) Create items in a conversation with the given ID. Args: items: The items to add to the conversation. You may add up to 20 items at a time. include: Additional fields to include in the response. See the `include` parameter for [listing Conversation items above](https://platform.openai.com/docs/api-reference/conversations/list-items#conversations_list_items-include) for more information. 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 >Expected a non-empty value for `conversation_id` but received /conversations//itemsitemsr6r7r8r9r:querybodyoptionscast_to) ValueError_postrrItemCreateParamsrr$r-conversation_idr@r6r7r8r9r:s r.createz Items.create2s>]^m]pqr rzzo.f 5 '5!13E3V3VW(+'%%y'&:/items/r6rArErF) rGrr"_getrrrItemRetrieveParamsrr-item_idrKr6r7r8r9r:s r.retrievezItems.retrieve`s:]^m]pqr rUV]U`ab b  II!/!2''C,"/ +)#)9g*>@T@g@gh S"23    r0afterr6limitorderr7r8r9r:c|std||jd|dttt |||| t ||||dt jtttSa List all items for a conversation with the given ID. Args: after: An item ID to list items after, used in pagination. include: Specify additional output data to include in the model response. Currently supported values are: - `web_search_call.action.sources`: Include the sources of the web search tool call. - `code_interpreter_call.outputs`: Includes the outputs of python code execution in code interpreter tool call items. - `computer_call_output.output.image_url`: Include image urls from the computer call output. - `file_search_call.results`: Include the search results of the file search tool call. - `message.input_image.image_url`: Include image urls from the input message. - `message.output_text.logprobs`: Include logprobs with assistant messages. - `reasoning.encrypted_content`: Includes an encrypted version of reasoning tokens in reasoning item outputs. This enables reasoning items to be used in multi-turn conversations when using the Responses API statelessly (like when the `store` parameter is set to `false`, or when an organization is enrolled in the zero data retention program). limit: A limit on the number of objects to be returned. Limit can range between 1 and 100, and the default is 20. order: The order to return the input items in. Default is `desc`. - `asc`: Return the input items in ascending order. - `desc`: Return the input items in 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 r=r>r?)rXr6rYrZrA)pagerEmodel) rG _get_api_listrr"rrrItemListParamsrr r-rKrXr6rYrZr7r8r9r:s r.listz Items.listsp]^m]pqr r!!o.f 5+,<=(+'%%!&#*!&!&  %33 s,-%"  r0r7r8r9r:c |std||std||jd|d|t||||tS)j Delete an item from a conversation with the given IDs. 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 r=rOr>rPrcrQrG_deleterr r-rUrKr7r8r9r:s r.deletez Items.deletess0]^m]pqr rUV]U`ab b||o.ggY ?(+Q[el!   r0)returnr+)rjr3rKstrr@z Iterable[ResponseInputItemParam]r6List[ResponseIncludable] | Omitr7Headers | Noner8 Query | Noner9 Body | Noner:'float | httpx.Timeout | None | NotGivenrjr$rUrlrKrlr6rmr7rnr8ror9rpr:rqrjr")rKrlrX str | Omitr6rmrY int | OmitrZLiteral['asc', 'desc'] | Omitr7rnr8ror9rpr:rqrjz,SyncConversationCursorPage[ConversationItem]rUrlrKrlr7rnr8ror9rpr:rqrjr __name__ __module__ __qualname____doc__rr/r4rrrLrVrbrir0r.r%r%s6**0048)-$("&;D, , 0 , 1 , &, ",  , 9,  , f48)-$("&;D. .  . 1 . &. ".  . 9.  . h!37 /3)-$("&;DM M  M 1 M  M -M &M "M  M 9M  6M l)-$("&;D" "  " &" ""  " 9"  " r0c  eZdZdZed dZed dZeddded ddZ eddded ddZ eeeeddded dd Z ddded  dd Z y)r&r(ct|Sr*)AsyncItemsWithRawResponser,s r.r/zAsyncItems.with_raw_responses)..r0ct|Sr2)AsyncItemsWithStreamingResponser,s r.r4z"AsyncItems.with_streaming_responses/t44r0Nr5c$K|std||jd|dtd|itjd{t ||||td|itjd{t d{S7G77w) r<r=r>r?r@Nr6rArC)rGrHrrrIrr$rJs r.rLzAsyncItems.creates>]^m]pqr rZZo.f 5,gu-=?Q?b?bcc(+'%19g2FHZHkHkll )   c m  s6ABB +B.B /BBB BBc6K|std||std|tt|jd|d|t ||||t d|it jd{tttd{S7-7 w) rNr=rOr>rPr6NrArQ) rGrr"rRrrrrSrrTs r.rVzAsyncItems.retrieveHs:]^m]pqr rUV]U`ab b ))!/!2''C,"/ +)# 5y'6JL`LsLs tt S"23    u s$A%B'B($B B BBrWc|std||jd|dttt |||| t ||||dt jtttSr\) rGr_rr"rrrr`rrras r.rbzAsyncItems.listxsp]^m]pqr r!!o.f 5,-=>(+'%%!&#*!&!&  %33 s,-%"  r0rcc K|std||std||jd|d|t||||td{S7w)rer=rOr>rPrcrQNrfrhs r.rizAsyncItems.deletes0]^m]pqr rUV]U`ab b\\o.ggY ?(+Q[el! "    sAAAA)rjr)rjrrkrr)rKrlrXrsr6rmrYrtrZrur7rnr8ror9rpr:rqrjzOAsyncPaginator[ConversationItem, AsyncConversationCursorPage[ConversationItem]]rvrwr|r0r.r&r&s6//5548)-$("&;D, , 0 , 1 , &, ",  , 9,  , f48)-$("&;D. .  . 1 . &. ".  . 9.  . h!37 /3)-$("&;DM M  M 1 M  M -M &M "M  M 9M  YM l)-$("&;D" "  " &" ""  " 9"  " r0ceZdZddZy)r+c2||_tj|j|_tj|j|_tj|j |_tj|j |_yN)_itemsr to_raw_response_wrapperrLrVrbrir-r@s r.__init__zItemsWithRawResponse.__init__ss &>> LL  )@@ NN  %<< JJ  '>> LL  r0Nr@r%rjNonerxryrzrr|r0r.r+r+ r0r+ceZdZddZy)rc2||_tj|j|_tj|j|_tj|j |_tj|j |_yr)rr async_to_raw_response_wrapperrLrVrbrirs r.rz"AsyncItemsWithRawResponse.__init__ss &DD LL  )FF NN  %BB JJ  'DD LL  r0Nr@r&rjrrr|r0r.rrrr0rceZdZddZy)r3c||_t|j|_t|j|_t|j|_t|j |_yr)rrrLrVrbrirs r.rz#ItemsWithStreamingResponse.__init__s[ 2 LL  5 NN  1 JJ  3 LL  r0Nrrr|r0r.r3r3rr0r3ceZdZddZy)rc||_t|j|_t|j|_t|j|_t|j |_yr)rrrLrVrbrirs r.rz(AsyncItemsWithStreamingResponse.__init__#s[ 8 LL  ; NN  7 JJ  9 LL  r0Nrrr|r0r.rr"rr0r): __future__rtypingrrrrtyping_extensionsrhttpxr _typesr r r rrrr_utilsrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.conversationsrrr types.conversations.conversationr #types.responses.response_includabler!%types.conversations.conversation_itemr")types.responses.response_input_item_paramr#*types.conversations.conversation_item_listr$__all__r%r&r+rr3rr|r0r.rs#,,% KKK<&:YQ@]]<EEON L !e Oe Pe !e P  $  $  $  r0