Add tasks queue dropdown

server/Server.js

@@ -72,7 +72,7 @@ class Server {
     this.abMergeManager = new AbMergeManager(this.db, this.taskManager)
     this.playbackSessionManager = new PlaybackSessionManager(this.db)
     this.coverManager = new CoverManager(this.db, this.cacheManager)
-    this.podcastManager = new PodcastManager(this.db, this.watcher, this.notificationManager)
+    this.podcastManager = new PodcastManager(this.db, this.watcher, this.notificationManager, this.taskManager)
     this.audioMetadataManager = new AudioMetadataMangaer(this.db, this.taskManager)
     this.rssFeedManager = new RssFeedManager(this.db)
     this.eBookManager = new EBookManager(this.db)

server/managers/PodcastManager.js

@@ -14,12 +14,15 @@ const LibraryFile = require('../objects/files/LibraryFile')
 const PodcastEpisodeDownload = require('../objects/PodcastEpisodeDownload')
 const PodcastEpisode = require('../objects/entities/PodcastEpisode')
 const AudioFile = require('../objects/files/AudioFile')
+const Task = require("../objects/Task");
+const Path = require("path");
 
 class PodcastManager {
-  constructor(db, watcher, notificationManager) {
+  constructor(db, watcher, notificationManager, taskManager) {
     this.db = db
     this.watcher = watcher
     this.notificationManager = notificationManager
+    this.taskManager = taskManager
 
     this.downloadQueue = []
     this.currentDownload = null
@@ -57,11 +60,11 @@ class PodcastManager {
       newPe.libraryItemId = libraryItem.id
       var newPeDl = new PodcastEpisodeDownload()
       newPeDl.setData(newPe, libraryItem, isAutoDownload, libraryItem.libraryId)
-      this.startPodcastEpisodeDownload(newPeDl)
+      this.startPodcastEpisodeDownload(newPeDl, libraryItem)
     })
   }
 
-  async startPodcastEpisodeDownload(podcastEpisodeDownload) {
+  async startPodcastEpisodeDownload(podcastEpisodeDownload, libraryItem) {
     SocketAuthority.emitter('download_queue_updated', this.getDownloadQueueDetails())
     if (this.currentDownload) {
       this.downloadQueue.push(podcastEpisodeDownload)
@@ -69,6 +72,15 @@ class PodcastManager {
       return
     }
 
+    const task = new Task()
+    const taskDescription = `Downloading episode "${podcastEpisodeDownload.podcastEpisode.title}".`
+    const taskData = {
+      libraryId: libraryItem.libraryId,
+      libraryItemId: libraryItem.id,
+    }
+    task.setData('download-podcast-episode', 'Downloading Episode', taskDescription, taskData)
+    this.taskManager.addTask(task)
+
     SocketAuthority.emitter('episode_download_started', podcastEpisodeDownload.toJSONForClient())
     this.currentDownload = podcastEpisodeDownload
 
@@ -91,21 +103,26 @@ class PodcastManager {
       if (!success) {
         await fs.remove(this.currentDownload.targetPath)
         this.currentDownload.setFinished(false)
+        task.setFailed('Failed to download episode')
       } else {
         Logger.info(`[PodcastManager] Successfully downloaded podcast episode "${this.currentDownload.podcastEpisode.title}"`)
         this.currentDownload.setFinished(true)
+        task.setFinished()
       }
     } else {
+      task.setFailed('Failed to download episode')
       this.currentDownload.setFinished(false)
     }
 
+    this.taskManager.taskFinished(task)
+
     SocketAuthority.emitter('episode_download_finished', this.currentDownload.toJSONForClient())
     SocketAuthority.emitter('download_queue_updated', this.getDownloadQueueDetails())
 
     this.watcher.removeIgnoreDir(this.currentDownload.libraryItem.path)
     this.currentDownload = null
     if (this.downloadQueue.length) {
-      this.startPodcastEpisodeDownload(this.downloadQueue.shift())
+      this.startPodcastEpisodeDownload(this.downloadQueue.shift(), libraryItem)
     }
   }