Merge pull request #4881 from mikiher/wrap-ensure-dir

Wrap ensureDir in try-catch blocks in manager classes

server/managers/BackupManager.js

@@ -48,9 +48,14 @@ class BackupManager {
   }
 
   async init() {
-    const backupsDirExists = await fs.pathExists(this.backupPath)
-    if (!backupsDirExists) {
-      await fs.ensureDir(this.backupPath)
+    try {
+      const backupsDirExists = await fs.pathExists(this.backupPath)
+      if (!backupsDirExists) {
+        await fs.ensureDir(this.backupPath)
+      }
+    } catch (error) {
+      Logger.error(`[BackupManager] Failed to ensure backup directory at "${this.backupPath}": ${error.message}`)
+      throw new Error(`[BackupManager] Failed to ensure backup directory at "${this.backupPath}"`, { cause: error })
     }
 
     await this.loadBackups()

server/managers/CacheManager.js

@@ -24,10 +24,15 @@ class CacheManager {
     this.ImageCachePath = Path.join(this.CachePath, 'images')
     this.ItemCachePath = Path.join(this.CachePath, 'items')
 
-    await fs.ensureDir(this.CachePath)
-    await fs.ensureDir(this.CoverCachePath)
-    await fs.ensureDir(this.ImageCachePath)
-    await fs.ensureDir(this.ItemCachePath)
+    try {
+      await fs.ensureDir(this.CachePath)
+      await fs.ensureDir(this.CoverCachePath)
+      await fs.ensureDir(this.ImageCachePath)
+      await fs.ensureDir(this.ItemCachePath)
+    } catch (error) {
+      Logger.error(`[CacheManager] Failed to create cache directories at "${this.CachePath}": ${error.message}`)
+      throw new Error(`[CacheManager] Failed to create cache directories at "${this.CachePath}"`, { cause: error })
+    }
   }
 
   async handleCoverCache(res, libraryItemId, options = {}) {

server/managers/LogManager.js

@@ -37,8 +37,13 @@ class LogManager {
   }
 
   async ensureLogDirs() {
-    await fs.ensureDir(this.DailyLogPath)
-    await fs.ensureDir(this.ScanLogPath)
+    try {
+      await fs.ensureDir(this.DailyLogPath)
+      await fs.ensureDir(this.ScanLogPath)
+    } catch (error) {
+      console.error(`[LogManager] Failed to create log directories at "${this.DailyLogPath}": ${error.message}`)
+      throw new Error(`[LogManager] Failed to create log directories at "${this.DailyLogPath}"`, { cause: error })
+    }
   }
 
   /**
@@ -110,12 +115,12 @@ class LogManager {
     const exists = await fs.pathExists(fullPath)
     if (!exists) {
       Logger.error(TAG, 'Invalid log dne ' + fullPath)
-      this.dailyLogFiles = this.dailyLogFiles.filter(dlf => dlf !== filename)
+      this.dailyLogFiles = this.dailyLogFiles.filter((dlf) => dlf !== filename)
     } else {
       try {
         await fs.unlink(fullPath)
         Logger.info(TAG, 'Removed daily log: ' + filename)
-        this.dailyLogFiles = this.dailyLogFiles.filter(dlf => dlf !== filename)
+        this.dailyLogFiles = this.dailyLogFiles.filter((dlf) => dlf !== filename)
       } catch (error) {
         Logger.error(TAG, 'Failed to unlink log file ' + fullPath)
       }
@@ -161,7 +166,7 @@ class LogManager {
     const logsDir = Path.join(global.MetadataPath, 'logs')
     await fs.ensureDir(logsDir)
     const crashLogPath = Path.join(logsDir, 'crash_logs.txt')
-    return fs.writeFile(crashLogPath, line, { flag: "a+" }).catch((error) => {
+    return fs.writeFile(crashLogPath, line, { flag: 'a+' }).catch((error) => {
       console.log('[LogManager] Appended crash log', error)
     })
   }

server/managers/MigrationManager.js

@@ -38,7 +38,12 @@ class MigrationManager {
     if (!(await fs.pathExists(this.configPath))) throw new Error(`Config path does not exist: ${this.configPath}`)
 
     this.migrationsDir = path.join(this.configPath, 'migrations')
-    await fs.ensureDir(this.migrationsDir)
+    try {
+      await fs.ensureDir(this.migrationsDir)
+    } catch (error) {
+      Logger.error(`[MigrationManager] Failed to create migrations directory at "${this.migrationsDir}": ${error.message}`)
+      throw new Error(`[MigrationManager] Failed to create migrations directory at "${this.migrationsDir}"`, { cause: error })
+    }
 
     this.serverVersion = this.extractVersionFromTag(serverVersion)
     if (!this.serverVersion) throw new Error(`Invalid server version: ${serverVersion}. Expected a version tag like v1.2.3.`)

server/managers/PlaybackSessionManager.js

@@ -459,7 +459,12 @@ class PlaybackSessionManager {
    * Remove all stream folders in `/metadata/streams`
    */
   async removeOrphanStreams() {
-    await fs.ensureDir(this.StreamsPath)
+    try {
+      await fs.ensureDir(this.StreamsPath)
+    } catch (error) {
+      Logger.error(`[PlaybackSessionManager] Failed to create streams directory at "${this.StreamsPath}": ${error.message}`)
+      throw new Error(`[PlaybackSessionManager] Failed to create streams directory at "${this.StreamsPath}"`, { cause: error })
+    }
     try {
       const streamsInPath = await fs.readdir(this.StreamsPath)
       for (const streamId of streamsInPath) {