X API Basics

const userId = "12345" // Numeric user ID

const response = await fetch(
  `https://api.twitter.com/2/users/${userId}/tweets?` +
    new URLSearchParams({
      max_results: "10",
      "tweet.fields": "created_at,public_metrics,author_id",
      expansions: "author_id",
      "user.fields": "name,username,profile_image_url",
    }),
  {
    headers: {
      Authorization: `Bearer ${process.env.X_BEARER_TOKEN}`,
    },
  }
)

const data = await response.json()
console.log(data)

async function getUserByUsername(username: string) {
  const response = await fetch(
    `https://api.twitter.com/2/users/by/username/${username}?` +
      new URLSearchParams({
        "user.fields": "id,name,username,description,public_metrics",
      }),
    {
      headers: {
        Authorization: `Bearer ${process.env.X_BEARER_TOKEN}`,
      },
    }
  )

  return response.json()
}

const user = await getUserByUsername("elonmusk")
console.log(user.data.id) // Use this ID for timeline fetches

async function postTweet(text: string, accessToken: string) {
  const response = await fetch("https://api.twitter.com/2/tweets", {
    method: "POST",
    headers: {
      Authorization: `Bearer ${accessToken}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ text }),
  })

  return response.json()
}

// With OAuth 2.0 access token
const result = await postTweet("Hello from my app!", userAccessToken)
console.log(result.data.id) // New tweet ID

async function replyToTweet(
  text: string,
  replyToId: string,
  accessToken: string
) {
  const response = await fetch("https://api.twitter.com/2/tweets", {
    method: "POST",
    headers: {
      Authorization: `Bearer ${accessToken}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      text,
      reply: {
        in_reply_to_tweet_id: replyToId,
      },
    }),
  })

  return response.json()
}

async function searchTweets(query: string) {
  const response = await fetch(
    `https://api.twitter.com/2/tweets/search/recent?` +
      new URLSearchParams({
        query,
        max_results: "10",
        "tweet.fields": "created_at,public_metrics,author_id",
      }),
    {
      headers: {
        Authorization: `Bearer ${process.env.X_BEARER_TOKEN}`,
      },
    }
  )

  return response.json()
}

const results = await searchTweets("typescript lang:en -is:retweet")

interface XAPIError {
  errors?: Array<{
    message: string
    code: number
  }>
  title?: string
  detail?: string
  status?: number
}

async function fetchWithErrorHandling(url: string, options: RequestInit) {
  const response = await fetch(url, options)

  if (!response.ok) {
    const error: XAPIError = await response.json()

    if (response.status === 429) {
      const resetTime = response.headers.get("x-rate-limit-reset")
      console.error(`Rate limited. Reset at: ${resetTime}`)
    }

    throw new Error(error.detail || error.title || "X API error")
  }

  return response.json()
}