Answering Flow：逐项生成、复核与局部修正
对已拆分的问题批次保留覆盖关系，修复失败项，不重新生成已经通过的项。
run({inputIds,items},context) 返回 AnswerResult[]。每个 item 包含 id、inputIds、data 和 sourceStatus；它们都由 App 在资料读取后决定。validateAnswerBatch 要求每个原始 inputId 至少被一个 item 覆盖，拒绝未知输入、重复任务 ID 和超限。
流程使用 App 的 generate、同步 check、可选异步 review、同步 fallback 与 canInvoke。maxItems、maxRepairs 显式配置；reviewPolicy 默认 optional，另可 required 或 off。canInvoke 只检查调用条件，真正模型调用仍须走 App 已绑定的 Runner 预算。generate 返回以 item.id 为键的 Map；返回外来 ID 会拒绝。
局部失败项才修复；已知复核失败不会因后续复核不可用而放行。最终状态为 accepted、fallback 或 blocked，fallback 的文字不是“已通过检查”的证据。来源 unavailable/conflict 不进入正常生成。Kit 内部使用 Workflow，不建立新的 Core 运行合同。
由简到繁的同业务示例
先处理一个有来源的说明问题
入门 · Node.js
离线示例直接使用已读正文，展示流程合同；换成模型生成时仍用同一个 generate 端口。
ts
import { Answering } from '@jangts/agent-core/kits/answering';
const flow = Answering.defineAnswerFlow<{ source: string }, string, {}>({
maxItems: 4, maxRepairs: 0, reviewPolicy: 'off', canInvoke: () => true,
async generate({ items }) { return new Map(items.map(item => [item.id, item.data.source])); },
check: ({ value }) => ({ status: value.trim() ? 'passed' : 'failed', issues: [] }),
fallback: () => ({ handled: false }),
});
const result = await flow.run({ inputIds: ['question-1'], items: [{ id: 'explain', inputIds: ['question-1'], sourceStatus: 'ready', data: { source: '普通对象可以实现节点合同。' } }] }, { app: {}, signal: new AbortController().signal });
console.log(result[0].status, result[0].value);js
import { Answering } from '@jangts/agent-core/kits/answering';
const flow = Answering.defineAnswerFlow({
maxItems: 4, maxRepairs: 0, reviewPolicy: 'off', canInvoke: () => true,
async generate({ items }) { return new Map(items.map(item => [item.id, item.data.source])); },
check: ({ value }) => ({ status: value.trim() ? 'passed' : 'failed', issues: [] }),
fallback: () => ({ handled: false }),
});
const result = await flow.run({ inputIds: ['question-1'], items: [{ id: 'explain', inputIds: ['question-1'], sourceStatus: 'ready', data: { source: '普通对象可以实现节点合同。' } }] }, { app: {}, signal: new AbortController().signal });
console.log(result[0].status, result[0].value);保持 run 不变，增加复核和一次局部修正
配置 · Node.js
示例以空草稿触发一次真实局部修正；生产 review 应依据真实证据，不用字符串等号代替语义复核。
ts
import { Answering } from '@jangts/agent-core/kits/answering';
const flow = Answering.defineAnswerFlow<{ source: string }, string, {}>({
maxItems: 4, maxRepairs: 1, reviewPolicy: 'required', canInvoke: () => true,
async generate({ items, repairs }) { return new Map(items.map(item => [item.id, repairs?.has(item.id) ? item.data.source : ''])); },
check: ({ value }) => ({ status: value.trim() ? 'passed' : 'failed', issues: value.trim() ? [] : [{ code: 'EMPTY', message: '需要非空回答' }] }),
async review({ items }) { return new Map(items.map(({ item, value }) => [item.id, { status: value === item.data.source ? 'passed' as const : 'failed' as const, issues: [] }])); },
fallback: () => ({ handled: true, value: '当前资料不足，暂时无法回答。' }),
});
const result = await flow.run({ inputIds: ['question-1'], items: [{ id: 'explain', inputIds: ['question-1'], sourceStatus: 'ready', data: { source: '普通对象可以实现节点合同。' } }] }, { app: {}, signal: new AbortController().signal });
console.log(result[0].status, result[0].checks);js
import { Answering } from '@jangts/agent-core/kits/answering';
const flow = Answering.defineAnswerFlow({
maxItems: 4, maxRepairs: 1, reviewPolicy: 'required', canInvoke: () => true,
async generate({ items, repairs }) { return new Map(items.map(item => [item.id, repairs?.has(item.id) ? item.data.source : ''])); },
check: ({ value }) => ({ status: value.trim() ? 'passed' : 'failed', issues: value.trim() ? [] : [{ code: 'EMPTY', message: '需要非空回答' }] }),
async review({ items }) { return new Map(items.map(({ item, value }) => [item.id, { status: value === item.data.source ? 'passed' : 'failed', issues: [] }])); },
fallback: () => ({ handled: true, value: '当前资料不足，暂时无法回答。' }),
});
const result = await flow.run({ inputIds: ['question-1'], items: [{ id: 'explain', inputIds: ['question-1'], sourceStatus: 'ready', data: { source: '普通对象可以实现节点合同。' } }] }, { app: {}, signal: new AbortController().signal });
console.log(result[0].status, result[0].checks);先验证多问题覆盖，防止遗漏输入
扩展 · Node.js
ts
import { Answering } from '@jangts/agent-core/kits/answering';
const items = [
{ id: 'define', inputIds: ['q1'], sourceStatus: 'ready' as const, data: { source: '定义节点' } },
{ id: 'run', inputIds: ['q2'], sourceStatus: 'unavailable' as const, data: { source: '' } },
];
Answering.validateAnswerBatch(['q1', 'q2'], items, 4);
console.log('两个问题均有明确处理项，包括资料不可用的项。');js
import { Answering } from '@jangts/agent-core/kits/answering';
const items = [
{ id: 'define', inputIds: ['q1'], sourceStatus: 'ready', data: { source: '定义节点' } },
{ id: 'run', inputIds: ['q2'], sourceStatus: 'unavailable', data: { source: '' } },
];
Answering.validateAnswerBatch(['q1', 'q2'], items, 4);
console.log('两个问题均有明确处理项，包括资料不可用的项。');