レスポンス高速化 (#13)

* レスポンス高速化 #5 * fix
YDKK · Oct 24, 2020 · 0b07f92 · 0b07f92
1 parent a72e6dc
commit 0b07f92
Showing 1 changed file with 18 additions and 6 deletions.
diff --git a/SlackLineBridge/Controllers/WebhookController.cs b/SlackLineBridge/Controllers/WebhookController.cs
@@ -45,7 +45,7 @@ public WebhookController(
         }
 
         [HttpPost("/slack")]
-        public async Task<OkResult> Slack([FromForm]SlackData data)
+        public async Task<OkResult> Slack([FromForm] SlackData data)
         {
             if (data.user_name == "slackbot") return Ok();
 
@@ -123,7 +123,7 @@ public async Task<OkResult> Slack([FromForm]SlackData data)
         }
 
         [HttpPost("/line")]
-        public async Task<StatusCodeResult> Line()
+        public async Task<StatusCodeResult> LineAsync()
         {
             if (!Request.Headers.ContainsKey("X-Line-Signature"))
             {
@@ -132,11 +132,23 @@ public async Task<StatusCodeResult> Line()
                 return BadRequest();
             }
 
-            using var reader = new StreamReader(Request.Body);
-
-            _lineRequestQueue.Enqueue((Request.Headers["X-Line-Signature"], await reader.ReadToEndAsync(), Request.Host.ToString()));
+            string json = null;
+            string host = null;
+            try
+            {
+                using var reader = new StreamReader(Request.Body);
+                json = await reader.ReadToEndAsync();
+                host = Request.Host.ToString();
+                return Ok();
+            }
+            finally
+            {
+                Response.OnCompleted(async () =>
+                {
+                    _lineRequestQueue.Enqueue((Request.Headers["X-Line-Signature"], json, host));
+                });
+            }
 
-            return Ok();
         }
 
         [HttpGet("/health")]