Skip to content
English

ExecutableTool ​

CORE · interface · 类型合同

One registered tool, typed by its input, output, host context and id literal.

导入 ​

ts
import type { ExecutableTool } from '@jangts/agent-core/types';
js
/** @typedef {import('@jangts/agent-core/types').ExecutableTool} ExecutableTool */

其他公开入口:@jangts/agent-core/types、@jangts/agent-core/structs。

定义 ​

ts
interface ExecutableTool<Input, Output, App, Id>

继承或实现: ModelTool<Input, ToolProposal, App>。

泛型参数 ​

类型参数约束默认类型
Input—unknown
Output—unknown
App—unknown
Idstringstring

字段结构 ​

字段类型必需说明
idId必需只读。Stable id; also the name the model calls.
kindstring必需只读。Declared grouping used by registries and documentation; not an authorization boundary.
descriptionstring必需只读。Model-visible explanation of when to call the tool.
inputSchemaSchemaAdapter<Input>必需只读。Schema applied to raw model arguments before authorize and execute.
authorize(input: Input, context: OperationContext<App>) => MaybePromise<void>必需Host permission check. Runs before execution and may be asynchronous.
execute(input: Input, context: OperationContext<App> & import("../debug.js").NodeReportingContext) => MaybePromise<Output>必需Executes the already-authorized input; must not repeat authorization decisions.
debugSteps((result: Output, context: import("../debug.js").NodeReportingContext) => void) | undefined可省略Optional result hook; writes through context.createSubFlowLogger() are recorded immediately.
parseOutput(value: unknown) => Output必需Validates untrusted output (for example a cached replay) before it is returned.
activeToolCondition<App> | undefined可省略只读。Omitted means active. Authorization remains a separate execution boundary.
asIntentAsIntent<App> | undefined可省略只读。Omitted means this tool is not advertised by withIntent().
resolve(input: Input, context: Readonly<{ stageId: string; }>) => ToolProposal必需Converts validated arguments into the value handed back to the caller. Runs inside the model call, so it must return synchronously; throwing rejects the selection.

成员目录 ​

成员用途
authorizeHost permission check. Runs before execution and may be asynchronous.
executeExecutes the already-authorized input; must not repeat authorization decisions.
parseOutputValidates untrusted output (for example a cached replay) before it is returned.
resolveConverts validated arguments into the value handed back to the caller. Runs inside the model call, so it must return synchronously; throwing rejects the selection.

成员详情 ​

authorize ​

Host permission check. Runs before execution and may be asynchronous.

ts
ExecutableTool.authorize(input: Input, context: OperationContext<App>): MaybePromise<void>

Host permission check. Runs before execution and may be asynchronous.

参数类型传递说明
inputInput必需—
contextOperationContext<App>必需—
context 的字段
字段类型必需说明
appunknown extends App ? App : Readonly<App>必需只读。见类型定义及调用场景。
loggerSubFlowLog | undefined可省略只读。Explicit optional recorder for this operation; never inferred from diagnostics.
signalAbortSignal必需只读。Non-optional cancellation signal; never undefined once execution has started.
diagnosticsDiagnosticContext | undefined可省略只读。Diagnostic scope of the enclosing call, when recording is enabled.

返回: MaybePromise<void>。

等待后的值: void。

execute ​

Executes the already-authorized input; must not repeat authorization decisions.

ts
ExecutableTool.execute(input: Input, context: OperationContext<App> & import("../debug.js").NodeReportingContext): MaybePromise<Output>

Executes the already-authorized input; must not repeat authorization decisions.

参数类型传递说明
inputInput必需—
contextOperationContext<App> & NodeReportingContext必需—
context 的字段
字段类型必需说明
appunknown extends App ? App : Readonly<App>必需只读。见类型定义及调用场景。
loggerSubFlowLog | undefined可省略只读。Explicit optional recorder for this operation; never inferred from diagnostics.
signalAbortSignal必需只读。Non-optional cancellation signal; never undefined once execution has started.
diagnosticsDiagnosticContext | undefined可省略只读。Diagnostic scope of the enclosing call, when recording is enabled.
report(update: import("./execution/workflow.js").WorkflowNodeReport) => void必需Reports progress for the active node; Core supplies the execution identity.
createSubFlowLogger() => SubFlowLogger必需Bound to this context and owned by runtime; repeated calls in one visit return the same instance.

返回: MaybePromise<Output>。

等待后的值: Awaited<Output>。

parseOutput ​

Validates untrusted output (for example a cached replay) before it is returned.

ts
ExecutableTool.parseOutput(value: unknown): Output

Validates untrusted output (for example a cached replay) before it is returned.

参数类型传递说明
valueunknown必需—

返回: Output。

等待后的值: Awaited<Output>。

resolve ​

Converts validated arguments into the value handed back to the caller.

Runs inside the model call, so it must return synchronously; throwing rejects the selection.

ts
ExecutableTool.resolve(input: Input, context: Readonly<{ stageId: string; }>): ToolProposal

Converts validated arguments into the value handed back to the caller.

Runs inside the model call, so it must return synchronously; throwing rejects the selection.

参数类型传递说明
inputInput必需—
contextReadonly<{ stageId: string; }>必需—
context 的字段
字段类型必需说明
stageIdstring必需见类型定义及调用场景。

返回: ToolProposal。

返回值结构
字段类型必需说明
toolIdstring必需只读。见类型定义及调用场景。
inputunknown必需只读。见类型定义及调用场景。

使用示例 ​

最小本地只读工具 ​

入门 · Node.js

ts
import { ToolRegistry } from '@jangts/agent-core/tools';
const tools = new ToolRegistry().register({
  id: 'get_status', kind: 'read', description: '读取演示服务状态',
  parseInput(value: unknown) { if (!value || typeof value !== 'object' || Array.isArray(value)) throw new TypeError('需要对象'); return {}; },
  execute: () => '服务运行正常',
  parseOutput(value: unknown) { if (typeof value !== 'string') throw new TypeError('需要文本'); return value; },
}).seal();
const result = tools.invoke({ toolId: 'get_status', input: {} });
console.log(result.value, result.invocation.invocationId);
js
import { ToolRegistry } from '@jangts/agent-core/tools';
const tools = new ToolRegistry().register({
    id: 'get_status', kind: 'read', description: '读取演示服务状态',
    parseInput(value) { if (!value || typeof value !== 'object' || Array.isArray(value))
        throw new TypeError('需要对象'); return {}; },
    execute: () => '服务运行正常',
    parseOutput(value) { if (typeof value !== 'string')
        throw new TypeError('需要文本'); return value; },
}).seal();
const result = tools.invoke({ toolId: 'get_status', input: {} });
console.log(result.value, result.invocation.invocationId);

提前绑定,节点不再重复注入工具 ​

配置 · Node.js

第一个示例严格校验外部输入;第二个仅展示绑定关系,真实业务应使用相应 Schema 与授权。

ts
import { AgentCoreEngine, defineWorkflow, route } from '@jangts/agent-core/engine';
import { ToolRegistry } from '@jangts/agent-core/tools';
type State = { answer?: unknown };
const tools = new ToolRegistry().register({ id: 'get_status', kind: 'read',
  parseInput: () => ({}), execute: async () => '服务运行正常', parseOutput: value => value,
}).seal();
const workflow = defineWorkflow<State, unknown>({ id: 'status', nodes: [{
  id: 'read', description: '读取状态', startsRound: true,
  async run(_state, { tools }) { const { value } = await tools.invoke({ toolId: 'get_status', input: {} }); return { answer: value }; },
  routes: [route.deliver('answer')],
}] });
const agent = new AgentCoreEngine({ workflow }).bindToolRuntime(tools);
console.log(await agent.run({}));
js
import { AgentCoreEngine, defineWorkflow, route } from '@jangts/agent-core/engine';
import { ToolRegistry } from '@jangts/agent-core/tools';
const tools = new ToolRegistry().register({ id: 'get_status', kind: 'read',
    parseInput: () => ({}), execute: async () => '服务运行正常', parseOutput: value => value,
}).seal();
const workflow = defineWorkflow({ id: 'status', nodes: [{
            id: 'read', description: '读取状态', startsRound: true,
            async run(_state, { tools }) { const { value } = await tools.invoke({ toolId: 'get_status', input: {} }); return { answer: value }; },
            routes: [route.deliver('answer')],
        }] });
const agent = new AgentCoreEngine({ workflow }).bindToolRuntime(tools);
console.log(await agent.run({}));

相关策略源码 ​

相关定义 ​

接口参考、使用示例与开发指南。