Merge pull request #46 from NerosoftDev/develop

Develop

.editorconfig

@@ -25,4 +25,7 @@ resharper_move_local_function_after_jump_statement_highlighting = none;
 resharper_move_local_function_after_jump_statement = false;
 resharper_static_member_in_generic_type_highlighting = none;
 resharper_virtual_member_call_in_constructor_highlighting = none;
-resharper_inconsistently_synchronized_field_highlighting = hint;
+resharper_inconsistently_synchronized_field_highlighting = hint;
+resharper_redundant_type_declaration_body_highlighting = none;
+resharper_separate_local_functions_with_jump_statement_highlighting = none;
+resharper_convert_to_primary_constructor_highlighting = none;

Source/Euonia.Application/ApplicationModule.cs

@@ -7,13 +7,13 @@ namespace Nerosoft.Euonia.Application;
 /// <inheritdoc />
 public class ApplicationModule : ModuleContextBase
 {
-    /// <inheritdoc />
-    public override void ConfigureServices(ServiceConfigurationContext context)
-    {
-        context.Services.AddTransient<IInterceptor, LoggingInterceptor>();
-        context.Services.AddTransient<IInterceptor, AuthorizationInterceptor>();
-        context.Services.AddTransient<IInterceptor, ValidationInterceptor>();
-        context.Services.AddTransient<IInterceptor, TracingInterceptor>();
-        context.Services.AddScoped<IRequestContextAccessor, DelegateRequestContextAccessor>();
-    }
+	/// <inheritdoc />
+	public override void ConfigureServices(ServiceConfigurationContext context)
+	{
+		context.Services.AddTransient<IInterceptor, LoggingInterceptor>();
+		context.Services.AddTransient<IInterceptor, AuthorizationInterceptor>();
+		context.Services.AddTransient<IInterceptor, ValidationInterceptor>();
+		context.Services.AddTransient<IInterceptor, TracingInterceptor>();
+		context.Services.AddScoped(typeof(IUseCasePresenter<>), typeof(DefaultUseCasePresenter<>));
+	}
 }

Source/Euonia.Application/Behaviors/BearerTokenBehavior.cs

@@ -1,5 +1,6 @@
 using Nerosoft.Euonia.Bus;
 using Nerosoft.Euonia.Domain;
+using Nerosoft.Euonia.Modularity;
 using Nerosoft.Euonia.Pipeline;
 
 namespace Nerosoft.Euonia.Application;
@@ -30,15 +31,11 @@ public BearerTokenBehavior(IRequestContextAccessor contextAccessor)
 	/// <inheritdoc />
 	public async Task<CommandResponse> HandleAsync(IRoutedMessage context, PipelineDelegate<IRoutedMessage, CommandResponse> next)
 	{
-		if (_contextAccessor?.RequestHeaders.TryGetValue("Authorization", out var values) == true)
+		if (_contextAccessor?.Context?.RequestHeaders.TryGetValue("Authorization", out var value) == true)
 		{
-			if (values.Count > 0)
+			if (!string.IsNullOrWhiteSpace(value) && value.StartsWith("Bearer") && !value.Equals("Bearer null", StringComparison.OrdinalIgnoreCase))
 			{
-				var value = values[0];
-				if (!string.IsNullOrWhiteSpace(value) && value.StartsWith("Bearer") && !value.Equals("Bearer null", StringComparison.OrdinalIgnoreCase))
-				{
-					context.Metadata.Set("$nerosoft:token", value);
-				}
+				context.Metadata.Set("$nerosoft:token", value);
 			}
 		}
 

Source/Euonia.Application/Interceptors/TracingInterceptor.cs

@@ -1,6 +1,7 @@
 using System.Diagnostics;
 using Castle.DynamicProxy;
 using Microsoft.Extensions.Logging;
+using Nerosoft.Euonia.Modularity;
 
 namespace Nerosoft.Euonia.Application;
 

Source/Euonia.Application/Services/BaseApplicationService.cs

@@ -1,5 +1,6 @@
 using Nerosoft.Euonia.Bus;
 using Nerosoft.Euonia.Claims;
+using Nerosoft.Euonia.Modularity;
 
 namespace Nerosoft.Euonia.Application;
 

Source/Euonia.Application/UseCase/DefaultUseCasePresenter.cs

@@ -0,0 +1,52 @@
+namespace Nerosoft.Euonia.Application;
+
+/// <summary>
+/// The default implementation of <see cref="IUseCasePresenter{TOutput}"/>.
+/// </summary>
+/// <typeparam name="TOutput"></typeparam>
+public class DefaultUseCasePresenter<TOutput> : DisposableObject,
+                                                IUseCasePresenter<TOutput>
+	where TOutput : IUseCaseOutput
+{
+	/// <inheritdoc/>
+	public event EventHandler<TOutput> OnSucceed;
+
+	/// <inheritdoc/>
+	public event EventHandler<Exception> OnFailed;
+
+	/// <inheritdoc/>
+	public event EventHandler OnCanceled;
+
+	/// <inheritdoc/>
+	public void Error(Exception exception)
+	{
+		if (exception is OperationCanceledException)
+		{
+			OnCanceled?.Invoke(this, EventArgs.Empty);
+		}
+		else
+		{
+			OnFailed?.Invoke(this, exception);
+		}
+	}
+
+	/// <inheritdoc/>
+	public void Ok(TOutput output)
+	{
+		Output = output;
+		OnSucceed?.Invoke(this, output);
+	}
+
+	/// <summary>
+	/// Gets the output of the use case.
+	/// </summary>
+	public TOutput Output { get; private set; }
+
+	/// <inheritdoc/>
+	protected override void Dispose(bool disposing)
+	{
+		OnSucceed = null;
+		OnFailed = null;
+		OnCanceled = null;
+	}
+}

Source/Euonia.Application/UseCase/EmptyUseCaseInput.cs

@@ -0,0 +1,6 @@
+namespace Nerosoft.Euonia.Application;
+
+/// <summary>
+/// Represents a none input use case.
+/// </summary>
+public record EmptyUseCaseInput : IUseCaseInput;

Source/Euonia.Application/UseCase/EmptyUseCaseOutput.cs

@@ -0,0 +1,6 @@
+namespace Nerosoft.Euonia.Application;
+
+/// <summary>
+/// Represents the use case should not return any output.
+/// </summary>
+public sealed record EmptyUseCaseOutput : IUseCaseOutput;

Source/Euonia.Application/UseCase/IUseCase.cs

@@ -0,0 +1,40 @@
+namespace Nerosoft.Euonia.Application;
+
+/// <summary>
+/// Defines an interface for use case.
+/// </summary>
+/// <typeparam name="TInput"></typeparam>
+/// <typeparam name="TOutput"></typeparam>
+public interface IUseCase<in TInput, TOutput>
+	where TInput : IUseCaseInput
+	where TOutput : IUseCaseOutput
+{
+	/// <summary>
+	/// Executes the use case.
+	/// </summary>
+	/// <param name="input"></param>
+	/// <param name="cancellationToken"></param>
+	/// <returns></returns>
+	Task<TOutput> ExecuteAsync(TInput input, CancellationToken cancellationToken = default);
+
+	/// <summary>
+	/// Gets the presenter of the use case.
+	/// </summary>
+	IUseCasePresenter<TOutput> Presenter { get; }
+}
+
+/// <summary>
+/// Defines an interface for use case.
+/// </summary>
+/// <typeparam name="TInput"></typeparam>
+public interface IUseCase<in TInput>
+	where TInput : IUseCaseInput
+{
+	/// <summary>
+	/// Executes the use case.
+	/// </summary>
+	/// <param name="input"></param>
+	/// <param name="cancellationToken"></param>
+	/// <returns></returns>
+	Task ExecuteAsync(TInput input, CancellationToken cancellationToken = default);
+}

Source/Euonia.Application/UseCase/IUseCaseInput.cs

@@ -0,0 +1,8 @@
+namespace Nerosoft.Euonia.Application;
+
+/// <summary>
+/// Defines the input data structure of a use case.
+/// </summary>
+public interface IUseCaseInput
+{
+}

Source/Euonia.Application/UseCase/IUseCaseOutput.cs

@@ -0,0 +1,8 @@
+namespace Nerosoft.Euonia.Application;
+
+/// <summary>
+/// Defines the structure of use case execute result.
+/// </summary>
+public interface IUseCaseOutput
+{
+}

Source/Euonia.Application/UseCase/IUseCaseOutputFailure.cs

@@ -0,0 +1,13 @@
+namespace Nerosoft.Euonia.Application;
+
+/// <summary>
+/// Represents the structure of use case output when it is failure.
+/// </summary>
+public interface IUseCaseOutputFailure
+{
+	/// <summary>
+	/// 
+	/// </summary>
+	/// <param name="exception"></param>
+	void Error(Exception exception);
+}