Struct HttpTransport 

pub struct HttpTransport { /* private fields */ }

Low-level JSON-over-HTTP transport bound to one opencode base URL.

Cloning is cheap: the inner reqwest::Client is reference-counted.

Implementations

impl HttpTransport

pub fn new( client: Client, base_url: impl Into<String>, timeout: Option<Duration>, auth: Option<BasicAuth>, scope: Scope, ) -> Self

Bind a transport to a base URL.

Trailing slashes on base_url are stripped so path builders can append /-prefixed segments without producing //. The URL itself is validated lazily by reqwest at send time; a malformed base surfaces as Error::Transport.

pub fn base_url(&self) -> &str

The normalized base URL (no trailing slash).

pub fn auth(&self) -> Option<&BasicAuth>

Credentials attached to every request, if any.

pub fn scope(&self) -> &Scope

The directory / workspace scoping applied to every session URL and the GET /event stream this transport builds.

pub fn join(&self, path: &str) -> String

Join an arbitrary path (leading slash optional) onto the base URL. Backing helper for the client’s raw escape hatch; the path is used verbatim (not segment-encoded).

pub fn session_create_url(&self) -> String

URL for POST /session (session creation).

pub fn prompt_async_url(&self, session_id: &str) -> String

URL for POST /session/{sessionID}/prompt_async.

pub fn messages_url( &self, session_id: &str, limit: Option<u64>, before: Option<&str>, ) -> String

URL for GET /session/{sessionID}/message, optionally paginated with the limit and before query parameters used for reconciliation polling.

pub fn abort_url(&self, session_id: &str) -> String

URL for POST /session/{sessionID}/abort.

pub fn permission_url(&self, session_id: &str, permission_id: &str) -> String

URL for POST /session/{sessionID}/permissions/{permissionID}.

pub fn event_url(&self) -> String

URL for the GET /event SSE stream, with any configured Scope applied as directory / workspace query parameters.

pub fn event_request(&self) -> RequestBuilder

A RequestBuilder for the GET /event SSE stream on this transport’s Client, with the configured base URL, Scope, and auth applied.

Hand it to crate::sse::EventStream::from_request to open an authenticated event stream that reuses this transport’s connection pool. No per-request timeout is applied, since the stream is long-lived.

pub async fn request_json<R: DeserializeOwned>( &self, method: Method, url: &str, body: Option<Value>, ) -> Result<R>

Send a request and deserialize the JSON response body into R.

pub async fn request_unit( &self, method: Method, url: &str, body: Option<Value>, ) -> Result<()>

Send a request that yields no response body (e.g. an HTTP 204), discarding the body on success.

Trait Implementations

impl Clone for HttpTransport

fn clone(&self) -> HttpTransport

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HttpTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.