fix(webhook): enrich comment payload author and avatar

Innei · Innei · commit 2833c38957c6 · 2026-03-23T14:23:48.000+08:00
diff --git a/apps/core/src/processors/helper/helper.event-payload.service.ts b/apps/core/src/processors/helper/helper.event-payload.service.ts
@@ -2,9 +2,12 @@ import { Injectable } from '@nestjs/common'
 
 import { BusinessEvents } from '~/constants/business-event.constant'
 import { NoteModel } from '~/modules/note/note.model'
+import { OwnerService } from '~/modules/owner/owner.service'
 import { PageModel } from '~/modules/page/page.model'
 import { PostModel } from '~/modules/post/post.model'
+import { ReaderService } from '~/modules/reader/reader.service'
 import { InjectModel } from '~/transformers/model.transformer'
+import { getAvatar } from '~/utils/tool.util'
 
 @Injectable()
 export class EventPayloadEnricherService {
@@ -15,8 +18,40 @@ export class EventPayloadEnricherService {
     private readonly noteModel: MongooseModel<NoteModel>,
     @InjectModel(PageModel)
     private readonly pageModel: MongooseModel<PageModel>,
+    private readonly readerService: ReaderService,
+    private readonly ownerService: OwnerService,
   ) {}
 
+  private async enrichCommentPayload(data: any): Promise<any> {
+    if (!data?.readerId) {
+      return data
+    }
+
+    const reader = await this.readerService
+      .findReaderInIds([data.readerId])
+      .then((readers) => readers[0] ?? null)
+
+    if (!reader) {
+      return data
+    }
+
+    if (reader.role === 'owner') {
+      const owner = await this.ownerService.getOwner().catch(() => null)
+
+      return {
+        ...data,
+        author: owner?.name || reader.name || data.author,
+        avatar: owner?.avatar || reader.image || getAvatar(reader.email),
+      }
+    }
+
+    return {
+      ...data,
+      author: reader.name || data.author,
+      avatar: reader.image || data.avatar || getAvatar(reader.email),
+    }
+  }
+
   async enrichPayload(event: BusinessEvents, data: any): Promise<any> {
     if (!data?.id) return data
 
@@ -55,6 +90,9 @@ export class EventPayloadEnricherService {
           data
         )
       }
+      case BusinessEvents.COMMENT_CREATE: {
+        return this.enrichCommentPayload(data)
+      }
       default: {
         return data
       }
diff --git a/apps/core/src/processors/helper/helper.module.ts b/apps/core/src/processors/helper/helper.module.ts
@@ -10,6 +10,7 @@ import { AiModule } from '~/modules/ai/ai.module'
 import { NoteModule } from '~/modules/note/note.module'
 import { PageModule } from '~/modules/page/page.module'
 import { PostModule } from '~/modules/post/post.module'
+import { ReaderModule } from '~/modules/reader/reader.module'
 
 import { AssetService } from './helper.asset.service'
 import { BarkPushService } from './helper.bark.service'
@@ -66,6 +67,7 @@ const providers: Provider<any>[] = [
     forwardRef(() => PostModule),
     forwardRef(() => NoteModule),
     forwardRef(() => PageModule),
+    forwardRef(() => ReaderModule),
   ],
   providers,
   exports: providers,
