feat: Add support for sync operations

src/toolbox_langchain_sdk/async_client.py

@@ -0,0 +1,171 @@
+# Copyright 2025 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from typing import Any, Callable, Optional, Union
+from warnings import warn
+
+from aiohttp import ClientSession
+
+from .tools import AsyncToolboxTool
+from .utils import ManifestSchema, _load_manifest
+
+
+# This class is an internal implementation detail and is not exposed to the
+# end-user. It should not be used directly by external code. Changes to this
+# class will not be considered breaking changes to the public API.
+class AsyncToolboxClient:
+
+    def __init__(
+        self,
+        url: str,
+        session: ClientSession,
+    ):
+        """
+        Initializes the AsyncToolboxClient for the Toolbox service at the given URL.
+
+        Args:
+            url: The base URL of the Toolbox service.
+            session: An HTTP client session.
+        """
+        self.__url = url
+        self.__session = session
+
+    async def aload_tool(
+        self,
+        tool_name: str,
+        auth_tokens: dict[str, Callable[[], str]] = {},
+        auth_headers: Optional[dict[str, Callable[[], str]]] = None,
+        bound_params: dict[str, Union[Any, Callable[[], Any]]] = {},
+        strict: bool = True,
+    ) -> AsyncToolboxTool:
+        """
+        Loads the tool with the given tool name from the Toolbox service.
+
+        Args:
+            tool_name: The name of the tool to load.
+            auth_tokens: An optional mapping of authentication source names to
+                functions that retrieve ID tokens.
+            auth_headers: Deprecated. Use `auth_tokens` instead.
+            bound_params: An optional mapping of parameter names to their
+                bound values.
+            strict: If True, raises a ValueError if any of the given bound
+                parameters are missing from the schema or require
+                authentication. If False, only issues a warning.
+
+        Returns:
+            A tool loaded from the Toolbox.
+        """
+        if auth_headers:
+            if auth_tokens:
+                warn(
+                    "Both `auth_tokens` and `auth_headers` are provided. `auth_headers` is deprecated, and `auth_tokens` will be used.",
+                    DeprecationWarning,
+                )
+            else:
+                warn(
+                    "Argument `auth_headers` is deprecated. Use `auth_tokens` instead.",
+                    DeprecationWarning,
+                )
+                auth_tokens = auth_headers
+
+        url = f"{self.__url}/api/tool/{tool_name}"
+        manifest: ManifestSchema = await _load_manifest(url, self.__session)
+
+        return AsyncToolboxTool(
+            tool_name,
+            manifest.tools[tool_name],
+            self.__url,
+            self.__session,
+            auth_tokens,
+            bound_params,
+            strict,
+        )
+
+    async def aload_toolset(
+        self,
+        toolset_name: Optional[str] = None,
+        auth_tokens: dict[str, Callable[[], str]] = {},
+        auth_headers: Optional[dict[str, Callable[[], str]]] = None,
+        bound_params: dict[str, Union[Any, Callable[[], Any]]] = {},
+        strict: bool = True,
+    ) -> list[AsyncToolboxTool]:
+        """
+        Loads tools from the Toolbox service, optionally filtered by toolset
+        name.
+
+        Args:
+            toolset_name: The name of the toolset to load. If not provided,
+                all tools are loaded.
+            auth_tokens: An optional mapping of authentication source names to
+                functions that retrieve ID tokens.
+            auth_headers: Deprecated. Use `auth_tokens` instead.
+            bound_params: An optional mapping of parameter names to their
+                bound values.
+            strict: If True, raises a ValueError if any of the given bound
+                parameters are missing from the schema or require
+                authentication. If False, only issues a warning.
+
+        Returns:
+            A list of all tools loaded from the Toolbox.
+        """
+        if auth_headers:
+            if auth_tokens:
+                warn(
+                    "Both `auth_tokens` and `auth_headers` are provided. `auth_headers` is deprecated, and `auth_tokens` will be used.",
+                    DeprecationWarning,
+                )
+            else:
+                warn(
+                    "Argument `auth_headers` is deprecated. Use `auth_tokens` instead.",
+                    DeprecationWarning,
+                )
+                auth_tokens = auth_headers
+
+        url = f"{self.__url}/api/toolset/{toolset_name or ''}"
+        manifest: ManifestSchema = await _load_manifest(url, self.__session)
+        tools: list[AsyncToolboxTool] = []
+
+        for tool_name, tool_schema in manifest.tools.items():
+            tools.append(
+                AsyncToolboxTool(
+                    tool_name,
+                    tool_schema,
+                    self.__url,
+                    self.__session,
+                    auth_tokens,
+                    bound_params,
+                    strict,
+                )
+            )
+        return tools
+
+    def load_tool(
+        self,
+        tool_name: str,
+        auth_tokens: dict[str, Callable[[], str]] = {},
+        auth_headers: Optional[dict[str, Callable[[], str]]] = None,
+        bound_params: dict[str, Union[Any, Callable[[], Any]]] = {},
+        strict: bool = True,
+    ) -> AsyncToolboxTool:
+        raise NotImplementedError("Synchronous methods not supported by async client.")
+
+    def load_toolset(
+        self,
+        toolset_name: Optional[str] = None,
+        auth_tokens: dict[str, Callable[[], str]] = {},
+        auth_headers: Optional[dict[str, Callable[[], str]]] = None,
+        bound_params: dict[str, Union[Any, Callable[[], Any]]] = {},
+        strict: bool = True,
+    ) -> list[AsyncToolboxTool]:
+        raise NotImplementedError("Synchronous methods not supported by async client.")