jfOddlZddlmZmZddlmZddlmZmZddl m Z ddl m Z dd l mZdd lmZdd lmZdd lmZdd lmZddlmZejejdZGddZGddZdS)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)AsyncRawScimClient RawScimClient) EmptyResponse)ResourceTypesResponse)SchemasResponse) ScimEmail)ScimName)ScimUser)ScimUsersListResponse)ServiceProviderConfig.c8eZdZdefdZedefdZdddej e de fdZ dddej e de fd Zdddej e defd Zddddd d ej ed ej edej edej e def dZeeedddededej ejedej edej edej e defdZdddedej e defdZdddedej e defdZdS) ScimClientclient_wrapperc0t||_dSN)r)r _raw_clientselfrs b/lsinfo/ai/hellotax_ai/base_platform/venv/lib/python3.11/site-packages/langfuse/api/scim/client.py__init__zScimClient.__init__s(GGGreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawScimClient rrs rwith_raw_responsezScimClient.with_raw_response rNrequest_optionsr$cF|j|}|jS)a Get SCIM Service Provider Configuration (requires organization-scoped API key) Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ServiceProviderConfig Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.scim.get_service_provider_config() r#rget_service_provider_configdatarr$ _responses rr'z&ScimClient.get_service_provider_config$s/:$@@+A  ~rcF|j|}|jS)a Get SCIM Resource Types (requires organization-scoped API key) Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ResourceTypesResponse Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.scim.get_resource_types() r#rget_resource_typesr(r)s rr-zScimClient.get_resource_typesFs%:$777XX ~rcF|j|}|jS)a Get SCIM Schemas (requires organization-scoped API key) Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- SchemasResponse Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.scim.get_schemas() r#r get_schemasr(r)s rr0zScimClient.get_schemasfs%:$000QQ ~rfilter start_indexcountr$r2r3r4cL|j||||}|jS)a0 List users in the organization (requires organization-scoped API key) Parameters ---------- filter : typing.Optional[str] Filter expression (e.g. userName eq "value") start_index : typing.Optional[int] 1-based index of the first result to return (default 1) count : typing.Optional[int] Maximum number of results to return (default 100) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ScimUsersListResponse Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.scim.list_users() r1r list_usersr(rr2r3r4r$r*s rr7zScimClient.list_userss8V$//#+ 0  ~remailsactivepasswordr$ user_namenamer:r;r<cP|j||||||}|jS)a Create a new user in the organization (requires organization-scoped API key) Parameters ---------- user_name : str User's email address (required) name : ScimName User's name information emails : typing.Optional[typing.Sequence[ScimEmail]] User's email addresses active : typing.Optional[bool] Whether the user is active password : typing.Optional[str] Initial password for the user request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ScimUser Examples -------- from langfuse import LangfuseAPI from langfuse.scim import ScimName client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.scim.create_user( user_name="userName", name=ScimName(), ) r=r>r:r;r<r$r create_userr(rr=r>r:r;r<r$r*s rrBzScimClient.create_users>n$00+ 1  ~ruser_idcH|j||}|jS)a& Get a specific user by ID (requires organization-scoped API key) Parameters ---------- user_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ScimUser Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.scim.get_user( user_id="userId", ) r#rget_userr(rrDr$r*s rrGzScimClient.get_users(B$--g-WW ~rcH|j||}|jS)a Remove a user from the organization (requires organization-scoped API key). Note that this only removes the user from the organization but does not delete the user entity itself. Parameters ---------- user_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- EmptyResponse Examples -------- from langfuse import LangfuseAPI client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.scim.delete_user( user_id="userId", ) r#r delete_userr(rHs rrKzScimClient.delete_users1B$00 _1  ~r)__name__ __module__ __qualname__rrpropertyr r!typingOptionalrrr'r r-r r0strintrr7OMITrSequencer boolrrBrGr rKrrrrsH*;HHHH =   X EI   "(/."A      FEI"(/."A BEI"(/."A F(,,0&*;? 111$1_S) 1 s# 1  8 1 1111p?C(,)-;????? ?  :; ? % ?/#&? 8? ????DSW""""060O" """"JSW$$$$060O$ $$$$$$rrc8eZdZdefdZedefdZdddej e de fdZ dddej e de fd Zdddej e defd Zddddd d ej ed ej edej edej e def dZeeedddededej ejedej edej edej e defdZdddedej e defdZdddedej e defdZdS)AsyncScimClientrc0t||_dSr)rrrs rrzAsyncScimClient.__init__Fs-^LLLrrc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawScimClient rr s rr!z!AsyncScimClient.with_raw_responseIr"rNr#r$cVK|j|d{V}|jS)a Get SCIM Service Provider Configuration (requires organization-scoped API key) Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ServiceProviderConfig Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.scim.get_service_provider_config() asyncio.run(main()) r#Nr&r)s rr'z+AsyncScimClient.get_service_provider_configTsRJ*FF+G        ~rcVK|j|d{V}|jS)ak Get SCIM Resource Types (requires organization-scoped API key) Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ResourceTypesResponse Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.scim.get_resource_types() asyncio.run(main()) r#Nr,r)s rr-z"AsyncScimClient.get_resource_types~sQJ*==+>        ~rcVK|j|d{V}|jS)aW Get SCIM Schemas (requires organization-scoped API key) Parameters ---------- request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- SchemasResponse Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.scim.get_schemas() asyncio.run(main()) r#Nr/r)s rr0zAsyncScimClient.get_schemass<J*666WWWWWWWW ~rr1r2r3r4c\K|j||||d{V}|jS)a List users in the organization (requires organization-scoped API key) Parameters ---------- filter : typing.Optional[str] Filter expression (e.g. userName eq "value") start_index : typing.Optional[int] 1-based index of the first result to return (default 1) count : typing.Optional[int] Maximum number of results to return (default 100) request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ScimUsersListResponse Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.scim.list_users() asyncio.run(main()) r1Nr6r8s rr7zAsyncScimClient.list_userssZf*55#+ 6        ~rr9r=r>r:r;r<c`K|j||||||d{V}|jS)ai Create a new user in the organization (requires organization-scoped API key) Parameters ---------- user_name : str User's email address (required) name : ScimName User's name information emails : typing.Optional[typing.Sequence[ScimEmail]] User's email addresses active : typing.Optional[bool] Whether the user is active password : typing.Optional[str] Initial password for the user request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ScimUser Examples -------- import asyncio from langfuse import AsyncLangfuseAPI from langfuse.scim import ScimName client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.scim.create_user( user_name="userName", name=ScimName(), ) asyncio.run(main()) r@NrArCs rrBzAsyncScimClient.create_user s`~*66+ 7        ~rrDcXK|j||d{V}|jS)a Get a specific user by ID (requires organization-scoped API key) Parameters ---------- user_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- ScimUser Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.scim.get_user( user_id="userId", ) asyncio.run(main()) r#NrFrHs rrGzAsyncScimClient.get_userTsSR*33 _4        ~rcXK|j||d{V}|jS)a Remove a user from the organization (requires organization-scoped API key). Note that this only removes the user from the organization but does not delete the user entity itself. Parameters ---------- user_id : str request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- EmptyResponse Examples -------- import asyncio from langfuse import AsyncLangfuseAPI client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.scim.delete_user( user_id="userId", ) asyncio.run(main()) r#NrJrHs rrKzAsyncScimClient.delete_usersSR*66 _7        ~r)rLrMrNrrrOrr!rPrQrrr'r r-r r0rRrSrr7rTrrUr rVrrBrGr rKrWrrrYrYEsM*<MMMM #5   X EI((("(/."A( ((((VEI((("(/."A( ((((VEI&&&"(/."A& &&&&V(,,0&*;? 999$9_S) 9 s# 9  8 9 9999@?C(,)-;?GGGG G  :; G % G/#&G 8G GGGGTSW,,,,060O, ,,,,^SW,,,,060O, ,,,,,,rrY)rPcore.client_wrapperrrcore.request_optionsr raw_clientrr types.empty_responser types.resource_types_responser types.schemas_responser types.scim_emailr types.scim_namertypes.scim_userrtypes.scim_users_list_responsertypes.service_provider_configrcastAnyrTrrYrWrrrpsf GGGGGGGG11111199999999//////@@@@@@333333''''''%%%%%%%%%%%%AAAAAA@@@@@@v{6:s##mmmmmmmm` iiiiiiiiiir