работает, но с ограничениями

This commit is contained in:
2025-02-18 12:34:15 +03:00
parent 794c64aacb
commit bb994f6761
2 changed files with 7 additions and 5 deletions
+4 -4
View File
@@ -15,8 +15,9 @@ builder.Modules.Add(new NextGenerationInteractionModule());
builder.Modules.Add(new RepresentationModule()); builder.Modules.Add(new RepresentationModule());
builder.Modules.Add(new NetworkFrontendBridge(new IPEndPoint(IPAddress.Loopback, 4567))); builder.Modules.Add(new NetworkFrontendBridge(new IPEndPoint(IPAddress.Loopback, 4567)));
builder.Modules.Add(new StaticRepresentationModuleProducer()); builder.Modules.Add(new StaticRepresentationModuleProducer());
// builder.Modules.Add(new BasicExecutionModule()); builder.Modules.Add(new RequestExtractor());
// builder.Modules.Add(new CoCodegenMethodRepository()); builder.Modules.Add(new BasicExecutionModule());
builder.Modules.Add(new CoCodegenMethodRepository());
// builder.Modules.Add(new StreamBasedVirtualBackendInteractionModule()); // builder.Modules.Add(new StreamBasedVirtualBackendInteractionModule());
// builder.Modules.Add(new JsonSerialisationModule()); // builder.Modules.Add(new JsonSerialisationModule());
builder.UseCollectableContextRepository(); builder.UseCollectableContextRepository();
@@ -27,8 +28,7 @@ TransmissionConfig.RealContextRepository = builder.GetModule<ContextRepository>(
TransmissionConfig.RemoteEndpointContextRepository = builder.GetModule<RemoteContextRepository>(); TransmissionConfig.RemoteEndpointContextRepository = builder.GetModule<RemoteContextRepository>();
builder.GetModule<NetworkFrontendBridge>()!.Connect(); builder.GetModule<NetworkFrontendBridge>()!.Connect();
// builder.GetModule<StreamBasedVirtualBackendInteractionModule>()!.StartVirtualInteraction(); _ = builder.GetModule<RequestExtractor>()!.StartExtraction();
Console.WriteLine(TransmissionConfig.OwnershipRepository!.GetOwnershipId()); Console.WriteLine(TransmissionConfig.OwnershipRepository!.GetOwnershipId());
var context = builder.GetModule<RemoteContextRepository>(); var context = builder.GetModule<RemoteContextRepository>();
+3 -1
View File
@@ -1,4 +1,5 @@
using mROA.Abstract; using System.Text.Json;
using mROA.Abstract;
namespace mROA.Implementation; namespace mROA.Implementation;
@@ -37,6 +38,7 @@ public class RepresentationModule : IRepresentationModule
while (true) while (true)
{ {
var message = await _interaction.GetNextMessageReceiving(); var message = await _interaction.GetNextMessageReceiving();
Console.WriteLine("Message received {0}", JsonSerializer.Serialize(message));
if ((requestId is null || message.Id == requestId) && if ((requestId is null || message.Id == requestId) &&
(messageType is null || message.SchemaId == messageType)) (messageType is null || message.SchemaId == messageType))
return message.Data; return message.Data;