66 lines
2.2 KiB
C#
66 lines
2.2 KiB
C#
// using mROA.Abstract;
|
|
//
|
|
// namespace mROA.Implementation.Backend;
|
|
//
|
|
// public class StreamBasedInteractionModule : IInteractionModule
|
|
// {
|
|
// internal ISerialisationModule _serialisationModule;
|
|
// private readonly Dictionary<int, Stream> _streams = new();
|
|
// internal Action<int, byte[]>? _handler;
|
|
//
|
|
// public void RegisterSource(Stream stream)
|
|
// {
|
|
// var id = Random.Shared.Next();
|
|
// _streams.Add(id, stream);
|
|
// _ = ListenTo((id, stream), _handler!);
|
|
// _serialisationModule.SendWelcomeMessage(id);
|
|
// }
|
|
//
|
|
// public Stream GetSource(int clientId)
|
|
// {
|
|
// return _streams.GetValueOrDefault(clientId, Stream.Null);
|
|
// }
|
|
//
|
|
// public void SendTo(int clientId, byte[] message)
|
|
// {
|
|
// if (!_streams.TryGetValue(clientId, out var stream))
|
|
// {
|
|
// throw new KeyNotFoundException($"Client {clientId} not found");
|
|
// }
|
|
//
|
|
// stream.Write(BitConverter.GetBytes((ushort)message.Length), 0, sizeof(ushort));
|
|
// stream.Write(message, 0, message.Length);
|
|
// }
|
|
//
|
|
// private async Task ListenTo((int id, Stream stream) client, Action<int, byte[]> action)
|
|
// {
|
|
// TransmissionConfig.OwnershipRepository = new MultiClientOwnershipRepository();
|
|
// const int bufferSize = ushort.MaxValue;
|
|
// try
|
|
// {
|
|
// byte[] buffer = new byte[bufferSize];
|
|
// while (client.stream.CanRead)
|
|
// {
|
|
// await client.stream.ReadExactlyAsync(buffer, 0, 2);
|
|
// var len = BitConverter.ToUInt16(buffer, 0);
|
|
// await client.stream.ReadExactlyAsync(buffer, 0, len);
|
|
// _ = Task.Run(() => action(client.id, buffer[..len]));
|
|
// }
|
|
// }
|
|
// catch (Exception)
|
|
// {
|
|
// Console.WriteLine($"Client handling finished:{client.id}");
|
|
// _streams.Remove(client.id);
|
|
// }
|
|
// }
|
|
//
|
|
// public void Inject<T>(T dependency)
|
|
// {
|
|
// if (dependency is ISerialisationModule serialisationModule)
|
|
// {
|
|
// _handler = serialisationModule.HandleIncomingRequest;
|
|
// _serialisationModule = serialisationModule;
|
|
// }
|
|
// }
|
|
//
|
|
// } |