move refactor

Author: thefringeninja

src/SqlStreamStore.HAL.Tests/SqlStreamStore.HAL.Tests.csproj

@@ -24,6 +24,6 @@
     <PackageReference Include="xunit" Version="2.3.0-beta5-build3769" />
     <PackageReference Include="xunit.runner.visualstudio" Version="2.3.0-beta5-build3769" />
     <DotNetCliToolReference Include="dotnet-xunit" Version="2.3.0-beta5-build3769" />
-    <DotNetCliToolReference Include="Microsoft.DotNet.Watcher.Tools" Version="1.0.1" />
+    <DotNetCliToolReference Include="Microsoft.DotNet.Watcher.Tools" Version="2.0.0" />
   </ItemGroup>
 </Project>

src/SqlStreamStore.HAL/OptionalHeadRequestWrapper.cs

@@ -0,0 +1,55 @@
+namespace SqlStreamStore.HAL
+{
+    using System;
+    using System.IO;
+    using System.Threading;
+    using System.Threading.Tasks;
+    using Microsoft.Owin;
+
+    internal class OptionalHeadRequestWrapper : IDisposable
+    {
+        private readonly IOwinContext _context;
+        private readonly Stream _originalBody;
+
+        public OptionalHeadRequestWrapper(IOwinContext context)
+        {
+            _context = context;
+            _originalBody = _context.Response.Body;
+            if(context.Request.Method == "HEAD")
+            {
+                context.Response.Body = new HeadRequestStream();
+            }
+        }
+        
+        public void Dispose()
+        {
+            _context.Response.Body = _originalBody;
+        }
+
+        class HeadRequestStream : Stream
+        {
+            private long _length;
+
+            public override void Flush() => FlushAsync(CancellationToken.None).Wait();
+            public override int Read(byte[] buffer, int offset, int count) => throw new NotImplementedException();
+            public override long Seek(long offset, SeekOrigin origin) => throw new NotImplementedException();
+            public override void SetLength(long value) => throw new NotImplementedException();
+            public override void Write(byte[] buffer, int offset, int count) => throw new NotImplementedException();
+
+            public override Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
+            {
+                _length += count;
+                Position += count;
+                return Task.CompletedTask;
+            }
+
+            public override Task FlushAsync(CancellationToken cancellationToken) => Task.CompletedTask;
+
+            public override bool CanRead { get; } = false;
+            public override bool CanSeek { get; } = false;
+            public override bool CanWrite { get; } = true;
+            public override long Length => _length;
+            public override long Position { get; set; }
+        } 
+    }
+}

src/SqlStreamStore.HAL/OwinContextExtensions.cs

@@ -1,61 +1,12 @@
 namespace SqlStreamStore.HAL
 {
-    using System;
     using System.IO;
-    using System.Threading;
     using System.Threading.Tasks;
     using Microsoft.IO;
     using Microsoft.Owin;
     using Newtonsoft.Json;
     using Newtonsoft.Json.Serialization;
     using SqlStreamStore.Streams;
-    
-    internal class OptionalHeadRequestWrapper : IDisposable
-    {
-        private readonly IOwinContext _context;
-        private readonly Stream _originalBody;
-
-        public OptionalHeadRequestWrapper(IOwinContext context)
-        {
-            _context = context;
-            _originalBody = _context.Response.Body;
-            if(context.Request.Method == "HEAD")
-            {
-                context.Response.Body = new HeadRequestStream();
-            }
-        }
-        
-        public void Dispose()
-        {
-            _context.Response.Body = _originalBody;
-        }
-
-        class HeadRequestStream : Stream
-        {
-            private long _length;
-
-            public override void Flush() => FlushAsync(CancellationToken.None).Wait();
-            public override int Read(byte[] buffer, int offset, int count) => throw new NotImplementedException();
-            public override long Seek(long offset, SeekOrigin origin) => throw new NotImplementedException();
-            public override void SetLength(long value) => throw new NotImplementedException();
-            public override void Write(byte[] buffer, int offset, int count) => throw new NotImplementedException();
-
-            public override Task WriteAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
-            {
-                _length += count;
-                Position += count;
-                return Task.CompletedTask;
-            }
-
-            public override Task FlushAsync(CancellationToken cancellationToken) => Task.CompletedTask;
-
-            public override bool CanRead { get; } = false;
-            public override bool CanSeek { get; } = false;
-            public override bool CanWrite { get; } = true;
-            public override long Length => _length;
-            public override long Position { get; set; }
-        } 
-    }
 
     internal static class OwinContextExtensions
     {