$%hqlddlmZddlmZmZmZddlmZddlZddl 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.GddeZ/GddeZ0GddZ1GddZ2GddZ3GddZ4y)) 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)Metadata)MessageDeleted)MessageContentPartParamMessages AsyncMessagesc FeZdZed dZeddZeeddded ddZddded ddZeddded dd Z eeeeeddded dd Z ddded dd Z y)r!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 )MessagesWithRawResponseselfs d/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/openai/resources/beta/threads/messages.pywith_raw_responsezMessages.with_raw_responses't,,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 )MessagesWithStreamingResponser's r)with_streaming_responsez Messages.with_streaming_response)s-T22r+N attachmentsmetadata extra_headers extra_query extra_bodytimeoutc |std|ddi|xsi}|jd|dt||||dtjt |||| t S) / 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/ /messagescontentroler1r2r3r4r5r6bodyoptionscast_to) ValueError_postrrMessageCreateParamsrr r( thread_idr?r@r1r2r3r4r5r6s r)createzMessages.create2s\WXaWdef f&QMNrArB)rFrGrrrHrrrIs r)rKzAsyncMessages.createHs\WXaWdef f&QMB?BBr\c |std|ddi|xsi}|jd|dttt ||| | t |||||dt jtSrc)rFrgrrrrrrhris r)rjzAsyncMessages.lists\WXaWdef f&QM> OO  )@@     '>> OO  %<< MM  '>> OO  r+Nrr!rpNonerrrrrr+r)r&r&J r+r&ceZdZddZy)rcz||_tj|j|_tj|j|_tj|j |_tj|j |_tj|j|_yr)rr async_to_raw_response_wrapperrKrUr[rjrors r)rz%AsyncMessagesWithRawResponse.__init__`s!&DD OO  )FF     'DD OO  %BB MM  'DD OO  r+Nrr"rprrrr+r)rr_rr+rceZdZddZy)r.c||_t|j|_t|j|_t|j|_t|j |_t|j |_yr)rrrKrUr[rjrors r)rz&MessagesWithStreamingResponse.__init__usr!2 OO  5     3 OO  1 MM  3 OO  r+Nrrrr+r)r.r.trr+r.ceZdZddZy)rc||_t|j|_t|j|_t|j|_t|j |_t|j |_yr)rrrKrUr[rjrors r)rz+AsyncMessagesWithStreamingResponse.__init__sr!8 OO  ;     9 OO  7 MM  9 OO  r+Nrrrr+r)rrrr+r)5 __future__rtypingrrrtyping_extensionsrhttpxr _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.rrr+r)rs#,,% !@@=';Z:ed25AU  'S S lS $S l  *  *  *  r+