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