ParsedTextWriter.cs

using System;
using System.IO;
 
namespace OSDP.Net.Tracing;

public class ParsedTextWriter : IDisposable
{
    private readonly StreamWriter _writer;
    private readonly MessageSpy _messageSpy;
    private readonly IPacketTextFormatter _formatter;
    private DateTime _lastPacketTime = DateTime.MinValue;

    public ParsedTextWriter(string outputPath, byte[] securityKey = null)
        : this(outputPath, securityKey, new OSDPPacketTextFormatter())
    {
    }

    public ParsedTextWriter(string outputPath, byte[] securityKey, IPacketTextFormatter formatter)
    {
        var directory = Path.GetDirectoryName(outputPath);
        if (!string.IsNullOrEmpty(directory))
            Directory.CreateDirectory(directory);
 
        _writer = new StreamWriter(outputPath, append: true);
        _messageSpy = new MessageSpy(securityKey);
        _formatter = formatter;
    }

    public void WritePacket(byte[] packetData, DateTime timestamp)
    {
        TimeSpan? delta = _lastPacketTime > DateTime.MinValue
            ? timestamp - _lastPacketTime
            : null;
        _lastPacketTime = timestamp;
 
        try
        {
            var packet = _messageSpy.ParsePacket(packetData);
            _writer.Write(_formatter.FormatPacket(packet, timestamp, delta));
            _writer.Flush();
        }
        catch (Exception ex)
        {
            _writer.Write(_formatter.FormatError(packetData, timestamp, delta, ex.Message));
            _writer.Flush();
        }
    }

    public void Dispose()
    {
        _writer.Dispose();
    }
}