using System;
using System.Collections.Generic;
using System.Linq;
using Moq;
using NUnit.Framework;
using Umbraco.Core;
using Umbraco.Core.Logging;
using Umbraco.Core.Models.Membership;
using Umbraco.Core.Persistence;

using Umbraco.Core.Persistence.Querying;
using Umbraco.Core.Persistence.Repositories;
using Umbraco.Core.Persistence.UnitOfWork;
using Umbraco.Tests.TestHelpers;
using Umbraco.Tests.TestHelpers.Entities;

namespace Umbraco.Tests.Persistence.Repositories
{
    [DatabaseTestBehavior(DatabaseBehavior.NewDbFileAndSchemaPerTest)]
    [TestFixture]
    public class UserRepositoryTest : BaseDatabaseFactoryTest
    {
        [SetUp]
        public override void Initialize()
        {
            base.Initialize();
        }

        [TearDown]
        public override void TearDown()
        {
            base.TearDown();
        }

        private UserRepository CreateRepository(IDatabaseUnitOfWork unitOfWork, out UserTypeRepository userTypeRepository)
        {
            userTypeRepository = new UserTypeRepository(unitOfWork, CacheHelper.CreateDisabledCacheHelper(), Mock.Of<ILogger>(), MappingResolver);
            var repository = new UserRepository(unitOfWork, CacheHelper.CreateDisabledCacheHelper(), Mock.Of<ILogger>(), userTypeRepository, MappingResolver);
            return repository;
        }


        [Test]
        public void Can_Perform_Add_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var user = MockedUser.CreateUser(CreateAndCommitUserType());

                // Act
                repository.AddOrUpdate(user);
                unitOfWork.Flush();

                // Assert
                Assert.That(user.HasIdentity, Is.True);
            }
        }

        [Test]
        public void Can_Perform_Multiple_Adds_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var user1 = MockedUser.CreateUser(CreateAndCommitUserType(), "1");
                var use2 = MockedUser.CreateUser(CreateAndCommitUserType(), "2");

                // Act
                repository.AddOrUpdate(user1);
                unitOfWork.Flush();
                repository.AddOrUpdate(use2);
                unitOfWork.Flush();

                // Assert
                Assert.That(user1.HasIdentity, Is.True);
                Assert.That(use2.HasIdentity, Is.True);
            }
        }

        [Test]
        public void Can_Verify_Fresh_Entity_Is_Not_Dirty()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var user = MockedUser.CreateUser(CreateAndCommitUserType());
                repository.AddOrUpdate(user);
                unitOfWork.Flush();

                // Act
                var resolved = repository.Get((int)user.Id);
                bool dirty = ((User)resolved).IsDirty();

                // Assert
                Assert.That(dirty, Is.False);
            }
        }

        [Test]
        public void Can_Perform_Update_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var user = MockedUser.CreateUser(CreateAndCommitUserType());
                repository.AddOrUpdate(user);
                unitOfWork.Flush();

                // Act
                var resolved = (User)repository.Get((int)user.Id);

                resolved.Name = "New Name";
                //the db column is not used, default permissions are taken from the user type's permissions, this is a getter only
                //resolved.DefaultPermissions = "ZYX";
                resolved.Language = "fr";
                resolved.IsApproved = false;
                resolved.RawPasswordValue = "new";
                resolved.IsLockedOut = true;
                resolved.StartContentId = 10;
                resolved.StartMediaId = 11;
                resolved.Email = "new@new.com";
                resolved.Username = "newName";
                resolved.RemoveAllowedSection("content");

                repository.AddOrUpdate(resolved);
                unitOfWork.Flush();
                var updatedItem = (User)repository.Get((int)user.Id);

                // Assert
                Assert.That(updatedItem.Id, Is.EqualTo(resolved.Id));
                Assert.That(updatedItem.Name, Is.EqualTo(resolved.Name));
                //Assert.That(updatedItem.DefaultPermissions, Is.EqualTo(resolved.DefaultPermissions));
                Assert.That(updatedItem.Language, Is.EqualTo(resolved.Language));
                Assert.That(updatedItem.IsApproved, Is.EqualTo(resolved.IsApproved));
                Assert.That(updatedItem.RawPasswordValue, Is.EqualTo(resolved.RawPasswordValue));
                Assert.That(updatedItem.IsLockedOut, Is.EqualTo(resolved.IsLockedOut));
                Assert.That(updatedItem.StartContentId, Is.EqualTo(resolved.StartContentId));
                Assert.That(updatedItem.StartMediaId, Is.EqualTo(resolved.StartMediaId));
                Assert.That(updatedItem.Email, Is.EqualTo(resolved.Email));
                Assert.That(updatedItem.Username, Is.EqualTo(resolved.Username));
                Assert.That(updatedItem.AllowedSections.Count(), Is.EqualTo(1));
                Assert.IsTrue(updatedItem.AllowedSections.Contains("media"));
            }
        }

        [Test]
        public void Can_Perform_Delete_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var user = MockedUser.CreateUser(CreateAndCommitUserType());

                // Act
                repository.AddOrUpdate(user);
                unitOfWork.Flush();
                var id = user.Id;

                var utRepo = new UserTypeRepository(unitOfWork, CacheHelper.CreateDisabledCacheHelper(), Logger, MappingResolver);
                var repository2 = new UserRepository(unitOfWork, CacheHelper.CreateDisabledCacheHelper(), Logger, utRepo, MappingResolver);

                repository2.Delete(user);
                unitOfWork.Flush();

                var resolved = repository2.Get((int) id);

                // Assert
                Assert.That(resolved, Is.Null);
            }
        }

        //[Test]
        //public void Can_Perform_Delete_On_UserRepository_With_Permissions_Assigned()
        //{
        //    // Arrange
        //    var provider = new NPocoUnitOfWorkProvider(Logger);
        //    using (var unitOfWork = provider.GetUnitOfWork())
        //    UserTypeRepository userTypeRepository;
        //using (var repository = CreateRepository(unitOfWork, out userTypeRepository))
        //{

        //    var user = MockedUser.CreateUser(CreateAndCommitUserType());
        //    //repository.AssignPermissions()

        //    // Act
        //    repository.AddOrUpdate(user);
        //    unitOfWork.Commit();
        //    var id = user.Id;

        //    var repository2 = RepositoryResolver.Current.ResolveByType<IUserRepository>(unitOfWork);
        //    repository2.Delete(user);
        //    unitOfWork.Commit();

        //    var resolved = repository2.Get((int)id);

        //    // Assert
        //    Assert.That(resolved, Is.Null);
        //}

        //}

        [Test]
        public void Can_Perform_Get_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var user = MockedUser.CreateUser(CreateAndCommitUserType());
                repository.AddOrUpdate(user);
                unitOfWork.Flush();

                // Act
                var updatedItem = repository.Get((int) user.Id);

                // Assert
                AssertPropertyValues(updatedItem, user);
            }
        }

        [Test]
        public void Can_Perform_GetByQuery_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act
                var query = new Query<IUser>(SqlSyntax, MappingResolver).Where(x => x.Username == "TestUser1");
                var result = repository.GetByQuery(query);

                // Assert
                Assert.That(result.Count(), Is.GreaterThanOrEqualTo(1));
            }
        }

        [Test]
        public void Can_Perform_GetAll_By_Param_Ids_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var users = CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act
                var result = repository.GetAll((int) users[0].Id, (int) users[1].Id);

                // Assert
                Assert.That(result, Is.Not.Null);
                Assert.That(result.Any(), Is.True);
                Assert.That(result.Count(), Is.EqualTo(2));
            }
        }

        [Test]
        public void Can_Perform_GetAll_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act
                var result = repository.GetAll();

                // Assert
                Assert.That(result, Is.Not.Null);
                Assert.That(result.Any(), Is.True);
                Assert.That(result.Count(), Is.GreaterThanOrEqualTo(3));
            }
        }

        [Test]
        public void Can_Perform_Exists_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var users = CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act
                var exists = repository.Exists((int) users[0].Id);

                // Assert
                Assert.That(exists, Is.True);
            }
        }

        [Test]
        public void Can_Perform_Count_On_UserRepository()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var users = CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act
                var query = new Query<IUser>(SqlSyntax, MappingResolver).Where(x => x.Username == "TestUser1" || x.Username == "TestUser2");
                var result = repository.Count(query);

                // Assert
                Assert.That(result, Is.GreaterThanOrEqualTo(2));
            }
        }

        [Test]
        public void Can_Remove_Section_For_User()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var users = CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act

                //add and remove a few times, this tests the internal collection
                users[0].RemoveAllowedSection("content");
                users[0].RemoveAllowedSection("content");
                users[0].AddAllowedSection("content");
                users[0].RemoveAllowedSection("content");

                users[1].RemoveAllowedSection("media");
                users[1].RemoveAllowedSection("media");

                repository.AddOrUpdate(users[0]);
                repository.AddOrUpdate(users[1]);
                unitOfWork.Flush();

                // Assert
                var result = repository.GetAll((int) users[0].Id, (int) users[1].Id).ToArray();
                Assert.AreEqual(1, result[0].AllowedSections.Count());
                Assert.AreEqual("media", result[0].AllowedSections.First());
                Assert.AreEqual(1, result[1].AllowedSections.Count());
                Assert.AreEqual("content", result[1].AllowedSections.First());
            }
        }

        [Test]
        public void Can_Add_Section_For_User()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var users = CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act

                //add and remove a few times, this tests the internal collection
                users[0].AddAllowedSection("settings");
                users[0].AddAllowedSection("settings");
                users[0].RemoveAllowedSection("settings");
                users[0].AddAllowedSection("settings");

                users[1].AddAllowedSection("developer");

                //add the same even though it's already there
                users[2].AddAllowedSection("content");

                repository.AddOrUpdate(users[0]);
                repository.AddOrUpdate(users[1]);
                unitOfWork.Flush();

                // Assert
                var result = repository.GetAll((int) users[0].Id, (int) users[1].Id, (int) users[2].Id).ToArray();
                Assert.AreEqual(3, result[0].AllowedSections.Count());
                Assert.IsTrue(result[0].AllowedSections.Contains("content"));
                Assert.IsTrue(result[0].AllowedSections.Contains("media"));
                Assert.IsTrue(result[0].AllowedSections.Contains("settings"));
                Assert.AreEqual(3, result[1].AllowedSections.Count());
                Assert.IsTrue(result[1].AllowedSections.Contains("content"));
                Assert.IsTrue(result[1].AllowedSections.Contains("media"));
                Assert.IsTrue(result[1].AllowedSections.Contains("developer"));
                Assert.AreEqual(2, result[2].AllowedSections.Count());
                Assert.IsTrue(result[1].AllowedSections.Contains("content"));
                Assert.IsTrue(result[1].AllowedSections.Contains("media"));
            }
        }

        [Test]
        public void Can_Update_Section_For_User()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var users = CreateAndCommitMultipleUsers(repository, unitOfWork);

                // Act

                users[0].RemoveAllowedSection("content");
                users[0].AddAllowedSection("settings");

                repository.AddOrUpdate(users[0]);
                unitOfWork.Flush();

                // Assert
                var result = repository.Get((int) users[0].Id);
                Assert.AreEqual(2, result.AllowedSections.Count());
                Assert.IsTrue(result.AllowedSections.Contains("settings"));
                Assert.IsTrue(result.AllowedSections.Contains("media"));
            }
        }


        [Test]
        public void Get_Users_Assigned_To_Section()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                UserTypeRepository userTypeRepository;
                var repository = CreateRepository(unitOfWork, out userTypeRepository);

                var user1 = MockedUser.CreateUser(CreateAndCommitUserType(), "1", "test", "media");
                var user2 = MockedUser.CreateUser(CreateAndCommitUserType(), "2", "media", "settings");
                var user3 = MockedUser.CreateUser(CreateAndCommitUserType(), "3", "test", "settings");
                repository.AddOrUpdate(user1);
                repository.AddOrUpdate(user2);
                repository.AddOrUpdate(user3);
                unitOfWork.Flush();

                // Act

                var users = repository.GetUsersAssignedToSection("test");

                // Assert
                Assert.AreEqual(2, users.Count());
                var names = users.Select(x => x.Username).ToArray();
                Assert.IsTrue(names.Contains("TestUser1"));
                Assert.IsTrue(names.Contains("TestUser3"));
            }
        }

        [Test]
        public void Default_User_Permissions_Based_On_User_Type()
        {
            // Arrange
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                var utRepo = new UserTypeRepository(unitOfWork, CacheHelper.CreateDisabledCacheHelper(), Logger, MappingResolver);
                var repository = new UserRepository(unitOfWork, CacheHelper.CreateDisabledCacheHelper(), Logger, utRepo, MappingResolver);

                // Act
                var user1 = MockedUser.CreateUser(CreateAndCommitUserType(), "1", "test", "media");
                repository.AddOrUpdate(user1);
                unitOfWork.Flush();

                // Assert
                Assert.AreEqual(3, user1.DefaultPermissions.Count());
                Assert.AreEqual("A", user1.DefaultPermissions.ElementAt(0));
                Assert.AreEqual("B", user1.DefaultPermissions.ElementAt(1));
                Assert.AreEqual("C", user1.DefaultPermissions.ElementAt(2));
            }
        }

        private void AssertPropertyValues(IUser updatedItem, IUser originalUser)
        {
            Assert.That(updatedItem.Id, Is.EqualTo(originalUser.Id));
            Assert.That(updatedItem.Name, Is.EqualTo(originalUser.Name));
            Assert.That(updatedItem.DefaultPermissions, Is.EqualTo(originalUser.DefaultPermissions));
            Assert.That(updatedItem.Language, Is.EqualTo(originalUser.Language));
            Assert.That(updatedItem.IsApproved, Is.EqualTo(originalUser.IsApproved));
            Assert.That(updatedItem.RawPasswordValue, Is.EqualTo(originalUser.RawPasswordValue));
            Assert.That(updatedItem.IsLockedOut, Is.EqualTo(originalUser.IsLockedOut));
            Assert.That(updatedItem.StartContentId, Is.EqualTo(originalUser.StartContentId));
            Assert.That(updatedItem.StartMediaId, Is.EqualTo(originalUser.StartMediaId));
            Assert.That(updatedItem.Email, Is.EqualTo(originalUser.Email));
            Assert.That(updatedItem.Username, Is.EqualTo(originalUser.Username));
            Assert.That(updatedItem.AllowedSections.Count(), Is.EqualTo(2));
            Assert.IsTrue(updatedItem.AllowedSections.Contains("media"));
            Assert.IsTrue(updatedItem.AllowedSections.Contains("content"));
        }

        private IUser[] CreateAndCommitMultipleUsers(IUserRepository repository, IUnitOfWork unitOfWork)
        {
            var user1 = MockedUser.CreateUser(CreateAndCommitUserType(), "1");
            var user2 = MockedUser.CreateUser(CreateAndCommitUserType(), "2");
            var user3 = MockedUser.CreateUser(CreateAndCommitUserType(), "3");
            repository.AddOrUpdate(user1);
            repository.AddOrUpdate(user2);
            repository.AddOrUpdate(user3);
            unitOfWork.Flush();
            return new IUser[] { user1, user2, user3 };
        }

        private IUserType CreateAndCommitUserType()
        {
            var provider = new NPocoUnitOfWorkProvider(Logger);
            using (var unitOfWork = provider.GetUnitOfWork())
            {
                var repository = new UserTypeRepository(unitOfWork, CacheHelper.CreateDisabledCacheHelper(), Logger, MappingResolver);
                var userType = MockedUserType.CreateUserType();
                repository.AddOrUpdate(userType);
                unitOfWork.Flush();
                return userType;
            }
        }
    }
}