Implemented the File requester #11

Author: FlorianRappl

src/AngleSharp.Io.Tests/AngleSharp.Io.Tests.csproj

@@ -93,6 +93,7 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="Helper.cs" />
+    <Compile Include="Network\FileRequesterTests.cs" />
     <Compile Include="Network\FtpRequesterTests.cs" />
     <Compile Include="Network\HttpClientRequesterTests.cs" />
     <Compile Include="Network\Mocks\Request.cs" />
@@ -106,6 +107,9 @@
     <None Include="packages.config" />
   </ItemGroup>
   <ItemGroup>
+    <Content Include="TestContent.txt">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+    </Content>
   </ItemGroup>
   <Choose>
     <When Condition="'$(VisualStudioVersion)' == '10.0' And '$(IsCodedUITest)' == 'True'">

src/AngleSharp.Io.Tests/Network/FileRequesterTests.cs

@@ -0,0 +1,63 @@
+namespace AngleSharp.Io.Tests.Network
+{
+    using AngleSharp.Dom.Html;
+    using AngleSharp.Extensions;
+    using AngleSharp.Io.Network;
+    using AngleSharp.Network.Default;
+    using NUnit.Framework;
+    using System;
+    using System.IO;
+    using System.Reflection;
+    using System.Threading;
+    using System.Threading.Tasks;
+
+    [TestFixture]
+    public class FileRequesterTests
+    {
+        static String GetLocalPath()
+        {
+            var directory = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);
+            var path = Path.Combine(directory, "TestContent.txt");
+            var uri = new Uri(path);
+            return uri.AbsoluteUri;
+        }
+
+        [Test]
+        public async Task GetLocalFileViaFileRequester()
+        {
+            var url = GetLocalPath();
+            var requester = new FileRequester();
+            var request = new Request { Address = Url.Create(url) };
+
+            var response = await requester.RequestAsync(request, CancellationToken.None);
+            Assert.IsNotNull(response);
+
+            var content = await new StreamReader(response.Content).ReadToEndAsync();
+            Assert.AreEqual("Foo!", content);
+        }
+
+        [Test]
+        public async Task FollowLinkToUseFileRequesterUsingAllRequesters()
+        {
+            var url = GetLocalPath();
+            var config = Configuration.Default.WithRequesters();
+            var context = BrowsingContext.New(config);
+            var document = await context.OpenAsync(res => res.Content("<a href='" + url + "'>Download</a>"));
+            var result = await document.QuerySelector<IHtmlAnchorElement>("a").NavigateAsync();
+            var content = result.Body.TextContent;
+            Assert.AreEqual("Foo!", content);
+        }
+
+        [Test]
+        public async Task FollowLinkToUseFileRequesterUsingStandardRequesters()
+        {
+            var url = GetLocalPath();
+            var config = Configuration.Default.WithDefaultLoader();
+            var context = BrowsingContext.New(config);
+            var document = await context.OpenAsync(res => res.Content("<a href='" + url + "'>Download</a>"));
+            var result = await document.QuerySelector<IHtmlAnchorElement>("a").NavigateAsync();
+            var content = result.Body.TextContent;
+            Assert.AreEqual(0, content.Length);
+        }
+    }
+}

src/AngleSharp.Io.Tests/TestContent.txt

@@ -0,0 +1 @@
+Foo!

src/AngleSharp.Io/AngleSharp.Io.csproj

@@ -52,6 +52,7 @@
     <Compile Include="Extensions\GeneralExtensions.cs" />
     <Compile Include="Dom\WebSocket.cs" />
     <Compile Include="Interfaces\IStorage.cs" />
+    <Compile Include="Network\FileRequester.cs" />
     <Compile Include="Network\FtpRequester.cs" />
     <Compile Include="Network\HttpClientRequester.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />

src/AngleSharp.Io/ConfigurationExtensions.cs

@@ -20,7 +20,7 @@ public static class ConfigurationExtensions
         /// <returns>The new configuration.</returns>
         public static IConfiguration WithRequesters(this IConfiguration configuration, Action<LoaderService> setup = null)
         {
-            var requesters = new IRequester[] { new HttpClientRequester(), new DataRequester(), new FtpRequester() };
+            var requesters = new IRequester[] { new HttpClientRequester(), new DataRequester(), new FtpRequester(), new FileRequester() };
             return configuration.WithDefaultLoader(setup, requesters);
         }
 
@@ -36,7 +36,7 @@ public static IConfiguration WithRequesters(this IConfiguration configuration, A
         public static IConfiguration WithRequesters(this IConfiguration configuration, HttpMessageHandler httpMessageHandler, Action<LoaderService> setup = null)
         {
             var httpClient = new HttpClient(httpMessageHandler);
-            var requesters = new IRequester[] { new HttpClientRequester(httpClient), new DataRequester(), new FtpRequester() };
+            var requesters = new IRequester[] { new HttpClientRequester(httpClient), new DataRequester(), new FtpRequester(), new FileRequester() };
             return configuration.WithDefaultLoader(setup, requesters);
         }
     }

src/AngleSharp.Io/Network/FileRequester.cs

@@ -0,0 +1,37 @@
+namespace AngleSharp.Io.Network
+{
+    using AngleSharp.Network;
+    using AngleSharp.Network.Default;
+    using System;
+    using System.Net;
+    using System.Threading;
+    using System.Threading.Tasks;
+
+    public class FileRequester : IRequester
+    {
+        public async Task<IResponse> RequestAsync(IRequest request, CancellationToken cancel)
+        {
+            var requester = FileWebRequest.Create(request.Address.Href) as FileWebRequest;
+
+            if (requester != null)
+            {
+                var response = await requester.GetResponseAsync().ConfigureAwait(false);
+                var content = response.GetResponseStream();
+
+                return new Response
+                {
+                    Address = request.Address,
+                    Content = content,
+                    StatusCode = HttpStatusCode.OK
+                };
+            }
+
+            return default(IResponse);
+        }
+
+        public Boolean SupportsProtocol(String protocol)
+        {
+            return !String.IsNullOrEmpty(protocol) && protocol.Equals(ProtocolNames.File);
+        }
+    }
+}