ActivityLogEntryPoint.cs 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172
  1. using System;
  2. using System.Globalization;
  3. using System.Threading.Tasks;
  4. using Jellyfin.Data.Entities;
  5. using MediaBrowser.Common.Plugins;
  6. using MediaBrowser.Common.Updates;
  7. using MediaBrowser.Controller.Plugins;
  8. using MediaBrowser.Controller.Session;
  9. using MediaBrowser.Model.Activity;
  10. using MediaBrowser.Model.Globalization;
  11. using MediaBrowser.Model.Notifications;
  12. using MediaBrowser.Model.Updates;
  13. namespace Emby.Server.Implementations.Activity
  14. {
  15. /// <summary>
  16. /// Entry point for the activity logger.
  17. /// </summary>
  18. public sealed class ActivityLogEntryPoint : IServerEntryPoint
  19. {
  20. private readonly IInstallationManager _installationManager;
  21. private readonly ISessionManager _sessionManager;
  22. private readonly IActivityManager _activityManager;
  23. private readonly ILocalizationManager _localization;
  24. /// <summary>
  25. /// Initializes a new instance of the <see cref="ActivityLogEntryPoint"/> class.
  26. /// </summary>
  27. /// <param name="sessionManager">The session manager.</param>
  28. /// <param name="activityManager">The activity manager.</param>
  29. /// <param name="localization">The localization manager.</param>
  30. /// <param name="installationManager">The installation manager.</param>
  31. public ActivityLogEntryPoint(
  32. ISessionManager sessionManager,
  33. IActivityManager activityManager,
  34. ILocalizationManager localization,
  35. IInstallationManager installationManager)
  36. {
  37. _sessionManager = sessionManager;
  38. _activityManager = activityManager;
  39. _localization = localization;
  40. _installationManager = installationManager;
  41. }
  42. /// <inheritdoc />
  43. public Task RunAsync()
  44. {
  45. _installationManager.PluginUninstalled += OnPluginUninstalled;
  46. _installationManager.PluginUpdated += OnPluginUpdated;
  47. _installationManager.PackageInstallationFailed += OnPackageInstallationFailed;
  48. _sessionManager.SessionStarted += OnSessionStarted;
  49. _sessionManager.SessionEnded += OnSessionEnded;
  50. return Task.CompletedTask;
  51. }
  52. private async void OnSessionEnded(object sender, SessionEventArgs e)
  53. {
  54. var session = e.SessionInfo;
  55. if (string.IsNullOrEmpty(session.UserName))
  56. {
  57. return;
  58. }
  59. await CreateLogEntry(new ActivityLog(
  60. string.Format(
  61. CultureInfo.InvariantCulture,
  62. _localization.GetLocalizedString("UserOfflineFromDevice"),
  63. session.UserName,
  64. session.DeviceName),
  65. "SessionEnded",
  66. session.UserId)
  67. {
  68. ShortOverview = string.Format(
  69. CultureInfo.InvariantCulture,
  70. _localization.GetLocalizedString("LabelIpAddressValue"),
  71. session.RemoteEndPoint),
  72. }).ConfigureAwait(false);
  73. }
  74. private async void OnSessionStarted(object sender, SessionEventArgs e)
  75. {
  76. var session = e.SessionInfo;
  77. if (string.IsNullOrEmpty(session.UserName))
  78. {
  79. return;
  80. }
  81. await CreateLogEntry(new ActivityLog(
  82. string.Format(
  83. CultureInfo.InvariantCulture,
  84. _localization.GetLocalizedString("UserOnlineFromDevice"),
  85. session.UserName,
  86. session.DeviceName),
  87. "SessionStarted",
  88. session.UserId)
  89. {
  90. ShortOverview = string.Format(
  91. CultureInfo.InvariantCulture,
  92. _localization.GetLocalizedString("LabelIpAddressValue"),
  93. session.RemoteEndPoint)
  94. }).ConfigureAwait(false);
  95. }
  96. private async void OnPluginUpdated(object sender, InstallationInfo e)
  97. {
  98. await CreateLogEntry(new ActivityLog(
  99. string.Format(
  100. CultureInfo.InvariantCulture,
  101. _localization.GetLocalizedString("PluginUpdatedWithName"),
  102. e.Name),
  103. NotificationType.PluginUpdateInstalled.ToString(),
  104. Guid.Empty)
  105. {
  106. ShortOverview = string.Format(
  107. CultureInfo.InvariantCulture,
  108. _localization.GetLocalizedString("VersionNumber"),
  109. e.Version),
  110. Overview = e.Changelog
  111. }).ConfigureAwait(false);
  112. }
  113. private async void OnPluginUninstalled(object sender, IPlugin e)
  114. {
  115. await CreateLogEntry(new ActivityLog(
  116. string.Format(
  117. CultureInfo.InvariantCulture,
  118. _localization.GetLocalizedString("PluginUninstalledWithName"),
  119. e.Name),
  120. NotificationType.PluginUninstalled.ToString(),
  121. Guid.Empty))
  122. .ConfigureAwait(false);
  123. }
  124. private async void OnPackageInstallationFailed(object sender, InstallationFailedEventArgs e)
  125. {
  126. var installationInfo = e.InstallationInfo;
  127. await CreateLogEntry(new ActivityLog(
  128. string.Format(
  129. CultureInfo.InvariantCulture,
  130. _localization.GetLocalizedString("NameInstallFailed"),
  131. installationInfo.Name),
  132. NotificationType.InstallationFailed.ToString(),
  133. Guid.Empty)
  134. {
  135. ShortOverview = string.Format(
  136. CultureInfo.InvariantCulture,
  137. _localization.GetLocalizedString("VersionNumber"),
  138. installationInfo.Version),
  139. Overview = e.Exception.Message
  140. }).ConfigureAwait(false);
  141. }
  142. private async Task CreateLogEntry(ActivityLog entry)
  143. => await _activityManager.CreateAsync(entry).ConfigureAwait(false);
  144. /// <inheritdoc />
  145. public void Dispose()
  146. {
  147. _installationManager.PluginUninstalled -= OnPluginUninstalled;
  148. _installationManager.PluginUpdated -= OnPluginUpdated;
  149. _installationManager.PackageInstallationFailed -= OnPackageInstallationFailed;
  150. _sessionManager.SessionStarted -= OnSessionStarted;
  151. _sessionManager.SessionEnded -= OnSessionEnded;
  152. }
  153. }
  154. }