< Summary - Jellyfin

Information
Class: Jellyfin.LiveTv.Timers.ItemDataProvider<T>
Assembly: Jellyfin.LiveTv
File(s): /srv/git/jellyfin/src/Jellyfin.LiveTv/Timers/ItemDataProvider.cs
Line coverage
22%
Covered lines: 14
Uncovered lines: 47
Coverable lines: 61
Total lines: 156
Line coverage: 22.9%
Branch coverage
14%
Covered branches: 2
Total branches: 14
Branch coverage: 14.2%
Method coverage

Feature is only available for sponsors

Upgrade to PRO version

Coverage history

Coverage history 0 25 50 75 100

Metrics

MethodBranch coverage Crap Score Cyclomatic complexity Line coverage
.ctor(...)100%11100%
EnsureLoaded()33.33%20626.66%
SaveList()0%620%
GetAll()100%11100%
Update(...)0%620%
Add(...)0%620%
AddOrUpdate(...)0%620%
Delete(...)100%210%

File(s)

/srv/git/jellyfin/src/Jellyfin.LiveTv/Timers/ItemDataProvider.cs

#LineLine coverage
 1#pragma warning disable CS1591
 2
 3using System;
 4using System.Collections.Generic;
 5using System.Diagnostics.CodeAnalysis;
 6using System.IO;
 7using System.Linq;
 8using System.Text.Json;
 9using System.Threading;
 10using Jellyfin.Extensions.Json;
 11using Microsoft.Extensions.Logging;
 12
 13namespace Jellyfin.LiveTv.Timers
 14{
 15    public class ItemDataProvider<T>
 16        where T : class
 17    {
 18        private readonly string _dataPath;
 4219        private readonly Lock _fileDataLock = new();
 4220        private readonly JsonSerializerOptions _jsonOptions = JsonDefaults.Options;
 21        private T[]? _items;
 22
 23        public ItemDataProvider(
 24            ILogger logger,
 25            string dataPath,
 26            Func<T, T, bool> equalityComparer)
 27        {
 4228            Logger = logger;
 4229            _dataPath = dataPath;
 4230            EqualityComparer = equalityComparer;
 4231        }
 32
 33        protected ILogger Logger { get; }
 34
 35        protected Func<T, T, bool> EqualityComparer { get; }
 36
 37        [MemberNotNull(nameof(_items))]
 38        private void EnsureLoaded()
 39        {
 2140            if (_items is not null)
 41            {
 042                return;
 43            }
 44
 2145            if (File.Exists(_dataPath))
 46            {
 047                Logger.LogInformation("Loading live tv data from {Path}", _dataPath);
 48
 49                try
 50                {
 051                    var bytes = File.ReadAllBytes(_dataPath);
 052                    _items = JsonSerializer.Deserialize<T[]>(bytes, _jsonOptions);
 053                    if (_items is null)
 54                    {
 055                        Logger.LogError("Error deserializing {Path}, data was null", _dataPath);
 056                        _items = Array.Empty<T>();
 57                    }
 58
 059                    return;
 60                }
 061                catch (JsonException ex)
 62                {
 063                    Logger.LogError(ex, "Error deserializing {Path}", _dataPath);
 064                }
 65            }
 66
 2167            _items = Array.Empty<T>();
 2168        }
 69
 70        private void SaveList()
 71        {
 072            Directory.CreateDirectory(Path.GetDirectoryName(_dataPath) ?? throw new ArgumentException("Path can't be a r
 073            var jsonString = JsonSerializer.Serialize(_items, _jsonOptions);
 074            File.WriteAllText(_dataPath, jsonString);
 075        }
 76
 77        public IReadOnlyList<T> GetAll()
 2178        {
 79            lock (_fileDataLock)
 80            {
 2181                EnsureLoaded();
 2182                return (T[])_items.Clone();
 83            }
 2184        }
 85
 86        public virtual void Update(T item)
 87        {
 088            ArgumentNullException.ThrowIfNull(item);
 89
 90            lock (_fileDataLock)
 91            {
 092                EnsureLoaded();
 93
 094                var index = Array.FindIndex(_items, i => EqualityComparer(i, item));
 095                if (index == -1)
 96                {
 097                    throw new ArgumentException("item not found");
 98                }
 99
 0100                _items[index] = item;
 101
 0102                SaveList();
 0103            }
 0104        }
 105
 106        public virtual void Add(T item)
 107        {
 0108            ArgumentNullException.ThrowIfNull(item);
 109
 110            lock (_fileDataLock)
 111            {
 0112                EnsureLoaded();
 113
 0114                if (_items.Any(i => EqualityComparer(i, item)))
 115                {
 0116                    throw new ArgumentException("item already exists", nameof(item));
 117                }
 118
 0119                _items = [.._items, item];
 120
 0121                SaveList();
 0122            }
 0123        }
 124
 125        public virtual void AddOrUpdate(T item)
 0126        {
 127            lock (_fileDataLock)
 128            {
 0129                EnsureLoaded();
 130
 0131                int index = Array.FindIndex(_items, i => EqualityComparer(i, item));
 0132                if (index == -1)
 133                {
 0134                    _items = [.._items, item];
 135                }
 136                else
 137                {
 0138                    _items[index] = item;
 139                }
 140
 0141                SaveList();
 0142            }
 0143        }
 144
 145        public virtual void Delete(T item)
 0146        {
 147            lock (_fileDataLock)
 148            {
 0149                EnsureLoaded();
 0150                _items = _items.Where(i => !EqualityComparer(i, item)).ToArray();
 151
 0152                SaveList();
 0153            }
 0154        }
 155    }
 156}
Generated by: ReportGenerator 5.4.5.0
4/26/2025 - 12:10:59 AM
GitHub | reportgenerator.io

Methods/Properties

.ctor(Microsoft.Extensions.Logging.ILogger,System.String,System.Func`3<T,T,System.Boolean>)
EnsureLoaded()
SaveList()
GetAll()
Update(T)
Add(T)
AddOrUpdate(T)
Delete(T)