From 2fa0f3cb8be2c6e76f0e362413289c735e75dcdd Mon Sep 17 00:00:00 2001 From: Veljko Tosic Date: Wed, 4 Mar 2026 23:13:21 +0100 Subject: [PATCH] Messages --- .../AcceptUserRequestToJoinMessage.cs | 6 ++++++ .../AcceptUserRequestToJoinMessageHandler.cs | 19 +++++++++++++++++++ .../RejectUserRequestToJoinMessage.cs | 6 ++++++ .../RejectUserRequestToJoinMessageHandler.cs | 19 +++++++++++++++++++ 4 files changed, 50 insertions(+) create mode 100644 dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessage.cs create mode 100644 dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessageHandler.cs create mode 100644 dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessage.cs create mode 100644 dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessageHandler.cs diff --git a/dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessage.cs b/dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessage.cs new file mode 100644 index 0000000..79d4401 --- /dev/null +++ b/dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessage.cs @@ -0,0 +1,6 @@ +using AipsCore.Application.Abstract.MessageBroking; +using AipsCore.Application.Models.Whiteboard.Command.AcceptUserRequestToJoin; + +namespace AipsCore.Application.Common.Message.AcceptUserRequestToJoin; + +public record AcceptUserRequestToJoinMessage(AcceptUserRequestToJoinCommand Command) : IMessage; \ No newline at end of file diff --git a/dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessageHandler.cs b/dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessageHandler.cs new file mode 100644 index 0000000..c42f1b8 --- /dev/null +++ b/dotnet/AipsCore/Application/Common/Message/AcceptUserRequestToJoin/AcceptUserRequestToJoinMessageHandler.cs @@ -0,0 +1,19 @@ +using AipsCore.Application.Abstract; +using AipsCore.Application.Abstract.MessageBroking; + +namespace AipsCore.Application.Common.Message.AcceptUserRequestToJoin; + +public class AcceptUserRequestToJoinMessageHandler : IMessageHandler +{ + private readonly IDispatcher _dispatcher; + + public AcceptUserRequestToJoinMessageHandler(IDispatcher dispatcher) + { + _dispatcher = dispatcher; + } + + public async Task Handle(AcceptUserRequestToJoinMessage message, CancellationToken cancellationToken) + { + await _dispatcher.Execute(message.Command, cancellationToken); + } +} \ No newline at end of file diff --git a/dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessage.cs b/dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessage.cs new file mode 100644 index 0000000..d92dd98 --- /dev/null +++ b/dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessage.cs @@ -0,0 +1,6 @@ +using AipsCore.Application.Abstract.MessageBroking; +using AipsCore.Application.Models.Whiteboard.Command.RejectUserRequestToJoin; + +namespace AipsCore.Application.Common.Message.RejectUserRequestToJoin; + +public record RejectUserRequestToJoinMessage(RejectUserRequestToJoinCommand Command): IMessage; \ No newline at end of file diff --git a/dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessageHandler.cs b/dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessageHandler.cs new file mode 100644 index 0000000..a076a32 --- /dev/null +++ b/dotnet/AipsCore/Application/Common/Message/RejectUserRequestToJoin/RejectUserRequestToJoinMessageHandler.cs @@ -0,0 +1,19 @@ +using AipsCore.Application.Abstract; +using AipsCore.Application.Abstract.MessageBroking; + +namespace AipsCore.Application.Common.Message.RejectUserRequestToJoin; + +public class RejectUserRequestToJoinMessageHandler : IMessageHandler +{ + private readonly IDispatcher _dispatcher; + + public RejectUserRequestToJoinMessageHandler(IDispatcher dispatcher) + { + _dispatcher = dispatcher; + } + + public async Task Handle(RejectUserRequestToJoinMessage message, CancellationToken cancellationToken) + { + await _dispatcher.Execute(message.Command, cancellationToken); + } +} \ No newline at end of file