Skip to content

Commit 3f831d7

Browse files
A-ProgrammerA-Programmer
committed
Add MediatR feature and some tests and Sample Console App
1 parent 916d2bb commit 3f831d7

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

42 files changed

+1037
-76
lines changed

‎KSFramework.sln‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,18 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{827E0CD3-B72
77
EndProject
88
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "KSFramework", "src\KSFramework\KSFramework.csproj", "{B335BD79-05C0-4F0E-A2DA-FC72DF07A18C}"
99
EndProject
10+
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Samples", "Samples", "{5D20AA90-6969-D8BD-9DCD-8634F4692FDA}"
11+
EndProject
12+
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "MediatorSampleApp", "MediatorSampleApp", "{B36C9166-6687-1700-0084-D88BD073518A}"
13+
EndProject
14+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Mediator", "Samples\MediatorSampleApp\Mediator.csproj", "{D849CD75-73AE-4F1A-80EA-0FC596C80723}"
15+
EndProject
16+
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tests", "tests", "{0AB3BF05-4346-4AA6-1389-037BE0695223}"
17+
EndProject
18+
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "KSFramework", "KSFramework", "{6F746C7E-99E8-D040-B792-CDA2514E83CE}"
19+
EndProject
20+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "KSFramework.UnitTests", "tests\KSFramework\KSFramework.UnitTests\KSFramework.UnitTests.csproj", "{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}"
21+
EndProject
1022
Global
1123
GlobalSection(SolutionConfigurationPlatforms) = preSolution
1224
Debug|Any CPU = Debug|Any CPU
@@ -29,11 +41,39 @@ Global
2941
{B335BD79-05C0-4F0E-A2DA-FC72DF07A18C}.Release|x64.Build.0 = Release|Any CPU
3042
{B335BD79-05C0-4F0E-A2DA-FC72DF07A18C}.Release|x86.ActiveCfg = Release|Any CPU
3143
{B335BD79-05C0-4F0E-A2DA-FC72DF07A18C}.Release|x86.Build.0 = Release|Any CPU
44+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
45+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Debug|Any CPU.Build.0 = Debug|Any CPU
46+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Debug|x64.ActiveCfg = Debug|Any CPU
47+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Debug|x64.Build.0 = Debug|Any CPU
48+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Debug|x86.ActiveCfg = Debug|Any CPU
49+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Debug|x86.Build.0 = Debug|Any CPU
50+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Release|Any CPU.ActiveCfg = Release|Any CPU
51+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Release|Any CPU.Build.0 = Release|Any CPU
52+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Release|x64.ActiveCfg = Release|Any CPU
53+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Release|x64.Build.0 = Release|Any CPU
54+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Release|x86.ActiveCfg = Release|Any CPU
55+
{D849CD75-73AE-4F1A-80EA-0FC596C80723}.Release|x86.Build.0 = Release|Any CPU
56+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
57+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Debug|Any CPU.Build.0 = Debug|Any CPU
58+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Debug|x64.ActiveCfg = Debug|Any CPU
59+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Debug|x64.Build.0 = Debug|Any CPU
60+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Debug|x86.ActiveCfg = Debug|Any CPU
61+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Debug|x86.Build.0 = Debug|Any CPU
62+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Release|Any CPU.ActiveCfg = Release|Any CPU
63+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Release|Any CPU.Build.0 = Release|Any CPU
64+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Release|x64.ActiveCfg = Release|Any CPU
65+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Release|x64.Build.0 = Release|Any CPU
66+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Release|x86.ActiveCfg = Release|Any CPU
67+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5}.Release|x86.Build.0 = Release|Any CPU
3268
EndGlobalSection
3369
GlobalSection(SolutionProperties) = preSolution
3470
HideSolutionNode = FALSE
3571
EndGlobalSection
3672
GlobalSection(NestedProjects) = preSolution
3773
{B335BD79-05C0-4F0E-A2DA-FC72DF07A18C} = {827E0CD3-B72D-47B6-A68D-7590B98EB39B}
74+
{B36C9166-6687-1700-0084-D88BD073518A} = {5D20AA90-6969-D8BD-9DCD-8634F4692FDA}
75+
{D849CD75-73AE-4F1A-80EA-0FC596C80723} = {B36C9166-6687-1700-0084-D88BD073518A}
76+
{6F746C7E-99E8-D040-B792-CDA2514E83CE} = {0AB3BF05-4346-4AA6-1389-037BE0695223}
77+
{48D1B7B2-D99B-4554-BBFB-95E75720B8E5} = {6F746C7E-99E8-D040-B792-CDA2514E83CE}
3878
EndGlobalSection
3979
EndGlobal

‎Samples/MediatorSampleApp/CounterStreamTest.cs‎

Lines changed: 0 additions & 6 deletions
This file was deleted.

‎Samples/MediatorSampleApp/LoggingNotificationBehavior.cs‎

Lines changed: 0 additions & 6 deletions
This file was deleted.

‎Samples/MediatorSampleApp/Mediator.csproj‎

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
<Project Sdk="Microsoft.NET.Sdk">
2+
3+
<PropertyGroup>
4+
<OutputType>Exe</OutputType>
5+
<TargetFramework>net10.0</TargetFramework>
6+
<ImplicitUsings>enable</ImplicitUsings>
7+
<Nullable>enable</Nullable>
8+
</PropertyGroup>
9+
10+
<ItemGroup>
11+
<ProjectReference Include="..\..\src\KSFramework\KSFramework.csproj" />
12+
</ItemGroup>
13+
14+
</Project>

‎Samples/MediatorSampleApp/MultiplyByTwoRequest.cs‎

Lines changed: 0 additions & 6 deletions
This file was deleted.

‎Samples/MediatorSampleApp/NotificationTest.cs‎

Lines changed: 0 additions & 6 deletions
This file was deleted.

‎Samples/MediatorSampleApp/Program.cs‎

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
using FluentValidation;
2+
using KSFramework.Messaging;
3+
using KSFramework.Messaging.Abstraction;
4+
using KSFramework.Messaging.Behaviors;
5+
using KSFramework.Messaging.Configuration;
6+
using KSFramework.Messaging.Samples;
7+
using Microsoft.Extensions.DependencyInjection;
8+
9+
var services = new ServiceCollection();
10+
11+
// فقط یکبار mediator رو ثبت کن
12+
services.AddScoped<IMediator, Mediator>();
13+
services.AddScoped<ISender>(sp => sp.GetRequiredService<IMediator>());
14+
15+
services.AddLogging();
16+
17+
services.AddValidatorsFromAssembly(typeof(Program).Assembly);
18+
services.AddMessaging(typeof(MultiplyByTwoHandler).Assembly);
19+
20+
// اگر رفتارهای pipeline داری، ثبت کن
21+
services.AddScoped(typeof(IPipelineBehavior<,>), typeof(RequestProcessorBehavior<,>));
22+
services.AddMessaging(typeof(ExceptionHandlingBehavior<,>).Assembly, typeof(MultiplyByTwoRequest).Assembly);
23+
24+
var provider = services.BuildServiceProvider();
25+
26+
var mediator = provider.GetRequiredService<IMediator>();
27+
28+
var result = await mediator.Send(new MultiplyByTwoRequest(5));
29+
Console.WriteLine($"Result: {result}");

‎src/KSFramework/Domain/IDomainEvent.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
using MediatR;
1+
using KSFramework.Messaging.Abstraction;
22

33
namespace KSFramework.Domain;
44
public interface IDomainEvent : INotification

‎src/KSFramework/KSFramework.csproj‎

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,10 @@
2828
</ItemGroup>
2929

3030
<ItemGroup>
31-
<PackageReference Include="MediatR" Version="12.5.0" />
32-
<PackageReference Include="FluentValidation" Version="12.0.0" />
31+
<!-- TODO: To be removed-->
32+
<!-- <PackageReference Include="MediatR" Version="12.5.0" />-->
33+
<PackageReference Include="FluentValidation" Version="12.0" />
34+
<PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="12.0" />
3335
<PackageReference Include="Microsoft.AspNetCore.Mvc" Version="2.3.0" />
3436
<PackageReference Include="Microsoft.AspNetCore.Mvc.TagHelpers" Version="2.3.0" />
3537
<PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.5" />
@@ -38,6 +40,7 @@
3840
<PackageReference Include="Microsoft.Extensions.Hosting" Version="9.0.5" />
3941
<PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
4042
<PackageReference Include="Pluralize.NET" Version="1.0.2" />
43+
<PackageReference Include="Scrutor" Version="6.0.1" />
4144
</ItemGroup>
4245

4346
</Project>

‎src/KSFramework/Messaging/Abstraction/IMediator.cs‎

Lines changed: 28 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,4 @@
1-
using KSFramework.Messaging.Abstraction;
2-
3-
namespace KSFramework.Messaging;
1+
namespace KSFramework.Messaging.Abstraction;
42

53
/// <summary>
64
/// Represents a mediator that supports sending requests and publishing notifications.
@@ -16,4 +14,31 @@ public interface IMediator : ISender
1614
/// <returns>A task representing the asynchronous operation.</returns>
1715
Task Publish<TNotification>(TNotification notification, CancellationToken cancellationToken = default)
1816
where TNotification : INotification;
17+
18+
/// <summary>
19+
/// Sends a request without knowing the response type at compile time.
20+
/// </summary>
21+
/// <param name="request">The request to send.</param>
22+
/// <param name="cancellationToken">Cancellation token.</param>
23+
/// <returns>A task that represents the response.</returns>
24+
Task<object?> Send(object request, CancellationToken cancellationToken = default);
25+
26+
/// <summary>
27+
/// Publishes a notification without knowing the notification type at compile time.
28+
/// </summary>
29+
/// <param name="notification">The notification instance.</param>
30+
/// <param name="cancellationToken">Cancellation token.</param>
31+
/// <returns>A task representing the asynchronous operation.</returns>
32+
Task Publish(object notification, CancellationToken cancellationToken = default);
33+
34+
/// <summary>
35+
/// Creates a stream of responses for a given stream request.
36+
/// </summary>
37+
/// <typeparam name="TResponse">Type of the streamed response.</typeparam>
38+
/// <param name="request">The stream request instance.</param>
39+
/// <param name="cancellationToken">Cancellation token.</param>
40+
/// <returns>An asynchronous stream of responses.</returns>
41+
IAsyncEnumerable<TResponse> CreateStream<TResponse>(
42+
IStreamRequest<TResponse> request,
43+
CancellationToken cancellationToken = default);
1944
}

0 commit comments

Comments
 (0)