const http = require('http');

exports.handler = function(event, context, callback) {
  const webhookUrl = '你的服务器IP';  // 改为你的实际 IP
  const webhookPath = '/webhook/oss';

  console.log('函数触发时间:', new Date().toISOString());
  console.log('请求 ID:', context.requestId);

  // 解析 OSS 事件
  let ossEvent;
  try {
    ossEvent = JSON.parse(event.toString());
    console.log('事件数量:', ossEvent.events ? ossEvent.events.length : 0);
  } catch (e) {
    console.error('解析事件失败:', e);
    ossEvent = { events: [] };
  }

  // 转发给 webhook 服务器
  const postData = JSON.stringify(ossEvent);

  const options = {
    hostname: webhookUrl,
    port: 80,
    path: webhookPath,
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'Content-Length': Buffer.byteLength(postData),
      'User-Agent': 'AliyunFC-OSS-Trigger/1.0'
    },
    timeout: 10000
  };

  console.log(`转发到: http://${webhookUrl}${webhookPath}`);

  const req = http.request(options, (res) => {
    let data = '';
    res.on('data', (chunk) => { data += chunk; });
    res.on('end', () => {
      console.log(`✅ 转发成功 - 状态:${res.statusCode}`);
      callback(null, { statusCode: 200, body: '转发成功' });
    });
  });

  req.on('error', (e) => {
    console.error(`❌ 转发失败: ${e.message}`);
    callback(null, { statusCode: 200, body: '已记录' });
  });

  req.on('timeout', () => {
    req.destroy();
    console.error('⏱️ 请求超时');
    callback(null, { statusCode: 200, body: '超时' });
  });

  req.write(postData);
  req.end();
};

const express = require('express');
const { exec } = require('child_process');
const fs = require('fs');
const path = require('path');

const app = express();
app.use(express.json());
app.use(express.urlencoded({ extended: true }));
app.use(express.text({ type: 'text/plain' }));

// ==================== 配置区域（修改这里） ====================
const CONFIG = {
  projectDir: '/root/projects/afilmory',          // 项目目录
  bucket: 'afilmory-XXXX',                  // OSS Bucket 名称
  buildDelay: 30000,                              // 防抖延迟（毫秒）
  logFile: path.join(__dirname, 'webhook.log'),  // 日志文件路径
  buildScript: '/root/webhook-service/build-afilmory.sh', // 构建脚本路径
};
// ============================================================

// 日志函数
function log(message) {
  const timestamp = new Date().toISOString();
  const logMessage = `[${timestamp}] ${message}`;
  console.log(logMessage);
  fs.appendFileSync(CONFIG.logFile, logMessage + '\n');
}

// 脱敏函数 - 隐藏日志中的敏感信息
function sanitizeLog(logContent) {
  return logContent
    // 隐藏 AccessKey
    .replace(/AccessKey(Id|Secret)[:=]\s*[\w\/\+=]+/gi, 'AccessKey***隐藏***')
    // 隐藏完整服务器路径
    .replace(/\/root\/[^\s]+/g, '/项目目录/***')
    // 隐藏 IP 地址
    .replace(/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/g, '***.***.***.**')
    // 隐藏 OSS bucket 完整名称（保留前3个字符）
    .replace(/afilmory-\w+/g, 'afi***')
    // 隐藏 OSS endpoint 中的 bucket 名称
    .replace(/oss:\/\/afilmory-[\w-]+/g, 'oss://afi***');
}

// 构建队列
let isBuilding = false;
let pendingBuild = false;
let buildHistory = [];
const MAX_HISTORY = 10;

// 记录构建历史
function addBuildHistory(status, message) {
  buildHistory.unshift({
    timestamp: new Date().toISOString(),
    status,
    message
  });
  if (buildHistory.length > MAX_HISTORY) {
    buildHistory = buildHistory.slice(0, MAX_HISTORY);
  }
}

// 执行构建
function runBuild() {
  if (isBuilding) {
    log('⏳ 已有构建在进行中，标记为待构建');
    pendingBuild = true;
    return;
  }

  isBuilding = true;
  log('🔄 开始自动构建...');
  addBuildHistory('building', '开始构建');

  exec(CONFIG.buildScript, { shell: '/bin/bash' }, (error, stdout, stderr) => {
    isBuilding = false;

    if (stdout) {
      log(`输出:\n${stdout}`);
    }

    if (error) {
      const errorMsg = `构建失败: ${error.message}`;
      log(`❌ ${errorMsg}`);
      addBuildHistory('failed', errorMsg);

      if (stderr) {
        log(`错误详情:\n${stderr}`);
      }

      if (pendingBuild) {
        pendingBuild = false;
        setTimeout(runBuild, 5000);
      }
      return;
    }

    log('✅ 自动构建完成');
    addBuildHistory('success', '构建完成');

    if (pendingBuild) {
      pendingBuild = false;
      setTimeout(runBuild, 2000);
    }
  });
}

// Webhook 接口（OSS 事件通知 - 公开）
app.post('/webhook/oss', (req, res) => {
  log(`📩 收到 OSS 事件通知`);

  try {
    let body = req.body;

    // 函数计算转发的消息是 JSON 格式（也兼容 Base64 编码，以防使用其他方式）
    if (typeof body === 'string') {
      try {
        // 先尝试直接解析 JSON（函数计算格式）
        body = JSON.parse(body);
        log(`✅ JSON 解析成功（函数计算格式）`);
      } catch (e1) {
        // 如果失败，尝试 Base64 解码（兼容其他方式）
        try {
          const decoded = Buffer.from(body, 'base64').toString('utf-8');
          body = JSON.parse(decoded);
          log(`✅ Base64 解码成功（兼容模式）`);
        } catch (e2) {
          log(`⚠️ 消息解析失败: ${e1.message}`);
          body = {};
        }
      }
    }

    // 检查是否有 events 字段
    if (!body || !body.events || !Array.isArray(body.events)) {
      log('⚠️ 请求体格式不正确，触发兜底构建');
      clearTimeout(global.buildTimeout);
      global.buildTimeout = setTimeout(() => {
        runBuild();
      }, CONFIG.buildDelay);

      return res.json({
        success: true,
        message: '已接收通知（格式异常，触发兜底构建）'
      });
    }

    const events = body.events;
    log(`收到 ${events.length} 个事件`);

    // 过滤照片相关事件（创建、删除、重命名）
    const photoEvents = events.filter(e => {
      const isPhotoEvent = e.eventName && (
        e.eventName.startsWith('ObjectCreated') ||   // 上传、复制（重命名第1步）
        e.eventName.startsWith('ObjectRemoved')      // 删除、删除旧文件（重命名第2步）
      );
      const hasKey = e.oss && e.oss.object && e.oss.object.key;
      const inPhotos = hasKey && e.oss.object.key.startsWith('photos/');
      const isImage = hasKey && /\.(jpg|jpeg|png|heic|heif|tiff|webp|raw|dng|cr2|nef)$/i.test(e.oss.object.key);

      if (hasKey && isPhotoEvent && inPhotos && isImage) {
        const eventType = e.eventName.includes('Created') ? '📤 上传/复制' :
                         e.eventName.includes('Removed') ? '🗑️  删除' : e.eventName;
        const fileName = e.oss.object.key.split('/').pop();
        log(`  ${eventType}: ${fileName}`);
      }

      return isPhotoEvent && inPhotos && isImage;
    });

    if (photoEvents.length === 0) {
      log('ℹ️  非照片相关事件，忽略');
      return res.json({ success: true, message: '非照片相关事件' });
    }

    log(`📸 检测到 ${photoEvents.length} 个照片变化（上传/删除/重命名）`);

    // 30秒防抖：多个操作（如重命名=复制+删除）只触发一次构建
    clearTimeout(global.buildTimeout);
    global.buildTimeout = setTimeout(() => {
      runBuild();
    }, CONFIG.buildDelay);

    log(`⏱️  将在 ${CONFIG.buildDelay / 1000} 秒后开始构建`);

    res.json({
      success: true,
      message: `已接收 ${photoEvents.length} 个照片变化，将在 ${CONFIG.buildDelay / 1000} 秒后构建`
    });

  } catch (error) {
    log(`❌ 处理事件失败: ${error.message}`);

    // 出错也触发构建（兜底）
    clearTimeout(global.buildTimeout);
    global.buildTimeout = setTimeout(() => {
      runBuild();
    }, CONFIG.buildDelay);

    res.status(200).json({
      success: true,
      message: '已接收通知（处理异常，触发兜底构建）'
    });
  }
});

// 查看状态（公开，只显示安全信息）
app.get('/webhook/status', (req, res) => {
  res.json({
    status: 'ok',
    isBuilding,
    pendingBuild,
    uptime: Math.floor(process.uptime()),
    uptimeFormatted: formatUptime(process.uptime()),
    buildHistory: buildHistory.slice(0, 5), // 只返回最近5条
    buildDelay: CONFIG.buildDelay / 1000
  });
});

// 格式化运行时间
function formatUptime(seconds) {
  const days = Math.floor(seconds / 86400);
  const hours = Math.floor((seconds % 86400) / 3600);
  const minutes = Math.floor((seconds % 3600) / 60);

  const parts = [];
  if (days > 0) parts.push(`${days}天`);
  if (hours > 0) parts.push(`${hours}小时`);
  if (minutes > 0) parts.push(`${minutes}分钟`);

  return parts.join(' ') || '刚刚启动';
}

// 查看日志（公开，但自动脱敏）
app.get('/webhook/logs', (req, res) => {
  if (!fs.existsSync(CONFIG.logFile)) {
    return res.type('text/plain').send('暂无日志');
  }

  try {
    const logs = fs.readFileSync(CONFIG.logFile, 'utf-8');
    const lines = logs.split('\n').slice(-100); // 最近100行

    // 脱敏处理
    const sanitizedLogs = lines.map(line => sanitizeLog(line)).join('\n');

    res.type('text/plain');
    res.send(sanitizedLogs);
  } catch (error) {
    res.type('text/plain').send('读取日志失败');
  }
});

// 健康检查（公开）
app.get('/webhook/health', (req, res) => {
  res.json({
    status: 'ok',
    timestamp: new Date().toISOString(),
    building: isBuilding
  });
});

// 管理界面（公开，只读）
app.get('/webhook', (req, res) => {
  res.send(`
    <!DOCTYPE html>
    <html lang="zh-CN">
    <head>
      <meta charset="UTF-8">
      <meta name="viewport" content="width=device-width, initial-scale=1.0">
      <title>Afilmory Webhook 监控</title>
      <style>
        * {
          margin: 0;
          padding: 0;
          box-sizing: border-box;
        }
        body {
          font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", sans-serif;
          background: linear-gradient(135deg, #667eea 0%, #764ba2 100%);
          min-height: 100vh;
          padding: 20px;
        }
        .container {
          max-width: 900px;
          margin: 0 auto;
        }
        .card {
          background: white;
          border-radius: 12px;
          padding: 24px;
          margin-bottom: 20px;
          box-shadow: 0 4px 6px rgba(0,0,0,0.1);
        }
        h1 {
          color: #333;
          margin-bottom: 8px;
          font-size: 28px;
        }
        .subtitle {
          color: #666;
          font-size: 14px;
          margin-bottom: 20px;
        }
        .status-indicator {
          display: inline-flex;
          align-items: center;
          padding: 8px 16px;
          border-radius: 20px;
          font-weight: 500;
          font-size: 14px;
          margin-bottom: 12px;
        }
        .status-idle {
          background: #d4edda;
          color: #155724;
        }
        .status-building {
          background: #fff3cd;
          color: #856404;
        }
        .status-dot {
          width: 8px;
          height: 8px;
          border-radius: 50%;
          margin-right: 8px;
          animation: pulse 2s infinite;
        }
        .status-idle .status-dot {
          background: #28a745;
        }
        .status-building .status-dot {
          background: #ffc107;
        }
        @keyframes pulse {
          0%, 100% { opacity: 1; }
          50% { opacity: 0.5; }
        }
        .info-grid {
          display: grid;
          grid-template-columns: repeat(auto-fit, minmax(200px, 1fr));
          gap: 16px;
          margin: 20px 0;
        }
        .info-item {
          background: #f8f9fa;
          padding: 16px;
          border-radius: 8px;
          border-left: 4px solid #667eea;
        }
        .info-label {
          font-size: 12px;
          color: #666;
          margin-bottom: 4px;
        }
        .info-value {
          font-size: 20px;
          font-weight: 600;
          color: #333;
        }
        .section-title {
          font-size: 18px;
          font-weight: 600;
          color: #333;
          margin-bottom: 16px;
          padding-bottom: 8px;
          border-bottom: 2px solid #e9ecef;
        }
        .history-item {
          display: flex;
          align-items: center;
          padding: 12px;
          margin-bottom: 8px;
          background: #f8f9fa;
          border-radius: 6px;
          border-left: 4px solid transparent;
        }
        .history-item.success {
          border-left-color: #28a745;
        }
        .history-item.failed {
          border-left-color: #dc3545;
        }
        .history-item.building {
          border-left-color: #ffc107;
        }
        .history-time {
          font-size: 12px;
          color: #666;
          margin-right: 12px;
          min-width: 100px;
        }
        .history-message {
          flex: 1;
          font-size: 14px;
          color: #333;
        }
        .history-badge {
          padding: 4px 12px;
          border-radius: 12px;
          font-size: 12px;
          font-weight: 500;
        }
        .badge-success {
          background: #d4edda;
          color: #155724;
        }
        .badge-failed {
          background: #f8d7da;
          color: #721c24;
        }
        .badge-building {
          background: #fff3cd;
          color: #856404;
        }
        .btn {
          display: inline-block;
          padding: 10px 20px;
          background: #667eea;
          color: white;
          text-decoration: none;
          border-radius: 6px;
          font-size: 14px;
          margin-right: 10px;
          transition: background 0.3s;
        }
        .btn:hover {
          background: #5568d3;
        }
        .footer {
          text-align: center;
          color: white;
          margin-top: 32px;
          font-size: 14px;
          opacity: 0.9;
        }
        .empty-state {
          text-align: center;
          padding: 40px;
          color: #999;
        }
      </style>
      <script>
        // 自动刷新状态
        async function refreshStatus() {
          try {
            const response = await fetch('/webhook/status');
            const data = await response.json();

            // 更新状态
            const statusEl = document.getElementById('status');
            const uptimeEl = document.getElementById('uptime');
            const historyEl = document.getElementById('history');

            if (data.isBuilding) {
              statusEl.innerHTML = '<span class="status-dot"></span>正在构建中...';
              statusEl.className = 'status-indicator status-building';
            } else {
              statusEl.innerHTML = '<span class="status-dot"></span>空闲';
              statusEl.className = 'status-indicator status-idle';
            }

            uptimeEl.textContent = data.uptimeFormatted;

            // 更新历史
            if (data.buildHistory && data.buildHistory.length > 0) {
              historyEl.innerHTML = data.buildHistory.map(item => {
                const time = new Date(item.timestamp).toLocaleString('zh-CN', {
                  month: '2-digit',
                  day: '2-digit',
                  hour: '2-digit',
                  minute: '2-digit'
                });
                const badgeClass = item.status === 'success' ? 'badge-success' :
                                   item.status === 'failed' ? 'badge-failed' : 'badge-building';
                const statusText = item.status === 'success' ? '成功' :
                                  item.status === 'failed' ? '失败' : '构建中';

                return \`
                  <div class="history-item \${item.status}">
                    <div class="history-time">\${time}</div>
                    <div class="history-message">\${item.message}</div>
                    <span class="history-badge \${badgeClass}">\${statusText}</span>
                  </div>
                \`;
              }).join('');
            } else {
              historyEl.innerHTML = '<div class="empty-state">暂无构建记录</div>';
            }
          } catch (error) {
            console.error('刷新状态失败:', error);
          }
        }

        // 页面加载时刷新
        document.addEventListener('DOMContentLoaded', () => {
          refreshStatus();
          // 每10秒自动刷新
          setInterval(refreshStatus, 10000);
        });
      </script>
    </head>
    <body>
      <div class="container">
        <div class="card">
          <h1>📸 Afilmory Webhook 监控</h1>
          <p class="subtitle">自动构建监控 · 只读模式</p>

          <div id="status" class="status-indicator status-${isBuilding ? 'building' : 'idle'}">
            <span class="status-dot"></span>
            ${isBuilding ? '正在构建中...' : '空闲'}
          </div>
          ${pendingBuild ? '<p style="color: #856404; font-size: 14px; margin-top: 8px;">⏳ 有待处理的构建任务</p>' : ''}

          <div class="info-grid">
            <div class="info-item">
              <div class="info-label">服务运行时间</div>
              <div class="info-value" id="uptime">${formatUptime(process.uptime())}</div>
            </div>
            <div class="info-item">
              <div class="info-label">防抖延迟</div>
              <div class="info-value">${CONFIG.buildDelay / 1000}秒</div>
            </div>
            <div class="info-item">
              <div class="info-label">构建状态</div>
              <div class="info-value">${isBuilding ? '进行中' : '空闲'}</div>
            </div>
          </div>
        </div>

        <div class="card">
          <div class="section-title">🕐 最近构建历史</div>
          <div id="history">
            ${buildHistory.length > 0 ? buildHistory.slice(0, 5).map(item => {
              const time = new Date(item.timestamp).toLocaleString('zh-CN', {
                month: '2-digit',
                day: '2-digit',
                hour: '2-digit',
                minute: '2-digit'
              });
              const badgeClass = item.status === 'success' ? 'badge-success' :
                                item.status === 'failed' ? 'badge-failed' : 'badge-building';
              const statusText = item.status === 'success' ? '成功' :
                                item.status === 'failed' ? '失败' : '构建中';

              return `
                <div class="history-item ${item.status}">
                  <div class="history-time">${time}</div>
                  <div class="history-message">${item.message}</div>
                  <span class="history-badge ${badgeClass}">${statusText}</span>
                </div>
              `;
            }).join('') : '<div class="empty-state">暂无构建记录</div>'}
          </div>
        </div>

        <div class="card">
          <div class="section-title">🔗 快捷链接</div>
          <a href="/webhook/status" class="btn" target="_blank">📊 查看状态 JSON</a>
          <a href="/webhook/logs" class="btn" target="_blank">📝 查看日志</a>
          <a href="/webhook/health" class="btn" target="_blank">💚 健康检查</a>
        </div>

        <div class="footer">
          <p>Afilmory Webhook Service · 自动化构建监控</p>
          <p style="margin-top: 8px; font-size: 12px;">页面每10秒自动刷新</p>
        </div>
      </div>
    </body>
    </html>
  `);
});

// 首页重定向到 webhook 管理界面
app.get('/', (req, res) => {
  res.redirect('/webhook');
});

// 监听地址配置
const HOST = process.env.WEBHOOK_HOST || '127.0.0.1';
const PORT = process.env.WEBHOOK_PORT || 3002;

app.listen(PORT, HOST, () => {
  log(`🎣 Webhook 服务启动成功`);
  log(`📍 监听地址: ${HOST}:${PORT}`);
  log(`📝 日志文件: ${CONFIG.logFile}`);
  log(`⏱️  防抖延迟: ${CONFIG.buildDelay / 1000} 秒`);

  if (HOST === '127.0.0.1' || HOST === 'localhost') {
    log(`✅ 安全模式：仅监听 localhost，通过 Nginx 访问`);
  }
});

process.on('SIGTERM', () => {
  log('收到 SIGTERM 信号，准备退出...');
  process.exit(0);
});

process.on('SIGINT', () => {
  log('收到 SIGINT 信号，准备退出...');
  process.exit(0);
});

#!/bin/bash

# ==================== 配置区域（修改这里） ====================
# 项目目录
PROJECT_DIR="/root/projects/afilmory"

# OSS Bucket 名称
OSS_BUCKET="afilmory-xxx"

# PM2 应用名称
PM2_APP_NAME="afilmory"

# Manifest 和缩略图路径（相对于项目根目录）
MANIFEST_PATH="apps/web/src/data/photos-manifest.json"
THUMBNAILS_PATH="apps/web/src/data/thumbnails"

# SSR 应用目录（如果需要重新构建）
SSR_DIR="apps/ssr"
# ============================================================

set -e  # 遇到错误立即退出

# 日志函数
log() {
    echo "[$(date '+%Y-%m-%d %H:%M:%S')] $1"
}

log "=========================================="
log "开始自动构建 Afilmory"
log "=========================================="

# 进入项目目录
cd "$PROJECT_DIR" || {
    log "❌ 错误：无法进入项目目录 $PROJECT_DIR"
    exit 1
}

# 加载环境变量
if [ -f .env ]; then
    log "📝 加载环境变量"
    set -a
    source .env
    set +a
else
    log "⚠️  警告：.env 文件不存在"
fi

# 运行 Builder
log "📸 运行 Builder 处理照片"
if pnpm run build:manifest 2>&1; then
    log "✅ Builder 执行成功"
else
    log "❌ Builder 执行失败"
    exit 1
fi

# 检查 manifest 文件是否存在
if [ ! -f "$MANIFEST_PATH" ]; then
    log "❌ 错误：找不到 manifest 文件: $MANIFEST_PATH"
    exit 1
fi

# 检查缩略图目录是否存在
if [ ! -d "$THUMBNAILS_PATH" ]; then
    log "⚠️  警告：找不到 thumbnails 目录: $THUMBNAILS_PATH"
    log "尝试查找 thumbnails 目录..."
    THUMBNAILS_PATH=$(find . -name "thumbnails" -type d | grep -v node_modules | head -1)
    if [ -z "$THUMBNAILS_PATH" ]; then
        log "❌ 错误：无法找到 thumbnails 目录"
        exit 1
    fi
    log "✅ 找到 thumbnails 目录: $THUMBNAILS_PATH"
fi

# 上传 manifest 到 OSS
log "📤 上传 manifest 到 OSS"
if ossutil cp "$MANIFEST_PATH" \
    oss://$OSS_BUCKET/photos-manifest.json --update 2>&1; then
    log "✅ Manifest 上传成功"
else
    log "❌ Manifest 上传失败"
    exit 1
fi

# 上传缩略图到 OSS
log "📤 上传缩略图到 OSS"
if ossutil cp -r "$THUMBNAILS_PATH/" \
    oss://$OSS_BUCKET/thumbnails/ --update 2>&1; then
    log "✅ 缩略图上传成功"
else
    log "❌ 缩略图上传失败"
    exit 1
fi

# 设置 Content-Type
log "🔧 设置 manifest Content-Type"
if ossutil set-meta oss://$OSS_BUCKET/photos-manifest.json \
    Content-Type:application/json --update 2>&1; then
    log "✅ Content-Type 设置成功"
else
    log "⚠️  Content-Type 设置失败（不影响使用）"
fi

# 重新构建 SSR 应用（可选）
log "🔨 重新构建 SSR 应用"
cd "$PROJECT_DIR/$SSR_DIR"
if pnpm run build 2>&1; then
    log "✅ SSR 构建成功"
else
    log "⚠️  SSR 构建失败（可能不影响）"
fi

# 重启服务
log "🔄 重启 Afilmory 服务"
if pm2 restart "$PM2_APP_NAME" --update-env 2>&1; then
    log "✅ 服务重启成功"
else
    log "❌ 服务重启失败"
    exit 1
fi

log "=========================================="
log "✅ 构建完成！"
log "=========================================="

exit 0