namespace MillTracking.Shared.Models.Telegrams;

[StructLayout(LayoutKind.Sequential, CharSet = CharSet.Ansi, Pack = 1)]
public readonly record struct EndOfBarTelegram
{
    public static readonly string Key = nameof(EndOfBarTelegram);

    public readonly uint MessageLength;
    public readonly uint MessageId;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 2)]
    public readonly string ProfileType;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 30)]
    public readonly string ProfileName;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 20)]
    public readonly string BloomId;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 14)]
    public readonly string TimeIn;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 14)]
    public readonly string TimeOut;
    public readonly float BarLength;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] Mean;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] Max;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] Min;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] DefectLength;
}

namespace MillTracking.Shared.Models.Telegrams;

[StructLayout(LayoutKind.Sequential, CharSet = CharSet.Ansi, Pack = 1)]
public readonly record struct EndOfBarTelegram
{
    public static readonly string Key = nameof(EndOfBarTelegram);

    public readonly uint MessageLength;
    public readonly uint MessageId;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 2)]
    public readonly string ProfileType;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 30)]
    public readonly string ProfileName;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 20)]
    public readonly string BloomId;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 14)]
    public readonly string TimeIn;
    [MarshalAs(UnmanagedType.ByValTStr, SizeConst = 14)]
    public readonly string TimeOut;
    public readonly float BarLength;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] Mean;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] Max;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] Min;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 50)]
    public readonly float[] DefectLength;
}

        public static T? DecodeJson<T>(ReadOnlyMemory<byte> buffer, JsonSerializerOptions? jsonOptions = null)
        {
            try
            {
                JsonSerializerOptions options = jsonOptions ?? defaultJsonOptions;
                T val = JsonSerializer.Deserialize<T>(Encoding.UTF8.GetString(buffer.Span), options);
                return (val != null) ? val : default(T);
            }
            catch (Exception)
            {
                return default(T);
            }
        }

        public static T? DecodeJson<T>(ReadOnlyMemory<byte> buffer, JsonSerializerOptions? jsonOptions = null)
        {
            try
            {
                JsonSerializerOptions options = jsonOptions ?? defaultJsonOptions;
                T val = JsonSerializer.Deserialize<T>(Encoding.UTF8.GetString(buffer.Span), options);
                return (val != null) ? val : default(T);
            }
            catch (Exception)
            {
                return default(T);
            }
        }

    private async ValueTask WriteDowntimeMessageToStandController(ReadOnlySequence<byte> buffer,
        CancellationToken cancellationToken)
    {
        if (!_tcpClient.Connected)
        {
            try
            {
                _tcpClient = new();
                await _tcpClient.ConnectAsync(_connectionsOptions.StandControllerIp, _connectionsOptions.DataCollectorPort, cancellationToken); // reusing this port
                _logger.LogInformation("Connected to the stand controller on {_standControllerIp}:{_standControllerPort}",
                    _connectionsOptions.StandControllerIp, _connectionsOptions.StandControllerPort);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "WriteDowntimeMessageToStandController-Exception");
            }
        }

        try
        {
            foreach (var segment in buffer)
            {
                var stream = _tcpClient.GetStream();

                await stream.WriteAsync(segment, cancellationToken);
            }
        }
        catch (Exception ex)
        {
            _logger.LogError(ex,
                "Error sending downtime to the stand controller at {_standControllerIp}.",
                _connectionsOptions.StandControllerIp);

            _tcpClient.Close();
        }
    }

    private async ValueTask WriteDowntimeMessageToStandController(ReadOnlySequence<byte> buffer,
        CancellationToken cancellationToken)
    {
        if (!_tcpClient.Connected)
        {
            try
            {
                _tcpClient = new();
                await _tcpClient.ConnectAsync(_connectionsOptions.StandControllerIp, _connectionsOptions.DataCollectorPort, cancellationToken); // reusing this port
                _logger.LogInformation("Connected to the stand controller on {_standControllerIp}:{_standControllerPort}",
                    _connectionsOptions.StandControllerIp, _connectionsOptions.StandControllerPort);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "WriteDowntimeMessageToStandController-Exception");
            }
        }

        try
        {
            foreach (var segment in buffer)
            {
                var stream = _tcpClient.GetStream();

                await stream.WriteAsync(segment, cancellationToken);
            }
        }
        catch (Exception ex)
        {
            _logger.LogError(ex,
                "Error sending downtime to the stand controller at {_standControllerIp}.",
                _connectionsOptions.StandControllerIp);

            _tcpClient.Close();
        }
    }