Kavita/API/Controllers/OPDSController.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
using System.Xml.Serialization;
using API.Comparators;
using API.DTOs;
using API.DTOs.CollectionTags;
using API.DTOs.Filtering;
using API.DTOs.OPDS;
using API.Entities;
using API.Extensions;
using API.Helpers;
using API.Interfaces;
using API.Interfaces.Services;
using API.Services;
using Kavita.Common;
using Microsoft.AspNetCore.Mvc;

namespace API.Controllers
{
    public class OpdsController : BaseApiController
    {
        private readonly IUnitOfWork _unitOfWork;
        private readonly IDownloadService _downloadService;
        private readonly IDirectoryService _directoryService;
        private readonly ICacheService _cacheService;
        private readonly IReaderService _readerService;


        private readonly XmlSerializer _xmlSerializer;
        private readonly XmlSerializer _xmlOpenSearchSerializer;
        private const string Prefix = "/api/opds/";
        private readonly FilterDto _filterDto = new FilterDto()
        {
            MangaFormat = null
        };
        private readonly ChapterSortComparer _chapterSortComparer = new ChapterSortComparer();

        public OpdsController(IUnitOfWork unitOfWork, IDownloadService downloadService,
            IDirectoryService directoryService, ICacheService cacheService,
            IReaderService readerService)
        {
            _unitOfWork = unitOfWork;
            _downloadService = downloadService;
            _directoryService = directoryService;
            _cacheService = cacheService;
            _readerService = readerService;


            _xmlSerializer = new XmlSerializer(typeof(Feed));
            _xmlOpenSearchSerializer = new XmlSerializer(typeof(OpenSearchDescription));

        }

        [HttpPost("{apiKey}")]
        [HttpGet("{apiKey}")]
        [Produces("application/xml")]
        public async Task<IActionResult> Get(string apiKey)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var feed = CreateFeed("Kavita", string.Empty, apiKey);
            feed.Id = "root";
            feed.Entries.Add(new FeedEntry()
            {
                Id = "inProgress",
                Title = "In Progress",
                Content = new FeedEntryContent()
                {
                    Text = "Browse by In Progress"
                },
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/in-progress"),
                }
            });
            feed.Entries.Add(new FeedEntry()
            {
                Id = "recentlyAdded",
                Title = "Recently Added",
                Content = new FeedEntryContent()
                {
                    Text = "Browse by Recently Added"
                },
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/recently-added"),
                }
            });
            feed.Entries.Add(new FeedEntry()
            {
                Id = "readingList",
                Title = "Reading Lists",
                Content = new FeedEntryContent()
                {
                    Text = "Browse by Reading Lists"
                },
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/reading-list"),
                }
            });
            feed.Entries.Add(new FeedEntry()
            {
                Id = "allLibraries",
                Title = "All Libraries",
                Content = new FeedEntryContent()
                {
                    Text = "Browse by Libraries"
                },
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/libraries"),
                }
            });
            feed.Entries.Add(new FeedEntry()
            {
                Id = "allCollections",
                Title = "All Collections",
                Content = new FeedEntryContent()
                {
                    Text = "Browse by Collections"
                },
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/collections"),
                }
            });
            return CreateXmlResult(SerializeXml(feed));
        }


        [HttpGet("{apiKey}/libraries")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetLibraries(string apiKey)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var libraries = await _unitOfWork.LibraryRepository.GetLibrariesForUserIdAsync(userId);

            var feed = CreateFeed("All Libraries", $"{apiKey}/libraries", apiKey);

            foreach (var library in libraries)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Id = library.Id.ToString(),
                    Title = library.Name,
                    Links = new List<FeedLink>()
                    {
                        CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/libraries/{library.Id}"),
                    }
                });
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/collections")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetCollections(string apiKey)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var user = await _unitOfWork.UserRepository.GetUserByIdAsync(userId);
            var isAdmin = await _unitOfWork.UserRepository.IsUserAdmin(user);

            IList<CollectionTagDto> tags;
            if (isAdmin)
            {
                tags = (await _unitOfWork.CollectionTagRepository.GetAllTagDtosAsync()).ToList();
            }
            else
            {
                tags = (await _unitOfWork.CollectionTagRepository.GetAllPromotedTagDtosAsync()).ToList();
            }


            var feed = CreateFeed("All Collections", $"{apiKey}/collections", apiKey);

            foreach (var tag in tags)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Id = tag.Id.ToString(),
                    Title = tag.Title,
                    Summary = tag.Summary,
                    Links = new List<FeedLink>()
                    {
                        CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/collections/{tag.Id}"),
                        CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/collection-cover?collectionId={tag.Id}"),
                        CreateLink(FeedLinkRelation.Thumbnail, FeedLinkType.Image, $"/api/image/collection-cover?collectionId={tag.Id}")
                    }
                });
            }

            if (tags.Count == 0)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Title = "Nothing here",
                });
            }

            return CreateXmlResult(SerializeXml(feed));
        }


        [HttpGet("{apiKey}/collections/{collectionId}")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetCollection(int collectionId, string apiKey, [FromQuery] int pageNumber = 0)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var user = await _unitOfWork.UserRepository.GetUserByIdAsync(userId);
            var isAdmin = await _unitOfWork.UserRepository.IsUserAdmin(user);

            IEnumerable <CollectionTagDto> tags;
            if (isAdmin)
            {
                tags = await _unitOfWork.CollectionTagRepository.GetAllTagDtosAsync();
            }
            else
            {
                tags = await _unitOfWork.CollectionTagRepository.GetAllPromotedTagDtosAsync();
            }

            var tag = tags.SingleOrDefault(t => t.Id == collectionId);
            if (tag == null)
            {
                return BadRequest("Collection does not exist or you don't have access");
            }

            var series = await _unitOfWork.SeriesRepository.GetSeriesDtoForCollectionAsync(collectionId, userId, new UserParams()
            {
                PageNumber = pageNumber,
                PageSize = 20
            });

            var feed = CreateFeed(tag.Title + " Collection", $"{apiKey}/collections/{collectionId}", apiKey);
            AddPagination(feed, series, $"{Prefix}{apiKey}/collections/{collectionId}");

            foreach (var seriesDto in series)
            {
                feed.Entries.Add(CreateSeries(seriesDto, apiKey));
            }


            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/reading-list")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetReadingLists(string apiKey, [FromQuery] int pageNumber = 0)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);

            var readingLists = await _unitOfWork.ReadingListRepository.GetReadingListDtosForUserAsync(userId, true, new UserParams()
            {
                PageNumber = pageNumber
            });


            var feed = CreateFeed("All Reading Lists", $"{apiKey}/reading-list", apiKey);

            foreach (var readingListDto in readingLists)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Id = readingListDto.Id.ToString(),
                    Title = readingListDto.Title,
                    Summary = readingListDto.Summary,
                    Links = new List<FeedLink>()
                    {
                        CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/reading-list/{readingListDto.Id}"),
                    }
                });
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/reading-list/{readingListId}")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetReadingListItems(int readingListId, string apiKey)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var user = await _unitOfWork.UserRepository.GetUserByIdAsync(userId);

            var userWithLists = await _unitOfWork.UserRepository.GetUserWithReadingListsByUsernameAsync(user.UserName);
            var readingList = userWithLists.ReadingLists.SingleOrDefault(t => t.Id == readingListId);
            if (readingList == null)
            {
                return BadRequest("Reading list does not exist or you don't have access");
            }

            var feed = CreateFeed(readingList.Title + " Reading List", $"{apiKey}/reading-list/{readingListId}", apiKey);

            var items = (await _unitOfWork.ReadingListRepository.GetReadingListItemDtosByIdAsync(readingListId, userId)).ToList();
            foreach (var item in items)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Id = item.ChapterId.ToString(),
                    Title = $"{item.SeriesName} Chapter {item.ChapterNumber}",
                    Links = new List<FeedLink>()
                    {
                        CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/series/{item.SeriesId}/volume/{item.VolumeId}/chapter/{item.ChapterId}"),
                        CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/chapter-cover?chapterId={item.ChapterId}")
                    }
                });
            }

            if (items.Count == 0)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Title = "Nothing here",
                });
            }



            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/libraries/{libraryId}")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetSeriesForLibrary(int libraryId, string apiKey, [FromQuery] int pageNumber = 0)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var library =
                (await _unitOfWork.LibraryRepository.GetLibrariesForUserIdAsync(userId)).SingleOrDefault(l =>
                    l.Id == libraryId);
            if (library == null)
            {
                return BadRequest("User does not have access to this library");
            }

            var series = await _unitOfWork.SeriesRepository.GetSeriesDtoForLibraryIdAsync(libraryId, userId, new UserParams()
            {
                PageNumber = pageNumber,
                PageSize = 20
            }, _filterDto);

            var feed = CreateFeed(library.Name, $"{apiKey}/libraries/{libraryId}", apiKey);
            AddPagination(feed, series, $"{Prefix}{apiKey}/libraries/{libraryId}");

            foreach (var seriesDto in series)
            {
                feed.Entries.Add(CreateSeries(seriesDto, apiKey));
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/recently-added")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetRecentlyAdded(string apiKey, [FromQuery] int pageNumber = 1)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var recentlyAdded = await _unitOfWork.SeriesRepository.GetRecentlyAdded(0, userId, new UserParams()
            {
                PageNumber = pageNumber,
                PageSize = 20
            }, _filterDto);

            var feed = CreateFeed("Recently Added", $"{apiKey}/recently-added", apiKey);
            AddPagination(feed, recentlyAdded, $"{Prefix}{apiKey}/recently-added");

            foreach (var seriesDto in recentlyAdded)
            {
                feed.Entries.Add(CreateSeries(seriesDto, apiKey));
            }

            if (recentlyAdded.Count == 0)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Title = "Nothing here",
                });
            }


            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/in-progress")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetInProgress(string apiKey, [FromQuery] int pageNumber = 1)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var userParams = new UserParams()
            {
                PageNumber = pageNumber,
                PageSize = 20
            };
            var results = await _unitOfWork.SeriesRepository.GetInProgress(userId, 0, userParams, _filterDto);
            var listResults = results.DistinctBy(s => s.Name).Skip((userParams.PageNumber - 1) * userParams.PageSize)
                .Take(userParams.PageSize).ToList();
            var pagedList = new PagedList<SeriesDto>(listResults, listResults.Count, userParams.PageNumber, userParams.PageSize);

            Response.AddPaginationHeader(pagedList.CurrentPage, pagedList.PageSize, pagedList.TotalCount, pagedList.TotalPages);

            var feed = CreateFeed("In Progress", $"{apiKey}/in-progress", apiKey);
            AddPagination(feed, pagedList, $"{Prefix}{apiKey}/in-progress");

            foreach (var seriesDto in pagedList)
            {
                feed.Entries.Add(CreateSeries(seriesDto, apiKey));
            }

            if (pagedList.Count == 0)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Title = "Nothing here",
                });
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/series")]
        [Produces("application/xml")]
        public async Task<IActionResult> SearchSeries(string apiKey, [FromQuery] string query)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            if (string.IsNullOrEmpty(query))
            {
                return BadRequest("You must pass a query parameter");
            }
            query = query.Replace(@"%", "");
            // Get libraries user has access to
            var libraries = (await _unitOfWork.LibraryRepository.GetLibrariesForUserIdAsync(userId)).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(), query);

            var feed = CreateFeed(query, $"{apiKey}/series?query=" + query, apiKey);

            foreach (var seriesDto in series)
            {
                feed.Entries.Add(CreateSeries(seriesDto, apiKey));
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/search")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetSearchDescriptor(string apiKey)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var feed = new OpenSearchDescription()
            {
                ShortName = "Search",
                Description = "Search for Series",
                Url = new SearchLink()
                {
                    Type = FeedLinkType.AtomAcquisition,
                    Template = $"{Prefix}{apiKey}/series?query=" + "{searchTerms}"
                }
            };

            await using var sm = new StringWriter();
            _xmlOpenSearchSerializer.Serialize(sm, feed);

            return CreateXmlResult(sm.ToString().Replace("utf-16", "utf-8"));
        }

        [HttpGet("{apiKey}/series/{seriesId}")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetSeries(string apiKey, int seriesId)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var series = await _unitOfWork.SeriesRepository.GetSeriesDtoByIdAsync(seriesId, userId);
            var volumes = await _unitOfWork.VolumeRepository.GetVolumesDtoAsync(seriesId, userId);
            var feed = CreateFeed(series.Name + " - Volumes", $"{apiKey}/series/{series.Id}", apiKey);
            feed.Links.Add(CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/series-cover?seriesId={seriesId}"));
            foreach (var volumeDto in volumes)
            {
                feed.Entries.Add(CreateVolume(volumeDto, seriesId, apiKey));
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/series/{seriesId}/volume/{volumeId}")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetVolume(string apiKey, int seriesId, int volumeId)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var series = await _unitOfWork.SeriesRepository.GetSeriesDtoByIdAsync(seriesId, userId);
            var volume = await _unitOfWork.VolumeRepository.GetVolumeAsync(volumeId);
            var chapters =
                (await _unitOfWork.ChapterRepository.GetChaptersAsync(volumeId)).OrderBy(x => double.Parse(x.Number),
                    _chapterSortComparer);

            var feed = CreateFeed(series.Name + " - Volume " + volume.Name + " - Chapters ", $"{apiKey}/series/{seriesId}/volume/{volumeId}", apiKey);
            foreach (var chapter in chapters)
            {
                feed.Entries.Add(new FeedEntry()
                {
                    Id = chapter.Id.ToString(),
                    Title = "Chapter " + chapter.Number,
                    Links = new List<FeedLink>()
                    {
                        CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/series/{seriesId}/volume/{volumeId}/chapter/{chapter.Id}"),
                        CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/chapter-cover?chapterId={chapter.Id}")
                    }
                });
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        [HttpGet("{apiKey}/series/{seriesId}/volume/{volumeId}/chapter/{chapterId}")]
        [Produces("application/xml")]
        public async Task<IActionResult> GetChapter(string apiKey, int seriesId, int volumeId, int chapterId)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var userId = await GetUser(apiKey);
            var series = await _unitOfWork.SeriesRepository.GetSeriesDtoByIdAsync(seriesId, userId);
            var volume = await _unitOfWork.VolumeRepository.GetVolumeAsync(volumeId);
            var chapter = await _unitOfWork.ChapterRepository.GetChapterDtoAsync(chapterId);
            var files = await _unitOfWork.ChapterRepository.GetFilesForChapterAsync(chapterId);

            var feed = CreateFeed(series.Name + " - Volume " + volume.Name + " - Chapters ", $"{apiKey}/series/{seriesId}/volume/{volumeId}/chapter/{chapterId}", apiKey);
            foreach (var mangaFile in files)
            {
                feed.Entries.Add(CreateChapter(seriesId, volumeId, chapterId, mangaFile, series, volume, chapter, apiKey));
            }

            return CreateXmlResult(SerializeXml(feed));
        }

        /// <summary>
        /// Downloads a file
        /// </summary>
        /// <param name="seriesId"></param>
        /// <param name="volumeId"></param>
        /// <param name="chapterId"></param>
        /// <param name="filename">Not used. Only for Chunky to allow download links</param>
        /// <returns></returns>
        [HttpGet("{apiKey}/series/{seriesId}/volume/{volumeId}/chapter/{chapterId}/download/{filename}")]
        public async Task<ActionResult> DownloadFile(string apiKey, int seriesId, int volumeId, int chapterId, string filename)
        {
            if (!(await _unitOfWork.SettingsRepository.GetSettingsDtoAsync()).EnableOpds)
                return BadRequest("OPDS is not enabled on this server");
            var files = await _unitOfWork.ChapterRepository.GetFilesForChapterAsync(chapterId);
            var (bytes, contentType, fileDownloadName) = await _downloadService.GetFirstFileDownload(files);
            return File(bytes, contentType, fileDownloadName);
        }

        private static ContentResult CreateXmlResult(string xml)
        {
            return new ContentResult
            {
                ContentType = "application/xml",
                Content = xml,
                StatusCode = 200
            };
        }

        private static void AddPagination(Feed feed, PagedList<SeriesDto> list, string href)
        {
            var url = href;
            if (href.Contains("?"))
            {
                url += "&amp;";
            }
            else
            {
                url += "?";
            }

            var pageNumber = Math.Max(list.CurrentPage, 1);

            if (pageNumber > 1)
            {
                feed.Links.Add(CreateLink(FeedLinkRelation.Prev, FeedLinkType.AtomNavigation, url + "pageNumber=" + (pageNumber - 1)));
            }

            if (pageNumber + 1 < list.TotalPages)
            {
                feed.Links.Add(CreateLink(FeedLinkRelation.Next, FeedLinkType.AtomNavigation, url + "pageNumber=" + (pageNumber + 1)));
            }

            // Update self to point to current page
            var selfLink = feed.Links.SingleOrDefault(l => l.Rel == FeedLinkRelation.Self);
            if (selfLink != null)
            {
                selfLink.Href = url + "pageNumber=" + pageNumber;
            }


            feed.Total = list.TotalPages * list.PageSize;
            feed.ItemsPerPage = list.PageSize;
            feed.StartIndex = (Math.Max(list.CurrentPage - 1, 0) * list.PageSize) + 1;
        }

        private static FeedEntry CreateSeries(SeriesDto seriesDto, string apiKey)
        {
            return new FeedEntry()
            {
                Id = seriesDto.Id.ToString(),
                Title = $"{seriesDto.Name} ({seriesDto.Format})",
                Summary = seriesDto.Summary,
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/series/{seriesDto.Id}"),
                    CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/series-cover?seriesId={seriesDto.Id}"),
                    CreateLink(FeedLinkRelation.Thumbnail, FeedLinkType.Image, $"/api/image/series-cover?seriesId={seriesDto.Id}")
                }
            };
        }

        private static FeedEntry CreateSeries(SearchResultDto searchResultDto, string apiKey)
        {
            return new FeedEntry()
            {
                Id = searchResultDto.SeriesId.ToString(),
                Title = $"{searchResultDto.Name} ({searchResultDto.Format})",
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/series/{searchResultDto.SeriesId}"),
                    CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/series-cover?seriesId={searchResultDto.SeriesId}"),
                    CreateLink(FeedLinkRelation.Thumbnail, FeedLinkType.Image, $"/api/image/series-cover?seriesId={searchResultDto.SeriesId}")
                }
            };
        }

        private static FeedEntry CreateVolume(VolumeDto volumeDto, int seriesId, string apiKey)
        {
            return new FeedEntry()
            {
                Id = volumeDto.Id.ToString(),
                Title = "Volume " + volumeDto.Name,
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.SubSection, FeedLinkType.AtomNavigation, Prefix + $"{apiKey}/series/{seriesId}/volume/{volumeDto.Id}"),
                    CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/volume-cover?volumeId={volumeDto.Id}"),
                    CreateLink(FeedLinkRelation.Thumbnail, FeedLinkType.Image, $"/api/image/volume-cover?volumeId={volumeDto.Id}")
                }
            };
        }

        private FeedEntry CreateChapter(int seriesId, int volumeId, int chapterId, MangaFile mangaFile, SeriesDto series, Volume volume, ChapterDto chapter, string apiKey)
        {
            var fileSize =
                DirectoryService.GetHumanReadableBytes(DirectoryService.GetTotalSize(new List<string>()
                    {mangaFile.FilePath}));
            var fileType = _downloadService.GetContentTypeFromFile(mangaFile.FilePath);
            var filename = Uri.EscapeUriString(Path.GetFileName(mangaFile.FilePath) ?? string.Empty);
            return new FeedEntry()
            {
                Id = mangaFile.Id.ToString(),
                Title = $"{series.Name} - Volume {volume.Name} - Chapter {chapter.Number}",
                Extent = fileSize,
                Summary = $"{fileType.Split("/")[1]} - {fileSize}",
                Format = mangaFile.Format.ToString(),
                Links = new List<FeedLink>()
                {
                    CreateLink(FeedLinkRelation.Image, FeedLinkType.Image, $"/api/image/chapter-cover?chapterId={chapterId}"),
                    CreateLink(FeedLinkRelation.Thumbnail, FeedLinkType.Image, $"/api/image/chapter-cover?chapterId={chapterId}"),
                    // Chunky requires a file at the end. Our API ignores this
                    CreateLink(FeedLinkRelation.Acquisition, fileType, $"{Prefix}{apiKey}/series/{seriesId}/volume/{volumeId}/chapter/{chapterId}/download/{filename}"),
                    CreatePageStreamLink(seriesId, volumeId, chapterId, mangaFile, apiKey)
                },
                Content = new FeedEntryContent()
                {
                    Text = fileType,
                    Type = "text"
                }
            };
        }

        [HttpGet("{apiKey}/image")]
        public async Task<ActionResult> GetPageStreamedImage(string apiKey, [FromQuery] int seriesId, [FromQuery] int volumeId,[FromQuery] int chapterId, [FromQuery] int pageNumber)
        {
            if (pageNumber < 0) return BadRequest("Page cannot be less than 0");
            var chapter = await _cacheService.Ensure(chapterId);
            if (chapter == null) return BadRequest("There was an issue finding image file for reading");

            try
            {
                var (path, _) = await _cacheService.GetCachedPagePath(chapter, pageNumber);
                if (string.IsNullOrEmpty(path) || !System.IO.File.Exists(path)) return BadRequest($"No such image for page {pageNumber}");

                var content = await _directoryService.ReadFileAsync(path);
                var format = Path.GetExtension(path).Replace(".", "");

                // Calculates SHA1 Hash for byte[]
                Response.AddCacheHeader(content);

                // Save progress for the user
                await _readerService.SaveReadingProgress(new ProgressDto()
                {
                    ChapterId = chapterId,
                    PageNum = pageNumber,
                    SeriesId = seriesId,
                    VolumeId = volumeId
                }, await GetUser(apiKey));

                return File(content, "image/" + format);
            }
            catch (Exception)
            {
                _cacheService.CleanupChapters(new []{ chapterId });
                throw;
            }
        }

        [HttpGet("{apiKey}/favicon")]
        public async Task<ActionResult> GetFavicon(string apiKey)
        {
            var files = DirectoryService.GetFilesWithExtension(Path.Join(Directory.GetCurrentDirectory(), ".."), @"\.ico");
            if (files.Length == 0) return BadRequest("Cannot find icon");
            var path = files[0];
            var content = await _directoryService.ReadFileAsync(path);
            var format = Path.GetExtension(path).Replace(".", "");

            // Calculates SHA1 Hash for byte[]
            Response.AddCacheHeader(content);

            return File(content, "image/" + format);
        }

        /// <summary>
        /// Gets the user from the API key
        /// </summary>
        /// <returns></returns>
        private async Task<int> GetUser(string apiKey)
        {
            try
            {
                var user = await _unitOfWork.UserRepository.GetUserIdByApiKeyAsync(apiKey);
                return user;
            }
            catch
            {
                /* Do nothing */
            }
            throw new KavitaException("User does not exist");
        }

        private static FeedLink CreatePageStreamLink(int seriesId, int volumeId, int chapterId, MangaFile mangaFile, string apiKey)
        {
            var link = CreateLink(FeedLinkRelation.Stream, "image/jpeg", $"{Prefix}{apiKey}/image?seriesId={seriesId}&volumeId={volumeId}&chapterId={chapterId}&pageNumber=" + "{pageNumber}");
            link.TotalPages = mangaFile.Pages;
            return link;
        }

        private static FeedLink CreateLink(string rel, string type, string href)
        {
            return new FeedLink()
            {
                Rel = rel,
                Href = href,
                Type = type
            };
        }

        private static Feed CreateFeed(string title, string href, string apiKey)
        {
            var link = CreateLink(FeedLinkRelation.Self, string.IsNullOrEmpty(href) ?
                FeedLinkType.AtomNavigation :
                FeedLinkType.AtomAcquisition, Prefix + href);

            return new Feed()
            {
                Title = title,
                Icon = Prefix + $"{apiKey}/favicon",
                Links = new List<FeedLink>()
                {
                    link,
                    CreateLink(FeedLinkRelation.Start, FeedLinkType.AtomNavigation, Prefix + apiKey),
                    CreateLink(FeedLinkRelation.Search, FeedLinkType.AtomSearch, Prefix + $"{apiKey}/search")
                },
            };
        }

        private string SerializeXml(Feed feed)
        {
            if (feed == null) return string.Empty;
            using var sm = new StringWriter();
            _xmlSerializer.Serialize(sm, feed);
            return sm.ToString().Replace("utf-16", "utf-8"); // Chunky cannot accept UTF-16 feeds
        }
    }
}