| | | 1 | | using System.Runtime.Serialization; |
| | | 2 | | using NLightning.Domain.Node; |
| | | 3 | | using NLightning.Domain.Serialization.Payloads; |
| | | 4 | | |
| | | 5 | | namespace NLightning.Infrastructure.Serialization.Payloads; |
| | | 6 | | |
| | | 7 | | using Domain.Protocol.Payloads; |
| | | 8 | | using Domain.Protocol.Payloads.Interfaces; |
| | | 9 | | using Exceptions; |
| | | 10 | | using Interfaces; |
| | | 11 | | |
| | | 12 | | public class InitPayloadSerializer : IPayloadSerializer<InitPayload> |
| | | 13 | | { |
| | | 14 | | private readonly IFeatureSetSerializer _featureSetSerializer; |
| | | 15 | | |
| | 4 | 16 | | public InitPayloadSerializer(IFeatureSetSerializer featureSetSerializer) |
| | | 17 | | { |
| | 4 | 18 | | _featureSetSerializer = featureSetSerializer; |
| | 4 | 19 | | } |
| | | 20 | | |
| | | 21 | | public async Task SerializeAsync(IMessagePayload payload, Stream stream) |
| | | 22 | | { |
| | 8 | 23 | | if (payload is not InitPayload initPayload) |
| | 0 | 24 | | throw new SerializationException($"Payload is not of type {nameof(InitPayload)}"); |
| | | 25 | | |
| | 8 | 26 | | await _featureSetSerializer.SerializeAsync(initPayload.FeatureSet, stream, true); |
| | 8 | 27 | | await _featureSetSerializer.SerializeAsync(initPayload.FeatureSet, stream); |
| | 8 | 28 | | } |
| | | 29 | | |
| | | 30 | | public async Task<InitPayload?> DeserializeAsync(Stream stream) |
| | | 31 | | { |
| | | 32 | | try |
| | | 33 | | { |
| | 12 | 34 | | var globalFeatures = await _featureSetSerializer.DeserializeAsync(stream); |
| | 12 | 35 | | var features = await _featureSetSerializer.DeserializeAsync(stream); |
| | | 36 | | |
| | 12 | 37 | | return new InitPayload(FeatureSet.Combine(globalFeatures, features)); |
| | | 38 | | } |
| | 0 | 39 | | catch (Exception e) |
| | | 40 | | { |
| | 0 | 41 | | throw new PayloadSerializationException("Error deserializing InitPayload", e); |
| | | 42 | | } |
| | 12 | 43 | | } |
| | | 44 | | |
| | | 45 | | async Task<IMessagePayload?> IPayloadSerializer.DeserializeAsync(Stream stream) |
| | | 46 | | { |
| | 0 | 47 | | return await DeserializeAsync(stream); |
| | 0 | 48 | | } |
| | | 49 | | } |