aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/Activity
diff options
context:
space:
mode:
authorPatrick Barron <barronpm@gmail.com>2020-08-15 02:07:28 -0400
committerPatrick Barron <barronpm@gmail.com>2020-08-15 02:07:28 -0400
commit8570cfdba652eb61e2746ea9de6cb9c8bb23eaf5 (patch)
tree50fd98b1dab544b1d74d5ae570cff091bbb38de8 /Emby.Server.Implementations/Activity
parentca3a8bdb98aeb5d112a4d2a456ebcc445dc5fd12 (diff)
Migrate ActivityLogEntryPoint.OnSessionEnded to IEventConsumer
Diffstat (limited to 'Emby.Server.Implementations/Activity')
-rw-r--r--Emby.Server.Implementations/Activity/ActivityLogEntryPoint.cs78
1 files changed, 0 insertions, 78 deletions
diff --git a/Emby.Server.Implementations/Activity/ActivityLogEntryPoint.cs b/Emby.Server.Implementations/Activity/ActivityLogEntryPoint.cs
deleted file mode 100644
index d863acd0b..000000000
--- a/Emby.Server.Implementations/Activity/ActivityLogEntryPoint.cs
+++ /dev/null
@@ -1,78 +0,0 @@
-using System.Globalization;
-using System.Threading.Tasks;
-using Jellyfin.Data.Entities;
-using MediaBrowser.Controller.Plugins;
-using MediaBrowser.Controller.Session;
-using MediaBrowser.Model.Activity;
-using MediaBrowser.Model.Globalization;
-
-namespace Emby.Server.Implementations.Activity
-{
- /// <summary>
- /// Entry point for the activity logger.
- /// </summary>
- public sealed class ActivityLogEntryPoint : IServerEntryPoint
- {
- private readonly ISessionManager _sessionManager;
- private readonly IActivityManager _activityManager;
- private readonly ILocalizationManager _localization;
-
- /// <summary>
- /// Initializes a new instance of the <see cref="ActivityLogEntryPoint"/> class.
- /// </summary>
- /// <param name="sessionManager">The session manager.</param>
- /// <param name="activityManager">The activity manager.</param>
- /// <param name="localization">The localization manager.</param>
- public ActivityLogEntryPoint(
- ISessionManager sessionManager,
- IActivityManager activityManager,
- ILocalizationManager localization)
- {
- _sessionManager = sessionManager;
- _activityManager = activityManager;
- _localization = localization;
- }
-
- /// <inheritdoc />
- public Task RunAsync()
- {
- _sessionManager.SessionEnded += OnSessionEnded;
-
- return Task.CompletedTask;
- }
-
- private async void OnSessionEnded(object sender, SessionEventArgs e)
- {
- var session = e.SessionInfo;
-
- if (string.IsNullOrEmpty(session.UserName))
- {
- return;
- }
-
- await CreateLogEntry(new ActivityLog(
- string.Format(
- CultureInfo.InvariantCulture,
- _localization.GetLocalizedString("UserOfflineFromDevice"),
- session.UserName,
- session.DeviceName),
- "SessionEnded",
- session.UserId)
- {
- ShortOverview = string.Format(
- CultureInfo.InvariantCulture,
- _localization.GetLocalizedString("LabelIpAddressValue"),
- session.RemoteEndPoint),
- }).ConfigureAwait(false);
- }
-
- private async Task CreateLogEntry(ActivityLog entry)
- => await _activityManager.CreateAsync(entry).ConfigureAwait(false);
-
- /// <inheritdoc />
- public void Dispose()
- {
- _sessionManager.SessionEnded -= OnSessionEnded;
- }
- }
-}