feat(api): manual updates (#20)

Author: stainless-app[bot]

.stats.yml

@@ -1,2 +1,2 @@
-configured_endpoints: 6
+configured_endpoints: 7
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/openint%2Fopenint-603899f0fe4bb2708f918f1c736c2f244adce7936136aeeb3b45f727d209b4af.yml

api.md

@@ -8,6 +8,7 @@ from openint.types import (
     CreateMagicLinkResponse,
     CreateTokenResponse,
     GetConnectionResponse,
+    GetCurrentUserResponse,
     ListConnectionConfigsResponse,
     ListConnectionsResponse,
 )
@@ -19,5 +20,6 @@ Methods:
 - <code title="post /customer/{customer_id}/magic-link">client.<a href="./src/openint/_client.py">create_magic_link</a>(customer_id, \*\*<a href="src/openint/types/client_create_magic_link_params.py">params</a>) -> <a href="./src/openint/types/create_magic_link_response.py">CreateMagicLinkResponse</a></code>
 - <code title="post /customer/{customer_id}/token">client.<a href="./src/openint/_client.py">create_token</a>(customer_id, \*\*<a href="src/openint/types/client_create_token_params.py">params</a>) -> <a href="./src/openint/types/create_token_response.py">CreateTokenResponse</a></code>
 - <code title="get /connection/{id}">client.<a href="./src/openint/_client.py">get_connection</a>(id, \*\*<a href="src/openint/types/client_get_connection_params.py">params</a>) -> <a href="./src/openint/types/get_connection_response.py">GetConnectionResponse</a></code>
+- <code title="get /viewer">client.<a href="./src/openint/_client.py">get_current_user</a>() -> <a href="./src/openint/types/get_current_user_response.py">GetCurrentUserResponse</a></code>
 - <code title="get /connector-config">client.<a href="./src/openint/_client.py">list_connection_configs</a>(\*\*<a href="src/openint/types/client_list_connection_configs_params.py">params</a>) -> <a href="./src/openint/types/list_connection_configs_response.py">SyncOffsetPagination[ListConnectionConfigsResponse]</a></code>
 - <code title="get /connection">client.<a href="./src/openint/_client.py">list_connections</a>(\*\*<a href="src/openint/types/client_list_connections_params.py">params</a>) -> <a href="./src/openint/types/list_connections_response.py">SyncOffsetPagination[ListConnectionsResponse]</a></code>

src/openint/_client.py

@@ -55,6 +55,7 @@
 from .types.create_token_response import CreateTokenResponse
 from .types.get_connection_response import GetConnectionResponse
 from .types.check_connection_response import CheckConnectionResponse
+from .types.get_current_user_response import GetCurrentUserResponse
 from .types.list_connections_response import ListConnectionsResponse
 from .types.create_magic_link_response import CreateMagicLinkResponse
 from .types.list_connection_configs_response import ListConnectionConfigsResponse
@@ -480,6 +481,30 @@ def get_connection(
             ),
         )
 
+    def get_current_user(
+        self,
+        *,
+        # 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 | httpx.Timeout | None | NotGiven = NOT_GIVEN,
+    ) -> GetCurrentUserResponse:
+        """Get information about the current authenticated user"""
+        return cast(
+            GetCurrentUserResponse,
+            self.get(
+                "/viewer",
+                options=make_request_options(
+                    extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                ),
+                cast_to=cast(
+                    Any, GetCurrentUserResponse
+                ),  # Union types cannot be passed in as arguments in the type system
+            ),
+        )
+
     def list_connection_configs(
         self,
         *,
@@ -1147,6 +1172,30 @@ async def get_connection(
             ),
         )
 
+    async def get_current_user(
+        self,
+        *,
+        # 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 | httpx.Timeout | None | NotGiven = NOT_GIVEN,
+    ) -> GetCurrentUserResponse:
+        """Get information about the current authenticated user"""
+        return cast(
+            GetCurrentUserResponse,
+            await self.get(
+                "/viewer",
+                options=make_request_options(
+                    extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                ),
+                cast_to=cast(
+                    Any, GetCurrentUserResponse
+                ),  # Union types cannot be passed in as arguments in the type system
+            ),
+        )
+
     def list_connection_configs(
         self,
         *,
@@ -1410,6 +1459,9 @@ def __init__(self, client: Openint) -> None:
         self.get_connection = to_raw_response_wrapper(
             client.get_connection,
         )
+        self.get_current_user = to_raw_response_wrapper(
+            client.get_current_user,
+        )
         self.list_connection_configs = to_raw_response_wrapper(
             client.list_connection_configs,
         )
@@ -1432,6 +1484,9 @@ def __init__(self, client: AsyncOpenint) -> None:
         self.get_connection = async_to_raw_response_wrapper(
             client.get_connection,
         )
+        self.get_current_user = async_to_raw_response_wrapper(
+            client.get_current_user,
+        )
         self.list_connection_configs = async_to_raw_response_wrapper(
             client.list_connection_configs,
         )
@@ -1454,6 +1509,9 @@ def __init__(self, client: Openint) -> None:
         self.get_connection = to_streamed_response_wrapper(
             client.get_connection,
         )
+        self.get_current_user = to_streamed_response_wrapper(
+            client.get_current_user,
+        )
         self.list_connection_configs = to_streamed_response_wrapper(
             client.list_connection_configs,
         )
@@ -1476,6 +1534,9 @@ def __init__(self, client: AsyncOpenint) -> None:
         self.get_connection = async_to_streamed_response_wrapper(
             client.get_connection,
         )
+        self.get_current_user = async_to_streamed_response_wrapper(
+            client.get_current_user,
+        )
         self.list_connection_configs = async_to_streamed_response_wrapper(
             client.list_connection_configs,
         )

src/openint/types/__init__.py

@@ -5,6 +5,7 @@
 from .create_token_response import CreateTokenResponse as CreateTokenResponse
 from .get_connection_response import GetConnectionResponse as GetConnectionResponse
 from .check_connection_response import CheckConnectionResponse as CheckConnectionResponse
+from .get_current_user_response import GetCurrentUserResponse as GetCurrentUserResponse
 from .list_connections_response import ListConnectionsResponse as ListConnectionsResponse
 from .client_create_token_params import ClientCreateTokenParams as ClientCreateTokenParams
 from .create_magic_link_response import CreateMagicLinkResponse as CreateMagicLinkResponse

src/openint/types/get_current_user_response.py

@@ -0,0 +1,43 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import Dict, Union, Optional
+from typing_extensions import Literal, TypeAlias
+
+from pydantic import Field as FieldInfo
+
+from .._models import BaseModel
+
+__all__ = ["GetCurrentUserResponse", "Role", "UnionMember1", "UnionMember2", "UnionMember3"]
+
+
+class Role(BaseModel):
+    role: Literal["anon"]
+
+
+class UnionMember1(BaseModel):
+    customer_id: str = FieldInfo(alias="customerId")
+
+    org_id: str = FieldInfo(alias="orgId")
+
+    role: Literal["customer"]
+
+
+class UnionMember2(BaseModel):
+    role: Literal["user"]
+
+    user_id: str = FieldInfo(alias="userId")
+
+    extra: Optional[Dict[str, object]] = None
+
+    org_id: Optional[str] = FieldInfo(alias="orgId", default=None)
+
+
+class UnionMember3(BaseModel):
+    org_id: str = FieldInfo(alias="orgId")
+
+    role: Literal["org"]
+
+    extra: Optional[Dict[str, object]] = None
+
+
+GetCurrentUserResponse: TypeAlias = Union[Role, UnionMember1, UnionMember2, UnionMember3, Role]

tests/api_resources/test_client.py

@@ -12,6 +12,7 @@
 from openint.types import (
     CreateTokenResponse,
     GetConnectionResponse,
+    GetCurrentUserResponse,
     CheckConnectionResponse,
     CreateMagicLinkResponse,
     ListConnectionsResponse,
@@ -227,6 +228,34 @@ def test_path_params_get_connection(self, client: Openint) -> None:
                 id="",
             )
 
+    @pytest.mark.skip()
+    @parametrize
+    def test_method_get_current_user(self, client: Openint) -> None:
+        client_ = client.get_current_user()
+        assert_matches_type(GetCurrentUserResponse, client_, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    def test_raw_response_get_current_user(self, client: Openint) -> None:
+        response = client.with_raw_response.get_current_user()
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        client_ = response.parse()
+        assert_matches_type(GetCurrentUserResponse, client_, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    def test_streaming_response_get_current_user(self, client: Openint) -> None:
+        with client.with_streaming_response.get_current_user() as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            client_ = response.parse()
+            assert_matches_type(GetCurrentUserResponse, client_, path=["response"])
+
+        assert cast(Any, response.is_closed) is True
+
     @pytest.mark.skip()
     @parametrize
     def test_method_list_connection_configs(self, client: Openint) -> None:
@@ -514,6 +543,34 @@ async def test_path_params_get_connection(self, async_client: AsyncOpenint) -> N
                 id="",
             )
 
+    @pytest.mark.skip()
+    @parametrize
+    async def test_method_get_current_user(self, async_client: AsyncOpenint) -> None:
+        client = await async_client.get_current_user()
+        assert_matches_type(GetCurrentUserResponse, client, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    async def test_raw_response_get_current_user(self, async_client: AsyncOpenint) -> None:
+        response = await async_client.with_raw_response.get_current_user()
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        client = await response.parse()
+        assert_matches_type(GetCurrentUserResponse, client, path=["response"])
+
+    @pytest.mark.skip()
+    @parametrize
+    async def test_streaming_response_get_current_user(self, async_client: AsyncOpenint) -> None:
+        async with async_client.with_streaming_response.get_current_user() as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            client = await response.parse()
+            assert_matches_type(GetCurrentUserResponse, client, path=["response"])
+
+        assert cast(Any, response.is_closed) is True
+
     @pytest.mark.skip()
     @parametrize
     async def test_method_list_connection_configs(self, async_client: AsyncOpenint) -> None: