End of section 12

Author: onur-ozguzel

API/Controllers/CartController.cs

@@ -0,0 +1,34 @@
+using Core.Entities;
+using Core.Interfaces;
+using Microsoft.AspNetCore.Mvc;
+
+namespace API.Controllers;
+
+public class CartController(ICartService cartService) : BaseApiController
+{
+    [HttpGet]
+    public async Task<ActionResult<ShoppingCart>> GetCartById(string id)
+    {
+        var cart = await cartService.GetCartAsync(id);
+
+        return Ok(cart ?? new ShoppingCart { Id = id });
+    }
+
+    [HttpPost]
+    public async Task<ActionResult<ShoppingCart>> UpdateCart(ShoppingCart cart)
+    {
+        var updatedCart = await cartService.SetCartAsync(cart);
+        if (updatedCart == null) return BadRequest("Problem with cart");
+
+        return updatedCart;
+    }
+
+    [HttpDelete]
+    public async Task<ActionResult> DeleteCart(string id)
+    {
+        var result = await cartService.DeleteCartAsync(id);
+        if (!result) return BadRequest("Problem deleting cart");
+
+        return Ok();
+    }
+}

API/Program.cs

@@ -1,7 +1,9 @@
 using API.Middleware;
 using Core.Interfaces;
 using Infrastructure.Data;
+using Infrastructure.Services;
 using Microsoft.EntityFrameworkCore;
+using StackExchange.Redis;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -15,6 +17,15 @@
 builder.Services.AddScoped<IProductRepository, ProductRepository>();
 builder.Services.AddScoped(typeof(IGenericRepository<>), typeof(GenericRepository<>));
 builder.Services.AddCors();
+builder.Services.AddSingleton<IConnectionMultiplexer>(config =>
+{
+    var connString = builder.Configuration.GetConnectionString("Redis")
+        ?? throw new Exception("Cannot get redis connection string");
+
+    var configuration = ConfigurationOptions.Parse(connString, true);
+    return ConnectionMultiplexer.Connect(configuration);
+});
+builder.Services.AddSingleton<ICartService, CartService>();
 
 // Learn more about configuring OpenAPI at https://aka.ms/aspnet/openapi
 builder.Services.AddOpenApi();

API/appsettings.Development.json

@@ -6,6 +6,7 @@
     }
   },
   "ConnectionStrings": {
-    "DefaultConnection": "Server=localhost,1433;Database=skinet;User Id=SA;Password=Password@1;TrustServerCertificate=True"
+    "DefaultConnection": "Server=localhost,1433;Database=skinet;User Id=SA;Password=Password@1;TrustServerCertificate=True",
+    "Redis": "localhost"
   }
 }

Core/Entities/CartItem.cs

@@ -0,0 +1,12 @@
+namespace Core.Entities;
+
+public class CartItem
+{
+    public int ProductId { get; set; }
+    public required string ProductName { get; set; }
+    public decimal Price { get; set; }
+    public int Quantity { get; set; }
+    public required string PictureUrl { get; set; }
+    public required string Brand { get; set; }
+    public required string Type { get; set; }
+}

Core/Entities/ShoppingCart.cs

@@ -0,0 +1,8 @@
+namespace Core.Entities;
+
+public class ShoppingCart
+{
+    public required string Id { get; set; }
+    public List<CartItem> Items { get; set; } = [];
+    
+}

Core/Interfaces/ICartService.cs

@@ -0,0 +1,10 @@
+using Core.Entities;
+
+namespace Core.Interfaces;
+
+public interface ICartService
+{
+    Task<ShoppingCart?> GetCartAsync(string key);
+    Task<ShoppingCart?> SetCartAsync(ShoppingCart cart);
+    Task<bool> DeleteCartAsync(string key);
+}

Infrastructure/Infrastructure.csproj

@@ -6,6 +6,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.1" />
+    <PackageReference Include="StackExchange.Redis" Version="2.8.24" />
   </ItemGroup>
 
   <ItemGroup>

Infrastructure/Services/CartService.cs

@@ -0,0 +1,31 @@
+using System.Text.Json;
+using Core.Entities;
+using Core.Interfaces;
+using StackExchange.Redis;
+
+namespace Infrastructure.Services;
+
+public class CartService(IConnectionMultiplexer redis) : ICartService
+{
+    private readonly IDatabase _database = redis.GetDatabase();
+
+    public async Task<bool> DeleteCartAsync(string key)
+    {
+        return await _database.KeyDeleteAsync(key);
+    }
+
+    public async Task<ShoppingCart?> GetCartAsync(string key)
+    {
+        var data = await _database.StringGetAsync(key);
+
+        return data.IsNullOrEmpty ? null : JsonSerializer.Deserialize<ShoppingCart>(data!);
+    }
+
+    public async Task<ShoppingCart?> SetCartAsync(ShoppingCart cart)
+    {
+        var created = await _database.StringSetAsync(cart.Id, JsonSerializer.Serialize(cart), TimeSpan.FromDays(30));
+        if (!created) return null;
+
+        return await GetCartAsync(cart.Id);
+    }
+}

docker-compose.yml

@@ -5,4 +5,16 @@ services:
       ACCEPT_EULA: "1"
       MSSQL_SA_PASSWORD: "Password@1"
     ports:
-      - "1433:1433"
+      - "1433:1433"
+    volumes:
+      - sql-data:/var/opt/mssql
+  redis:
+    image: redis:latest
+    ports:
+      - "6379:6379"
+    volumes:
+      - redis-data:/data
+
+volumes:
+  redis-data:
+  sql-data: