zhizhi/scripts/sync-dev-status.js

/**
 * sync-dev-status.js
 * 从 Notion 主控台同步 dev-status.json 到 GitHub 仓库
 * 
 * 使用方式：
 *   NOTION_TOKEN=xxx DEV_STATUS_DB_ID=xxx node scripts/sync-dev-status.js
 * 
 * 如果 Notion 环境变量不可用，将基于本地文件刷新 last_sync 时间戳
 */

const fs = require('fs');
const path = require('path');
const https = require('https');

const DEV_STATUS_PATH = path.join('.github', 'persona-brain', 'dev-status.json');
const ROOT_STATUS_PATH = 'dev-status.json';

const NOTION_TOKEN = process.env.NOTION_TOKEN || '';
const DEV_STATUS_DB_ID = process.env.DEV_STATUS_DB_ID || '';

// ── Notion API 请求封装 ──
function notionRequest(method, endpoint, body) {
  return new Promise((resolve, reject) => {
    const data = body ? JSON.stringify(body) : null;
    const options = {
      hostname: 'api.notion.com',
      path: `/v1/${endpoint}`,
      method,
      headers: {
        'Authorization': `Bearer ${NOTION_TOKEN}`,
        'Notion-Version': '2022-06-28',
        'Content-Type': 'application/json',
      },
    };
    if (data) options.headers['Content-Length'] = Buffer.byteLength(data);

    const req = https.request(options, (res) => {
      let result = '';
      res.on('data', (chunk) => result += chunk);
      res.on('end', () => {
        try {
          resolve({ status: res.statusCode, data: JSON.parse(result) });
        } catch {
          resolve({ status: res.statusCode, data: result });
        }
      });
    });
    req.on('error', reject);
    if (data) req.write(data);
    req.end();
  });
}

// ── 从 Notion 数据库查询开发者状态 ──
async function fetchDevStatusFromNotion() {
  if (!NOTION_TOKEN || !DEV_STATUS_DB_ID) {
    console.log('⚠️ NOTION_TOKEN 或 DEV_STATUS_DB_ID 未配置，跳过 Notion 同步');
    return null;
  }

  console.log('📡 正在从 Notion 查询开发者状态...');

  const response = await notionRequest('POST', `databases/${DEV_STATUS_DB_ID}/query`, {
    sorts: [{ property: '编号', direction: 'ascending' }],
  });

  if (response.status !== 200) {
    console.error(`❌ Notion API 返回 ${response.status}:`, JSON.stringify(response.data).slice(0, 500));
    return null;
  }

  const pages = response.data.results || [];
  if (pages.length === 0) {
    console.log('⚠️ Notion 数据库为空，跳过同步');
    return null;
  }

  console.log(`✅ 从 Notion 获取到 ${pages.length} 条开发者记录`);

  // 解析 Notion 页面属性为 dev-status 格式
  const team = pages.map(page => {
    const props = page.properties || {};
    return {
      dev_id: getNotionText(props['编号']) || getNotionTitle(props['Name']) || '',
      name: getNotionText(props['昵称']) || getNotionTitle(props['Name']) || '',
      module: getNotionText(props['当前模块']) || '',
      status: mapNotionStatus(getNotionSelect(props['状态'])),
      current: getNotionText(props['当前进度']) || '',
      waiting: getNotionText(props['等待项']) || '',
      streak: getNotionNumber(props['连胜']) || 0,
    };
  }).filter(d => d.dev_id);

  return team;
}

// ── Notion 属性解析辅助函数 ──
function getNotionText(prop) {
  if (!prop) return '';
  if (prop.type === 'rich_text') return (prop.rich_text || []).map(t => t.plain_text).join('');
  if (prop.type === 'title') return (prop.title || []).map(t => t.plain_text).join('');
  return '';
}

function getNotionTitle(prop) {
  if (!prop) return '';
  if (prop.type === 'title') return (prop.title || []).map(t => t.plain_text).join('');
  return '';
}

function getNotionSelect(prop) {
  if (!prop || prop.type !== 'select') return '';
  return prop.select?.name || '';
}

function getNotionNumber(prop) {
  if (!prop || prop.type !== 'number') return 0;
  return prop.number || 0;
}

function mapNotionStatus(status) {
  const map = {
    '活跃': 'active',
    '等待SYSLOG': 'waiting_syslog',
    '等待广播': 'waiting_broadcast',
    '暂停': 'paused',
    '已毕业': 'graduated',
  };
  return map[status] || status || 'active';
}

// ── 生成汇总信息 ──
function generateSummary(team) {
  const activeCount = team.filter(d => d.status === 'active').length;
  const waitingSyslog = team.filter(d => d.status === 'waiting_syslog').length;
  const topStreak = team.reduce((max, d) => d.streak > max.streak ? d : max, { streak: 0 });
  const alerts = team
    .filter(d => d.waiting && d.waiting.includes('⚠️'))
    .map(d => `${d.dev_id} ${d.name}: ${d.waiting}`);

  return {
    total_devs: team.length,
    active_waiting_syslog: waitingSyslog,
    active_normal: activeCount,
    top_streak: topStreak.dev_id ? `${topStreak.dev_id} ${topStreak.name} ${topStreak.streak}连胜` : '无',
    alerts,
  };
}

// ── 主流程 ──
async function main() {
  const now = new Date();
  const bjTime = new Date(now.getTime() + 8 * 60 * 60 * 1000);
  const timestamp = bjTime.toISOString().replace('Z', '+08:00');

  console.log(`🔄 dev-status.json 同步开始 · ${timestamp}`);

  // 读取当前状态
  let currentStatus = {};
  try {
    currentStatus = JSON.parse(fs.readFileSync(DEV_STATUS_PATH, 'utf8'));
  } catch {
    console.log('⚠️ 当前 dev-status.json 不存在或格式错误，将创建新文件');
  }

  // 尝试从 Notion 获取数据
  const notionTeam = await fetchDevStatusFromNotion();

  if (notionTeam) {
    // Notion 同步成功
    currentStatus.team = notionTeam;
    currentStatus.summary = generateSummary(notionTeam);
    currentStatus.sync_source = 'notion-master-console';
    console.log(`✅ Notion 同步成功 · ${notionTeam.length} 位开发者`);
  } else {
    // Notion 不可用时，保持现有数据，仅更新时间戳
    console.log('📌 Notion 不可用，保留当前数据，更新同步时间戳');
    if (currentStatus.team) {
      currentStatus.summary = generateSummary(currentStatus.team);
    }
    currentStatus.sync_source = currentStatus.sync_source || 'local-refresh';
  }

  // 更新同步时间
  currentStatus.last_sync = timestamp;

  // 写入 persona-brain 版本
  fs.writeFileSync(DEV_STATUS_PATH, JSON.stringify(currentStatus, null, 2) + '\n');
  console.log(`✅ 已写入 ${DEV_STATUS_PATH}`);

  // 同步写入根目录版本
  fs.writeFileSync(ROOT_STATUS_PATH, JSON.stringify(currentStatus, null, 2) + '\n');
  console.log(`✅ 已写入 ${ROOT_STATUS_PATH}`);

  // 输出摘要
  if (currentStatus.summary) {
    console.log('\n📊 团队状态摘要:');
    console.log(`   总开发者: ${currentStatus.summary.total_devs}`);
    console.log(`   等待SYSLOG: ${currentStatus.summary.active_waiting_syslog}`);
    console.log(`   最高连胜: ${currentStatus.summary.top_streak}`);
    if (currentStatus.summary.alerts?.length > 0) {
      console.log(`   ⚠️ 告警: ${currentStatus.summary.alerts.length} 条`);
      currentStatus.summary.alerts.forEach(a => console.log(`      - ${a}`));
    }
  }

  console.log(`\n✅ dev-status.json 同步完成 · ${timestamp}`);
}

main().catch(err => {
  console.error('❌ 同步失败:', err.message);
  process.exit(1);
});