providers (#73)

Author: Sudashiii

sake/src/lib/server/application/composition.ts

@@ -88,6 +88,9 @@ import { MetadataAggregatorService } from '$lib/server/application/services/Meta
 import { ExternalBookMetadataService } from '$lib/server/application/services/ExternalBookMetadataService';
 import { GoogleBooksMetadataProvider } from '$lib/server/infrastructure/metadata-providers/googleBooksMetadataProvider';
 import { OpenLibraryMetadataProvider } from '$lib/server/infrastructure/metadata-providers/openLibraryMetadataProvider';
+import { createMetadataProviders } from '$lib/server/infrastructure/metadata-providers/metadataProviderFactory';
+import { getActivatedMetadataProviders } from '$lib/server/config/activatedMetadataProviders';
+import { SearchMetadataCandidatesUseCase } from '$lib/server/application/use-cases/SearchMetadataCandidatesUseCase';
 import { ManagedBookCoverService } from '$lib/server/application/services/ManagedBookCoverService';
 import { GetLibraryCoverUseCase } from '$lib/server/application/use-cases/GetLibraryCoverUseCase';
 import { ImportLibraryBookCoverUseCase } from '$lib/server/application/use-cases/ImportLibraryBookCoverUseCase';
@@ -125,6 +128,9 @@ export const externalBookMetadataService = new ExternalBookMetadataService(
 	baselineMetadataAggregator
 );
 
+export const activatedMetadataProviders = createMetadataProviders(getActivatedMetadataProviders());
+export const activatedMetadataAggregator = new MetadataAggregatorService(activatedMetadataProviders);
+
 export const downloadBookUseCase = new DownloadBookUseCase(
 	zlibraryClient,
 	bookRepository,
@@ -297,3 +303,7 @@ export const updateShelfRulesUseCase = new UpdateShelfRulesUseCase(shelfReposito
 export const reorderShelvesUseCase = new ReorderShelvesUseCase(shelfRepository);
 export const deleteShelfUseCase = new DeleteShelfUseCase(shelfRepository);
 export const setBookShelvesUseCase = new SetBookShelvesUseCase(bookRepository, shelfRepository);
+export const searchMetadataCandidatesUseCase = new SearchMetadataCandidatesUseCase(
+	activatedMetadataAggregator,
+	bookRepository
+);

sake/src/lib/server/application/use-cases/SearchMetadataCandidatesUseCase.ts

@@ -0,0 +1,52 @@
+import type { BookRepositoryPort } from '$lib/server/application/ports/BookRepositoryPort';
+import type { MetadataQuery } from '$lib/server/application/ports/MetadataProviderPort';
+import {
+	MetadataAggregatorService,
+	type MetadataAggregatorResult
+} from '$lib/server/application/services/MetadataAggregatorService';
+import { apiError, apiOk, type ApiResult } from '$lib/server/http/api';
+
+export interface SearchMetadataCandidatesInput {
+	bookId?: number;
+	query?: MetadataQuery;
+}
+
+export type SearchMetadataCandidatesResult = MetadataAggregatorResult;
+
+export class SearchMetadataCandidatesUseCase {
+	constructor(
+		private readonly aggregator: MetadataAggregatorService,
+		private readonly bookRepository: BookRepositoryPort
+	) {}
+
+	async execute(
+		input: SearchMetadataCandidatesInput
+	): Promise<ApiResult<SearchMetadataCandidatesResult>> {
+		if (input.bookId == null && input.query == null) {
+			return apiError('Either bookId or query must be provided', 400);
+		}
+
+		let query: MetadataQuery;
+
+		if (input.bookId != null) {
+			const book = await this.bookRepository.getById(input.bookId);
+			if (!book) {
+				return apiError('Book not found', 404);
+			}
+			query = {
+				title: book.title,
+				author: book.author ?? null,
+				isbn: book.identifier ?? null,
+				language: book.language ?? null,
+				googleBooksId: book.google_books_id ?? null,
+				openLibraryKey: book.open_library_key ?? null,
+				...input.query
+			};
+		} else {
+			query = input.query!;
+		}
+
+		const result = await this.aggregator.lookup(query);
+		return apiOk(result);
+	}
+}