agents / Exports / EventEmitterPlugin

Class: EventEmitterPlugin

Plugin for event detection and propagation Emits events during agent execution lifecycle

Hierarchy

• AbstractPlugin<EventEmitterPluginOptions, EventEmitterPluginStats>

  ↳ EventEmitterPlugin

Table of contents

Constructors

• constructor

Properties

• enabled
• category
• priority
• name
• version

Methods

• initialize
• subscribeToModuleEvents
• unsubscribeFromModuleEvents
• dispose
• enable
• disable
• isEnabled
• getConfig
• updateConfig
• getData
• clearData
• getStatus
• beforeRun
• afterRun
• beforeToolCall
• afterToolCall
• beforeProviderCall
• afterProviderCall
• onStreamingChunk
• onMessageAdded
• onModuleEvent
• beforeExecution
• afterExecution
• beforeConversation
• afterConversation
• beforeToolExecution
• afterToolExecution
• onError
• on
• once
• off
• emit
• flushBuffer
• getStats
• clearAllListeners
• destroy

Constructors

constructor

• new EventEmitterPlugin(options?): EventEmitterPlugin

Parameters

Name	Type
options	EventEmitterPluginOptions

Returns

EventEmitterPlugin

Overrides

AbstractPlugin.constructor

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:265

Properties

enabled

• enabled: boolean = true

Plugin enabled state

Inherited from

AbstractPlugin.enabled

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:307

---

category

• category: PluginCategory = PluginCategory.CUSTOM

Plugin category for classification

Inherited from

AbstractPlugin.category

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:310

---

priority

• priority: number = PluginPriority.NORMAL

Plugin priority for execution order

Inherited from

AbstractPlugin.priority

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:313

---

name

• name: string = 'EventEmitterPlugin'

Plugin name

Overrides

AbstractPlugin.name

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:254

---

version

• version: string = '1.0.0'

Plugin version

Overrides

AbstractPlugin.version

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:255

Methods

initialize

▸ initialize(options?): Promise<void>

Initialize the plugin with type-safe options

Parameters

Name	Type
options?	EventEmitterPluginOptions

Returns

Promise<void>

Inherited from

AbstractPlugin.initialize

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:338

---

subscribeToModuleEvents

▸ subscribeToModuleEvents(eventEmitter): Promise<void>

Subscribe to module events through EventEmitter

Parameters

Name	Type
eventEmitter	EventEmitterPlugin

Returns

Promise<void>

Inherited from

AbstractPlugin.subscribeToModuleEvents

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:366

---

unsubscribeFromModuleEvents

▸ unsubscribeFromModuleEvents(eventEmitter): Promise<void>

Unsubscribe from module events

Parameters

Name	Type
eventEmitter	EventEmitterPlugin

Returns

Promise<void>

Inherited from

AbstractPlugin.unsubscribeFromModuleEvents

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:423

---

dispose

▸ dispose(): Promise<void>

Cleanup plugin resources

Returns

Promise<void>

Inherited from

AbstractPlugin.dispose

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:438

---

enable

▸ enable(): void

Enable the plugin

Returns

void

Inherited from

AbstractPlugin.enable

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:450

---

disable

▸ disable(): void

Disable the plugin

Returns

void

Inherited from

AbstractPlugin.disable

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:457

---

isEnabled

▸ isEnabled(): boolean

Check if plugin is enabled

Returns

boolean

Inherited from

AbstractPlugin.isEnabled

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:464

---

getConfig

▸ getConfig(): IPluginConfig

Get plugin configuration

Returns

IPluginConfig

Inherited from

AbstractPlugin.getConfig

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:471

---

updateConfig

▸ updateConfig(_config): void

Update plugin configuration

Parameters

Name	Type
_config	IPluginConfig

Returns

void

Inherited from

AbstractPlugin.updateConfig

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:478

---

getData

▸ getData(): IPluginData

Get plugin data - enhanced with classification information

Returns

IPluginData

Inherited from

AbstractPlugin.getData

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:485

---

clearData

▸ clearData(): void

Clear plugin data - common interface for all plugins This method should be implemented by plugins that store data

Returns

void

Inherited from

AbstractPlugin.clearData

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:505

---

getStatus

▸ getStatus(): Object

Get plugin status - enhanced with classification information

Returns

Object

Name	Type
name	string
version	string
enabled	boolean
initialized	boolean
category	PluginCategory
priority	number
subscribedEventsCount	number
hasEventEmitter	boolean

Inherited from

AbstractPlugin.getStatus

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:510

---

beforeRun

▸ beforeRun(input, options?): Promise<void>

Called before agent run

Parameters

Name	Type
input	string
options?	IRunOptions

Returns

Promise<void>

Inherited from

AbstractPlugin.beforeRun

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:564

---

afterRun

▸ afterRun(input, response, options?): Promise<void>

Called after agent run

Parameters

Name	Type
input	string
response	string
options?	IRunOptions

Returns

Promise<void>

Inherited from

AbstractPlugin.afterRun

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:565

---

beforeToolCall

▸ beforeToolCall(toolName, parameters): Promise<void>

Called before tool execution

Parameters

Name	Type
toolName	string
parameters	TToolParameters

Returns

Promise<void>

Inherited from

AbstractPlugin.beforeToolCall

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:570

---

afterToolCall

▸ afterToolCall(toolName, parameters, result): Promise<void>

Called after tool execution

Parameters

Name	Type
toolName	string
parameters	TToolParameters
result	IToolExecutionResult

Returns

Promise<void>

Inherited from

AbstractPlugin.afterToolCall

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:572

---

beforeProviderCall

▸ beforeProviderCall(messages): Promise<void>

Called before AI provider call

Parameters

Name	Type
messages	TUniversalMessage[]

Returns

Promise<void>

Inherited from

AbstractPlugin.beforeProviderCall

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:574

---

afterProviderCall

▸ afterProviderCall(messages, response): Promise<void>

Called after AI provider call

Parameters

Name	Type
messages	TUniversalMessage[]
response	TUniversalMessage

Returns

Promise<void>

Inherited from

AbstractPlugin.afterProviderCall

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:575

---

onStreamingChunk

▸ onStreamingChunk(chunk): Promise<void>

Called on streaming chunk

Parameters

Name	Type
chunk	TUniversalMessage

Returns

Promise<void>

Inherited from

AbstractPlugin.onStreamingChunk

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:576

---

onMessageAdded

▸ onMessageAdded(message): Promise<void>

Called on message added to history

Parameters

Name	Type
message	TUniversalMessage

Returns

Promise<void>

Inherited from

AbstractPlugin.onMessageAdded

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:578

---

onModuleEvent

▸ onModuleEvent(eventType, eventData): Promise<void>

Called when module events are received

Parameters

Name	Type
eventType	EventType
eventData	EventData

Returns

Promise<void>

Inherited from

AbstractPlugin.onModuleEvent

Defined in

packages/agents/src/abstracts/abstract-plugin.ts:579

---

beforeExecution

▸ beforeExecution(context): Promise<void>

Before execution starts

Parameters

Name	Type
context	IPluginExecutionContext

Returns

Promise<void>

Overrides

AbstractPlugin.beforeExecution

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:315

---

afterExecution

▸ afterExecution(context, result): Promise<void>

After execution completes

Parameters

Name	Type
context	IPluginExecutionContext
result	IPluginExecutionResult

Returns

Promise<void>

Overrides

AbstractPlugin.afterExecution

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:330

---

beforeConversation

▸ beforeConversation(context): Promise<void>

Before conversation starts

Parameters

Name	Type
context	IPluginExecutionContext

Returns

Promise<void>

Overrides

AbstractPlugin.beforeConversation

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:347

---

afterConversation

▸ afterConversation(context, result): Promise<void>

After conversation completes

Parameters

Name	Type
context	IPluginExecutionContext
result	IPluginExecutionResult

Returns

Promise<void>

Overrides

AbstractPlugin.afterConversation

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:366

---

beforeToolExecution

▸ beforeToolExecution(context, toolData): Promise<void>

Before tool execution - emits tool.beforeExecute event

Parameters

Name	Type
context	IPluginExecutionContext
toolData	IToolExecutionContext

Returns

Promise<void>

Overrides

AbstractPlugin.beforeToolExecution

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:387

---

afterToolExecution

▸ afterToolExecution(context, toolResults): Promise<void>

After tool execution - emits tool.success or tool.error events

Parameters

Name	Type
context	IPluginExecutionContext
toolResults	IPluginExecutionResult

Returns

Promise<void>

Overrides

AbstractPlugin.afterToolExecution

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:410

---

onError

▸ onError(error, context?): Promise<void>

On error

REASON: Error context structure varies by execution phase and error type, needs flexible handling ALTERNATIVES_CONSIDERED:

1. Strict error context interface (breaks error handling flexibility)
2. Union types (insufficient for dynamic error contexts)
3. Generic constraints (too complex for error handling)
4. Interface definitions (too rigid for varied error contexts)
5. Type assertions (decreases type safety) TODO: Consider standardized error context interface

Parameters

Name	Type
error	Error
context?	IPluginErrorContext

Returns

Promise<void>

Overrides

AbstractPlugin.onError

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:458

---

on

▸ on(eventType, listener, options?): string

Register event listener

Parameters

Name	Type
eventType	EventType
listener	EventListener
options?	Object
options.once?	boolean
options.filter?	(event: EventData) => boolean

Returns

string

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:473

---

once

▸ once(eventType, listener, filter?): string

Register one-time event listener

Parameters

Name	Type
eventType	EventType
listener	EventListener
filter?	(event: EventData) => boolean

Returns

string

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:513

---

off

▸ off(eventType, handlerIdOrListener): boolean

Remove event listener

Parameters

Name	Type
eventType	EventType
handlerIdOrListener	string | EventListener

Returns

boolean

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:523

---

emit

▸ emit(eventType, eventData?): Promise<void>

Emit an event

Parameters

Name	Type
eventType	EventType
eventData	Partial<EventData>

Returns

Promise<void>

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:550

---

flushBuffer

▸ flushBuffer(): Promise<void>

Flush buffered events

Returns

Promise<void>

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:664

---

getStats

▸ getStats(): EventEmitterPluginStats

Get event emitter statistics

Returns

EventEmitterPluginStats

Overrides

AbstractPlugin.getStats

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:682

---

clearAllListeners

▸ clearAllListeners(): void

Clear all listeners

Returns

void

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:706

---

destroy

▸ destroy(): Promise<void>

Cleanup on plugin destruction

Returns

Promise<void>

Defined in

packages/agents/src/plugins/event-emitter-plugin.ts:714