Struct Client 

pub struct Client { /* private fields */ }

Client for Compose Channels

Channel linking, status, and disconnect for WhatsApp, Telegram, Slack, and Discord. The channels service runs at https://services.compose.market.

Version: 0.8.6

Implementations

impl Client

pub fn new(baseurl: &str) -> Self

Create a new client.

baseurl is the base URL provided to the internal reqwest::Client, and should include a scheme and hostname, as well as port and a path stem if applicable.

pub fn new_with_client(baseurl: &str, client: Client) -> Self

Construct a new client with an existing reqwest::Client, allowing more control over its configuration.

baseurl is the base URL provided to the internal reqwest::Client, and should include a scheme and hostname, as well as port and a path stem if applicable.

impl Client

pub fn list(&self) -> List<'_>

List available channels

Sends a GET request to /channels

let response = client.list()
    .send()
    .await;

pub fn slack_manifest(&self) -> SlackManifest<'_>

Get Slack app manifest

Sends a GET request to /channels/slack/manifest

let response = client.slack_manifest()
    .send()
    .await;

pub fn get(&self) -> Get<'_>

Get channel info and available endpoints

Sends a GET request to /channels/{channel}

let response = client.get()
    .channel(channel)
    .send()
    .await;

pub fn disconnect(&self) -> Disconnect<'_>

Disconnect routes for a channel

Sends a POST request to /channels/{channel}/disconnect

let response = client.disconnect()
    .channel(channel)
    .body(body)
    .send()
    .await;

pub fn link(&self) -> Link<'_>

Create a linking code for a channel

Generates a short-lived linking code that pairs a user’s wallet with an agent on the specified channel. The response includes a URL or action that the user must follow to complete the linking process (QR code for WhatsApp, OAuth redirect for Slack/Discord, bot link for Telegram).

Sends a POST request to /channels/{channel}/link

let response = client.link()
    .channel(channel)
    .body(body)
    .send()
    .await;

pub fn status(&self) -> Status<'_>

Check connection status and list routes

Sends a GET request to /channels/{channel}/status

Arguments:

• channel
• account_id
• agent_wallet
• hai_id: Required when scope is local.
• scope: Route scope. Omit or use global for hosted/global ties; use local with haiId for HAI-bound local ties.
• thread_id
• user_address

let response = client.status()
    .channel(channel)
    .account_id(account_id)
    .agent_wallet(agent_wallet)
    .hai_id(hai_id)
    .scope(scope)
    .thread_id(thread_id)
    .user_address(user_address)
    .send()
    .await;

Trait Implementations

impl ClientHooks for &Client

async fn pre<E>( &self, request: &mut Request, info: &OperationInfo, ) -> Result<(), Error<E>>

Runs prior to the execution of the request. This may be used to modify the request before it is transmitted.

async fn post<E>( &self, result: &Result<Response, Error>, info: &OperationInfo, ) -> Result<(), Error<E>>

Runs after completion of the request.

async fn exec( &self, request: Request, info: &OperationInfo, ) -> Result<Response, Error>

Execute the request. Note that for almost any reasonable implementation this will include code equivalent to this:

impl ClientInfo<()> for Client

fn api_version() -> &'static str

Get the version of this API.

fn baseurl(&self) -> &str

Get the base URL to which requests are made.

fn client(&self) -> &Client

Get the internal reqwest::Client used to make requests.

fn inner(&self) -> &()

Get the inner value of type T if one is specified.

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.