jellyfin/Emby.Server.Implementations/LiveTv/EmbyTV/ItemDataProvider.cs

161 lines
4.1 KiB
C#
Raw Normal View History

#pragma warning disable CS1591
using System;
2015-07-20 18:32:55 +00:00
using System.Collections.Generic;
using System.IO;
using System.Linq;
using MediaBrowser.Model.Serialization;
using Microsoft.Extensions.Logging;
2015-07-20 18:32:55 +00:00
2016-11-03 23:35:19 +00:00
namespace Emby.Server.Implementations.LiveTv.EmbyTV
2015-07-20 18:32:55 +00:00
{
public class ItemDataProvider<T>
where T : class
{
private readonly IJsonSerializer _jsonSerializer;
private readonly string _dataPath;
private readonly object _fileDataLock = new object();
private T[] _items;
2015-07-20 18:32:55 +00:00
public ItemDataProvider(
IJsonSerializer jsonSerializer,
ILogger logger,
string dataPath,
Func<T, T, bool> equalityComparer)
2015-07-20 18:32:55 +00:00
{
_jsonSerializer = jsonSerializer;
2015-07-20 18:32:55 +00:00
Logger = logger;
_dataPath = dataPath;
EqualityComparer = equalityComparer;
}
protected ILogger Logger { get; }
2019-02-24 14:47:59 +00:00
protected Func<T, T, bool> EqualityComparer { get; }
2015-07-20 18:32:55 +00:00
private void EnsureLoaded()
2015-07-20 18:32:55 +00:00
{
if (_items != null)
2015-07-20 18:32:55 +00:00
{
return;
2015-07-20 18:32:55 +00:00
}
if (File.Exists(_dataPath))
2015-07-20 18:32:55 +00:00
{
Logger.LogInformation("Loading live tv data from {Path}", _dataPath);
try
{
_items = _jsonSerializer.DeserializeFromFile<T[]>(_dataPath);
return;
}
catch (Exception ex)
{
Logger.LogError(ex, "Error deserializing {Path}", _dataPath);
}
2015-07-20 18:32:55 +00:00
}
_items = Array.Empty<T>();
2015-07-20 18:32:55 +00:00
}
private void SaveList()
2015-07-20 18:32:55 +00:00
{
2019-02-24 14:47:59 +00:00
Directory.CreateDirectory(Path.GetDirectoryName(_dataPath));
_jsonSerializer.SerializeToFile(_items, _dataPath);
}
2015-07-23 23:40:54 +00:00
public IReadOnlyList<T> GetAll()
{
2015-07-20 18:32:55 +00:00
lock (_fileDataLock)
{
EnsureLoaded();
return (T[])_items.Clone();
2015-07-20 18:32:55 +00:00
}
}
public virtual void Update(T item)
{
if (item == null)
{
throw new ArgumentNullException(nameof(item));
}
lock (_fileDataLock)
2015-07-20 18:32:55 +00:00
{
EnsureLoaded();
2015-07-20 18:32:55 +00:00
var index = Array.FindIndex(_items, i => EqualityComparer(i, item));
if (index == -1)
{
throw new ArgumentException("item not found");
}
2015-07-20 18:32:55 +00:00
_items[index] = item;
SaveList();
}
2015-07-20 18:32:55 +00:00
}
public virtual void Add(T item)
{
if (item == null)
{
throw new ArgumentNullException(nameof(item));
}
lock (_fileDataLock)
2015-07-20 18:32:55 +00:00
{
EnsureLoaded();
2015-07-20 18:32:55 +00:00
if (_items.Any(i => EqualityComparer(i, item)))
{
throw new ArgumentException("item already exists", nameof(item));
}
2015-07-20 18:32:55 +00:00
int oldLen = _items.Length;
var newList = new T[oldLen + 1];
_items.CopyTo(newList, 0);
newList[oldLen] = item;
_items = newList;
SaveList();
}
2015-07-20 18:32:55 +00:00
}
public virtual void AddOrUpdate(T item)
{
lock (_fileDataLock)
{
EnsureLoaded();
int index = Array.FindIndex(_items, i => EqualityComparer(i, item));
if (index == -1)
{
int oldLen = _items.Length;
var newList = new T[oldLen + 1];
_items.CopyTo(newList, 0);
newList[oldLen] = item;
_items = newList;
}
else
{
_items[index] = item;
}
SaveList();
}
}
2015-11-21 04:55:26 +00:00
2015-07-20 18:32:55 +00:00
public virtual void Delete(T item)
{
lock (_fileDataLock)
{
EnsureLoaded();
_items = _items.Where(i => !EqualityComparer(i, item)).ToArray();
2015-07-20 18:32:55 +00:00
SaveList();
}
2015-07-20 18:32:55 +00:00
}
}
}