agents / Exports / WorkflowEventSubscriber

Class: WorkflowEventSubscriber

WorkflowEventSubscriber EventService 이벤트를 모니터링하여 Workflow Node로 변환 EventService에 구독 메서드가 없으므로 ActionTrackingEventService를 확장하여 사용

Hierarchy

• ActionTrackingEventService

  ↳ WorkflowEventSubscriber

Table of contents

Constructors

• constructor

Methods

• trackExecution
• createBoundEmit
• createContextBoundInstance
• getHierarchy
• clearHierarchy
• subscribeToWorkflowEvents
• unsubscribe
• emit
• getAllNodes
• getNode
• getConnections
• getNodeEdgeManagerEdges
• getEdges
• getWorkflowData
• getConnectionSummary

Constructors

constructor

• new WorkflowEventSubscriber(logger?): WorkflowEventSubscriber

Parameters

Name	Type
logger?	SimpleLogger

Returns

WorkflowEventSubscriber

Overrides

ActionTrackingEventService.constructor

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:261

Methods

trackExecution

▸ trackExecution(executionId, parentExecutionId?, level?): void

Track execution in the hierarchy Registers a new execution node with parent-child relationships

Parameters

Name	Type
executionId	string
parentExecutionId?	string
level?	number

Returns

void

Inherited from

ActionTrackingEventService.trackExecution

Defined in

packages/agents/src/services/event-service.ts:308

---

createBoundEmit

▸ createBoundEmit(executionId): (eventType: string, data: ServiceEventData) => void

Create bound emit function with automatic hierarchical context Returns a function that automatically includes parent/level information

Parameters

Name	Type
executionId	string

Returns

fn

▸ (eventType, data): void

Parameters

Name	Type
eventType	string
data	ServiceEventData

Returns

void

Inherited from

ActionTrackingEventService.createBoundEmit

Defined in

packages/agents/src/services/event-service.ts:337

---

createContextBoundInstance

▸ createContextBoundInstance(executionContext): EventService

🎯 [CONTEXT-BINDING] Create new EventService instance with injected context This enables automatic context propagation through the event system

Parameters

Name	Type	Description
executionContext	ToolExecutionContext	Context to inject into the new instance

Returns

EventService

New EventService instance with context binding

Inherited from

ActionTrackingEventService.createContextBoundInstance

Defined in

packages/agents/src/services/event-service.ts:360

---

getHierarchy

▸ getHierarchy(): Map<string, ExecutionNode>

Get current hierarchy state (for debugging)

Returns

Map<string, ExecutionNode>

Inherited from

ActionTrackingEventService.getHierarchy

Defined in

packages/agents/src/services/event-service.ts:741

---

clearHierarchy

▸ clearHierarchy(): void

Clear hierarchy state

Returns

void

Inherited from

ActionTrackingEventService.clearHierarchy

Defined in

packages/agents/src/services/event-service.ts:748

---

subscribeToWorkflowEvents

▸ subscribeToWorkflowEvents(callback): void

Workflow Node 업데이트 구독

Parameters

Name	Type
callback	(nodeUpdate: WorkflowNodeUpdate) => void

Returns

void

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:276

---

unsubscribe

▸ unsubscribe(callback): void

이벤트 구독 해제

Parameters

Name	Type
callback	(nodeUpdate: WorkflowNodeUpdate) => void

Returns

void

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:284

---

emit

▸ emit(eventType, data): void

emit 메서드 오버라이드하여 이벤트 모니터링 모든 이벤트가 이 메서드를 통과하므로 여기서 Node 생성 처리 비동기 처리로 이벤트 블로킹 방지

Parameters

Name	Type
eventType	string
data	ServiceEventData

Returns

void

Overrides

ActionTrackingEventService.emit

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:297

---

getAllNodes

▸ getAllNodes(): WorkflowNode[]

Returns

WorkflowNode[]

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:1605

---

getNode

▸ getNode(nodeId): undefined | WorkflowNode

Parameters

Name	Type
nodeId	string

Returns

undefined | WorkflowNode

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:1619

---

getConnections

▸ getConnections(): WorkflowConnection[]

Returns

WorkflowConnection[]

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:1623

---

getNodeEdgeManagerEdges

▸ getNodeEdgeManagerEdges(): UniversalWorkflowEdge[]

🚀 NodeEdgeManager에서 생성된 실제 edges 반환 (컨버터 우회) 실시간 데이터 생성 목표에 맞춰 컨버터 의존성 제거

Returns

UniversalWorkflowEdge[]

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:1635

---

getEdges

▸ getEdges(): UniversalWorkflowEdge[]

직접 생성된 edges 배열 반환

Returns

UniversalWorkflowEdge[]

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:1812

---

getWorkflowData

▸ getWorkflowData(): Object

nodes와 edges를 포함한 완전한 워크플로우 데이터 반환 🎯 [LEGACY-REMOVAL] NodeEdgeManager에서 모든 데이터 가져오기 (레거시 nodeMap 제거)

Returns

Object

Name	Type
nodes	WorkflowNode[]
edges	UniversalWorkflowEdge[]

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:1820

---

getConnectionSummary

▸ getConnectionSummary(): Object

디버깅을 위한 연결 상태 요약 반환

Returns

Object

Name	Type
totalNodes	number
totalEdges	number
edgesByType	Record<string, number>

Defined in

packages/agents/src/services/workflow-event-subscriber.ts:1830