Function searchTweets

src/tools/search/x-search.ts:121–165

(
  query: string,
  opts: {
    pages?: number;
    maxResults?: number;
    sortOrder?: 'relevancy' | 'recency';
    since?: string;
  } = {},
)

}

async function searchTweets(
  query: string,
  opts: {
    pages?: number;
    maxResults?: number;
    sortOrder?: 'relevancy' | 'recency';
    since?: string;
  } = {},
): Promise<XTweet[]> {
  const pages = Math.min(opts.pages ?? 1, 5);
  const maxResults = Math.max(Math.min(opts.maxResults ?? 100, 100), 10);
  const sort = opts.sortOrder ?? 'relevancy';
  const encoded = encodeURIComponent(query);

  let timeFilter = '';
  if (opts.since) {
    const startTime = parseSince(opts.since);
    if (startTime) timeFilter = `&start_time=${startTime}`;
  }

  const allTweets: XTweet[] = [];
  let nextToken: string | undefined;

  for (let page = 0; page < pages; page++) {
    const pagination = nextToken ? `&pagination_token=${nextToken}` : '';
    const url =
      `${X_API_BASE}/tweets/search/recent?query=${encoded}` +
      `&max_results=${maxResults}&${TWEET_FIELDS}` +
      `&sort_order=${sort}${timeFilter}${pagination}`;

    const raw = await xApiGet(url);
    allTweets.push(...parseTweets(raw));
    nextToken = raw.meta?.next_token;
    if (!nextToken) break;
    if (page < pages - 1) await sleep(RATE_DELAY_MS);
  }

  // Deduplicate
  const seen = new Set<string>();
  return allTweets.filter((t) => {
    if (seen.has(t.id)) return false;
    seen.add(t.id);
    return true;
  });
}

async function getProfile(
  username: string,