ActivityManager.cs 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. #pragma warning disable CS1591
  2. using System;
  3. using MediaBrowser.Controller.Library;
  4. using MediaBrowser.Model.Activity;
  5. using MediaBrowser.Model.Events;
  6. using MediaBrowser.Model.Querying;
  7. using Microsoft.Extensions.Logging;
  8. namespace Emby.Server.Implementations.Activity
  9. {
  10. public class ActivityManager : IActivityManager
  11. {
  12. private readonly IActivityRepository _repo;
  13. private readonly IUserManager _userManager;
  14. public ActivityManager(IActivityRepository repo, IUserManager userManager)
  15. {
  16. _repo = repo;
  17. _userManager = userManager;
  18. }
  19. public event EventHandler<GenericEventArgs<ActivityLogEntry>> EntryCreated;
  20. public void Create(ActivityLogEntry entry)
  21. {
  22. entry.Date = DateTime.UtcNow;
  23. _repo.Create(entry);
  24. EntryCreated?.Invoke(this, new GenericEventArgs<ActivityLogEntry>(entry));
  25. }
  26. public QueryResult<ActivityLogEntry> GetActivityLogEntries(DateTime? minDate, bool? hasUserId, int? startIndex, int? limit)
  27. {
  28. var result = _repo.GetActivityLogEntries(minDate, hasUserId, startIndex, limit);
  29. foreach (var item in result.Items)
  30. {
  31. if (item.UserId == Guid.Empty)
  32. {
  33. continue;
  34. }
  35. var user = _userManager.GetUserById(item.UserId);
  36. if (user != null)
  37. {
  38. var dto = _userManager.GetUserDto(user);
  39. item.UserPrimaryImageTag = dto.PrimaryImageTag;
  40. }
  41. }
  42. return result;
  43. }
  44. public QueryResult<ActivityLogEntry> GetActivityLogEntries(DateTime? minDate, int? startIndex, int? limit)
  45. {
  46. return GetActivityLogEntries(minDate, null, startIndex, limit);
  47. }
  48. }
  49. }