search.handlers.ts•4.34 kB
import { TwitterClient } from '../client/twitter.js';
import { HandlerResponse, TwitterHandler } from '../types/handlers.js';
import { createResponse } from '../utils/response.js';
import { createMissingTwitterApiKeyResponse, formatTwitterError } from '../utils/twitter-response.js';
import { TweetV2, TwitterApiReadOnly, UserV2, TweetSearchRecentV2Paginator } from 'twitter-api-v2';
interface SearchTweetsArgs {
query: string;
maxResults?: number;
tweetFields?: string[];
}
interface HashtagAnalyticsArgs {
hashtag: string;
startTime?: string;
endTime?: string;
}
interface TweetWithAuthor extends TweetV2 {
author?: UserV2;
}
export const handleSearchTweets: TwitterHandler<SearchTweetsArgs> = async (
client: TwitterClient | null,
{ query, maxResults = 10, tweetFields }: SearchTweetsArgs
): Promise<HandlerResponse> => {
if (!client) {
return createMissingTwitterApiKeyResponse('searchTweets');
}
try {
const searchResult = await client.v2.search(query, {
max_results: maxResults,
'tweet.fields': tweetFields?.join(',') || 'created_at,public_metrics',
expansions: ['author_id'],
'user.fields': ['username']
});
const tweets = Array.isArray(searchResult.data) ? searchResult.data : [];
if (tweets.length === 0) {
return createResponse(`No tweets found for query: ${query}`);
}
const formattedTweets = tweets.map((tweet: TweetV2): TweetWithAuthor => ({
...tweet,
author: searchResult.includes?.users?.find((u: UserV2) => u.id === tweet.author_id)
}));
return createResponse(`Search results: ${JSON.stringify(formattedTweets, null, 2)}`);
} catch (error) {
if (error instanceof Error) {
if (error.message.includes('400') && error.message.includes('Invalid Request')) {
throw new Error(`Search functionality requires Pro tier access ($5,000/month) or higher. Current Basic tier ($200/month) does not include recent search API access. Consider upgrading at https://developer.x.com/en/portal/products/pro or use alternative data sources.`);
}
throw new Error(formatTwitterError(error, 'searching tweets'));
}
throw error;
}
};
export const handleHashtagAnalytics: TwitterHandler<HashtagAnalyticsArgs> = async (
client: TwitterClient | null,
{ hashtag, startTime, endTime }: HashtagAnalyticsArgs
): Promise<HandlerResponse> => {
if (!client) {
return createMissingTwitterApiKeyResponse('hashtagAnalytics');
}
try {
const query = `#${hashtag.replace(/^#/, '')}`;
const searchResult = await client.v2.search(query, {
max_results: 100,
'tweet.fields': 'public_metrics,created_at',
start_time: startTime,
end_time: endTime
});
const tweets = Array.isArray(searchResult.data) ? searchResult.data : [];
if (tweets.length === 0) {
return createResponse(`No tweets found for hashtag: ${hashtag}`);
}
const analytics = {
totalTweets: tweets.length,
totalLikes: tweets.reduce((sum: number, tweet: TweetV2) =>
sum + (tweet.public_metrics?.like_count || 0), 0),
totalRetweets: tweets.reduce((sum: number, tweet: TweetV2) =>
sum + (tweet.public_metrics?.retweet_count || 0), 0),
totalReplies: tweets.reduce((sum: number, tweet: TweetV2) =>
sum + (tweet.public_metrics?.reply_count || 0), 0)
};
return createResponse(`Hashtag Analytics for ${hashtag}:\n${JSON.stringify(analytics, null, 2)}`);
} catch (error) {
if (error instanceof Error) {
if (error.message.includes('400') && error.message.includes('Invalid Request')) {
throw new Error(`Hashtag analytics requires Pro tier access ($5,000/month) or higher for search functionality. Current Basic tier ($200/month) does not include recent search API access. Consider upgrading at https://developer.x.com/en/portal/products/pro or use alternative analytics sources.`);
}
throw new Error(formatTwitterError(error, 'getting hashtag analytics'));
}
throw error;
}
};