Implements search functionality and prepares for upcoming paging in v0.3.

API/Controllers/LibraryController.cs

@@ -2,14 +2,18 @@
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
+using System.Text;
 using System.Threading.Tasks;
+using API.Data;
 using API.DTOs;
 using API.Entities;
 using API.Extensions;
+using API.Helpers;
 using API.Interfaces;
 using AutoMapper;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging;
 
 namespace API.Controllers
@@ -22,16 +26,18 @@ namespace API.Controllers
         private readonly IMapper _mapper;
         private readonly ITaskScheduler _taskScheduler;
         private readonly IUnitOfWork _unitOfWork;
+        private readonly DataContext _dataContext; // TODO: Remove, only for FTS prototyping
 
         public LibraryController(IDirectoryService directoryService, 
             ILogger<LibraryController> logger, IMapper mapper, ITaskScheduler taskScheduler, 
-            IUnitOfWork unitOfWork)
+            IUnitOfWork unitOfWork, DataContext dataContext)
         {
             _directoryService = directoryService;
             _logger = logger;
             _mapper = mapper;
             _taskScheduler = taskScheduler;
             _unitOfWork = unitOfWork;
+            _dataContext = dataContext;
         }
         
         /// <summary>
@@ -213,5 +219,24 @@ namespace API.Controllers
             return Ok();
 
         }
+        
+        [HttpGet("search")]
+        public async Task<ActionResult<IEnumerable<SearchResultDto>>> Search(string queryString)
+        {
+            //NOTE: What about normalizing search query and only searching against normalizedname in Series? 
+            // So One Punch would match One-Punch
+            // This also means less indexes we need.
+            queryString = queryString.Replace(@"%", "");
+            
+            var user = await _unitOfWork.UserRepository.GetUserByUsernameAsync(User.GetUsername());
+            // Get libraries user has access to
+            var libraries = (await _unitOfWork.LibraryRepository.GetLibrariesForUserIdAsync(user.Id)).ToList();
+            
+            if (!libraries.Any()) return BadRequest("User does not have access to any libraries");
+
+            var series = await _unitOfWork.SeriesRepository.SearchSeries(libraries.Select(l => l.Id).ToArray(), queryString);
+
+            return Ok(series);
+        }
     }
 }

API/DTOs/ImageDto.cs

@@ -9,7 +9,8 @@
         public int Height { get; init; }
         public string Format { get; init; }
         public byte[] Content { get; init; }
-        public int Chapter { get; set; }
+        //public int Chapter { get; set; }
         public string MangaFileName { get; set; }
+        public bool NeedsSplitting { get; set; }
     }
 }

API/DTOs/SearchQueryDto.cs

@@ -2,6 +2,6 @@
 {
     public class SearchQueryDto
     {
-        
+        public string QueryString { get; init; }
     }
 }

API/DTOs/SearchResultDto.cs

@@ -2,6 +2,15 @@
 {
     public class SearchResultDto
     {
+        public int SeriesId { get; init; }
+        public string Name { get; init; }
+        public string OriginalName { get; init; }
+        public string SortName { get; init; }
+        public byte[] CoverImage { get; init; } // This should be optional or a thumbImage (much smaller)
         
+        
+        // Grouping information
+        public string LibraryName { get; set; }
+        public int LibraryId { get; set; }
     }
 }

API/Data/LibraryRepository.cs

@@ -60,6 +60,15 @@ namespace API.Data
             return await _context.SaveChangesAsync() > 0;
         }
 
+        public async Task<IEnumerable<Library>> GetLibrariesForUserIdAsync(int userId)
+        {
+            return await _context.Library
+                .Include(l => l.AppUsers)
+                .Where(l => l.AppUsers.Select(ap => ap.Id).Contains(userId))
+                .AsNoTracking()
+                .ToListAsync();
+        }
+
         public async Task<IEnumerable<LibraryDto>> GetLibraryDtosAsync()
         {
             return await _context.Library

API/Data/SeriesRepository.cs

@@ -9,6 +9,7 @@ using API.Interfaces;
 using AutoMapper;
 using AutoMapper.QueryableExtensions;
 using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
 
 namespace API.Data
 {
@@ -16,11 +17,13 @@ namespace API.Data
     {
         private readonly DataContext _context;
         private readonly IMapper _mapper;
+        private readonly ILogger _logger;
 
-        public SeriesRepository(DataContext context, IMapper mapper)
+        public SeriesRepository(DataContext context, IMapper mapper, ILogger logger)
         {
             _context = context;
             _mapper = mapper;
+            _logger = logger;
         }
 
         public void Add(Series series)
@@ -74,7 +77,25 @@ namespace API.Data
             await AddSeriesModifiers(userId, series);
 
 
-            Console.WriteLine("Processed GetSeriesDtoForLibraryIdAsync in {0} milliseconds", sw.ElapsedMilliseconds);
+            _logger.LogDebug("Processed GetSeriesDtoForLibraryIdAsync in {ElapsedMilliseconds} milliseconds", sw.ElapsedMilliseconds);
+            return series;
+        }
+        
+        public async Task<IEnumerable<SearchResultDto>> SearchSeries(int[] libraryIds, string searchQuery)
+        {
+            var sw = Stopwatch.StartNew();
+            var series = await _context.Series
+                .Where(s => libraryIds.Contains(s.LibraryId))
+                .Where(s => EF.Functions.Like(s.Name, $"%{searchQuery}%") 
+                            || EF.Functions.Like(s.OriginalName, $"%{searchQuery}%"))
+                .Include(s => s.Library) // NOTE: Is there a way to do this faster? 
+                .OrderBy(s => s.SortName)
+                .AsNoTracking()
+                .ProjectTo<SearchResultDto>(_mapper.ConfigurationProvider)
+                .ToListAsync();
+
+
+            _logger.LogDebug("Processed SearchSeries in {ElapsedMilliseconds} milliseconds", sw.ElapsedMilliseconds);
             return series;
         }
 

API/Data/UnitOfWork.cs

@@ -3,6 +3,7 @@ using API.Entities;
 using API.Interfaces;
 using AutoMapper;
 using Microsoft.AspNetCore.Identity;
+using Microsoft.Extensions.Logging;
 
 namespace API.Data
 {
@@ -11,15 +12,17 @@ namespace API.Data
         private readonly DataContext _context;
         private readonly IMapper _mapper;
         private readonly UserManager<AppUser> _userManager;
+        private readonly ILogger<UnitOfWork> _seriesLogger;
 
-        public UnitOfWork(DataContext context, IMapper mapper, UserManager<AppUser> userManager)
+        public UnitOfWork(DataContext context, IMapper mapper, UserManager<AppUser> userManager, ILogger<UnitOfWork> seriesLogger)
         {
             _context = context;
             _mapper = mapper;
             _userManager = userManager;
+            _seriesLogger = seriesLogger;
         }
 
-        public ISeriesRepository SeriesRepository => new SeriesRepository(_context, _mapper);
+        public ISeriesRepository SeriesRepository => new SeriesRepository(_context, _mapper, _seriesLogger);
         public IUserRepository UserRepository => new UserRepository(_context, _userManager);
         public ILibraryRepository LibraryRepository => new LibraryRepository(_context, _mapper);
 

API/Entities/FTSSeries.cs

@@ -0,0 +1,14 @@
+namespace API.Entities
+{
+    public class FTSSeries
+    {
+        public int RowId { get; set; }
+        public Series Series { get; set; }
+        
+        public string Name { get; set; }
+        public string OriginalName { get; set; }
+        
+        public string Match { get; set; }
+        public double? Rank { get; set; }
+    }
+}

API/Entities/Series.cs

@@ -30,6 +30,7 @@ namespace API.Entities
         public DateTime Created { get; set; }
         public DateTime LastModified { get; set; }
         public byte[] CoverImage { get; set; }
+        // NOTE: Do I want to store a thumbImage for search results? 
         /// <summary>
         /// Sum of all Volume page counts
         /// </summary>

API/Extensions/HttpExtensions.cs

@@ -1,7 +1,17 @@
-namespace API.Extensions
+using System.Text.Json;
-{
+using API.Helpers;
-    public class HttpExtensions
+using Microsoft.AspNetCore.Http;
-    {
 
+namespace API.Extensions
+{
+    public static class HttpExtensions
+    {
+        public static void AddPaginationHeader(this HttpResponse response, int currentPage, 
+            int itemsPerPage, int totalItems, int totalPages)
+        {
+            var paginationHeader = new PaginationHeader(currentPage, itemsPerPage, totalItems, totalPages);
+            response.Headers.Add("Pagination", JsonSerializer.Serialize(paginationHeader));
+            response.Headers.Add("Access-Control-Expose-Headers", "Pagination");
+        }
     }
 }

API/Helpers/AutoMapperProfiles.cs

@@ -23,6 +23,13 @@ namespace API.Helpers
             
             CreateMap<AppUserPreferences, UserPreferencesDto>();
 
+            CreateMap<Series, SearchResultDto>()
+                .ForMember(dest => dest.SeriesId,
+                    opt => opt.MapFrom(src => src.Id))
+                .ForMember(dest => dest.LibraryName,
+                    opt => opt.MapFrom(src => src.Library.Name));
+            
+            
             CreateMap<Library, LibraryDto>()
                 .ForMember(dest => dest.Folders,
                     opt => 

API/Helpers/PagedList.cs

@@ -1,7 +1,32 @@
-namespace API.Helpers
+using System;
-{
+using System.Collections.Generic;
-    public class PagedList
+using System.Linq;
-    {
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
 
+namespace API.Helpers
+{
+    public class PagedList<T> : List<T>
+    {
+        public PagedList(IEnumerable<T> items, int count, int pageNumber, int pageSize)
+        {
+            CurrentPage = pageNumber;
+            TotalPages = (int) Math.Ceiling(count / (double) pageSize);
+            PageSize = pageSize;
+            TotalCount = count;
+            AddRange(items);
+        }
+
+        public int CurrentPage { get; set; }
+        public int TotalPages { get; set; }
+        public int PageSize { get; set; }
+        public int TotalCount { get; set; }
+
+        public static async Task<PagedList<T>> CreateAsync(IQueryable<T> source, int pageNumber, int pageSize)
+        {
+            var count = await source.CountAsync();
+            var items = await source.Skip((pageNumber - 1) * pageSize).Take(pageSize).ToListAsync();
+            return new PagedList<T>(items, count, pageNumber, pageSize);
+        }
     }
 }

API/Helpers/PaginationHeader.cs

@@ -2,6 +2,17 @@
 {
     public class PaginationHeader
     {
+        public PaginationHeader(int currentPage, int itemsPerPage, int totalItems, int totalPages)
+        {
+            CurrentPage = currentPage;
+            ItemsPerPage = itemsPerPage;
+            TotalItems = totalItems;
+            TotalPages = totalPages;
+        }
 
+        public int CurrentPage { get; set; }
+        public int ItemsPerPage { get; set; }
+        public int TotalItems { get; set; }
+        public int TotalPages { get; set; }
     }
 }

API/Helpers/UserParams.cs

@@ -2,6 +2,14 @@
 {
     public class UserParams
     {
+        private const int MaxPageSize = 50;
+        public int PageNumber { get; set; } = 1;
+        private int _pageSize = 10;
 
+        public int PageSize
+        {
+            get => _pageSize;
+            set => _pageSize = (value > MaxPageSize) ? MaxPageSize : value;
+        }
     }
 }

API/Interfaces/ILibraryRepository.cs

@@ -16,5 +16,6 @@ namespace API.Interfaces
         Task<IEnumerable<LibraryDto>> GetLibraryDtosForUsernameAsync(string userName);
         Task<IEnumerable<Library>> GetLibrariesAsync();
         Task<bool> DeleteLibrary(int libraryId);
+        Task<IEnumerable<Library>> GetLibrariesForUserIdAsync(int userId);
     }
 }

API/Interfaces/ISeriesRepository.cs

@@ -11,7 +11,19 @@ namespace API.Interfaces
         void Update(Series series);
         Task<Series> GetSeriesByNameAsync(string name);
         Series GetSeriesByName(string name);
+        /// <summary>
+        /// Adds user information like progress, ratings, etc
+        /// </summary>
+        /// <param name="libraryId"></param>
+        /// <param name="userId"></param>
+        /// <returns></returns>
         Task<IEnumerable<SeriesDto>> GetSeriesDtoForLibraryIdAsync(int libraryId, int userId);
+        /// <summary>
+        /// Does not add user information like progress, ratings, etc.
+        /// </summary>
+        /// <param name="libraryIds"></param>
+        /// <returns></returns>
+        Task<IEnumerable<SearchResultDto>> SearchSeries(int[] libraryIds, string searchQuery);
         Task<IEnumerable<Series>> GetSeriesForLibraryIdAsync(int libraryId);
         Task<IEnumerable<VolumeDto>> GetVolumesDtoAsync(int seriesId, int userId);
         IEnumerable<Volume> GetVolumes(int seriesId);

API/Services/MetadataService.cs

@@ -52,6 +52,8 @@ namespace API.Services
 
        public void UpdateMetadata(Series series, bool forceUpdate)
        {
+          // TODO: this doesn't actually invoke finding a new cover. Also all these should be groupped ideally so we limit
+          // disk I/O to one method.
           if (series == null) return;
           if (ShouldFindCoverImage(series.CoverImage, forceUpdate))
           {