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 async fn set_pool(&self, pool: DbPool)

Set the database pool for usage tracking.

Called after DB initialization to enable fire-and-forget recording of every X API call.

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, 'life3, 'async_trait>( &'life0 self, query: &'life1 str, max_results: u32, since_id: Option<&'life2 str>, pagination_token: Option<&'life3 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, 'life3: 'async_trait,

Search recent tweets matching the given query.

fn get_mentions<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, user_id: &'life1 str, since_id: Option<&'life2 str>, pagination_token: Option<&'life3 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, 'life3: '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 upload_media<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 [u8], media_type: MediaType, ) -> Pin<Box<dyn Future<Output = Result<MediaId, XApiError>> + Send + 'async_trait>>

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

Upload media to X API for attaching to tweets.

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

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

Post a new tweet with media attachments.

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

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

Reply to an existing tweet with media attachments.

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, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, max_results: u32, pagination_token: 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,

Get recent tweets from a specific user.

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.

fn quote_tweet<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, text: &'life1 str, quoted_tweet_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,

Post a quote tweet referencing another tweet.

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

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

Like a tweet on behalf of the authenticated user.

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

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

Follow a user on behalf of the authenticated user.

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

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

Unfollow a user on behalf of the authenticated user.

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

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

Retweet a tweet on behalf of the authenticated user.

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

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

Undo a retweet on behalf of the authenticated user.

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

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

Delete a tweet by its ID.

fn get_home_timeline<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, max_results: u32, pagination_token: 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,

Get the authenticated user’s home timeline (reverse chronological).

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

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

Unlike a tweet on behalf of the authenticated user.

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

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

Get followers of a user.

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

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

Get accounts a user is following.

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

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

Get a user by their ID.

fn get_liked_tweets<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, max_results: u32, pagination_token: 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,

Get tweets liked by a user.

fn get_bookmarks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_id: &'life1 str, max_results: u32, pagination_token: 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,

Get the authenticated user’s bookmarks.

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

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

Bookmark a tweet.

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

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

Remove a bookmark.

fn get_users_by_ids<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, user_ids: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = Result<UsersResponse, XApiError>> + Send + 'async_trait>>

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

Get multiple users by their IDs.

fn get_tweet_liking_users<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tweet_id: &'life1 str, max_results: u32, pagination_token: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<UsersResponse, XApiError>> + Send + 'async_trait>>

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

Get users who liked a specific tweet.

fn raw_request<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, method: &'life1 str, url: &'life2 str, query: Option<&'life3 [(String, String)]>, body: Option<&'life4 str>, headers: Option<&'life5 [(String, String)]>, ) -> Pin<Box<dyn Future<Output = Result<RawApiResponse, XApiError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Execute a raw HTTP request against the X API.