using System; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using API.Data; using API.Data.Repositories; using API.DTOs; using API.Entities; using API.Extensions; using API.Helpers.Builders; using Kavita.Common; namespace API.Services; public interface IReadingProfileService { /// /// Returns the ReadingProfile that should be applied to the given series, walks up the tree. /// Series -> Library -> Default /// /// /// /// Task GetReadingProfileForSeries(int userId, int seriesId); /// /// Updates a given reading profile for a user /// /// /// /// Task UpdateReadingProfile(int userId, UserReadingProfileDto dto); /// /// Creates a new reading profile for a user. Name must be unique per user /// /// /// /// Task CreateReadingProfile(int userId, UserReadingProfileDto dto); /// /// Updates the implicit reading profile for a series, creates one if none exists /// /// /// /// /// Task UpdateImplicitReadingProfile(int userId, int seriesId, UserReadingProfileDto dto); /// /// Deletes the implicit reading profile for a given series, if it exists /// /// /// /// Task DeleteImplicitForSeries(int userId, int seriesId); /// /// Deletes a given profile for a user /// /// /// /// /// /// The default profile for the user cannot be deleted Task DeleteReadingProfile(int userId, int profileId); /// /// Sets the given profile as global default /// /// /// /// Task SetDefaultReadingProfile(int userId, int profileId); } public class ReadingProfileService(IUnitOfWork unitOfWork, ILocalizationService localizationService): IReadingProfileService { public async Task GetReadingProfileForSeries(int userId, int seriesId) { var seriesProfile = await unitOfWork.AppUserReadingProfileRepository.GetProfileDtoForSeries(userId, seriesId); if (seriesProfile != null) return seriesProfile; var series = await unitOfWork.SeriesRepository.GetSeriesByIdAsync(seriesId); if (series == null) throw new KavitaException(await localizationService.Translate(userId, "series-doesnt-exist")); var libraryProfile = await unitOfWork.AppUserReadingProfileRepository.GetProfileDtoForLibrary(userId, series.LibraryId); if (libraryProfile != null) return libraryProfile; var user = await unitOfWork.UserRepository.GetUserByIdAsync(userId, AppUserIncludes.UserPreferences); if (user == null) throw new UnauthorizedAccessException(); return await unitOfWork.AppUserReadingProfileRepository.GetProfileDto(user.UserPreferences.DefaultReadingProfileId); } public async Task UpdateReadingProfile(int userId, UserReadingProfileDto dto) { var user = await unitOfWork.UserRepository.GetUserByIdAsync(userId, AppUserIncludes.UserPreferences); if (user == null) throw new UnauthorizedAccessException(); var existingProfile = await unitOfWork.AppUserReadingProfileRepository.GetProfile(dto.Id); if (existingProfile == null) throw new KavitaException("profile-does-not-exist"); if (existingProfile.UserId != userId) throw new UnauthorizedAccessException(); UpdateReaderProfileFields(existingProfile, dto); unitOfWork.AppUserReadingProfileRepository.Update(existingProfile); return await unitOfWork.CommitAsync(); } public async Task CreateReadingProfile(int userId, UserReadingProfileDto dto) { var user = await unitOfWork.UserRepository.GetUserByIdAsync(userId, AppUserIncludes.UserPreferences); if (user == null) throw new UnauthorizedAccessException(); var other = await unitOfWork.AppUserReadingProfileRepository.GetProfileByName(userId, dto.Name); if (other != null) throw new KavitaException("name-already-in-use"); var newProfile = new AppUserReadingProfileBuilder(user.Id).Build(); UpdateReaderProfileFields(newProfile, dto); unitOfWork.AppUserReadingProfileRepository.Add(newProfile); await unitOfWork.CommitAsync(); return await unitOfWork.AppUserReadingProfileRepository.GetProfileDto(newProfile.Id); } public async Task UpdateImplicitReadingProfile(int userId, int seriesId, UserReadingProfileDto dto) { var user = await unitOfWork.UserRepository.GetUserByIdAsync(userId, AppUserIncludes.UserPreferences); if (user == null) throw new UnauthorizedAccessException(); var existingProfile = await unitOfWork.AppUserReadingProfileRepository.GetProfileForSeries(userId, seriesId); // Series already had an implicit profile, update it if (existingProfile is {Implicit: true}) { UpdateReaderProfileFields(existingProfile, dto, false); unitOfWork.AppUserReadingProfileRepository.Update(existingProfile); return await unitOfWork.CommitAsync(); } var series = await unitOfWork.SeriesRepository.GetSeriesByIdAsync(seriesId) ?? throw new KeyNotFoundException(); existingProfile = new AppUserReadingProfileBuilder(userId) .WithSeries(series) .WithImplicit(true) .Build(); UpdateReaderProfileFields(existingProfile, dto, false); existingProfile.Name = $"Implicit Profile for {seriesId}"; existingProfile.NormalizedName = existingProfile.Name.ToNormalized(); user.UserPreferences.ReadingProfiles.Add(existingProfile); return await unitOfWork.CommitAsync(); } public async Task DeleteImplicitForSeries(int userId, int seriesId) { var profile = await unitOfWork.AppUserReadingProfileRepository.GetProfileForSeries(userId, seriesId, ReadingProfileIncludes.Series); if (profile == null) return; if (!profile.Implicit) return; profile.Series = profile.Series.Where(s => s.Id != seriesId).ToList(); await unitOfWork.CommitAsync(); } public async Task DeleteReadingProfile(int userId, int profileId) { var profile = await unitOfWork.AppUserReadingProfileRepository.GetProfile(profileId); if (profile == null) throw new KavitaException(await localizationService.Translate(userId, "profile-doesnt-exist")); var user = await unitOfWork.UserRepository.GetUserByIdAsync(userId, AppUserIncludes.UserPreferences); if (user == null || profile.UserId != userId) throw new UnauthorizedAccessException(); if (user.UserPreferences.DefaultReadingProfileId == profileId) throw new KavitaException("cant-delete-default-profile"); unitOfWork.AppUserReadingProfileRepository.Remove(profile); await unitOfWork.CommitAsync(); } public async Task SetDefaultReadingProfile(int userId, int profileId) { var profile = await unitOfWork.AppUserReadingProfileRepository.GetProfile(profileId); if (profile == null) throw new KavitaException("profile-not-found"); if (profile.UserId != userId) throw new UnauthorizedAccessException(); var user = await unitOfWork.UserRepository.GetUserByIdAsync(userId, AppUserIncludes.UserPreferences); if (user == null) throw new UnauthorizedAccessException(); user.UserPreferences.DefaultReadingProfileId = profile.Id; await unitOfWork.CommitAsync(); } private static void UpdateReaderProfileFields(AppUserReadingProfile existingProfile, UserReadingProfileDto dto, bool updateName = true) { if (updateName && !string.IsNullOrEmpty(dto.Name) && existingProfile.NormalizedName != dto.Name.ToNormalized()) { existingProfile.Name = dto.Name; existingProfile.NormalizedName = dto.Name.ToNormalized(); } // Manga Reader existingProfile.ReadingDirection = dto.ReadingDirection; existingProfile.ScalingOption = dto.ScalingOption; existingProfile.PageSplitOption = dto.PageSplitOption; existingProfile.ReaderMode = dto.ReaderMode; existingProfile.AutoCloseMenu = dto.AutoCloseMenu; existingProfile.ShowScreenHints = dto.ShowScreenHints; existingProfile.EmulateBook = dto.EmulateBook; existingProfile.LayoutMode = dto.LayoutMode; existingProfile.BackgroundColor = string.IsNullOrEmpty(dto.BackgroundColor) ? "#000000" : dto.BackgroundColor; existingProfile.SwipeToPaginate = dto.SwipeToPaginate; existingProfile.AllowAutomaticWebtoonReaderDetection = dto.AllowAutomaticWebtoonReaderDetection; // EpubReading existingProfile.BookReaderMargin = dto.BookReaderMargin; existingProfile.BookReaderLineSpacing = dto.BookReaderLineSpacing; existingProfile.BookReaderFontSize = dto.BookReaderFontSize; existingProfile.BookReaderFontFamily = dto.BookReaderFontFamily; existingProfile.BookReaderTapToPaginate = dto.BookReaderTapToPaginate; existingProfile.BookReaderReadingDirection = dto.BookReaderReadingDirection; existingProfile.BookReaderWritingStyle = dto.BookReaderWritingStyle; existingProfile.BookThemeName = dto.BookReaderThemeName; existingProfile.BookReaderLayoutMode = dto.BookReaderLayoutMode; existingProfile.BookReaderImmersiveMode = dto.BookReaderImmersiveMode; // Pdf Reading existingProfile.PdfTheme = dto.PdfTheme; existingProfile.PdfScrollMode = dto.PdfScrollMode; existingProfile.PdfSpreadMode = dto.PdfSpreadMode; } }