PrivateChatsRepositoryTests

Govor.API.Tests/IntegrationTests/EF/Repositories/PrivateChatsRepositoryTests.cs

@@ -1,7 +1,203 @@
+using AutoFixture;
+using Govor.Core.Infrastructure.Validators;
+using Govor.Core.Models;
+using Govor.Data;
+using Govor.Data.Repositories;
+using Govor.Data.Repositories.Exceptions;
+using Microsoft.EntityFrameworkCore;
+
 namespace Govor.API.Tests.IntegrationTests.EF.Repositories;
 
 [TestFixture]
 public class PrivateChatsRepositoryTests
 {
+    private Fixture _fixture;
+    private DbContextOptions<GovorDbContext> _options;
+    private IObjectValidator<PrivateChat> _validator = new PrivateChatValidator();
+    private int _testIteration = 0;
     
+    [SetUp]
+    public void SetUp()
+    {
+        _testIteration += 1;
+        
+        _fixture = new Fixture();
+
+        _fixture.Behaviors
+            .OfType<ThrowingRecursionBehavior>()
+            .ToList()
+            .ForEach(b => _fixture.Behaviors.Remove(b));
+
+        _fixture.Behaviors.Add(new OmitOnRecursionBehavior());
+
+        _options = new DbContextOptionsBuilder<GovorDbContext>()
+            .UseInMemoryDatabase(databaseName: $"DbGovor_{nameof(PrivateChatsRepositoryTests)}_{_testIteration}")
+            .Options;
+    }
+    
+    [Test]
+    public async Task Given_NotEmptySetDb_When_GetAll_Then_ReturnAll()
+    {
+        // Arrange
+        var random = new Random();
+        var chats = _fixture.CreateMany<PrivateChat>(random.Next(2, 10)).ToList();
+
+        await using var context = new GovorDbContext(_options);
+        var messagesRepository = new PrivateChatsRepository(context, _validator);
+
+        context.PrivateChats.AddRange(chats);
+        await context.SaveChangesAsync();
+
+        // Act 
+
+        var result = await messagesRepository.GetAllAsync();
+
+        // Assert 
+        Assert.That(result, Is.Not.Null);
+        Assert.That(result.Count, Is.EqualTo(chats.Count));
+        Assert.That(result, Is.EquivalentTo(chats));
+    }
+    
+    [Test]
+    public void Given_EmptySetDb_When_GetAll_Should_Throw_NotFoundException()
+    {
+        // Arrange 
+        using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        // Act & Assert 
+        Assert.ThrowsAsync<NotFoundException>(async () => await repository.GetAllAsync());
+    }
+    
+    [Test]
+    public async Task Given_ValidChatId_When_GetById_Then_ReturnChat()
+    {
+        // Arrange 
+        var chats = _fixture.CreateMany<PrivateChat>(10);
+        var id = chats.First().Id;
+        
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        
+        context.PrivateChats.AddRange(chats);
+        await context.SaveChangesAsync();
+        
+        // Act
+        var result = await repository.GetByIdAsync(id);
+        
+        // Assert 
+        Assert.That(result, Is.Not.Null);
+        Assert.That(result, Is.EqualTo(chats.First()));
+    }
+    
+    [Test]
+    public async Task Given_InvalidMessageId_When_FindById_Should_Throw_NotFoundByKeyException()
+    {
+        // Arrange 
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        
+        // Act & Assert 
+        Assert.ThrowsAsync<NotFoundByKeyException<Guid>>(async () => await repository.GetByIdAsync(_fixture.Create<Guid>()));
+    }
+    
+    [Test]
+    public async Task Given_MembersId_When_GetByMembersAsync_Then_ReturnChat()
+    {
+        // Arrange 
+        var chats = _fixture.CreateMany<PrivateChat>(10);
+        var id1 = chats.First().UserAId;
+        var id2 = chats.First().UserBId;
+        
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        
+        context.PrivateChats.AddRange(chats);
+        await context.SaveChangesAsync();
+        
+        // Act
+        var result = await repository.GetByMembersAsync(id1, id2);
+        
+        // Assert 
+        Assert.That(result, Is.Not.Null);
+        Assert.That(result, Is.EqualTo(chats.First()));
+    }
+    
+    [Test]
+    public async Task Given_InvalidMembersId_When_GetByMembersAsync_Should_Throw_NotFoundByKeyException()
+    {
+        // Arrange 
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        
+        // Act & Assert 
+        Assert.ThrowsAsync<NotFoundByKeyException<(Guid, Guid)>>(async () => await repository.GetByMembersAsync(_fixture.Create<Guid>(), _fixture.Create<Guid>()));
+    }
+    
+    [Test]
+    public async Task Given_ValidMessage_When_AddAsync_Then_MessageAdded()
+    {
+        // Arrange
+        var chat = _fixture.Create<PrivateChat>();
+        
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+    
+        // Act 
+        await repository.AddAsync(chat);
+        
+        // Assert 
+        Assert.That(context.PrivateChats.Count, Is.EqualTo(1));
+        Assert.That(context.PrivateChats.First(), Is.EqualTo(chat));
+    }
+    
+    [Test]
+    public async Task Given_InvalidMessage_When_AddAsync_Should_Throw_AdditionException()
+    {
+        // Arrange
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        
+        // Act & Assert 
+        Assert.ThrowsAsync<AdditionException>(async () => await repository.AddAsync(default));
+    }
+    
+    [Test]
+    public async Task Given_ExistMessage_When_Exist_Then_ReturnTrue()
+    {
+        // Arrange
+        var chat = _fixture.Create<PrivateChat>();
+        
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        
+        context.PrivateChats.Add(chat);
+        await context.SaveChangesAsync();
+        
+        // Act 
+        var result1 = repository.Exist(chat.UserAId, chat.UserBId);
+        var result2 = repository.Exist(chat.Id);
+        
+        
+        // Assert 
+        Assert.That(result1, Is.True);
+        Assert.That(result2, Is.True);
+    }
+
+    [Test]
+    public async Task Given_NotExistMessage_When_Exist_Then_ReturnFalse()
+    {
+        // Arrange
+        var chat = _fixture.Create<PrivateChat>();
+        
+        await using var context = new GovorDbContext(_options);
+        var repository = new PrivateChatsRepository(context, _validator);
+        
+        // Act 
+        var result1 = repository.Exist(chat.UserAId, chat.UserBId);
+        var result2 = repository.Exist(chat.Id);
+        
+        // Assert 
+        Assert.That(result1, Is.False);
+        Assert.That(result2, Is.False);
+    }
 }

Govor.API.Tests/UnitTests/Infrastructure/Validators/ChatGroupValidatorTests.cs

@@ -0,0 +1,7 @@
+namespace Govor.API.Tests.UnitTests.Infrastructure.Validators;
+
+[TestFixture]
+public class ChatGroupValidatorTests
+{
+    
+}

Govor.API.Tests/UnitTests/Infrastructure/Validators/PrivateChatValidatorTests.cs

@@ -1,7 +1,77 @@
+using AutoFixture;
+using Govor.Core.Infrastructure.Validators;
+using Govor.Core.Models;
+
 namespace Govor.API.Tests.UnitTests.Infrastructure.Validators;
 
 [TestFixture]
 public class PrivateChatValidatorTests
 {
+    private IObjectValidator<PrivateChat> _validator = new PrivateChatValidator();
+    private Fixture _fixture;
     
+    [SetUp]
+    public void SetUp()
+    {
+        _fixture = new Fixture();
+
+        _fixture.Behaviors
+            .OfType<ThrowingRecursionBehavior>()
+            .ToList()
+            .ForEach(b => _fixture.Behaviors.Remove(b));
+
+        _fixture.Behaviors.Add(new OmitOnRecursionBehavior());
+    }
+
+    [Test]
+    public void Validate_PrivateChat_Valid()
+    {
+        // Arrange
+        var privateChat = _fixture.Create<PrivateChat>();
+        
+        // Act & Assert 
+        Assert.DoesNotThrow(() => _validator.Validate(privateChat));
+        Assert.That(_validator.TryValidate(privateChat), Is.True);
+    }
+
+    [Test]
+    public void Validate_When_PrivateChatIsNull_Invalid()
+    {
+        // Act & Assert 
+        Assert.Throws<InvalidObjectException<PrivateChat>>(() => _validator.Validate(default));
+        Assert.That(_validator.TryValidate(default), Is.False);
+    }
+
+    [Test]
+    public void Validate_When_PrivateChatIdIsEmpty_Invalid()
+    {
+        // Arrange 
+        var privateChat = _fixture.Create<PrivateChat>();
+        privateChat.Id = Guid.Empty;
+        // Act & Assert 
+        Assert.Throws<InvalidObjectException<PrivateChat>>(() => _validator.Validate(privateChat));
+        Assert.That(_validator.TryValidate(privateChat), Is.False);
+    }
+    
+    [Test]
+    public void Validate_When_UserAIdIsEmpty_Invalid()
+    {
+        // Arrange 
+        var privateChat = _fixture.Create<PrivateChat>();
+        privateChat.UserAId = Guid.Empty;
+        // Act & Assert 
+        Assert.Throws<InvalidObjectException<PrivateChat>>(() => _validator.Validate(privateChat));
+        Assert.That(_validator.TryValidate(privateChat), Is.False);
+    }
+    
+    [Test]
+    public void Validate_When_UserBIdIsEmpty_Invalid()
+    {
+        // Arrange 
+        var privateChat = _fixture.Create<PrivateChat>();
+        privateChat.UserBId = Guid.Empty;
+        // Act & Assert 
+        Assert.Throws<InvalidObjectException<PrivateChat>>(() => _validator.Validate(privateChat));
+        Assert.That(_validator.TryValidate(privateChat), Is.False);
+    }
 }

Govor.API.Tests/UnitTests/Services/MessageServiceTests.cs

@@ -69,7 +69,7 @@ public class MessageServiceTests
         var result = await _messageService.SendMessageAsync(sendMessageParams);
         // Assert 
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(true));
+        Assert.That(result.IsSuccess, Is.True);
         Assert.That(result.Exception, Is.Null);
         
         _mockMessagesRepo.Verify(r => r.AddAsync(It.Is<Message>(m => 
@@ -103,7 +103,7 @@ public class MessageServiceTests
         
         // Assert 
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(true));
+        Assert.That(result.IsSuccess, Is.True);
         Assert.That(result.Exception, Is.Null);
         _mockMessagesRepo.Verify(r => r.AddAsync(It.Is<Message>(m =>
             m.RecipientId == groupId &&
@@ -132,7 +132,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(false));
+        Assert.That(result.IsSuccess, Is.False);
         Assert.That(result.Exception, Is.Not.Null);
         Assert.That(result.Exception,Is.TypeOf<KeyNotFoundException>());
         Assert.That(result.Message, Is.Null);
@@ -162,7 +162,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(false));
+        Assert.That(result.IsSuccess, Is.False);
         Assert.That(result.Exception, Is.Not.Null);
         Assert.That(result.Exception,Is.TypeOf<FriendshipException>());
         Assert.That(result.Message, Is.Null);
@@ -197,7 +197,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(true));
+        Assert.That(result.IsSuccess, Is.True);
         Assert.That(result.OriginalMessage, Is.Not.Null);
         
         Assert.That(messageId, Is.EqualTo(result.OriginalMessage!.Id));
@@ -225,7 +225,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(false));
+        Assert.That(result.IsSuccess, Is.False);
         Assert.That(result.Exception, Is.Not.Null);
         Assert.That(result.Exception,Is.TypeOf<NotFoundByKeyException<Guid>>());
         Assert.That(result.OriginalMessage, Is.Null);
@@ -248,7 +248,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(false));
+        Assert.That(result.IsSuccess, Is.False);
         Assert.That(result.Exception, Is.Not.Null);
         Assert.That(result.Exception,Is.TypeOf<UnauthorizedAccessException>());
         Assert.That(result.OriginalMessage, Is.Null);
@@ -272,7 +272,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(true));
+        Assert.That(result.IsSuccess, Is.True);
         Assert.That(result.OriginalMessage, Is.Not.Null);
         Assert.That(messageId, Is.EqualTo(result.OriginalMessage!.Id));
         _mockMessagesRepo.Verify(r => r.RemoveAsync(messageId), Times.Once);
@@ -294,7 +294,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(false));
+        Assert.That(result.IsSuccess, Is.False);
         Assert.That(result.Exception, Is.Not.Null);
         Assert.That(result.Exception,Is.TypeOf<NotFoundByKeyException<Guid>>());
         Assert.That(result.OriginalMessage, Is.Null);
@@ -317,7 +317,7 @@ public class MessageServiceTests
 
         // Assert
         Assert.That(result, Is.Not.Null);
-        Assert.That(result.IsSuccess, Is.EqualTo(false));
+        Assert.That(result.IsSuccess, Is.False);
         Assert.That(result.Exception, Is.Not.Null);
         Assert.That(result.Exception,Is.TypeOf<UnauthorizedAccessException>());
         Assert.That(result.OriginalMessage, Is.Null);

Govor.Core/Infrastructure/Validators/ChatGroupValidator.cs

@@ -4,13 +4,41 @@ namespace Govor.Core.Infrastructure.Validators;
 
 public class ChatGroupValidator : IObjectValidator<ChatGroup>
 {
-    public void Validate(ChatGroup objectToValidate)
+    public void Validate(ChatGroup chat)
     {
-        throw new NotImplementedException();
+        try
+        {
+            if(chat is null)
+                throw new ArgumentNullException(nameof(chat));
+            if(chat.Id == Guid.Empty)
+                throw new ArgumentException("Id of chat group can't be empty",nameof(chat.Id));
+            if(string.IsNullOrEmpty(chat.Name))
+                throw new ArgumentException("Name of chat group can't be empty",nameof(chat.Name));
+            if(chat.Description is null)
+                throw new ArgumentException("Description of chat group can't be null",nameof(chat.Description));
+            if(chat.ImageId == Guid.Empty)
+                throw new ArgumentException("ImageId of chat group can't be empty",nameof(chat.ImageId));
+            if(chat.IsPrivate && chat.InviteCodes.Count <= 0)
+                throw new ArgumentException("Private group must have invitation links",nameof(chat.InviteCodes));
+            if(chat.Admins.Count <= 0)
+                throw new ArgumentException("Chat must have owner",nameof(chat.Admins));
+        }
+        catch (Exception ex)
+        {
+            throw new InvalidObjectException<ChatGroup>(ex);
+        }
     }
 
-    public bool TryValidate(ChatGroup objectToValidate)
+    public bool TryValidate(ChatGroup chat)
     {
-        throw new NotImplementedException();
+        try
+        {
+            Validate(chat);
+            return true;
+        }
+        catch (Exception)
+        {
+            return false;
+        }
     }
 }

Govor.Core/Models/PrivateChat.cs

@@ -6,4 +6,12 @@ public class PrivateChat
     public Guid UserAId { get; set; }
     public Guid UserBId { get; set; }
     public List<Message> Messages { get; set; } =  new List<Message>();
+
+    public override bool Equals(object? obj)
+    {
+        PrivateChat other = obj as PrivateChat;
+        return Id == other.Id &&
+               UserAId == other.UserAId &&
+               UserBId == other.UserBId;
+    }
 }