using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using System;
using System.Linq;
using System.Threading.Tasks;
using Timeline.Entities;
using Timeline.Helpers;
using Timeline.Models.Validation;
namespace Timeline.Services.User
{
public interface IUserCredentialService
{
///
/// Try to verify the given username and password.
///
/// The username of the user to verify.
/// The password of the user to verify.
/// User id.
/// Thrown when or is null.
/// Thrown when is of bad format or is empty.
/// Thrown when the user with given username does not exist.
/// Thrown when password is wrong.
Task VerifyCredential(string username, string password);
///
/// Try to change a user's password with old password.
///
/// The id of user to change password of.
/// Old password.
/// New password.
/// Thrown if or is null.
/// Thrown if or is empty.
/// Thrown if the user with given username does not exist.
/// Thrown if the old password is wrong.
Task ChangePassword(long id, string oldPassword, string newPassword);
}
public class UserCredentialService : IUserCredentialService
{
private readonly ILogger _logger;
private readonly DatabaseContext _database;
private readonly IPasswordService _passwordService;
private readonly UsernameValidator _usernameValidator = new UsernameValidator();
public UserCredentialService(ILogger logger, DatabaseContext database, IPasswordService passwordService)
{
_logger = logger;
_database = database;
_passwordService = passwordService;
}
public async Task VerifyCredential(string username, string password)
{
if (username == null)
throw new ArgumentNullException(nameof(username));
if (password == null)
throw new ArgumentNullException(nameof(password));
if (!_usernameValidator.Validate(username, out var message))
throw new ArgumentException(message);
if (password.Length == 0)
throw new ArgumentException("Password can't be empty.");
var entity = await _database.Users.Where(u => u.Username == username).Select(u => new { u.Id, u.Password }).SingleOrDefaultAsync();
if (entity == null)
throw new UserNotExistException(username);
if (!_passwordService.VerifyPassword(entity.Password, password))
throw new BadPasswordException(password);
return entity.Id;
}
public async Task ChangePassword(long id, string oldPassword, string newPassword)
{
if (oldPassword == null)
throw new ArgumentNullException(nameof(oldPassword));
if (newPassword == null)
throw new ArgumentNullException(nameof(newPassword));
if (oldPassword.Length == 0)
throw new ArgumentException("Old password can't be empty.");
if (newPassword.Length == 0)
throw new ArgumentException("New password can't be empty.");
var entity = await _database.Users.Where(u => u.Id == id).SingleOrDefaultAsync();
if (entity == null)
throw new UserNotExistException(id);
if (!_passwordService.VerifyPassword(entity.Password, oldPassword))
throw new BadPasswordException(oldPassword);
entity.Password = _passwordService.HashPassword(newPassword);
entity.Version += 1;
await _database.SaveChangesAsync();
_logger.LogInformation(Log.Format(Resources.Services.UserService.LogDatabaseUpdate, ("Id", id), ("Operation", "Change password")));
}
}
}