using System.Text;

namespace UniversalNetFrame451.IO;

public class RawDataLog : BaseFilter
{
    private class LogData(bool IsSend, Data rawData)
    {
        public bool IsSend { get; } = IsSend;

        public Data RawData { get; } = rawData;
    }

    private EventQueue<LogData> _logEvent;
    private string _filePath;

    public bool Initialize(string filePath)
    {
        this._filePath = filePath;
        _logEvent = new(LogEvent);
        return true;
    }

    public override bool Receive(Data data)
    {
        this._logEvent.Enqueue(new(false, data));
        return base.Receive(data);
    }

    public override bool Send(Data data)
    {
        this._logEvent.Enqueue(new(true, data));
        Console.WriteLine("Send");
        return base.Send(data);
    }


    private void LogEvent(LogData data)
    {
        //Write Log Here
        //StringBuilder sb = new();
        //foreach (byte item in data.RawData.RawData)
        //{
        //    sb.Append(item);
        //    sb.Append(' ');
        //}
        //Console.WriteLine(sb);
    }
}