кодовая база для нового базового класса удаленного объекта

mROA/Abstract/ICommandExecution.cs

@@ -2,7 +2,7 @@ namespace mROA.Abstract;
 
 public interface ICommandExecution
 {
-    Guid CallRequestId { get; init; }
+    Guid Id { get; init; }
     int ClientId { get; set; }
     int CommandId { get; }
 }

mROA/Abstract/IRemoteObject.cs

@@ -1,7 +0,0 @@
-namespace mROA.Abstract;
-
-public interface IRemoteObject
-{
-    public int Id { get; }
-    public int OwnerId { get; }
-}

mROA/Implementation/Backend/BasicExecutionModule.cs

@@ -48,7 +48,7 @@ public class BasicExecutionModule : IExecuteModule
             return new TypedFinalCommandExecution
             {
                 CommandId = command.CommandId, Result = finalResult,
-                CallRequestId = command.CallRequestId,
+                Id = command.CallRequestId,
                 Type = currentCommand.ReturnType
             };
         }
@@ -56,7 +56,7 @@ public class BasicExecutionModule : IExecuteModule
         {
             return new ExceptionCommandExecution
             {
-                CallRequestId = command.CallRequestId, CommandId = command.CommandId,
+                Id = command.CallRequestId, CommandId = command.CommandId,
                 Exception = e.ToString()
             };
         }
@@ -75,13 +75,13 @@ public class BasicExecutionModule : IExecuteModule
             result.Wait(token);
 
 
-            return new FinalCommandExecution { CommandId = command.CommandId, CallRequestId = command.CallRequestId };
+            return new FinalCommandExecution { CommandId = command.CommandId, Id = command.CallRequestId };
         }
         catch (Exception e)
         {
             return new ExceptionCommandExecution
             {
-                CallRequestId = command.CallRequestId, CommandId = command.CommandId,
+                Id = command.CallRequestId, CommandId = command.CommandId,
                 Exception = e.ToString()
             };
         }
@@ -102,7 +102,7 @@ public class BasicExecutionModule : IExecuteModule
             var finalResult = result.GetType().GetProperty("Result")?.GetValue(result);
             return new TypedFinalCommandExecution
             {
-                CallRequestId = command.CallRequestId,
+                Id = command.CallRequestId,
                 Result = finalResult,
                 CommandId = command.CommandId,
                 Type = finalResult?.GetType()
@@ -112,7 +112,7 @@ public class BasicExecutionModule : IExecuteModule
         {
             return new ExceptionCommandExecution
             {
-                CallRequestId = command.CallRequestId, CommandId = command.CommandId,
+                Id = command.CallRequestId, CommandId = command.CommandId,
                 Exception = e.ToString()
             };
         }

mROA/Implementation/Backend/NetworkGatewayModule.cs

@@ -6,7 +6,6 @@ namespace mROA.Implementation.Backend;
 
 public class NetworkGatewayModule : IGatewayModule
 {
-    private readonly IPEndPoint? _endpoint;
     private readonly Type? _interactionModuleType;
     private readonly IInjectableModule[]? _injectableModules;
     private readonly TcpListener? _tcpListener;
@@ -14,16 +13,14 @@ public class NetworkGatewayModule : IGatewayModule
 
     public NetworkGatewayModule(IPEndPoint endpoint, Type interactionModuleType, IInjectableModule[] injectableModules)
     {
-        _endpoint = endpoint;
+        _tcpListener = new(endpoint);
-        _tcpListener = new(_endpoint);
-
         _interactionModuleType = interactionModuleType;
         _injectableModules = injectableModules;
     }
 
     public void Run()
     {
-        _tcpListener.Start();
+        _tcpListener!.Start();
         Console.WriteLine($"Listening on {_tcpListener.LocalEndpoint}");
         Console.WriteLine("Enter Backspace to stop");
 

mROA/Implementation/CallRequest.cs

@@ -1,4 +1,6 @@
-namespace mROA.Implementation;
+using System.Text.Json.Serialization;
+
+namespace mROA.Implementation;
 
 public interface ICallRequest
 {
@@ -14,6 +16,7 @@ public class DefaultCallRequest : ICallRequest
     public int CommandId { get; init; }
     public int ObjectId { get; init; } = -1;
     
-    public Type ParameterType { get; init; }
+    [JsonIgnore]
+    public Type? ParameterType { get; init; }
     public object? Parameter { get; set; }
 }

mROA/Implementation/CommandExecution/ExceptionCommandExecution.cs

@@ -1,11 +1,18 @@
-using mROA.Abstract;
+using System.Text.Json;
+using mROA.Abstract;
+using mROA.Implementation.Frontend;
 
 namespace mROA.Implementation;
 
 public class ExceptionCommandExecution : ICommandExecution
 {
-    public Guid CallRequestId { get; init; }
+    public Guid Id { get; init; }
     public int ClientId { get; set; }
     public int CommandId { get; init; }
     public required string Exception { get; set; }
+
+    public RemoteException GetException()
+    {
+        return new RemoteException(Exception) { CallRequestId = Id };
+    }
 }

mROA/Implementation/CommandExecution/FinalCommandExecution.cs

@@ -7,7 +7,7 @@ namespace mROA.Implementation;
 
 public class FinalCommandExecution : ICommandExecution
 {
-    public Guid CallRequestId { get; init; }
+    public Guid Id { get; init; }
     [JsonIgnore]
     public int ClientId { get; set; }
     [JsonIgnore]

mROA/Implementation/Frontend/RequestExtractor.cs

@@ -1,4 +1,5 @@
 using mROA.Abstract;
+using mROA.Implementation.Backend;
 
 namespace mROA.Implementation.Frontend;
 
@@ -9,6 +10,7 @@ public class RequestExtractor : IRequestExtractor
     private IMethodRepository? _methodRepository;
     private IExecuteModule? _executeModule;
     private ISerializationToolkit? _serializationToolkit;
+
     public void Inject<T>(T dependency)
     {
         switch (dependency)
@@ -44,24 +46,38 @@ public class RequestExtractor : IRequestExtractor
         if (_methodRepository == null)
             throw new NullReferenceException("Method repository is null.");
 
-        while (true)
+        var multiClientOwnershipRepository = TransmissionConfig.OwnershipRepository as MultiClientOwnershipRepository;
+
+
+        multiClientOwnershipRepository?.RegisterOwnership(_representationModule.Id);
+
+        try
         {
-            var request = await _representationModule!.GetMessage<DefaultCallRequest>(messageType: MessageType.CallRequest);
+            while (true)
-            
-            if (request.Parameter is not null)
             {
-                var parameterType = _methodRepository!.GetMethod(request.CommandId).GetParameters().First().ParameterType;
+                var request =
-                request.Parameter = _serializationToolkit.Cast(request.Parameter, parameterType);
+                    await _representationModule!.GetMessage<DefaultCallRequest>(messageType: MessageType.CallRequest);
+
+                if (request.Parameter is not null)
+                {
+                    var parameterType = _methodRepository!.GetMethod(request.CommandId).GetParameters().First()
+                        .ParameterType;
+
+                    request.Parameter = _serializationToolkit.Cast(request.Parameter, parameterType);
+                }
+
+                var result = _executeModule.Execute(request, _contextRepository);
+
+                var resultType = result is FinalCommandExecution
+                    ? MessageType.FinishedCommandExecution
+                    : MessageType.ExceptionCommandExecution;
+
+                await _representationModule.PostCallMessage(request.CallRequestId, resultType, result);
             }
-            
+        }
-            var result = _executeModule.Execute(request, _contextRepository);
+        catch
-            
+        {
-            var resultType = result is FinalCommandExecution
+            multiClientOwnershipRepository?.RegisterOwnership(_representationModule.Id);
-                 ? MessageType.FinishedCommandExecution
-                 : MessageType.ErrorCommandExecution;
-            
-            await _representationModule.PostCallMessage(request.CallRequestId, resultType, result);
-            
         }
     }
 }

mROA/Implementation/NetworkMessage.cs

@@ -12,5 +12,5 @@ public class NetworkMessage
 
 public enum MessageType
 {
-    Unknown, FinishedCommandExecution, ErrorCommandExecution, AcyncCancelCommandExecution, CallRequest, IdAssigning 
+    Unknown, FinishedCommandExecution, ExceptionCommandExecution, AcyncCancelCommandExecution, CallRequest, IdAssigning 
 }

mROA/Implementation/RemoteContextRepository.cs

@@ -39,7 +39,7 @@ public class RemoteContextRepository : IContextRepository
 
     public int GetObjectIndex(object o)
     {
-        if (o is IRemoteObject remote)
+        if (o is RemoteObjectBase remote)
         {
             return remote.Id;
         }

mROA/Implementation/RemoteObjectBase.cs

@@ -0,0 +1,59 @@
+using mROA.Implementation;
+// ReSharper disable UnusedMember.Global
+
+namespace mROA.Abstract;
+
+public abstract class RemoteObjectBase
+{
+    private readonly int _id;
+    private readonly IRepresentationModule _representationModule;
+    public int Id => _id;
+    public int OwnerId => _representationModule.Id;
+
+    public RemoteObjectBase(int id, IRepresentationModule representationModule)
+    {
+        _id = id;
+        _representationModule = representationModule;
+    }
+
+    public async Task<T> GetResultAsync<T>(int methodId, object? parameter = default)
+    {
+        var request = new DefaultCallRequest
+            { CommandId = methodId, ObjectId = _id, Parameter = parameter, ParameterType = parameter?.GetType() };
+        await _representationModule.PostCallMessage(request.CallRequestId, MessageType.CallRequest, request);
+
+        var successResponse =
+            _representationModule.GetMessage<FinalCommandExecution<T>>(
+                messageType: MessageType.FinishedCommandExecution, requestId: request.CallRequestId);
+        var errorResponse =
+            _representationModule.GetMessage<ExceptionCommandExecution>(
+                messageType: MessageType.ExceptionCommandExecution, requestId: request.CallRequestId);
+        Task.WaitAny(successResponse, errorResponse);
+
+        if (successResponse.IsCompletedSuccessfully)
+            return successResponse.Result.Result!;
+
+        throw errorResponse.Result.GetException();
+    }
+
+    public async Task CallAsync(int methodId, object? parameter = default)
+    {
+        var request = new DefaultCallRequest
+            { CommandId = methodId, ObjectId = _id, Parameter = parameter, ParameterType = parameter?.GetType() };
+        await _representationModule.PostCallMessage(request.CallRequestId, MessageType.CallRequest, request);
+
+        var successResponse =
+            _representationModule.GetMessage<FinalCommandExecution>(
+                messageType: MessageType.FinishedCommandExecution, requestId: request.CallRequestId);
+        var errorResponse =
+            _representationModule.GetMessage<ExceptionCommandExecution>(
+                messageType: MessageType.ExceptionCommandExecution, requestId: request.CallRequestId);
+
+        Task.WaitAny(successResponse, errorResponse);
+
+        if (successResponse.IsCompletedSuccessfully)
+            return;
+
+        throw errorResponse.Result.GetException();
+    }
+}

mROA/Implementation/SharedObject.cs

@@ -63,7 +63,7 @@ public class SharedObject<T> where T : notnull
     {
         Value = value;
 
-        if (value is IRemoteObject ro)
+        if (value is RemoteObjectBase ro)
         {
             _ownerId = ro.OwnerId;
             _contextId = ro.Id;