git add .

Author: winverse

apps/cron/src/common/plugins/global/cronPlugin.mts

@@ -7,7 +7,7 @@ import { DeleteFeedJob } from '@jobs/DeleteFeedJob.mjs'
 import { FastifyPluginAsync } from 'fastify'
 import { container } from 'tsyringe'
 import { ENV } from '@env'
-import { CheckSpamPostJob } from '@jobs/CheckSpamPostJob.mjs'
+import { CheckPostSpamJob } from '@jobs/CheckPostSpamJob.mjs'
 import { DeletePostReadJob } from '@jobs/DeletePostReadJob.mjs'
 
 const cronPlugin: FastifyPluginAsync = async (fastfiy) => {
@@ -18,7 +18,7 @@ const cronPlugin: FastifyPluginAsync = async (fastfiy) => {
   const statsDailyJob = container.resolve(StatsDaily)
   const statsWeeklyJob = container.resolve(StatsWeekly)
   const statsMonthlyJob = container.resolve(StatsMonthly)
-  const checkSpamPostJob = container.resolve(CheckSpamPostJob)
+  const checkPostSpamJob = container.resolve(CheckPostSpamJob)
   const deleteReadPostJob = container.resolve(DeletePostReadJob)
 
   // 덜 실행하면서, 실행되는 순서로 정렬
@@ -54,7 +54,7 @@ const cronPlugin: FastifyPluginAsync = async (fastfiy) => {
     {
       name: 'check post spam in every 2 minutes',
       cronTime: '*/2 * * * *', // every 2 minutes
-      jobService: checkSpamPostJob,
+      jobService: checkPostSpamJob,
     },
     {
       name: 'delete post read in every 2 minutes',
@@ -151,7 +151,7 @@ type JobService =
   | StatsDaily
   | StatsWeekly
   | StatsMonthly
-  | CheckSpamPostJob
+  | CheckPostSpamJob
   | DeletePostReadJob
 
 type BaseJobService = {

apps/cron/src/jobs/CheckSpamPostJob.mts renamed to apps/cron/src/jobs/CheckPostSpamJob.mts

@@ -1,12 +1,12 @@
 import { injectable, singleton } from 'tsyringe'
 import { Job, JobProgress } from './JobProgress.mjs'
 import { PostService } from '@services/PostService/index.mjs'
-import { CheckPostSpamArgs, RedisService } from '@lib/redis/RedisService.mjs'
+import { type CheckPostSpamQueueData, RedisService } from '@lib/redis/RedisService.mjs'
 import { DiscordService } from '@lib/discord/DiscordService.mjs'
 
 @injectable()
 @singleton()
-export class CheckSpamPostJob extends JobProgress implements Job {
+export class CheckPostSpamJob extends JobProgress implements Job {
   constructor(
     private readonly redis: RedisService,
     private readonly discord: DiscordService,
@@ -23,7 +23,7 @@ export class CheckSpamPostJob extends JobProgress implements Job {
     while (true) {
       const item = await this.redis.lindex(spamQueueName, 0)
       if (!item) break
-      const data: CheckPostSpamArgs = JSON.parse(item)
+      const data: CheckPostSpamQueueData = JSON.parse(item)
       try {
         await this.postService.checkSpam(data)
       } catch (error) {

apps/cron/src/lib/redis/RedisService.mts

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

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/cron/src/services/PostService/index.mts

@@ -4,12 +4,12 @@ import { injectable, singleton } from 'tsyringe'
 import geoip from 'geoip-country'
 import { subMonths } from 'date-fns'
 import { DiscordService } from '@lib/discord/DiscordService.mjs'
-import { CheckPostSpamArgs } from '@lib/redis/RedisService.mjs'
+import type { CheckPostSpamQueueData } from '@lib/redis/RedisService.mjs'
 
 interface Service {
   findById(postId: string): Promise<Post | null>
   scoreCalculator(postId: string): Promise<void>
-  checkSpam(args: CheckPostSpamArgs): Promise<void>
+  checkSpam(data: CheckPostSpamQueueData): Promise<void>
 }
 
 @singleton()
@@ -68,7 +68,7 @@ export class PostService implements Service {
     })
   }
 
-  public async checkSpam({ post_id, user_id, ip }: CheckPostSpamArgs): Promise<void> {
+  public async checkSpam({ post_id, user_id, ip }: CheckPostSpamQueueData): Promise<void> {
     const post = await this.db.post.findUnique({
       where: {
         id: post_id,