from __future__ import annotations from typing_extensions import Literal import httpx2 from ...._types import Body, Omit, Query, Headers, NotGiven, SequenceNotStr, omit, not_given from ...._utils import path_template from ...._compat import cached_property from ...._resource import SyncAPIResource, AsyncAPIResource from ...._response import ( to_raw_response_wrapper, to_streamed_response_wrapper, async_to_raw_response_wrapper, async_to_streamed_response_wrapper, ) from ....pagination import SyncPage, AsyncPage from ...._base_client import AsyncPaginator, make_request_options from ....types.beta.organization.user_remove_response import UserRemoveResponse from ....types.beta.organization.beta_organization_user import BetaOrganizationUser __all__ = ["Users", "AsyncUsers"] class Users(SyncAPIResource): @cached_property def with_raw_response(self) -> UsersWithRawResponse: """ 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/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers """ return UsersWithRawResponse(self) @cached_property def with_streaming_response(self) -> UsersWithStreamingResponse: """ An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response """ return UsersWithStreamingResponse(self) def retrieve( self, user_id: str, *, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> BetaOrganizationUser: """ Retrieve a member of the organization by user ID. Args: user_id: ID of the User. 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 """ if not user_id: raise ValueError(f"Expected a non-empty value for `user_id` but received {user_id!r}") return self._get( path_template("/v1/organizations/users/{user_id}?beta=true", user_id=user_id), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=BetaOrganizationUser, ) def update( self, user_id: str, *, role: Literal["billing", "claude_code_user", "developer", "managed", "user"], # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> BetaOrganizationUser: """ Update a member's organization role. Args: user_id: ID of the User. role: New role for the User. The accepted values depend on the organization type. Console and API organizations accept `user`, `developer`, `billing`, and `claude_code_user`; `admin` cannot be assigned through the API. Claude Enterprise organizations accept `user` and `managed`. 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 """ if not user_id: raise ValueError(f"Expected a non-empty value for `user_id` but received {user_id!r}") return self._post( path_template("/v1/organizations/users/{user_id}?beta=true", user_id=user_id), body={"role": role}, options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=BetaOrganizationUser, ) def list( self, *, after_id: str | Omit = omit, before_id: str | Omit = omit, email: str | Omit = omit, limit: int | Omit = omit, roles: SequenceNotStr[str] | Omit = omit, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> SyncPage[BetaOrganizationUser]: """ List the organization's members. Args: after_id: ID of the object to use as a cursor for pagination. When provided, returns the page of results immediately after this object. before_id: ID of the object to use as a cursor for pagination. When provided, returns the page of results immediately before this object. email: Filter by user email. limit: Number of items to return per page. Defaults to `20`. Ranges from `1` to `1000`. roles: Filter to items whose `role` equals one of the supplied values. Repeatable; values are OR'ed together. Accepted values depend on the organization type: Console and API organizations accept `user`, `developer`, `billing`, `admin`, and `claude_code_user`; Claude Enterprise organizations accept `user`, `owner`, `primary_owner`, `membership_admin`, and `managed`. 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 """ return self._get_api_list( "/v1/organizations/users?beta=true", page=SyncPage[BetaOrganizationUser], options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout, query={ "after_id": after_id, "before_id": before_id, "email": email, "limit": limit, "roles": roles, }, ), model=BetaOrganizationUser, ) def remove( self, user_id: str, *, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> UserRemoveResponse: """ Remove a member from the organization. Args: user_id: ID of the User. 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 """ if not user_id: raise ValueError(f"Expected a non-empty value for `user_id` but received {user_id!r}") return self._delete( path_template("/v1/organizations/users/{user_id}?beta=true", user_id=user_id), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=UserRemoveResponse, ) class AsyncUsers(AsyncAPIResource): @cached_property def with_raw_response(self) -> AsyncUsersWithRawResponse: """ 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/anthropics/anthropic-sdk-python#accessing-raw-response-data-eg-headers """ return AsyncUsersWithRawResponse(self) @cached_property def with_streaming_response(self) -> AsyncUsersWithStreamingResponse: """ An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/anthropics/anthropic-sdk-python#with_streaming_response """ return AsyncUsersWithStreamingResponse(self) async def retrieve( self, user_id: str, *, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> BetaOrganizationUser: """ Retrieve a member of the organization by user ID. Args: user_id: ID of the User. 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 """ if not user_id: raise ValueError(f"Expected a non-empty value for `user_id` but received {user_id!r}") return await self._get( path_template("/v1/organizations/users/{user_id}?beta=true", user_id=user_id), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=BetaOrganizationUser, ) async def update( self, user_id: str, *, role: Literal["billing", "claude_code_user", "developer", "managed", "user"], # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> BetaOrganizationUser: """ Update a member's organization role. Args: user_id: ID of the User. role: New role for the User. The accepted values depend on the organization type. Console and API organizations accept `user`, `developer`, `billing`, and `claude_code_user`; `admin` cannot be assigned through the API. Claude Enterprise organizations accept `user` and `managed`. 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 """ if not user_id: raise ValueError(f"Expected a non-empty value for `user_id` but received {user_id!r}") return await self._post( path_template("/v1/organizations/users/{user_id}?beta=true", user_id=user_id), body={"role": role}, options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=BetaOrganizationUser, ) def list( self, *, after_id: str | Omit = omit, before_id: str | Omit = omit, email: str | Omit = omit, limit: int | Omit = omit, roles: SequenceNotStr[str] | Omit = omit, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> AsyncPaginator[BetaOrganizationUser, AsyncPage[BetaOrganizationUser]]: """ List the organization's members. Args: after_id: ID of the object to use as a cursor for pagination. When provided, returns the page of results immediately after this object. before_id: ID of the object to use as a cursor for pagination. When provided, returns the page of results immediately before this object. email: Filter by user email. limit: Number of items to return per page. Defaults to `20`. Ranges from `1` to `1000`. roles: Filter to items whose `role` equals one of the supplied values. Repeatable; values are OR'ed together. Accepted values depend on the organization type: Console and API organizations accept `user`, `developer`, `billing`, `admin`, and `claude_code_user`; Claude Enterprise organizations accept `user`, `owner`, `primary_owner`, `membership_admin`, and `managed`. 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 """ return self._get_api_list( "/v1/organizations/users?beta=true", page=AsyncPage[BetaOrganizationUser], options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout, query={ "after_id": after_id, "before_id": before_id, "email": email, "limit": limit, "roles": roles, }, ), model=BetaOrganizationUser, ) async def remove( self, user_id: str, *, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx2.Timeout | None | NotGiven = not_given, ) -> UserRemoveResponse: """ Remove a member from the organization. Args: user_id: ID of the User. 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 """ if not user_id: raise ValueError(f"Expected a non-empty value for `user_id` but received {user_id!r}") return await self._delete( path_template("/v1/organizations/users/{user_id}?beta=true", user_id=user_id), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=UserRemoveResponse, ) class UsersWithRawResponse: def __init__(self, users: Users) -> None: self._users = users self.retrieve = to_raw_response_wrapper( users.retrieve, ) self.update = to_raw_response_wrapper( users.update, ) self.list = to_raw_response_wrapper( users.list, ) self.remove = to_raw_response_wrapper( users.remove, ) class AsyncUsersWithRawResponse: def __init__(self, users: AsyncUsers) -> None: self._users = users self.retrieve = async_to_raw_response_wrapper( users.retrieve, ) self.update = async_to_raw_response_wrapper( users.update, ) self.list = async_to_raw_response_wrapper( users.list, ) self.remove = async_to_raw_response_wrapper( users.remove, ) class UsersWithStreamingResponse: def __init__(self, users: Users) -> None: self._users = users self.retrieve = to_streamed_response_wrapper( users.retrieve, ) self.update = to_streamed_response_wrapper( users.update, ) self.list = to_streamed_response_wrapper( users.list, ) self.remove = to_streamed_response_wrapper( users.remove, ) class AsyncUsersWithStreamingResponse: def __init__(self, users: AsyncUsers) -> None: self._users = users self.retrieve = async_to_streamed_response_wrapper( users.retrieve, ) self.update = async_to_streamed_response_wrapper( users.update, ) self.list = async_to_streamed_response_wrapper( users.list, ) self.remove = async_to_streamed_response_wrapper( users.remove, )