Make webhooks process async (#17)

Marethyu1 · web-flow · commit c16bca8bf54f · 2021-11-23T19:23:02.000Z
diff --git a/Octokit.Webhooks.sln b/Octokit.Webhooks.sln
@@ -60,6 +60,10 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "workflows", "workflows", "{
 		.github\workflows\release-drafter.yml = .github\workflows\release-drafter.yml
 	EndProjectSection
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "AspNetCore", "samples\AspNetCore\AspNetCore.csproj", "{2EE1581B-E8B6-409E-8879-6F1EFC8C682B}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "samples", "samples", "{174C8B3B-E8D3-4845-AE7C-8C0DEC43354F}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -78,6 +82,10 @@ Global
 		{E46C1DB5-F21C-46A9-8D17-F08278BC0BF8}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{E46C1DB5-F21C-46A9-8D17-F08278BC0BF8}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{E46C1DB5-F21C-46A9-8D17-F08278BC0BF8}.Release|Any CPU.Build.0 = Release|Any CPU
+		{2EE1581B-E8B6-409E-8879-6F1EFC8C682B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2EE1581B-E8B6-409E-8879-6F1EFC8C682B}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2EE1581B-E8B6-409E-8879-6F1EFC8C682B}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2EE1581B-E8B6-409E-8879-6F1EFC8C682B}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -89,6 +97,7 @@ Global
 		{841C67EF-BBB2-4730-8E29-22FF3FD54306} = {EFE1E5ED-D337-4874-82EC-D9FA0BC7D3AB}
 		{E46C1DB5-F21C-46A9-8D17-F08278BC0BF8} = {719809C2-A551-4C4A-9EFD-B10FB5E35BC0}
 		{566DF0E2-1288-4083-9B55-4C8B69BB1432} = {EFE1E5ED-D337-4874-82EC-D9FA0BC7D3AB}
+		{2EE1581B-E8B6-409E-8879-6F1EFC8C682B} = {174C8B3B-E8D3-4845-AE7C-8C0DEC43354F}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {73F36209-F8D6-4066-8951-D97729F773CF}
diff --git a/samples/AspNetCore/MyWebhookEventProcessor.cs b/samples/AspNetCore/MyWebhookEventProcessor.cs
@@ -1,5 +1,6 @@
 ﻿namespace AspNetCore
 {
+    using System.Threading.Tasks;
     using Microsoft.Extensions.Logging;
     using Octokit.Webhooks;
     using Octokit.Webhooks.Events;
@@ -14,15 +15,17 @@ public MyWebhookEventProcessor(ILogger<MyWebhookEventProcessor> logger)
             this.logger = logger;
         }
 
-        protected override void ProcessPullRequestWebhook(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action)
+        protected override async Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action)
         {
             switch (action)
             {
                 case PullRequestActionValue.Opened:
                     this.logger.LogInformation("pull request opened");
+                    await Task.Delay(1000);
                     break;
                 default:
                     this.logger.LogInformation("Some other pull request event");
+                    await Task.Delay(1000);
                     break;
             }
         }
diff --git a/src/Octokit.Webhooks.AspNetCore/GitHubWebhookExtensions.cs b/src/Octokit.Webhooks.AspNetCore/GitHubWebhookExtensions.cs
@@ -36,7 +36,8 @@ public static void MapGitHubWebhooks(this IEndpointRouteBuilder endpoints, strin
                 try
                 {
                     var service = context.RequestServices.GetRequiredService<WebhookEventProcessor>();
-                    service.ProcessWebhook(context.Request.Headers, body);
+                    await service.ProcessWebhookAsync(context.Request.Headers, body)
+                        .ConfigureAwait(false);
                     context.Response.StatusCode = 200;
                 }
                 catch (Exception)
diff --git a/src/Octokit.Webhooks/WebhookEventProcessor.cs b/src/Octokit.Webhooks/WebhookEventProcessor.cs

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,6 @@`
`1`	`1`	`namespace AspNetCore`
`2`	`2`	`{`
	`3`	`+ using System.Threading.Tasks;`
`3`	`4`	`using Microsoft.Extensions.Logging;`
`4`	`5`	`using Octokit.Webhooks;`
`5`	`6`	`using Octokit.Webhooks.Events;`
`@@ -14,15 +15,17 @@ public MyWebhookEventProcessor(ILogger<MyWebhookEventProcessor> logger)`
`14`	`15`	`this.logger = logger;`
`15`	`16`	`}`
`16`	`17`
`17`		`- protected override void ProcessPullRequestWebhook(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action)`
	`18`	`+ protected override async Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action)`
`18`	`19`	`{`
`19`	`20`	`switch (action)`
`20`	`21`	`{`
`21`	`22`	`case PullRequestActionValue.Opened:`
`22`	`23`	`this.logger.LogInformation("pull request opened");`
	`24`	`+ await Task.Delay(1000);`
`23`	`25`	`break;`
`24`	`26`	`default:`
`25`	`27`	`this.logger.LogInformation("Some other pull request event");`
	`28`	`+ await Task.Delay(1000);`
`26`	`29`	`break;`
`27`	`30`	`}`
`28`	`31`	`}`
Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,8 @@ public static void MapGitHubWebhooks(this IEndpointRouteBuilder endpoints, strin`
`36`	`36`	`try`
`37`	`37`	`{`
`38`	`38`	`var service = context.RequestServices.GetRequiredService<WebhookEventProcessor>();`
`39`		`- service.ProcessWebhook(context.Request.Headers, body);`
	`39`	`+ await service.ProcessWebhookAsync(context.Request.Headers, body)`
	`40`	`+ .ConfigureAwait(false);`
`40`	`41`	`context.Response.StatusCode = 200;`
`41`	`42`	`}`
`42`	`43`	`catch (Exception)`