Merge pull request #15 from steve-bang/dev

Merge CICD

RESTApi/Accounts/Auth.http

@@ -0,0 +1,24 @@
+@Host = https://localhost:7159/api/v1/auth
+
+
+### Register
+POST {{Host}}/register
+Accept: application/json
+Content-Type: application/json
+
+{
+    "emailAddress" : "[email protected]",
+    "password" : "password",
+    "confirmPassword" : "password"
+}
+
+### Login user
+POST {{Host}}/login
+Accept: application/json
+Content-Type: application/json
+
+{
+    "emailAddress" : "[email protected]",
+    "password" : "password"
+}
+

RESTApi/Accounts/Roles.http

@@ -0,0 +1,14 @@
+@Host = https://localhost:7159/api/v1/roles
+@UserId = a9ad6829-10f7-404e-224f-08dd2274641d
+
+
+### Add new role
+POST {{Host}}
+Accept: application/json
+Content-Type: application/json
+
+{
+    "name" : "Contributor",
+    "description" : "Grants full access to manage all resources, but does not allow you to assign roles in Azure RBAC, manage assignments in Azure Blueprints, or share image galleries."
+}
+

RESTApi/Accounts/Users.http

@@ -0,0 +1,54 @@
+@Host = https://localhost:7159/api/v1/users
+@UserId = a9ad6829-10f7-404e-224f-08dd2274641d
+@BearerToken = eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJodHRwOi8vc2NoZW1hcy54bWxzb2FwLm9yZy93cy8yMDA1LzA1L2lkZW50aXR5L2NsYWltcy9uYW1laWRlbnRpZmllciI6ImE5YWQ2ODI5LTEwZjctNDA0ZS0yMjRmLTA4ZGQyMjc0NjQxZCIsImh0dHA6Ly9zY2hlbWFzLnhtbHNvYXAub3JnL3dzLzIwMDUvMDUvaWRlbnRpdHkvY2xhaW1zL2VtYWlsYWRkcmVzcyI6Im1yc3RldmVAZXhhbXBsZS5jb20iLCJleHAiOjE3MzU4NTUzNjUsImlzcyI6Imh0dHBzOi8vYXV0aHplcm8uY29tIiwiYXVkIjoiaHR0cHM6Ly9hdXRoemVyby5jb20ifQ.Rag8ymY4KWBBBLsHdbPC-M95EgrrjC4HUS7hzHihDWU
+
+
+### Get user by Id
+GET {{Host}}/{{UserId}}
+Accept: application/json
+Content-Type: application/json
+Authorization: Bearer {{BearerToken}}
+
+
+
+### Update user's data by Id
+PATCH {{Host}}/{{UserId}}
+Accept: application/json
+Content-Type: application/json
+Authorization: Bearer {{BearerToken}}
+
+{
+    "firstName" : "Steve",
+    "lastName" : "Smith",
+    "bio": "I am a software developer",
+    "avatarUrl": "https://example.com/avatar.jpg"
+}
+
+
+### Assign roles to user
+POST {{Host}}/{{UserId}}/roles
+Accept: application/json
+Content-Type: application/json
+Authorization: Bearer {{BearerToken}}
+
+{
+    "roles": ["760a2dfc-7114-47dd-d257-08dd297fd518", "327db532-0652-479b-d258-08dd297fd518"]
+}
+
+### Get user's roles
+GET {{Host}}/{{UserId}}/roles
+Accept: application/json
+Content-Type: application/json
+Authorization: Bearer {{BearerToken}}
+
+
+### Remove roles from user
+DELETE {{Host}}/{{UserId}}/roles
+Accept: application/json
+Content-Type: application/json
+Authorization: Bearer {{BearerToken}}
+
+{
+    "roles": ["760a2dfc-7114-47dd-d257-08dd297fd518"]
+}
+

database/log/sqlagentstartup.log

@@ -0,0 +1,6 @@
+
+Microsoft (R) SQLServerAgent 16.0.4165.4
+Copyright (C) 2022 Microsoft Corporation. All rights reserved.
+
+SQLAgent is disabled
+SQLAgent is exiting

src/AuthZero.AccountService/AuthZero.AccountService.Application/AuthZero.AccountService.Application.csproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net9.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="../../AuthZero.AppHost.Shared/AuthZero.AppHost.Shared.csproj" />
+    <ProjectReference Include="../../AuthZero.Shared/AuthZero.Shared.csproj" />
+    <ProjectReference Include="../AuthZero.AccountService.Domain/AuthZero.AccountService.Domain.csproj" />
+    <ProjectReference Include="../AuthZero.AccountService.Infrastructure/AuthZero.AccountService.Infrastructure.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Aspire.Confluent.Kafka" Version="9.0.0" />
+    <PackageReference Include="Aspire.StackExchange.Redis.DistributedCaching" Version="9.0.0" />
+  </ItemGroup>
+
+</Project>

src/AuthZero.AccountService/AuthZero.AccountService.Application/DependencyInjection.cs

@@ -0,0 +1,29 @@
+using AuthZero.AppHost.Shared.Constants;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+
+namespace AuthZero.AccountService.Application;
+
+public static class DependencyInjection
+{
+    public static IHostApplicationBuilder AddApplication(this IHostApplicationBuilder builder)
+    {
+        // Add the MediatR services
+        builder.Services.AddMediatR(config =>
+        {
+            // Register all the handlers from the current assembly
+            config.RegisterServicesFromAssembly(typeof(DependencyInjection).Assembly);
+
+            // Register the ValidationBehavior
+            //config.AddOpenBehavior(typeof(ValidationBehaviour<,>));
+        });
+
+        // Add the Kafka services
+        builder.AddKafkaProducer<string, string>(Names.KafkaMessages);
+
+        // Add Redis services
+        builder.AddRedisDistributedCache("caching");
+
+        return builder;
+    }
+}

src/AuthZero.AccountService/AuthZero.AccountService.Application/DomainEventHandlers/UserRegisterEventHandler.cs

@@ -0,0 +1,32 @@
+
+
+using AuthZero.AccountService.Domain.Events;
+using AuthZero.AppHost.Shared.Messages;
+using Confluent.Kafka;
+
+
+namespace AuthZero.AccountService.Application.DomainEventHandlers;
+
+
+
+public class UserRegisterEventHandler(
+    IProducer<string, string> _messageProducer
+) : INotificationHandler<UserRegisterEvent>
+{
+
+    public async Task Handle(UserRegisterEvent notification, CancellationToken cancellationToken)
+    {
+        var message = new Message<string, string>{ Key = notification.User.Id.ToString(), Value = notification.User.EmailAddress, Timestamp = new Timestamp(DateTimeOffset.UtcNow) };
+
+        var result = await _messageProducer.ProduceAsync(Topics.UserRegisterSuccess, message);
+
+        if (result.Status != PersistenceStatus.Persisted)
+        {
+            throw new Exception("Failed to produce message");
+        }
+
+        Console.WriteLine($"Produced message to topic {result.Topic}, partition {result.Partition}, offset {result.Offset}");
+
+
+    }
+}

src/AuthZero.AccountService/AuthZero.AccountService.Application/Features/Commands/AddRoleCommand.cs

@@ -0,0 +1,7 @@
+
+namespace AuthZero.AccountService.Application.Features.Commands;
+
+public record AddRoleCommand(
+    string Name,
+    string Description
+) : IRequest<Guid>;

src/AuthZero.AccountService/AuthZero.AccountService.Application/Features/Commands/AddRoleCommandHandler.cs

@@ -0,0 +1,20 @@
+
+using AuthZero.AccountService.Domain.AggregatesModel;
+
+namespace AuthZero.AccountService.Application.Features.Commands;
+
+public class AddRoleCommandHandler(
+    IRoleRepository _roleRepository
+) : IRequestHandler<AddRoleCommand, Guid>
+{
+    public async Task<Guid> Handle(AddRoleCommand request, CancellationToken cancellationToken)
+    {
+
+
+        var role = await _roleRepository.AddAsync(new Role(request.Name, request.Description));
+
+        await _roleRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
+
+        return role.Id;
+    }
+}

src/AuthZero.AccountService/AuthZero.AccountService.Application/Features/Commands/AssignRoleCommand.cs

@@ -0,0 +1,7 @@
+
+namespace AuthZero.AccountService.Application.Features.Commands;
+
+public record AssignRoleCommand(
+    Guid UserId,
+    Guid[] Roles
+) : IRequest<bool>;

src/AuthZero.AccountService/AuthZero.AccountService.Application/Features/Commands/AssignRoleCommandHandler.cs

@@ -0,0 +1,36 @@
+
+using AuthZero.AccountService.Domain.AggregatesModel;
+using AuthZero.Shared.Exceptions;
+
+namespace AuthZero.AccountService.Application.Features.Commands;
+
+public record AssignRoleCommandHandler(
+    IRoleRepository _roleRepository,
+    IUserRepository _userRepository
+) : IRequestHandler<AssignRoleCommand, bool>
+{
+
+    public async Task<bool> Handle(AssignRoleCommand request, CancellationToken cancellationToken)
+    {
+        var user = await _userRepository.GetByIdAsync(request.UserId);
+        if (user == null)
+        {
+            throw new NotFoundDataException(nameof(User), "User.NotFound");
+        }
+
+        var roles = await _roleRepository.GetRolesByIdsAsync(request.Roles);
+
+        if (roles == null)
+        {
+            throw new NotFoundDataException(nameof(Role), "Role.NotFound");
+        }
+
+        user.AssignRoles(roles);
+
+        _userRepository.Update(user);
+
+        bool result = await _userRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
+
+        return result;
+    }
+}

src/AuthZero.AccountService/AuthZero.AccountService.Application/Features/Commands/EditUserCommand.cs

@@ -0,0 +1,10 @@
+
+namespace AuthZero.AccountService.Application.Features.Commands;
+
+public record EditUserCommand(
+    Guid Id,
+    string AvatarUrl,
+    string Bio,
+    string FirstName,
+    string LastName
+) : IRequest<bool>;

src/AuthZero.AccountService/AuthZero.AccountService.Application/Features/Commands/EditUserCommandHandler.cs

@@ -0,0 +1,28 @@
+
+using AuthZero.Shared.Exceptions;
+
+namespace AuthZero.AccountService.Application.Features.Commands;
+
+public class EditUserCommandHandler(
+    IUserRepository _userRepository
+) : IRequestHandler<EditUserCommand, bool>
+{
+    public async Task<bool> Handle(EditUserCommand request, CancellationToken cancellationToken)
+    {
+        User? user = await _userRepository.GetByIdAsync(request.Id);
+
+        if(user is null)
+            throw new NotFoundDataException("User", "User.NotFound");
+
+        user.Edit(
+            avatarUrl: request.AvatarUrl,
+            bio: request.Bio,
+            firstName: request.FirstName,
+            lastName: request.LastName
+        );
+
+        await _userRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
+
+        return true;
+    }
+}

src/AuthZero.AccountService/AuthZero.AccountService.Application/Features/Commands/LoginUserCommand.cs

@@ -0,0 +1,12 @@
+
+namespace AuthZero.AccountService.Application.Features.Commands;
+
+/// <summary>
+/// Login a user.
+/// </summary>
+/// <param name="EmailAddress">The email address of the user.</param>
+/// <param name="Password">The password of the user.</param>
+public record LoginUserCommand(
+    string EmailAddress,
+    string Password
+) : IRequest<ResultUserLoginSuccess>;