fix: add update post score routes

Author: winverse

apps/cron/src/services/FeedService/index.mts

@@ -12,7 +12,7 @@ interface Service {
 @injectable()
 @singleton()
 export class FeedService implements Service {
-constructor(
+  constructor(
     private readonly db: DbService,
     private readonly utils: UtilsService,
     private readonly followUserService: FollowUserService,

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

@@ -15,10 +15,7 @@ interface Service {
 @injectable()
 @singleton()
 export class FeedService implements Service {
-  constructor(
-    private readonly db: DbService,
-    private readonly utils: UtilsService,
-  ) {}
+  constructor(private readonly db: DbService, private readonly utils: UtilsService) {}
   async getFeedPosts(input: FeedPostsInput, singedUserId?: string): Promise<Post[]> {
     if (!singedUserId) {
       return []

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

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

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

@@ -59,19 +59,19 @@ export class RedisService extends Redis.default implements Service {
     }
   }
 
-  public addToCreateFeedQueue(data: CreateFeedQueueData) {
+  public async addToCreateFeedQueue(data: CreateFeedQueueData): Promise<number> {
     const queueName = this.queueName.createFeed
-    return this.lpush(queueName, JSON.stringify(data))
+    return await this.lpush(queueName, JSON.stringify(data))
   }
 
-  public addToCheckPostSpamQueue(data: CheckPostSpamQueueData): Promise<number> {
+  public async addToCheckPostSpamQueue(data: CheckPostSpamQueueData): Promise<number> {
     const queueName = this.queueName.checkPostSpam
-    return this.lpush(queueName, JSON.stringify(data))
+    return await this.lpush(queueName, JSON.stringify(data))
   }
 
-  public addToScorePostQueue(data: ScorePostQueueData): Promise<number> {
+  public async addToScorePostQueue(data: ScorePostQueueData): Promise<number> {
     const queueName = this.queueName.scorePost
-    return this.lpush(queueName, JSON.stringify(data))
+    return await this.lpush(queueName, JSON.stringify(data))
   }
 }