59 lines
2.4 KiB
C#
59 lines
2.4 KiB
C#
using System.IO;
|
|
using INetMock.Client.Audit;
|
|
using INetMock.Client.Audit.Serialization;
|
|
using INetMock.Client.Test.Hex;
|
|
using Xunit;
|
|
|
|
namespace INetMock.Client.Test.Audit.Serialization;
|
|
|
|
public class GenericReaderTest
|
|
{
|
|
private const string HttpEventPayload = "000000a7120b088092b8c398feffffff01180120022a047f00000132047f00000138d8fc0140504a3308041224544c535f45434448455f45434453415f574954485f4145535f3235365f4342435f5348411a096c6f63616c686f7374a2014c080112096c6f63616c686f73741a15687474703a2f2f6c6f63616c686f73742f6173646622084854545020312e312a1c0a0641636365707412120a106170706c69636174696f6e2f6a736f6e";
|
|
private const string DnsEventPayload = "0000004e120b088092b8c398feffffff01180220012a100000000000000000000000000000000132100000000000000000000000000000000138d8fc014050aa0110120e0801120a6769746c61622e636f6d";
|
|
|
|
private readonly byte[] _httpEventPayloadBytes;
|
|
private readonly byte[] _dnsEventPayloadBytes;
|
|
|
|
public GenericReaderTest()
|
|
{
|
|
_httpEventPayloadBytes = HttpEventPayload.HexToByteArray();
|
|
_dnsEventPayloadBytes = DnsEventPayload.HexToByteArray();
|
|
}
|
|
|
|
[Fact]
|
|
public async void TestRead_HttpEvent_Success()
|
|
{
|
|
await using var protoReader = new ProtoReader(new MemoryStream(_httpEventPayloadBytes));
|
|
await using IEventReader reader = new GenericReader(protoReader);
|
|
await foreach (var ev in reader.ReadAllAsync())
|
|
{
|
|
Assert.NotNull(ev);
|
|
Assert.NotNull(ev.Details);
|
|
|
|
Assert.NotNull(ev.DetailsAs<HttpDetails>());
|
|
Assert.Null(ev.DetailsAs<DnsDetails>());
|
|
|
|
var httpEvent = (Event<HttpDetails>)ev;
|
|
Assert.NotNull(httpEvent);
|
|
Assert.NotNull(httpEvent.Details);
|
|
}
|
|
}
|
|
|
|
[Fact]
|
|
public async void TestRead_DnsEvent_Success()
|
|
{
|
|
await using var memStream = new MemoryStream(_dnsEventPayloadBytes);
|
|
await using var protoReader = new ProtoReader(new MemoryStream(_dnsEventPayloadBytes));
|
|
await using IEventReader reader = new GenericReader(protoReader);
|
|
await foreach (var ev in reader.ReadAllAsync())
|
|
{
|
|
Assert.NotNull(ev);
|
|
Assert.NotNull(ev.Details);
|
|
Assert.NotNull(ev.DetailsAs<DnsDetails>());
|
|
|
|
var dnsEvent = (Event<DnsDetails>)ev;
|
|
Assert.NotNull(dnsEvent);
|
|
Assert.NotNull(dnsEvent.Details);
|
|
}
|
|
}
|
|
}
|