Started work on higher (stream/message) and lower (byte) level api.

Author: yreynhout

src/StreamSource.Tests/StreamSource.Tests.csproj

@@ -57,6 +57,7 @@
       <Name>StreamSource</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup />
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.

src/StreamSource/IStreamStoreWriter.cs

@@ -0,0 +1,7 @@
+namespace StreamSource
+{
+    public interface IStreamStoreWriter
+    {
+        void Write(StreamChangeset changeset);
+    }
+}

src/StreamSource/IStreamStoreWriterSelector.cs

@@ -0,0 +1,9 @@
+using StreamSource.Naming;
+
+namespace StreamSource
+{
+    public interface IStreamStoreWriterSelector
+    {
+        IStreamStoreWriter Select(StreamName name);
+    }
+}

src/StreamSource/Metadatum.cs

@@ -0,0 +1,18 @@
+using System;
+
+namespace StreamSource
+{
+    public class Metadatum
+    {
+        public readonly string Name;
+        public readonly string Value;
+
+        public Metadatum(string name, string value)
+        {
+            if (name == null) throw new ArgumentNullException("name");
+            if (value == null) throw new ArgumentNullException("value");
+            Name = name;
+            Value = value;
+        }
+    }
+}

src/StreamSource/Serialization/IMessageDeserializer.cs

@@ -0,0 +1,7 @@
+namespace StreamSource.Serialization
+{
+    public interface IMessageDeserializer
+    {
+        object Deserialize(MessageRecord record);
+    }
+}

src/StreamSource/Serialization/IMessageSerializer.cs

@@ -0,0 +1,7 @@
+namespace StreamSource.Serialization
+{
+    public interface IMessageSerializer
+    {
+        MessageRecord Serialize(object message);
+    }
+}

src/StreamSource/Serialization/IMetadataDeserializer.cs

@@ -0,0 +1,7 @@
+namespace StreamSource.Serialization
+{
+    public interface IMetadataDeserializer
+    {
+        Metadatum[] Deserialize(byte[] data);
+    }
+}

src/StreamSource/Serialization/IMetadataSerializer.cs

@@ -0,0 +1,7 @@
+namespace StreamSource.Serialization
+{
+    public interface IMetadataSerializer
+    {
+        byte[] Deserialize(Metadatum[] metadata);
+    }
+}

src/StreamSource/Serialization/MessageRecord.cs

@@ -0,0 +1,18 @@
+using System;
+
+namespace StreamSource.Serialization
+{
+    public class MessageRecord
+    {
+        public readonly string Contract;
+        public readonly byte[] Data;
+
+        public MessageRecord(string contract, byte[] data)
+        {
+            if (contract == null) throw new ArgumentNullException("contract");
+            if (data == null) throw new ArgumentNullException("data");
+            Contract = contract;
+            Data = data;
+        }
+    }
+}

src/StreamSource/Storage/IStreamStoreRecordWriter.cs

@@ -0,0 +1,7 @@
+namespace StreamSource.Storage
+{
+    public interface IStreamStoreRecordWriter
+    {
+        void Write(StreamRecord[] records);
+    }
+}

src/StreamSource/Storage/StreamRecord.cs

@@ -0,0 +1,39 @@
+using System;
+
+namespace StreamSource.Storage
+{
+    public class StreamRecord
+    {
+        public readonly byte[] StreamId;
+        public readonly int StreamExpectedVersion;
+        public readonly string StreamName;
+        public readonly Guid MessageId;
+        public readonly byte[] MessageData;
+        public readonly string MessageDataContract;
+        public readonly byte[] MessageMetadata;
+        public readonly int MessageOrdinal;
+        public readonly Guid CausationId;
+        public readonly Guid CorrelationId;
+
+        public StreamRecord(byte[] streamId, string streamName, int streamExpectedVersion, Guid messageId, byte[] messageData, string messageDataContract, byte[] messageMetadata, int messageOrdinal, Guid causationId, Guid correlationId)
+        {
+            if (streamId == null) throw new ArgumentNullException("streamId");
+            if (streamExpectedVersion < 0) throw new ArgumentOutOfRangeException("streamExpectedVersion", streamExpectedVersion, "The expected version must be greater than or equal to 0.");
+            if (streamName == null) throw new ArgumentNullException("streamName");
+            if (messageData == null) throw new ArgumentNullException("messageData");
+            if (messageDataContract == null) throw new ArgumentNullException("messageDataContract");
+            if (messageMetadata == null) throw new ArgumentNullException("messageMetadata");
+            if (messageOrdinal < 0) throw new ArgumentOutOfRangeException("messageOrdinal", messageOrdinal, "The message ordinal must be greater than or equal to 0.");
+            StreamId = streamId;
+            StreamExpectedVersion = streamExpectedVersion;
+            StreamName = streamName;
+            MessageId = messageId;
+            MessageData = messageData;
+            MessageDataContract = messageDataContract;
+            MessageMetadata = messageMetadata;
+            MessageOrdinal = messageOrdinal;
+            CausationId = causationId;
+            CorrelationId = correlationId;
+        }
+    }
+}

src/StreamSource/StreamChange.cs

@@ -0,0 +1,20 @@
+using System;
+
+namespace StreamSource
+{
+    public class StreamChange
+    {
+        public readonly Guid MessageId;
+        public readonly object Message;
+        public readonly Metadatum[] Metadata;
+
+        public StreamChange(Guid messageId, object message, Metadatum[] metadata)
+        {
+            if (message == null) throw new ArgumentNullException("message");
+            if (metadata == null) throw new ArgumentNullException("metadata");
+            MessageId = messageId;
+            Message = message;
+            Metadata = metadata;
+        }
+    }
+}

src/StreamSource/StreamChangeset.cs

@@ -0,0 +1,26 @@
+using System;
+using StreamSource.Naming;
+
+namespace StreamSource
+{
+    public class StreamChangeset
+    {
+        public readonly StreamName Name;
+        public readonly int ExpectedVersion;
+        public readonly Guid CausationId;
+        public readonly Guid CorrelationId;
+        public readonly StreamChange[] Changes;
+
+        public StreamChangeset(StreamName name, int expectedVersion, Guid causationId, Guid correlationId, StreamChange[] changes)
+        {
+            if (name == null) throw new ArgumentNullException("name");
+            if (expectedVersion < 0) throw new ArgumentOutOfRangeException("expectedVersion", expectedVersion, "The expected version must be greater than or equal to 0.");
+            if (changes == null) throw new ArgumentNullException("changes");
+            Name = name;
+            ExpectedVersion = expectedVersion;
+            CausationId = causationId;
+            CorrelationId = correlationId;
+            Changes = changes;
+        }
+    }
+}

src/StreamSource/StreamSource.csproj

@@ -37,10 +37,22 @@
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="Serialization\IMessageDeserializer.cs" />
+    <Compile Include="Serialization\IMessageSerializer.cs" />
+    <Compile Include="Storage\IStreamStoreRecordWriter.cs" />
+    <Compile Include="IStreamStoreWriterSelector.cs" />
+    <Compile Include="Metadatum.cs" />
+    <Compile Include="Serialization\IMetadataDeserializer.cs" />
+    <Compile Include="Serialization\IMetadataSerializer.cs" />
+    <Compile Include="Serialization\MessageRecord.cs" />
+    <Compile Include="StreamChange.cs" />
+    <Compile Include="StreamChangeset.cs" />
+    <Compile Include="Storage\StreamRecord.cs" />
     <Compile Include="Naming\StreamName.cs" />
     <Compile Include="Naming\StreamNameComponent.cs" />
     <Compile Include="Naming\StreamNameFormat.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
+    <Compile Include="IStreamStoreWriter.cs" />
   </ItemGroup>
   <ItemGroup />
   <Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />