xiaoshu-app/scripts/migrate-word-audio.mjs

#!/usr/bin/env node
import { readFileSync } from 'node:fs';
import { randomBytes } from 'node:crypto';
import { request as httpsRequest } from 'node:https';
const sql=readFileSync(new URL('./sql/word-audio.sql',import.meta.url),'utf8');
if(!process.argv.includes('--apply')) {
  console.log('只读检查：单词读音缓存迁移已就绪。--apply 创建服务端缓存与用量表，不生成音频。');
  process.exit(0);
}
const master=process.env.XIAOSHU_MASTER_KEY;
if(!master)throw new Error('缺少 XIAOSHU_MASTER_KEY');
const parseUrl=(process.env.XIAOSHU_PARSE_URL||'https://server.xiaoshu.pro/parse').replace(/\/$/,'');
const appId=process.env.XIAOSHU_PARSE_APP_ID||'7pIbDBJmKx_main';
async function request(path,options={}) {
  const res=await fetch(parseUrl+path,{...options,headers:{'Content-Type':'application/json','X-Parse-Application-Id':appId,'X-Parse-Master-Key':master}});
  const data=await res.json();if(!res.ok||data.error)throw new Error(data.error||data.message||data.retmsg||`HTTP ${res.status}`);return data;
}
function invokeMigration(url,token) {
  return new Promise((resolve,reject)=>{const body=JSON.stringify({token,params:{}}),req=httpsRequest(url,{method:'POST',headers:{'Content-Type':'application/json','Content-Length':Buffer.byteLength(body)}},(res)=>{let raw='';res.setEncoding('utf8');res.on('data',(chunk)=>raw+=chunk);res.on('end',()=>{try{resolve({ok:Number(res.statusCode)>=200&&Number(res.statusCode)<300,data:JSON.parse(raw)})}catch(error){reject(error)}});});req.on('error',reject);req.write(body);req.end();});
}
// Register additive Parse fields before SQL, so schema metadata and physical columns agree.
const knownSchemas=(await request('/schemas')).results||[];
const permissions={find:{},count:{},get:{},create:{},update:{},delete:{},addField:{}};
for(const [name,fields] of Object.entries({
 WordAudioCache:{company:{type:'String'},word:{type:'String'},phonetic:{type:'String'},voice:{type:'String'},status:{type:'String'},url:{type:'String'},audio:{type:'String'},lease:{type:'String'},leaseUntil:{type:'Date'},retryAfter:{type:'Date'},lastError:{type:'String'}},
 WordAudioAttempt:{company:{type:'String'},actor:{type:'String'},cacheId:{type:'String'},providerCall:{type:'Boolean'},status:{type:'String'}},
})){
 const schema=knownSchemas.find(row=>row.className===name);
 const missing=Object.fromEntries(Object.entries(fields).filter(([key])=>!schema?.fields?.[key]));
 await request(schema?'/schemas/'+name:'/schemas',{method:schema?'PUT':'POST',body:JSON.stringify({...(schema?{}:{className:name}),fields:missing,classLevelPermissions:permissions})});
}
const company=(await request('/classes/Company?limit=1&keys=objectId')).results?.[0];
if(!company)throw new Error('未找到帐套');
const suffix=Date.now()+'_'+randomBytes(5).toString('hex'),path='xiaoshu/system/word-audio-'+suffix;
let userId='',functionId='';
try {
  const sessions=await request('/classes/_Session?include=user&limit=200&order=-updatedAt');
  const selected=sessions.results.find(s=>s.sessionToken&&s.user?.isAdmin&&!s.user?.isDisabled&&new Date(s.expiresAt.iso)>new Date());
  if(!selected)throw new Error('没有可用管理员会话');
  const account={objectId:selected.user.objectId,sessionToken:selected.sessionToken};const authorizedId=account.objectId;
  const code=`async function handler(request,response){try{const current=request.user;if(!current)return response.status(401).json({success:false});await current.fetch({useMasterKey:true});if(Date.now()>${Date.now()+600000}||current.id!==${JSON.stringify(authorizedId)})return response.status(403).json({success:false});await Psql.tx(async tx=>{await tx.none("SET LOCAL lock_timeout = '5s'");await tx.none(${JSON.stringify(sql)});});const counts=await Psql.query('SELECT COUNT(*)::int AS cached FROM "WordAudioCache"');return response.json({success:true,counts});}catch(error){return response.status(500).json({success:false,message:String(error.message||error)});}}`;
  const fn=await request('/classes/Function',{method:'POST',body:JSON.stringify({name:path,path,code,type:'standalone',desc:'单词读音缓存一次性数据库迁移',enabled:true,params:[],paramList:[],respType:'json'})});functionId=fn.objectId;
  const res=await invokeMigration(parseUrl.replace(/\/parse$/,'/api/functions/')+path,account.sessionToken);
  if(!res.ok||!res.data.success)throw new Error(res.data.message||'迁移失败');console.log(JSON.stringify(res.data,null,2));
} finally {
  // Cleanup failures are reported, including IDs, so no temporary privileged surface is silently left behind.
  const failures=[];
  if(functionId)try{await request('/classes/Function/'+functionId,{method:'DELETE'});}catch{failures.push('临时函数 '+functionId);}
  if(userId)try{await request('/users/'+userId,{method:'DELETE'});}catch{failures.push('临时管理员 '+userId);}
  if(failures.length)throw new Error('需要清理：'+failures.join('、'));
}