Update feed queue name in GenerateFeedJob and RedisService

Author: winverse

packages/velog-cron/src/jobs/GenerateFeedJob.ts

@@ -16,7 +16,7 @@ export class GenerateFeedJob extends JobProgress implements Job {
     console.log('Create feed job start...')
     console.time('create feed')
 
-    const feedQueueName = this.redis.queueName.feed
+    const feedQueueName = this.redis.queueName.createFeed
     let handledQueueCount = 0
     while (true) {
       const item = await this.redis.lindex(feedQueueName, 0)

packages/velog-cron/src/lib/redis/RedisService.ts

@@ -30,7 +30,7 @@ export class RedisService extends Redis implements Service {
 
   get queueName() {
     return {
-      feed: 'queue:feed',
+      createFeed: 'queue:feed',
     }
   }
 }
@@ -39,4 +39,4 @@ type GenerateRedisKey = {
   trendingWriters: () => string
 }
 
-type QueueName = 'feed'
+type QueueName = 'createFeed'

packages/velog-scripts/lib/redis/RedisService.mts

@@ -2,9 +2,7 @@ import { injectable, singleton } from 'tsyringe'
 import Redis from 'ioredis'
 import { ENV } from '../../env/env.mjs'
 
-interface Service {
-  get setName(): SetName
-}
+interface Service {}
 
 @injectable()
 @singleton()
@@ -20,32 +18,4 @@ export class RedisService extends Redis implements Service {
       })
     })
   }
-
-  get setName() {
-    return {
-      blockList: 'set:blockList',
-    }
-  }
-
-  public async addBlockList(username: string) {
-    try {
-      const keyname = this.setName.blockList
-      await this.sadd(keyname, username)
-    } catch (error) {
-      throw error
-    }
-  }
-
-  public async readBlockList() {
-    try {
-      const keyname = this.setName.blockList
-      return await this.smembers(keyname)
-    } catch (error) {
-      throw error
-    }
-  }
-}
-
-type SetName = {
-  blockList: string
 }

packages/velog-server/src/lib/redis/RedisService.ts

@@ -6,7 +6,6 @@ interface Service {
   connection(): Promise<string>
   get generateKey(): GenerateRedisKey
   get queueName(): Record<QueueName, string>
-  get setName(): Record<SetName, string>
   createFeedQueue(data: CreateFeedArgs): Promise<number>
 }
 
@@ -39,18 +38,13 @@ export class RedisService extends Redis implements Service {
 
   public get queueName(): Record<QueueName, string> {
     return {
-      feed: 'queue:feed',
-    }
-  }
-
-  public get setName(): Record<SetName, string> {
-    return {
-      blockList: 'set:blockList',
+      createFeed: 'queue:feed',
+      spamCheck: 'queue:postIdsForSpamCheck',
     }
   }
 
   public async createFeedQueue(data: CreateFeedArgs): Promise<number> {
-    const queueName = this.queueName.feed
+    const queueName = this.queueName.createFeed
     return await this.lpush(queueName, JSON.stringify(data))
   }
 }
@@ -64,9 +58,7 @@ type GenerateRedisKey = {
   trendingWriters: () => string
 }
 
-type QueueName = 'feed'
-
-type SetName = 'blockList'
+type QueueName = 'createFeed' | 'spamCheck'
 
 type CreateFeedArgs = {
   fk_following_id: string