Source/Tx.Bond/Internal/BondEnvelope.cs

using System;
using System.Reactive;

namespace Tx.Bond
{
    [global::Bond.Schema]
    internal class BondEnvelope : IEnvelope
    {
        [global::Bond.Id(1)]
        public long ReceivedFileTimeUtc { get; set; }

        [global::Bond.Id(2)]
        public long OccurrenceFileTimeUtc { get; set; }

        [global::Bond.Id(3)]
        public string TypeId { get; set; }

        [global::Bond.Id(4)]
        public string Source { get; set; }

        [global::Bond.Id(5)]
        public string Protocol { get; set; }

        [global::Bond.Id(6)]
        public byte[] Payload { get; set; }

        public DateTimeOffset OccurrenceTime => DateTimeOffset.FromFileTime(OccurrenceFileTimeUtc);

        public DateTimeOffset ReceivedTime => DateTimeOffset.FromFileTime(ReceivedFileTimeUtc);

        public object PayloadInstance { get; set; }
    }
}