feat: configurable cleanup job crons

Author: LouisHaftmann

lib/env.ts

@@ -1,11 +1,14 @@
+import { tmpdir } from 'node:os'
 import { z } from 'zod'
 
 const booleanSchema = z.string().transform((v) => v.toLowerCase() === 'true')
 const portSchema = z.coerce.number().int().min(1).max(65_535)
 
 const envSchema = z.object({
   ENABLE_DIRECT_DOWNLOADS: booleanSchema.default('false'),
-  CLEANUP_OLDER_THAN_DAYS: z.coerce.number().int().min(0).default(90),
+  CACHE_CLEANUP_OLDER_THAN_DAYS: z.coerce.number().int().min(0).default(90),
+  CACHE_CLEANUP_CRON: z.string().default('0 0 * * *'),
+  UPLOAD_CLEANUP_CRON: z.string().default('*/10 * * * *'),
   API_BASE_URL: z.string().url(),
   STORAGE_DRIVER: z.string().toLowerCase().default('filesystem'),
   DB_DRIVER: z.string().toLowerCase().default('sqlite'),

plugins/cleanup.ts

@@ -7,16 +7,27 @@ import { Cron } from 'croner'
 import { useStorageAdapter } from '~/lib/storage'
 
 export default defineNitroPlugin(() => {
-  if (ENV.CLEANUP_OLDER_THAN_DAYS === 0) return
+  // cache cleanup
+  if (ENV.CACHE_CLEANUP_OLDER_THAN_DAYS > 0) {
+    const job = new Cron(ENV.CACHE_CLEANUP_CRON)
+    const nextRun = job.nextRun()
+    logger.info(
+      `Cleaning up cache entries older than ${colorize('blue', `${ENV.CACHE_CLEANUP_OLDER_THAN_DAYS}d`)} with schedule ${colorize('blue', job.getPattern() ?? '')}${nextRun ? ` (next run: ${nextRun.toLocaleString()})` : ''}`,
+    )
+    job.schedule(async () => {
+      const adapter = await useStorageAdapter()
+      await adapter.pruneCaches(ENV.CACHE_CLEANUP_OLDER_THAN_DAYS)
+    })
+  }
 
-  const job = new Cron('0 0 * * *') // daily
+  // upload cleanup
+  const job = new Cron(ENV.UPLOAD_CLEANUP_CRON)
   const nextRun = job.nextRun()
   logger.info(
-    `Cleaning up cache entries older than ${colorize('blue', `${ENV.CLEANUP_OLDER_THAN_DAYS}d`)} with schedule ${colorize('blue', job.getPattern() ?? '')}${nextRun ? ` (next run: ${nextRun.toLocaleString()})` : ''}`,
+    `Cleaning up dangling uploads with schedule ${colorize('blue', job.getPattern() ?? '')}${nextRun ? ` (next run: ${nextRun.toLocaleString()})` : ''}`,
   )
   job.schedule(async () => {
     const adapter = await useStorageAdapter()
-    await adapter.pruneCaches(ENV.CLEANUP_OLDER_THAN_DAYS)
     await adapter.pruneUploads()
   })
 })