xiaoshu-app/scripts/audit-app-cloud-actions.mjs

#!/usr/bin/env node

import { readdir, readFile } from 'node:fs/promises';
import path from 'node:path';
import vm from 'node:vm';

const APP_ID = process.env.XIAOSHU_PARSE_APP_ID || '7pIbDBJmKx_main';
const FUNCTION_URL = (process.env.XIAOSHU_FUNCTION_URL || 'https://server.xiaoshu.pro/api/functions').replace(/\/$/, '');

async function walk(directory) {
  const files = [];
  for (const entry of await readdir(directory, { withFileTypes: true })) {
    const target = path.join(directory, entry.name);
    if (entry.isDirectory()) files.push(...await walk(target));
    else if (entry.name.endsWith('.ts') && !entry.name.endsWith('.spec.ts')) files.push(target);
  }
  return files;
}

const requested = new Set();
for (const file of await walk('projects/xiaoshu-mobile/src/app')) {
  const source = await readFile(file, 'utf8');
  for (const pattern of [
    /\b(?:this\.)?api\.(?:get|post)(?:<[^>]*>)?\(\s*['"]([^'"]+)['"]/g,
    /\b(?:saveAction|deleteAction|listAction|loadAction):\s*['"]([^'"]+)['"]/g,
    /['"](ranklist_[1-5])['"]/g,
    /['"](reading\/(?:me|query|get|create|update|ai|user\/update))['"]/g,
    /\b(?:this\.)?auth\.login\(\s*['"]([^'"]+)['"]/g,
  ]) for (const match of source.matchAll(pattern)) requested.add(match[1]);
}

const paritySource = await readFile('projects/xiaoshu-mobile/src/app/core/source-parity.generated.ts', 'utf8');
const parityMatch = paritySource.match(/export const SOURCE_API_ACTIONS = (\[[\s\S]*?\]) as const;/);
if (!parityMatch) throw new Error('无法读取 SOURCE_API_ACTIONS');
for (const action of JSON.parse(parityMatch[1])) requested.add(String(action));

let payload;
const local=process.argv.includes('--local');
if(local){
 const source=await readFile(new URL('./deploy-admin-functions.mjs',import.meta.url),'utf8');
 const code=source.match(/const appGatewayCode = String.raw`([\s\S]*?)\n`;/)?.[1];if(!code)throw Error('Cannot extract local gateway');
 const context=vm.createContext({console,process:{env:{}},Date});vm.runInContext(code+'\n'+await readFile(new URL('./cloud/mobile-teaching.js',import.meta.url),'utf8'),context);
 const response={json:body=>{payload=body;return response;},status:()=>response};
 await context.handler({body:{params:{action:'migration_status'}}},response);
 if(!payload?.result)throw Error('Local migration_status failed');
}else{
 const response=await fetch(`${FUNCTION_URL}/xiaoshu/app/gateway`,{method:'POST',headers:{'X-Parse-Application-Id':APP_ID,'Content-Type':'application/json'},body:JSON.stringify({params:{action:'migration_status'}}),signal:AbortSignal.timeout(20000)});
 payload=await response.json().catch(()=>({}));if(!response.ok||!payload.result)throw Error(`migration_status 请求失败：${response.status}`);
}
const implemented = new Set(Array.isArray(payload.result.implemented) ? payload.result.implemented.map(String) : []);
const blocked = new Set(Object.keys(payload.result.blocked || {}));
const covered = new Set([...implemented, ...blocked, ...(payload.result.disabledActions || [])]);
const missing = [...requested].filter((action) => !covered.has(action) && !action.startsWith('ops/')).sort();
const report = {
  source:local?'local-code':'online-gateway',
  passed: missing.length === 0,
  requested: requested.size,
  implemented: implemented.size,
  blocked: blocked.size,
  missing,
};
console.log(JSON.stringify(report, null, 2));
if (missing.length) process.exitCode = 1;