OjJxddlmZddlmZddlZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZmZddlmZdd lmZmZdd lmZmZdd lmZmZdd lmZm Z dd l!m"Z"m#Z#ddl$m%Z%ddl&m'Z'ddl(m)Z)ddl*m+Z+ddgZ,GddeZ-GddeZ.GddZ/GddZ0GddZ1GddZ2y)) annotations)LiteralN)_legacy_response)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncNextCursorPageAsyncNextCursorPage)AsyncPaginatormake_request_options)user_list_paramsuser_create_params)UserCreateResponse)UserDeleteResponse)UserRetrieveResponse)OrganizationGroupUserUsers AsyncUsersceZdZed dZed dZddded d dZddded d dZe e e ddded ddZ 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 )UsersWithRawResponseselfs /var/www/origus_pro_usr/data/www/origus.pro/core/.venv/lib/python3.12/site-packages/openai/resources/admin/organization/groups/users.pywith_raw_responsezUsers.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 )UsersWithStreamingResponser&s r(with_streaming_responsezUsers.with_streaming_response%s*$//r*N extra_headers extra_query extra_bodytimeoutc |std||jtd|td|itj t ||||dditS)  Adds a user to a group. Args: user_id: Identifier of the user to add to the group. 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 7Expected a non-empty value for `group_id` but received %/organization/groups/{group_id}/usersgroup_iduser_idadmin_api_key_authTr0r1r2r3securitybodyoptionscast_to) ValueError_postrrrUserCreateParamsrrr'r9r:r0r1r2r3s r(createz Users.create.st4VW_Vbcd dzz AH U )W!57I7Z7Z[(+'%.5 '  r*c |std||std||jtd||t||||dditS) P Retrieves a user in a group. 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 r66Expected a non-empty value for `user_id` but received //organization/groups/{group_id}/users/{user_id}r9r:r;Tr<r@rArB_getrrrr'r:r9r0r1r2r3s r(retrievezUsers.retrieveWsz0VW_Vbcd dUV]U`ab byy KV^ho p(+'%.5 )  r*afterlimitorderr0r1r2r3c|std||jtd|ttt ||||t |||dtjdditS a Lists the users assigned to a group. Args: after: A cursor for use in pagination. Provide the ID of the last user from the previous list response to retrieve the next page. limit: A limit on the number of users to be returned. Limit can range between 0 and 1000, and the default is 100. order: Specifies the sort order of users in the list. 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 r6r7r8)rRrSrTr;T)r0r1r2r3queryr=)pager@model) rB _get_api_listrrrrrrUserListParams r'r9rRrSrTr0r1r2r3s r(listz Users.listsDVW_Vbcd d!! AH U#$9:(+'%%!&!&!& %33 /5(%"  r*c |std||std||jtd||t||||dditS) P Removes a user from a group. 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 r6rIrJrKr;Tr<rLrB_deleterrrrOs r(deletez Users.deletesz0VW_Vbcd dUV]U`ab b|| KV^ho p(+'%.5 '  r*)returnr%)rcr-r9strr:rer0Headers | Noner1 Query | Noner2 Body | Noner3(float | httpx2.Timeout | None | NotGivenrcrr:rer9rer0rfr1rgr2rhr3rircr)r9rerR str | OmitrS int | OmitrTLiteral['asc', 'desc'] | Omitr0rfr1rgr2rhr3rircz)SyncNextCursorPage[OrganizationGroupUser]r:rer9rer0rfr1rgr2rhr3rircr __name__ __module__ __qualname__rr)r.r rFrPr r]rbr*r(r r s**00)-$("&)rBrCrrrrDrrrEs r(rFzAsyncUsers.creates4VW_Vbcd dZZ AH U,i-ACUCfCfgg(+'%.5 '   g  s$AA5 A1 "A5,A3-A53A5c K|std||std||jtd||t||||dditd {S7w) rHr6rIrJrKr;Tr<rLNrMrOs r(rPzAsyncUsers.retrieves0VW_Vbcd dUV]U`ab bYY KV^ho p(+'%.5 )    AA!AA!rQc|std||jtd|ttt ||||t |||dtjdditSrV) rBrZrrrrrrr[r\s r(r]zAsyncUsers.listFsDVW_Vbcd d!! AH U$%:;(+'%%!&!&!& %33 /5(%"  r*c K|std||std||jtd||t||||dditd {S7w) r_r6rIrJrKr;Tr<rLNr`rOs r(rbzAsyncUsers.deletes0VW_Vbcd dUV]U`ab b\\ KV^ho p(+'%.5 '"    r{)rcrv)rcrxrdrj)r9rerRrkrSrlrTrmr0rfr1rgr2rhr3rirczQAsyncPaginator[OrganizationGroupUser, AsyncNextCursorPage[OrganizationGroupUser]]rnrorsr*r(r!r!s//55)-$("&> LL  )@@ NN  %<< JJ  '>> LL  r*Nrr rcNonerprqrrrrsr*r(r%r% r*r%ceZdZddZy)rvc2||_tj|j|_tj|j|_tj|j |_tj|j |_yr)rrasync_to_raw_response_wrapperrFrPr]rbrs r(rz"AsyncUsersWithRawResponse.__init__ss &DD LL  )FF NN  %BB JJ  'DD LL  r*Nrr!rcrrrsr*r(rvrvrr*rvceZdZddZy)r-c||_t|j|_t|j|_t|j|_t|j |_yr)rrrFrPr]rbrs r(rz#UsersWithStreamingResponse.__init__s[ 2 LL  5 NN  1 JJ  3 LL  r*Nrrrsr*r(r-r-rr*r-ceZdZddZy)rxc||_t|j|_t|j|_t|j|_t|j |_yr)rrrFrPr]rbrs r(rz(AsyncUsersWithStreamingResponse.__init__s[ 8 LL  ; NN  7 JJ  9 LL  r*Nrrrsr*r(rxrxrr*rx)3 __future__rtyping_extensionsrhttpx2r_typesrrr r r r r _utilsrrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.admin.organization.groupsrr4types.admin.organization.groups.user_create_responser4types.admin.organization.groups.user_delete_responser6types.admin.organization.groups.user_retrieve_responser7types.admin.organization.groups.organization_group_userr__all__r r!r%rvr-rxrsr*r(rs#% "MMMMM(<[CBUXX\^ L !D OD ND !D N  $  $  $  r*