个人数据仪表盘

1. 列出并优先排序数据源 - 一级（每日）：银行交易、步数、屏幕时间 - 二级（每小时）：GitHub 提交、日历事件、天气 - 三级（每周）：邮件统计、音乐收听、睡眠摘要 - MVP 从 2-3 个一级源开始 2. 测试每个源的 API - 认证：OAuth（Strava、Google）、API key（GitHub）、屏幕抓取（银行无 API 时） - 限流：记录每源限制（Strava 100/15 分钟、GitHub 5000/小时） - 分页和增量同步：支持 ?since=lastSync 游标 3. 设计统一数据模型 - 每源映射到通用事件：{ source, timestamp, metric, value, meta } - 银行 -> { metric: "spend", value: -42.50, meta: { merchant, category } } - 健身 -> { metric: "steps", value: 8234, meta: {} } - 存 SQLite，索引 (source, timestamp) 4. 选图表库 - uPlot：40KB，时序最快，无交互（仅缩放） - ECharts：800KB 但全功能（地图、热力图、交互） - Recharts：React 原生，200KB，适合可组合仪表盘 - 按包预算选，非按功能数 5. 设计同步计划 - 每源按自然频率 cron（银行：6 小时、健身：1 小时） - 错开任务避免同时打所有 API - 每源标记 lastSync 和 nextSync 供 UI 用

// 统一事件模型 interface Event { source: "bank" | "fitness" | "github" | "calendar" | "screentime"; timestamp: number; // unix 毫秒 metric: string; // "spend" | "steps" | "commits" | "focus_minutes" value: number; meta: Record<string, string | number>; } // SQLite schema CREATE TABLE events ( source TEXT NOT NULL, timestamp INTEGER NOT NULL, metric TEXT NOT NULL, value REAL NOT NULL, meta TEXT, -- JSON UNIQUE(source, timestamp, metric) ); CREATE INDEX idx_events_query ON events(source, timestamp); // 同步计划（错开） cron: [ { source: "fitness", every: "1h", offset: "0m" }, { source: "github", every: "1h", offset: "15m" }, { source: "bank", every: "6h", offset: "30m" }, { source: "screentime", every: "6h", offset: "45m" }, ];

1. 建每源同步适配器 - 每适配器：{ auth, fetch(since): Event[], rateLimitInfo } - 适配器内处理 token 刷新（OAuth） - 返回限流 header 让调度器退避 2. 使同步幂等且增量 - 按 (source, timestamp, metric) upsert——重跑同步安全 - 传最后同步时间戳作游标：fetch(since = lastSync) - 每次限 1000 事件；源返回更多则分页 3. 优雅处理失败 - 401：刷新 token，重试一次，然后标记源"auth_expired" - 429：读 Retry-After header，重排任务，指数退避 - 5xx：带抖动重试 3 次，然后标记源"degraded"（显示旧数据带警告） 4. 建响应式图表 - 按时间范围查存储；订阅存储变更获实时更新 - 每源显示"2 分钟前更新"——过期指示建信任 - 首次同步时显示加载骨架；源降级时显示错误态 5. 加同步调度器 - BullMQ + Redis：每源一队列，按源频率重复任务 - 错开偏移使所有源不同秒触发 - 仪表盘：显示下次同步时间和每源"立即同步"按钮

// 幂等增量同步（Strava 适配器） async function syncStrava(since: number) { const token = await refreshIfExpired("strava"); const activities = await fetch( `https://api.strava.com/athlete/activities?after=${since}`, { headers: { Authorization: `Bearer ${token}` } } ).then(r => r.json()); const events = activities.map(a => ({ source: "fitness", timestamp: a.start_date * 1000, metric: "steps", value: a.steps, meta: { type: a.type }, })); // upsert——重跑安全（UNIQUE 约束） await db.events.upsertMany(events, ["source", "timestamp", "metric"]); return { synced: events.length, lastSync: Math.max(...events.map(e => e.timestamp)) }; } // UI 中的过期指示 function SourceBadge({ source }) { const lastSync = useLastSync(source); // 响应式 const stale = Date.now() - lastSync > 2 * 3600_000; // 2 小时 return <span className={stale ? "stale" : "fresh"}> {stale ? "⚠️" : "✓"} 更新于 {timeAgo(lastSync)} </span>; }

1. 选部署模型 - 自托管 VPS（Hetzner $5/月）：完全控制，数据归你 - Fly.io 单实例：易部署，缩到一，数据在挂载卷 - 本地优先（Tauri 应用 + SQLite）：数据不离机，经用户云同步 2. 敏感数据静态加密 - events 表用 SQLCipher（SQLite + AES-256） - 加密密钥来自用户主密码（argon2id KDF） - 非敏感元数据（源名、同步时间）可不加密以快查询 3. 保护 OAuth token - 刷新 token 加密存数据库，绝不存 env 文件或明文 - 用每部署密钥（openssl rand 32）作加密密钥 - 按计划轮换密钥；轮换时重新加密 token 4. 锁定实例 - 前置 Cloudflare：WAF、限流和 TLS - 认证：单用户 Basic auth 或强密码会话 cookie - 无公开注册——这是个人应用非 SaaS 5. 备份和灾难恢复 - 每晚：加密 SQLite 文件上传到 Backblaze B2 或 S3 - 每月测恢复：下载、解密、对备份跑应用 - 文档化恢复流程，使丢 VFS 是 30 分钟恢复非数据丢失

// SQLCipher：加密 SQLite import Database from "better-sqlite3"; const db = new Database("data.db"); db.pragma(`key = "${process.env.DB_ENCRYPTION_KEY}"`); // AES-256 // events 表现在静态加密 // Fly.io 部署（单实例，挂载卷） # fly.toml app = "my-dashboard" [mounts] source = "dashboard_data" destination = "/data" # 数据在卷上跨部署持久 // 每晚加密备份（定时） const dump = db.backup("/data/snapshot.db"); const encrypted = await encrypt(dump, process.env.BACKUP_KEY); await b2.upload("dashboard-backups/snapshot-" + date() + ".enc", encrypted); // 前置 Cloudflare：WAF + 限流 + TLS // 认证：单用户会话 cookie（无公开注册） app.use(session({ secret: process.env.SESSION_SECRET }));