Merge pull request #1 from abpframework/master

pull latest from source

docs/en/AspNetCore/Tag-Helpers.md

@@ -1,3 +0,0 @@
-# Tag Helpers
-
-TODO

docs/en/AspNetCore/Tag-Helpers/Dynamic-Forms.md

@@ -0,0 +1,3 @@
+## Dynamic Forms
+
+This is not documented yet. You can see a [demo](http://bootstrap-taghelpers.abp.io/Components/DynamicForms) for now.

docs/en/Aspect-Oriented-Programming.md

@@ -0,0 +1,3 @@
+## Dynamic Proxying / Interceptors
+
+TODO

docs/en/Caching.md

@@ -0,0 +1,3 @@
+# Caching
+
+TODO

docs/en/CorrelationId.md

@@ -0,0 +1,3 @@
+# Correlation ID
+
+TODO

docs/en/Data-Filtering.md

@@ -0,0 +1,3 @@
+# Data Filtering
+
+TODO

docs/en/Specifications.md

@@ -0,0 +1,3 @@
+# Specifications
+
+TODO!

docs/en/docs-nav.json

@@ -218,7 +218,7 @@
             },
             {
               "text": "Tag Helpers",
-              "path": "Tag-Helpers.md"
+              "path": "AspNetCore/Tag-Helpers/Index.md"
             },
             {
               "text": "Theming",

framework/src/Volo.Abp.AspNetCore.TestBase/Volo/Abp/AspNetCore/TestBase/DynamicProxying/AspNetCoreTestDynamicProxyHttpClientFactory.cs

@@ -8,15 +8,20 @@ namespace Volo.Abp.AspNetCore.TestBase.DynamicProxying
     public class AspNetCoreTestDynamicProxyHttpClientFactory : IDynamicProxyHttpClientFactory, ITransientDependency
     {
         private readonly ITestServerAccessor _testServerAccessor;
+        private readonly IHttpClientFactory _httpClientFactory;
 
-        public AspNetCoreTestDynamicProxyHttpClientFactory(ITestServerAccessor testServerAccessor)
+        public AspNetCoreTestDynamicProxyHttpClientFactory(ITestServerAccessor testServerAccessor, IHttpClientFactory httpClientFactory) {
-        {
             _testServerAccessor = testServerAccessor;
+            _httpClientFactory = httpClientFactory;
         }
 
         public HttpClient Create()
         {
             return _testServerAccessor.Server.CreateClient();
         }
+
+        public HttpClient Create(string name) {
+            return Create();
+        }
     }
 }

framework/src/Volo.Abp.Http.Client.IdentityModel/Volo/Abp/Http/Client/IdentityModel/IdentityModelRemoteServiceHttpClientAuthenticator.cs

@@ -28,7 +28,7 @@ namespace Volo.Abp.Http.Client.IdentityModel
                 var accessToken = await GetAccessTokenFromHttpContextOrNullAsync();
                 if (accessToken != null)
                 {
-                    context.Client.SetBearerToken(accessToken);
+                    context.Request.SetBearerToken(accessToken);
                     return;
                 }
             }

framework/src/Volo.Abp.Http.Client/Microsoft/Extensions/DependencyInjection/ServiceCollectionDynamicHttpClientProxyExtensions.cs

@@ -3,6 +3,7 @@ using System.Linq;
 using System.Reflection;
 using Castle.DynamicProxy;
 using JetBrains.Annotations;
+using Polly;
 using Volo.Abp;
 using Volo.Abp.Castle.DynamicProxy;
 using Volo.Abp.Http.Client;
@@ -105,6 +106,12 @@ namespace Microsoft.Extensions.DependencyInjection
             {
                 options.HttpClientProxies[type] = new DynamicHttpClientProxyConfig(type, remoteServiceConfigurationName);
             });
+            
+            //use IHttpClientFactory and polly
+            services.AddHttpClient(remoteServiceConfigurationName)
+                .AddTransientHttpErrorPolicy(builder =>
+                    // retry 3 times
+                    builder.WaitAndRetryAsync(3, i => TimeSpan.FromSeconds(Math.Pow(2, i))));
 
             var interceptorType = typeof(DynamicHttpProxyInterceptor<>).MakeGenericType(type);
             services.AddTransient(interceptorType);

framework/src/Volo.Abp.Http.Client/Volo.Abp.Http.Client.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <Import Project="..\..\..\common.props" />
 
@@ -15,6 +15,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.Authentication.Abstractions" Version="2.2.0" />
+    <PackageReference Include="Microsoft.Extensions.Http.Polly" Version="2.2.0" />
   </ItemGroup>
 
   <ItemGroup>

framework/src/Volo.Abp.Http.Client/Volo/Abp/Http/Client/DynamicProxying/DefaultDynamicProxyHttpClientFactory.cs

@@ -1,13 +1,25 @@
 using System.Net.Http;
 using Volo.Abp.DependencyInjection;
 
-namespace Volo.Abp.Http.Client.DynamicProxying
+namespace Volo.Abp.Http.Client.DynamicProxying 
 {
-    public class DefaultDynamicProxyHttpClientFactory : IDynamicProxyHttpClientFactory, ITransientDependency
+    public class DefaultDynamicProxyHttpClientFactory : IDynamicProxyHttpClientFactory, ITransientDependency 
     {
-        public HttpClient Create()
+        private readonly IHttpClientFactory _httpClientFactory;
+
+        public DefaultDynamicProxyHttpClientFactory(IHttpClientFactory httpClientFactory) 
+        {
+            _httpClientFactory = httpClientFactory;
+        }
+
+        public HttpClient Create() 
+        {
+            return _httpClientFactory.CreateClient();
+        }
+
+        public HttpClient Create(string name) 
         {
-            return new HttpClient();
+            return _httpClientFactory.CreateClient(name);
         }
     }
 }

framework/src/Volo.Abp.Http.Client/Volo/Abp/Http/Client/DynamicProxying/DynamicHttpProxyInterceptor.cs

@@ -128,41 +128,41 @@ namespace Volo.Abp.Http.Client.DynamicProxying
 
         private async Task<string> MakeRequestAsync(IAbpMethodInvocation invocation)
         {
-            using (var client = HttpClientFactory.Create())
+            var clientConfig = ClientOptions.HttpClientProxies.GetOrDefault(typeof(TService)) ?? throw new AbpException($"Could not get DynamicHttpClientProxyConfig for {typeof(TService).FullName}.");
-            {
+            var remoteServiceConfig = RemoteServiceOptions.RemoteServices.GetConfigurationOrDefault(clientConfig.RemoteServiceName);
-                var clientConfig = ClientOptions.HttpClientProxies.GetOrDefault(typeof(TService)) ?? throw new AbpException($"Could not get DynamicHttpClientProxyConfig for {typeof(TService).FullName}.");
-                var remoteServiceConfig = RemoteServiceOptions.RemoteServices.GetConfigurationOrDefault(clientConfig.RemoteServiceName);
 
-                var action = await ApiDescriptionFinder.FindActionAsync(remoteServiceConfig.BaseUrl, typeof(TService), invocation.Method);
+            var client = HttpClientFactory.Create(clientConfig.RemoteServiceName);
-                var apiVersion = GetApiVersionInfo(action);
-                var url = remoteServiceConfig.BaseUrl + UrlBuilder.GenerateUrlWithParameters(action, invocation.ArgumentsDictionary, apiVersion);
 
-                var requestMessage = new HttpRequestMessage(action.GetHttpMethod(), url)
+            var action = await ApiDescriptionFinder.FindActionAsync(remoteServiceConfig.BaseUrl, typeof(TService), invocation.Method);
-                {
+            var apiVersion = GetApiVersionInfo(action);
-                    Content = RequestPayloadBuilder.BuildContent(action, invocation.ArgumentsDictionary, JsonSerializer, apiVersion)
+            var url = remoteServiceConfig.BaseUrl + UrlBuilder.GenerateUrlWithParameters(action, invocation.ArgumentsDictionary, apiVersion);
-                };
-
-                AddHeaders(invocation, action, requestMessage, apiVersion);
-
-                await ClientAuthenticator.Authenticate(
-                    new RemoteServiceHttpClientAuthenticateContext(
-                        client,
-                        requestMessage,
-                        remoteServiceConfig,
-                        clientConfig.RemoteServiceName
-                    )
-                );
 
-                var response = await client.SendAsync(requestMessage, GetCancellationToken());
+            var requestMessage = new HttpRequestMessage(action.GetHttpMethod(), url)
+            {
+                Content = RequestPayloadBuilder.BuildContent(action, invocation.ArgumentsDictionary, JsonSerializer, apiVersion)
+            };
 
-                if (!response.IsSuccessStatusCode)
+            AddHeaders(invocation, action, requestMessage, apiVersion);
-                {
-                    await ThrowExceptionForResponseAsync(response);
-                }
 
-                return await response.Content.ReadAsStringAsync();
+            await ClientAuthenticator.Authenticate(
+                new RemoteServiceHttpClientAuthenticateContext(
+                    client,
+                    requestMessage,
+                    remoteServiceConfig,
+                    clientConfig.RemoteServiceName
+                )
+            );
+
+            var response = await client.SendAsync(requestMessage, GetCancellationToken());
+
+            if (!response.IsSuccessStatusCode)
+            {
+                await ThrowExceptionForResponseAsync(response);
             }
-        }
+
+            return await response.Content.ReadAsStringAsync();
+        } 
+        
 
         private ApiVersionInfo GetApiVersionInfo(ActionApiDescriptionModel action)
         {

framework/src/Volo.Abp.Http.Client/Volo/Abp/Http/Client/DynamicProxying/IDynamicProxyHttpClientFactory.cs

@@ -5,5 +5,7 @@ namespace Volo.Abp.Http.Client.DynamicProxying
     public interface IDynamicProxyHttpClientFactory
     {
         HttpClient Create();
+
+        HttpClient Create(string name);
     }
 }

samples/BookStore/src/Acme.BookStore.Web/Acme.BookStore.Web.csproj

@@ -4,6 +4,7 @@
 
   <PropertyGroup>
     <TargetFramework>netcoreapp2.2</TargetFramework>
+    <AspNetCoreHostingModel>InProcess</AspNetCoreHostingModel>
     <AssetTargetFallback>$(AssetTargetFallback);portable-net45+win8+wp8+wpa81;</AssetTargetFallback>
     <AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
     <GenerateBindingRedirectsOutputType>true</GenerateBindingRedirectsOutputType>

samples/BookStore/src/Acme.BookStore.Web/Program.cs

@@ -43,6 +43,7 @@ namespace Acme.BookStore.Web
                 .UseKestrel()
                 .UseContentRoot(Directory.GetCurrentDirectory())
                 .UseIISIntegration()
+                .UseIIS()
                 .UseStartup<Startup>()
                 .UseSerilog()
                 .Build();

samples/MicroserviceDemo/modules/product/src/ProductManagement.Application/ProductManagement/ProductManagementApplicationAutoMapperProfile.cs

@@ -6,7 +6,7 @@ namespace ProductManagement
     {
         public ProductManagementApplicationAutoMapperProfile()
         {
-            
+            CreateMap<Product, ProductDto>();
         }
     }
 }