Shopping cart

TickAPI/TickAPI.Tests/Common/Results/ResultTests.cs

@@ -37,6 +37,21 @@ public void Failure_ShouldReturnResultWithError()
         Assert.Equal(statusCode, result.StatusCode);
     }
 
+    [Fact]
+    public void PropagateError_WhenResultWithErrorPassed_ShouldReturnResultWithError()
+    {
+        const int statusCode = 500;
+        const string errorMsg = "error message";
+        var resultWithError = Result.Failure(statusCode, errorMsg);
+
+        var result = Result.PropagateError(resultWithError);
+
+        Assert.True(result.IsError);
+        Assert.False(result.IsSuccess);
+        Assert.Equal(errorMsg, result.ErrorMsg);
+        Assert.Equal(statusCode, result.StatusCode);
+    }
+
     [Fact]
     public void PropagateError_WhenGenericResultWithErrorPassed_ShouldReturnResultWithError()
     {
@@ -55,6 +70,16 @@ public void PropagateError_WhenGenericResultWithErrorPassed_ShouldReturnResultWi
         Assert.Equal(statusCode, result.StatusCode);
     }
 
+    [Fact]
+    public void PropagateError_WhenResultWithSuccessPassed_ShouldThrowArgumentException()
+    {
+        var resultWithSuccess = Result.Success();
+
+        var act = () => Result.PropagateError(resultWithSuccess);
+
+        Assert.Throws<ArgumentException>(act);
+    }
+
     [Fact]
     public void PropagateError_WhenGenericResultWithSuccessPassed_ShouldThrowArgumentException()
     {
@@ -97,7 +122,7 @@ public void ToObjectResult_WhenResultIsSuccess_ShouldReturnObjectResultWithDefau
         // Assert
         Assert.IsType<ObjectResult>(objectResult);
         Assert.Equal(StatusCodes.Status200OK, objectResult.StatusCode);
-        Assert.Null(objectResult.Value);
+        Assert.Equal(string.Empty, objectResult.Value);
     }
 
     [Fact]
@@ -113,6 +138,6 @@ public void ToObjectResult_WhenResultIsSuccessWithCustomStatusCode_ShouldReturnO
         // Assert
         Assert.IsType<ObjectResult>(objectResult);
         Assert.Equal(customSuccessCode, objectResult.StatusCode);
-        Assert.Null(objectResult.Value);
+        Assert.Equal(string.Empty, objectResult.Value);
     }
 }

TickAPI/TickAPI.Tests/Events/Services/EventServiceTests.cs

@@ -631,8 +631,8 @@ public async Task GetEventDetailsAsync_WhenSuccessful_ShouldReturnEventDetails()
             .ReturnsAsync(Result<Event>.Success(@event));
 
         ticketServiceMock
-            .Setup(m => m.GetNumberOfAvailableTicketsByType(It.IsAny<TicketType>()))
-            .Returns((TicketType input) => 
+            .Setup(m => m.GetNumberOfAvailableTicketsByTypeAsync(It.IsAny<TicketType>()))
+            .ReturnsAsync((TicketType input) => 
                 Result<uint>.Success((uint)(input.Price / 10))
             );
 

TickAPI/TickAPI.Tests/Tickets/Services/TicketServiceTests.cs

@@ -10,60 +10,76 @@
 using TickAPI.Customers.Models;
 using TickAPI.Events.Models;
 using TickAPI.Organizers.Models;
+using TickAPI.ShoppingCarts.Abstractions;
 using TickAPI.Tickets.Abstractions;
 using TickAPI.Tickets.DTOs.Response;
 using TickAPI.Tickets.Models;
 using TickAPI.Tickets.Services;
+using TickAPI.TicketTypes.Abstractions;
 using TickAPI.TicketTypes.Models;
 
 namespace TickAPI.Tests.Tickets.Services;
 
 public class TicketServiceTests
 {
     [Fact]
-    public void GetNumberOfAvailableTicketsByType_AmountsAreCorrect_ShouldReturnCorrectNumberOfTickets()
+    public async Task GetNumberOfAvailableTicketsByType_AmountsAreCorrect_ShouldReturnCorrectNumberOfTickets()
     {
         // Arrange
         var type = new TicketType { MaxCount = 30 };
         var ticketList = new List<Ticket>(new Ticket[10]);
 
         var ticketRepositoryMock = new Mock<ITicketRepository>();
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
         var paginationServiceMock = new Mock<IPaginationService>();
         var qrServiceMock = new Mock<IQRCodeService>();
 
         ticketRepositoryMock
             .Setup(m => m.GetAllTicketsByTicketType(type))
             .Returns(ticketList.AsQueryable());
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        shoppingCartRepositoryMock
+            .Setup(s => s.GetAmountOfTicketTypeAsync(type.Id))
+            .ReturnsAsync(Result<long>.Success(0));
+
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
-        var result = sut.GetNumberOfAvailableTicketsByType(type);
+        var result = await sut.GetNumberOfAvailableTicketsByTypeAsync(type);
 
         // Assert
         Assert.True(result.IsSuccess);
         Assert.Equal(20u, result.Value);
     }
 
     [Fact]
-    public void GetNumberOfAvailableTicketsByType_WhenMoreTicketExistThanMaxCount_ShouldReturnError()
+    public async Task GetNumberOfAvailableTicketsByType_WhenMoreTicketExistThanMaxCount_ShouldReturnError()
     {
         // Arrange
         var type = new TicketType { MaxCount = 30 };
         var ticketList = new List<Ticket>(new Ticket[50]);
 
         var ticketRepositoryMock = new Mock<ITicketRepository>();
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
         var paginationServiceMock = new Mock<IPaginationService>();
         var qrServiceMock = new Mock<IQRCodeService>();
 
         ticketRepositoryMock
             .Setup(m => m.GetAllTicketsByTicketType(type))
             .Returns(ticketList.AsQueryable());
+
+        shoppingCartRepositoryMock
+            .Setup(s => s.GetAmountOfTicketTypeAsync(type.Id))
+            .ReturnsAsync(Result<long>.Success(0));
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
-        var result = sut.GetNumberOfAvailableTicketsByType(type);
+        var result = await sut.GetNumberOfAvailableTicketsByTypeAsync(type);
 
         // Assert
         Assert.True(result.IsError);
@@ -111,6 +127,9 @@ public async Task GetTicketsForResellAsync_WhenDataIsValid_ShouldReturnSuccess()
         ticketRepositoryMock.Setup(repo => repo.GetTicketsByEventId(eventId))
             .Returns(allTickets);
 
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
+
         var paginatedTickets = new PaginatedData<Ticket>(
             new List<Ticket> { ticket1, ticket2 },
             page,
@@ -156,7 +175,8 @@ public async Task GetTicketsForResellAsync_WhenDataIsValid_ShouldReturnSuccess()
 
         var qrServiceMock = new Mock<IQRCodeService>();
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object,  qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
         var result = await sut.GetTicketsForResellAsync(eventId, page, pageSize);
@@ -206,6 +226,9 @@ public async Task GetTicketsForResellAsync_WhenNoTicketsForResell_ShouldReturnEm
         ticketRepositoryMock.Setup(repo => repo.GetTicketsByEventId(eventId))
             .Returns(tickets);
 
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
+
         var paginatedData = new PaginatedData<Ticket>(
             new List<Ticket>(),
             page,
@@ -234,7 +257,8 @@ public async Task GetTicketsForResellAsync_WhenNoTicketsForResell_ShouldReturnEm
             .Returns(mappedData);
         var qrServiceMock = new Mock<IQRCodeService>();
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
         var result = await sut.GetTicketsForResellAsync(eventId, page, pageSize);
@@ -272,14 +296,18 @@ public async Task GetTicketsForResellAsync_WhenPaginationFails_ShouldPropagateEr
         var ticketRepositoryMock = new Mock<ITicketRepository>();
         ticketRepositoryMock.Setup(repo => repo.GetTicketsByEventId(eventId))
             .Returns(tickets);
+
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
 
         var paginationServiceMock = new Mock<IPaginationService>();
         paginationServiceMock.Setup(p => p.PaginateAsync(It.IsAny<IQueryable<Ticket>>(), pageSize, page))
             .ReturnsAsync(Result<PaginatedData<Ticket>>.Failure(statusCode, errorMsg));
 
         var qrServiceMock = new Mock<IQRCodeService>();
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object,  qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
         var result = await sut.GetTicketsForResellAsync(eventId, page, pageSize);
@@ -304,6 +332,9 @@ public async Task GetTicketsForResellAsync_WhenNoTicketsForEvent_ShouldReturnEmp
         ticketRepositoryMock.Setup(repo => repo.GetTicketsByEventId(eventId))
             .Returns(tickets);
 
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
+
         var paginatedData = new PaginatedData<Ticket>(
             new List<Ticket>(),
             page,
@@ -332,7 +363,8 @@ public async Task GetTicketsForResellAsync_WhenNoTicketsForEvent_ShouldReturnEmp
             .Returns(mappedData);
         var qrServiceMock = new Mock<IQRCodeService>();
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
         var result = await sut.GetTicketsForResellAsync(eventId, page, pageSize);
@@ -380,9 +412,11 @@ public async Task GetTicketDetailsAsync_WhenTicketExistsForTheUser_ShouldReturnT
                 }
             },
         };
-        string email = "123@123.com";
-        string scanurl = "http://localhost";
-        Mock<ITicketRepository> ticketRepositoryMock = new Mock<ITicketRepository>();
+        const string email = "123@123.com";
+        const string scanurl = "http://localhost";
+        var ticketRepositoryMock = new Mock<ITicketRepository>();
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
 
         var paginationServiceMock = new Mock<IPaginationService>();
 
@@ -392,7 +426,8 @@ public async Task GetTicketDetailsAsync_WhenTicketExistsForTheUser_ShouldReturnT
         var qrServiceMock = new Mock<IQRCodeService>();
         qrServiceMock.Setup(m => m.GenerateQrCode(scanurl)).Returns([]);
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
 
@@ -426,18 +461,21 @@ public async Task GetTicketDetailsAsync_WhenTicketDoesNotExistForTheUser_ShouldR
 
         // Arrange
 
-        Guid  ticketId = Guid.NewGuid();
-        string email = "123@123.com";
-        string scanUrl = "http://localhost";
+        var  ticketId = Guid.NewGuid();
+        const string email = "123@123.com";
+        const string scanUrl = "http://localhost";
 
-        Mock<ITicketRepository> ticketRepositoryMock = new Mock<ITicketRepository>();
+        var ticketRepositoryMock = new Mock<ITicketRepository>();
         ticketRepositoryMock.Setup(m => m.GetTicketWithDetailsByIdAndEmailAsync(ticketId, email)).
             ReturnsAsync(Result<Ticket>.Failure(StatusCodes.Status404NotFound, "Ticket with this id doesn't exist " +
                                                                              "for this user"));
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
         var paginationServiceMock = new Mock<IPaginationService>();
         var qrServiceMock = new Mock<IQRCodeService>();
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object,  qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
 
@@ -513,6 +551,8 @@ public async Task GetTicketsForCustomerAsync_WithValidInput_ReturnsSuccessResult
 
         var ticketRepositoryMock = new Mock<ITicketRepository>();
         ticketRepositoryMock.Setup(r => r.GetTicketsByCustomerEmail(email)).Returns(tickets.AsQueryable());
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
 
         var paginationServiceMock = new Mock<IPaginationService>();
         paginationServiceMock.Setup(p => p.PaginateAsync(tickets.AsQueryable(), pageSize, page))
@@ -523,7 +563,8 @@ public async Task GetTicketsForCustomerAsync_WithValidInput_ReturnsSuccessResult
 
         var qrServiceMock = new Mock<IQRCodeService>();
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
         var result = await sut.GetTicketsForCustomerAsync(email, page, pageSize);
@@ -555,6 +596,9 @@ public async Task GetTicketsForCustomerAsync_WhenUserHasNoTickets_ReturnsEmptyPa
 
         var ticketRepositoryMock = new Mock<ITicketRepository>();
         ticketRepositoryMock.Setup(r => r.GetTicketsByCustomerEmail(email)).Returns(emptyTickets.AsQueryable());
+
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
 
         var paginationServiceMock = new Mock<IPaginationService>();
         paginationServiceMock.Setup(p => p.PaginateAsync(emptyTickets.AsQueryable(), pageSize, page)).ReturnsAsync(paginatedResult);
@@ -563,7 +607,8 @@ public async Task GetTicketsForCustomerAsync_WhenUserHasNoTickets_ReturnsEmptyPa
 
         var qrServiceMock = new Mock<IQRCodeService>();
 
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
         var result = await sut.GetTicketsForCustomerAsync(email, page, pageSize);
@@ -580,9 +625,12 @@ public async Task ScanTicket_WhenScanningSuccesful_ShouldReturnSuccess()
         var guid = Guid.NewGuid();
         var ticketRepositoryMock = new Mock<ITicketRepository>();
         ticketRepositoryMock.Setup(m => m.MarkTicketAsUsed(guid)).ReturnsAsync(Result.Success());
+        var ticketTypeRepositoryMock = new Mock<ITicketTypeRepository>();
+        var shoppingCartRepositoryMock = new Mock<IShoppingCartRepository>();
         var paginationServiceMock = new Mock<IPaginationService>();
         var qrServiceMock = new Mock<IQRCodeService>();
-        var sut = new TicketService(ticketRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
+        var sut = new TicketService(ticketRepositoryMock.Object, ticketTypeRepositoryMock.Object,
+            shoppingCartRepositoryMock.Object, paginationServiceMock.Object, qrServiceMock.Object);
 
         // Act
         var res = await sut.ScanTicket(guid);

TickAPI/TickAPI/Common/Redis/Abstractions/IRedisService.cs

@@ -13,4 +13,5 @@ public interface IRedisService
     public Task<long> DecrementValueAsync(string key, long value = 1);
     public Task<long?> GetLongValueAsync(string key);
     public Task<bool> SetLongValueAsync(string key, long value, TimeSpan? expiry = null);
+    public Task<IEnumerable<string>> GetKeysByPatternAsync(string pattern);
 }

TickAPI/TickAPI/Common/Redis/Services/RedisService.cs

@@ -6,11 +6,13 @@ namespace TickAPI.Common.Redis.Services;
 
 public class RedisService : IRedisService
 {
+    private readonly IConnectionMultiplexer _connectionMultiplexer;
     private readonly IDatabase _database;
     private static readonly JsonSerializerOptions JsonOptions = new(JsonSerializerDefaults.Web);
 
     public RedisService(IConnectionMultiplexer connectionMultiplexer)
     {
+        _connectionMultiplexer = connectionMultiplexer;
         _database = connectionMultiplexer.GetDatabase();
     }
 
@@ -85,6 +87,12 @@ public async Task<bool> SetLongValueAsync(string key, long value, TimeSpan? expi
         return await RetryAsync(async () => await _database.StringSetAsync(key, value.ToString(), expiry));
     }
 
+    public async Task<IEnumerable<string>> GetKeysByPatternAsync(string pattern)
+    {
+        var server = _connectionMultiplexer.GetServer(_connectionMultiplexer.GetEndPoints().First());
+        return server.Keys(pattern: pattern).Select(k => k.ToString());
+    }
+
     private static async Task<T> RetryAsync<T>(Func<Task<T>> action, int retryCount = 3, int millisecondsDelay = 100)
     {
         var attempt = 0;

TickAPI/TickAPI/Common/Results/Result.cs

@@ -27,6 +27,16 @@ public static Result Failure(int statusCode, string errorMsg)
         return new Result(false, statusCode, errorMsg);
     }
 
+    public static Result PropagateError(Result other)
+    {
+        if (other.IsSuccess)
+        {
+            throw new ArgumentException("Trying to propagate error from successful value");
+        }
+
+        return Failure(other.StatusCode, other.ErrorMsg);
+    }
+
     public static Result PropagateError<TE>(Result<TE> other)
     {
         if (other.IsSuccess)
@@ -47,7 +57,7 @@ public ObjectResult ToObjectResult(int successCode = StatusCodes.Status200OK)
             };
         }
 
-        return new ObjectResult(null)
+        return new ObjectResult(string.Empty)
         {
             StatusCode = successCode
         };