diff --git a/packages/core/lib/events/DomainEventEmitter.ts b/packages/core/lib/events/DomainEventEmitter.ts index c42587c5..62ef036a 100644 --- a/packages/core/lib/events/DomainEventEmitter.ts +++ b/packages/core/lib/events/DomainEventEmitter.ts @@ -80,6 +80,21 @@ export class DomainEventEmitter }) } + if (this._handlerSpy) { + this._handlerSpy.addProcessedMessage( + { + // @ts-ignore + message: { + type: eventTypeName, + ...data, + ...(metadata !== undefined ? { metadata } : {}), + }, + processingResult: 'published', + }, + data.id, + ) + } + const eventHandlers = this.eventHandlerMap[eventTypeName] // No relevant handlers are registered, we can stop processing diff --git a/packages/core/package.json b/packages/core/package.json index ae82aa3f..f0291aff 100644 --- a/packages/core/package.json +++ b/packages/core/package.json @@ -36,8 +36,8 @@ "devDependencies": { "@types/node": "^20.12.8", "@types/tmp": "^0.2.6", - "@typescript-eslint/eslint-plugin": "^7.7.1", - "@typescript-eslint/parser": "^7.7.1", + "@typescript-eslint/eslint-plugin": "^7.14.1", + "@typescript-eslint/parser": "^7.14.1", "@vitest/coverage-v8": "^1.6.0", "awilix": "^10.0.2", "awilix-manager": "^5.2.1",