fmode-app/scripts/deploy-cloud-fn.mjs

#!/usr/bin/env node
/**
 * 云函数热更脚本（本地使用，不部署、不上传）
 *
 * ## 用途
 *
 * 把 `cloud/functions/*.js` 的最新源码推到线上 Parse 的 `Function` 表。
 * 热更免重启（`PUT /parse/classes/Function/<objectId>`）。
 *
 * ## 为什么需要 Master-Key
 *
 * 写 `Function` 表属于平台管理操作，只有 Master-Key 有权限。
 * 🔴 **Master-Key 绝不能写进代码或提交进 git**，只能通过环境变量传入：
 *
 * ```bash
 * PARSE_MASTER_KEY=xxx node scripts/deploy-cloud-fn.mjs
 * PARSE_MASTER_KEY=xxx node scripts/deploy-cloud-fn.mjs --dry-run
 * ```
 *
 * ## 安全
 *
 * · 默认 **dry-run**：只打印将要更新什么，不发请求
 * · `--apply` 才真正 PUT
 * · 不发请求前先 GET 一次，对比线上版本，避免误覆盖别人改过的代码
 *
 * ## 频率限制
 *
 * 实测：`PUT` 连续请求会返回 403，需退避重试（见操作追踪 :3125）。
 */
import { readFileSync } from 'node:fs';
import { dirname, resolve } from 'node:path';
import { fileURLToPath } from 'node:url';

const here = dirname(fileURLToPath(import.meta.url));
const root = resolve(here, '..');

const APP_ID = 'ncloudmaster';
const BASE = 'https://server.fmode.cn/parse';
const MK = process.env.PARSE_MASTER_KEY;
const APPLY = process.argv.includes('--apply');

/** 要部署的函数清单
 *
 * `create: true` 表示「线上还没这条就新建」——新建后会在控制台打印 objectId，
 * 需要把它写回 `src/app/core/api/parse-api.ts` 的 `FN` 常量。
 */
const TARGETS = [
  {
    file: 'cloud/functions/fmodeagent-chatthreads.js',
    id: 'oR5O67i1Cm',
    name: 'fmodeagent-chatthreads',
    version: '0.1.9',
  },
  {
    file: 'cloud/functions/fmode-file-hub.js',
    id: null, // 新建前未知，部署时按 name 查
    name: 'fmode-file-hub',
    version: '0.1.0',
    create: true,
  },
];

function authHeaders() {
  return {
    'X-Parse-Application-Id': APP_ID,
    'X-Parse-Master-Key': MK,
    'Content-Type': 'application/json',
  };
}

async function getRemote(id) {
  const res = await fetch(`${BASE}/classes/Function/${id}`, { headers: authHeaders() });
  if (!res.ok) throw new Error(`读取失败 HTTP ${res.status}`);
  return res.json();
}

/** 按函数名查 objectId（新建前用于判断「线上是否已存在」） */
async function findByName(name) {
  const where = encodeURIComponent(JSON.stringify({ name }));
  const res = await fetch(`${BASE}/classes/Function?where=${where}&limit=1`, {
    headers: authHeaders(),
  });
  if (!res.ok) throw new Error(`按名查询失败 HTTP ${res.status}`);
  const j = await res.json();
  return (j.results ?? [])[0] ?? null;
}

/** 新建云函数（POST /classes/Function），返回新 objectId */
async function createRemote(name, code, version) {
  const res = await fetch(`${BASE}/classes/Function`, {
    method: 'POST',
    headers: authHeaders(),
    body: JSON.stringify({ name, code, version, enabled: true }),
  });
  const text = await res.text();
  if (!res.ok) throw new Error(`新建失败 HTTP ${res.status}: ${text.slice(0, 200)}`);
  const j = JSON.parse(text);
  return j.objectId;
}

/** PUT 有频率限制，403 时退避重试 */
async function putRemote(id, body, attempt = 1) {
  const res = await fetch(`${BASE}/classes/Function/${id}`, {
    method: 'PUT',
    headers: authHeaders(),
    body: JSON.stringify(body),
  });
  if (res.status === 403 && attempt <= 4) {
    const wait = 1000 * attempt;
    console.log(`  ⚠️ 403（频率限制），${wait}ms 后重试 ${attempt}/4`);
    await new Promise((r) => setTimeout(r, wait));
    return putRemote(id, body, attempt + 1);
  }
  const text = await res.text();
  if (!res.ok) throw new Error(`PUT 失败 HTTP ${res.status}: ${text.slice(0, 200)}`);
  try {
    return JSON.parse(text);
  } catch {
    return { raw: text.slice(0, 200) };
  }
}

async function main() {
  if (!MK) {
    console.error('❌ 缺少 PARSE_MASTER_KEY 环境变量');
    console.error('   用法：PARSE_MASTER_KEY=xxx node scripts/deploy-cloud-fn.mjs [--apply]');
    process.exit(2);
  }

  console.log(APPLY ? '🔴 APPLY：将热更线上云函数' : '🟡 DRY-RUN：只对比，不写入');

  for (const t of TARGETS) {
    const code = readFileSync(resolve(root, t.file), 'utf8');
    console.log(`\n=== ${t.name} (${t.id ?? '待新建'}) ===`);
    console.log(`  本地源码：${t.file}，${code.length} 字符，v${t.version}`);

    /* 新建分支：线上还没有这条 Function 记录 */
    if (t.create) {
      let existing = null;
      try {
        existing = await findByName(t.name);
      } catch (e) {
        console.log(`  ⚠️ 按名查询失败：${e.message}`);
      }
      if (!existing) {
        console.log('  → 线上不存在，将新建');
        if (!APPLY) {
          console.log('  → 加 --apply 才会真正新建');
          continue;
        }
        const id = await createRemote(t.name, code, t.version);
        console.log(`  ✅ 已新建，objectId = ${id}`);
        console.log(`  🔴 请把它写进 src/app/core/api/parse-api.ts 的 FN 常量`);
        continue;
      }
      t.id = existing.objectId;
      console.log(`  → 线上已存在，objectId = ${t.id}，转为更新`);
    }

    let remote;
    try {
      remote = await getRemote(t.id);
    } catch (e) {
      console.log(`  ⚠️ 读取线上失败：${e.message}（跳过对比）`);
      remote = null;
    }
    if (remote) {
      const rc = remote.code || '';
      console.log(`  线上源码：${rc.length} 字符，v${remote.version ?? '?'}`);
      if (rc === code) {
        console.log('  ✅ 与线上完全一致，无需部署');
        continue;
      }
      if (rc.length && code.length < rc.length * 0.7) {
        console.log('  🔴 警告：本地源码明显小于线上，可能回退功能，已跳过');
        continue;
      }
    }

    if (!APPLY) {
      console.log('  → 加 --apply 才会真正热更');
      continue;
    }

    const r = await putRemote(t.id, { code, version: t.version, enabled: true });
    console.log(`  ✅ 已热更：${JSON.stringify(r).slice(0, 120)}（免重启，立即生效）`);
  }
}

main().catch((e) => {
  console.error('❌ 执行失败：', e.message);
  process.exit(1);
});