OracleService

neo-modules.sln

@@ -24,6 +24,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Neo.Network.RPC.Tests", "te
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Neo.Plugins.Storage.Tests", "tests\Neo.Plugins.Storage.Tests\Neo.Plugins.Storage.Tests.csproj", "{9E7EA895-302A-4C0C-BA9B-54F9A67AD75C}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "OracleService", "src\Oracle\OracleService.csproj", "{9ABE9097-94AE-4B63-90DD-C20A0BC4D78E}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -66,6 +68,10 @@ Global
 		{9E7EA895-302A-4C0C-BA9B-54F9A67AD75C}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{9E7EA895-302A-4C0C-BA9B-54F9A67AD75C}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{9E7EA895-302A-4C0C-BA9B-54F9A67AD75C}.Release|Any CPU.Build.0 = Release|Any CPU
+		{9ABE9097-94AE-4B63-90DD-C20A0BC4D78E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{9ABE9097-94AE-4B63-90DD-C20A0BC4D78E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{9ABE9097-94AE-4B63-90DD-C20A0BC4D78E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{9ABE9097-94AE-4B63-90DD-C20A0BC4D78E}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -80,6 +86,7 @@ Global
 		{1403FFE9-4265-4269-8E3D-5A79EFD108CA} = {97E81C78-1637-481F-9485-DA1225E94C23}
 		{D52460B3-AB5C-4D07-B400-9E7ADCB01FF5} = {59D802AB-C552-422A-B9C3-64D329FBCDCC}
 		{9E7EA895-302A-4C0C-BA9B-54F9A67AD75C} = {59D802AB-C552-422A-B9C3-64D329FBCDCC}
+		{9ABE9097-94AE-4B63-90DD-C20A0BC4D78E} = {97E81C78-1637-481F-9485-DA1225E94C23}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {61D3ADE6-BBFC-402D-AB42-1C71C9F9EDE3}

src/Oracle/OracleService.csproj

@@ -0,0 +1,24 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <Version>3.0.0-preview2</Version>
+    <TargetFramework>netstandard2.1</TargetFramework>
+    <RootNamespace>Neo.Plugins</RootNamespace>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Neo.ConsoleService" Version="1.0.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <None Update="OracleService\config.json">
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+      <CopyToPublishDirectory>PreserveNewest</CopyToPublishDirectory>
+    </None>
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\RpcServer\RpcServer.csproj" />
+  </ItemGroup>
+
+</Project>

src/Oracle/OracleService/config.json

@@ -0,0 +1,9 @@
+{
+  "PluginConfiguration": {
+    "Nodes": [],
+    "Wallet": "",
+    "MaxTaskTimeout": 432000000,
+    "HttpTimeout": 5000,
+    "AllowPrivateHost":  false
+  }
+}

src/Oracle/Protocol/IOracleProtocol.cs

@@ -0,0 +1,7 @@
+namespace Neo.Plugins
+{
+    interface IOracleProtocol
+    {
+        string Request(string url);
+    }
+}

src/Oracle/Protocol/OracleHttpProtocol.cs

@@ -0,0 +1,78 @@
+using System;
+using System.Diagnostics;
+using System.IO;
+using System.Linq;
+using System.Net;
+using System.Net.Http;
+using System.Threading.Tasks;
+
+namespace Neo.Plugins
+{
+    public class OracleHttpProtocol : IOracleProtocol
+    {
+        public int Timeout { get; set; } = 5000;
+        public bool AllowPrivateHost { get; set; } = false;
+        public readonly string[] AllowedFormats = new string[] { "application/json" };
+
+        public string Request(string url)
+        {
+            Utility.Log(nameof(OracleHttpProtocol), LogLevel.Debug, $"Request: {url}");
+
+            if (!Uri.TryCreate(url, UriKind.Absolute, out var uri)) throw new InvalidOperationException("UrlError");
+            if (!AllowPrivateHost && IsInternal(Dns.GetHostEntry(uri.Host))) throw new InvalidOperationException("Access to private host is not allowed");
+
+            using var handler = new HttpClientHandler();
+            using var client = new HttpClient(handler);
+            client.DefaultRequestHeaders.Add("Accept", string.Join(",", AllowedFormats));
+
+            Task<HttpResponseMessage> result = client.GetAsync(uri);
+            Stopwatch sw = new Stopwatch();
+            sw.Start();
+            if (!result.Wait(Timeout)) throw new TimeoutException("Timeout");
+            if (result.Result.StatusCode == HttpStatusCode.NotFound) throw new FileNotFoundException($"{url} is not found");
+            if (!result.Result.IsSuccessStatusCode) throw new InvalidOperationException("Response error");
+            if (!AllowedFormats.Contains(result.Result.Content.Headers.ContentType.MediaType)) throw new InvalidOperationException("ContentType it's not allowed");
+            sw.Stop();
+            var taskRet = result.Result.Content.ReadAsStringAsync();
+            if (Timeout <= sw.ElapsedMilliseconds || !taskRet.Wait(Timeout - (int)sw.ElapsedMilliseconds)) throw new TimeoutException("Timeout");
+            return taskRet.Result;
+        }
+
+        internal static bool IsInternal(IPHostEntry entry)
+        {
+            foreach (var ip in entry.AddressList)
+                if (IsInternal(ip))
+                    return true;
+
+            return false;
+        }
+
+        /// <summary>
+        ///       ::1          -   IPv6  loopback
+        ///       10.0.0.0     -   10.255.255.255  (10/8 prefix)
+        ///       127.0.0.0    -   127.255.255.255  (127/8 prefix)
+        ///       172.16.0.0   -   172.31.255.255  (172.16/12 prefix)
+        ///       192.168.0.0  -   192.168.255.255 (192.168/16 prefix)
+        /// </summary>
+        /// <param name="ipAddress">Address</param>
+        /// <returns>True if it was an internal address</returns>
+        internal static bool IsInternal(IPAddress ipAddress)
+        {
+            if (IPAddress.IsLoopback(ipAddress)) return true;
+            if (IPAddress.Broadcast.Equals(ipAddress)) return true;
+            if (IPAddress.Any.Equals(ipAddress)) return true;
+            if (IPAddress.IPv6Any.Equals(ipAddress)) return true;
+            if (IPAddress.IPv6Loopback.Equals(ipAddress)) return true;
+
+            var ip = ipAddress.GetAddressBytes();
+            switch (ip[0])
+            {
+                case 10:
+                case 127: return true;
+                case 172: return ip[1] >= 16 && ip[1] < 32;
+                case 192: return ip[1] == 168;
+                default: return false;
+            }
+        }
+    }
+}

src/RpcServer/RpcServer.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
     <Version>3.0.0-preview3</Version>
@@ -15,7 +15,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.ResponseCompression" Version="2.2.0" />
-    <PackageReference Include="Neo" Version="3.0.0-CI01066" />
+    <PackageReference Include="Neo" Version="3.0.0-CI01077" />
   </ItemGroup>
 
 </Project>