2020-12-02 21:51:53 -05:00
|
|
|
using System;
|
2021-08-15 11:20:07 -04:00
|
|
|
using System.Diagnostics.CodeAnalysis;
|
2020-10-27 19:57:52 -04:00
|
|
|
using System.Linq;
|
2020-12-02 21:51:53 -05:00
|
|
|
using System.Threading;
|
2021-06-19 12:02:33 -04:00
|
|
|
using Jellyfin.Extensions;
|
2020-10-27 19:57:52 -04:00
|
|
|
using MediaBrowser.Controller.Channels;
|
|
|
|
using MediaBrowser.Controller.Configuration;
|
|
|
|
using MediaBrowser.Controller.Entities;
|
|
|
|
using MediaBrowser.Model.Configuration;
|
|
|
|
|
|
|
|
namespace MediaBrowser.Controller.BaseItemManager
|
|
|
|
{
|
|
|
|
/// <inheritdoc />
|
|
|
|
public class BaseItemManager : IBaseItemManager
|
|
|
|
{
|
|
|
|
private readonly IServerConfigurationManager _serverConfigurationManager;
|
|
|
|
|
2021-08-15 11:20:07 -04:00
|
|
|
private int _metadataRefreshConcurrency;
|
2020-12-03 02:07:51 -05:00
|
|
|
|
2020-10-27 19:57:52 -04:00
|
|
|
/// <summary>
|
|
|
|
/// Initializes a new instance of the <see cref="BaseItemManager"/> class.
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="serverConfigurationManager">Instance of the <see cref="IServerConfigurationManager"/> interface.</param>
|
|
|
|
public BaseItemManager(IServerConfigurationManager serverConfigurationManager)
|
|
|
|
{
|
|
|
|
_serverConfigurationManager = serverConfigurationManager;
|
2020-12-02 21:51:53 -05:00
|
|
|
|
2020-12-03 02:07:51 -05:00
|
|
|
_metadataRefreshConcurrency = GetMetadataRefreshConcurrency();
|
|
|
|
SetupMetadataThrottler();
|
2020-12-02 21:51:53 -05:00
|
|
|
|
2020-12-03 20:11:53 -05:00
|
|
|
_serverConfigurationManager.ConfigurationUpdated += OnConfigurationUpdated;
|
2020-10-27 19:57:52 -04:00
|
|
|
}
|
|
|
|
|
2020-12-02 21:51:53 -05:00
|
|
|
/// <inheritdoc />
|
2020-12-03 02:23:13 -05:00
|
|
|
public SemaphoreSlim MetadataRefreshThrottler { get; private set; }
|
2020-12-02 21:51:53 -05:00
|
|
|
|
2020-10-27 19:57:52 -04:00
|
|
|
/// <inheritdoc />
|
2021-12-18 15:40:27 -05:00
|
|
|
public bool IsMetadataFetcherEnabled(BaseItem baseItem, TypeOptions? libraryTypeOptions, string name)
|
2020-10-27 19:57:52 -04:00
|
|
|
{
|
|
|
|
if (baseItem is Channel)
|
|
|
|
{
|
2020-11-08 08:42:54 -05:00
|
|
|
// Hack alert.
|
2020-10-27 19:57:52 -04:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (baseItem.SourceType == SourceType.Channel)
|
|
|
|
{
|
2020-11-08 08:42:49 -05:00
|
|
|
// Hack alert.
|
2020-10-27 19:57:52 -04:00
|
|
|
return !baseItem.EnableMediaSourceDisplay;
|
|
|
|
}
|
|
|
|
|
2022-12-05 09:01:13 -05:00
|
|
|
if (libraryTypeOptions is not null)
|
2020-10-27 19:57:52 -04:00
|
|
|
{
|
2021-12-18 15:40:27 -05:00
|
|
|
return libraryTypeOptions.MetadataFetchers.Contains(name.AsSpan(), StringComparison.OrdinalIgnoreCase);
|
2020-10-27 19:57:52 -04:00
|
|
|
}
|
|
|
|
|
2021-11-15 08:47:06 -05:00
|
|
|
var itemConfig = _serverConfigurationManager.Configuration.MetadataOptions.FirstOrDefault(i => string.Equals(i.ItemType, baseItem.GetType().Name, StringComparison.OrdinalIgnoreCase));
|
2020-10-27 19:57:52 -04:00
|
|
|
|
2022-12-05 09:00:20 -05:00
|
|
|
return itemConfig is null || !itemConfig.DisabledMetadataFetchers.Contains(name.AsSpan(), StringComparison.OrdinalIgnoreCase);
|
2020-10-27 19:57:52 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
/// <inheritdoc />
|
2021-12-18 15:40:27 -05:00
|
|
|
public bool IsImageFetcherEnabled(BaseItem baseItem, TypeOptions? libraryTypeOptions, string name)
|
2020-10-27 19:57:52 -04:00
|
|
|
{
|
|
|
|
if (baseItem is Channel)
|
|
|
|
{
|
2020-11-08 08:42:40 -05:00
|
|
|
// Hack alert.
|
2020-10-27 19:57:52 -04:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (baseItem.SourceType == SourceType.Channel)
|
|
|
|
{
|
2020-11-08 08:42:33 -05:00
|
|
|
// Hack alert.
|
2020-10-27 19:57:52 -04:00
|
|
|
return !baseItem.EnableMediaSourceDisplay;
|
|
|
|
}
|
|
|
|
|
2022-12-05 09:01:13 -05:00
|
|
|
if (libraryTypeOptions is not null)
|
2020-10-27 19:57:52 -04:00
|
|
|
{
|
2021-12-18 15:40:27 -05:00
|
|
|
return libraryTypeOptions.ImageFetchers.Contains(name.AsSpan(), StringComparison.OrdinalIgnoreCase);
|
2020-10-27 19:57:52 -04:00
|
|
|
}
|
|
|
|
|
2021-11-15 08:47:06 -05:00
|
|
|
var itemConfig = _serverConfigurationManager.Configuration.MetadataOptions.FirstOrDefault(i => string.Equals(i.ItemType, baseItem.GetType().Name, StringComparison.OrdinalIgnoreCase));
|
2020-10-27 19:57:52 -04:00
|
|
|
|
2022-12-05 09:00:20 -05:00
|
|
|
return itemConfig is null || !itemConfig.DisabledImageFetchers.Contains(name.AsSpan(), StringComparison.OrdinalIgnoreCase);
|
2020-10-27 19:57:52 -04:00
|
|
|
}
|
2020-12-03 02:07:51 -05:00
|
|
|
|
2020-12-03 20:11:53 -05:00
|
|
|
/// <summary>
|
|
|
|
/// Called when the configuration is updated.
|
|
|
|
/// It will refresh the metadata throttler if the relevant config changed.
|
|
|
|
/// </summary>
|
2021-08-15 11:20:07 -04:00
|
|
|
private void OnConfigurationUpdated(object? sender, EventArgs e)
|
2020-12-03 20:11:53 -05:00
|
|
|
{
|
|
|
|
int newMetadataRefreshConcurrency = GetMetadataRefreshConcurrency();
|
|
|
|
if (_metadataRefreshConcurrency != newMetadataRefreshConcurrency)
|
|
|
|
{
|
|
|
|
_metadataRefreshConcurrency = newMetadataRefreshConcurrency;
|
|
|
|
SetupMetadataThrottler();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-12-03 02:07:51 -05:00
|
|
|
/// <summary>
|
|
|
|
/// Creates the metadata refresh throttler.
|
|
|
|
/// </summary>
|
2021-08-15 11:20:07 -04:00
|
|
|
[MemberNotNull(nameof(MetadataRefreshThrottler))]
|
2020-12-03 02:07:51 -05:00
|
|
|
private void SetupMetadataThrottler()
|
|
|
|
{
|
2020-12-03 02:23:13 -05:00
|
|
|
MetadataRefreshThrottler = new SemaphoreSlim(_metadataRefreshConcurrency);
|
2020-12-03 02:07:51 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// Returns the metadata refresh concurrency.
|
|
|
|
/// </summary>
|
|
|
|
private int GetMetadataRefreshConcurrency()
|
|
|
|
{
|
|
|
|
var concurrency = _serverConfigurationManager.Configuration.LibraryMetadataRefreshConcurrency;
|
|
|
|
|
|
|
|
if (concurrency <= 0)
|
|
|
|
{
|
|
|
|
concurrency = Environment.ProcessorCount;
|
|
|
|
}
|
|
|
|
|
|
|
|
return concurrency;
|
|
|
|
}
|
2020-10-27 19:57:52 -04:00
|
|
|
}
|
2020-11-08 08:42:33 -05:00
|
|
|
}
|