ActivityManager.cs 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. using System;
  2. using MediaBrowser.Controller.Library;
  3. using MediaBrowser.Model.Activity;
  4. using MediaBrowser.Model.Events;
  5. using MediaBrowser.Model.Querying;
  6. namespace Emby.Server.Implementations.Activity
  7. {
  8. /// <summary>
  9. /// The activity log manager.
  10. /// </summary>
  11. public class ActivityManager : IActivityManager
  12. {
  13. private readonly IActivityRepository _repo;
  14. private readonly IUserManager _userManager;
  15. /// <summary>
  16. /// Initializes a new instance of the <see cref="ActivityManager"/> class.
  17. /// </summary>
  18. /// <param name="repo">The activity repository.</param>
  19. /// <param name="userManager">The user manager.</param>
  20. public ActivityManager(IActivityRepository repo, IUserManager userManager)
  21. {
  22. _repo = repo;
  23. _userManager = userManager;
  24. }
  25. /// <inheritdoc />
  26. public event EventHandler<GenericEventArgs<ActivityLogEntry>> EntryCreated;
  27. public void Create(ActivityLogEntry entry)
  28. {
  29. entry.Date = DateTime.UtcNow;
  30. _repo.Create(entry);
  31. EntryCreated?.Invoke(this, new GenericEventArgs<ActivityLogEntry>(entry));
  32. }
  33. /// <inheritdoc />
  34. public QueryResult<ActivityLogEntry> GetActivityLogEntries(DateTime? minDate, bool? hasUserId, int? startIndex, int? limit)
  35. {
  36. var result = _repo.GetActivityLogEntries(minDate, hasUserId, startIndex, limit);
  37. foreach (var item in result.Items)
  38. {
  39. if (item.UserId == Guid.Empty)
  40. {
  41. continue;
  42. }
  43. var user = _userManager.GetUserById(item.UserId);
  44. if (user != null)
  45. {
  46. var dto = _userManager.GetUserDto(user);
  47. item.UserPrimaryImageTag = dto.PrimaryImageTag;
  48. }
  49. }
  50. return result;
  51. }
  52. /// <inheritdoc />
  53. public QueryResult<ActivityLogEntry> GetActivityLogEntries(DateTime? minDate, int? startIndex, int? limit)
  54. {
  55. return GetActivityLogEntries(minDate, null, startIndex, limit);
  56. }
  57. }
  58. }