mirror of
https://github.com/Kareadita/Kavita.git
synced 2025-06-12 18:14:15 -04:00
* Updated scan time for watcher to 30 seconds for non-dev. Moved ScanFolder off the Scan queue as it doesn't need to be there. Updated loggers * Fixed jumpbar missing * Tweaked the messaging for CoverGen * When we return early due to nothing being done on library and series scan, make sure we kick off other tasks that need to occur. * Fixed a foreign constraint issue on Volumes when we were adding to a new series. * Fixed a case where when picking normalized series, capitalization differences wouldn't stack when they should. * Reduced the logging output on dev and prod settings. * Fixed a bug in the code that finds the highest directory from a file, where we were not checking against a normalized path. * Cleaned up some code * Fixed broken unit tests
108 lines
3.9 KiB
C#
108 lines
3.9 KiB
C#
using System;
|
|
using System.Threading.Tasks;
|
|
using API.Data.Repositories;
|
|
using API.Entities;
|
|
using AutoMapper;
|
|
using Microsoft.AspNetCore.Identity;
|
|
|
|
namespace API.Data;
|
|
|
|
public interface IUnitOfWork
|
|
{
|
|
ISeriesRepository SeriesRepository { get; }
|
|
IUserRepository UserRepository { get; }
|
|
ILibraryRepository LibraryRepository { get; }
|
|
IVolumeRepository VolumeRepository { get; }
|
|
ISettingsRepository SettingsRepository { get; }
|
|
IAppUserProgressRepository AppUserProgressRepository { get; }
|
|
ICollectionTagRepository CollectionTagRepository { get; }
|
|
IChapterRepository ChapterRepository { get; }
|
|
IReadingListRepository ReadingListRepository { get; }
|
|
ISeriesMetadataRepository SeriesMetadataRepository { get; }
|
|
IPersonRepository PersonRepository { get; }
|
|
IGenreRepository GenreRepository { get; }
|
|
ITagRepository TagRepository { get; }
|
|
ISiteThemeRepository SiteThemeRepository { get; }
|
|
IMangaFileRepository MangaFileRepository { get; }
|
|
bool Commit();
|
|
Task<bool> CommitAsync();
|
|
bool HasChanges();
|
|
Task<bool> RollbackAsync();
|
|
}
|
|
public class UnitOfWork : IUnitOfWork
|
|
{
|
|
private readonly DataContext _context;
|
|
private readonly IMapper _mapper;
|
|
private readonly UserManager<AppUser> _userManager;
|
|
|
|
public UnitOfWork(DataContext context, IMapper mapper, UserManager<AppUser> userManager)
|
|
{
|
|
_context = context;
|
|
_mapper = mapper;
|
|
_userManager = userManager;
|
|
}
|
|
|
|
public ISeriesRepository SeriesRepository => new SeriesRepository(_context, _mapper);
|
|
public IUserRepository UserRepository => new UserRepository(_context, _userManager, _mapper);
|
|
public ILibraryRepository LibraryRepository => new LibraryRepository(_context, _mapper);
|
|
|
|
public IVolumeRepository VolumeRepository => new VolumeRepository(_context, _mapper);
|
|
|
|
public ISettingsRepository SettingsRepository => new SettingsRepository(_context, _mapper);
|
|
|
|
public IAppUserProgressRepository AppUserProgressRepository => new AppUserProgressRepository(_context);
|
|
public ICollectionTagRepository CollectionTagRepository => new CollectionTagRepository(_context, _mapper);
|
|
public IChapterRepository ChapterRepository => new ChapterRepository(_context, _mapper);
|
|
public IReadingListRepository ReadingListRepository => new ReadingListRepository(_context, _mapper);
|
|
public ISeriesMetadataRepository SeriesMetadataRepository => new SeriesMetadataRepository(_context);
|
|
public IPersonRepository PersonRepository => new PersonRepository(_context, _mapper);
|
|
public IGenreRepository GenreRepository => new GenreRepository(_context, _mapper);
|
|
public ITagRepository TagRepository => new TagRepository(_context, _mapper);
|
|
public ISiteThemeRepository SiteThemeRepository => new SiteThemeRepository(_context, _mapper);
|
|
public IMangaFileRepository MangaFileRepository => new MangaFileRepository(_context, _mapper);
|
|
|
|
/// <summary>
|
|
/// Commits changes to the DB. Completes the open transaction.
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public bool Commit()
|
|
{
|
|
return _context.SaveChanges() > 0;
|
|
}
|
|
/// <summary>
|
|
/// Commits changes to the DB. Completes the open transaction.
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public async Task<bool> CommitAsync()
|
|
{
|
|
return await _context.SaveChangesAsync() > 0;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Is the DB Context aware of Changes in loaded entities
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public bool HasChanges()
|
|
{
|
|
return _context.ChangeTracker.HasChanges();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Rollback transaction
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public async Task<bool> RollbackAsync()
|
|
{
|
|
try
|
|
{
|
|
await _context.Database.RollbackTransactionAsync();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
// Swallow exception (this might be used in places where a transaction isn't setup)
|
|
}
|
|
|
|
return true;
|
|
}
|
|
}
|