wjones
86883cd5c6
- Refactor migrations and provider to use multiple PostgreSQL schemas, each matching a legacy SQLite database (activitylog, authentication, displaypreferences, library, users). - All tables, foreign keys, and indexes are now schema-qualified; Down migration drops tables by schema. - Provider ensures schemas exist before migrations; entities are mapped to correct schemas in OnModelCreating. - Add support for max-pool-size, min-pool-size, and multiplexing connection options; update logging accordingly. - VACUUM ANALYZE now runs per schema during scheduled optimization. - TruncateAllTablesAsync now truncates tables with schema qualification. - README updated with schema structure, new options, and multiplexing warnings. - CacheDecorator now calls async repository methods using .GetAwaiter().GetResult(), with documentation. - Lays groundwork for full async/await and multiplexing support in the database layer.
49 lines
1.6 KiB
C#
49 lines
1.6 KiB
C#
// <copyright file="KeyframeManager.cs" company="PlaceholderCompany">
|
|
// Copyright (c) PlaceholderCompany. All rights reserved.
|
|
// </copyright>
|
|
|
|
namespace Emby.Server.Implementations.Library;
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using Jellyfin.MediaEncoding.Keyframes;
|
|
using MediaBrowser.Controller.IO;
|
|
using MediaBrowser.Controller.Persistence;
|
|
|
|
/// <summary>
|
|
/// Manager for Keyframe data.
|
|
/// </summary>
|
|
public class KeyframeManager : IKeyframeManager
|
|
{
|
|
private readonly IKeyframeRepository _repository;
|
|
|
|
/// <summary>
|
|
/// Initializes a new instance of the <see cref="KeyframeManager"/> class.
|
|
/// </summary>
|
|
/// <param name="repository">The keyframe repository.</param>
|
|
public KeyframeManager(IKeyframeRepository repository)
|
|
{
|
|
_repository = repository;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<IReadOnlyList<KeyframeData>> GetKeyframeDataAsync(Guid itemId, CancellationToken cancellationToken = default)
|
|
{
|
|
return await _repository.GetKeyframeDataAsync(itemId, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task SaveKeyframeDataAsync(Guid itemId, KeyframeData data, CancellationToken cancellationToken)
|
|
{
|
|
await _repository.SaveKeyframeDataAsync(itemId, data, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task DeleteKeyframeDataAsync(Guid itemId, CancellationToken cancellationToken)
|
|
{
|
|
await _repository.DeleteKeyframeDataAsync(itemId, cancellationToken).ConfigureAwait(false);
|
|
}
|
|
}
|