EvilBeaver/OneScript: Исполняющая среда скриптов на языке 1С

src/OneScript.DebugProtocol/TcpServer/BinaryChannel.cs

66 строк2 KB

EvilBeaver

Реализация команды disconnect отладчика

16 сен 2023, 11:00

16 сен 2023, 11:00cdd29d1

/*----------------------------------------------------------
This Source Code Form is subject to the terms of the 
Mozilla Public License, v.2.0. If a copy of the MPL 
was not distributed with this file, You can obtain one 
at http://mozilla.org/MPL/2.0/.
----------------------------------------------------------*/

using System.IO;
using System.Net.Sockets;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
using OneScript.DebugProtocol.Abstractions;

namespace OneScript.DebugProtocol
{
    /// <summary>
    /// TCP-канал, использующий стандартную Binary-сериализацию .NET
    /// </summary>
    public class BinaryChannel : ICommunicationChannel
    {
        private readonly TcpClient _client;
        private readonly NetworkStream _clientStream;
        private readonly BinaryFormatter _serializer;

        public BinaryChannel(TcpClient client)
        {
            _client = client;
            _clientStream = _client.GetStream();
            _serializer = new BinaryFormatter();
        }

        public bool Connected => _client.Connected;
        
        public void Write(object data)
        {
            _serializer.Serialize(_clientStream, data);
        }
        
        public T Read<T>()
        {
            return (T)Read();
        }

        public object Read()
        {
            try
            {
                return _serializer.Deserialize(_clientStream);
            }
            catch (SerializationException e)
            {
                throw new ChannelException("Serialization Exception occured", Connected, e);
            }
            catch (IOException e)
            {
                throw new ChannelException("Network exception occured", true, e);
            }
        }

        public void Dispose()
        {
            _clientStream.Dispose();
            _client.Close();
        }
    }
}