using MediaBrowser.Common.Events; using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Library; using MediaBrowser.Controller.Persistence; using MediaBrowser.Model.Entities; using MediaBrowser.Model.Logging; using System; using System.Collections.Concurrent; using System.Threading; using System.Threading.Tasks; namespace MediaBrowser.Server.Implementations.Library { /// /// Class UserDataManager /// public class UserDataManager : IUserDataManager { public event EventHandler UserDataSaved; private readonly ConcurrentDictionary _userData = new ConcurrentDictionary(); private readonly ILogger _logger; public UserDataManager(ILogManager logManager) { _logger = logManager.GetLogger(GetType().Name); } /// /// Gets or sets the repository. /// /// The repository. public IUserDataRepository Repository { get; set; } /// /// Saves the user data. /// /// The user id. /// The key. /// The user data. /// The reason. /// The cancellation token. /// Task. /// /// userData /// or /// cancellationToken /// or /// userId /// or /// key /// public async Task SaveUserData(Guid userId, string key, UserItemData userData, UserDataSaveReason reason, CancellationToken cancellationToken) { if (userData == null) { throw new ArgumentNullException("userData"); } if (cancellationToken == null) { throw new ArgumentNullException("cancellationToken"); } if (userId == Guid.Empty) { throw new ArgumentNullException("userId"); } if (string.IsNullOrEmpty(key)) { throw new ArgumentNullException("key"); } cancellationToken.ThrowIfCancellationRequested(); try { await Repository.SaveUserData(userId, key, userData, cancellationToken).ConfigureAwait(false); var newValue = userData; // Once it succeeds, put it into the dictionary to make it available to everyone else _userData.AddOrUpdate(GetCacheKey(userId, key), newValue, delegate { return newValue; }); } catch (Exception ex) { _logger.ErrorException("Error saving user data", ex); throw; } EventHelper.FireEventIfNotNull(UserDataSaved, this, new UserDataSaveEventArgs { Key = key, UserData = userData, SaveReason = reason, UserId = userId }, _logger); } /// /// Gets the user data. /// /// The user id. /// The key. /// Task{UserItemData}. public UserItemData GetUserData(Guid userId, string key) { if (userId == Guid.Empty) { throw new ArgumentNullException("userId"); } if (string.IsNullOrEmpty(key)) { throw new ArgumentNullException("key"); } return _userData.GetOrAdd(GetCacheKey(userId, key), keyName => Repository.GetUserData(userId, key)); } /// /// Gets the internal key. /// /// The user id. /// The key. /// System.String. private string GetCacheKey(Guid userId, string key) { return userId + key; } } }