chore: Add cancellationToken to all methods (#708)

Author: sommmen

README.md

@@ -56,7 +56,7 @@ Libraries to handle GitHub Webhooks in .NET applications.
     ```C#
     public sealed class MyWebhookEventProcessor : WebhookEventProcessor
     {
-        protected override Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action) 
+        protected override Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action, CancellationToken cancellationToken = default) 
         {
             ...
         }

samples/AspNetCore/MyWebhookEventProcessor.cs

@@ -1,5 +1,6 @@
-namespace AspNetCore;
+namespace AspNetCore;
 
+using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using Octokit.Webhooks;
@@ -8,17 +9,17 @@
 
 public class MyWebhookEventProcessor(ILogger<MyWebhookEventProcessor> logger) : WebhookEventProcessor
 {
-    protected override async Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action)
+    protected override async Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action, CancellationToken cancellationToken = default)
     {
         switch (action)
         {
             case PullRequestActionValue.Opened:
                 logger.LogInformation("pull request opened");
-                await Task.Delay(1000);
+                await Task.Delay(1000, cancellationToken);
                 break;
             default:
                 logger.LogInformation("Some other pull request event");
-                await Task.Delay(1000);
+                await Task.Delay(1000, cancellationToken);
                 break;
         }
     }

samples/AzureFunctions/MyWebhookEventProcessor.cs

@@ -1,5 +1,6 @@
 namespace AzureFunctions;
 
+using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using Octokit.Webhooks;
@@ -8,17 +9,17 @@ namespace AzureFunctions;
 
 public class MyWebhookEventProcessor(ILogger<MyWebhookEventProcessor> logger) : WebhookEventProcessor
 {
-    protected override async Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action)
+    protected override async Task ProcessPullRequestWebhookAsync(WebhookHeaders headers, PullRequestEvent pullRequestEvent, PullRequestAction action, CancellationToken cancellationToken = default)
     {
         switch (action)
         {
             case PullRequestActionValue.Opened:
                 logger.LogInformation("pull request opened");
-                await Task.Delay(1000);
+                await Task.Delay(1000, cancellationToken);
                 break;
             default:
                 logger.LogInformation("Some other pull request event");
-                await Task.Delay(1000);
+                await Task.Delay(1000, cancellationToken);
                 break;
         }
     }

src/Octokit.Webhooks.AspNetCore/GitHubWebhookExtensions.cs

@@ -1,11 +1,12 @@
-namespace Octokit.Webhooks.AspNetCore;
+namespace Octokit.Webhooks.AspNetCore;
 
 using System;
 using System.Globalization;
 using System.IO;
 using System.Net.Mime;
 using System.Security.Cryptography;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Http;
@@ -23,7 +24,8 @@ public static partial class GitHubWebhookExtensions
     public static IEndpointConventionBuilder MapGitHubWebhooks(
         this IEndpointRouteBuilder endpoints,
         string path = "/api/github/webhooks",
-        string? secret = null)
+        string? secret = null,
+        bool cancelOnRequestAborted = false)
     {
         var options = endpoints.ServiceProvider.GetService<IOptionsMonitor<GitHubWebhookOptions>>();
         return endpoints.MapPost(
@@ -58,7 +60,7 @@ public static IEndpointConventionBuilder MapGitHubWebhooks(
                 try
                 {
                     var service = context.RequestServices.GetRequiredService<WebhookEventProcessor>();
-                    await service.ProcessWebhookAsync(context.Request.Headers, body)
+                    await service.ProcessWebhookAsync(context.Request.Headers, body, cancelOnRequestAborted ? context.RequestAborted : CancellationToken.None)
                         .ConfigureAwait(false);
                     context.Response.StatusCode = 200;
                 }