1import { mkdir } from 'node:fs/promises';
2import process from 'node:process';
3import {
4  CHROME_CANDIDATES_FULL,
5  CdpConnection,
6  findExistingChromeDebugPort,
7  getDefaultProfileDir,
8  gracefulKillChrome,
9  launchChrome,
10  openPageSession,
11  sleep,
12  waitForXSessionPersistence,
13  waitForChromeDebugPort,
14} from './x-utils.js';
15 
16function extractTweetUrl(urlOrId: string): string | null {
17  // If it's already a full URL, normalize it
18  if (urlOrId.match(/(?:x\.com|twitter\.com)\/\w+\/status\/\d+/)) {
19    return urlOrId.replace(/twitter\.com/, 'x.com').split('?')[0];
20  }
21  return null;
22}
23 
24interface QuoteOptions {
25  tweetUrl: string;
26  comment?: string;
27  submit?: boolean;
28  timeoutMs?: number;
29  profileDir?: string;
30  chromePath?: string;
31}
32 
33export async function quotePost(options: QuoteOptions): Promise<void> {
34  const { tweetUrl, comment, submit = false, timeoutMs = 120_000, profileDir = getDefaultProfileDir() } = options;
35 
36  await mkdir(profileDir, { recursive: true });
37 
38  const existingPort = await findExistingChromeDebugPort(profileDir);
39  const reusing = existingPort !== null;
40  let port = existingPort ?? 0;
41  console.log(`[x-quote] Opening tweet: ${tweetUrl}`);
42  let chrome: Awaited<ReturnType<typeof launchChrome>>['chrome'] | null = null;
43  if (!reusing) {
44    const launched = await launchChrome(tweetUrl, profileDir, CHROME_CANDIDATES_FULL, options.chromePath);
45    port = launched.port;
46    chrome = launched.chrome;
47  }
48 
49  if (reusing) console.log(`[x-quote] Reusing existing Chrome on port ${port}`);
50  else console.log(`[x-quote] Launching Chrome (profile: ${profileDir})`);
51 
52  let cdp: CdpConnection | null = null;
53  let sessionId: string | null = null;
54  let targetId: string | null = null;
55  let loggedInDuringRun = false;
56 
57  try {
58    const wsUrl = await waitForChromeDebugPort(port, 30_000, { includeLastError: true });
59    cdp = await CdpConnection.connect(wsUrl, 30_000, { defaultTimeoutMs: 15_000 });
60 
61    const page = await openPageSession({
62      cdp,
63      reusing,
64      url: tweetUrl,
65      matchTarget: (target) => target.type === 'page' && target.url.includes('x.com'),
66      enablePage: true,
67      enableRuntime: true,
68      enableNetwork: true,
69    });
70    const activeSessionId = page.sessionId;
71    sessionId = activeSessionId;
72    targetId = page.targetId;
73 
74    console.log('[x-quote] Waiting for tweet to load...');
75    await sleep(3000);
76 
77    // Wait for retweet button to appear (indicates tweet loaded and user logged in)
78    const waitForRetweetButton = async (): Promise<boolean> => {
79      const start = Date.now();
80      while (Date.now() - start < timeoutMs) {
81        const result = await cdp!.send<{ result: { value: boolean } }>('Runtime.evaluate', {
82          expression: `!!document.querySelector('[data-testid="retweet"]')`,
83          returnByValue: true,
84        }, { sessionId: activeSessionId });
85        if (result.result.value) return true;
86        await sleep(1000);
87      }
88      return false;
89    };
90 
91    const retweetFound = await waitForRetweetButton();
92    if (!retweetFound) {
93      console.log('[x-quote] Tweet not found or not logged in. Please log in to X in the browser window.');
94      console.log('[x-quote] Waiting for login...');
95      const loggedIn = await waitForRetweetButton();
96      if (!loggedIn) throw new Error('Timed out waiting for tweet. Please log in first or check the tweet URL.');
97      loggedInDuringRun = true;
98    }
99 
100    // Click the retweet button
101    console.log('[x-quote] Clicking retweet button...');
102    await cdp.send('Runtime.evaluate', {
103      expression: `document.querySelector('[data-testid="retweet"]')?.click()`,
104    }, { sessionId: activeSessionId });
105    await sleep(1000);
106 
107    // Wait for and click the "Quote" option in the menu
108    console.log('[x-quote] Selecting quote option...');
109    const waitForQuoteOption = async (): Promise<boolean> => {
110      const start = Date.now();
111      while (Date.now() - start < 10_000) {
112        const result = await cdp!.send<{ result: { value: boolean } }>('Runtime.evaluate', {
113          expression: `!!document.querySelector('[data-testid="Dropdown"] [role="menuitem"]:nth-child(2)')`,
114          returnByValue: true,
115        }, { sessionId: activeSessionId });
116        if (result.result.value) return true;
117        await sleep(200);
118      }
119      return false;
120    };
121 
122    const quoteOptionFound = await waitForQuoteOption();
123    if (!quoteOptionFound) {
124      throw new Error('Quote option not found. The menu may not have opened.');
125    }
126 
127    // Click the quote option (second menu item)
128    await cdp.send('Runtime.evaluate', {
129      expression: `document.querySelector('[data-testid="Dropdown"] [role="menuitem"]:nth-child(2)')?.click()`,
130    }, { sessionId: activeSessionId });
131    await sleep(2000);
132 
133    // Wait for the quote compose dialog
134    console.log('[x-quote] Waiting for quote compose dialog...');
135    const waitForQuoteDialog = async (): Promise<boolean> => {
136      const start = Date.now();
137      while (Date.now() - start < 10_000) {
138        const result = await cdp!.send<{ result: { value: boolean } }>('Runtime.evaluate', {
139          expression: `!!document.querySelector('[data-testid="tweetTextarea_0"]')`,
140          returnByValue: true,
141        }, { sessionId: activeSessionId });
142        if (result.result.value) return true;
143        await sleep(200);
144      }
145      return false;
146    };
147 
148    const dialogFound = await waitForQuoteDialog();
149    if (!dialogFound) {
150      throw new Error('Quote compose dialog not found.');
151    }
152 
153    // Type the comment if provided
154    if (comment) {
155      console.log('[x-quote] Typing comment...');
156      // Use CDP Input.insertText for more reliable text insertion
157      await cdp.send('Runtime.evaluate', {
158        expression: `document.querySelector('[data-testid="tweetTextarea_0"]')?.focus()`,
159      }, { sessionId: activeSessionId });
160      await sleep(200);
161 
162      await cdp.send('Input.insertText', {
163        text: comment,
164      }, { sessionId: activeSessionId });
165      await sleep(500);
166    }
167 
168    if (submit) {
169      console.log('[x-quote] Submitting quote post...');
170      await cdp.send('Runtime.evaluate', {
171        expression: `document.querySelector('[data-testid="tweetButton"]')?.click()`,
172      }, { sessionId: activeSessionId });
173      await sleep(2000);
174      console.log('[x-quote] Quote post submitted!');
175    } else {
176      console.log('[x-quote] Quote composed (preview mode). Add --submit to post.');
177      console.log('[x-quote] Browser will stay open for 30 seconds for preview...');
178      await sleep(30_000);
179    }
180  } finally {
181    let leaveChromeOpen = false;
182    if (chrome && loggedInDuringRun && cdp && sessionId) {
183      console.log('[x-quote] Waiting for X session cookies to persist...');
184      const sessionReady = await waitForXSessionPersistence({ cdp, sessionId });
185      if (!sessionReady) {
186        console.warn('[x-quote] X session cookies not observed yet. Leaving Chrome open so login can finish persisting.');
187        leaveChromeOpen = true;
188      }
189    }
190 
191    if (cdp) {
192      if (reusing && targetId) {
193        try { await cdp.send('Target.closeTarget', { targetId }, { timeoutMs: 5_000 }); } catch {}
194      }
195      cdp.close();
196    }
197    if (chrome) {
198      if (leaveChromeOpen) {
199        chrome.unref();
200      } else {
201        await gracefulKillChrome(chrome, port);
202      }
203    }
204  }
205}
206 
207function printUsage(): never {
208  console.log(`Quote a tweet on X (Twitter) using real Chrome browser
209 
210Usage:
211  npx -y bun x-quote.ts <tweet-url> [options] [comment]
212 
213Options:
214  --submit         Actually post (default: preview only)
215  --profile <dir>  Chrome profile directory
216  --help           Show this help
217 
218Examples:
219  npx -y bun x-quote.ts https://x.com/user/status/123456789 "Great insight!"
220  npx -y bun x-quote.ts https://x.com/user/status/123456789 "I agree!" --submit
221`);
222  process.exit(0);
223}
224 
225async function main(): Promise<void> {
226  const args = process.argv.slice(2);
227  if (args.includes('--help') || args.includes('-h')) printUsage();
228 
229  let tweetUrl: string | undefined;
230  let submit = false;
231  let profileDir: string | undefined;
232  const commentParts: string[] = [];
233 
234  for (let i = 0; i < args.length; i++) {
235    const arg = args[i]!;
236    if (arg === '--submit') {
237      submit = true;
238    } else if (arg === '--profile' && args[i + 1]) {
239      profileDir = args[++i];
240    } else if (!arg.startsWith('-')) {
241      // First non-option argument is the tweet URL
242      if (!tweetUrl && arg.match(/(?:x\.com|twitter\.com)\/\w+\/status\/\d+/)) {
243        tweetUrl = extractTweetUrl(arg) ?? undefined;
244      } else {
245        commentParts.push(arg);
246      }
247    }
248  }
249 
250  if (!tweetUrl) {
251    console.error('Error: Please provide a tweet URL.');
252    console.error('Example: npx -y bun x-quote.ts https://x.com/user/status/123456789 "Your comment"');
253    process.exit(1);
254  }
255 
256  const comment = commentParts.join(' ').trim() || undefined;
257 
258  await quotePost({ tweetUrl, comment, submit, profileDir });
259}
260 
261await main().catch((err) => {
262  console.error(`Error: ${err instanceof Error ? err.message : String(err)}`);
263  process.exit(1);
264});
265