// Independent, read-only acceptance of the saved S2. Never calls save/start/import.
import fs from 'node:fs';
import crypto from 'node:crypto';
import assert from 'node:assert/strict';
import {invoke,classRows} from '../server/scripts/platform-client.mjs';
import {loadPublicBoard} from '../src/services/workshop-data.js';

const sessionId='btrFqkz0yw',artifactId='b7NOby5ys0',outputSourceId='wPbc3huKIM',s1Id='G8IrkkDG7X';
const outputFile='work/live-S2-readback-20261102.json';
const templateBytes=fs.readFileSync('work/first-live-S2-template.json'),template=JSON.parse(templateBytes);
const s1Template=JSON.parse(fs.readFileSync('work/first-live-S1-v2-template.json','utf8'));
const imported=JSON.parse(fs.readFileSync('work/consumer-quotes-readback-20261102-complete.json','utf8')).imports;
const requestId=template.taskKey+':save:v1';
const sha=x=>crypto.createHash('sha256').update(x).digest('hex');
const canonical=x=>x&&typeof x==='object'?Array.isArray(x)?'['+x.map(canonical).join(',')+']':'{'+Object.keys(x).sort().map(k=>JSON.stringify(k)+':'+canonical(x[k])).join(',')+'}':JSON.stringify(x);
const pointer=(className,objectId)=>({__type:'Pointer',className,objectId});
const read=async(className,objectId)=>{
 const r=await invoke('ksfGetRecord',{className,objectId});
 assert.equal(r.http,200);assert.equal(r.body?.result?.ok,true);const record=r.body.result.data.record;
 assert.equal(record?.objectId,objectId);return record;
};
assert.equal(fs.existsSync(outputFile),false,'Preserve earlier acceptance');
let check='local template fingerprint';
try{
 const packaged=JSON.parse(fs.readFileSync('work/first-live-S2-package-receipt.json','utf8'));
 assert.equal(sha(templateBytes),packaged.templateSha256);assert.equal(template.sessionId,null);
 check='read saved records and history';
 const results=await Promise.allSettled([
  read('KfSession',sessionId),read('KfArtifact',artifactId),read('KfArtifact',s1Id),read('KfSource',outputSourceId),
  Promise.all(imported.map(r=>read('KfSource',r.sourceId))),
  Promise.all(imported.map(r=>read('KfEvidence',r.evidenceId))),
  classRows('KfArtifact',{workshopKey:'KSF-真实资料-20261102-01'}),
  classRows('KsfOperation',{operation:'workshop-task',requestId}),
  classRows('KfOpportunity',{sessionRef:pointer('KfSession',sessionId)}),
  classRows('KfProject',{sessionRef:pointer('KfSession',sessionId)}),
 ]);
 assert.deepEqual(results.flatMap((r,i)=>r.status==='rejected'?[i]:[]),[],'Read group failure, indexes only');
 const [session,artifact,s1,generated,origins,evidence,history,operations,opportunities,projects]=results.map(r=>r.value);
 check='saved S2 matches template';
 for(const field of ['title','rawText','version','stageCode','artifactType'])assert.deepEqual(artifact[field],template[field],field);
 assert.equal(artifact.reportSeriesKey,template.taskKey);assert.equal(artifact.reportType,'workshop_auxiliary');
 assert.equal(artifact.dashboardState,'workshop');assert.equal(artifact.dataMode,'live');assert.equal(artifact.recordState,'active');
 assert.equal(artifact.ownerSession,sessionId);assert.deepEqual(artifact.sessionRef,pointer('KfSession',sessionId));
 assert.deepEqual(artifact.sourceRef,pointer('KfSource',outputSourceId));assert.equal(artifact.projectRef??null,null);
 assert.equal(artifact.previousVersionRef??null,null);assert.equal(artifact.reportContentHash,sha(canonical(template.report)));
 assert.equal(artifact.report.title,template.title);assert.ok(Number.isFinite(Date.parse(artifact.report.generatedAt)));
 assert.equal(artifact.report.executive[0],'课堂过程成果，未经员工正式确认；待验证项不作为市场结论。');
 assert.deepEqual(artifact.report.executive.slice(1),template.report.executive);
 for(const field of ['chapters','evidence','subtitle','method','sources'])assert.deepEqual(artifact.report[field],template.report[field],field);
 assert.deepEqual(artifact.meta.workshop.sourceIds,template.sourceIds);assert.deepEqual(artifact.meta.workshop.pendingQuestions,template.pendingQuestions);
 assert.equal(artifact.meta.workshop.formalConfirmation,false);assert.equal(artifact.contentConfirmedAt??null,null);assert.equal(artifact.dashboardPublishedAt??null,null);
 assert.equal(generated.rawText,template.rawText);assert.equal(generated.contentHash,sha(template.rawText));assert.equal(generated.dataMode,'live');
 check='live original sources and exact quotes';
 let quoteCount=0;
 for(const [key,entry]of Object.entries(template.report.evidence)){
  const ids=imported.find(x=>key==='consumer-'+x.key);assert.ok(ids);assert.equal(entry.sourceId,ids.sourceId);
  const origin=origins.find(x=>x.objectId===entry.sourceId),quoteRecord=evidence.find(x=>x.objectId===ids.evidenceId);
  assert.ok(origin);assert.ok(quoteRecord);assert.equal(origin.dataMode,'live');assert.equal(origin.sourceKind,'social');assert.equal(origin.platform,'smzdm');
  assert.equal(sha(origin.rawText),origin.contentHash);assert.equal(quoteRecord.sourceRef?.objectId,origin.objectId);
  assert.equal(quoteRecord.evidenceKind,'public_user_experience_self_report');assert.equal(quoteRecord.productRef??null,null);
  assert.equal(quoteRecord.publishedAt??null,null);assert.equal(quoteRecord.locator.publicationTimezone,'unknown');
  assert.equal(entry.quotes.length,1);assert.equal(entry.quotes[0].text,quoteRecord.quote);
  for(const quote of entry.quotes){assert.ok(origin.rawText.includes(quote.text));quoteCount++;}
 }
 assert.equal(quoteCount,4);assert.equal(artifact.sources.length,4);assert.equal(artifact.evidenceCount,4);
 check='session, identity, original S1 and operation';
 assert.equal(session.dataMode,'live');assert.equal(session.stageCode,'S2');assert.equal(session.step,'submitted');
 assert.deepEqual(session.meta.attribution,artifact.meta.attribution);assert.deepEqual(s1.meta.attribution,artifact.meta.attribution);
 assert.equal(artifact.agentName,'王刚001');assert.equal(artifact.agentId,session.meta.attribution.agentKey);
 for(const field of ['title','rawText','version','stageCode'])assert.deepEqual(s1[field],s1Template[field]);
 assert.deepEqual(s1.report.chapters,s1Template.report.chapters);assert.deepEqual(s1.report.evidence,s1Template.report.evidence);
 assert.deepEqual(s1.meta.workshop.sourceIds,s1Template.sourceIds);
 const versions=history.filter(x=>x.reportSeriesKey===template.taskKey);
 assert.equal(versions.length,1);assert.equal(versions[0].objectId,artifactId);assert.equal(versions[0].version,1);
 assert.equal(history.length,3);assert.equal(operations.length,1);assert.equal(opportunities.length,0);assert.equal(projects.length,0);
 assert.equal(operations[0].payloadHash,sha(canonical({...template,sessionId,requestId})));
 assert.equal(operations[0].receipt.artifactId,artifactId);assert.equal(operations[0].receipt.sourceId,outputSourceId);
 assert.equal(operations[0].receipt.opportunityId,null);assert.equal(operations[0].receipt.projectId,null);
 check='public board projection';
 const publicData=await loadPublicBoard({url:'https://kangshifu.fmode.cn/api/functions',appId:'FKieRbIoGt_main'});
 const projected=publicData.artifact.find(x=>x.objectId===artifactId);assert.ok(projected);
 assert.equal(projected.stageCode,'S2');assert.equal(projected.dataMode,'live');assert.equal(projected.dashboardState,'workshop');
 assert.deepEqual(projected.report.evidence,template.report.evidence);assert.deepEqual(projected.report.chapters,template.report.chapters);
 assert.ok(publicData.artifact.some(x=>x.objectId===s1Id));
 for(const value of [session.meta.attribution.participantAccount?.accountId,session.meta.attribution.agentAccount?.accountId,session.meta.attribution.conversationKey].filter(Boolean))assert.equal(JSON.stringify(publicData).includes(value),false);
 const result={ok:true,operation:'live-S2-independently-verified',at:new Date().toISOString(),readOnly:true,businessWrites:0,
  sessionId,artifactId,outputSourceId,reportUrl:'https://kangshifu.fmode.cn/report/'+artifactId,version:1,stageCode:'S2',dataMode:'live',
  dashboardState:'workshop',reportSeriesKey:template.taskKey,sourceIds:template.sourceIds,evidenceIds:imported.map(x=>x.evidenceId),
  reportQuoteCount:quoteCount,pendingQuestionCount:6,templateMatched:true,originalS1Preserved:true,originalS1ArtifactId:s1Id,
  privateAttributionMatched:true,sessionStage:'S2',operationCount:1,s2VersionCount:1,opportunityCount:0,projectCount:0,
  publicBoardDataVerified:true,formalReportPublished:false,employeeConfirmed:false,browserVerified:false};
 fs.writeFileSync(outputFile,JSON.stringify(result,null,2)+'\n',{flag:'wx'});console.log(JSON.stringify(result,null,2));
}catch(error){
 const result={ok:false,operation:'live-S2-independent-readback-stopped',check,
  checkLine:error.stack?.match(/verify-live-S2-readback\.mjs:(\d+):/)?.[1]??null,readOnly:true,businessWrites:0};
 fs.writeFileSync(outputFile,JSON.stringify(result,null,2)+'\n',{flag:'wx'});console.error(JSON.stringify(result,null,2));process.exitCode=1;
}