clean code

weseek · Oct 18, 2024 · df8e58f · df8e58f
1 parent 87a70f6
commit df8e58f
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/apps/app/src/features/openai/server/services/thread-deletion-cron.ts b/apps/app/src/features/openai/server/services/thread-deletion-cron.ts
@@ -22,22 +22,25 @@ class ThreadDeletionCronService {
       return;
     }
 
-    // Executed at 0 minutes of every hour
-    // const cronSchedule = '0 * * * *';
+    const openaiService = getOpenaiService();
+    if (openaiService == null) {
+      throw new Error('OpenAI service is not initialized');
+    }
 
-    // debug mode
-    const cronSchedule = '* * * * *';
+    this.openaiService = openaiService;
+
+    // Executed at 0 minutes of every hour
+    const cronSchedule = '0 * * * *';
 
     this.cronJob?.stop();
     this.cronJob = this.generateCronJob(cronSchedule);
     this.cronJob.start();
   }
 
   private async executeJob(): Promise<void> {
-    const openaiService = getOpenaiService();
-
-    // Delete only 100 by rateLimit countermeasure on OpenAI side
-    await openaiService?.deleteExpiredThreads(DELETE_LIMIT);
+    // Must be careful of OpenAI's rate limit
+    // Delete up to 100 threads per hour
+    await this.openaiService.deleteExpiredThreads(DELETE_LIMIT);
   }
 
   private generateCronJob(cronSchedule: string) {