From 807dc8705d5bcc6521dd3044b09557fa140f9d35 Mon Sep 17 00:00:00 2001 From: hailin Date: Tue, 9 Dec 2025 22:29:54 -0800 Subject: [PATCH] fix(referral): add EventAckPublisher to InfrastructureModule MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Refactor EventAckPublisher to use KafkaService instead of ClientKafka - Add kafka/index.ts export file - Register EventAckPublisher in InfrastructureModule providers and exports 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 --- backend/services/referral-service/src/infrastructure/index.ts | 1 + .../referral-service/src/infrastructure/kafka/index.ts | 1 + .../referral-service/src/modules/infrastructure.module.ts | 3 +++ 3 files changed, 5 insertions(+) create mode 100644 backend/services/referral-service/src/infrastructure/kafka/index.ts diff --git a/backend/services/referral-service/src/infrastructure/index.ts b/backend/services/referral-service/src/infrastructure/index.ts index cb51e191..d1ee8cd6 100644 --- a/backend/services/referral-service/src/infrastructure/index.ts +++ b/backend/services/referral-service/src/infrastructure/index.ts @@ -2,3 +2,4 @@ export * from './database'; export * from './repositories'; export * from './messaging'; export * from './cache'; +export * from './kafka'; diff --git a/backend/services/referral-service/src/infrastructure/kafka/index.ts b/backend/services/referral-service/src/infrastructure/kafka/index.ts new file mode 100644 index 00000000..be96c4c6 --- /dev/null +++ b/backend/services/referral-service/src/infrastructure/kafka/index.ts @@ -0,0 +1 @@ +export * from './event-ack.publisher'; diff --git a/backend/services/referral-service/src/modules/infrastructure.module.ts b/backend/services/referral-service/src/modules/infrastructure.module.ts index 44f796f5..bfcb48bc 100644 --- a/backend/services/referral-service/src/modules/infrastructure.module.ts +++ b/backend/services/referral-service/src/modules/infrastructure.module.ts @@ -7,6 +7,7 @@ import { KafkaService, EventPublisherService, RedisService, + EventAckPublisher, } from '../infrastructure'; import { REFERRAL_RELATIONSHIP_REPOSITORY, @@ -21,6 +22,7 @@ import { KafkaService, RedisService, EventPublisherService, + EventAckPublisher, { provide: REFERRAL_RELATIONSHIP_REPOSITORY, useClass: ReferralRelationshipRepository, @@ -35,6 +37,7 @@ import { KafkaService, RedisService, EventPublisherService, + EventAckPublisher, REFERRAL_RELATIONSHIP_REPOSITORY, TEAM_STATISTICS_REPOSITORY, ],