Fix Grpc generate problem.

Add grpc service installer in identity and email project.
Add in iJwtService CreateToken method and implement in JwtService .
Delete email logic in identity service and implement message pattern logic.

crs/CommonComponents/Common/Common.csproj

@@ -16,7 +16,7 @@
 		<PackageReference Include="Microsoft.EntityFrameworkCore" Version="8.0.1" />
 		<PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.1" />
 		<PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
-		<PackageReference Include="Polly" Version="8.2.1" />
+		<PackageReference Include="Polly" Version="8.3.0" />
 		<PackageReference Include="prometheus-net" Version="8.2.1" />
 		<PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="6.5.0" />
 		<PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="6.5.0" />

crs/CommonComponents/Contracts/Abstractions/Abstractions.proto

@@ -1,6 +1,8 @@
 syntax = "proto3";
 
-package Contracts.Abstractions.Protobuf;
+option csharp_namespace = "Contracts.Abstractions";
+
+package abstractions;
 
 
 message NotFound {}

crs/CommonComponents/Contracts/Contracts.csproj

@@ -1,18 +1,28 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
-  <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-  </PropertyGroup>
+	<PropertyGroup>
+		<TargetFramework>net8.0</TargetFramework>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+	</PropertyGroup>
 
-  <ItemGroup>
-    <ProjectReference Include="..\Common\Common.csproj" />
-    <ProjectReference Include="..\EventBus\EventBus.Common\EventBus.Common.csproj" />
-  </ItemGroup>
+	<ItemGroup>
+		<ProjectReference Include="..\Common\Common.csproj" />
+		<ProjectReference Include="..\EventBus\EventBus.Common\EventBus.Common.csproj" />
+	</ItemGroup>
 
-  <ItemGroup>
-    <Folder Include="Abstractions\" />
-  </ItemGroup>
+	<ItemGroup>
+		<Protobuf Include="Abstractions\Abstractions.proto" GrpcServices="Both" />
+		<Protobuf Include="Services\Identity\Identity.proto" GrpcServices="Both" />
+	</ItemGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Google.Protobuf" Version="3.25.2" />
+		<PackageReference Include="Grpc.Net.Client" Version="2.60.0" />
+		<PackageReference Include="Grpc.Tools" Version="2.61.0">
+			<PrivateAssets>all</PrivateAssets>
+			<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+		</PackageReference>
+	</ItemGroup>
 
 </Project>

crs/CommonComponents/Contracts/Services/Identity/Identity.proto

@@ -1,25 +1,25 @@
 syntax = "proto3";
 
-package Contracts.Services.Idenitty.Protobuf;
+option csharp_namespace = "Contracts.Services.Identity";
 
-import "Abstractions/Abstractions.proto";
+package identity;
 
-service IdenittyService {
+service IdentityService {
 	rpc GetUser(GetUserRequest) returns (User);
 }
 
 message GetUserRequest {
 	string id = 1;
 }
 
-message UserDetails {
+message User {
 	string user_id = 1;
-	string email = 3;
-	string first_name = 2;
-	string last_name = 2;
-	bool is_email_confirmed = 4;
-	Role role = 5;
-	Gender gender = 6;
+	string email = 2;
+	string first_name = 3;
+	string last_name = 4;
+	bool is_email_confirmed = 5;
+	Role role = 6;
+	Gender gender = 7;
 }
 
 enum Role {

crs/CommonComponents/EventBus/EventBus.MassTransit.RabbitMQ/GlobalUsings.cs

@@ -1,4 +1,2 @@
 global using MassTransit;
-global using MassTransit.Configuration;
 global using EventBus.Common.Abstractions;
-global using Common.Events;

crs/Docker/.env

@@ -19,4 +19,10 @@ REDIS_PASSWORD=Password123
 RABBITMQ_DEFAULT_USER=admin
 RABBITMQ_DEFAULT_PASS=admin
 
-CERTBOT_EMAIL=akber.sharifov2004@gmail.com
+CERTBOT_EMAIL=akber.sharifov2004@gmail.com
+
+EMAIL_FROM=Eshop
+EMAIL_HOST=smtp.gmail.com
+EMAIL_PORT=587
+EMAIL_USERNAME=akber.sharifov2004@gmail.com
+EMAIL_PASSWORD=ueey qfia bnyx atce

crs/Docker/docker-compose.override.yml

@@ -80,11 +80,19 @@ services:
       - ASPNETCORE_HTTP_PORTS=5110
       - ASPNETCORE_ENVIRONMENT=Development
       # Custom environment variables
+      - Email__From=${EMAIL_FROM}}
+      - Email__Host=${EMAIL_HOST}
+      - Email__Port=${EMAIL_PORT}
+      - Email__Username=${EMAIL_USERNAME}
+      - Email__Password=${EMAIL_PASSWORD}
+      - Retry__Message__Send__Count=3
       - RABBITMQ_DEFAULT_USER=${RABBITMQ_DEFAULT_USER}
       - RABBITMQ_DEFAULT_PASS=${RABBITMQ_DEFAULT_PASS} 
     ports:
       - "5110:80"
 
+
+
   mssql:
     environment:
     - ACCEPT_EULA=Y

crs/Services/Catalog/Catalog.Infrastructure/Catalog.Infrastructure.csproj

@@ -8,7 +8,7 @@
 
 	<ItemGroup>
 		<PackageReference Include="MediatR" Version="12.2.0" />
-		<PackageReference Include="Polly" Version="8.2.1" />
+		<PackageReference Include="Polly" Version="8.3.0" />
 		<PackageReference Include="Quartz" Version="3.8.0" />
 	</ItemGroup>
 

crs/Services/Email/Email.App/Configurations/GrpcServiceInstaller.cs

@@ -0,0 +1,14 @@
+namespace Email.App.Configurations;
+
+internal sealed class GrpcServiceInstaller : IServiceInstaller
+{
+    public void Install(IServiceCollection services, IConfiguration configuration)
+    {
+        services.AddGrpcClient<IdentityService.IdentityServiceClient>(options =>
+        {
+            options.Address = new Uri(Env.IDENTITY_URL);
+        });
+
+        services.AddGrpc();
+    }
+}

crs/Services/Email/Email.App/Email.App.csproj

@@ -12,6 +12,7 @@
 
 	<ItemGroup>
 		<PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="11.9.0" />
+		<PackageReference Include="Grpc.AspNetCore" Version="2.60.0" />
 		<PackageReference Include="MailKit" Version="4.3.0" />
 		<PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.6" />
 		<PackageReference Include="NetEscapades.Configuration.Yaml" Version="3.1.0" />
@@ -24,6 +25,7 @@
 
 	<ItemGroup>
 	  <ProjectReference Include="..\..\..\CommonComponents\Common\Common.csproj" />
+	  <ProjectReference Include="..\..\..\CommonComponents\Contracts\Contracts.csproj" />
 	  <ProjectReference Include="..\Email.Application\Email.Application.csproj" />
 	  <ProjectReference Include="..\Email.Infrastructure\Email.Infrastructure.csproj" />
 	</ItemGroup>

crs/Services/Email/Email.App/Env.cs

@@ -5,6 +5,7 @@
 /// </summary>
 internal static class Env
 {
+    public static string IDENTITY_URL => GetEnvironmentVariable("IDENTITY_URL");
     public static string RABBITMQ_DEFAULT_USER => GetEnvironmentVariable("RABBITMQ_DEFAULT_USER");
     public static string RABBITMQ_DEFAULT_PASS => GetEnvironmentVariable("RABBITMQ_DEFAULT_PASS");
 

crs/Services/Email/Email.App/GlobalUsings.cs

@@ -8,3 +8,4 @@
 global using FluentValidation;
 global using Email.App.OptionsSetup;
 global using Common.Infrastructure.Middleware;
+global using Contracts.Services.Identity;

crs/Services/Email/Email.App/appsettings.yml

@@ -2,14 +2,6 @@ Logging:
   LogLevel:
     Default: Information
     Microsoft.AspNetCore: Warning
-
-Email:
-  From: Eshop
-  Host: smtp.gmail.com
-  Port: 587
-  Username: akber.sharifov2004@gmail.com
-  Password: ueey qfia bnyx atce
-
 
 Swagger:
     Title: "Email API"

crs/Services/Email/Email.Application/Emails/Commands/SendConfirmationUserMessage/SendConfirmationUserMessageCommandHandler.cs

@@ -4,11 +4,13 @@ internal sealed class SendConfirmationUserMessageCommandHandler(IIdentityEmailSe
     : ICommandHandler<SendConfirmationUserMessageCommand>
 {
     private readonly IIdentityEmailService _emailService = emailService;
-    private readonly I
 
 
     public Task<Result> Handle(SendConfirmationUserMessageCommand request, CancellationToken cancellationToken)
     {
+
+
+
         _emailService.SendConfirmationEmailAsync(
                        new SendConfirmationEmailRequest
                        {

crs/Services/Email/Email.Application/GlobalUsings.cs

@@ -1,4 +1,4 @@
 global using System.Reflection;
 global using Common.Application.Abstractions.Messaging.Command;
 global using Common.Domain.Primitives.Results;
-global using Email.Infrastructure.Email.Abstractions;
+global using Email.Infrastructure.Email.Abstractions;

crs/Services/Email/Email.Infrastructure/Email.Infrastructure.csproj

@@ -10,6 +10,8 @@
     <PackageReference Include="MailKit" Version="4.3.0" />
     <PackageReference Include="Microsoft.Extensions.Options" Version="8.0.1" />
     <PackageReference Include="MimeKit" Version="4.3.0" />
+    <PackageReference Include="Polly" Version="8.3.0" />
+    <PackageReference Include="Polly.Contrib.WaitAndRetry" Version="1.1.1" />
   </ItemGroup>
 
   <ItemGroup>

crs/Services/Email/Email.Infrastructure/Email/Abstractions/IEmailService.cs

@@ -8,5 +8,5 @@ public interface IEmailService
     /// <param name="request">The <see cref="SendMessageRequest"/>.</param>
     /// <param name="cancellationToken">The <see cref="CancellationToken"/>.</param>
     /// <returns></returns>
-    Task SendAsync(SendMessageRequest request, CancellationToken cancellationToken = default);
+    Task SendMessageAsync(SendMessageRequest request, CancellationToken cancellationToken = default);
 }

crs/Services/Email/Email.Infrastructure/Email/EmailOptions.cs

@@ -7,4 +7,5 @@ public class EmailOptions
     public int Port { get; set; }
     public string Username { get; set; } = null!;
     public string Password { get; set; } = null!;
+    public int RetryMessageSendCount { get; set; }
 }

crs/Services/Email/Email.Infrastructure/Email/EmailTemplatePath.cs

@@ -3,7 +3,7 @@
 /// <summary>
 /// This class is used to get the path of the email templates.
 /// </summary>
-public static class EmailTemplatePath
+internal static class EmailTemplatePath
 {
     /// <summary>
     /// required change this template: {{firstName}}, {{lastName}}, {{confirmationLink}}

crs/Services/Email/Email.Infrastructure/Email/Services/EmailBaseService.cs

@@ -1,10 +1,17 @@
 namespace Email.Infrastructure.Email;
 
-public abstract class EmailBaseService(IOptions<EmailOptions> options) : IEmailService
+internal abstract class EmailBaseService(IOptions<EmailOptions> options) : IEmailService
 {
     private readonly EmailOptions _options = options.Value;
 
-    public async Task SendAsync(SendMessageRequest request, CancellationToken cancellationToken = default)
+    public async Task SendMessageAsync(SendMessageRequest request, CancellationToken cancellationToken = default) => 
+        await Policy.Handle<Exception>()
+        .WaitAndRetryAsync(
+            _options.RetryMessageSendCount,
+            retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)))
+        .ExecuteAsync(async () => await SendAsync(request, cancellationToken));
+
+    private async Task SendAsync(SendMessageRequest request, CancellationToken cancellationToken = default)
     {
         MimeMessage message = new();
         message.From.Add(MailboxAddress.Parse(_options.From));

crs/Services/Email/Email.Infrastructure/Email/Services/IdentityEmailService.cs

@@ -29,6 +29,6 @@ public async Task SendConfirmationEmailAsync(SendConfirmationEmailRequest reques
             Body: confirmEmailTemplate
             );
 
-        await SendAsync(sendMessageRequest, cancellationToken);
+        await SendMessageAsync(sendMessageRequest, cancellationToken);
     }
 }

crs/Services/Email/Email.Infrastructure/GlobalUsings.cs

@@ -5,4 +5,5 @@
 global using MimeKit;
 global using MailKit.Net.Smtp;
 global using System.Reflection;
-global using System.Text.Encodings.Web;
+global using System.Text.Encodings.Web;
+global using Polly;

crs/Services/Email/Email.MessageBus/Email.MessageBus.csproj

@@ -13,6 +13,7 @@
   <ItemGroup>
     <ProjectReference Include="..\..\..\CommonComponents\Contracts\Contracts.csproj" />
     <ProjectReference Include="..\..\..\CommonComponents\EventBus\EventBus.MassTransit\EventBus.MassTransit.csproj" />
+    <ProjectReference Include="..\Email.Application\Email.Application.csproj" />
   </ItemGroup>
 
 </Project>

crs/Services/Email/Email.MessageBus/GlobalUsings.cs

@@ -1,3 +1,4 @@
 global using EventBus.MassTransit.Handlers;
 global using Contracts.Services.Identity.Commands;
-global using MassTransit;
+global using MassTransit;
+global using MediatR;

crs/Services/Email/Email.MessageBus/Handlers/Commands/UserCreatedConfirmationEmailSendCommandHandler.cs

@@ -1,10 +1,23 @@
-namespace Email.MessageBus.Handlers.Commands;
+using Email.Application.Emails.Commands.SendConfirmationUserMessage;
 
-public sealed class UserCreatedConfirmationEmailSendCommandHandler
-    : IntegrationCommandHandler<UserCreatedConfirmationEmailSendCommand>
+namespace Email.MessageBus.Handlers.Commands;
+
+internal sealed class UserCreatedConfirmationEmailSendCommandHandler(ISender sender)
+        : IntegrationCommandHandler<UserCreatedConfirmationEmailSendCommand>
 {
-    public override Task Handle(ConsumeContext<UserCreatedConfirmationEmailSendCommand> context)
+    private readonly ISender _sender = sender;
+
+    public override async Task Handle(ConsumeContext<UserCreatedConfirmationEmailSendCommand> context)
     {
-        throw new NotImplementedException();
+        var request = new SendConfirmationUserMessageCommand(
+            context.Message.UserId,
+            context.Message.ReturnUrl);
+
+        var result = await _sender.Send(request);
+
+        if (result.IsFailure)
+        {
+            throw new Exception(result.Error);
+        }
     }
 }

crs/Services/Identity/Idenitty.Grpc/GlobalUsings.cs

@@ -0,0 +1,3 @@
+global using Grpc.Core;
+global using Contracts.Services.Identity;
+global using MediatR;

crs/Services/Identity/Idenitty.Grpc/Idenitty.Grpc.csproj

@@ -1,9 +1,20 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
-  <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-  </PropertyGroup>
+	<PropertyGroup>
+		<TargetFramework>net8.0</TargetFramework>
+		<ImplicitUsings>enable</ImplicitUsings>
+		<Nullable>enable</Nullable>
+	</PropertyGroup>
+
+	<ItemGroup>
+		<PackageReference Include="Grpc.Tools" Version="2.61.0">
+			<PrivateAssets>all</PrivateAssets>
+			<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+		</PackageReference>
+	</ItemGroup>
+
+	<ItemGroup>
+		<ProjectReference Include="..\..\..\CommonComponents\Contracts\Contracts.csproj" />
+	</ItemGroup>
 
 </Project>

crs/Services/Identity/Idenitty.Grpc/IdentityGrpcService.cs

@@ -0,0 +1,13 @@
+namespace Idenitty.Grpc;
+
+public sealed class IdentityGrpcService(ISender sender) : IdentityService.IdentityServiceBase
+{
+    private readonly ISender _sender = sender;
+
+    public override async Task<User> GetUser(GetUserRequest request, ServerCallContext context)
+    {
+        var result = await _sender.Send();
+
+        return base.GetUser(request, context);
+    }
+}

crs/Services/Identity/Identity.App/Configurations/GrpcServiceInstaller.cs

@@ -0,0 +1,9 @@
+namespace Identity.App.Configurations;
+
+internal sealed class GrpcServiceInstaller : IServiceInstaller
+{
+    public void Install(IServiceCollection services, IConfiguration configuration)
+    {
+        services.AddGrpc();
+    }
+}