moving this ot of middleware and back to the resource

Author: thefringeninja

src/SqlStreamStore.HAL/Constants.cs

@@ -9,6 +9,7 @@ public static class Headers
         {
             public const string ExpectedVersion = "SSS-ExpectedVersion";
             public const string HeadPosition = "SSS-HeadPosition";
+            public const string Location = "Location";
 
             public static class ContentTypes
             {

src/SqlStreamStore.HAL/ReadStreamMiddleware.cs

@@ -3,7 +3,6 @@ namespace SqlStreamStore.HAL
     using Microsoft.Owin;
     using Microsoft.Owin.Builder;
     using Owin;
-    using SqlStreamStore.Streams;
     using MidFunc = System.Func<System.Func<System.Collections.Generic.IDictionary<string, object>,
             System.Threading.Tasks.Task
         >, System.Func<System.Collections.Generic.IDictionary<string, object>,
@@ -56,14 +55,6 @@ private static MidFunc GetStreamMessage(StreamResource stream) => next => async
 
             var response = await stream.GetMessage(options, context.Request.CallCancelled);
 
-            if(options.StreamVersion == StreamVersion.End)
-            {
-                context.Response.StatusCode = 307;
-                context.Response.Headers["Location"] = $"{((dynamic) response.Hal.Model).StreamVersion}";
-
-                return;
-            }
-
             using(new OptionalHeadRequestWrapper(context))
             {
                 await context.WriteHalResponse(response);

src/SqlStreamStore.HAL/StreamResource.cs

@@ -34,7 +34,7 @@ public async Task<Response> AppendMessages(
                     : 200);
             if(options.ExpectedVersion == ExpectedVersion.NoStream)
             {
-                response.Headers["Location"] = new[] { $"streams/{options.StreamId}" };
+                response.Headers[Constants.Headers.Location] = new[] { $"streams/{options.StreamId}" };
             }
             return response;
         }
@@ -60,6 +60,18 @@ public async Task<Response> GetMessage(
                         .AddLinks(StreamLinks.Feed(options)),
                     404);
             }
+            
+            if(options.StreamVersion == StreamVersion.End)
+            {
+                return new Response(new HALResponse(new object()), 307)
+                {
+                    Headers =
+                    {
+                        [Constants.Headers.Location] = new[] { $"{message.StreamVersion}" }
+                    }
+                };
+            }
+
 
             var payload = await message.GetJsonData(cancellationToken);