feat(api): update via SDK Studio

Author: stainless-app[bot]

README.md

@@ -29,11 +29,12 @@ The full API of this library can be found in [api.md](api.md).
 ```python
 from gitpod import Gitpod
 
-client = Gitpod()
-
-runner = client.runners.create(
-    connect_protocol_version=1,
+client = Gitpod(
+    connect_protocol_version=True,
+    connect_timeout_header=0,
 )
+
+runner = client.runners.create()
 print(runner.access_token)
 ```
 
@@ -50,13 +51,14 @@ Simply import `AsyncGitpod` instead of `Gitpod` and use `await` with each API ca
 import asyncio
 from gitpod import AsyncGitpod
 
-client = AsyncGitpod()
+client = AsyncGitpod(
+    connect_protocol_version=True,
+    connect_timeout_header=0,
+)
 
 
 async def main() -> None:
-    runner = await client.runners.create(
-        connect_protocol_version=1,
-    )
+    runner = await client.runners.create()
     print(runner.access_token)
 
 
@@ -87,12 +89,13 @@ All errors inherit from `gitpod.APIError`.
 import gitpod
 from gitpod import Gitpod
 
-client = Gitpod()
+client = Gitpod(
+    connect_protocol_version=True,
+    connect_timeout_header=0,
+)
 
 try:
-    client.runners.create(
-        connect_protocol_version=1,
-    )
+    client.runners.create()
 except gitpod.APIConnectionError as e:
     print("The server could not be reached")
     print(e.__cause__)  # an underlying Exception, likely raised within httpx.
@@ -132,12 +135,12 @@ from gitpod import Gitpod
 client = Gitpod(
     # default is 2
     max_retries=0,
+    connect_protocol_version=True,
+    connect_timeout_header=0,
 )
 
 # Or, configure per-request:
-client.with_options(max_retries=5).runners.create(
-    connect_protocol_version=1,
-)
+client.with_options(max_retries=5).runners.create()
 ```
 
 ### Timeouts
@@ -152,17 +155,19 @@ from gitpod import Gitpod
 client = Gitpod(
     # 20 seconds (default is 1 minute)
     timeout=20.0,
+    connect_protocol_version=True,
+    connect_timeout_header=0,
 )
 
 # More granular control:
 client = Gitpod(
     timeout=httpx.Timeout(60.0, read=5.0, write=10.0, connect=2.0),
+    connect_protocol_version=True,
+    connect_timeout_header=0,
 )
 
 # Override per-request:
-client.with_options(timeout=5.0).runners.create(
-    connect_protocol_version=1,
-)
+client.with_options(timeout=5.0).runners.create()
 ```
 
 On timeout, an `APITimeoutError` is thrown.
@@ -202,10 +207,11 @@ The "raw" Response object can be accessed by prefixing `.with_raw_response.` to
 ```py
 from gitpod import Gitpod
 
-client = Gitpod()
-response = client.runners.with_raw_response.create(
-    connect_protocol_version=1,
+client = Gitpod(
+    connect_protocol_version=True,
+    connect_timeout_header=0,
 )
+response = client.runners.with_raw_response.create()
 print(response.headers.get('X-My-Header'))
 
 runner = response.parse()  # get the object that `runners.create()` would have returned
@@ -223,9 +229,7 @@ The above interface eagerly reads the full response body when you make the reque
 To stream the response body, use `.with_streaming_response` instead, which requires a context manager and only reads the response body once you call `.read()`, `.text()`, `.json()`, `.iter_bytes()`, `.iter_text()`, `.iter_lines()` or `.parse()`. In the async client, these are async methods.
 
 ```python
-with client.runners.with_streaming_response.create(
-    connect_protocol_version=1,
-) as response:
+with client.runners.with_streaming_response.create() as response:
     print(response.headers.get("X-My-Header"))
 
     for line in response.iter_lines():
@@ -287,6 +291,8 @@ client = Gitpod(
         proxy="http://my.test.proxy.example.com",
         transport=httpx.HTTPTransport(local_address="0.0.0.0"),
     ),
+    connect_protocol_version=True,
+    connect_timeout_header=0,
 )
 ```
 
@@ -303,7 +309,10 @@ By default the library closes underlying HTTP connections whenever the client is
 ```py
 from gitpod import Gitpod
 
-with Gitpod() as client:
+with Gitpod(
+    connect_protocol_version=True,
+    connect_timeout_header=0,
+) as client:
   # make requests here
   ...
 

src/gitpod/_client.py

@@ -54,11 +54,15 @@ class Gitpod(SyncAPIClient):
 
     # client options
     bearer_token: str
+    connect_protocol_version: bool
+    connect_timeout_header: float
 
     def __init__(
         self,
         *,
         bearer_token: str | None = None,
+        connect_protocol_version: bool | None = 1,
+        connect_timeout_header: float,
         base_url: str | httpx.URL | None = None,
         timeout: Union[float, Timeout, None, NotGiven] = NOT_GIVEN,
         max_retries: int = DEFAULT_MAX_RETRIES,
@@ -90,6 +94,12 @@ def __init__(
             )
         self.bearer_token = bearer_token
 
+        if connect_protocol_version is None:
+            connect_protocol_version = 1
+        self.connect_protocol_version = connect_protocol_version
+
+        self.connect_timeout_header = connect_timeout_header
+
         if base_url is None:
             base_url = os.environ.get("GITPOD_BASE_URL")
         if base_url is None:
@@ -134,13 +144,17 @@ def default_headers(self) -> dict[str, str | Omit]:
         return {
             **super().default_headers,
             "X-Stainless-Async": "false",
+            "Connect-Protocol-Version": str(self.connect_protocol_version),
+            "Connect-Timeout-Ms": str(self.connect_timeout_header),
             **self._custom_headers,
         }
 
     def copy(
         self,
         *,
         bearer_token: str | None = None,
+        connect_protocol_version: bool | None = None,
+        connect_timeout_header: float | None = None,
         base_url: str | httpx.URL | None = None,
         timeout: float | Timeout | None | NotGiven = NOT_GIVEN,
         http_client: httpx.Client | None = None,
@@ -175,6 +189,8 @@ def copy(
         http_client = http_client or self._client
         return self.__class__(
             bearer_token=bearer_token or self.bearer_token,
+            connect_protocol_version=connect_protocol_version or self.connect_protocol_version,
+            connect_timeout_header=connect_timeout_header or self.connect_timeout_header,
             base_url=base_url or self.base_url,
             timeout=self.timeout if isinstance(timeout, NotGiven) else timeout,
             http_client=http_client,
@@ -236,11 +252,15 @@ class AsyncGitpod(AsyncAPIClient):
 
     # client options
     bearer_token: str
+    connect_protocol_version: bool
+    connect_timeout_header: float
 
     def __init__(
         self,
         *,
         bearer_token: str | None = None,
+        connect_protocol_version: bool | None = 1,
+        connect_timeout_header: float,
         base_url: str | httpx.URL | None = None,
         timeout: Union[float, Timeout, None, NotGiven] = NOT_GIVEN,
         max_retries: int = DEFAULT_MAX_RETRIES,
@@ -272,6 +292,12 @@ def __init__(
             )
         self.bearer_token = bearer_token
 
+        if connect_protocol_version is None:
+            connect_protocol_version = 1
+        self.connect_protocol_version = connect_protocol_version
+
+        self.connect_timeout_header = connect_timeout_header
+
         if base_url is None:
             base_url = os.environ.get("GITPOD_BASE_URL")
         if base_url is None:
@@ -316,13 +342,17 @@ def default_headers(self) -> dict[str, str | Omit]:
         return {
             **super().default_headers,
             "X-Stainless-Async": f"async:{get_async_library()}",
+            "Connect-Protocol-Version": str(self.connect_protocol_version),
+            "Connect-Timeout-Ms": str(self.connect_timeout_header),
             **self._custom_headers,
         }
 
     def copy(
         self,
         *,
         bearer_token: str | None = None,
+        connect_protocol_version: bool | None = None,
+        connect_timeout_header: float | None = None,
         base_url: str | httpx.URL | None = None,
         timeout: float | Timeout | None | NotGiven = NOT_GIVEN,
         http_client: httpx.AsyncClient | None = None,
@@ -357,6 +387,8 @@ def copy(
         http_client = http_client or self._client
         return self.__class__(
             bearer_token=bearer_token or self.bearer_token,
+            connect_protocol_version=connect_protocol_version or self.connect_protocol_version,
+            connect_timeout_header=connect_timeout_header or self.connect_timeout_header,
             base_url=base_url or self.base_url,
             timeout=self.timeout if isinstance(timeout, NotGiven) else timeout,
             http_client=http_client,

src/gitpod/resources/environment_classes.py

@@ -2,16 +2,12 @@
 
 from __future__ import annotations
 
-from typing_extensions import Literal
-
 import httpx
 
 from ..types import environment_class_list_params
 from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
 from .._utils import (
-    is_given,
     maybe_transform,
-    strip_not_given,
     async_maybe_transform,
 )
 from .._compat import cached_property
@@ -51,10 +47,8 @@ def with_streaming_response(self) -> EnvironmentClassesResourceWithStreamingResp
     def list(
         self,
         *,
-        connect_protocol_version: Literal[1],
         filter: environment_class_list_params.Filter | NotGiven = NOT_GIVEN,
         pagination: environment_class_list_params.Pagination | NotGiven = NOT_GIVEN,
-        connect_timeout_ms: float | NotGiven = NOT_GIVEN,
         # 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,
@@ -69,12 +63,8 @@ def list(
         query buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
 
         Args:
-          connect_protocol_version: Define the version of the Connect protocol
-
           pagination: pagination contains the pagination options for listing environment classes
 
-          connect_timeout_ms: Define the timeout, in ms
-
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -83,15 +73,6 @@ def list(
 
           timeout: Override the client-level default timeout for this request, in seconds
         """
-        extra_headers = {
-            **strip_not_given(
-                {
-                    "Connect-Protocol-Version": str(connect_protocol_version),
-                    "Connect-Timeout-Ms": str(connect_timeout_ms) if is_given(connect_timeout_ms) else NOT_GIVEN,
-                }
-            ),
-            **(extra_headers or {}),
-        }
         return self._post(
             "/gitpod.v1.EnvironmentService/ListEnvironmentClasses",
             body=maybe_transform(
@@ -131,10 +112,8 @@ def with_streaming_response(self) -> AsyncEnvironmentClassesResourceWithStreamin
     async def list(
         self,
         *,
-        connect_protocol_version: Literal[1],
         filter: environment_class_list_params.Filter | NotGiven = NOT_GIVEN,
         pagination: environment_class_list_params.Pagination | NotGiven = NOT_GIVEN,
-        connect_timeout_ms: float | NotGiven = NOT_GIVEN,
         # 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,
@@ -149,12 +128,8 @@ async def list(
         query buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
 
         Args:
-          connect_protocol_version: Define the version of the Connect protocol
-
           pagination: pagination contains the pagination options for listing environment classes
 
-          connect_timeout_ms: Define the timeout, in ms
-
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -163,15 +138,6 @@ async def list(
 
           timeout: Override the client-level default timeout for this request, in seconds
         """
-        extra_headers = {
-            **strip_not_given(
-                {
-                    "Connect-Protocol-Version": str(connect_protocol_version),
-                    "Connect-Timeout-Ms": str(connect_timeout_ms) if is_given(connect_timeout_ms) else NOT_GIVEN,
-                }
-            ),
-            **(extra_headers or {}),
-        }
         return await self._post(
             "/gitpod.v1.EnvironmentService/ListEnvironmentClasses",
             body=await async_maybe_transform(