feat(v2ex): add daily, me, and notifications session adapters
This commit is contained in:
jackwener committed
1 parent
53cd006a23
commit
eb9050fadd
3 files changed
+285
No files matched your search
@@ -0,0 +1,105 @@
|
||||
/**
|
||||
* V2EX Daily Check-in adapter.
|
||||
*/
|
||||
import { cli, Strategy } from '../../registry.js';
|
||||
import type { IPage } from '../../types.js';
|
||||
|
||||
cli({
|
||||
site: 'v2ex',
|
||||
name: 'daily',
|
||||
description: 'V2EX 每日签到并领取铜币',
|
||||
domain: 'www.v2ex.com',
|
||||
strategy: Strategy.COOKIE,
|
||||
browser: true,
|
||||
forceExtension: true,
|
||||
args: [],
|
||||
columns: ['status', 'message'],
|
||||
func: async (page: IPage | null) => {
|
||||
if (!page) throw new Error('Browser page required');
|
||||
|
||||
if (process.env.OPENCLI_VERBOSE) {
|
||||
console.error('[opencli:v2ex] Navigating to /mission/daily');
|
||||
}
|
||||
await page.goto('https://www.v2ex.com/mission/daily');
|
||||
|
||||
// Cloudflare challenge bypass wait
|
||||
for (let i = 0; i < 5; i++) {
|
||||
await new Promise(r => setTimeout(r, 1500));
|
||||
const title = await page.evaluate(`() => document.title`);
|
||||
if (!title?.includes('Just a moment')) break;
|
||||
if (process.env.OPENCLI_VERBOSE) console.error('[opencli:v2ex] Waiting for Cloudflare...');
|
||||
}
|
||||
|
||||
// Evaluate DOM to find if we need to check in
|
||||
const checkResult = await page.evaluate(`
|
||||
async () => {
|
||||
const btn = document.querySelector('input.super.normal.button');
|
||||
if (!btn || !btn.value.includes('领取')) {
|
||||
return { claimed: true, message: '今日奖励已发/无需领取' };
|
||||
}
|
||||
|
||||
const onclick = btn.getAttribute('onclick');
|
||||
if (onclick) {
|
||||
const match = onclick.match(/once=(\\d+)/);
|
||||
if (match) {
|
||||
return { claimed: false, once: match[1], message: btn.value };
|
||||
}
|
||||
}
|
||||
|
||||
return {
|
||||
claimed: false,
|
||||
error: '找到了按钮，但未能提取 once token',
|
||||
debug_title: document.title,
|
||||
debug_body: document.body.innerText.substring(0, 200).replace(/\\n/g, ' ')
|
||||
};
|
||||
}
|
||||
`);
|
||||
|
||||
if (checkResult.error) {
|
||||
if (process.env.OPENCLI_VERBOSE) {
|
||||
console.error(`[opencli:v2ex:debug] Page Title: ${checkResult.debug_title}`);
|
||||
console.error(`[opencli:v2ex:debug] Page Body: ${checkResult.debug_body}`);
|
||||
}
|
||||
throw new Error(checkResult.error);
|
||||
}
|
||||
|
||||
if (checkResult.claimed) {
|
||||
return [{ status: '✅ 已签到', message: checkResult.message }];
|
||||
}
|
||||
|
||||
// Perform check in
|
||||
if (process.env.OPENCLI_VERBOSE) {
|
||||
console.error(`[opencli:v2ex] Found check-in token: once=${checkResult.once}. Checking in...`);
|
||||
}
|
||||
|
||||
await page.goto(`https://www.v2ex.com/mission/daily/redeem?once=${checkResult.once}`);
|
||||
await new Promise(resolve => setTimeout(resolve, 3000)); // wait longer for redirect
|
||||
|
||||
// Verify result
|
||||
const verifyResult = await page.evaluate(`
|
||||
async () => {
|
||||
const btn = document.querySelector('input.super.normal.button');
|
||||
if (!btn || !btn.value.includes('领取')) {
|
||||
// fetch balance to show user
|
||||
let balance = '';
|
||||
const balanceLink = document.querySelector('a.balance_area');
|
||||
if (balanceLink) {
|
||||
balance = Array.from(balanceLink.childNodes)
|
||||
.filter(n => n.nodeType === 3)
|
||||
.map(n => n.textContent?.trim())
|
||||
.join(' ')
|
||||
.trim();
|
||||
}
|
||||
return { success: true, balance };
|
||||
}
|
||||
return { success: false };
|
||||
}
|
||||
`);
|
||||
|
||||
if (verifyResult.success) {
|
||||
return [{ status: '🎉 签到成功', message: `当前余额: ${verifyResult.balance || '未知'}` }];
|
||||
} else {
|
||||
return [{ status: '❌ 签到失败', message: '未能确认签到结果，请手动检查' }];
|
||||
}
|
||||
},
|
||||
});
|
||||
@@ -0,0 +1,103 @@
|
||||
/**
|
||||
* V2EX Me (Profile/Balance) adapter.
|
||||
*/
|
||||
import { cli, Strategy } from '../../registry.js';
|
||||
import type { IPage } from '../../types.js';
|
||||
|
||||
cli({
|
||||
site: 'v2ex',
|
||||
name: 'me',
|
||||
description: 'V2EX 获取个人资料 (余额/未读提醒)',
|
||||
domain: 'www.v2ex.com',
|
||||
strategy: Strategy.COOKIE,
|
||||
browser: true,
|
||||
forceExtension: true,
|
||||
args: [],
|
||||
columns: ['username', 'balance', 'unread_notifications', 'daily_reward_ready'],
|
||||
func: async (page: IPage | null) => {
|
||||
if (!page) throw new Error('Browser page required');
|
||||
|
||||
if (process.env.OPENCLI_VERBOSE) {
|
||||
console.error('[opencli:v2ex] Navigating to /');
|
||||
}
|
||||
await page.goto('https://www.v2ex.com/');
|
||||
|
||||
// Cloudflare challenge bypass wait
|
||||
for (let i = 0; i < 5; i++) {
|
||||
await new Promise(r => setTimeout(r, 1500));
|
||||
const title = await page.evaluate(`() => document.title`);
|
||||
if (!title?.includes('Just a moment')) break;
|
||||
if (process.env.OPENCLI_VERBOSE) console.error('[opencli:v2ex] Waiting for Cloudflare...');
|
||||
}
|
||||
|
||||
// Evaluate DOM to extract user profile
|
||||
const data = await page.evaluate(`
|
||||
async () => {
|
||||
let username = 'Unknown';
|
||||
const navLinks = Array.from(document.querySelectorAll('a.top')).map(a => a.textContent?.trim());
|
||||
if (navLinks.length > 1 && navLinks[0] === '首页') {
|
||||
username = navLinks[1] || 'Unknown';
|
||||
}
|
||||
|
||||
if (username === 'Unknown') {
|
||||
// Fallback check just in case
|
||||
const profileEl = document.querySelector('a[href^="/member/"]');
|
||||
if (profileEl && profileEl.textContent && profileEl.textContent.trim().length > 0) {
|
||||
username = profileEl.textContent.trim();
|
||||
}
|
||||
}
|
||||
|
||||
let balance = '0';
|
||||
const balanceLink = document.querySelector('a.balance_area');
|
||||
if (balanceLink) {
|
||||
balance = Array.from(balanceLink.childNodes)
|
||||
.filter(n => n.nodeType === 3)
|
||||
.map(n => n.textContent?.trim())
|
||||
.join(' ')
|
||||
.trim();
|
||||
}
|
||||
|
||||
let unread_notifications = '0';
|
||||
const notesEl = document.querySelector('a[href="/notifications"]');
|
||||
if (notesEl) {
|
||||
const text = notesEl.textContent?.trim() || '';
|
||||
const match = text.match(/(\\d+)\\s*未读提醒/);
|
||||
if (match) {
|
||||
unread_notifications = match[1];
|
||||
}
|
||||
}
|
||||
|
||||
let daily_reward_ready = false;
|
||||
const dailyEl = document.querySelector('a[href^="/mission/daily"]');
|
||||
if (dailyEl && dailyEl.textContent?.includes('领取今日的登录奖励')) {
|
||||
daily_reward_ready = true;
|
||||
}
|
||||
|
||||
if (username === 'Unknown') {
|
||||
return {
|
||||
error: '请先登录 V2EX（可能是 Cookie 未配置或已失效）',
|
||||
debug_title: document.title,
|
||||
debug_body: document.body.innerText.substring(0, 200).replace(/\\n/g, ' ')
|
||||
};
|
||||
}
|
||||
|
||||
return {
|
||||
username,
|
||||
balance,
|
||||
unread_notifications,
|
||||
daily_reward_ready: daily_reward_ready ? '是' : '否'
|
||||
};
|
||||
}
|
||||
`);
|
||||
|
||||
if (data.error) {
|
||||
if (process.env.OPENCLI_VERBOSE) {
|
||||
console.error(`[opencli:v2ex:debug] Page Title: ${data.debug_title}`);
|
||||
console.error(`[opencli:v2ex:debug] Page Body: ${data.debug_body}`);
|
||||
}
|
||||
throw new Error(data.error);
|
||||
}
|
||||
|
||||
return [data];
|
||||
},
|
||||
});
|
||||
@@ -0,0 +1,77 @@
|
||||
/**
|
||||
* V2EX Notifications adapter.
|
||||
*/
|
||||
import { cli, Strategy } from '../../registry.js';
|
||||
import type { IPage } from '../../types.js';
|
||||
|
||||
cli({
|
||||
site: 'v2ex',
|
||||
name: 'notifications',
|
||||
description: 'V2EX 获取提醒 (回复/由于)',
|
||||
domain: 'www.v2ex.com',
|
||||
strategy: Strategy.COOKIE,
|
||||
browser: true,
|
||||
forceExtension: true,
|
||||
args: [
|
||||
{ name: 'limit', type: 'int', default: 20, help: 'Number of notifications' }
|
||||
],
|
||||
columns: ['type', 'content', 'time'],
|
||||
func: async (page: IPage | null, kwargs) => {
|
||||
if (!page) throw new Error('Browser page required');
|
||||
|
||||
if (process.env.OPENCLI_VERBOSE) {
|
||||
console.error('[opencli:v2ex] Navigating to /notifications');
|
||||
}
|
||||
await page.goto('https://www.v2ex.com/notifications');
|
||||
await new Promise(r => setTimeout(r, 1500)); // waitForLoadState doesn't always work robustly
|
||||
|
||||
// Evaluate DOM to extract notifications
|
||||
const data = await page.evaluate(`
|
||||
async () => {
|
||||
const items = Array.from(document.querySelectorAll('#Main .box .cell[id^="n_"]'));
|
||||
return items.map(item => {
|
||||
let type = '通知';
|
||||
let time = '';
|
||||
|
||||
// determine type based on text content
|
||||
const text = item.textContent || '';
|
||||
if (text.includes('回复了你')) type = '回复';
|
||||
else if (text.includes('感谢了你')) type = '感谢';
|
||||
else if (text.includes('收藏了你')) type = '收藏';
|
||||
else if (text.includes('提及你')) type = '提及';
|
||||
|
||||
const timeEl = item.querySelector('.snow');
|
||||
if (timeEl) {
|
||||
time = timeEl.textContent?.trim() || '';
|
||||
}
|
||||
|
||||
// payload contains the actual reply text if any
|
||||
let payload = '';
|
||||
const payloadEl = item.querySelector('.payload');
|
||||
if (payloadEl) {
|
||||
payload = payloadEl.textContent?.trim() || '';
|
||||
}
|
||||
|
||||
// fallback to full text cleaning if no payload (e.g. for favorites/thanks)
|
||||
let content = payload;
|
||||
if (!content) {
|
||||
content = text.replace(/\\s+/g, ' ').trim();
|
||||
// strip out time from content if present
|
||||
if (time && content.includes(time)) {
|
||||
content = content.replace(time, '').trim();
|
||||
}
|
||||
}
|
||||
|
||||
return { type, content, time };
|
||||
});
|
||||
}
|
||||
`);
|
||||
|
||||
if (!Array.isArray(data)) {
|
||||
throw new Error('Failed to parse notifications data');
|
||||
}
|
||||
|
||||
const limit = kwargs.limit || 20;
|
||||
return data.slice(0, limit);
|
||||
},
|
||||
});
|
||||
Reference in new issue
Block a user