Remove unused property of interaction module

This commit is contained in:
2025-04-08 23:50:24 +03:00
parent ab40cad3ee
commit e2012dc2d3
3 changed files with 3 additions and 14 deletions
-1
View File
@@ -9,7 +9,6 @@ namespace mROA.Abstract
{ {
int ConnectionId { get; set; } int ConnectionId { get; set; }
public Stream? BaseStream { get; set; } public Stream? BaseStream { get; set; }
public IntPtr StreamHandle { get; set; }
Task<NetworkMessageHeader> GetNextMessageReceiving(bool infinite = true); Task<NetworkMessageHeader> GetNextMessageReceiving(bool infinite = true);
Task PostMessageAsync(NetworkMessageHeader messageHeader); Task PostMessageAsync(NetworkMessageHeader messageHeader);
void HandleMessage(NetworkMessageHeader messageHeader); void HandleMessage(NetworkMessageHeader messageHeader);
@@ -73,7 +73,6 @@ namespace mROA.Implementation.Backend
interaction!.Inject(_serialization); interaction!.Inject(_serialization);
interaction.BaseStream = client.GetStream(); interaction.BaseStream = client.GetStream();
interaction.StreamHandle = client.Client.Handle;
var connectionRequest = interaction.GetNextMessageReceiving(false) var connectionRequest = interaction.GetNextMessageReceiving(false)
.GetAwaiter().GetResult()!; .GetAwaiter().GetResult()!;
@@ -91,7 +90,6 @@ namespace mROA.Implementation.Backend
var recoveryRequest = _serialization!.Deserialize<ClientRecovery>(connectionRequest.Data)!; var recoveryRequest = _serialization!.Deserialize<ClientRecovery>(connectionRequest.Data)!;
var recoveryInteraction = _hub.GetInteraction(recoveryRequest.Id); var recoveryInteraction = _hub.GetInteraction(recoveryRequest.Id);
recoveryInteraction.BaseStream = client.GetStream(); recoveryInteraction.BaseStream = client.GetStream();
recoveryInteraction.StreamHandle = client.Client.Handle;
recoveryInteraction.Restart(false); recoveryInteraction.Restart(false);
Console.WriteLine("Connection recovery for client {0} finished", recoveryRequest.Id); Console.WriteLine("Connection recovery for client {0} finished", recoveryRequest.Id);
@@ -2,7 +2,6 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.IO; using System.IO;
using System.Linq; using System.Linq;
using System.Net.Sockets;
using System.Threading.Tasks; using System.Threading.Tasks;
using mROA.Abstract; using mROA.Abstract;
@@ -27,14 +26,7 @@ namespace mROA.Implementation
} }
public int ConnectionId { get; set; } public int ConnectionId { get; set; }
public Stream? BaseStream { get; set; }
public Stream? BaseStream
{
get => _baseStream;
set => _baseStream = value;
}
public IntPtr StreamHandle { get; set; }
public void Inject<T>(T dependency) public void Inject<T>(T dependency)
@@ -63,7 +55,7 @@ namespace mROA.Implementation
{ {
#if TRACE #if TRACE
Console.WriteLine( Console.WriteLine(
$"{DateTime.Now.TimeOfDay} Posting message to {StreamHandle}: {messageHeader.Id} - {messageHeader.MessageType} to {ConnectionId}"); $"{DateTime.Now.TimeOfDay} Posting message: {messageHeader.Id} - {messageHeader.MessageType} to {ConnectionId}");
#endif #endif
var rawMessage = _serialization.Serialize(messageHeader); var rawMessage = _serialization.Serialize(messageHeader);
@@ -178,7 +170,7 @@ namespace mROA.Implementation
var message = _serialization.Deserialize<NetworkMessageHeader>(localSpan.Span); var message = _serialization.Deserialize<NetworkMessageHeader>(localSpan.Span);
#if TRACE #if TRACE
Console.WriteLine($"{DateTime.Now.TimeOfDay} Received Message from {StreamHandle} {message.Id} - {message.MessageType}"); Console.WriteLine($"{DateTime.Now.TimeOfDay} Received Message {message.Id} - {message.MessageType}");
TransmissionConfig.TotalTransmittedBytes += len; TransmissionConfig.TotalTransmittedBytes += len;
Console.WriteLine($"Total received bytes are {TransmissionConfig.TotalTransmittedBytes}"); Console.WriteLine($"Total received bytes are {TransmissionConfig.TotalTransmittedBytes}");
#endif #endif