video-workflow/cloud-functions/03-historyManager.js

/**
 * 云函数：historyManager（历史记录）
 * 替代：GET/POST/DELETE /api/history[/:id]
 * 支持 action：list | create | delete | clearAll
 */
const { requireSession, assertRequestedUserMatchesSession } = require('./_session');

async function handler(request, response) {
  try {
    await ensureTable();

    const action = pickParam(request, 'action') || 'list';
    const session = await requireSession(request, Psql);
    assertRequestedUserMatchesSession(request, session);
    const userId = session.userId;

    if (action === 'list') return listHistory(request, response, userId);
    if (action === 'create') return createHistory(request, response, userId);
    if (action === 'delete') return deleteHistory(request, response, userId);
    if (action === 'clearAll') return clearHistory(response, userId);

    return response.json({ code: 400, success: false, error: `未知 action: ${action}` });
  } catch (error) {
    console.error('historyManager failed:', error && error.message);
    return response.json({ code: error.status || 500, success: false, error: error.message });
  }
}

async function ensureTable() {
  await Psql.query(`
    CREATE TABLE IF NOT EXISTS "History" (
      "objectId"  VARCHAR(50) PRIMARY KEY,
      "bizId"     VARCHAR(255),
      "data"      JSONB NOT NULL DEFAULT '{}',
      "userId"    VARCHAR(255) DEFAULT '',
      "action"    VARCHAR(100) DEFAULT '',
      "createdAt" TIMESTAMPTZ  DEFAULT NOW()
    )
  `);
  await Psql.query(`CREATE INDEX IF NOT EXISTS idx_history_user ON "History" ("userId")`);
  await Psql.query(`CREATE INDEX IF NOT EXISTS idx_history_created ON "History" ("createdAt" DESC)`);
}

async function listHistory(request, response, userId) {
  const limit = safeLimit(pickParam(request, 'limit'), 500, 2000);
  const rows = await Psql.query(
    `SELECT * FROM "History" WHERE "userId" = $1 ORDER BY "createdAt" DESC LIMIT $2`,
    [userId, limit]
  );
  return response.json({ code: 200, success: true, data: rows.map(rowToObj) });
}

async function createHistory(request, response, userId) {
  const body = pickParam(request, 'entry', 'data') || request.body || {};
  const bizId = body.id || body.bizId || generateId();
  const merged = {
    ...body,
    id: bizId,
    bizId,
    userId,
    created_at: body.created_at || new Date().toISOString(),
  };
  await Psql.query(
    `INSERT INTO "History" ("objectId","bizId","data","userId","action") VALUES ($1,$2,$3,$4,$5)`,
    [generateId(), bizId, JSON.stringify(merged), userId, body.action || body.type || '']
  );
  return response.json({ code: 200, success: true, data: merged });
}

async function deleteHistory(request, response, userId) {
  const id = pickParam(request, 'id', 'bizId');
  if (!id) return response.json({ code: 400, success: false, error: '缺少 id' });
  const result = await Psql.query(`DELETE FROM "History" WHERE "bizId" = $1 AND "userId" = $2 RETURNING "bizId"`, [id, userId]);
  return response.json({ code: 200, success: true, data: { id, deleted: result.length > 0 } });
}

async function clearHistory(response, userId) {
  await Psql.query(`DELETE FROM "History" WHERE "userId" = $1`, [userId]);
  return response.json({ code: 200, success: true, message: '已清空当前账号历史' });
}

function rowToObj(row) {
  const data = typeof row.data === 'string' ? JSON.parse(row.data) : (row.data || {});
  return { ...data, objectId: row.objectId, createdAt: row.createdAt };
}

function pickParam(request, ...names) {
  const sources = [request.params, request.body, request.query, request];
  for (const src of sources) {
    if (!src || typeof src !== 'object') continue;
    for (const name of names) {
      const value = src[name];
      if (value !== undefined && value !== null && value !== '') return value;
    }
  }
  return null;
}

function safeLimit(value, fallback, max) {
  const parsed = parseInt(value || fallback, 10);
  return Number.isFinite(parsed) ? Math.min(Math.max(parsed, 1), max) : fallback;
}

function generateId() {
  const chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
  let value = '';
  for (let i = 0; i < 10; i += 1) value += chars.charAt(Math.floor(Math.random() * chars.length));
  return value;
}