Compare commits

..

19 Commits

Author SHA1 Message Date
NAME 7af67c2056 Update 2026-05-24 01:40:08 +00:00
NAME 6d66ecb13e Update 2026-05-23 16:36:37 +00:00
NAME 9d2b9a1f90 Update 2026-05-23 16:24:11 +00:00
NAME 574f0944fa Update 2026-05-23 16:11:12 +00:00
NAME f4b1ebfe51 Update 2026-05-23 06:26:01 +00:00
NAME 79022be20b Update 2026-05-22 03:14:03 +00:00
NAME eeaae0b0b9 Update 2026-05-21 05:39:28 +00:00
NAME 8df31c96e1 Update 2026-05-21 05:33:42 +00:00
NAME e107464716 Update 2026-05-21 05:27:30 +00:00
NAME fe22461a07 Update 2026-05-20 03:10:28 +00:00
NAME b18cd6d79f Update 2026-05-20 03:00:33 +00:00
NAME 85cca5a5c3 Merge branch 'master' of https://git.realflashkaze.duckdns.org/realflashkaze/x-poster-client 2026-05-20 02:57:08 +00:00
Your Name 21fd90a069 D 2026-05-20 09:55:59 +07:00
NAME a6a4ae6e00 Update 2026-05-18 02:42:09 +00:00
NAME 79bc738e1f Update 2026-05-17 08:24:17 +00:00
NAME 1025ce9778 Update 2026-05-16 16:47:17 +00:00
NAME 1608122288 Update 2026-05-16 16:15:01 +00:00
NAME e506996855 Update 2026-05-16 14:02:06 +00:00
NAME 6a7856065a Update 2026-05-16 11:58:13 +00:00
12 changed files with 947 additions and 104 deletions
+2
View File
@@ -60,3 +60,5 @@ dist
dist.zip
data/*
x_profile_data
x_profile_data/*
+86 -19
View File
@@ -1,32 +1,63 @@
console.log('[XAI Background] ✅ Service worker started');
// ===== MENU =====
// ===== TẠO MENU: XÓA CŨ → TẠO MỚI, KHÔNG GỘP =====
chrome.runtime.onInstalled.addListener(() => {
chrome.contextMenus.create({
id: 'writeComment',
title: '✍️ Viết comment',
contexts: ['all'],
documentUrlPatterns: ['https://x.com/*']
chrome.contextMenus.removeAll(() => {
// Menu 1: Comment — KHÔNG cần bôi đen, chỉ trên X
chrome.contextMenus.create({
id: 'writeComment',
title: '✍️ Viết comment',
contexts: ['all'],
documentUrlPatterns: ['https://x.com/*']
});
// Menu 2: Dịch — CHỈ hiện khi đã bôi đen text, có thể dùng trên mọi trang
chrome.contextMenus.create({
id: 'translateText',
title: '🌐 Dịch văn bản',
contexts: ['selection'],
documentUrlPatterns: ['https://x.com/*', 'http://*/*', 'https://*/*']
});
});
});
// FIRE & FORGET — không đợi content trả lời
// ===== XỬ LÝ CLICK MENU =====
chrome.contextMenus.onClicked.addListener((info, tab) => {
if (info.menuItemId !== 'writeComment' || !tab?.id) return;
chrome.tabs.sendMessage(tab.id, { action: 'OPEN_FORM' }).catch(() => {});
if (!tab?.id) return;
if (info.menuItemId === 'writeComment') {
// Gửi xuống content: mở form comment
chrome.tabs.sendMessage(tab.id, { action: 'OPEN_FORM' }).catch(() => {});
return;
}
if (info.menuItemId === 'translateText' && info.selectionText) {
// Gửi xuống content: mở tab Dịch + fill text sẵn
chrome.tabs.sendMessage(tab.id, {
action: 'OPEN_TRANSLATE_FORM',
text: info.selectionText
}).catch(() => {});
return;
}
});
// LUÔN GỌI sendResponse(), KHÔNG BAO GIỜ return true
// ===== NHẬN MESSAGE TỪ CONTENT =====
chrome.runtime.onMessage.addListener((request, sender, sendResponse) => {
if (request.action === 'GENERATE_COMMENT') {
handleGenerate(request.data, sender.tab.id);
sendResponse({ received: true });
return false;
}
if (request.action === 'TRANSLATE_TEXT') {
handleTranslate(request.data, sender.tab.id);
sendResponse({ received: true });
return false;
}
sendResponse({ unknown: true });
return false;
});
// ===== GỌI API COMMENT =====
async function handleGenerate({ text, lang, tone, angle }, tabId) {
const cfg = await chrome.storage.local.get(['apiUrl', 'apiKey']);
if (!cfg.apiUrl || !cfg.apiKey) {
@@ -38,25 +69,61 @@ async function handleGenerate({ text, lang, tone, angle }, tabId) {
}
try {
const payload = {
originalPost: text,
language: lang,
tone: tone?tone.toLowerCase():undefined,
angle: angle?angle.toLowerCase():undefined,
};
const res = await fetch(cfg.apiUrl, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
'Authorization': `Bearer ${cfg.apiKey}`
},
body: JSON.stringify(payload)
body: JSON.stringify({ tweet_text: text, lang, tone, angle })
});
const data = await res.json();
if (!res.ok) throw new Error(`HTTP ${res.status}`);
const comment = data.comment || data.text || JSON.stringify(data);
await chrome.tabs.sendMessage(tabId, { action: 'SHOW_RESULT', comment }).catch(() => {});
await chrome.tabs.sendMessage(tabId, {
action: 'SHOW_RESULT',
comment: data.comment || data.text || JSON.stringify(data),
model: data.model || '',
commentTransVi: data.commentTransVi || '',
commentTransModel: data.commentTransModel || '',
}).catch(() => {});
} catch (err) {
await chrome.tabs.sendMessage(tabId, { action: 'SHOW_ERROR', error: err.message }).catch(() => {});
}
}
// ===== GỌI API DỊCH =====
async function handleTranslate({ text, target_lang, target_model }, tabId) {
const cfg = await chrome.storage.local.get(['apiUrl','apiKey','translateUrl','translateKey']);
const url = cfg.translateUrl || cfg.apiUrl;
const key = cfg.translateKey || cfg.apiKey;
if (!url || !key) {
await chrome.tabs.sendMessage(tabId, {
action: 'SHOW_TRANSLATE_ERROR',
error: '⚠️ Chưa cấu hình API.'
}).catch(() => {});
return;
}
try {
const res = await fetch(url, {
method: 'POST',
headers: {
'Content-Type': 'application/json',
'Authorization': `Bearer ${key}`
},
body: JSON.stringify({ text, target_lang, target_model })
});
const data = await res.json();
if (!res.ok) throw new Error(`HTTP ${res.status}`);
await chrome.tabs.sendMessage(tabId, {
action: 'SHOW_TRANSLATE_RESULT',
content: data.content || data.text || data.translation || JSON.stringify(data),
model: data.model || '',
}).catch(() => {});
} catch (err) {
await chrome.tabs.sendMessage(tabId, { action: 'SHOW_TRANSLATE_ERROR', error: err.message }).catch(() => {});
}
}
+254 -53
View File
@@ -2,21 +2,28 @@
'use strict';
let lastTweetText = '';
let lastSelectedText = '';
let sidebarHost = null;
let isTyping = false; // chặn bấm paste nhiều lần
let isTyping = false;
// ===== DATA =====
const LANGS = [
{ value: 'en', label: 'English' ,selected: true },
{ value: 'vi', label: 'Việt' },
{ value: 'en', label: 'English' },
{ value: 'ja', label: 'Nhật' },
{ value: 'ko', label: 'Han' },
{ value: 'cn', label: 'TQ' }
];
const ModelAI = [
{ value: 'openai', label: 'Chat GPT' },
{ value: 'google', label: 'Gemini' },
{ value: 'deepseek', label: 'Deep Seek' },
]
const TONE_BASE = [
{ value: 'CASUAL', text: 'Giản dị, thân thiện' , selected: true },
{ value: 'PROFESSIONAL', text: 'chuyên nghiệp, rõ ràng, đáng tin cậy' },
{ value: 'CASUAL', text: 'Giản dị, thân thiện' },
{ value: 'HYPE', text: 'Hype — Hào hứng, tràn đầy năng lượng' },
{ value: 'URGENT', text: 'urgent' },
{ value: 'HUMOROUS', text: 'Dí dỏm, hài hước' },
@@ -35,6 +42,7 @@
];
const ANGLE_DEFAULT = [
{ value: 'NATURAL', text: 'Phản ứng tự nhiên' },
{ value: 'AGREE', text: 'Đồng ý' },
{ value: 'CHALLENGE', text: 'Không đồng ý' },
{ value: 'ADD_INFO', text: 'Thêm thông tin liên quan hữu ích' },
@@ -63,18 +71,22 @@
return tone === 'EMPATHETIC' ? [...ANGLE_DEFAULT, ...ANGLE_EMPATHY] : [...ANGLE_DEFAULT];
}
// ===== A. CAPTURE TWEET =====
// ===== A. CAPTURE TWEET & SELECTED TEXT =====
document.addEventListener('contextmenu', (e) => {
const sel = window.getSelection().toString().trim();
if (sel) lastSelectedText = sel;
const article = e.target.closest('article');
if (!article) { lastTweetText = ''; return; }
const textEl =
article.querySelector('[data-testid="tweetText"]') ||
article.querySelector('div[lang]') ||
article.querySelector('div[dir="auto"]');
lastTweetText = textEl ? textEl.innerText.trim() : article.innerText.trim().slice(0, 600);
if (article) {
const textEl =
article.querySelector('[data-testid="tweetText"]') ||
article.querySelector('div[lang]') ||
article.querySelector('div[dir="auto"]');
lastTweetText = textEl ? textEl.innerText.trim() : article.innerText.trim().slice(0, 600);
}
});
// ===== B. LISTENER — FIX LỖI CHANNEL =====
// ===== B. LISTENER =====
chrome.runtime.onMessage.addListener((req, sender, sendResponse) => {
if (req.action === 'OPEN_FORM') {
if (!lastTweetText) {
@@ -85,8 +97,19 @@
sendResponse({ ok: true });
return false;
}
if (req.action === 'OPEN_TRANSLATE_FORM') {
openSidebar('');
switchTab('translate');
const s = sidebarHost?.shadowRoot;
if (s) {
const input = s.querySelector('#trans-input');
if (input) input.value = req.text || '';
}
sendResponse({ ok: true });
return false;
}
if (req.action === 'SHOW_RESULT') {
showResult(req.comment);
showResult(req.comment, req.model, req.commentTransVi, req.commentTransModel);
sendResponse({ ok: true });
return false;
}
@@ -95,6 +118,16 @@
sendResponse({ ok: true });
return false;
}
if (req.action === 'SHOW_TRANSLATE_RESULT') {
showTranslateResult(req.content, req.model);
sendResponse({ ok: true });
return false;
}
if (req.action === 'SHOW_TRANSLATE_ERROR') {
showTranslateError(req.error);
sendResponse({ ok: true });
return false;
}
sendResponse({ ok: false, unknown: true });
return false;
});
@@ -152,8 +185,25 @@
}
// ===== D. SIDEBAR UI =====
function switchTab(name) {
if (!sidebarHost) return;
const s = sidebarHost.shadowRoot;
s.querySelectorAll('.tab-btn').forEach(b => b.classList.toggle('active', b.dataset.tab === name));
s.querySelectorAll('.tab-content').forEach(c => c.classList.toggle('active', c.id === `tab-${name}`));
}
function openSidebar(tweetText) {
removeSidebar();
// ⭐ FIX: Nếu mở comment mới (có tweetText), xóa sidebar cũ để render lại từ đầu
if (tweetText && sidebarHost) {
removeSidebar();
}
// Nếu sidebar vẫn còn (trường hợp translate hoặc đang mở), chỉ cần mở drawer
if (sidebarHost) {
const drawer = sidebarHost.shadowRoot.querySelector('.drawer');
if (drawer) drawer.classList.add('open');
return;
}
const host = document.createElement('div');
host.id = 'x-ai-sidebar-host';
@@ -186,11 +236,12 @@
.tab-btn.active { color: #1d9bf0; border-bottom-color: #1d9bf0; }
.tab-content { padding: 16px 18px; flex: 1; overflow-y: auto; display: none; flex-direction: column; gap: 10px; }
.tab-content.active { display: flex; }
.tweet-box { background: #f7f9f9; border: 1px solid #cfd9de; border-radius: 10px; padding: 10px; font-size: 13px;
.tweet-box { background: #f7f9f9; border: 1px solid #cfd9de; border-radius: 10px; padding: 10px; font-size: 16px;
line-height: 1.4; max-height: 150px; overflow-y: auto; color: #333; white-space: pre-wrap; word-break: break-word; }
label { font-size: 12px; font-weight: 700; color: #536471; text-transform: uppercase; letter-spacing: .3px; margin-top: 4px; }
select, input[type="text"], input[type="password"] { width: 100%; padding: 9px 10px; border-radius: 8px; border: 1px solid #cfd9de;
font-size: 14px; background: #fff; box-sizing: border-box; }
select, input[type="text"], input[type="password"], textarea { width: 100%; padding: 9px 10px; border-radius: 8px; border: 1px solid #cfd9de;
font-size: 14px; background: #fff; box-sizing: border-box; font-family: inherit; }
textarea { resize: vertical; min-height: 80px; }
.hint-text { font-size: 12px; color: #888; line-height: 1.4; font-style: italic; }
button.primary { width: 100%; padding: 10px; border-radius: 9999px; border: none; background: #1d9bf0; color: #fff;
font-weight: 700; font-size: 15px; cursor: pointer; margin-top: 6px; }
@@ -204,6 +255,7 @@
white-space: pre-wrap; word-break: break-word; }
.status.ok { background: #e8f6fe; border: 1px solid #b4dffc; }
.status.err { background: #ffeaea; border: 1px solid #ffc5c5; color: #b00; }
.status.trans { background: #f0fdf4; border: 1px solid #86efac; color: #14532d; }
.copy-hint { font-size: 12px; color: #536471; text-align: center; display: none; }
.badge { display: inline-block; padding: 2px 8px; border-radius: 999px; background: #ffad1f; color: #fff; font-size: 11px; font-weight: 700; }
.typing-opts { margin-top: 8px; padding-top: 10px; border-top: 1px solid #eff3f4; display: none; flex-direction: column; gap: 8px; }
@@ -223,6 +275,7 @@
<div class="header"><span>✍️ AI Comment</span><button class="btn-x">✕</button></div>
<div class="tabs">
<button class="tab-btn active" data-tab="comment">Comment</button>
<button class="tab-btn" data-tab="translate">🌐 Dịch</button>
<button class="tab-btn" data-tab="config">⚙️ Config <span class="badge" id="cfg-missing" style="display:none">!</span></button>
</div>
@@ -243,7 +296,8 @@
<button class="primary" id="ai-run">🚀 Tạo Comment</button>
<div class="status" id="ai-status"></div>
<div class="copy-hint" id="ai-hint">📋 Copy kết quả và dán vào ô reply!</div>
<div class="status trans" id="ai-trans-vi" style="display:none;"></div>
<div class="copy-hint" id="ai-hint"></div>
<div class="typing-opts" id="ai-typing-opts">
<label class="check-row">
@@ -260,14 +314,47 @@
</div>
</div>
<div class="tab-content" id="tab-translate">
<div style="font-size:13px;color:#536471;margin-bottom:6px;">
Nhập văn bản và chọn ngôn ngữ cần dịch. API translate lấy từ tab Config.
</div>
<label>Văn bản cần dịch</label>
<textarea id="trans-input" style="font-size:18px" placeholder="Nhập hoặc bôi đen rồi chuột phải..."></textarea>
<div style="display: flex">
<div>
<label>Ngôn ngữ đích</label>
<select id="trans-target">${LANGS.map(l => `<option value="${l.value}" ${l.value === 'ja' ? 'selected' : ''}>${l.label}</option>`).join('')}</select>
</div>
<div>
<label>Model</label>
<select id="trans-model">${ModelAI.map(l => `<option value="${l.value}" ${l.value === 'openai' ? 'selected' : ''}>${l.label}</option>`).join('')}</select>
</div>
</div>
<button class="primary" id="trans-run">🌐 Dịch</button>
<div class="status" id="trans-status"></div>
<div class="copy-hint" id="trans-hint"></div>
<div class="btn-row">
<button class="primary gray" id="trans-copy">📋 Copy</button>
<button class="primary green" id="trans-paste">📥 Dán vào ô reply</button>
</div>
</div>
<div class="tab-content" id="tab-config">
<div style="font-size:13px; color:#536471; margin-bottom:6px;">
Nhập API của bạn. Dữ liệu được lưu trên trình duyệt này.
Cấu hình API. Nếu Translate URL để trống, sẽ dùng chung Comment URL.
</div>
<label>API URL</label>
<label>Comment API URL</label>
<input type="text" id="cfg-url" placeholder="https://api.yoursite.com/v1/generate">
<label>API Key</label>
<label>Comment API Key</label>
<input type="password" id="cfg-key" placeholder="sk-...">
<label>Translate API URL (tùy chọn)</label>
<input type="text" id="cfg-trans-url" placeholder="https://api.yoursite.com/v1/translate">
<label>Translate API Key (tùy chọn)</label>
<input type="password" id="cfg-trans-key" placeholder="sk-...">
<div style="display:flex; gap:8px;">
<button class="primary" id="cfg-save" style="flex:1">💾 Lưu</button>
<button class="primary green" id="cfg-test" style="flex:1">🧪 Test đọc</button>
@@ -306,6 +393,7 @@
const angleHint= drawer.querySelector('#ai-angle-hint');
const runBtn = drawer.querySelector('#ai-run');
const statusEl = drawer.querySelector('#ai-status');
const transViEl= drawer.querySelector('#ai-trans-vi');
const copyHint = drawer.querySelector('#ai-hint');
const typingOpts = drawer.querySelector('#ai-typing-opts');
const typingChk = drawer.querySelector('#ai-typing');
@@ -350,7 +438,9 @@
const angle = angleSel.value;
runBtn.disabled = true;
statusEl.style.display = 'block'; statusEl.className = 'status ok';
statusEl.textContent = '⏳ Đang gọi API...'; copyHint.style.display = 'none';
statusEl.textContent = '⏳ Đang gọi API...';
transViEl.style.display = 'none'; transViEl.textContent = '';
copyHint.style.display = 'none';
typingOpts.classList.remove('visible');
chrome.runtime.sendMessage(
@@ -365,28 +455,18 @@
);
});
// COPY BUTTON
copyBtn.addEventListener('click', async () => {
const text = statusEl.textContent;
if (!text || text.startsWith('⏳') || text.startsWith('Lỗi') || text.startsWith('⚠️')) {
const old = copyBtn.textContent;
copyBtn.textContent = '⚠️ Chưa có nội dung!';
setTimeout(() => copyBtn.textContent = old, 1200);
flashBtn(copyBtn, '⚠️ Chưa có nội dung!');
return;
}
try {
await navigator.clipboard.writeText(text);
const old = copyBtn.textContent;
copyBtn.textContent = '✅ Đã copy!';
setTimeout(() => copyBtn.textContent = old, 1200);
} catch (e) {
const old = copyBtn.textContent;
copyBtn.textContent = '❌ Lỗi copy';
setTimeout(() => copyBtn.textContent = old, 1200);
}
flashBtn(copyBtn, '✅ Đã copy!');
} catch (e) { flashBtn(copyBtn, '❌ Lỗi copy'); }
});
// PASTE BUTTON
pasteBtn.addEventListener('click', async () => {
const text = statusEl.textContent;
if (!text || text.startsWith('⏳') || text.startsWith('Lỗi') || text.startsWith('⚠️')) {
@@ -394,9 +474,7 @@
return;
}
if (isTyping) return;
isTyping = true;
pasteBtn.disabled = true;
isTyping = true; pasteBtn.disabled = true;
try {
if (typingChk.checked) {
pasteBtn.textContent = '⌨️ Đang gõ...';
@@ -410,76 +488,199 @@
console.error('Typing error:', err);
alert('Lỗi khi nhập: ' + err.message);
} finally {
isTyping = false;
pasteBtn.disabled = false;
isTyping = false; pasteBtn.disabled = false;
pasteBtn.textContent = '📥 Dán vào ô reply';
}
});
// ===== TRANSLATE TAB =====
const transInput = drawer.querySelector('#trans-input');
const transTarget= drawer.querySelector('#trans-target');
const transModel= drawer.querySelector('#trans-model');
const transRun = drawer.querySelector('#trans-run');
const transStatus= drawer.querySelector('#trans-status');
const transHint = drawer.querySelector('#trans-hint');
const transCopy = drawer.querySelector('#trans-copy');
const transPaste = drawer.querySelector('#trans-paste');
transRun.addEventListener('click', () => {
const text = transInput.value.trim();
const target = transTarget.value;
const targetModel = transModel.value;
if (!text) { flashBtn(transRun, '⚠️ Nhập văn bản!'); return; }
transRun.disabled = true;
transStatus.style.display = 'block'; transStatus.className = 'status ok';
transStatus.textContent = '⏳ Đang dịch...';
transHint.style.display = 'none';
chrome.runtime.sendMessage(
{ action: 'TRANSLATE_TEXT', data: { text, target_lang: target, target_model: targetModel } },
() => {
if (chrome.runtime.lastError) {
transStatus.className = 'status err';
transStatus.textContent = 'Lỗi kết nối: ' + chrome.runtime.lastError.message;
transRun.disabled = false;
}
}
);
});
transCopy.addEventListener('click', async () => {
const text = transStatus.textContent;
if (!text || text.startsWith('⏳')) { flashBtn(transCopy, '⚠️ Chưa có!'); return; }
try { await navigator.clipboard.writeText(text); flashBtn(transCopy, '✅ Đã copy!'); }
catch (e) { flashBtn(transCopy, '❌ Lỗi'); }
});
transPaste.addEventListener('click', async () => {
const text = transStatus.textContent;
if (!text || text.startsWith('⏳')) { alert('Chưa có kết quả dịch!'); return; }
if (isTyping) return;
isTyping = true; transPaste.disabled = true;
try {
transPaste.textContent = '⌨️ Đang gõ...';
const ok = await simulateHumanTyping(text);
if (ok) drawer.classList.remove('open');
} catch (err) {
alert('Lỗi khi nhập: ' + err.message);
} finally {
isTyping = false; transPaste.disabled = false;
transPaste.textContent = '📥 Dán vào ô reply';
}
});
// ===== CONFIG TAB =====
const urlIn = drawer.querySelector('#cfg-url');
const keyIn = drawer.querySelector('#cfg-key');
const saveBtn = drawer.querySelector('#cfg-save');
const testBtn = drawer.querySelector('#cfg-test');
const cfgStatus= drawer.querySelector('#cfg-status');
const cfgBadge = drawer.querySelector('#cfg-missing');
const urlIn = drawer.querySelector('#cfg-url');
const keyIn = drawer.querySelector('#cfg-key');
const transUrlIn= drawer.querySelector('#cfg-trans-url');
const transKeyIn= drawer.querySelector('#cfg-trans-key');
const saveBtn = drawer.querySelector('#cfg-save');
const testBtn = drawer.querySelector('#cfg-test');
const cfgStatus = drawer.querySelector('#cfg-status');
const cfgBadge = drawer.querySelector('#cfg-missing');
function showCfgStatus(msg, isErr) {
cfgStatus.style.display = 'block';
cfgStatus.className = 'status ' + (isErr ? 'err' : 'ok');
cfgStatus.textContent = msg;
}
chrome.storage.local.get(['apiUrl', 'apiKey'], (cfg) => {
chrome.storage.local.get(['apiUrl','apiKey','translateUrl','translateKey'], (cfg) => {
if (cfg.apiUrl) urlIn.value = cfg.apiUrl;
if (cfg.apiKey) keyIn.value = cfg.apiKey;
if (cfg.translateUrl) transUrlIn.value = cfg.translateUrl;
if (cfg.translateKey) transKeyIn.value = cfg.translateKey;
cfgBadge.style.display = (!cfg.apiUrl || !cfg.apiKey) ? 'inline-block' : 'none';
});
saveBtn.addEventListener('click', () => {
const url = urlIn.value.trim(), key = keyIn.value.trim();
if (!url || !key) { showCfgStatus('❌ URL và Key không được để trống!', true); return; }
if (!url || !key) { showCfgStatus('❌ Comment URL và Key không được để trống!', true); return; }
try { new URL(url); } catch { showCfgStatus('❌ URL không hợp lệ', true); return; }
chrome.storage.local.set({ apiUrl: url, apiKey: key }, () => {
const tUrl = transUrlIn.value.trim();
const tKey = transKeyIn.value.trim();
chrome.storage.local.set({
apiUrl: url, apiKey: key,
translateUrl: tUrl, translateKey: tKey
}, () => {
showCfgStatus('✅ Đã lưu!', false);
cfgBadge.style.display = 'none';
});
});
testBtn.addEventListener('click', () => {
chrome.storage.local.get(['apiUrl', 'apiKey'], (cfg) => {
showCfgStatus(`URL: ${cfg.apiUrl || '(trống)'}\nKey: ${cfg.apiKey ? cfg.apiKey.slice(0,8)+'...' : '(trống)'}`, !cfg.apiUrl || !cfg.apiKey);
chrome.storage.local.get(['apiUrl','apiKey','translateUrl','translateKey'], (cfg) => {
const tUrl = cfg.translateUrl || cfg.apiUrl || '(trống)';
showCfgStatus(
`Comment: ${cfg.apiUrl || '(trống)'}\n` +
`Translate: ${tUrl}\n` +
`Key: ${cfg.apiKey ? cfg.apiKey.slice(0,8)+'...' : '(trống)'}`,
!cfg.apiUrl || !cfg.apiKey
);
});
});
}
// ===== SHOW RESULT / ERROR =====
function showResult(comment) {
function showResult(comment, model='', transVi='', transByModal = '') {
if (!sidebarHost) return;
const s = sidebarHost.shadowRoot;
const statusEl = s.querySelector('#ai-status');
const transViEl= s.querySelector('#ai-trans-vi');
const copyHint = s.querySelector('#ai-hint');
const runBtn = s.querySelector('#ai-run');
const drawer = s.querySelector('.drawer');
const typingOpts = s.querySelector('#ai-typing-opts');
if (statusEl) { statusEl.style.display = 'block'; statusEl.className = 'status ok'; statusEl.textContent = comment; }
if (copyHint) copyHint.style.display = 'block';
console.log({model});
if (statusEl) {
statusEl.style.display = 'block';
statusEl.className = 'status ok';
statusEl.textContent = comment;
}
if (transViEl) {
if (transVi) {
transViEl.style.display = 'block';
transViEl.textContent = '🇻🇳 ' + transVi;
} else {
transViEl.style.display = 'none';
transViEl.textContent = '';
}
}
if (copyHint) { copyHint.style.display = 'block'; copyHint.textContent = `W:${model} - T:${transByModal}` || '📋 Copy kết quả và dán vào ô reply!'; }
if (runBtn) runBtn.disabled = false;
if (drawer) drawer.classList.add('open');
if (typingOpts) typingOpts.classList.add('visible');
}
function showError(msg) {
if (!sidebarHost) return;
const s = sidebarHost.shadowRoot;
const statusEl = s.querySelector('#ai-status');
const transViEl= s.querySelector('#ai-trans-vi');
const runBtn = s.querySelector('#ai-run');
const drawer = s.querySelector('.drawer');
if (statusEl) { statusEl.style.display = 'block'; statusEl.className = 'status err'; statusEl.textContent = msg; }
if (transViEl) { transViEl.style.display = 'none'; transViEl.textContent = ''; }
if (runBtn) runBtn.disabled = false;
if (drawer) drawer.classList.add('open');
}
function showTranslateResult(content, model = '') {
if (!sidebarHost) return;
const s = sidebarHost.shadowRoot;
const status = s.querySelector('#trans-status');
const hint = s.querySelector('#trans-hint');
const runBtn = s.querySelector('#trans-run');
const drawer = s.querySelector('.drawer');
if (status) { status.style.display = 'block'; status.className = 'status ok'; status.textContent = content; }
if (hint) {
hint.style.display = 'block';hint.textContent = model
}
if (runBtn) runBtn.disabled = false;
if (drawer) drawer.classList.add('open');
}
function showTranslateError(msg) {
if (!sidebarHost) return;
const s = sidebarHost.shadowRoot;
const status = s.querySelector('#trans-status');
const runBtn = s.querySelector('#trans-run');
if (status) { status.style.display = 'block'; status.className = 'status err'; status.textContent = msg; }
if (runBtn) runBtn.disabled = false;
}
function removeSidebar() {
if (sidebarHost) { sidebarHost.remove(); sidebarHost = null; }
}
function escapeHtml(text) {
const d = document.createElement('div'); d.textContent = text; return d.innerHTML;
}
function flashBtn(btn, msg) {
const old = btn.textContent;
btn.textContent = msg;
setTimeout(() => btn.textContent = old, 1200);
}
})();
+4 -1
View File
@@ -5,6 +5,9 @@ export function rand(min, max) {
export function getTweetIdFromUrl(xUrl: string) {
xUrl = xUrl.replace('twitter.com', 'x.com').split('?')[0];
const match = xUrl.match(/status\/(\d+)/);
if (!match) throw new Error('URL X không hợp lệ');
if (!match) throw new Error('getTweetIdFromUrl: URL X không hợp lệ');
return match[1];
}
export const _toNumber = (value) => {
return 1 * value;
}
+16 -4
View File
@@ -2,7 +2,7 @@
import {Injectable, Logger} from "@nestjs/common";
import {SqsPostService} from "./sqs.post.service";
import {SUPPORT_SOCIAL_PROVIDERS, XPosterRouterService, XStrategy} from "../x-poster/x-poster.router.service";
import {rand} from "../helper";
import {getTweetIdFromUrl, rand} from "../helper";
import {FacebookApi} from "../x-poster/facebook.api";
import {NotifyService} from "../notify.service";
import {XCacheService} from "../x-cache/x-cache.service";
@@ -68,8 +68,8 @@ export class SqsPosterWorker {
private async process(data: any) {
this.logger.log('📩 Got job:', data);
const {type, content, xSubmitProvider, tweetUrl, publishTo, tweetId, telegramChatId} = data;
switch (type) {
const {type, job_type, content, xSubmitProvider, tweetUrl, publishTo, tweetId, telegramChatId} = data;
switch (type || job_type) {
case 'X_POSTER_TWEET': {
await this.doPostTweet(
content,
@@ -87,6 +87,15 @@ export class SqsPosterWorker {
);
break;
}
case 'X_POSTER_REPLY_VIA_AUTO': {
await this.doReplyTweet(
content,
tweetUrl,
tweetId,
xSubmitProvider
);
break;
}
case 'X_POSTER_QUOTE': {
await this.doQuoteTweet(
content,
@@ -159,11 +168,14 @@ export class SqsPosterWorker {
private async doReplyTweet(
text: string,
tweetUrl: string,
tweetId: string,
tweetId?: string,
strategy: string = XStrategy.BROWSER_COOKIE
) {
try {
this.logger.log('doReplyTweet');
if (!tweetId) {
tweetId = getTweetIdFromUrl(tweetUrl)
}
// @ts-ignore
const r = await this.xRouterService.postReply({text, tweetUrl, tweetId, strategy});
if (r.success) {
+16 -4
View File
@@ -1,5 +1,6 @@
import {Inject, Injectable} from "@nestjs/common";
import {Cache, CACHE_MANAGER} from "@nestjs/cache-manager";
import {_toNumber} from "../helper";
@Injectable()
export class XCacheService {
@@ -22,7 +23,7 @@ export class XCacheService {
}
async setCacheTwRefreshToken(refreshToken: string) {
await this.cacheManager.set('tw_app_refresh_token', refreshToken, 30 * 24 * 3600);
await this.setCachedKey('tw_app_refresh_token', refreshToken, 30 * 24 * 3600);
}
async getCacheTwRefreshToken() {
@@ -61,20 +62,31 @@ export class XCacheService {
async changeStateXCookiesIsAlive() {
const cacheKey = 'state_xcookie_status';
const currentState = await this.isXCookiesAlive();
return this.cacheManager.set(cacheKey, currentState ? 0 : 1, 365 * 24 * 3600);
return this.setCachedKey(cacheKey, currentState ? 0 : 1, 365 * 24 * 3600);
}
async setStateXCookiesIsDie() {
const cacheKey = 'state_xcookie_status';
return this.cacheManager.set(cacheKey, 0, 365 * 24 * 3600);
return this.setCachedKey(cacheKey, 0, 3 * 24 * 3600);
}
async setStateXCookiesIsSillALive() {
const cacheKey = 'state_xcookie_status';
return this.cacheManager.set(cacheKey, 1, 365 * 24 * 3600);
return this.setCachedKey(cacheKey, 1, 3 * 24 * 3600);
}
async isXCookiesAlive() {
const cacheKey = 'state_xcookie_status';
return 1 === Number(await this.cacheManager.get(cacheKey));
}
async setDoneTweetComment(tweetId) {
await this.setCachedKey(`cmt_tweetId:${tweetId}`, 1, 30 * 24 * 3600);
return {tweetId};
}
async isDoneTweetComment(tweetId) {
const v = await this.getCachedData(`cmt_tweetId:${tweetId}`);
return 1 === _toNumber(v);
}
}
+8
View File
@@ -1,6 +1,8 @@
// src/modules/social/facebook-api.service.ts
import {HttpException, HttpStatus, Injectable, Logger} from '@nestjs/common';
import axios from 'axios';
import * as Http from "node:http";
import {NotifyService} from "../notify.service";
@Injectable()
export class FacebookApi {
@@ -9,6 +11,11 @@ export class FacebookApi {
private readonly pageAccessToken = process.env.FB_PAGE_ACCESS_TOKEN;
private readonly pageId = process.env.FB_PAGE_ID;
constructor(private notifyService: NotifyService) {
}
async postToPage(content: string, imageUrl?: string, throwEx = true) {
// console.log('postToPage==>', content, imageUrl);
try {
@@ -47,6 +54,7 @@ export class FacebookApi {
fbErrormessage += '\n\n' + fbError.message;
this.logger.error('Subcode:', fbError.error_subcode);
this.logger.error('FB Trace ID:', fbError.fbtrace_id);
await this.notifyService.sendUrgentMessageToTele(fbErrormessage);
} else {
// Lỗi do mạng hoặc cấu hình Axios sai
this.logger.error('Lỗi hệ thống/mạng:', error.message);
+2 -17
View File
@@ -173,7 +173,7 @@ export class XBrowserService implements OnModuleInit, OnModuleDestroy {
this.logger.debug('isCookieLive?');
if (page.url().includes('/home')) {
this.logger.log('Cookies live');
// await this.xCacheService.setStateXCookiesIsSillALive();
await this.xCacheService.setStateXCookiesIsSillALive();
if (sendNotiWhenAlive) {
// await this.notifyService.sendMessageToTele('✅Verify cookie pass')
}
@@ -198,20 +198,6 @@ export class XBrowserService implements OnModuleInit, OnModuleDestroy {
return isLoggedIn;
}
// async actVerifyCookie(): Promise<any> {
// this.logger.debug('==> actVerifyCookie');
// // const isAlive = await this.cookieSvc.verifyCookie();
// const isAlive = await this.verifyCookie();
// if (!isAlive) {
// await this.xCacheService.setStateXCookiesIsDie();
// await this.notifyService.sendUrgentMessageToTele('❌Cookie đã hết hạn vui lòng cập nhập để sử dụng.')
// }
// await this.xCacheService.setStateXCookiesIsSillALive();
// await this.notifyService.sendMessageToTele('✅Verify cookie pass')
//
// return isAlive;
// }
async likeTweet(tweetUrl: string) {
let page: Page | null = null;
@@ -330,6 +316,7 @@ export class XBrowserService implements OnModuleInit, OnModuleDestroy {
// const composer = page.locator('a[href="/compose/post"]').first();
// await page.waitForTimeout(2000 + (Math.random()+Math.random()) * 3000);
// await composer.click();
this.logger.debug('Bắt đầu nhập tweet ...');
const textarea = page.locator('div[data-testid="tweetTextarea_0"]');
await page.waitForTimeout(2000 + (Math.random() + Math.random()) * 3000);
@@ -594,8 +581,6 @@ export class XBrowserService implements OnModuleInit, OnModuleDestroy {
await page?.close().catch(() => null);
}
}
private async cleanupStaleContexts() {
+17 -1
View File
@@ -6,6 +6,7 @@ import {XCookieService} from "./x-cookie.service";
import {XApiService} from "./x-api.service";
import {XCacheService} from "../x-cache/x-cache.service";
import {XBrowserService} from "./x-browser.service";
import {XPwService} from "./x.pw.service";
@Controller('')
export class XPosterController {
@@ -14,10 +15,25 @@ export class XPosterController {
private readonly xCookieService: XCookieService,
private readonly xBrowserService: XBrowserService,
private readonly xCacheService: XCacheService,
private readonly xApiService: XApiService
private readonly xApiService: XApiService,
private readonly xPwService: XPwService,
) {
}
@Get('x_view')
async twitterViewPage(@Query('url') url: string,) {
const targetUrl = url || 'https://x.com';
// Gọi dịch vụ chạy profile
const title = await this.xPwService.runWithProfile(targetUrl);
return {
success: true,
message: `Đã chạy xong kịch bản cho trang web`,
pageTitle: title,
};
}
@Get('tw_callback')
async twitterAuthCallback(
+2
View File
@@ -7,6 +7,7 @@ import {XPosterRouterService} from "./x-poster.router.service";
import {XCookieService} from "./x-cookie.service";
import {XCacheService} from "../x-cache/x-cache.service";
import {NotifyService} from "../notify.service";
import {XPwService} from "./x.pw.service";
@Global()
@Module({
@@ -18,6 +19,7 @@ import {NotifyService} from "../notify.service";
XCacheService,
XPosterRouterService,
NotifyService,
XPwService
],
controllers: [XPosterController],
exports: [XApiService, XBrowserService, XPosterRouterService],
+17 -4
View File
@@ -7,6 +7,7 @@ import {XCookieService} from "./x-cookie.service";
import {NotifyService} from "../notify.service";
import {getAccount} from "./utils/x-headers.util";
import {XCacheService} from "../x-cache/x-cache.service";
import {XPwService} from "./x.pw.service";
export enum SUPPORT_SOCIAL_PROVIDERS {
FB = 'fb',
@@ -51,6 +52,7 @@ export class XPosterRouterService {
private readonly apiSvc: XApiService,
private readonly cookieSvc: XCookieService,
private readonly browserSvc: XBrowserService,
private readonly browserProfileSvc: XPwService,
private readonly notifyService: NotifyService,
private readonly xCacheService: XCacheService,
) {
@@ -63,7 +65,7 @@ export class XPosterRouterService {
async verifyCookie(): Promise<any> {
this.logger.debug('==> Verify Cookie');
// const isAlive = await this.cookieSvc.verifyCookie();
const isAlive = await this.browserSvc.verifyCookie();
const isAlive = await this.browserProfileSvc.verifyCookie();
if (!isAlive) {
await this.xCacheService.setStateXCookiesIsDie();
await this.notifyService.sendUrgentMessageToTele('❌Cookie đã hết hạn vui lòng cập nhập để sử dụng.')
@@ -301,7 +303,8 @@ export class XPosterRouterService {
// return await this.cookieSvc.createTweet(account.cookie, text);
}
if (method === 'browser' && account.browser) {
return await this.browserSvc.postTweet(account.browser, text);
// return await this.browserSvc.postTweet(account.browser, text);
return await this.browserProfileSvc.postTweet(account.browser, text);
}
return {success: false, error: `Method ${method} not configured`};
} catch (e: any) {
@@ -345,11 +348,16 @@ export class XPosterRouterService {
}
}
if (method === 'browser' && account.browser) {
return await this.browserSvc.postReply(
return await this.browserProfileSvc.postReply(
account.browser,
params.tweetUrl,
params.text
);
// return await this.browserSvc.postReply(
// account.browser,
// params.tweetUrl,
// params.text
// );
}
return {success: false, error: `Method ${method} not configured`};
} catch (e: any) {
@@ -390,11 +398,16 @@ export class XPosterRouterService {
}
}
if (method === 'browser' && account.browser) {
return await this.browserSvc.postQuote(
return await this.browserProfileSvc.postQuote(
account.browser,
params.tweetUrl!,
params.text
);
// return await this.browserSvc.postQuote(
// account.browser,
// params.tweetUrl!,
// params.text
// );
}
return {success: false, error: `Method ${method} not configured`};
} catch (e: any) {
+522
View File
@@ -0,0 +1,522 @@
import {HttpException, Injectable, Logger, OnModuleDestroy} from "@nestjs/common";
import {BrowserContext, chromium, Page} from "playwright";
import * as path from 'path';
import {_toNumber, rand} from "../helper";
import {getAccount} from "./utils/x-headers.util";
import {BrowserAccount, BrowserTweetResult} from "./x-browser.service";
import {XCacheService} from "../x-cache/x-cache.service";
@Injectable()
export class XPwService implements OnModuleDestroy {
private context: BrowserContext | null = null;
private readonly logger = new Logger("XPwService");
constructor(
private readonly xCacheService: XCacheService,
) {
}
async runWithProfile(targetUrl?: string): Promise<Page> {
// 1. Định nghĩa đường dẫn lưu trữ Profile (nằm trong thư mục dự án)
const profilePath = path.resolve(__dirname, `../../x_profile_data/${process.env.X_USERNAME}`);
const width = _toNumber(process.env.BROWSER_WP_WIDTH || 1479);
const height = _toNumber(process.env.BROWSER_WP_HEIGHT || 795);
// 2. Cấu hình các tham số ẩn danh (Antidetect)
const antidetectArgs = [
'--disable-blink-features=AutomationControlled',
// '--no-sandbox',
'--disable-infobars',
'--start-maximized',
'--no-default-browser-check',
// '--disable-setuid-sandbox'
`--user-agent=${process.env.BROWSER_USER_AGENT}`,
`--window-size=${width},${height}`
];
// 3. Khởi chạy Persistent Context nếu chưa được khởi tạo
if (!this.context || this.context.isClosed()) {
this.context = await chromium.launchPersistentContext(profilePath, {
// channel: 'chrome', // Sử dụng Google Chrome thật
headless: false, // Để False để xem giao diện và đăng nhập lần đầu
args: antidetectArgs,
ignoreDefaultArgs: ['--enable-automation', '--disable-extensions'],
// ==========================================
// THÊM DÒNG NÀY ĐỂ ÉP CHROME BẬT LẠI SANDBOX
// ==========================================
chromiumSandbox: true,
viewport: {
width: width,
height: height-100,
}
});
}
// 4. Lấy ra Tab (Page) đầu tiên có sẵn
const pages = this.context.pages();
const page: Page = pages.length > 0 ? pages[0] : await this.context.newPage();
// 5. Giả lập User-Agent giống người dùng thật
await page.setExtraHTTPHeaders({
'User-Agent': `${process.env.BROWSER_USER_AGENT}`,
});
return page;
// // 6. Điều hướng tới trang web mục tiêu
// console.log(`Đang truy cập: ${targetUrl}`);
// await page.goto(targetUrl, {waitUntil: 'domcontentloaded'});
//
// // Lấy tiêu đề trang để kiểm tra xem đã chạy thành công chưa
// const pageTitle = await page.title();
//
// // Lưu ý: Không đóng context ở đây nếu bạn muốn giữ phiên chạy tiếp theo nhanh hơn.
// // Nếu muốn đóng ngay sau khi xong việc, dùng: await this.context.close(); this.context = null;
//
// return pageTitle;
}
async newPage(): Promise<Page> {
const account = getAccount();
return this.getPage(account.browser)
}
async getPage(account: BrowserAccount): Promise<Page> {
return this.runWithProfile()
}
async verifyCookie(sendNotiWhenAlive = false): Promise<boolean> {
const page = await this.newPage();
try {
await page.goto('https://x.com/', {
waitUntil: 'domcontentloaded',
timeout: 30_000,
});
await page.waitForTimeout(2000 + (Math.random() + Math.random()) * 3000);
await page.mouse.wheel(0, rand(300, 500));
return await this.isCookieLive(page, sendNotiWhenAlive);
} catch (er) {
this.logger.error(`Browser verify cookie fail: ${er.message}`);
return false;
} finally {
await page?.close().catch(() => null);
}
}
async isCookieLive(page: Page, sendNotiWhenAlive = false): Promise<boolean> {
this.logger.debug('isCookieLive?');
if (page.url().includes('/home')) {
this.logger.log('Cookies live');
await this.xCacheService.setStateXCookiesIsSillALive();
if (sendNotiWhenAlive) {
// await this.notifyService.sendMessageToTele('✅Verify cookie pass')
}
return true;
}
const isLoggedIn = await page
.locator('[data-testid="SideNav_AccountSwitcher_Button"], [data-testid="AppTabBar_Home_Link"]')
.first()
.isVisible()
.catch(() => false);
this.logger.log(`🔐 Session restore: ${isLoggedIn ? 'LOGGED IN' : 'GUEST (cookie có thể expired)'}`);
// if (isLoggedIn) {
// await this.xCacheService.setStateXCookiesIsSillALive();
// if (sendNotiWhenAlive) {
// await this.notifyService.sendMessageToTele('✅Verify cookie pass')
// }
// } else {
// await this.xCacheService.setStateXCookiesIsDie();
// await this.notifyService.sendUrgentMessageToTele('❌Cookie đã hết hạn vui lòng cập nhập để sử dụng.')
// }
return isLoggedIn;
}
async likeTweet(tweetUrl: string) {
let page: Page | null = null;
try {
page = await this.newPage();
await page.goto(tweetUrl, {
waitUntil: 'domcontentloaded',
timeout: 30_000,
});
await this.actLikeTweet(page);
} catch (e) {
}
}
async actLikeTweet(page: Page, isCloseAfterEnd = false) {
try {
this.logger.debug('actLikeTweet:');
await page.waitForTimeout(2000 + (Math.random() + Math.random()) * 3000);
// 1. Cuộn xuống 1000 pixel
await page.mouse.wheel(0, rand(300, 500));
await page.waitForTimeout(rand(2000, 4000));
await page.mouse.wheel(0, rand(300, 500));
this.logger.debug('actLikeTweet:Đã cuộn xuống');
// Nghỉ 2 giây để quan sát
await page.waitForTimeout(rand(2000, 4000));
// 2. Cuộn ngược lên lại 500 pixel
await page.mouse.wheel(0, -1 * 1000);
this.logger.debug('actLikeTweet:Đã cuộn lên');
await page.waitForTimeout(rand(500, 1500));
//like
this.logger.debug('actLikeTweet:Bắt đầu nhấn like');
// Sử dụng selector cụ thể cho bài viết chính (thường có vai trò là article)
const mainTweetLike = page
.locator('article[data-testid="tweet"]').first()
.locator('button[data-testid="like"]');
await mainTweetLike.click();
this.logger.debug('actLikeTweet:Đã like xong');
return true;
} catch (e) {
this.logger.debug(e);
this.logger.error('actLikeTweet: Error:' + e.message);
return false;
} finally {
if (isCloseAfterEnd) {
page.close().catch(() => null);
}
}
}
async postTweet(
account: BrowserAccount,
text: string,
): Promise<BrowserTweetResult> {
let page: Page | null = null;
try {
page = await this.newPage();
// Intercept để lấy tweet id từ response
let capturedTweetId: string | undefined;
// page.on('response', async (resp) => {
// if (resp.url().includes('/CreateTweet')) {
// try {
// const json = await resp.json();
// capturedTweetId =
// json?.data?.create_tweet?.tweet_results?.result?.rest_id;
// } catch {
// }
// }
// });
// await page.keyboard.press('Mở trang ...');
await page.goto('https://x.com/home', {
waitUntil: 'domcontentloaded',
timeout: 30_000,
});
await page.waitForTimeout(2000 + (Math.random() + Math.random()) * 3000);
await page.mouse.wheel(0, rand(300, 500));
await page.waitForTimeout(rand(1000, 4000));
// Detect login/challenge screen
if (page.url().includes('/login') || page.url().includes('/flow')) {
return {
success: false,
error: 'Redirected to login',
needsRelogin: true,
};
}
await this.isCookieLive(page, false);
await page.mouse.wheel(200, rand(300, 800));
await page.waitForTimeout(rand(2000, 5000));
await page.evaluate(() => window.scrollTo({top: 0, behavior: 'smooth'}));
await page.waitForTimeout(rand(1000, 2000));
// page.mouse.move()
// Mở composer
// const composer = page.locator('a[href="/compose/post"]').first();
// await page.waitForTimeout(2000 + (Math.random()+Math.random()) * 3000);
// await composer.click();
this.logger.debug('Bắt đầu nhập tweet ...');
const textarea = page.locator('div[data-testid="tweetTextarea_0"]');
await page.waitForTimeout(2000 + (Math.random() + Math.random()) * 3000);
// nhập content (fallback nếu type fail)
try {
await textarea.fill(''); // clear
await textarea.type(text, {delay: 50 + Math.random() * 200});
} catch {
await textarea.fill(text);
}
this.logger.debug(' Nhập tweet xong ...');
await page.waitForTimeout(2000 + (Math.random() + Math.random()) * 3000);
await page.waitForTimeout(5000);
// Chờ nút enable
// const postBtn = page.locator('button[data-testid="tweetButtonInline"]');
// await postBtn.waitFor({state: 'visible', timeout: 5_000});
// await postBtn.click();
// await page.locator('button[data-testid="tweetButtonInline"]').click({ force: true });
const btn = page.locator('button[data-testid="tweetButtonInline"]');
const btnBox = await btn.boundingBox();
this.logger.debug(btnBox);
this.logger.debug('Nhấn Control+Enter ...');
// @ts-ignore
// await page.mouse.click(btnBox?.x + btnBox.width / 2, btnBox.y + btnBox.height / 2);
await page.keyboard.press('Control+Enter');
this.logger.debug('Nhấn Control+Enter done ...');
await page.waitForTimeout(10000);
// Chờ request CreateTweet hoàn tất
// await page.waitForResponse(
// (r) => r.url().includes('/CreateTweet') && r.status() === 200,
// {timeout: 15_000},
// );
return {success: true, tweetId: capturedTweetId};
} catch (err: any) {
this.logger.error(`Browser post failed: ${err.message}`);
// console.error(err);
return {success: false, error: err.message};
} finally {
await page?.close().catch(() => null);
}
}
async postQuote(
account: BrowserAccount,
tweetUrl: string,
quoteText: string,
) {
const page = await this.getPage(account);
try {
// ===== SAFE GOTO =====
try {
await page.goto(tweetUrl, {waitUntil: 'domcontentloaded', timeout: 30000});
} catch (e) {
this.logger.debug('❌ Load fail');
throw e;
}
await page.waitForTimeout(rand(2000, 4000));
await this.isCookieLive(page, false);
// ===== CHECK LOGIN =====
if (await page.locator('input[name="text"]').count()) {
this.logger.error('❌ Cookie die → bị redirect login');
throw new HttpException('❌ Không thấy nút retweet (tweet private?)', 500);
}
// ===== SCROLL (giống người thật) =====
await page.mouse.wheel(0, rand(300, 800));
await page.waitForTimeout(rand(1000, 5000));
await page.mouse.wheel(0, rand(300, 800));
await page.waitForTimeout(rand(4000, 8000));
await page.mouse.wheel(0, -2000);
await page.waitForTimeout(rand(1000, 2000));
await this.actLikeTweet(page);
// ===== CLICK RETWEET =====
let retweetBtn = page.locator('[data-testid="retweet"]');
if (!(await retweetBtn.count())) {
this.logger.error('❌ Không thấy nút retweet (tweet private?)');
throw new HttpException('❌ Không thấy nút retweet (tweet private?)', 500);
}
await retweetBtn.first().click();
await page.waitForTimeout(rand(1000, 2000));
try {
await page.locator('a[href="/compose/post"]').click({timeout: 2000});
} catch {
this.logger.debug('fallback → click by text');
await page.locator('a[role="menuitem"]')
.filter({hasText: /Quote|Trích dẫn/i})
.click();
}
// // ===== CLICK QUOTE =====
// let quoteBtn = page.locator('[data-testid="retweetWithComment"]');
//
// if (!(await quoteBtn.count())) {
// this.logger.debug('❌ Không thấy nút quote');
// return;
// }
//
// await quoteBtn.first().click();
await page.waitForTimeout(rand(2000, 3000));
// ===== TYPE LIKE HUMAN =====
// const content = pick(quoteText);
const content = quoteText;
const box = page.locator('div[role="textbox"]').first();
// chọn đúng textbox đang visible
// const box = page.locator('div[role="textbox"]:visible').first();
if (!(await box.count())) {
this.logger.error('❌ Không thấy textbox');
throw new HttpException('❌ Không thấy textbox', 500);
}
// đợi nó xuất hiện thật sự
await box.waitFor({state: 'visible', timeout: 7000});
// scroll nhẹ vào view (tránh bị offscreen)
// await box.scrollIntoViewIfNeeded();
// focus trước khi gõ
this.logger.debug('focus trước khi gõ')
await box.click({delay: rand(50, 150)});
for (let char of content) {
await box.type(char, {delay: rand(50, 120)});
}
this.logger.debug('gõ quote xong ...')
await page.waitForTimeout(rand(1000, 2000));
// ===== POST =====
let postBtn = page.locator('[data-testid="tweetButton"]');
this.logger.debug('count ...')
if ((await postBtn.count())) {
this.logger.debug('click nút quote ...')
await postBtn.click({timeout: 7000}).catch(async (e) => {
this.logger.debug('❌ Nut click khong duoc, thử dùng bàn phím Control+Enter');
await page.keyboard.press('Control+Enter');
});
await page.waitForTimeout(rand(6000, 10000));
this.logger.debug('✅ Quoted thành công');
} else {
this.logger.debug('❌ Không thấy nút post, gọi Ctr + Enter');
await page.keyboard.press('Control+Enter');
await page.waitForTimeout(rand(4000, 6000));
this.logger.debug('✅ Quoted thành công');
}
return {success: true, error: ''};
} catch (err: any) {
this.logger.error(`Browser post quote failed: ${err.message}`);
// console.error(err);
return {success: false, error: `Browser post quote failed: ${err.message}`};
} finally {
await page?.close().catch(() => null);
}
}
async postReply(account: BrowserAccount, tweetUrl, content) {
if (!content) {
this.logger.debug(`Nội dung trả lời không có`);
throw new Error('Nội dung trả lời không có');
}
const page = await this.getPage(account);
try {
// limit X
// content = content.slice(0, 280);
// vào tweet
// ===== SAFE GOTO =====
try {
this.logger.debug(`Mo trang web tweetUrl`);
await page.goto(tweetUrl, {waitUntil: 'domcontentloaded', timeout: 30000});
} catch (e) {
this.logger.debug('❌ Load fail');
throw e;
}
// đợi UI ổn
this.logger.debug(`đợi UI ổn...`)
await page.waitForSelector('article', {timeout: 7000});
await this.isCookieLive(page, false);
// scroll nhẹ
this.logger.debug(`scroll nhẹ ...`)
await page.mouse.wheel(0, 300);
await page.mouse.wheel(300, 900);
await page.waitForTimeout(rand(2000, 8000));
await page.mouse.wheel(0, -2000);
await this.actLikeTweet(page);
// lấy textbox visible
const box = page.locator('div[role="textbox"]:visible').first();
await box.waitFor({state: 'visible', timeout: 7000});
// focus
this.logger.debug(`box focus ...`)
await box.click();
// nhập content (fallback nếu type fail)
try {
await box.fill(''); // clear
await box.type(content, {delay: 30 + Math.random() * 150});
} catch {
await box.fill(content);
}
this.logger.debug(`nhập nội dung xong ...`)
await page.waitForTimeout(800 + Math.random() * 1200);
// nút reply
const btn = page.locator('[data-testid="tweetButtonInline"]:visible');
if (!(await btn.count())) {
this.logger.debug('❌ Không thấy nút reply');
throw new Error('Không thấy nút reply');
// return false;
}
await btn.click();
this.logger.debug(`Đã nhấn nút gửi ...`)
await page.waitForTimeout(10000);
this.logger.debug('✅ Reply OK');
// scroll nhẹ
this.logger.debug(`scroll nhẹ ...`)
await page.mouse.wheel(0, rand(300, 500));
await page.waitForTimeout(rand(2000, 7000));
await page.mouse.wheel(0, -200);
await page.goBack({waitUntil: 'domcontentloaded', timeout: 10000})
return {success: true, error: ''};
} catch (err) {
this.logger.error(`Browser reply failed: ${err.message}`);
// console.error(err);
return {success: false, error: `Browser reply failed: ${err.message}`};
} finally {
//await page?.close().catch(() => null);
}
}
// Tự động đóng trình duyệt giải phóng RAM khi NestJS tắt ứng dụng
async onModuleDestroy() {
if (this.context) {
await this.context.close();
this.context = null;
console.log('Playwright Browser Context đã đóng an toàn.');
}
}
}