Remove invalid RSS feeds on init and remove feeds when associated entity is removed

server/Db.js

@@ -280,7 +280,7 @@ class Db {
   }
 
   getAllEntities(entityName) {
-    var entityDb = this.getEntityDb(entityName)
+    const entityDb = this.getEntityDb(entityName)
     return entityDb.select(() => true).then((results) => results.data).catch((error) => {
       Logger.error(`[DB] Failed to get all ${entityName}`, error)
       return null
@@ -371,16 +371,16 @@ class Db {
   }
 
   updateEntity(entityName, entity) {
-    var entityDb = this.getEntityDb(entityName)
+    const entityDb = this.getEntityDb(entityName)
 
-    var jsonEntity = entity
+    let jsonEntity = entity
     if (entity && entity.toJSON) {
       jsonEntity = entity.toJSON()
     }
 
     return entityDb.update((record) => record.id === entity.id, () => jsonEntity).then((results) => {
       Logger.debug(`[DB] Updated ${entityName}: ${results.updated}`)
-      var arrayKey = this.getEntityArrayKey(entityName)
+      const arrayKey = this.getEntityArrayKey(entityName)
       if (this[arrayKey]) {
         this[arrayKey] = this[arrayKey].map(e => {
           return e.id === entity.id ? entity : e

server/controllers/CollectionController.js

@@ -40,8 +40,8 @@ class CollectionController {
 
   async update(req, res) {
     const collection = req.collection
-    var wasUpdated = collection.update(req.body)
+    const wasUpdated = collection.update(req.body)
-    var jsonExpanded = collection.toJSONExpanded(this.db.libraryItems)
+    const jsonExpanded = collection.toJSONExpanded(this.db.libraryItems)
     if (wasUpdated) {
       await this.db.updateEntity('collection', collection)
       SocketAuthority.emitter('collection_updated', jsonExpanded)
@@ -51,7 +51,11 @@ class CollectionController {
 
   async delete(req, res) {
     const collection = req.collection
-    var jsonExpanded = collection.toJSONExpanded(this.db.libraryItems)
+    const jsonExpanded = collection.toJSONExpanded(this.db.libraryItems)
+
+    // Close rss feed - remove from db and emit socket event
+    await this.rssFeedManager.closeFeedForEntityId(collection.id)
+
     await this.db.removeEntity('collection', collection.id)
     SocketAuthority.emitter('collection_removed', jsonExpanded)
     res.sendStatus(200)
@@ -59,7 +63,7 @@ class CollectionController {
 
   async addBook(req, res) {
     const collection = req.collection
-    var libraryItem = this.db.libraryItems.find(li => li.id === req.body.id)
+    const libraryItem = this.db.libraryItems.find(li => li.id === req.body.id)
     if (!libraryItem) {
       return res.status(500).send('Book not found')
     }
@@ -70,7 +74,7 @@ class CollectionController {
       return res.status(500).send('Book already in collection')
     }
     collection.addBook(req.body.id)
-    var jsonExpanded = collection.toJSONExpanded(this.db.libraryItems)
+    const jsonExpanded = collection.toJSONExpanded(this.db.libraryItems)
     await this.db.updateEntity('collection', collection)
     SocketAuthority.emitter('collection_updated', jsonExpanded)
     res.json(jsonExpanded)

server/managers/RssFeedManager.js

@@ -17,14 +17,43 @@ class RssFeedManager {
     return Object.values(this.feeds)
   }
 
+  validateFeedEntity(feedObj) {
+    if (feedObj.entityType === 'collection') {
+      if (!this.db.collections.some(li => li.id === feedObj.entityId)) {
+        Logger.error(`[RssFeedManager] Removing feed "${feedObj.id}". Collection "${feedObj.entityId}" not found`)
+        return false
+      }
+    } else if (feedObj.entityType === 'libraryItem') {
+      if (!this.db.libraryItems.some(li => li.id === feedObj.entityId)) {
+        Logger.error(`[RssFeedManager] Removing feed "${feedObj.id}". Library item "${feedObj.entityId}" not found`)
+        return false
+      }
+    } else {
+      Logger.error(`[RssFeedManager] Removing feed "${feedObj.id}". Invalid entityType "${feedObj.entityType}"`)
+      return false
+    }
+    return true
+  }
+
   async init() {
     const feedObjects = await this.db.getAllEntities('feed')
-    if (feedObjects && feedObjects.length) {
+    if (!feedObjects || !feedObjects.length) return
-      feedObjects.forEach((feedObj) => {
+
-        const feed = new Feed(feedObj)
+    for (const feedObj of feedObjects) {
-        this.feeds[feed.id] = feed
+      // Migration: In v2.2.12 entityType "item" was updated to "libraryItem"
-        Logger.info(`[RssFeedManager] Opened rss feed ${feed.feedUrl}`)
+      if (feedObj.entityType === 'item') {
-      })
+        feedObj.entityType = 'libraryItem'
+        await this.db.updateEntity('feed', feedObj)
+      }
+
+      // Remove invalid feeds
+      if (!this.validateFeedEntity(feedObj)) {
+        await this.db.removeEntity('feed', feedObj.id)
+      }
+
+      const feed = new Feed(feedObj)
+      this.feeds[feed.id] = feed
+      Logger.info(`[RssFeedManager] Opened rss feed ${feed.feedUrl}`)
     }
   }
 
@@ -141,13 +170,23 @@ class RssFeedManager {
     return feed
   }
 
-  async closeRssFeed(id) {
+  async handleCloseFeed(feed) {
-    if (!this.feeds[id]) return
+    if (!feed) return
-    const feed = this.feeds[id]
+    await this.db.removeEntity('feed', feed.id)
-    await this.db.removeEntity('feed', id)
     SocketAuthority.emitter('rss_feed_closed', feed.toJSONMinified())
-    delete this.feeds[id]
+    delete this.feeds[feed.id]
     Logger.info(`[RssFeedManager] Closed RSS feed "${feed.feedUrl}"`)
   }
+
+  closeRssFeed(id) {
+    if (!this.feeds[id]) return
+    return this.handleCloseFeed(this.feeds[id])
+  }
+
+  closeFeedForEntityId(entityId) {
+    const feed = this.findFeedForEntityId(entityId)
+    if (!feed) return
+    return this.handleCloseFeed(feed)
+  }
 }
 module.exports = RssFeedManager

server/objects/Feed.js

@@ -87,7 +87,7 @@ class Feed {
     this.id = slug
     this.slug = slug
     this.userId = userId
-    this.entityType = 'item'
+    this.entityType = 'libraryItem'
     this.entityId = libraryItem.id
     this.entityUpdatedAt = libraryItem.updatedAt
     this.coverPath = media.coverPath || null

server/routers/ApiRouter.js

@@ -386,6 +386,9 @@ class ApiRouter {
       }
     }
 
+    // Close rss feed - remove from db and emit socket event
+    await this.rssFeedManager.closeFeedForEntityId(libraryItem.id)
+
     // purge cover cache
     if (libraryItem.media.coverPath) {
       await this.cacheManager.purgeCoverCache(libraryItem.id)