Class AsyncOpencode

src/opencode_ai/_client.py:206–364

class AsyncOpencode(AsyncAPIClient):
    event: event.AsyncEventResource
    app: app.AsyncAppResource
    find: find.AsyncFindResource
    file: file.AsyncFileResource
    config: config.AsyncConfigResource
    session: session.AsyncSessionResource
    tui: tui.AsyncTuiResource
    with_raw_response: AsyncOpencodeWithRawResponse
    with_streaming_response: AsyncOpencodeWithStreamedResponse

    # client options

    def __init__(
        self,
        *,
        base_url: str | httpx.URL | None = None,
        timeout: Union[float, Timeout, None, NotGiven] = NOT_GIVEN,
        max_retries: int = DEFAULT_MAX_RETRIES,
        default_headers: Mapping[str, str] | None = None,
        default_query: Mapping[str, object] | None = None,
        # Configure a custom httpx client.
        # We provide a `DefaultAsyncHttpxClient` class that you can pass to retain the default values we use for `limits`, `timeout` & `follow_redirects`.
        # See the [httpx documentation](https://www.python-httpx.org/api/#asyncclient) for more details.
        http_client: httpx.AsyncClient | None = None,
        # Enable or disable schema validation for data returned by the API.
        # When enabled an error APIResponseValidationError is raised
        # if the API responds with invalid data for the expected schema.
        #
        # This parameter may be removed or changed in the future.
        # If you rely on this feature, please open a GitHub issue
        # outlining your use-case to help us decide if it should be
        # part of our public interface in the future.
        _strict_response_validation: bool = False,
    ) -> None:
        """Construct a new async AsyncOpencode client instance."""
        if base_url is None:
            base_url = os.environ.get("OPENCODE_BASE_URL")
        if base_url is None:
            base_url = f"http://localhost:54321"

        super().__init__(
            version=__version__,
            base_url=base_url,
            max_retries=max_retries,
            timeout=timeout,
            http_client=http_client,
            custom_headers=default_headers,
            custom_query=default_query,
            _strict_response_validation=_strict_response_validation,
        )

        self._default_stream_cls = AsyncStream

        self.event = event.AsyncEventResource(self)
        self.app = app.AsyncAppResource(self)
        self.find = find.AsyncFindResource(self)
        self.file = file.AsyncFileResource(self)