feat: create score post queue

Author: winverse

apps/server/src/lib/redis/RedisService.ts

@@ -3,8 +3,8 @@ import { injectable, singleton } from 'tsyringe'
 import { RedisService as Redis } from '@packages/database/velog-redis'
 export type {
   ChangeEmailArgs,
-  CheckPostSpamArgs,
-  CreateFeedArgs,
+  CheckPostSpamQueueData,
+  CreateFeedQueueData,
 } from '@packages/database/velog-redis'
 
 @injectable()

apps/server/src/services/PostApiService/index.mts

@@ -17,7 +17,11 @@ import { SeriesService } from '@services/SeriesService/index.mjs'
 import { SearchService } from '@services/SearchService/index.js'
 import { ExternalIntegrationService } from '@services/ExternalIntegrationService/index.js'
 import { PostService } from '@services/PostService/index.js'
-import { CreateFeedArgs, RedisService, CheckPostSpamArgs } from '@lib/redis/RedisService.js'
+import {
+  RedisService,
+  type CreateFeedQueueData,
+  type CheckPostSpamQueueData,
+} from '@lib/redis/RedisService.js'
 import { GraphcdnService } from '@lib/graphcdn/GraphcdnService.js'
 import { ImageService } from '@services/ImageService/index.js'
 import { UserService } from '@services/UserService/index.js'
@@ -315,24 +319,24 @@ export class PostApiService implements Service {
       // create feed
       setTimeout(() => {
         if (!post) return
-        const queueData: CreateFeedArgs = {
+        const queueData: CreateFeedQueueData = {
           fk_following_id: signedUserId,
           fk_post_id: post.id,
         }
-        this.redis.createFeedQueue(queueData)
+        this.redis.addToCreateFeedQueue(queueData)
       }, 0)
 
       // check spam
       setTimeout(() => {
         if (!post) return
         if (isSpam) return
         if (isTusted) return
-        const queueData: CheckPostSpamArgs = {
+        const queueData: CheckPostSpamQueueData = {
           post_id: post.id,
           user_id: signedUserId,
           ip,
         }
-        this.redis.addToSpamCheckQueue(queueData)
+        this.redis.addToCheckPostSpamQueue(queueData)
       }, 0)
     }
 

apps/server/src/services/PostService/index.ts

@@ -405,17 +405,7 @@ export class PostService implements Service {
     }
   }
   public async updatePostScore(postId: string) {
-    try {
-      await axios.patch(
-        `${ENV.cronHost}/api/posts/v1/score/${postId}`,
-        {},
-        {
-          headers: {
-            'Cron-Api-Key': ENV.cronApiKey,
-          },
-        },
-      )
-    } catch (_) {}
+    await this.redis.addToScorePostQueue({ post_id: postId })
   }
   public shortDescription(post: Post): string {
     if (post.short_description) return post.short_description

packages/database/src/velog-redis/index.mts

@@ -4,7 +4,9 @@ interface Service {
   connection(): Promise<void>
   get generateKey(): GenerateRedisKey
   get queueName(): Record<QueueName, string>
-  createFeedQueue(data: CreateFeedArgs): Promise<number>
+  addToCreateFeedQueue(data: CreateFeedQueueData): Promise<number>
+  addToCheckPostSpamQueue(data: CheckPostSpamQueueData): Promise<number>
+  addToScorePostQueue(data: ScorePostQueueData): Promise<number>
 }
 
 type RedisOptions = {
@@ -53,17 +55,23 @@ export class RedisService extends Redis.default implements Service {
     return {
       createFeed: 'queue:feed',
       checkPostSpam: 'queue:checkPostSpam',
+      scorePost: 'queue:scorePost',
     }
   }
 
-  public async createFeedQueue(data: CreateFeedArgs): Promise<number> {
+  public addToCreateFeedQueue(data: CreateFeedQueueData) {
     const queueName = this.queueName.createFeed
-    return await this.lpush(queueName, JSON.stringify(data))
+    return this.lpush(queueName, JSON.stringify(data))
   }
 
-  public async addToSpamCheckQueue(data: CheckPostSpamArgs): Promise<number> {
+  public addToCheckPostSpamQueue(data: CheckPostSpamQueueData): Promise<number> {
     const queueName = this.queueName.checkPostSpam
-    return await this.lpush(queueName, JSON.stringify(data))
+    return this.lpush(queueName, JSON.stringify(data))
+  }
+
+  public addToScorePostQueue(data: ScorePostQueueData): Promise<number> {
+    const queueName = this.queueName.scorePost
+    return this.lpush(queueName, JSON.stringify(data))
   }
 }
 
@@ -81,20 +89,24 @@ type GenerateRedisKey = {
   deployBook: (bookId: string) => string
 }
 
-type QueueName = 'createFeed' | 'checkPostSpam'
+type QueueName = 'createFeed' | 'checkPostSpam' | 'scorePost'
 
 export type ChangeEmailArgs = {
   email: string
   userId: string
 }
 
-export type CreateFeedArgs = {
+export type CreateFeedQueueData = {
   fk_following_id: string
   fk_post_id: string
 }
 
-export type CheckPostSpamArgs = {
+export type CheckPostSpamQueueData = {
   post_id: string
   user_id: string
   ip: string
 }
+
+export type ScorePostQueueData = {
+  post_id: string
+}