adding endpoint for specific streams

Author: Mathew McLoughlin

SqlStreamStore.HAL/App.config

@@ -13,6 +13,10 @@
         <assemblyIdentity name="Newtonsoft.Json" publicKeyToken="30ad4fe6b2a6aeed" culture="neutral" />
         <bindingRedirect oldVersion="0.0.0.0-9.0.0.0" newVersion="9.0.0.0" />
       </dependentAssembly>
+      <dependentAssembly>
+        <assemblyIdentity name="Sigil" publicKeyToken="2d06c3494341c8ab" culture="neutral" />
+        <bindingRedirect oldVersion="0.0.0.0-4.7.0.0" newVersion="4.7.0.0" />
+      </dependentAssembly>
     </assemblyBinding>
   </runtime>
 </configuration>

SqlStreamStore.HAL/HALResponse.cs

@@ -1,17 +1,17 @@
 using System.Linq;
-using Newtonsoft.Json;
+using Jil;
 using SqlStreamStore.Streams;
 
 namespace SqlStreamStore.HAL
 {
     class HalResponse
     {
-        [JsonProperty(PropertyName = "_links")]
+        [JilDirective(Name = "_links")]
         public Links Links { get; private set; }
 
         public int Count { get; private set; }
 
-        [JsonProperty(PropertyName = "_embedded")]
+        [JilDirective(Name = "_embedded")]
         public object Embedded { get; private set; }
 
         public static HalResponse GetPage(StreamMessage[] messages, int pageSize, string path, int direction)
@@ -33,25 +33,35 @@ public static HalResponse GetPage(StreamMessage[] messages, int pageSize, string
             return new HalResponse
             {
                 Links = links,
-                Embedded = new { Page = messages.Select(ToResponse).ToList() },
+                Embedded = new { Page = messages.Select(ToPageResponse).ToList() },
                 Count = messages.Length
             };
         }
 
-        public static object GetMessage(StreamMessage message)
+        public static object GetMessage(StreamMessage m)
         {
-            return ToResponse(message);
+            return new
+            {
+                _links = Links.CreateItemLink(m.Position),
+                m.Position,
+                m.CreatedUtc,
+                m.MessageId,
+                JsonData = JSON.DeserializeDynamic(m.JsonData),
+                m.JsonMetadata,
+                m.StreamVersion,
+                m.StreamId,
+                m.Type
+            };
         }
 
-        static object ToResponse(StreamMessage m)
+        static object ToPageResponse(StreamMessage m)
         {
             return new
             {
-                Links = Links.CreateItemLink(m.Position),
+                _links = Links.CreateItemLink(m.Position),
                 m.Position,
                 m.CreatedUtc,
                 m.MessageId,
-                JsonData = JsonConvert.DeserializeObject(m.JsonData),
                 m.JsonMetadata,
                 m.StreamVersion,
                 m.StreamId,
@@ -64,15 +74,14 @@ class Links
     {
         public object Self { get; private set; }
 
-        [JsonProperty(NullValueHandling = NullValueHandling.Ignore)]
         public object Next { get; private set; }
 
         public static Links CreatePaginationLinks(string path, long positionOfFirstEvent, long positionOfLastEvent, int numberOfEvents, int pageSize, int direction)
         {
             return new Links
             {
-                Self = new { Href = path + "?position=" + positionOfFirstEvent },
-                Next = numberOfEvents < pageSize ? null : new { Href = path + "?position=" + positionOfLastEvent + direction }
+                Self = new { Href = path + $"?position={positionOfFirstEvent}&direction={(direction == 1 ? "forwards" : "backwards")}" },
+                Next = numberOfEvents < pageSize ? null : new { Href = $"{path}?position={positionOfLastEvent + direction}&direction={(direction == 1 ? "forwards" : "backwards")}" }
             };
         }
 
@@ -84,4 +93,4 @@ public static Links CreateItemLink(long position)
             };
         }
     }
-}   
+}

SqlStreamStore.HAL/Program.cs

@@ -1,6 +1,7 @@
 using Microsoft.Owin.Hosting;
 using SqlStreamStore.Streams;
 using System;
+using System.Linq;
 
 namespace SqlStreamStore.HAL
 {
@@ -9,17 +10,18 @@ class Program
         static void Main()
         {
             var streamStore = new InMemoryStreamStore();
-            var messages = SeedData.Get(1000);
+            var messages = SeedData.Get(40);
 
-            streamStore.AppendToStream("SomeStream", ExpectedVersion.Any, messages);
+            streamStore.AppendToStream("SomeStream", ExpectedVersion.Any, messages).GetAwaiter().GetResult();
+            streamStore.AppendToStream("SomeOtherStream", ExpectedVersion.Any, messages).GetAwaiter().GetResult();
 
             var settings = new SqlStreamStoreHalSettings
             {
                 Store = streamStore,
-                PageSize = 20
+                PageSize = 100
             };
 
-            var baseUrl = "http://+:8080";
+            var baseUrl = "http://localhost:8080";
 
             using (WebApp.Start(baseUrl, app => app.UseSqlStreamStoreHal(settings)))
             {

SqlStreamStore.HAL/SqlStreamStore.HAL.csproj

@@ -33,6 +33,10 @@
     <WarningLevel>4</WarningLevel>
   </PropertyGroup>
   <ItemGroup>
+    <Reference Include="Jil, Version=2.14.5.0, Culture=neutral, processorArchitecture=MSIL">
+      <HintPath>..\packages\Jil.2.14.5\lib\net45\Jil.dll</HintPath>
+      <Private>True</Private>
+    </Reference>
     <Reference Include="Microsoft.Owin, Version=3.0.1.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35, processorArchitecture=MSIL">
       <HintPath>..\packages\Microsoft.Owin.3.0.1\lib\net45\Microsoft.Owin.dll</HintPath>
       <Private>True</Private>
@@ -72,6 +76,7 @@
     <Reference Include="System" />
     <Reference Include="System.Core" />
     <Reference Include="Microsoft.CSharp" />
+    <Reference Include="System.Runtime.Serialization" />
   </ItemGroup>
   <ItemGroup>
     <Compile Include="HALResponse.cs" />

SqlStreamStore.HAL/SqlStreamStoreHalMiddleware.cs

@@ -1,15 +1,18 @@
 using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Threading.Tasks;
+using Jil;
 using Microsoft.Owin.Builder;
 using Nancy;
 using Nancy.Bootstrapper;
+using Nancy.IO;
 using Nancy.TinyIoc;
 using Owin;
 
 namespace SqlStreamStore.HAL
 {
-    internal static class SqlStreamStoreHalMiddleware
+    public static class SqlStreamStoreHalMiddleware
     {
         public static void UseSqlStreamStoreHal(this IAppBuilder app, SqlStreamStoreHalSettings settings)
         {
@@ -48,10 +51,33 @@ public Bootstrapper(SqlStreamStoreHalSettings settings)
         protected override void ApplicationStartup(TinyIoCContainer container, IPipelines pipelines)
         {
             container.Register(_settings);
+            container.Register<ISerializer, JilSerializer>();
             base.ApplicationStartup(container, pipelines);
         }
     }
-    
+
+    public class JilSerializer : ISerializer
+    {
+        private static readonly Options Options = new Options(
+            excludeNulls: true,
+            serializationNameFormat: SerializationNameFormat.CamelCase);
+
+        public bool CanSerialize(string contentType)
+        {
+            return true;
+        }
+
+        public void Serialize<TModel>(string contentType, TModel model, Stream outputStream)
+        {
+            using (var output = new StreamWriter(new UnclosableStreamWrapper(outputStream)))
+            {
+                JSON.SerializeDynamic(model, output, Options);
+            }
+        }
+
+        public IEnumerable<string> Extensions => new List<string> { "json" };
+    }
+
     public class SqlStreamStoreHalSettings
     {
         public IReadonlyStreamStore Store { get; set; }

SqlStreamStore.HAL/SqlStreamStoreHalModule.cs

@@ -1,5 +1,4 @@
-using System;
-using System.Collections.Generic;
+using System.Collections.Generic;
 using System.Threading.Tasks;
 using Nancy;
 using SqlStreamStore.Streams;
@@ -8,7 +7,7 @@ namespace SqlStreamStore.HAL
 {
     public class SqlStreamStoreHalModule : NancyModule
     {
-        readonly Dictionary<string, int> _directionLookup = new Dictionary<string, int>
+        private readonly Dictionary<string, int> _directionLookup = new Dictionary<string, int>
         {
             { "forwards", Direction.Forwards },
             { "backwards", Direction.Backwards }
@@ -25,46 +24,63 @@ public SqlStreamStoreHalModule(SqlStreamStoreHalSettings settings)
                 var readAllPage = await GetReadAllPage(settings.Store, settings.PageSize, position, direction);
                 return Response.AsJson(HalResponse.GetPage(readAllPage.Messages, settings.PageSize, Request.Path, direction));
             };
+            
+            Get["stream/{position}", true] = async (args, ct) =>
+            {
+                var message = await settings.Store.ReadAllForwards(args.Position, 1);
+                var model = HalResponse.GetMessage(message.Messages[0]);
+                return FormatterExtensions.AsJson(Response, model);
+            };
 
-            Get["stream/{position}", true] = async (arg, ct) =>
+            Get["streams/{streamId}", true] = async (args, ct) =>
             {
-                var message = await settings.Store.ReadAllForwards(arg.Position, 1);
-                return FormatterExtensions.AsJson(Response, HalResponse.GetMessage(message.Messages[0]));
+                var direction = GetDirection();
+                var position = GetPosition();
+
+                ReadStreamPage readAllPage = await GetReadStreamPage(args.StreamId, settings.Store, settings.PageSize, (int?)position, direction);
+                return Response.AsJson(HalResponse.GetPage(readAllPage.Messages, settings.PageSize, Request.Path, direction));
             };
         }
 
-        private long GetPosition()
+        private long? GetPosition()
         {
-            long position;
+            string position = Request.Query.Position;
+
+            if (position == null)
+            {
+                return null;
+            }
 
-            if (!long.TryParse((string)Request.Query.Position ?? "0", out position))
+            long longPosition;
+            if (!long.TryParse(position, out longPosition))
             {
-                throw new Exception("position must be a long");
+                return null;
             }
 
-            return position;
+            return longPosition;
         }
 
         private int GetDirection()
         {
-            string direction = Request.Query.Direction;
-
-            if (!_directionLookup.ContainsKey(direction))
-            {
-                throw new Exception("direction parameter must be {forwards} or {backwards}");
-            }
-
-            return _directionLookup[direction];
+            var direction = (string)Request.Query.Direction ?? "forwards";
+            return !_directionLookup.ContainsKey(direction) ? Direction.Forwards : _directionLookup[direction];
         }
 
-        private Task<ReadAllPage> GetReadAllPage(IReadonlyStreamStore store, int pageSize, long? position, int direction)
+        private static Task<ReadAllPage> GetReadAllPage(IReadonlyStreamStore store, int pageSize, long? position, int direction)
         {
             return direction == Direction.Forwards ?
                 store.ReadAllForwards(position ?? Position.Start, pageSize) :
                 store.ReadAllBackwards(position ?? Position.End, pageSize);
         }
 
-        static class Direction
+        private static Task<ReadStreamPage> GetReadStreamPage(string streamId, IReadonlyStreamStore store, int pageSize, int? position, int direction)
+        {
+            return direction == Direction.Forwards ?
+                store.ReadStreamForwards(streamId, position ?? (int)Position.Start, pageSize) :
+                store.ReadStreamBackwards(streamId, position ?? (int)Position.End, pageSize);
+        }
+
+        private static class Direction
         {
             public static int Forwards => 1;
             public static int Backwards => -1;

SqlStreamStore.HAL/packages.config

@@ -1,5 +1,6 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
+  <package id="Jil" version="2.14.5" targetFramework="net46" />
   <package id="Microsoft.Owin" version="3.0.1" targetFramework="net46" />
   <package id="Microsoft.Owin.Host.HttpListener" version="3.0.1" targetFramework="net46" />
   <package id="Microsoft.Owin.Hosting" version="3.0.1" targetFramework="net46" />