✨ feat(x-bot): implement webhook-based X bot with two-tweet reply flow

- Switch from polling to webhook-based event handling (CRC + POST handler)
- Add subscription/credit check before generation (canUserSendMessage)
- Implement two-tweet reply: "Creating your app..." then "App is ready" with links
- Send error reply tweet on generation failure
- Add schema fields: authorUsername, firstReplyTweetId, firstReplyContent, firstRepliedAt
- Create webhook registration script (pnpm run x-bot:register-webhook)
- Rename all capsulethis references to rnvibecode/reactnativevibecode.com
- New env vars needed: TWITTER_WEBHOOK_SECRET, TWITTER_BEARER_TOKEN

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: bidah

apps/web/app/(app)/api/create-container/route.ts

@@ -334,7 +334,7 @@ export async function POST(req: NextRequest) {
             // Set API Base URL for the sandbox app
             try {
               const { updateSandboxEnvFile } = await import('@/lib/convex/sandbox-utils')
-              const apiBaseUrl = process.env.NEXT_PUBLIC_BASE_URL || 'https://www.capsulethis.com'
+              const apiBaseUrl = process.env.NEXT_PUBLIC_BASE_URL || 'https://www.reactnativevibecode.com'
               await updateSandboxEnvFile(sandbox, 'EXPO_PUBLIC_API_BASE_URL', apiBaseUrl)
               console.log(`[Create Container] Set EXPO_PUBLIC_API_BASE_URL to ${apiBaseUrl}`)
             } catch (error) {
@@ -498,7 +498,7 @@ export async function POST(req: NextRequest) {
     // Set API Base URL for the sandbox app
     try {
       const { updateSandboxEnvFile } = await import('@/lib/convex/sandbox-utils')
-      const apiBaseUrl = process.env.NEXT_PUBLIC_BASE_URL || 'https://www.capsulethis.com'
+      const apiBaseUrl = process.env.NEXT_PUBLIC_BASE_URL || 'https://www.reactnativevibecode.com'
       await updateSandboxEnvFile(sandbox, 'EXPO_PUBLIC_API_BASE_URL', apiBaseUrl)
       console.log(`[Create Container] Set EXPO_PUBLIC_API_BASE_URL to ${apiBaseUrl}`)
     } catch (error) {

apps/web/app/(app)/api/x-bot/create-project/route.ts

@@ -15,7 +15,7 @@ const octokit = new Octokit({
 })
 
 const githubService = new GitHubService({
-  owner: process.env.GITHUB_OWNER || 'capsule-this',
+  owner: process.env.GITHUB_OWNER || 'react-native-vibe-code',
   token: process.env.GITHUB_TOKEN!,
 })
 
@@ -105,7 +105,7 @@ export async function POST(request: NextRequest) {
     console.log(`[X-Bot Create Project] Created project: ${projectId}`)
 
     // Create GitHub repository
-    const owner = process.env.GITHUB_OWNER || 'capsule-this'
+    const owner = process.env.GITHUB_OWNER || 'react-native-vibe-code'
     try {
       await octokit.repos.get({ owner, repo: repositoryName })
       console.log(`[X-Bot Create Project] GitHub repo already exists`)

apps/web/app/(app)/api/x-bot/generate/route.ts

@@ -1,4 +1,5 @@
 import { NextRequest, NextResponse } from 'next/server'
+import { Client, auth } from 'twitter-api-sdk'
 import { db } from '@/lib/db'
 import { xBotReplies, projects } from '@react-native-vibe-code/database'
 import { eq } from 'drizzle-orm'
@@ -10,6 +11,51 @@ export const maxDuration = 300 // 5 minutes
 // Secret key for x-bot internal calls
 const X_BOT_SECRET = process.env.X_BOT_SECRET
 
+/**
+ * Get authenticated Twitter client for sending error replies
+ */
+async function getAuthClient(): Promise<Client> {
+  const refreshToken = process.env.TWITTER_REFRESH_TOKEN
+  if (!refreshToken) {
+    throw new Error('TWITTER_REFRESH_TOKEN environment variable is required')
+  }
+
+  const oauth2Client = new auth.OAuth2User({
+    client_id: process.env.TWITTER_CLIENT_ID as string,
+    client_secret: process.env.TWITTER_CLIENT_SECRET as string,
+    callback: 'https://reactnativevibecode.com/api/x-bot/auth/callback',
+    scopes: ['tweet.read', 'tweet.write', 'users.read', 'offline.access'],
+  })
+
+  oauth2Client.token = { refresh_token: refreshToken }
+  await oauth2Client.refreshAccessToken()
+  return new Client(oauth2Client)
+}
+
+/**
+ * Send an error reply tweet when generation fails
+ */
+async function sendErrorReply(
+  tweetId: string,
+  authorUsername: string | null,
+  firstReplyTweetId: string | null
+): Promise<void> {
+  try {
+    const client = await getAuthClient()
+    const username = authorUsername || 'there'
+    const errorText = `Sorry @${username}, there was an issue creating your app. Please try again or visit reactnativevibecode.com to build it manually.`
+    const replyToId = firstReplyTweetId || tweetId
+
+    await client.tweets.createTweet({
+      text: errorText,
+      reply: { in_reply_to_tweet_id: replyToId },
+    })
+    console.log(`[X-Bot Generate] Error reply sent for tweet ${tweetId}`)
+  } catch (replyError) {
+    console.error(`[X-Bot Generate] Failed to send error reply:`, replyError)
+  }
+}
+
 interface GenerateRequest {
   projectId: string
   userId: string
@@ -109,10 +155,24 @@ export async function POST(request: NextRequest) {
           await db
             .update(xBotReplies)
             .set({
+              status: 'failed',
               generationStatus: 'failed',
               errorMessage: error,
             })
             .where(eq(xBotReplies.tweetId, tweetId))
+
+          // Send error reply tweet
+          const record = await db
+            .select()
+            .from(xBotReplies)
+            .where(eq(xBotReplies.tweetId, tweetId))
+            .limit(1)
+
+          await sendErrorReply(
+            tweetId,
+            record[0]?.authorUsername || null,
+            record[0]?.firstReplyTweetId || null
+          )
         },
       }
     )
@@ -133,11 +193,25 @@ export async function POST(request: NextRequest) {
     await db
       .update(xBotReplies)
       .set({
+        status: 'failed',
         generationStatus: 'failed',
         errorMessage: error.message || 'Unexpected error',
       })
       .where(eq(xBotReplies.tweetId, tweetId))
 
+    // Send error reply tweet
+    const record = await db
+      .select()
+      .from(xBotReplies)
+      .where(eq(xBotReplies.tweetId, tweetId))
+      .limit(1)
+
+    await sendErrorReply(
+      tweetId,
+      record[0]?.authorUsername || null,
+      record[0]?.firstReplyTweetId || null
+    )
+
     return NextResponse.json(
       { error: error.message || 'Generation failed' },
       { status: 500 }

apps/web/app/(app)/api/x-bot/reply/route.ts

@@ -25,7 +25,7 @@ async function getAuthClient(): Promise<Client> {
   const oauth2Client = new auth.OAuth2User({
     client_id: process.env.TWITTER_CLIENT_ID as string,
     client_secret: process.env.TWITTER_CLIENT_SECRET as string,
-    callback: 'http://www.capsulethis.com/api/x-bot/auth/callback',
+    callback: 'https://reactnativevibecode.com/api/x-bot/auth/callback',
     scopes: ['tweet.read', 'tweet.write', 'users.read', 'offline.access'],
   })
 
@@ -35,7 +35,6 @@ async function getAuthClient(): Promise<Client> {
 
   await oauth2Client.refreshAccessToken()
 
-  // Log if token was rotated
   if (
     oauth2Client.token?.refresh_token &&
     oauth2Client.token.refresh_token !== refreshToken
@@ -49,6 +48,42 @@ async function getAuthClient(): Promise<Client> {
   return new Client(oauth2Client)
 }
 
+/**
+ * Build the final reply text within Twitter's 280 character limit.
+ * Includes app title, brief description, edit link, and remix link.
+ */
+function buildReplyText(
+  title: string,
+  appDescription: string | null,
+  projectId: string
+): string {
+  const baseUrl =
+    process.env.NEXT_PUBLIC_APP_URL || 'https://reactnativevibecode.com'
+  const editUrl = `${baseUrl}/p/${projectId}`
+  const remixUrl = `${baseUrl}/p/${projectId}/remix`
+
+  const links = `\nEdit your app: ${editUrl}\nRemix it: ${remixUrl}`
+  const header = `Your app "${title}" is ready!`
+
+  // Calculate remaining space for description
+  // 280 char limit, account for header + links + newlines
+  const fixedLength = header.length + links.length + 2 // 2 for newlines between sections
+  const maxDescLength = 280 - fixedLength
+
+  if (!appDescription || maxDescLength <= 0) {
+    const text = `${header}${links}`
+    return text.length <= 280 ? text : text.substring(0, 280)
+  }
+
+  const desc =
+    appDescription.length > maxDescLength
+      ? appDescription.substring(0, maxDescLength - 3) + '...'
+      : appDescription
+
+  const text = `${header}\n\n${desc}${links}`
+  return text.length <= 280 ? text : `${header}${links}`
+}
+
 export async function POST(request: NextRequest) {
   try {
     const body: ReplyRequest = await request.json()
@@ -66,7 +101,9 @@ export async function POST(request: NextRequest) {
       )
     }
 
-    console.log(`[X-Bot Reply] Sending reply for tweet ${tweetId}, project ${projectId}`)
+    console.log(
+      `[X-Bot Reply] Sending final reply for tweet ${tweetId}, project ${projectId}`
+    )
 
     // Get project details
     const projectResults = await db
@@ -81,23 +118,36 @@ export async function POST(request: NextRequest) {
 
     const project = projectResults[0]
 
-    // Build reply text
-    const baseUrl = process.env.NEXT_PUBLIC_APP_URL || 'https://capsulethis.com'
-    const projectUrl = `${baseUrl}/p/${projectId}`
+    // Get xBotReplies record to find firstReplyTweetId and appDescription
+    const replyRecord = await db
+      .select()
+      .from(xBotReplies)
+      .where(eq(xBotReplies.tweetId, tweetId))
+      .limit(1)
 
-    const replyText = `Your app "${project.title}" is ready! 🚀\n\nView and edit: ${projectUrl}`
+    // Determine which tweet to reply to for proper threading
+    // Reply to the first reply tweet to create a thread, fallback to original tweet
+    const replyToTweetId = replyRecord[0]?.firstReplyTweetId || tweetId
+
+    // Build reply text with app details
+    const appDescription = replyRecord[0]?.appDescription || null
+    const replyText = buildReplyText(
+      project.title || 'Untitled App',
+      appDescription,
+      projectId
+    )
 
     // Send reply via Twitter API
     const client = await getAuthClient()
     const response = await client.tweets.createTweet({
       text: replyText,
-      reply: { in_reply_to_tweet_id: tweetId },
+      reply: { in_reply_to_tweet_id: replyToTweetId },
     })
 
     console.log(`[X-Bot Reply] Response:`, JSON.stringify(response))
 
     if (response.data?.id) {
-      // Update xBotReplies with reply info
+      // Update xBotReplies with final reply info
       await db
         .update(xBotReplies)
         .set({
@@ -116,7 +166,9 @@ export async function POST(request: NextRequest) {
         replyText,
       })
     } else {
-      console.error(`[X-Bot Reply] No reply ID returned for tweet ${tweetId}`)
+      console.error(
+        `[X-Bot Reply] No reply ID returned for tweet ${tweetId}`
+      )
 
       await db
         .update(xBotReplies)