WeRead Challenge Daily Report
${reportDate}
Version ${versionText}
Dear User,
${safeText}
Here are your reading statistics and achievements for today.
${extraHtml}
${imageGallery}
Best regards,
WeRead Challenge Team
This is an automated message, please do not reply.
Version ${versionText}
`;
}
// Utility function to redirect logging
function redirectConsole(method) {
const originalMethod = console[method];
console[method] = function (...args) {
let logstr = `[${method.toUpperCase()}][${formatLocalTimestamp()}]: ` + args.join(" ");
// Write to the log file
if (logStream) {
logStream.write(logstr + "\r\n");
}
// Also log to the console
console.log(logstr);
};
}
// --- 诊断与健康检查工具函数 ---
function isHttpUrl(str) {
try {
const u = new URL(str);
return u.protocol === "http:" || u.protocol === "https:";
} catch (_) {
return false;
}
}
async function fetchJson(url, timeoutMs = 3000) {
return await new Promise((resolve, reject) => {
const client = url.startsWith("https:") ? https : http;
const req = client.get(url, { timeout: timeoutMs }, (res) => {
let data = "";
res.on("data", (chunk) => (data += chunk));
res.on("end", () => {
try {
resolve({ statusCode: res.statusCode, body: JSON.parse(data || "{}") });
} catch (e) {
resolve({ statusCode: res.statusCode, body: data });
}
});
});
req.on("timeout", () => {
req.destroy(new Error("request timeout"));
});
req.on("error", reject);
});
}
async function checkSeleniumHealth(remoteUrl) {
try {
if (!remoteUrl || !isHttpUrl(remoteUrl)) {
console.warn("跳过健康检查：WEREAD_REMOTE_BROWSER 未设置或非法。");
return null;
}
// 优先 /status，兼容 /wd/hub/status
const base = remoteUrl.endsWith("/") ? remoteUrl.slice(0, -1) : remoteUrl;
const endpoints = ["/status", "/wd/hub/status"];
for (const ep of endpoints) {
try {
const { statusCode, body } = await fetchJson(`${base}${ep}`, 3000);
if (statusCode >= 200 && statusCode < 300) {
const ready = body?.ready ?? body?.value?.ready;
console.info(`Selenium 健康检查 ${ep} 响应: ready=${ready}`);
return { endpoint: ep, ready, raw: body };
}
} catch (_) {
// 继续尝试下一个端点
}
}
console.warn("Selenium 健康检查失败：所有端点无有效响应。");
return null;
} catch (e) {
console.warn("Selenium 健康检查异常：", e.message || e);
return null;
}
}
function dockerAvailable() {
try {
const out = spawnSync("docker", ["version"], { encoding: "utf8" });
return out.status === 0;
} catch (_) {
return false;
}
}
function findSeleniumContainers() {
try {
const out = execSync(
'docker ps --format "{{.ID}}\t{{.Image}}\t{{.Names}}"',
{ encoding: "utf8" }
);
const lines = out.split(/\r?\n/).filter(Boolean);
const hits = lines
.map((l) => {
const [id, image, name] = l.split(/\t/);
return { id, image, name };
})
.filter((x) =>
/selenium\/(standalone-|node-).*chrome/i.test(x.image || "") ||
/selenium/i.test(x.name || "")
);
return hits;
} catch (e) {
console.warn("查找 Selenium 容器失败：", e.message || e);
return [];
}
}
function collectSeleniumLogs(tail = 300) {
try {
if (!dockerAvailable()) {
console.warn("Docker 不可用，跳过 selenium 日志抓取。");
return null;
}
const containers = findSeleniumContainers();
if (!containers.length) {
console.warn("未发现运行中的 selenium 容器，跳过日志抓取。");
return null;
}
const ts = new Date()
.toISOString()
.replace(/[:.]/g, "-")
.replace("T", "_")
.replace("Z", "");
const outFile = path.join(getDataDirPath(), `selenium-logs-${ts}.log`);
let combined = "";
for (const c of containers) {
try {
const logs = execSync(`docker logs --tail=${tail} ${c.id} 2>&1`, {
encoding: "utf8",
stdio: ["ignore", "pipe", "pipe"],
});
combined += `\n===== CONTAINER ${c.name} (${c.image}) =====\n` + logs;
} catch (e) {
combined += `\n===== CONTAINER ${c.name} (${c.image}) 日志获取失败: ${e.message} =====\n`;
}
}
fs.writeFileSync(outFile, combined, "utf8");
console.info("已抓取 selenium 容器日志:", outFile);
return outFile;
} catch (e) {
console.warn("保存 selenium 日志失败：", e.message || e);
return null;
}
}
async function collectDiagnostics(reason) {
try {
console.warn("开始收集诊断信息，原因：", reason?.toString()?.slice(0, 180) || "未知");
await checkSeleniumHealth(WEREAD_REMOTE_BROWSER);
collectSeleniumLogs(400);
} catch (_) {
// 忽略诊断过程错误
}
}
function getOSInfo() {
const platform = os.platform();
const release = os.release();
switch (platform) {
case "win32":
return `Windows ${release}`;
case "darwin":
return `MacOS ${release}`;
case "linux":
return `Linux ${release}`;
default:
return `${platform} ${release}`;
}
}
// post data to weread log
function logEventToWereadLog(err) {
const url = DEBUG
? "http://127.0.0.1:8787/logs"
: "https://weread-challenge.techfetch.dev/logs";
const httpModule = DEBUG ? http : https;
let userInfo = getUserInfo();
let params = {
os: getOSInfo(),
browser: WEREAD_BROWSER,
duration: parseInt(WEREAD_DURATION) || 0,
enable_email: ENABLE_EMAIL,
error: err,
version: WEREAD_VERSION,
};
let data = { ...params, ...userInfo };
const options = {
method: "POST",
headers: {
"Content-Type": "application/json",
"User-Agent": "WeRead-Tracker/1.0",
},
};
// log stringified data
console.info("Logging to WeRead server:", JSON.stringify(data));
const req = httpModule.request(url, options, (res) => {
let responseData = "";
res.on("data", (chunk) => {
responseData += chunk;
});
res.on("end", () => {
if (res.statusCode >= 200 && res.statusCode < 300) {
console.info("Successfully logged to WeRead server");
} else {
console.error(
`Failed to log to WeRead server: ${res.statusCode} - ${responseData}`
);
}
});
});
req.on("error", (error) => {
console.error("Error logging to WeRead server:", error.message);
});
req.write(JSON.stringify(data));
req.end();
}
function getUserInfo() {
// return empty object if cookies file not found
if (!fs.existsSync(getCookieFilePath())) {
return {};
}
// read from cookies
let cookiesFile = fs.readFileSync(getCookieFilePath(), "utf8");
let cookies = JSON.parse(cookiesFile);
let userInfo = {};
for (const cookie of cookies) {
if (cookie.secure == undefined) {
continue;
}
switch (cookie.name) {
case "wr_gid":
if (cookie.secure == true) {
userInfo.wr_gid_s = parseInt(cookie.value) || 0;
} else {
userInfo.wr_gid = parseInt(cookie.value) || 0;
}
break;
case "wr_name":
userInfo.wr_name = decodeURIComponent(cookie.value);
break;
case "wr_localvid":
userInfo.wr_localvid = cookie.value;
break;
case "wr_gender":
userInfo.wr_gender = parseInt(cookie.value) || 0;
break;
case "wr_avatar":
userInfo.wr_avatar = decodeURIComponent(cookie.value);
break;
case "wr_rt":
userInfo.wr_rt = cookie.value;
break;
case "wr_vid":
userInfo.wr_vid = parseInt(cookie.value) || 0;
break;
}
}
return userInfo;
}
async function saveCookies(driver, filePath) {
let cookies = await driver.manage().getCookies();
// If using Safari, set secure to true for all cookies
if (WEREAD_BROWSER === Browser.SAFARI) {
cookies = cookies.map(cookie => ({ ...cookie, secure: true }));
}
fs.writeFileSync(filePath, JSON.stringify(cookies, null, 2));
console.info("Cookies saved successfully.");
}
async function loadCookies(driver, filePath) {
if (!fs.existsSync(filePath)) {
console.warn("No cookies file found.");
return;
}
const cookies = JSON.parse(fs.readFileSync(filePath, "utf8"));
for (const cookie of cookies) {
await driver.manage().addCookie(cookie);
}
console.info("Cookies loaded successfully.");
}
async function pressDownArrow(driver) {
await driver.actions().sendKeys(Key.ARROW_DOWN).perform();
// keep the key pressed for random time between 50ms to 500ms
let randomTime = Math.floor(Math.random() * 450) + 50;
await new Promise((resolve) => setTimeout(resolve, randomTime));
// release the down arrow key
await driver.actions().sendKeys(Key.NULL).perform();
}
// Function to check if element is in viewport
async function isElementInViewport(driver, element) {
// Get viewport dimensions using JavaScript
const viewport = await driver.executeScript(`
return {
height: window.innerHeight,
width: window.innerWidth
};
`);
// Get element position and size
const rect = await driver.executeScript(
`
const rect = arguments[0].getBoundingClientRect();
return {
top: rect.top,
left: rect.left,
bottom: rect.bottom,
right: rect.right
};
`,
element
);
// Check if element is within viewport
return (
rect.top >= 0 &&
rect.left >= 0 &&
rect.bottom <= viewport.height &&
rect.right <= viewport.width &&
(await element.isDisplayed())
);
}
// 简化的二维码定位函数
async function findQRCodeElement(driver) {
try {
console.info("正在查找二维码登录元素...");
// 使用更精确的定位策略，优先查找二维码图片
const qrCodeImg = await driver.wait(
until.elementLocated(
By.xpath("//img[contains(@class, 'qr') or contains(@src, 'qr') or contains(@alt, '二维码')]")
),
3000
);
console.info("找到二维码图片元素");
return true;
} catch (e) {
try {
// 备选方案：查找包含"扫码"或"二维码"文本的元素
await driver.wait(
until.elementLocated(
By.xpath("//*[contains(text(), '扫码') or contains(text(), '二维码')]")
),
3000
);
console.info("找到包含'扫码'或'二维码'文本的元素");
return true;
} catch (e) {
console.info("未找到二维码相关元素，可能已经登录");
return false;
}
}
}
// 从页面二维码图片中解码登录链接并在终端显示为二维码
async function extractAndDisplayQRCode(driver) {
try {
const qrImg = await driver.findElement(
By.xpath("//img[contains(@class, 'qr') or contains(@src, 'qr') or contains(@alt, '二维码')]")
);
const base64Png = await qrImg.takeScreenshot();
const { PNG } = require('pngjs');
const png = PNG.sync.read(Buffer.from(base64Png, 'base64'));
const jsQR = require('jsqr');
const code = jsQR(new Uint8ClampedArray(png.data), png.width, png.height);
if (code && code.data) {
console.info("登录链接:", code.data);
const qrcode = require('qrcode-terminal');
qrcode.generate(code.data, { small: true });
await notifyLoginLink(code.data);
return code.data;
}
console.warn("无法从二维码图片中解析登录链接");
return null;
} catch (e) {
console.warn("提取二维码登录链接失败:", e.message);
return null;
}
}
function canSendLoginLinkEmail() {
if (!ENABLE_EMAIL) {
return false;
}
const required = ["EMAIL_SMTP", "EMAIL_USER", "EMAIL_PASS", "EMAIL_TO"];
const missed = required.filter((key) => !process.env[key]);
if (missed.length) {
console.warn("邮件推送登录链接失败：缺少配置", missed.join(", "));
return false;
}
return true;
}
function buildLoginLinkEmailHtml(loginUrl) {
const safeUrl = escapeHtml(loginUrl);
const qrImageUrl = `https://api.qrserver.com/v1/create-qr-code/?size=360x360&data=${encodeURIComponent(loginUrl)}`;
const safeQrImageUrl = escapeHtml(qrImageUrl);
const versionText = escapeHtml(WEREAD_VERSION);
return `