Merge pull request #8 from StewKI/feature-whiteboard_membership

Feature whiteboard membership

dotnet/AipsCore/Application/Models/WhiteboardMembership/Command/CreateWhiteboardMembership/CreateWhiteboardMembershipCommand.cs

@@ -0,0 +1,13 @@
+using AipsCore.Application.Abstract.Command;
+using AipsCore.Domain.Models.WhiteboardMembership.ValueObjects;
+
+namespace AipsCore.Application.Models.WhiteboardMembership.Command.CreateWhiteboardMembership;
+
+public record CreateWhiteboardMembershipCommand(
+    string WhiteboardId, 
+    string UserId,
+    bool IsBanned,
+    bool EditingEnabled,
+    bool CanJoin,
+    DateTime LastInteractedAt)
+    : ICommand<WhiteboardMembershipId>;

dotnet/AipsCore/Application/Models/WhiteboardMembership/Command/CreateWhiteboardMembership/CreateWhiteboardMembershipCommandHandler.cs

@@ -0,0 +1,34 @@
+using AipsCore.Application.Abstract.Command;
+using AipsCore.Domain.Abstract;
+using AipsCore.Domain.Models.WhiteboardMembership.External;
+using AipsCore.Domain.Models.WhiteboardMembership.ValueObjects;
+
+namespace AipsCore.Application.Models.WhiteboardMembership.Command.CreateWhiteboardMembership;
+
+public class CreateWhiteboardMembershipCommandHandler : ICommandHandler<CreateWhiteboardMembershipCommand, WhiteboardMembershipId>
+{
+    private readonly IWhiteboardMembershipRepository _whiteboardMembershipRepository;
+    private readonly IUnitOfWork _unitOfWork;
+    
+    public CreateWhiteboardMembershipCommandHandler(IWhiteboardMembershipRepository whiteboardMembershipRepository, IUnitOfWork unitOfWork)
+    {
+        _whiteboardMembershipRepository = whiteboardMembershipRepository;
+        _unitOfWork = unitOfWork;
+    }
+    
+    public async Task<WhiteboardMembershipId> Handle(CreateWhiteboardMembershipCommand command, CancellationToken cancellationToken = default)
+    {
+        var whiteboardMembership = Domain.Models.WhiteboardMembership.WhiteboardMembership.Create(
+            command.WhiteboardId, 
+            command.UserId, 
+            command.IsBanned, 
+            command.EditingEnabled, 
+            command.CanJoin, 
+            command.LastInteractedAt);
+
+        await _whiteboardMembershipRepository.Save(whiteboardMembership, cancellationToken);
+        await _unitOfWork.SaveChangesAsync(cancellationToken);
+        
+        return whiteboardMembership.Id;
+    }
+}

dotnet/AipsCore/Infrastructure/DI/PersistenceRegistrationExtensions.cs

@@ -1,6 +1,7 @@
 using AipsCore.Domain.Abstract;
 using AipsCore.Domain.Models.User.External;
 using AipsCore.Domain.Models.Whiteboard.External;
+using AipsCore.Domain.Models.WhiteboardMembership.External;
 using AipsCore.Infrastructure.DI.Configuration;
 using AipsCore.Infrastructure.Persistence.Db;
 using AipsCore.Infrastructure.Persistence.User;
@@ -26,6 +27,7 @@ public static class PersistenceRegistrationExtensions
         services.AddTransient<IUnitOfWork, EfUnitOfWork>();
         services.AddTransient<IUserRepository, UserRepository>();
         services.AddTransient<IWhiteboardRepository, WhiteboardRepository>();
+        services.AddTransient<IWhiteboardMembershipRepository, IWhiteboardMembershipRepository>();
         
         return services;
     }

dotnet/AipsCore/Infrastructure/Persistence/Db/AipsDbContext.cs

@@ -6,6 +6,7 @@ public class AipsDbContext : DbContext
 {
     public DbSet<User.User> Users { get; set; }
     public DbSet<Whiteboard.Whiteboard> Whiteboards { get; set; }
+    public DbSet<WhiteboardMembership.WhiteboardMembership> WhiteboardMemberships { get; set; }
 
     public AipsDbContext(DbContextOptions<AipsDbContext> options)
         : base(options)

dotnet/AipsCore/Infrastructure/Persistence/WhiteboardMembership/WhiteboardMembership.cs

@@ -0,0 +1,25 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace AipsCore.Infrastructure.Persistence.WhiteboardMembership;
+
+public class WhiteboardMembership 
+{
+    [Key]
+    public Guid Id { get; set; }
+    
+    public Guid WhiteboardId { get; set; }
+
+    public Whiteboard.Whiteboard? Whiteboard { get; set; } = null!;
+    
+    public Guid UserId { get; set; }
+
+    public User.User? User { get; set; } = null!;
+    
+    public bool IsBanned { get; set; }
+    
+    public bool EditingEnabled { get; set; }
+    
+    public bool CanJoin { get; set; }
+    
+    public DateTime LastInteractedAt { get; set; }
+}

dotnet/AipsCore/Infrastructure/Persistence/WhiteboardMembership/WhiteboardMembershipRepository.cs

@@ -0,0 +1,63 @@
+using AipsCore.Domain.Models.WhiteboardMembership.External;
+using AipsCore.Domain.Models.WhiteboardMembership.ValueObjects;
+using AipsCore.Infrastructure.Persistence.Db;
+
+namespace AipsCore.Infrastructure.Persistence.WhiteboardMembership;
+
+public class WhiteboardMembershipRepository : IWhiteboardMembershipRepository
+{
+    private readonly AipsDbContext _context;
+    
+    public WhiteboardMembershipRepository(AipsDbContext context)
+    {
+        _context = context;
+    }
+    
+    public async Task<Domain.Models.WhiteboardMembership.WhiteboardMembership?> Get(WhiteboardMembershipId whiteboardMembershipId, CancellationToken cancellationToken = default)
+    {
+        var whiteboardMembershipEntity = await _context.WhiteboardMemberships.FindAsync(new Guid(whiteboardMembershipId.IdValue));
+        
+        if (whiteboardMembershipEntity is null) return null;
+
+        return Domain.Models.WhiteboardMembership.WhiteboardMembership.Create(
+            whiteboardMembershipEntity.Id.ToString(),
+            whiteboardMembershipEntity.WhiteboardId.ToString(),
+            whiteboardMembershipEntity.UserId.ToString(),
+            whiteboardMembershipEntity.IsBanned,
+            whiteboardMembershipEntity.EditingEnabled,
+            whiteboardMembershipEntity.CanJoin,
+            whiteboardMembershipEntity.LastInteractedAt);
+    }
+
+    public async Task Save(Domain.Models.WhiteboardMembership.WhiteboardMembership whiteboardMembership, CancellationToken cancellationToken = default)
+    {
+        var whiteboardMembershipEntity = await _context.WhiteboardMemberships.FindAsync(new Guid(whiteboardMembership.Id.IdValue));
+        
+        if (whiteboardMembershipEntity is not null)
+        {
+            whiteboardMembershipEntity.IsBanned = whiteboardMembership.IsBanned.IsBannedValue;
+            whiteboardMembershipEntity.EditingEnabled = whiteboardMembership.EditingEnabled.EditingEnabledValue;
+            whiteboardMembershipEntity.CanJoin = whiteboardMembership.CanJoin.CanJoinValue;
+            whiteboardMembershipEntity.LastInteractedAt = whiteboardMembership.LastInteractedAt.LastInteractedAtValue;
+            
+            _context.Update(whiteboardMembershipEntity);
+        }
+        else
+        {
+            whiteboardMembershipEntity = new WhiteboardMembership()
+            {
+                Id = new Guid(whiteboardMembership.Id.IdValue),
+                WhiteboardId = new Guid(whiteboardMembership.WhiteboardId.IdValue),
+                Whiteboard = null,
+                UserId = new Guid(whiteboardMembership.UserId.IdValue),
+                User = null,
+                IsBanned = whiteboardMembership.IsBanned.IsBannedValue,
+                EditingEnabled = whiteboardMembership.EditingEnabled.EditingEnabledValue,
+                CanJoin = whiteboardMembership.CanJoin.CanJoinValue,
+                LastInteractedAt = whiteboardMembership.LastInteractedAt.LastInteractedAtValue
+            };
+            
+            _context.Add(whiteboardMembershipEntity);
+        }
+    }
+}