From d3ec1d52d61da76f51f09be3ce4888fc9fab3770 Mon Sep 17 00:00:00 2001 From: WangDL Date: Sat, 23 May 2026 09:43:01 +0800 Subject: [PATCH] fix: move event publish inside retry loop --- src/modules/ai/gateway/ai-gateway.service.ts | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/modules/ai/gateway/ai-gateway.service.ts b/src/modules/ai/gateway/ai-gateway.service.ts index cef040e..4056bf6 100644 --- a/src/modules/ai/gateway/ai-gateway.service.ts +++ b/src/modules/ai/gateway/ai-gateway.service.ts @@ -63,9 +63,7 @@ export class AiGatewayService { output.usage.outputTokens, ); - this.eventBus?.publish(new (class extends BaseDomainEvent { eventType = 'ai.usage.recorded'; data: any; constructor(d: any) { super(); this.data = d; } })({ userId: request.userId, provider: target.provider, model: target.model, tier: request.tier, inputTokens: output.usage.inputTokens, outputTokens: output.usage.outputTokens, estimatedCost, latencyMs: output.latencyMs })); - - this.usageLog.log({ + this.usageLog.log({ userId: request.userId, feature: request.feature, provider: target.provider, @@ -101,8 +99,6 @@ export class AiGatewayService { } } - this.eventBus?.publish(new (class extends BaseDomainEvent { eventType = 'ai.usage.recorded'; data: any; constructor(d: any) { super(); this.data = d; } })({ userId: request.userId, provider: target.provider, model: target.model, tier: request.tier, inputTokens: output.usage.inputTokens, outputTokens: output.usage.outputTokens, estimatedCost, latencyMs: output.latencyMs })); - this.usageLog.log({ userId: request.userId, feature: request.feature,