feat: update post score by queue

Author: winverse

apps/cron/src/jobs/GenerateFeedJob.mts

@@ -22,12 +22,12 @@ export class GenerateFeedJob extends JobProgress implements Job {
       const { fk_following_id, fk_post_id } = data
       try {
         await this.feedService.createFeed({ followingId: fk_following_id, postId: fk_post_id })
-        await this.redis.lpop(feedQueueName)
-        handledQueueCount++
       } catch (error) {
         console.log('Error occurred while creating feed', error)
         console.log('data', data)
-        continue
+      } finally {
+        await this.redis.lpop(feedQueueName)
+        handledQueueCount++
       }
     }
     console.log(`Created Feed Count: ${handledQueueCount}`)

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

@@ -405,19 +405,7 @@ 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