Struct XApiHttpClient 

pub struct XApiHttpClient { /* private fields */ }

HTTP client for the X API v2.

Uses reqwest with Bearer token authentication. The access token is stored behind an Arc<RwLock> so the token manager can update it transparently after a refresh.

Implementations

impl XApiHttpClient

pub fn new(access_token: String) -> Self

Create a new X API HTTP client with the given access token.

pub fn with_base_url(access_token: String, base_url: String) -> Self

Create a new client with a custom base URL (for testing with wiremock).

pub fn access_token_lock(&self) -> Arc<RwLock<String>>

Get a shared reference to the access token lock for token manager integration.

pub async fn set_access_token(&self, token: String)

Update the access token (used by token manager after refresh).

Trait Implementations

impl XApiClient for XApiHttpClient

fn search_tweets<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 str, max_results: u32, since_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<SearchResponse, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Search recent tweets matching the given query.

fn get_mentions<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, since_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<MentionResponse, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get mentions for the authenticated user.

fn post_tweet<'life0, 'life1, 'async_trait>( &'life0 self, text: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<PostedTweet, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Post a new tweet.

fn reply_to_tweet<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, text: &'life1 str, in_reply_to_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<PostedTweet, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Reply to an existing tweet.

fn get_tweet<'life0, 'life1, 'async_trait>( &'life0 self, tweet_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Tweet, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a single tweet by ID.

fn get_me<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<User, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the authenticated user’s profile.

fn get_user_tweets<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 str, max_results: u32, ) -> Pin<Box<dyn Future<Output = Result<SearchResponse, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get recent tweets from a specific user.

fn follow_user<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_user_id: &'life1 str, target_user_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Follow a user by their user ID.

fn get_user_by_username<'life0, 'life1, 'async_trait>( &'life0 self, username: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<User, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Look up a user by their username.