Struct HttpClient 

pub struct HttpClient {

    pub http_client: Client,
    pub address: String,
    pub authorization: Option<Arc<String>>,
    pub user_agent: Option<String>,
    pub x_title: Option<String>,
    pub http_referer: Option<String>,
    pub x_github_authorization: Option<Arc<String>>,
    pub x_openrouter_authorization: Option<Arc<String>>,
    pub x_mcp_authorization: Option<Arc<HashMap<String, String>>>,
    pub x_viewer_signature: Option<Arc<String>>,
    pub x_viewer_address: Option<Arc<String>>,
    pub agent_instance_hierarchy: Option<Arc<String>>,
    pub mcp_session_id: Option<Arc<String>>,
}

HTTP client for making requests to the ObjectiveAI API.

Handles authentication, request building, and response parsing for both unary and streaming endpoints.

Example

let client = HttpClient::new(
    reqwest::Client::new(),
    None, // Use default address
    Some("your-api-key"),
    None, // user_agent
    None, // x_title
    None, // http_referer
    None, // x_github_authorization
    None, // x_openrouter_authorization
    None, // x_mcp_authorization
    None, // x_viewer_signature
    None, // x_viewer_address
);

Fields

http_client: Client

The underlying reqwest HTTP client.

address: String

Base URL for API requests. Defaults to https://api.objectiveai.dev.

authorization: Option<Arc<String>>

API key for authentication. Sent as Bearer token in Authorization header.

user_agent: Option<String>

Value for the User-Agent header.

x_title: Option<String>

Value for the X-Title header.

http_referer: Option<String>

Value for both Referer and HTTP-Referer headers.

x_github_authorization: Option<Arc<String>>

Value for the X-GITHUB-AUTHORIZATION header.

x_openrouter_authorization: Option<Arc<String>>

Value for the X-OPENROUTER-AUTHORIZATION header.

x_mcp_authorization: Option<Arc<HashMap<String, String>>>

Values for the X-MCP-AUTHORIZATION header (JSON-encoded).

x_viewer_signature: Option<Arc<String>>

Value for the X-VIEWER-SIGNATURE header.

x_viewer_address: Option<Arc<String>>

Value for the X-VIEWER-ADDRESS header.

agent_instance_hierarchy: Option<Arc<String>>

Value for the X-OBJECTIVEAI-AGENT-INSTANCE-HIERARCHY header.

mcp_session_id: Option<Arc<String>>

Value for the Mcp-Session-Id header — propagated through to objectiveai-mcp so server-side tool invocations see a stable per-session id. See objectiveai_sdk::mcp::MCP_SESSION_ID_HEADER.

Implementations

impl HttpClient

pub fn new( http_client: Client, address: Option<impl Into<String>>, authorization: Option<impl Into<String>>, user_agent: Option<impl Into<String>>, x_title: Option<impl Into<String>>, http_referer: Option<impl Into<String>>, x_github_authorization: Option<impl Into<String>>, x_openrouter_authorization: Option<impl Into<String>>, x_mcp_authorization: Option<HashMap<String, String>>, x_viewer_signature: Option<impl Into<String>>, x_viewer_address: Option<impl Into<String>>, agent_instance_hierarchy: Option<impl Into<String>>, mcp_session_id: Option<impl Into<String>>, ) -> Self

Creates a new HTTP client.

Arguments

• http_client - The reqwest client to use for requests
• address - Base URL for API requests (defaults to https://api.objectiveai.dev)
• authorization - API key for authentication
• user_agent - Optional User-Agent header value
• x_title - Optional X-Title header value
• http_referer - Optional Referer header value
• x_github_authorization - Optional X-GITHUB-AUTHORIZATION header value
• x_openrouter_authorization - Optional X-OPENROUTER-AUTHORIZATION header value
• x_mcp_authorization - Optional X-MCP-AUTHORIZATION header value (HashMap)
• x_viewer_signature - Optional X-VIEWER-SIGNATURE header value
• x_viewer_address - Optional X-VIEWER-ADDRESS header value
• agent_instance_hierarchy - Optional X-OBJECTIVEAI-AGENT-INSTANCE-HIERARCHY header value
• mcp_session_id - Optional Mcp-Session-Id header value

pub async fn send_unary<T: DeserializeOwned + Send + 'static>( &self, method: Method, path: impl AsRef<str>, body: Option<impl Serialize>, ) -> Result<T, HttpError>

Sends a unary (request-response) API call and deserializes the response.

Type Parameters

• T - The expected response type to deserialize into

Errors

Returns super::HttpError if the request fails, returns a non-success status, or the response cannot be deserialized.

pub async fn send_unary_no_response( &self, method: Method, path: impl AsRef<str>, body: Option<impl Serialize>, ) -> Result<(), HttpError>

Sends a unary API call that expects no response body.

Useful for DELETE or other operations that only return a status code.

Errors

Returns super::HttpError if the request fails or returns a non-success status.

pub async fn send_streaming<T: DeserializeOwned + Send + 'static, P: AsRef<str> + Send, B: Serialize + Send>( &self, method: Method, path: P, body: Option<B>, ) -> Result<impl Stream<Item = Result<T, HttpError>> + Send + 'static + use<T, P, B>, HttpError>

Sends a streaming API call using Server-Sent Events (SSE).

Returns a stream of deserialized chunks. The stream automatically handles:

• SSE [DONE] messages (filtered out)
• Comment lines starting with : (filtered out)
• Empty data lines (filtered out)
• API errors embedded in stream data

Type Parameters

• T - The expected chunk type to deserialize each SSE message into

Errors

Returns super::HttpError if the stream cannot be established.

pub async fn send_streaming_ws<Chunk, B, H, P>( &self, method: Method, path: P, body: B, handler: H, ) -> Result<(impl Stream<Item = Result<Chunk, HttpError>> + Send + Unpin + 'static + use<Chunk, B, H, P>, Notifier), HttpError>

where Chunk: DeserializeOwned + Send + 'static, B: Serialize + Send + 'static, H: McpHandler, P: AsRef<str>,

WebSocket variant of Self::send_streaming. Opens a WS to the configured address, sends body as the first text frame, then demultiplexes inbound frames into:

• Chunk frames (yielded on the returned Stream).
• client_response::Response frames (routed to the super::Notifier’s pending-id map).
• server_request::Request frames (dispatched to handler; the result is written back as a server_response::Response echoing the request id).

Both the returned Stream and the returned super::Notifier share the underlying WebSocket: dropping both stops the demux task and closes the connection cleanly. Dropping only one keeps the WS alive — useful when a caller wants to send notifies after the chunk stream has finished, or vice-versa.

impl HttpClient

pub async fn github_resolve_commit( &self, owner: &str, repository: &str, ) -> Result<Option<String>, HttpError>

Resolves the latest commit SHA for a repository.

Returns Ok(None) if the repository (or its commit list) cannot be found.

pub async fn github_get_agent( &self, owner: &str, repository: &str, commit: Option<&str>, ) -> Result<Option<RemoteAgentBaseWithFallbacks>, HttpError>

Fetches an Agent definition (agent.json) from GitHub.

If commit is None, the latest commit is resolved first. Returns Ok(None) if the repository, commit, or file does not exist.

pub async fn github_get_swarm( &self, owner: &str, repository: &str, commit: Option<&str>, ) -> Result<Option<RemoteSwarmBase>, HttpError>

Fetches a Swarm definition (swarm.json) from GitHub.

If commit is None, the latest commit is resolved first. Returns Ok(None) if the repository, commit, or file does not exist.

pub async fn github_get_function( &self, owner: &str, repository: &str, commit: Option<&str>, ) -> Result<Option<FullRemoteFunction>, HttpError>

Fetches a Function definition (function.json) from GitHub.

If commit is None, the latest commit is resolved first. Returns Ok(None) if the repository, commit, or file does not exist.

pub async fn github_get_profile( &self, owner: &str, repository: &str, commit: Option<&str>, ) -> Result<Option<RemoteProfile>, HttpError>

Fetches a Profile definition (profile.json) from GitHub.

If commit is None, the latest commit is resolved first. Returns Ok(None) if the repository, commit, or file does not exist.

Trait Implementations

impl Clone for HttpClient

fn clone(&self) -> HttpClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HttpClient

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

Formats the value using the given formatter.