Delete user config dir on user deletion

pull/2206/head
Bond_009 5 years ago
parent b3963058db
commit ab57b504fe

@ -42,13 +42,13 @@ namespace Emby.Server.Implementations.Library
/// </summary> /// </summary>
public class UserManager : IUserManager public class UserManager : IUserManager
{ {
private readonly object _policySyncLock = new object();
private readonly object _configSyncLock = new object();
/// <summary> /// <summary>
/// The logger. /// The logger.
/// </summary> /// </summary>
private readonly ILogger _logger; private readonly ILogger _logger;
private readonly object _policySyncLock = new object();
/// <summary> /// <summary>
/// Gets the active user repository. /// Gets the active user repository.
/// </summary> /// </summary>
@ -255,7 +255,12 @@ namespace Emby.Server.Implementations.Library
return builder.ToString(); return builder.ToString();
} }
public async Task<User> AuthenticateUser(string username, string password, string hashedPassword, string remoteEndPoint, bool isUserSession) public async Task<User> AuthenticateUser(
string username,
string password,
string hashedPassword,
string remoteEndPoint,
bool isUserSession)
{ {
if (string.IsNullOrWhiteSpace(username)) if (string.IsNullOrWhiteSpace(username))
{ {
@ -754,13 +759,10 @@ namespace Emby.Server.Implementations.Library
return user; return user;
} }
/// <summary> /// <inheritdoc />
/// Deletes the user. /// <exception cref="ArgumentNullException">The <c>user</c> is <c>null</c>.</exception>
/// </summary> /// <exception cref="ArgumentException">The <c>user</c> doesn't exist, or is the last administrator.</exception>
/// <param name="user">The user.</param> /// <exception cref="InvalidOperationException">The <c>user</c> can't be deleted; there are no other users.</exception>
/// <returns>Task.</returns>
/// <exception cref="ArgumentNullException">user</exception>
/// <exception cref="ArgumentException"></exception>
public void DeleteUser(User user) public void DeleteUser(User user)
{ {
if (user == null) if (user == null)
@ -779,7 +781,7 @@ namespace Emby.Server.Implementations.Library
if (_users.Count == 1) if (_users.Count == 1)
{ {
throw new ArgumentException(string.Format( throw new InvalidOperationException(string.Format(
CultureInfo.InvariantCulture, CultureInfo.InvariantCulture,
"The user '{0}' cannot be deleted because there must be at least one user in the system.", "The user '{0}' cannot be deleted because there must be at least one user in the system.",
user.Name)); user.Name));
@ -800,17 +802,20 @@ namespace Emby.Server.Implementations.Library
_userRepository.DeleteUser(user); _userRepository.DeleteUser(user);
try // Delete user config dir
{ lock (_configSyncLock)
_fileSystem.DeleteFile(configPath); lock (_policySyncLock)
}
catch (IOException ex)
{ {
_logger.LogError(ex, "Error deleting file {path}", configPath); try
{
Directory.Delete(user.ConfigurationDirectoryPath, true);
}
catch (IOException ex)
{
_logger.LogError(ex, "Error deleting user config dir: {Path}", user.ConfigurationDirectoryPath);
}
} }
DeleteUserPolicy(user);
_users.TryRemove(user.Id, out _); _users.TryRemove(user.Id, out _);
OnUserDeleted(user); OnUserDeleted(user);
@ -918,10 +923,9 @@ namespace Emby.Server.Implementations.Library
public UserPolicy GetUserPolicy(User user) public UserPolicy GetUserPolicy(User user)
{ {
var path = GetPolicyFilePath(user); var path = GetPolicyFilePath(user);
if (!File.Exists(path)) if (!File.Exists(path))
{ {
return GetDefaultPolicy(user); return GetDefaultPolicy();
} }
try try
@ -931,19 +935,15 @@ namespace Emby.Server.Implementations.Library
return (UserPolicy)_xmlSerializer.DeserializeFromFile(typeof(UserPolicy), path); return (UserPolicy)_xmlSerializer.DeserializeFromFile(typeof(UserPolicy), path);
} }
} }
catch (IOException)
{
return GetDefaultPolicy(user);
}
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "Error reading policy file: {path}", path); _logger.LogError(ex, "Error reading policy file: {Path}", path);
return GetDefaultPolicy(user); return GetDefaultPolicy();
} }
} }
private static UserPolicy GetDefaultPolicy(User user) private static UserPolicy GetDefaultPolicy()
{ {
return new UserPolicy return new UserPolicy
{ {
@ -983,27 +983,6 @@ namespace Emby.Server.Implementations.Library
} }
} }
private void DeleteUserPolicy(User user)
{
var path = GetPolicyFilePath(user);
try
{
lock (_policySyncLock)
{
_fileSystem.DeleteFile(path);
}
}
catch (IOException)
{
}
catch (Exception ex)
{
_logger.LogError(ex, "Error deleting policy file");
}
}
private static string GetPolicyFilePath(User user) private static string GetPolicyFilePath(User user)
{ {
return Path.Combine(user.ConfigurationDirectoryPath, "policy.xml"); return Path.Combine(user.ConfigurationDirectoryPath, "policy.xml");
@ -1030,19 +1009,14 @@ namespace Emby.Server.Implementations.Library
return (UserConfiguration)_xmlSerializer.DeserializeFromFile(typeof(UserConfiguration), path); return (UserConfiguration)_xmlSerializer.DeserializeFromFile(typeof(UserConfiguration), path);
} }
} }
catch (IOException)
{
return new UserConfiguration();
}
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "Error reading policy file: {path}", path); _logger.LogError(ex, "Error reading policy file: {Path}", path);
return new UserConfiguration(); return new UserConfiguration();
} }
} }
private readonly object _configSyncLock = new object();
public void UpdateConfiguration(Guid userId, UserConfiguration config) public void UpdateConfiguration(Guid userId, UserConfiguration config)
{ {
var user = GetUserById(userId); var user = GetUserById(userId);

@ -102,8 +102,6 @@ namespace MediaBrowser.Controller.Library
/// </summary> /// </summary>
/// <param name="user">The user.</param> /// <param name="user">The user.</param>
/// <returns>Task.</returns> /// <returns>Task.</returns>
/// <exception cref="ArgumentNullException">user</exception>
/// <exception cref="ArgumentException"></exception>
void DeleteUser(User user); void DeleteUser(User user);
/// <summary> /// <summary>

Loading…
Cancel
Save