-
服务器 / 爬虫文件日志
+
爬虫日志（数据库）
diff --git a/pages/api/admin/crawler-status.js b/pages/api/admin/crawler-status.js
index ba4c40a..87f0e62 100644
--- a/pages/api/admin/crawler-status.js
+++ b/pages/api/admin/crawler-status.js
@@ -1,12 +1,10 @@
import prisma from '../../../lib/prisma';
import { withAdmin } from '../../../utils/withAdmin';
-import { loadSiteConfig } from '../../../utils/siteConfig';
+import { loadEffectiveConfig } from '../../../utils/siteConfig';
/**
* 爬虫状态 API
* GET /api/admin/crawler-status
- * 返回：爬虫持久化的结构化状态（crawler:status），
- * 并与当前配置中的站点列表合并，保证新增/删除站点后状态表始终完整。
*/
async function handler(req, res) {
if (req.method !== 'GET') return res.status(405).json({ error: 'Method not allowed' });
@@ -20,7 +18,7 @@ async function handler(req, res) {
let configuredSites = [];
try {
- configuredSites = (loadSiteConfig().SUPPORT_WIKI) || [];
+ configuredSites = ((await loadEffectiveConfig()).SUPPORT_WIKI) || [];
} catch (e) {
configuredSites = [];
}
@@ -46,7 +44,6 @@ async function handler(req, res) {
};
});
- // 用合并后的站点列表修正总进度统计，保证新增站点也能反映到进度里
if (status && typeof status === 'object' && !status.running) {
status = {
...status,
diff --git a/pages/api/admin/file-logs.js b/pages/api/admin/file-logs.js
index 997c80f..dfe7c9c 100644
--- a/pages/api/admin/file-logs.js
+++ b/pages/api/admin/file-logs.js
@@ -1,47 +1,68 @@
import fs from 'fs';
import path from 'path';
import { withAdmin } from '../../../utils/withAdmin';
+import { readJobLogs } from '../../../utils/jobLog';
/**
- * 服务器 / 爬虫文件日志查看 API
- * GET /api/admin/file-logs?file=crawler|server|serverErr&lines=500
- * 返回指定日志文件末尾若干行。
+ * 日志查看。
+ * 爬虫日志在无服务器部署里来自数据库（logs:crawler）。
+ * server.log / server-err.log 只在自建虚拟机上存在，读不到就返回说明。
*/
-const LOG_FILES = {
- crawler: 'crawler.log',
+const FILE_LOGS = {
server: 'server.log',
serverErr: 'server-err.log',
};
+async function readDisk(fileName, linesLimit) {
+ const filePath = path.join(process.cwd(), fileName);
+ if (!fs.existsSync(filePath)) return null;
+ const content = fs.readFileSync(filePath, 'utf8');
+ const stat = fs.statSync(filePath);
+ const allLines = content.split(/\r?\n/).map(l => l.replace(/\r$/, '')).filter(l => l.trim().length > 0);
+ return {
+ lines: allLines.slice(-linesLimit),
+ totalLines: allLines.length,
+ size: stat.size,
+ mtime: stat.mtime,
+ };
+}
+
async function handler(req, res) {
if (req.method !== 'GET') return res.status(405).json({ error: 'Method not allowed' });
const fileKey = String(req.query.file || 'crawler');
- const linesLimit = Math.min(parseInt(req.query.lines) || 500, 5000);
- const fileName = LOG_FILES[fileKey];
- if (!fileName) return res.status(400).json({ error: '未知日志文件' });
-
- const filePath = path.join(process.cwd(), fileName);
+ const linesLimit = Math.min(parseInt(req.query.lines, 10) || 500, 5000);
try {
- let content = '';
- let stat = null;
- if (fs.existsSync(filePath)) {
- content = fs.readFileSync(filePath, 'utf8');
- stat = fs.statSync(filePath);
+ if (fileKey === 'crawler') {
+ const stored = await readJobLogs('crawler', linesLimit);
+ return res.status(200).json({
+ file: fileKey,
+ name: 'logs:crawler',
+ source: 'database',
+ lines: stored.lines,
+ totalLines: stored.totalLines,
+ size: stored.lines.join('\n').length,
+ mtime: stored.lines.length ? new Date().toISOString() : null,
+ });
}
- const allLines = content.split(/\r?\n/);
- const lines = allLines.map(l => l.replace(/\r$/, '')).filter(l => l.trim().length > 0).slice(-linesLimit);
-
- return res.status(200).json({
- file: fileKey,
- name: fileName,
- lines,
- totalLines: allLines.length,
- size: stat ? stat.size : 0,
- mtime: stat ? stat.mtime : null,
- });
+ const fileName = FILE_LOGS[fileKey];
+ if (!fileName) return res.status(400).json({ error: '未知日志文件' });
+ const disk = await readDisk(fileName, linesLimit);
+ if (!disk) {
+ return res.status(200).json({
+ file: fileKey,
+ name: fileName,
+ source: 'missing',
+ lines: [],
+ totalLines: 0,
+ size: 0,
+ mtime: null,
+ note: '无服务器部署没有常驻进程日志文件。爬虫输出在「crawler」里，来自数据库。',
+ });
+ }
+ return res.status(200).json({ file: fileKey, name: fileName, source: 'file', ...disk });
} catch (error) {
console.error('[file-logs] 读取失败:', error);
return res.status(500).json({ error: `读取日志失败: ${error.message}` });
diff --git a/pages/api/admin/sites.js b/pages/api/admin/sites.js
index cfa1815..f82250d 100644
--- a/pages/api/admin/sites.js
+++ b/pages/api/admin/sites.js
@@ -1,25 +1,27 @@
import { withAdmin } from '../../../utils/withAdmin';
-import { loadSiteConfig, saveSiteConfig, validateSite } from '../../../utils/siteConfig';
+import { loadEffectiveConfig, saveSiteConfig, validateSite } from '../../../utils/siteConfig';
/**
* 站点管理 API
- * GET /api/admin/sites -> 获取站点列表（读磁盘最新配置）
+ * GET /api/admin/sites -> 有效站点列表（数据库覆盖优先）
* POST /api/admin/sites -> 添加站点
* PUT /api/admin/sites -> 编辑站点（body 传 { param: 原PARAM, ...站点字段 }）
* DELETE /api/admin/sites -> 删除站点（body 或 query 传 { param }）
+ *
+ * 写入 settings.site:config。磁盘可写时同步刷新 wikitdb.config.js。
*/
async function handler(req, res) {
try {
if (req.method === 'GET') {
- const config = loadSiteConfig();
- return res.status(200).json({ sites: config.SUPPORT_WIKI });
+ const config = await loadEffectiveConfig();
+ return res.status(200).json({ sites: config.SUPPORT_WIKI, source: 'db-or-file' });
}
if (req.method === 'POST') {
const result = validateSite(req.body);
if (result.error) return res.status(400).json({ error: result.error });
- const config = loadSiteConfig();
+ const config = await loadEffectiveConfig();
if (config.SUPPORT_WIKI.some(s => s.PARAM === result.site.PARAM)) {
return res.status(400).json({ error: `PARAM "${result.site.PARAM}" 已被使用` });
@@ -29,7 +31,7 @@ async function handler(req, res) {
}
config.SUPPORT_WIKI.push(result.site);
- saveSiteConfig(config);
+ await saveSiteConfig(config);
return res.status(200).json({ success: true, sites: config.SUPPORT_WIKI });
}
@@ -40,11 +42,10 @@ async function handler(req, res) {
const result = validateSite(req.body);
if (result.error) return res.status(400).json({ error: result.error });
- const config = loadSiteConfig();
+ const config = await loadEffectiveConfig();
const idx = config.SUPPORT_WIKI.findIndex(s => s.PARAM === param);
if (idx === -1) return res.status(404).json({ error: '未找到该站点' });
- // 唯一性检查（排除自身）
if (config.SUPPORT_WIKI.some((s, i) => i !== idx && s.PARAM === result.site.PARAM)) {
return res.status(400).json({ error: `PARAM "${result.site.PARAM}" 已被其他站点使用` });
}
@@ -53,14 +54,14 @@ async function handler(req, res) {
}
config.SUPPORT_WIKI[idx] = result.site;
- saveSiteConfig(config);
+ await saveSiteConfig(config);
return res.status(200).json({ success: true, message: `站点 "${result.site.NAME}" 已更新`, sites: config.SUPPORT_WIKI });
}
if (req.method === 'DELETE') {
const param = String((req.body && req.body.param) || req.query.param || '').trim();
- const config = loadSiteConfig();
+ const config = await loadEffectiveConfig();
if (config.SUPPORT_WIKI.length <= 1) {
return res.status(400).json({ error: '至少需要保留一个站点，不能删除全部站点' });
}
@@ -69,14 +70,14 @@ async function handler(req, res) {
if (idx === -1) return res.status(404).json({ error: '未找到该站点' });
config.SUPPORT_WIKI.splice(idx, 1);
- saveSiteConfig(config);
+ await saveSiteConfig(config);
return res.status(200).json({ success: true, sites: config.SUPPORT_WIKI });
}
return res.status(405).json({ error: 'Method not allowed' });
} catch (error) {
console.error('[sites] 处理失败:', error);
- return res.status(500).json({ error: '站点管理失败，请检查 wikitdb.config.js 是否可写' });
+ return res.status(500).json({ error: '站点管理失败。无服务器部署会把站点写进数据库，请确认 DATABASE_URL 可用。' });
}
}
diff --git a/pages/api/cron/attribution.js b/pages/api/cron/attribution.js
new file mode 100644
index 0000000..8efb0d7
--- /dev/null
+++ b/pages/api/cron/attribution.js
@@ -0,0 +1,21 @@
+import { authorizeCron } from '../../../utils/cronAuth';
+
+export const config = { maxDuration: 60 };
+
+/** GET/POST /api/cron/attribution */
+export default async function handler(req, res) {
+ if (req.method !== 'GET' && req.method !== 'POST') {
+ return res.status(405).json({ error: 'Method not allowed' });
+ }
+ if (!authorizeCron(req)) return res.status(401).json({ error: '未授权的调度请求' });
+
+ const force = req.query.force === '1' || req.query.force === 'true';
+ try {
+ const { runAttributionSlice } = require('../../../jobs/attribution');
+ const result = await runAttributionSlice({ force });
+ return res.status(200).json({ ok: true, result });
+ } catch (error) {
+ console.error('[cron/attribution]', error);
+ return res.status(500).json({ error: error.message || '归属同步失败' });
+ }
+}
diff --git a/pages/api/cron/crawl.js b/pages/api/cron/crawl.js
new file mode 100644
index 0000000..b472cf4
--- /dev/null
+++ b/pages/api/cron/crawl.js
@@ -0,0 +1,29 @@
+import { authorizeCron } from '../../../utils/cronAuth';
+
+export const config = { maxDuration: 60 };
+
+/**
+ * GET/POST /api/cron/crawl
+ * 无服务器调度入口。Vercel Cron 或 GitHub Actions 带 CRON_SECRET 调用。
+ * 每次只推进一个时间片，游标在数据库里。
+ */
+export default async function handler(req, res) {
+ if (req.method !== 'GET' && req.method !== 'POST') {
+ return res.status(405).json({ error: 'Method not allowed' });
+ }
+ if (!authorizeCron(req)) return res.status(401).json({ error: '未授权的调度请求' });
+
+ const budget = Number(req.query.budget);
+ const force = req.query.force === '1' || req.query.force === 'true';
+ try {
+ const { runCrawlSlice } = require('../../../jobs/crawler');
+ const result = await runCrawlSlice({
+ force,
+ budgetMs: Number.isFinite(budget) && budget > 0 ? Math.min(budget * 1000, 50 * 1000) : undefined,
+ });
+ return res.status(200).json({ ok: true, result });
+ } catch (error) {
+ console.error('[cron/crawl]', error);
+ return res.status(500).json({ error: error.message || '爬虫切片失败' });
+ }
+}
diff --git a/pages/api/tools/delete-bot.js b/pages/api/tools/delete-bot.js
index 521ceb1..2c8983d 100644
--- a/pages/api/tools/delete-bot.js
+++ b/pages/api/tools/delete-bot.js
@@ -70,6 +70,12 @@ function readLatestLog(lines = 40) {
}
async function handler(req, res) {
+ if (process.env.VERCEL) {
+ return res.status(501).json({
+ success: false,
+ error: '宿主机删帖机器人依赖 systemd 和本地磁盘，无服务器部署请改用职员面板里的 BotAccount 自动扫描。',
+ });
+ }
// GET：状态 + 配置 + 日志
if (req.method === 'GET') {
const active = run(`systemctl is-active ${SERVICE}`).toLowerCase() === 'active';
diff --git a/prisma/schema.prisma b/prisma/schema.prisma
index 049eeb0..cc8981c 100644
--- a/prisma/schema.prisma
+++ b/prisma/schema.prisma
@@ -1,5 +1,6 @@
generator client {
- provider = "prisma-client-js"
+ provider = "prisma-client-js"
+ binaryTargets = ["native", "rhel-openssl-3.0.x"]
}
datasource db {
diff --git a/tests/cronAuth.test.js b/tests/cronAuth.test.js
new file mode 100644
index 0000000..809a1a0
--- /dev/null
+++ b/tests/cronAuth.test.js
@@ -0,0 +1,42 @@
+const test = require('node:test');
+const assert = require('node:assert/strict');
+const { authorizeCron } = require('../utils/cronAuth');
+const { normalizeLines } = require('../utils/jobLog');
+
+function withEnv(patch, fn) {
+ const previous = {};
+ for (const key of Object.keys(patch)) {
+ previous[key] = process.env[key];
+ if (patch[key] == null) delete process.env[key];
+ else process.env[key] = patch[key];
+ }
+ try {
+ return fn();
+ } finally {
+ for (const key of Object.keys(patch)) {
+ if (previous[key] == null) delete process.env[key];
+ else process.env[key] = previous[key];
+ }
+ }
+}
+
+test('cron auth fails closed without a secret', () => {
+ withEnv({ CRON_SECRET: null, ALLOW_INSECURE_CRON: null, NODE_ENV: 'production', VERCEL: '1' }, () => {
+ assert.equal(authorizeCron({ headers: { authorization: 'Bearer whatever-token' } }), false);
+ });
+});
+
+test('cron auth accepts the bearer secret and rejects a mismatch', () => {
+ withEnv({ CRON_SECRET: 'cron-secret-value-32chars!!', ALLOW_INSECURE_CRON: null, NODE_ENV: 'production', VERCEL: '1' }, () => {
+ assert.equal(authorizeCron({ headers: { authorization: 'Bearer cron-secret-value-32chars!!' } }), true);
+ assert.equal(authorizeCron({ headers: { 'x-cron-secret': 'cron-secret-value-32chars!!' } }), true);
+ assert.equal(authorizeCron({ headers: { authorization: 'Bearer nope' } }), false);
+ assert.equal(authorizeCron({ headers: {} }), false);
+ });
+});
+
+test('job log normalizes stored lines', () => {
+ assert.deepEqual(normalizeLines({ lines: ['a', 'b'] }), ['a', 'b']);
+ assert.deepEqual(normalizeLines('["a"]'), ['a']);
+ assert.deepEqual(normalizeLines(null), []);
+});
diff --git a/utils/cache.js b/utils/cache.js
index c8a3e08..541ecf5 100644
--- a/utils/cache.js
+++ b/utils/cache.js
@@ -1,34 +1,14 @@
/**
- * TTL 内存缓存
- * 支持不同过期时间，自动清理过期条目
+ * 单实例 TTL 缓存。
+ * 无服务器函数不能靠 setInterval 打扫（会拖住实例），读取时顺手丢掉过期项。
+ * 命中范围只在当前温实例内；跨实例共享的数据放数据库或 Upstash。
*/
const store = new Map();
-const DEFAULT_TTL = 5 * 60 * 1000; // 5 分钟
+const DEFAULT_TTL = 5 * 60 * 1000;
const MAX_ENTRIES = 500;
-let cleanupTimer = null;
-function startCleanup() {
- if (cleanupTimer) return;
- cleanupTimer = setInterval(() => {
- const now = Date.now();
- for (const [key, entry] of store) {
- if (now > entry.expiresAt) store.delete(key);
- }
- if (store.size === 0) {
- clearInterval(cleanupTimer);
- cleanupTimer = null;
- }
- }, 60 * 1000);
- if (cleanupTimer.unref) cleanupTimer.unref();
-}
-
-/**
- * 获取缓存值
- * @param {string} key
- * @returns {*} 缓存值或 undefined
- */
function get(key) {
const entry = store.get(key);
if (!entry) return undefined;
@@ -40,15 +20,10 @@ function get(key) {
return entry.value;
}
-/**
- * 设置缓存
- * @param {string} key
- * @param {*} value
- * @param {number} ttl 毫秒，默认 5 分钟
- */
function set(key, value, ttl = DEFAULT_TTL) {
if (store.size >= MAX_ENTRIES) {
- let oldest = null, oldestKey = null;
+ let oldest = null;
+ let oldestKey = null;
for (const [k, v] of store) {
if (!oldest || v.lastAccess < oldest.lastAccess) {
oldest = v;
@@ -58,29 +33,16 @@ function set(key, value, ttl = DEFAULT_TTL) {
if (oldestKey) store.delete(oldestKey);
}
store.set(key, { value, expiresAt: Date.now() + ttl, lastAccess: Date.now() });
- startCleanup();
}
-/**
- * 删除缓存
- */
function del(key) {
store.delete(key);
}
-/**
- * 清空所有缓存
- */
function flush() {
store.clear();
}
-/**
- * 带缓存的异步函数包装器
- * @param {string} key 缓存键
- * @param {Function} fn 异步函数
- * @param {number} ttl 缓存时间（毫秒）
- */
async function cached(key, fn, ttl = DEFAULT_TTL) {
const hit = get(key);
if (hit !== undefined) return hit;
diff --git a/utils/cronAuth.js b/utils/cronAuth.js
new file mode 100644
index 0000000..bc01234
--- /dev/null
+++ b/utils/cronAuth.js
@@ -0,0 +1,38 @@
+/**
+ * 定时任务入口鉴权。
+ * Vercel Cron 会带 Authorization: Bearer $CRON_SECRET。
+ * 未配置 CRON_SECRET 时拒绝（避免把爬虫端点暴露到公网）。
+ * 本地手动调试可设 ALLOW_INSECURE_CRON=1。
+ */
+const crypto = require('crypto');
+
+function header(req, name) {
+ const headers = (req && req.headers) || {};
+ const direct = headers[name] ?? headers[name.toLowerCase()];
+ if (Array.isArray(direct)) return String(direct[0] || '');
+ return direct ? String(direct) : '';
+}
+
+function tokenFromRequest(req) {
+ const auth = header(req, 'authorization');
+ if (/^Bearer\s+/i.test(auth)) return auth.replace(/^Bearer\s+/i, '').trim();
+ return header(req, 'x-cron-secret').trim();
+}
+
+function safeEqual(a, b) {
+ const left = Buffer.from(String(a));
+ const right = Buffer.from(String(b));
+ if (left.length !== right.length) return false;
+ return crypto.timingSafeEqual(left, right);
+}
+
+function authorizeCron(req) {
+ if (process.env.ALLOW_INSECURE_CRON === '1' && process.env.NODE_ENV !== 'production' && !process.env.VERCEL) {
+ return true;
+ }
+ const secret = process.env.CRON_SECRET || '';
+ if (!secret || secret.length < 16) return false;
+ return safeEqual(tokenFromRequest(req), secret);
+}
+
+module.exports = { authorizeCron, tokenFromRequest };
diff --git a/utils/jobLock.js b/utils/jobLock.js
new file mode 100644
index 0000000..b52e643
--- /dev/null
+++ b/utils/jobLock.js
@@ -0,0 +1,53 @@
+/**
+ * 用 settings 行做互斥锁。
+ * 无服务器平台会并发触发同一个 cron，锁保证同一任务只有一个切片在跑。
+ */
+function normalize(value) {
+ if (!value) return null;
+ if (typeof value === 'string') {
+ try { return JSON.parse(value); } catch (e) { return null; }
+ }
+ return value;
+}
+
+async function withJobLock(name, ttlMs, fn) {
+ const prisma = require('../lib/prisma');
+ const key = `lock:${name}`;
+ const owner = `${process.pid}-${Date.now()}-${Math.random().toString(16).slice(2)}`;
+ const until = Date.now() + ttlMs;
+
+ let state;
+ try {
+ state = await prisma.$transaction(async (tx) => {
+ const row = await tx.setting.findUnique({ where: { key } });
+ const cur = normalize(row && row.value);
+ if (cur && Number(cur.until) > Date.now()) return 'locked';
+ const value = { owner, until };
+ await tx.setting.upsert({
+ where: { key },
+ update: { value },
+ create: { key, value },
+ });
+ return 'ok';
+ }, { isolationLevel: 'Serializable' });
+ } catch (e) {
+ if (e.code === 'P2034') return { skipped: true, reason: 'locked' };
+ throw e;
+ }
+
+ if (state !== 'ok') return { skipped: true, reason: 'locked' };
+
+ try {
+ return await fn();
+ } finally {
+ try {
+ const row = await prisma.setting.findUnique({ where: { key } });
+ const cur = normalize(row && row.value);
+ if (cur && cur.owner === owner) {
+ await prisma.setting.delete({ where: { key } });
+ }
+ } catch (e) { /* 锁过期由下一轮覆盖 */ }
+ }
+}
+
+module.exports = { withJobLock };
diff --git a/utils/jobLog.js b/utils/jobLog.js
new file mode 100644
index 0000000..a5339ff
--- /dev/null
+++ b/utils/jobLog.js
@@ -0,0 +1,52 @@
+/**
+ * 任务日志写入 settings 表（logs:），替代 crawler.log 这类本地文件。
+ * 无服务器实例的磁盘在调用结束后就没了，管理后台仍从数据库读最近若干行。
+ */
+const MAX_LINES = 800;
+
+function normalizeLines(value) {
+ if (!value) return [];
+ const parsed = typeof value === 'string' ? safeJson(value) : value;
+ if (Array.isArray(parsed)) return parsed.map(String);
+ if (parsed && Array.isArray(parsed.lines)) return parsed.lines.map(String);
+ return [];
+}
+
+function safeJson(text) {
+ try { return JSON.parse(text); } catch (e) { return null; }
+}
+
+async function appendJobLogs(source, lines) {
+ const incoming = (Array.isArray(lines) ? lines : [lines]).map(String).filter(Boolean);
+ if (incoming.length === 0) return;
+ let prisma;
+ try {
+ prisma = require('../lib/prisma');
+ } catch (e) {
+ return;
+ }
+ const key = `logs:${source}`;
+ try {
+ const row = await prisma.setting.findUnique({ where: { key } });
+ const prev = normalizeLines(row && row.value);
+ const next = prev.concat(incoming).slice(-MAX_LINES);
+ await prisma.setting.upsert({
+ where: { key },
+ update: { value: { lines: next } },
+ create: { key, value: { lines: next } },
+ });
+ } catch (e) {
+ console.error(`[job-log] ${source} 写入失败: ${e.message}`);
+ }
+}
+
+async function readJobLogs(source, limit = 500) {
+ const prisma = require('../lib/prisma');
+ const key = `logs:${source}`;
+ const row = await prisma.setting.findUnique({ where: { key } });
+ const lines = normalizeLines(row && row.value);
+ const sliced = lines.slice(-Math.max(1, limit));
+ return { lines: sliced, totalLines: lines.length };
+}
+
+module.exports = { appendJobLogs, readJobLogs, normalizeLines, MAX_LINES };
diff --git a/utils/siteConfig.js b/utils/siteConfig.js
index 9baa4ac..2b0589b 100644
--- a/utils/siteConfig.js
+++ b/utils/siteConfig.js
@@ -1,7 +1,8 @@
/**
- * wikitdb.config.js 运行时读写工具
- * 使用 vm 沙箱解析配置文件，避免 Next.js webpack 打包导致的 require 缓存问题，
- * 确保读取到的始终是磁盘上的最新配置。
+ * 站点配置。
+ * 仓库里的 wikitdb.config.js 是默认值（会打进部署包）。
+ * 管理后台的改动写入 settings.site:config，无服务器实例没有可写磁盘时也能生效。
+ * 磁盘可写时仍会尝试刷新文件，方便自建虚拟机沿用原来的工作流。
*/
const fs = require('fs');
@@ -9,13 +10,13 @@ const path = require('path');
const vm = require('vm');
const CONFIG_FILENAME = 'wikitdb.config.js';
+const CONFIG_KEY = 'site:config';
function getConfigPath() {
return path.join(process.cwd(), CONFIG_FILENAME);
}
-/** 从磁盘加载配置（vm 沙箱执行，不污染全局） */
-function loadSiteConfig() {
+function loadSiteConfigFromFile() {
const filePath = getConfigPath();
const source = fs.readFileSync(filePath, 'utf8');
const sandbox = { module: { exports: {} }, exports: {} };
@@ -25,7 +26,37 @@ function loadSiteConfig() {
return cfg;
}
-/** 使 Node 侧的 require 缓存失效（对 auto-crawler.js 等独立进程生效） */
+/** 同步读取磁盘配置。已打包的页面仍直接 require 该文件。 */
+function loadSiteConfig() {
+ return loadSiteConfigFromFile();
+}
+
+function normalizeStored(value) {
+ if (!value) return null;
+ if (typeof value === 'string') {
+ try { return JSON.parse(value); } catch (e) { return null; }
+ }
+ return value;
+}
+
+/** 数据库覆盖优先，没有记录或数据库不可用时退回文件。 */
+async function loadEffectiveConfig() {
+ const fileCfg = loadSiteConfigFromFile();
+ try {
+ const prisma = require('../lib/prisma');
+ const row = await prisma.setting.findUnique({ where: { key: CONFIG_KEY } });
+ const stored = normalizeStored(row && row.value);
+ if (stored && Array.isArray(stored.SUPPORT_WIKI)) {
+ return {
+ ...fileCfg,
+ ...stored,
+ SUPPORT_WIKI: stored.SUPPORT_WIKI,
+ };
+ }
+ } catch (e) { /* 构建期或未连上数据库时用文件 */ }
+ return fileCfg;
+}
+
function invalidateConfigCache() {
try {
const resolved = require.resolve(getConfigPath());
@@ -33,7 +64,6 @@ function invalidateConfigCache() {
} catch (e) { /* 打包环境中可能无法解析，忽略 */ }
}
-/** 生成配置文件内容（保留站点模板注释，便于后续手工编辑） */
function buildConfigFileContent(config) {
const lines = [];
lines.push('module.exports = {');
@@ -61,10 +91,27 @@ function buildConfigFileContent(config) {
return lines.join('\n') + '\n';
}
-/** 写回配置文件并刷新缓存 */
-function saveSiteConfig(config) {
- fs.writeFileSync(getConfigPath(), buildConfigFileContent(config), 'utf8');
- invalidateConfigCache();
+async function saveSiteConfig(config) {
+ const payload = {
+ SITE_NAME: config.SITE_NAME || 'WikitDB',
+ SITE_URL: config.SITE_URL || '',
+ SITE_SINCE: config.SITE_SINCE || '2026',
+ SITE_AUTHOR: config.SITE_AUTHOR || 'WikitDB Team',
+ SUPPORT_WIKI: config.SUPPORT_WIKI || [],
+ };
+ const prisma = require('../lib/prisma');
+ await prisma.setting.upsert({
+ where: { key: CONFIG_KEY },
+ update: { value: payload },
+ create: { key: CONFIG_KEY, value: payload },
+ });
+ try {
+ fs.writeFileSync(getConfigPath(), buildConfigFileContent(payload), 'utf8');
+ invalidateConfigCache();
+ } catch (e) {
+ if (e.code !== 'EROFS' && e.code !== 'EACCES' && e.code !== 'EPERM' && e.code !== 'ENOENT') throw e;
+ }
+ return payload;
}
function isHttpUrl(value) {
@@ -77,10 +124,8 @@ function isHttpUrl(value) {
}
}
-/** 校验并规范化一个站点对象，返回 { site } 或 { error } */
function validateSite(input) {
input = input || {};
-
const site = {};
site.NAME = String(input.NAME || '').trim();
@@ -100,7 +145,6 @@ function validateSite(input) {
return { error: 'WIKIT_ID 只能包含字母、数字、点、下划线和连字符（1-80 位）' };
}
- // 可选字段
if (input.ImgURL) {
const imgUrl = String(input.ImgURL).trim();
if (!isHttpUrl(imgUrl)) return { error: 'Logo 链接 (ImgURL) 必须是有效的 http(s) 链接' };
@@ -127,8 +171,11 @@ function validateSite(input) {
module.exports = {
getConfigPath,
loadSiteConfig,
+ loadSiteConfigFromFile,
+ loadEffectiveConfig,
saveSiteConfig,
validateSite,
buildConfigFileContent,
invalidateConfigCache,
+ CONFIG_KEY,
};
diff --git a/vercel.json b/vercel.json
new file mode 100644
index 0000000..3dff4a7
--- /dev/null
+++ b/vercel.json
@@ -0,0 +1,12 @@
+{
+ "crons": [
+ {
+ "path": "/api/cron/crawl",
+ "schedule": "0 18 * * *"
+ },
+ {
+ "path": "/api/cron/attribution",
+ "schedule": "30 18 * * *"
+ }
+ ]
+}