groove/audiobookshelf
1
0
Fork 0
mirror of https://github.com/advplyr/audiobookshelf.git synced 2026-07-10 03:11:34 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Updated to use new NotificationManager singleton.

Browse source
This commit is contained in:
matt 2024-09-27 20:23:58 -05:00
parent a5ef1d4d0e
commit 9513580043
1 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

12
server/scanner/LibraryScanner.js
View file

@ -14,10 +14,10 @@ const LibraryItemScanner = require('./LibraryItemScanner')
const LibraryScan = require('./LibraryScan') const LibraryScan = require('./LibraryScan')
const LibraryItemScanData = require('./LibraryItemScanData') const LibraryItemScanData = require('./LibraryItemScanData')
const Task = require('../objects/Task') const Task = require('../objects/Task')
const NotificationManager = require('../managers/NotificationManager')
class LibraryScanner { class LibraryScanner {
constructor(notificationManager) { constructor() {
this.notificationManager = notificationManager
this.cancelLibraryScan = {} this.cancelLibraryScan = {}
/** @type {string[]} - library ids */ /** @type {string[]} - library ids */
this.librariesScanning = [] this.librariesScanning = []
@ -285,7 +285,7 @@ class LibraryScanner {
'items_added', 'items_added',
newOldLibraryItems.map((li) => li.toJSONExpanded()) newOldLibraryItems.map((li) => li.toJSONExpanded())
) )
this.notificationManager.onItemsAdded(newOldLibraryItems) NotificationManager.onItemsAdded(newOldLibraryItems)
newOldLibraryItems = [] newOldLibraryItems = []
} }
@ -298,7 +298,7 @@ class LibraryScanner {
'items_added', 'items_added',
newOldLibraryItems.map((li) => li.toJSONExpanded()) newOldLibraryItems.map((li) => li.toJSONExpanded())
) )
this.notificationManager.onItemsAdded(newOldLibraryItems) NotificationManager.onItemsAdded(newOldLibraryItems)
} }
} }
@ -650,7 +650,7 @@ class LibraryScanner {
if (newLibraryItem) { if (newLibraryItem) {
const oldNewLibraryItem = Database.libraryItemModel.getOldLibraryItem(newLibraryItem) const oldNewLibraryItem = Database.libraryItemModel.getOldLibraryItem(newLibraryItem)
SocketAuthority.emitter('item_added', oldNewLibraryItem.toJSONExpanded()) SocketAuthority.emitter('item_added', oldNewLibraryItem.toJSONExpanded())
this.notificationManager.onItemsAdded([oldNewLibraryItem]) NotificationManager.onItemsAdded([oldNewLibraryItem])
} }
itemGroupingResults[itemDir] = newLibraryItem ? ScanResult.ADDED : ScanResult.NOTHING itemGroupingResults[itemDir] = newLibraryItem ? ScanResult.ADDED : ScanResult.NOTHING
} }
@ -658,7 +658,7 @@ class LibraryScanner {
return itemGroupingResults return itemGroupingResults
} }
} }
module.exports = new LibraryScanner(new NotificationManager()) module.exports = new LibraryScanner()
function ItemToFileInoMatch(libraryItem1, libraryItem2) { function ItemToFileInoMatch(libraryItem1, libraryItem2) {
return libraryItem1.isFile && libraryItem2.libraryFiles.some((lf) => lf.ino === libraryItem1.ino) return libraryItem1.isFile && libraryItem2.libraryFiles.some((lf) => lf.ino === libraryItem1.ino)