kangshifu-board/scripts/accept-workshop-retest.mjs

// Independent-case outputs exercise current application handlers in memory only.
import fs from 'node:fs';
import path from 'node:path';
import os from 'node:os';
import crypto from 'node:crypto';
import assert from 'node:assert/strict';
import {fileURLToPath} from 'node:url';
import {createApplication} from '../server/src/core.mjs';
import {attachWorkshopHandlers} from '../server/src/workshop.mjs';
import {runWorkshop} from '../skills/ksf-workshop-runtime/scripts/ksf-workshop.mjs';
import {registerAgentProfile,registerParticipantProfile,readAgentProfileByKey,readParticipantProfile} from '../skills/ksf-workshop-runtime/scripts/ksf-identity.mjs';

const root=path.resolve(path.dirname(fileURLToPath(import.meta.url)),'..');
const work=path.join(root,'docs/workshop-skill-retest-20261109-r2');
const read=p=>JSON.parse(fs.readFileSync(p,'utf8').replace(/^\uFEFF/,''));
const data=read(path.join(root,'server/references/runtime-data.json'));
const sectionText=s=>s.kind==='table'?[s.title,s.data.cols.join(' | '),...s.data.rows.map(r=>r.join(' | '))].join('\n'):s.title+'\n'+s.text;
function memory(){
 let db={},seq=0,writes=0;
 return {
  get writes(){return writes;},
  async transaction(fn){const before=structuredClone(db),count=writes;try{return await fn(this);}catch(e){db=before;writes=count;throw e;}},async lock(){},
  async get(n,id){return structuredClone(db[n]?.find(r=>r.objectId===id)||null);},
  async list(n,{where={},afterId,limit=200,search}={}){return structuredClone((db[n]||[]).filter(r=>Object.entries(where).every(([k,v])=>JSON.stringify(r[k]??null)===JSON.stringify(v))).filter(r=>!search||JSON.stringify(r).includes(search)).filter(r=>!afterId||r.objectId>afterId).sort((a,b)=>a.objectId.localeCompare(b.objectId)).slice(0,limit));},
  async create(n,p){for(const k of Object.keys(p))assert.ok(data.tables[n]?.[k],n+'.'+k);const r={...structuredClone(p),objectId:'retest'+String(++seq).padStart(8,'0'),createdAt:new Date().toISOString(),updatedAt:new Date().toISOString()};(db[n]??=[]).push(r);writes++;return structuredClone(r);},
  async update(n,id,p){for(const k of Object.keys(p))assert.ok(data.tables[n]?.[k],n+'.'+k);const r=db[n]?.find(r=>r.objectId===id);assert.ok(r);Object.assign(r,structuredClone(p));writes++;return structuredClone(r);}
 };
}
function preflight(m){
 assert.ok(m.id&&m.stage&&m.type&&m.finding&&m.meaning&&m.reply&&m.next,m.id+' module contract');
 assert.ok(typeof m.reply==='string'&&Array.isArray(m.usedRecordIds),m.id+' reply/provenance contract');
 assert.ok(Array.isArray(m.sections)&&m.sections.length,m.id+' full sections');
 for(const s of m.sections){
  assert.ok(s.title,m.id+' section title');
  if(s.kind==='table'){
   assert.ok(s.data?.cols?.length&&Array.isArray(s.data.rows));
   for(const row of s.data.rows){assert.equal(row.length,s.data.cols.length,m.id+' rectangular table');assert.ok(row.every(c=>typeof c==='string'),m.id+' string cells');}
  }else assert.ok(['para','longpara'].includes(s.kind)&&typeof s.text==='string'&&s.text.trim());
 }
}
const table=(title,cols,rows)=>({kind:'table',title,data:{cols,rows:rows.map(r=>r.map(String))}});
const para=(title,text)=>({kind:'para',title,text});

export async function acceptRetest(){
 const draft=read(path.join(work,'independent-run/case-draft.json'));
 const fixture=read(path.join(work,'inputs/raw-materials.json'));
 const modules=draft.modules,checks=[],outputs=[],cardLinks=[],cardOutputs=[],supplementalOutputs=[],events=[];
 const expected=['D1-01','D1-02','D1-03','D1-04','D1-N','D2-01','D2-02','D2-03','D2-04','D2-05','D2-06','D2-07','D2-08'];
 assert.deepEqual(modules.map(m=>m.id),expected);
 const stages=['S1','S1','S1','S1','S2','S2','S2','S3','S3','S4','S4','S5','S5'];
 assert.deepEqual(modules.map(m=>m.stage),stages);
 const verify=(label,value)=>{assert.ok(value,label);checks.push(label);};
 const sourceRecords=[...fixture.products.map(p=>({...p,text:p.title,platform:'product-fixture'})),...fixture.reviews,...fixture.social];
 const byId=Object.fromEntries(sourceRecords.map(r=>[r.id,r]));
 modules.forEach(preflight);verify('13环节顺序、阶段与完整内容结构有效',true);
 const temp=fs.mkdtempSync(path.join(os.tmpdir(),'ksf-retest-case-'));
 const opts={profileDir:path.join(temp,'agents'),participantDir:path.join(temp,'people')};
 const agent=readAgentProfileByKey(registerAgentProfile({name:'本地独立案例执行者',role:'workshop',identityBasis:'operator_registration',runtimePlatform:'local-test',channel:'local-test',account:{platform:'local-test',accountId:'retest-agent'}},opts).profile.key,opts.profileDir);
 const person=readParticipantProfile(registerParticipantProfile({name:'本地案例学员',identityBasis:'participant_registration',account:{platform:'local-test'}},opts).profile.key,opts.participantDir);
 const store=memory(),app=createApplication({store,crypto,Parse:{},data,settings:{signingSecret:'local-retest-only'},files:{}});attachWorkshopHandlers(app,{store,data});
 const actor={id:'local-retest-only-service',kind:'service',scopes:['ingest:write','data:read','source:write'],projectIds:['*']};
 let seq=0,networkAttempts=0;
 const run=async(command,input,requestId='retest:'+String(++seq))=>{events.push({command,requestId});return runWorkshop(command,structuredClone(input),{requestId,agentProfile:agent,participantProfile:person,call:async(n,p)=>(await app.dispatch(n,structuredClone(p),actor)).data});};
 const oldFetch=globalThis.fetch;globalThis.fetch=()=>{networkAttempts++;throw Error('RETEST_NETWORK_FORBIDDEN');};
 try{
  const raw=JSON.stringify(fixture,null,2);
  const imported=await run('workshop-import',{source:{title:'独立复测构造题干；非真实研究资料',sourceKind:'dataset',dataMode:'sample',rawText:raw},records:Object.values(byId).map(r=>({itemKey:r.id,className:'KfEvidence',externalKey:'retest:input:'+r.id,data:{dataMode:'sample',quote:r.text,evidenceKind:'synthetic_test_only',quoteForm:'verbatim_excerpt',verificationState:'synthetic_only',platform:r.platform,locator:{fixture:'raw-materials.json',recordId:r.id}}}))});
  verify('6条商品及17条原始文字逐条桥接，保留重复/占位原件',imported.items.length===23);
  for(const item of imported.items){const r=await run('workshop-read',{className:item.className,objectId:item.objectId});verify('逐字回读 '+item.itemKey,r.record.quote===byId[item.itemKey].text);}
  const session=await run('workshop-start',{workshopKey:'independent-retest-r2',participant:{profileKey:person.key},conversation:{key:'retest-conversation',channel:'local-test'},dataMode:'sample'});
  const inputFor=m=>{
   const used=m.usedRecordIds||[];
   for(const id of used)assert.ok(byId[id],m.id+' unknown source '+id);
   const evidence=Object.fromEntries([...new Set(used)].map(id=>['ev_'+id,{sourceId:imported.sourceId,claim:'构造题干 '+id+'；不能当真实消费者证据',quotes:[{text:byId[id].text,ref:id}]}]));
   return {sessionId:session.sessionId,taskKey:'retest:'+m.id,version:1,stageCode:m.stage,title:'本地独立复测／'+m.id+'／'+m.title,artifactType:m.type,category:'拌面',sourceIds:[imported.sourceId],pendingQuestions:(draft.unresolved||[]).map(x=>typeof x==='string'?x:JSON.stringify(x)),rawText:[draft.notice,m.finding,m.meaning,...m.sections.map(sectionText),m.next].join('\n\n'),report:{executive:[m.finding,m.meaning,m.next],chapters:[{id:m.id.toLowerCase(),title:m.title,stage:m.stage,sections:m.sections}],evidence}};
  };
  let firstInput;
  for(const original of modules){
   const m=structuredClone(original);
   if(m.id==='D2-04'){
    assert.ok(draft.candidates.length>=2,'case has alternatives');
    for(const c of draft.candidates){
     const sections=c.reportSections||[table('候选详情',['字段','内容'],Object.entries(c).filter(([k])=>k!=='reportSections').map(([k,v])=>[k,typeof v==='string'?v:JSON.stringify(v)]))];
     const one={id:'card-'+c.key,stage:'S3',type:'opportunity_card',title:c.title,finding:c.benefitHypothesis||c.title,meaning:c.task||c.title,reply:c.title,next:typeof c.decisiveTest==='string'?c.decisiveTest:JSON.stringify(c.decisiveTest),sections,usedRecordIds:[...new Set([...(c.supportRecordIds||[]),...(c.counterRecordIds||[])])]};
     preflight(one);const p=inputFor(one);p.opportunity={key:'retest:'+c.key,title:c.title,demandSummary:one.finding,targetAudience:'依题干自述，规模和画像待核',usageScenario:one.meaning,fusionDefinition:'依本候选独立正文'};
     const saved=await run('workshop-save',p),a=await run('workshop-read',{className:'KfArtifact',objectId:saved.artifactId}),o=await run('workshop-read',{className:'KfOpportunity',objectId:saved.opportunityId});
     assert.deepEqual(a.record.report.chapters,p.report.chapters);verify(c.key+' 独立卡正文与关联精确回读',o.record.linkedArtifacts.includes(saved.artifactId));
     cardLinks.push({key:c.key,title:c.title,artifactId:saved.artifactId,opportunityId:saved.opportunityId,version:1});
     cardOutputs.push({...one,artifactId:saved.artifactId,automaticSourceId:saved.sourceId,report:a.record.report,rawText:a.record.rawText});
    }
   }
   if(m.supplementalReports?.length){
    const linked=[];
    for(const [index,sup] of m.supplementalReports.entries()){
     const first=sup.sections.find(s=>s.kind==='para'||s.kind==='longpara');
     const one={...sup,id:m.id+'-supp-'+String(index+1),finding:first?.text||sup.title,meaning:'本节独立核心产出；完整正文见各章节',reply:'本地研究草稿的独立配套报告，后续状态按实际回读核实。',next:m.next,usedRecordIds:sup.usedRecordIds||m.usedRecordIds};
     preflight(one);const p=inputFor(one),saved=await run('workshop-save',p),r=await run('workshop-read',{className:'KfArtifact',objectId:saved.artifactId});
     assert.deepEqual(r.record.report.chapters,p.report.chapters);assert.equal(r.record.rawText,p.rawText);
     verify(m.id+' 配套核心报告 '+String(index+1)+' 全文保存回读',r.record.artifactType===sup.type&&r.record.dataMode==='sample');
     const out={...one,moduleId:m.id,artifactId:saved.artifactId,automaticSourceId:saved.sourceId,report:r.record.report,rawText:r.record.rawText};
     linked.push(out);supplementalOutputs.push(out);
    }
    m.supplementalReports=linked;
    m.sections.push(table('独立配套成果实际本地编号',['成果','类型','报告编号','版本'],linked.map(s=>[s.title,s.type,s.artifactId,'1'])));
   }
   if(['D2-04','D2-05','D2-06','D2-08'].includes(m.id))m.sections.push(table('候选实际本地编号',['稳定键','机会编号','报告编号','版本'],cardLinks.map(c=>[c.key,c.opportunityId,c.artifactId,c.version])));
   if(m.id==='D2-08')m.sections.push(table('已保存环节导航',['环节','报告编号','版本'],outputs.map(o=>[o.id,o.artifactId,'1'])));
   const p=inputFor(m);firstInput??=structuredClone(p);
   const saved=await run('workshop-save',p,'retest:save:'+m.id),r=await run('workshop-read',{className:'KfArtifact',objectId:saved.artifactId});
   assert.deepEqual(r.record.report.chapters,p.report.chapters);assert.equal(r.record.rawText,p.rawText);
   verify(m.id+' 全部正文和表格精确回读',r.record.stageCode===m.stage&&r.record.version===1);
   verify(m.id+' 样例/未确认状态保留',r.record.dataMode==='sample'&&!saved.formalReportPublished&&!saved.employeeConfirmed);
   outputs.push({...m,artifactId:saved.artifactId,automaticSourceId:saved.sourceId,report:r.record.report,rawText:r.record.rawText});
  }
  const repeated=await run('workshop-save',firstInput,'retest:save:D1-01');verify('重放相同请求不重复建报告',repeated.artifactId===outputs[0].artifactId);
  const board=(await app.dispatch('ksfGetPublicBoard',{limit:500},null)).data;
  verify('每份报告、配套成果与候选在本地公开投影可见',[...outputs,...supplementalOutputs].every(o=>board.artifact.some(a=>a.objectId===o.artifactId))&&cardLinks.every(c=>board.opportunity.some(o=>o.objectId===c.opportunityId)));
  verify('单节多种核心成果分别保存且有真实编号导航',supplementalOutputs.length===3&&new Set([...outputs,...supplementalOutputs].map(o=>o.artifactId)).size===16);
  const unique=[...new Map(fixture.reviews.map(r=>[r.upstreamId,r])).values()];
  verify('原材料独立复算：15电商原件→14唯一→13非占位→12可讨论食用体验',fixture.reviews.length===15&&unique.length===14&&unique.filter(r=>r.id!=='E11').length===13&&unique.filter(r=>!['E10','E11'].includes(r.id)).length===12);
  const cond=fixture.scenarioConditions;
  const allowed=cond.netRevenuePerServing*(1-cond.minimumGrossMargin);
  verify('成本边界独立复算2.73元；新增成本上限0.23元',Math.abs(allowed-2.73)<1e-12&&Math.abs(allowed-cond.baseUnitCost-.23)<1e-12);
  verify('无外部网络调用',networkAttempts===0);
  const result={schema:'ksf.independent-case-local-acceptance.v1',checkedAt:new Date().toISOString(),ok:true,checksPassed:checks.length,checks,researchModules:13,candidates:cardLinks.length,supplementalReports:supplementalOutputs.length,independentAgentRun:true,caseType:'synthetic scenario, current Skill applied by separate context agent',parentEditedCaseOutput:false,localMemoryWrites:store.writes,productionDatabaseWrites:0,networkCalls:networkAttempts,paidCalls:0,candidateDeployed:false,formalReportSubmitted:false};
  fs.writeFileSync(path.join(work,'interface-acceptance.json'),JSON.stringify(result,null,2)+'\n');
  fs.writeFileSync(path.join(work,'sample-outputs.json'),JSON.stringify({notice:draft.notice,fixture,outputs,supplementalOutputs,cardOutputs,candidates:draft.candidates,cardLinks,finalRecommendation:draft.finalRecommendation,unresolved:draft.unresolved},null,2)+'\n');
  fs.writeFileSync(path.join(work,'local-board.json'),JSON.stringify(board,null,2)+'\n');
  fs.writeFileSync(path.join(work,'interface-events.json'),JSON.stringify(events,null,2)+'\n');
  return result;
 }finally{
  globalThis.fetch=oldFetch;
  const absolute=fs.realpathSync(temp);assert.ok(absolute.startsWith(fs.realpathSync(os.tmpdir())+path.sep)&&path.basename(absolute).startsWith('ksf-retest-case-'));fs.rmSync(absolute,{recursive:true});
 }
}
if(process.argv[1]&&path.resolve(process.argv[1])===fileURLToPath(import.meta.url)){const r=await acceptRetest();console.log(JSON.stringify({ok:r.ok,modules:r.researchModules,candidates:r.candidates,checks:r.checksPassed,productionWrites:0}));}