@kedge-agentic/workflow-nest

@kedge-agentic/workflow 的 NestJS 适配。

类型: NestJS 绑定 · 状态: public · v0.1.0

用途

把框架无关的 workflow 引擎接入 NestJS:

• WorkflowModule — factory provider, DI 接线
• @WorkflowTrigger 装饰器 + decorator-discovery bootstrap hook,声明式 trigger 注册
• TypeORM 持久化 — ObservationRecord / ObserverEventRecord repository (entity 来自 @kedge-agentic/observer-storage)
• OpenAiLlmGateway — 实现 LlmGateway port,供 LLM-driven handler 使用
• IndicatorRegistryService — per-session IndicatorDef[] 注册表; clearTenantSession 时清空

HTTP controller (event ingest / indicator ingest / session lifecycle) 住在宿主 backend (packages/platform/src/workflow-http/),因为要挂宿主 auth 的 @Auth(...) 装饰器。

Phase 8 (2026-05-31) 从 packages/platform/src/workflow/ 抽出。

主要导出

import {
  WorkflowModule,
  WorkflowEngineBootstrapAdapter,
  WorkflowTrigger,
  WORKFLOW_TRIGGER_METADATA,
} from '@kedge-agentic/workflow-nest'

// 便利再导出
import { WorkflowEngineService, WorkflowRegistry } from '@kedge-agentic/workflow-nest'

用法

@Module({
  imports: [
    WorkflowModule.forRoot({
      llmGateway: { /* OpenAI 配置 */ },
    }),
  ],
})
export class AppModule {}

@Injectable()
export class MyHandler implements OnApplicationBootstrap {
  @WorkflowTrigger(MY_TRIGGER_DEF)
  async handle(invocation: ToolInvocation): Promise<ToolResult> { ... }
}

依赖

• 运行时: @kedge-agentic/workflow, @kedge-agentic/ontology, @kedge-agentic/ontology-nest, @kedge-agentic/observer-storage
• Peer: @nestjs/common, @nestjs/core, @nestjs/config, @nestjs/swagger, @nestjs/typeorm, class-transformer, class-validator, reflect-metadata, typeorm, zod

关联包

• @kedge-agentic/workflow — 框架无关的引擎
• @kedge-agentic/workflow-client — solution backend 用的 HTTP 推送客户端
• @kedge-agentic/observer-storage — observation 的 TypeORM entity 类

构建 / 测试

npm run build:workflow-nest
npm test -w @kedge-agentic/workflow-nest