From 7920f610e5ed283d47614c24001edc05851ea386 Mon Sep 17 00:00:00 2001 From: tsolo4ever Date: Fri, 6 Mar 2026 05:52:52 -0600 Subject: [PATCH 01/49] feat: add Library Import page (Sonarr-style) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - New route /library-import with full-page import UX - Pinia store (libraryImport.ts) with FIFO lookup queue, scan, per-row search, and batch import - LibraryImportRow.vue: checkbox, folder path, detected metadata, inline match search with debounce - LibraryImportFooter.vue: sticky toolbar with Start Processing / Cancel / Import buttons and rate-limit warning (>100 lookups) - LibraryImportView.vue: root folder selector, scan button, last-scanned timestamp, results table - Uncomment nav link in App.vue; add PhFolderOpen import - Queue processes one item at a time (naturally rate-limit safe, matching Sonarr's approach) - UnmatchedFilesModal.vue unchanged — additive change Co-Authored-By: Claude Sonnet 4.6 --- fe/src/App.vue | 12 +- .../domain/audiobook/LibraryImportFooter.vue | 210 +++++++++ .../domain/audiobook/LibraryImportRow.vue | 428 ++++++++++++++++++ fe/src/stores/libraryImport.ts | 356 +++++++++++++++ fe/src/views/library/LibraryImportView.vue | 326 +++++++++++-- 5 files changed, 1302 insertions(+), 30 deletions(-) create mode 100644 fe/src/components/domain/audiobook/LibraryImportFooter.vue create mode 100644 fe/src/components/domain/audiobook/LibraryImportRow.vue create mode 100644 fe/src/stores/libraryImport.ts diff --git a/fe/src/App.vue b/fe/src/App.vue index a49ef69..4bccff6 100644 --- a/fe/src/App.vue +++ b/fe/src/App.vue @@ -291,10 +291,17 @@ Calendar - +
@@ -485,6 +492,7 @@ import { PhDownload, PhCheckCircle, PhList, + PhFolderOpen, } from '@phosphor-icons/vue' import { ref, computed, onMounted, onUnmounted, nextTick, watch } from 'vue' import { useEventListener } from '@vueuse/core' diff --git a/fe/src/components/domain/audiobook/LibraryImportFooter.vue b/fe/src/components/domain/audiobook/LibraryImportFooter.vue new file mode 100644 index 0000000..0b72f45 --- /dev/null +++ b/fe/src/components/domain/audiobook/LibraryImportFooter.vue @@ -0,0 +1,210 @@ + + + + + diff --git a/fe/src/components/domain/audiobook/LibraryImportRow.vue b/fe/src/components/domain/audiobook/LibraryImportRow.vue new file mode 100644 index 0000000..c2efb21 --- /dev/null +++ b/fe/src/components/domain/audiobook/LibraryImportRow.vue @@ -0,0 +1,428 @@ + + + + + diff --git a/fe/src/stores/libraryImport.ts b/fe/src/stores/libraryImport.ts new file mode 100644 index 0000000..8edf68f --- /dev/null +++ b/fe/src/stores/libraryImport.ts @@ -0,0 +1,356 @@ +import { defineStore } from 'pinia' +import { ref, computed } from 'vue' +import { apiService } from '@/services/api' +import { signalRService } from '@/services/signalr' +import { logger } from '@/utils/logger' +import type { SearchResult, AudibleBookMetadata, UnmatchedFileItem } from '@/types' + +export interface LibraryImportItem { + id: string // = fullPath (unique key) + fullPath: string // path to audio file + folderPath: string // bookFolder (parent directory) + relativePath: string // relative to root folder + folderName: string // search term: last non-empty path segment + // Detected from file scan + detectedTitle?: string + detectedAuthor?: string + detectedAsin?: string + detectedSeries?: string + format: string + fileCount: number + // Match state + selectedMatch: SearchResult | null + hasSearched: boolean // true once auto-search was attempted + isSearching: boolean // currently in-flight + // Selection + selected: boolean +} + +function extractFolderName(relativePath: string): string { + const parts = relativePath.replace(/\\/g, '/').split('/').filter(Boolean) + // Prefer the last meaningful segment (author/title structure) + return parts[parts.length - 1] ?? relativePath +} + +function unmatchedToImportItem(item: UnmatchedFileItem): LibraryImportItem { + return { + id: item.fullPath, + fullPath: item.fullPath, + folderPath: item.bookFolder, + relativePath: item.relativePath, + folderName: extractFolderName(item.relativePath), + detectedTitle: item.title, + detectedAuthor: item.author, + detectedAsin: item.asin, + detectedSeries: item.series, + format: item.format, + fileCount: item.fileCount, + selectedMatch: null, + hasSearched: false, + isSearching: false, + selected: false, + } +} + +function matchToMetadata(result: SearchResult): AudibleBookMetadata { + const authors: string[] = + result.authors && result.authors.length > 0 + ? result.authors.map((a) => a.name ?? '').filter(Boolean) + : result.author + ? [result.author] + : [] + + return { + title: result.title ?? '', + asin: result.asin ?? '', + authors, + subtitle: result.subtitle, + series: result.series, + seriesNumber: result.seriesNumber, + seriesAsin: result.seriesAsin, + description: result.description, + publisher: result.publisher, + language: result.language, + runtime: result.runtime ?? (result.lengthMinutes ? result.lengthMinutes * 60 : undefined), + imageUrl: result.imageUrl, + genres: result.genres, + narrators: result.narrators?.map((n) => n.name ?? '').filter(Boolean), + publishYear: result.releaseDate?.substring(0, 4) ?? result.publishDate?.substring(0, 4), + metadataSource: result.metadataSource, + } +} + +export const useLibraryImportStore = defineStore('libraryImport', () => { + const items = ref>({}) + const lookupQueue = ref([]) + const isProcessing = ref(false) + const rootFolderId = ref(null) + const scanStatus = ref<'idle' | 'scanning' | 'done' | 'error'>('idle') + const scanError = ref(null) + const lastScannedAt = ref(null) + const inputMode = ref<'move' | 'hardlink/copy'>('move') + const metadataFetchCount = ref(0) + const importErrors = ref([]) + + // ─── Computed ──────────────────────────────────────────────────────────────── + + const itemList = computed(() => Object.values(items.value)) + const selectedCount = computed(() => itemList.value.filter((i) => i.selected).length) + const hasUnprocessedItems = computed(() => itemList.value.some((i) => !i.hasSearched)) + const processedCount = computed(() => itemList.value.filter((i) => i.hasSearched).length) + const matchedCount = computed(() => itemList.value.filter((i) => i.selectedMatch).length) + + // ─── Scan ───────────────────────────────────────────────────────────────── + + async function initFromRootFolder(id: number) { + rootFolderId.value = id + scanStatus.value = 'idle' + try { + const saved = await apiService.getSavedUnmatchedFiles(id) + if (saved.lastScannedAt) lastScannedAt.value = saved.lastScannedAt + const newItems: Record = {} + for (const item of saved.items) { + const existing = items.value[item.fullPath] + // Preserve match/search state if item already exists + newItems[item.fullPath] = existing + ? { ...unmatchedToImportItem(item), selectedMatch: existing.selectedMatch, hasSearched: existing.hasSearched, isSearching: false, selected: existing.selected } + : unmatchedToImportItem(item) + } + items.value = newItems + if (saved.items.length > 0) scanStatus.value = 'done' + } catch (e) { + logger.debug('[libraryImport] Failed to load saved results:', e) + } + } + + async function triggerScan(id: number) { + rootFolderId.value = id + scanStatus.value = 'scanning' + scanError.value = null + items.value = {} + + let jobId = '' + let offSignalR: (() => void) | null = null + + offSignalR = signalRService.onUnmatchedScanComplete(async (payload) => { + if (payload.jobId !== jobId) return + offSignalR?.() + if (payload.error) { + scanStatus.value = 'error' + scanError.value = payload.error + return + } + try { + const response = await apiService.getUnmatchedResults(payload.jobId) + _populateFromItems(response.items) + lastScannedAt.value = new Date().toISOString() + scanStatus.value = 'done' + } catch (e) { + scanStatus.value = 'error' + scanError.value = (e as Error)?.message ?? 'Failed to fetch results' + } + }) + + try { + const result = await apiService.scanUnmatchedFiles(id) + jobId = result.jobId + // Poll once immediately — handles fast scans before SignalR fires + const check = await apiService.getUnmatchedResults(jobId) + if (check.status === 'Completed') { + offSignalR?.() + _populateFromItems(check.items) + lastScannedAt.value = new Date().toISOString() + scanStatus.value = 'done' + } else if (check.status === 'Failed') { + offSignalR?.() + scanStatus.value = 'error' + scanError.value = check.error ?? 'Scan failed' + } + } catch (e) { + offSignalR?.() + scanStatus.value = 'error' + scanError.value = (e as Error)?.message ?? 'Failed to start scan' + } + } + + function _populateFromItems(scanItems: UnmatchedFileItem[]) { + const newItems: Record = {} + for (const item of scanItems) { + newItems[item.fullPath] = unmatchedToImportItem(item) + } + items.value = newItems + } + + // ─── Queue Processing ───────────────────────────────────────────────────── + + function startProcessing() { + const unsearched = itemList.value.filter((i) => !i.hasSearched).map((i) => i.id) + if (unsearched.length === 0) return + lookupQueue.value = unsearched + isProcessing.value = true + metadataFetchCount.value = 0 + processNext() + } + + function stopProcessing() { + lookupQueue.value = [] + isProcessing.value = false + // Clear any in-flight isSearching flags + for (const id of Object.keys(items.value)) { + if (items.value[id].isSearching) { + items.value[id] = { ...items.value[id], isSearching: false } + } + } + } + + async function processNext() { + if (!isProcessing.value || lookupQueue.value.length === 0) { + isProcessing.value = false + return + } + + const id = lookupQueue.value[0] + const item = items.value[id] + + if (!item) { + lookupQueue.value = lookupQueue.value.slice(1) + await processNext() + return + } + + items.value[id] = { ...item, isSearching: true } + + try { + const results = await apiService.advancedSearch({ title: item.folderName, cap: 5 }) + metadataFetchCount.value++ + const first = results[0] ?? null + items.value[id] = { + ...items.value[id], + isSearching: false, + hasSearched: true, + selectedMatch: first, + selected: first !== null, + } + } catch { + items.value[id] = { ...items.value[id], isSearching: false, hasSearched: true } + } + + lookupQueue.value = lookupQueue.value.slice(1) + await processNext() + } + + // ─── Per-row manual search ──────────────────────────────────────────────── + + async function searchItem(id: string, query: string) { + const item = items.value[id] + if (!item) return + + items.value[id] = { ...item, isSearching: true } + try { + const results = await apiService.advancedSearch({ title: query, cap: 5 }) + items.value[id] = { ...items.value[id], isSearching: false, hasSearched: true } + return results + } catch { + items.value[id] = { ...items.value[id], isSearching: false } + return [] + } + } + + // ─── Match management ───────────────────────────────────────────────────── + + function selectMatch(id: string, match: SearchResult) { + const item = items.value[id] + if (!item) return + items.value[id] = { ...item, selectedMatch: match, hasSearched: true, selected: true } + } + + function clearMatch(id: string) { + const item = items.value[id] + if (!item) return + items.value[id] = { ...item, selectedMatch: null, selected: false } + } + + // ─── Selection ──────────────────────────────────────────────────────────── + + function toggleSelect(id: string) { + const item = items.value[id] + if (!item) return + items.value[id] = { ...item, selected: !item.selected } + } + + function toggleSelectAll() { + const allSelected = itemList.value.filter((i) => i.selectedMatch).every((i) => i.selected) + for (const item of itemList.value) { + if (item.selectedMatch) { + items.value[item.id] = { ...item, selected: !allSelected } + } + } + } + + // ─── Import ─────────────────────────────────────────────────────────────── + + async function importSelected(rootFolderPath: string): Promise<{ imported: number; errors: string[] }> { + const toImport = itemList.value.filter((i) => i.selected && i.selectedMatch) + importErrors.value = [] + let imported = 0 + + for (const item of toImport) { + const match = item.selectedMatch! + try { + const { audiobook } = await apiService.addToLibrary(matchToMetadata(match), { + destinationPath: rootFolderPath, + searchResult: match, + }) + await apiService.startManualImport({ + path: item.folderPath, + mode: 'interactive', + inputMode: inputMode.value, + items: [{ fullPath: item.fullPath, matchedAudiobookId: audiobook.id }], + }) + // Remove imported item from store + const updated = { ...items.value } + delete updated[item.id] + items.value = updated + imported++ + } catch (e) { + const msg = `${item.folderName}: ${(e as Error)?.message ?? 'Import failed'}` + importErrors.value.push(msg) + logger.debug('[libraryImport] Import error:', msg) + } + } + + return { imported, errors: importErrors.value } + } + + return { + // State + items, + lookupQueue, + isProcessing, + rootFolderId, + scanStatus, + scanError, + lastScannedAt, + inputMode, + metadataFetchCount, + importErrors, + // Computed + itemList, + selectedCount, + hasUnprocessedItems, + processedCount, + matchedCount, + // Actions + initFromRootFolder, + triggerScan, + startProcessing, + stopProcessing, + processNext, + searchItem, + selectMatch, + clearMatch, + toggleSelect, + toggleSelectAll, + importSelected, + } +}) diff --git a/fe/src/views/library/LibraryImportView.vue b/fe/src/views/library/LibraryImportView.vue index be9f337..59522e4 100644 --- a/fe/src/views/library/LibraryImportView.vue +++ b/fe/src/views/library/LibraryImportView.vue @@ -1,69 +1,339 @@ From f9cc168a94ef3dd9832d73245a6016f403713851 Mon Sep 17 00:00:00 2001 From: tsolo4ever Date: Fri, 6 Mar 2026 06:00:09 -0600 Subject: [PATCH 02/49] fix: resolve CI TypeScript errors in Library Import MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - SearchResult has no 'author' string field — use authors[] only - Narrow lookupQueue[0] with non-null assertion to satisfy strict index checks - Use object spread assignment instead of direct index mutation for items record Co-Authored-By: Claude Sonnet 4.6 --- .../domain/audiobook/LibraryImportRow.vue | 6 ++--- fe/src/stores/libraryImport.ts | 26 +++++++++---------- 2 files changed, 15 insertions(+), 17 deletions(-) diff --git a/fe/src/components/domain/audiobook/LibraryImportRow.vue b/fe/src/components/domain/audiobook/LibraryImportRow.vue index c2efb21..dd82a6b 100644 --- a/fe/src/components/domain/audiobook/LibraryImportRow.vue +++ b/fe/src/components/domain/audiobook/LibraryImportRow.vue @@ -39,8 +39,8 @@ {{ item.selectedMatch.title }} - - {{ item.selectedMatch.authors?.[0]?.name ?? item.selectedMatch.author }} + + {{ item.selectedMatch.authors[0]?.name }}
@@ -92,7 +92,7 @@
{{ result.title }} - {{ result.authors?.[0]?.name ?? result.author }} + {{ result.authors?.[0]?.name }} · {{ result.series }} · {{ result.asin }} diff --git a/fe/src/stores/libraryImport.ts b/fe/src/stores/libraryImport.ts index 8edf68f..baee3dd 100644 --- a/fe/src/stores/libraryImport.ts +++ b/fe/src/stores/libraryImport.ts @@ -56,9 +56,7 @@ function matchToMetadata(result: SearchResult): AudibleBookMetadata { const authors: string[] = result.authors && result.authors.length > 0 ? result.authors.map((a) => a.name ?? '').filter(Boolean) - : result.author - ? [result.author] - : [] + : [] return { title: result.title ?? '', @@ -197,8 +195,9 @@ export const useLibraryImportStore = defineStore('libraryImport', () => { isProcessing.value = false // Clear any in-flight isSearching flags for (const id of Object.keys(items.value)) { - if (items.value[id].isSearching) { - items.value[id] = { ...items.value[id], isSearching: false } + const entry = items.value[id] + if (entry?.isSearching) { + items.value = { ...items.value, [id]: { ...entry, isSearching: false } } } } } @@ -209,7 +208,7 @@ export const useLibraryImportStore = defineStore('libraryImport', () => { return } - const id = lookupQueue.value[0] + const id: string = lookupQueue.value[0]! const item = items.value[id] if (!item) { @@ -218,21 +217,20 @@ export const useLibraryImportStore = defineStore('libraryImport', () => { return } - items.value[id] = { ...item, isSearching: true } + items.value = { ...items.value, [id]: { ...item, isSearching: true } } try { const results = await apiService.advancedSearch({ title: item.folderName, cap: 5 }) metadataFetchCount.value++ const first = results[0] ?? null - items.value[id] = { - ...items.value[id], - isSearching: false, - hasSearched: true, - selectedMatch: first, - selected: first !== null, + const current = items.value[id]! + items.value = { + ...items.value, + [id]: { ...current, isSearching: false, hasSearched: true, selectedMatch: first, selected: first !== null }, } } catch { - items.value[id] = { ...items.value[id], isSearching: false, hasSearched: true } + const current = items.value[id] + if (current) items.value = { ...items.value, [id]: { ...current, isSearching: false, hasSearched: true } } } lookupQueue.value = lookupQueue.value.slice(1) From ab426710733ea05a97f68c87e72b6efc7b4a8681 Mon Sep 17 00:00:00 2001 From: tsolo4ever Date: Fri, 6 Mar 2026 06:15:40 -0600 Subject: [PATCH 03/49] fix: prefer detectedTitle over folderName for auto-search queries Folder names often contain year prefixes and series brackets (e.g. "2021 - Cleave's Edge [Morcster Chef 1]") which produce poor search results. When file tags provide a clean detectedTitle, use that instead for both auto-processing queue searches and the inline search pre-fill. Co-Authored-By: Claude Sonnet 4.6 --- fe/src/components/domain/audiobook/LibraryImportRow.vue | 2 +- fe/src/stores/libraryImport.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/src/components/domain/audiobook/LibraryImportRow.vue b/fe/src/components/domain/audiobook/LibraryImportRow.vue index dd82a6b..5aaeb80 100644 --- a/fe/src/components/domain/audiobook/LibraryImportRow.vue +++ b/fe/src/components/domain/audiobook/LibraryImportRow.vue @@ -120,7 +120,7 @@ const props = defineProps<{ item: LibraryImportItem }>() const store = useLibraryImportStore() const showSearch = ref(false) -const searchQuery = ref(props.item.folderName) +const searchQuery = ref(props.item.detectedTitle ?? props.item.folderName) const searchResults = ref([]) const isLocalSearching = ref(false) const hasSearched = ref(false) diff --git a/fe/src/stores/libraryImport.ts b/fe/src/stores/libraryImport.ts index baee3dd..fccdccc 100644 --- a/fe/src/stores/libraryImport.ts +++ b/fe/src/stores/libraryImport.ts @@ -220,7 +220,7 @@ export const useLibraryImportStore = defineStore('libraryImport', () => { items.value = { ...items.value, [id]: { ...item, isSearching: true } } try { - const results = await apiService.advancedSearch({ title: item.folderName, cap: 5 }) + const results = await apiService.advancedSearch({ title: item.detectedTitle ?? item.folderName, cap: 5 }) metadataFetchCount.value++ const first = results[0] ?? null const current = items.value[id]! From ac836d69d1bd04a51e1863cc9b86558ec6f1f75b Mon Sep 17 00:00:00 2001 From: tsolo4ever Date: Fri, 6 Mar 2026 06:20:11 -0600 Subject: [PATCH 04/49] fix: use detectedAsin for auto-search when available ASIN from file tags gives an exact match via advancedSearch({ asin }). Falls back to detectedTitle, then folderName for title search. Inline search panel pre-fill follows the same priority. Co-Authored-By: Claude Sonnet 4.6 --- fe/src/components/domain/audiobook/LibraryImportRow.vue | 2 +- fe/src/stores/libraryImport.ts | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/fe/src/components/domain/audiobook/LibraryImportRow.vue b/fe/src/components/domain/audiobook/LibraryImportRow.vue index 5aaeb80..ff9aaf6 100644 --- a/fe/src/components/domain/audiobook/LibraryImportRow.vue +++ b/fe/src/components/domain/audiobook/LibraryImportRow.vue @@ -120,7 +120,7 @@ const props = defineProps<{ item: LibraryImportItem }>() const store = useLibraryImportStore() const showSearch = ref(false) -const searchQuery = ref(props.item.detectedTitle ?? props.item.folderName) +const searchQuery = ref(props.item.detectedAsin ?? props.item.detectedTitle ?? props.item.folderName) const searchResults = ref([]) const isLocalSearching = ref(false) const hasSearched = ref(false) diff --git a/fe/src/stores/libraryImport.ts b/fe/src/stores/libraryImport.ts index fccdccc..f92dd4a 100644 --- a/fe/src/stores/libraryImport.ts +++ b/fe/src/stores/libraryImport.ts @@ -220,7 +220,10 @@ export const useLibraryImportStore = defineStore('libraryImport', () => { items.value = { ...items.value, [id]: { ...item, isSearching: true } } try { - const results = await apiService.advancedSearch({ title: item.detectedTitle ?? item.folderName, cap: 5 }) + const searchParams = item.detectedAsin + ? { asin: item.detectedAsin, cap: 5 } + : { title: item.detectedTitle ?? item.folderName, cap: 5 } + const results = await apiService.advancedSearch(searchParams) metadataFetchCount.value++ const first = results[0] ?? null const current = items.value[id]! From 6b87601a9d10eb57985d1602769b78765952bddb Mon Sep 17 00:00:00 2001 From: tsolo4ever Date: Thu, 5 Mar 2026 03:40:30 -0600 Subject: [PATCH 05/49] feat: add root folder unmatched file scanner MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Scans a root folder for audio files not already in the library, parses metadata from the folder path structure and sidecar files (desc.txt, reader.txt), and surfaces results for manual review. Users can add each unmatched book to the library via the existing AddLibraryModal and optionally link the file via manual-import. - PathMetadataParser: parses {Author}/{Series}/{Year} - {Title} [{Series} #]/ folder structure plus desc.txt and reader.txt sidecar files - UnmatchedScanQueueService: channel-based background job queue - UnmatchedScanBackgroundService: walks root folder, compares against tracked AudiobookFiles in DB, groups by book folder, pushes UnmatchedScanComplete via SettingsHub SignalR on completion - RootFoldersController: POST /{id}/scan-unmatched and GET /unmatched-results/{jobId} endpoints - UnmatchedFilesModal: two-phase modal (scan progress → results table with Add/Ignore per row) launched from root folder card - RootFoldersSettings: magnifying glass button on each folder card Co-Authored-By: Claude Sonnet 4.6 --- .../feedback/UnmatchedFilesModal.vue | 380 ++++++++++++++++++ .../settings/RootFoldersSettings.vue | 32 +- fe/src/services/api.ts | 11 + fe/src/services/signalr.ts | 20 + fe/src/types/index.ts | 28 ++ .../Controllers/RootFoldersController.cs | 36 +- .../HostedServiceRegistrationExtensions.cs | 5 + listenarr.api/Services/PathMetadataParser.cs | 122 ++++++ .../UnmatchedScanBackgroundService.cs | 174 ++++++++ .../Services/UnmatchedScanQueueService.cs | 86 ++++ 10 files changed, 889 insertions(+), 5 deletions(-) create mode 100644 fe/src/components/feedback/UnmatchedFilesModal.vue create mode 100644 listenarr.api/Services/PathMetadataParser.cs create mode 100644 listenarr.api/Services/UnmatchedScanBackgroundService.cs create mode 100644 listenarr.api/Services/UnmatchedScanQueueService.cs diff --git a/fe/src/components/feedback/UnmatchedFilesModal.vue b/fe/src/components/feedback/UnmatchedFilesModal.vue new file mode 100644 index 0000000..4113d45 --- /dev/null +++ b/fe/src/components/feedback/UnmatchedFilesModal.vue @@ -0,0 +1,380 @@ + + + + + diff --git a/fe/src/components/settings/RootFoldersSettings.vue b/fe/src/components/settings/RootFoldersSettings.vue index ffb5cf3..a7470fc 100644 --- a/fe/src/components/settings/RootFoldersSettings.vue +++ b/fe/src/components/settings/RootFoldersSettings.vue @@ -39,6 +39,14 @@
+