JsonRpcContext->JsonRpcParameters

Author: xljiulang

WebApiClientCore.Extensions.JsonRpc/Attributes/JsonRpcMethodAttribute.cs

@@ -13,18 +13,18 @@ public class JsonRpcMethodAttribute : HttpPostAttribute, IApiFilterAttribute
         /// </summary>
         private readonly string? method;
 
-        /// <summary>
-        /// 获取或设置JsonRpc的参数风格
-        /// 默认为JsonRpcParamsStyle.Array
-        /// </summary>
-        public JsonRpcParamsStyle ParamsStyle { get; set; } = JsonRpcParamsStyle.Array;
-
         /// <summary>
         /// 获取或设置提交的Content-Type
         /// 默认为application/json-rpc 
         /// </summary>
         public string ContentType { get; set; } = JsonRpcContent.MediaType;
 
+        /// <summary>
+        /// 获取或设置JsonRpc的参数风格
+        /// 默认为JsonRpcParamsStyle.Array
+        /// </summary>
+        public JsonRpcParamsStyle ParamsStyle { get; set; } = JsonRpcParamsStyle.Array;
+
         /// <summary>
         /// 获取过滤器是否启用
         /// </summary>
@@ -65,14 +65,9 @@ public JsonRpcMethodAttribute(string? method, string? path)
         /// <returns></returns>
         public override Task OnRequestAsync(ApiRequestContext context)
         {
-            var jsonRpcContext = new JsonRpcContext
-            {
-                MediaType = this.ContentType,
-                Method = this.method ?? context.ApiAction.Name,
-                ParamsStyle = this.ParamsStyle
-            };
+            var parametrs = new JsonRpcParameters();
+            context.Properties.Set(typeof(JsonRpcParameters), parametrs);
 
-            context.Properties.Set(typeof(JsonRpcContext), jsonRpcContext);
             return base.OnRequestAsync(context);
         }
 
@@ -83,7 +78,20 @@ public override Task OnRequestAsync(ApiRequestContext context)
         /// <returns></returns>
         Task IApiFilterAttribute.OnRequestAsync(ApiRequestContext context)
         {
-            context.Properties.Get<JsonRpcContext>(typeof(JsonRpcContext)).SetHttpContent(context);
+            var jsonRpcContent = new JsonRpcContent(this.ContentType);
+            context.HttpContext.RequestMessage.Content = jsonRpcContent;
+
+            var parameters = context.Properties.Get<JsonRpcParameters>(typeof(JsonRpcParameters));
+            var jsonRpcRequest = new JsonRpcRequest
+            {
+                Method = this.method ?? context.ApiAction.Name,
+                Params = parameters.ToJsonRpcParams(this.ParamsStyle),
+            };
+
+            var options = context.HttpContext.HttpApiOptions.JsonSerializeOptions;
+            var jsonSerializer = context.HttpContext.ServiceProvider.GetJsonSerializer();
+            jsonSerializer.Serialize(jsonRpcContent, jsonRpcRequest, options);
+
             return Task.CompletedTask;
         }
 

WebApiClientCore.Extensions.JsonRpc/Attributes/JsonRpcParamAttribute.cs

@@ -16,13 +16,13 @@ public class JsonRpcParamAttribute : ApiParameterAttribute
         /// <returns></returns>
         public override Task OnRequestAsync(ApiParameterContext context)
         {
-            var jsonRpcContext = context.Properties.Get<JsonRpcContext>(typeof(JsonRpcContext));
-            if (jsonRpcContext == null)
+            var parameters = context.Properties.Get<JsonRpcParameters>(typeof(JsonRpcParameters));
+            if (parameters == null)
             {
                 throw new ApiInvalidConfigException($"请为接口方法{context.ApiAction.Name}修饰{nameof(JsonRpcMethodAttribute)}");
             }
 
-            jsonRpcContext.Parameters.Add(context);
+            parameters.Add(context);
             return Task.CompletedTask;
         }
     }

WebApiClientCore.Extensions.JsonRpc/Internals/JsonRpcContext.cs

@@ -0,0 +1,29 @@
+using System.Collections.Generic;
+using System.Linq;
+using WebApiClientCore.Attributes;
+
+namespace WebApiClientCore.Extensions.JsonRpc
+{
+    /// <summary>
+    /// 表示JsonRpc参数
+    /// </summary>
+    class JsonRpcParameters : List<ApiParameterContext>
+    {
+        /// <summary>
+        /// 转换为jsonRpc请求参数
+        /// </summary>
+        /// <param name="paramsStyle"></param>
+        /// <returns></returns>
+        public object ToJsonRpcParams(JsonRpcParamsStyle paramsStyle)
+        {
+            if (paramsStyle == JsonRpcParamsStyle.Array)
+            {
+                return this.Select(item => item.ParameterValue).ToArray();
+            }
+            else
+            {
+                return this.ToDictionary(item => item.Parameter.Name, item => item.ParameterValue);
+            }
+        } 
+    }
+}