How to use FetchRequestPausedResponse class of PuppeteerSharp.Messaging package

...110            {111                switch (e.MessageID)112                {113                    case "Fetch.requestPaused":114                        await OnRequestPausedAsync(e.MessageData.ToObject<FetchRequestPausedResponse>(true)).ConfigureAwait(false);115                        break;116                    case "Fetch.authRequired":117                        await OnAuthRequiredAsync(e.MessageData.ToObject<FetchAuthRequiredResponse>(true)).ConfigureAwait(false);118                        break;119                    case "Network.requestWillBeSent":120                        await OnRequestWillBeSentAsync(e.MessageData.ToObject<RequestWillBeSentPayload>(true)).ConfigureAwait(false);121                        break;122                    case "Network.requestServedFromCache":123                        OnRequestServedFromCache(e.MessageData.ToObject<RequestServedFromCacheResponse>(true));124                        break;125                    case "Network.responseReceived":126                        OnResponseReceived(e.MessageData.ToObject<ResponseReceivedResponse>(true));127                        break;128                    case "Network.loadingFinished":129                        OnLoadingFinished(e.MessageData.ToObject<LoadingFinishedResponse>(true));130                        break;131                    case "Network.loadingFailed":132                        OnLoadingFailed(e.MessageData.ToObject<LoadingFailedResponse>(true));133                        break;134                }135            }136            catch (Exception ex)137            {138                var message = $"NetworkManager failed to process {e.MessageID}. {ex.Message}. {ex.StackTrace}";139                _client.Close(message);140            }141        }142        private void OnLoadingFailed(LoadingFailedResponse e)143        {144            // For certain requestIds we never receive requestWillBeSent event.145            // @see https://crbug.com/750469146            if (_requestIdToRequest.TryGetValue(e.RequestId, out var request))147            {148                request.Failure = e.ErrorText;149                request.Response?.BodyLoadedTaskWrapper.TrySetResult(true);150                _requestIdToRequest.TryRemove(request.RequestId, out _);151                if (request.InterceptionId != null)152                {153                    _attemptedAuthentications.Remove(request.InterceptionId);154                }155                RequestFailed?.Invoke(this, new RequestEventArgs156                {157                    Request = request158                });159            }160        }161        private void OnLoadingFinished(LoadingFinishedResponse e)162        {163            // For certain requestIds we never receive requestWillBeSent event.164            // @see https://crbug.com/750469165            if (_requestIdToRequest.TryGetValue(e.RequestId, out var request))166            {167                request.Response?.BodyLoadedTaskWrapper.TrySetResult(true);168                _requestIdToRequest.TryRemove(request.RequestId, out _);169                if (request.InterceptionId != null)170                {171                    _attemptedAuthentications.Remove(request.InterceptionId);172                }173                RequestFinished?.Invoke(this, new RequestEventArgs174                {175                    Request = request176                });177            }178        }179        private void OnResponseReceived(ResponseReceivedResponse e)180        {181            // FileUpload sends a response without a matching request.182            if (_requestIdToRequest.TryGetValue(e.RequestId, out var request))183            {184                var response = new Response(185                    _client,186                    request,187                    e.Response);188                request.Response = response;189                Response?.Invoke(this, new ResponseCreatedEventArgs190                {191                    Response = response192                });193            }194        }195        private async Task OnAuthRequiredAsync(FetchAuthRequiredResponse e)196        {197            var response = "Default";198            if (_attemptedAuthentications.Contains(e.RequestId))199            {200                response = "CancelAuth";201            }202            else if (_credentials != null)203            {204                response = "ProvideCredentials";205                _attemptedAuthentications.Add(e.RequestId);206            }207            var credentials = _credentials ?? new Credentials();208            try209            {210                await _client.SendAsync("Fetch.continueWithAuth", new ContinueWithAuthRequest211                {212                    RequestId = e.RequestId,213                    AuthChallengeResponse = new ContinueWithAuthRequestChallengeResponse214                    {215                        Response = response,216                        Username = credentials.Username,217                        Password = credentials.Password218                    }219                }).ConfigureAwait(false);220            }221            catch { }222        }223        private async Task OnRequestPausedAsync(FetchRequestPausedResponse e)224        {225            if (!_userRequestInterceptionEnabled && _protocolRequestInterceptionEnabled)226            {227                try228                {229                    await _client.SendAsync("Fetch.continueRequest", new FetchContinueRequestRequest230                    {231                        RequestId = e.RequestId232                    }).ConfigureAwait(false);233                }234                catch { }235            }236            var requestId = e.NetworkId;237            var interceptionId = e.RequestId;...

...7{8    internal class NetworkEventManager9    {10        private readonly ConcurrentDictionary<string, RequestWillBeSentPayload> _requestWillBeSentMap = new();11        private readonly ConcurrentDictionary<string, FetchRequestPausedResponse> _requestPausedMap = new();12        private readonly ConcurrentDictionary<string, Request> _httpRequestsMap = new();13        private readonly ConcurrentDictionary<string, QueuedEventGroup> _queuedEventGroupMap = new();14        private readonly ConcurrentDictionary<string, List<RedirectInfo>> _queuedRedirectInfoMap = new();15        private readonly ConcurrentDictionary<string, List<ResponseReceivedExtraInfoResponse>> _responseReceivedExtraInfoMap = new();16        public int NumRequestsInProgress17            => _httpRequestsMap.Values.Count(r => r.Response == null);18        internal void Forget(string requestId)19        {20            _requestWillBeSentMap.TryRemove(requestId, out _);21            _requestPausedMap.TryRemove(requestId, out _);22            _queuedEventGroupMap.TryRemove(requestId, out _);23            _queuedRedirectInfoMap.TryRemove(requestId, out _);24            _responseReceivedExtraInfoMap.TryRemove(requestId, out _);25        }26        internal List<ResponseReceivedExtraInfoResponse> ResponseExtraInfo(string networkRequestId)27        {28            if (!_responseReceivedExtraInfoMap.ContainsKey(networkRequestId))29            {30                _responseReceivedExtraInfoMap.AddOrUpdate(31                    networkRequestId,32                    new List<ResponseReceivedExtraInfoResponse>(),33                    (_, __) => new List<ResponseReceivedExtraInfoResponse>());34            }35            _responseReceivedExtraInfoMap.TryGetValue(networkRequestId, out var result);36            return result;37        }38        private List<RedirectInfo> QueuedRedirectInfo(string fetchRequestId)39        {40            if (!_queuedRedirectInfoMap.ContainsKey(fetchRequestId))41            {42                _queuedRedirectInfoMap.TryAdd(fetchRequestId, new List<RedirectInfo>());43            }44            _queuedRedirectInfoMap.TryGetValue(fetchRequestId, out var result);45            return result;46        }47        internal void QueueRedirectInfo(string fetchRequestId, RedirectInfo redirectInfo)48            => QueuedRedirectInfo(fetchRequestId).Add(redirectInfo);49        internal RedirectInfo TakeQueuedRedirectInfo(string fetchRequestId)50        {51            var list = QueuedRedirectInfo(fetchRequestId);52            var result = list.FirstOrDefault();53            if (result != null)54            {55                list.Remove(result);56            }57            return result;58        }59        internal ResponseReceivedExtraInfoResponse ShiftResponseExtraInfo(string networkRequestId)60        {61            if (!_responseReceivedExtraInfoMap.ContainsKey(networkRequestId))62            {63                _responseReceivedExtraInfoMap.TryAdd(networkRequestId, new List<ResponseReceivedExtraInfoResponse>());64            }65            _responseReceivedExtraInfoMap.TryGetValue(networkRequestId, out var list);66            var result = list.FirstOrDefault();67            if (result != null)68            {69                list.Remove(result);70            }71            return result;72        }73        internal void StoreRequestWillBeSent(string networkRequestId, RequestWillBeSentPayload e)74            => _requestWillBeSentMap.AddOrUpdate(networkRequestId, e, (_, __) => e);75        internal RequestWillBeSentPayload GetRequestWillBeSent(string networkRequestId)76        {77            _requestWillBeSentMap.TryGetValue(networkRequestId, out var result);78            return result;79        }80        internal void ForgetRequestWillBeSent(string networkRequestId)81            => _requestWillBeSentMap.TryRemove(networkRequestId, out _);82        internal FetchRequestPausedResponse GetRequestPaused(string networkRequestId)83        {84            _requestPausedMap.TryGetValue(networkRequestId, out var result);85            return result;86        }87        internal void ForgetRequestPaused(string networkRequestId)88            => _requestPausedMap.TryRemove(networkRequestId, out _);89        internal void StoreRequestPaused(string networkRequestId, FetchRequestPausedResponse e)90            => _requestPausedMap.AddOrUpdate(networkRequestId, e, (_, __) => e);91        internal Request GetRequest(string networkRequestId)92        {93            _httpRequestsMap.TryGetValue(networkRequestId, out var result);94            return result;95        }96        internal void StoreRequest(string networkRequestId, Request request)97            => _httpRequestsMap.AddOrUpdate(networkRequestId, request, (_, __) => request);98        internal void ForgetRequest(string requestId)99            => _requestWillBeSentMap.TryRemove(requestId, out _);100        internal void QueuedEventGroup(string networkRequestId, QueuedEventGroup group)101            => _queuedEventGroupMap.AddOrUpdate(networkRequestId, group, (_, __) => group);102        internal QueuedEventGroup GetQueuedEventGroup(string networkRequestId)103        {...

1namespace PuppeteerSharp.Messaging2{3    internal class FetchRequestPausedResponse4    {5        public string RequestId { get; set; }6        public string NetworkId { get; set; }7    }...

1using System;2using System.Threading.Tasks;3using PuppeteerSharp;4using PuppeteerSharp.Messaging;5{6    static async Task Main(string[] args)7    {8        {9        };10        var browser = await Puppeteer.LaunchAsync(options);11        var page = await browser.NewPageAsync();12        await page.SetRequestInterceptionAsync(true);13        page.Request += async (sender, e) =>14        {15            Console.WriteLine(e.Request.Url);16            await e.Request.ContinueAsync();17        };18        await browser.CloseAsync();19    }20}21using System;22using System.Threading.Tasks;23using PuppeteerSharp;24{25    static async Task Main(string[] args)26    {27        {28        };29        var browser = await Puppeteer.LaunchAsync(options);30        var page = await browser.NewPageAsync();31        await page.SetRequestInterceptionAsync(true);32        page.Request += async (sender, e) =>33        {34            Console.WriteLine(e.Request.Url);35            await e.Request.ContinueAsync();36        };37        await browser.CloseAsync();38    }39}40   at PuppeteerSharp.Page.OnRequestAsync(Object sender, RequestEventArgs e) in C:\projects\puppeteer-sharp\lib\PuppeteerSharp\Page.cs:line 124741   at PuppeteerSharp.Page.OnRequestAsync(Object sender, RequestEventArgs e) in C:\projects\puppeteer-sharp\lib\PuppeteerSharp\Page.cs:line 1247

1using PuppeteerSharp.Messaging;2using System;3using System.Collections.Generic;4using System.Linq;5using System.Text;6using System.Threading.Tasks;7{8    {9        static void Main(string[] args)10        {11            var fetchRequestPausedResponse = new FetchRequestPausedResponse();12            fetchRequestPausedResponse.Request.Url = url;13            Console.WriteLine(fetchRequestPausedResponse.Request.Url);14            Console.ReadKey();15        }16    }17}

1using System;2using System.IO;3using System.Threading.Tasks;4using PuppeteerSharp;5using PuppeteerSharp.Messaging;6{7    {8        static async Task Main(string[] args)9        {10            {11            };12            using (var browser = await Puppeteer.LaunchAsync(options))13            {14                var page = await browser.NewPageAsync();15                await page.SetRequestInterceptionAsync(true);16                page.Request += async (sender, e) =>17                {18                    await e.Request.ContinueAsync();19                };20                page.Response += async (sender, e) =>21                {22                    var response = e.Response;23                    var request = response.Request;24                    var requestMethod = request.Method;25                    var requestUrl = request.Url;26                    var requestHeaders = request.Headers;27                    var requestPostData = request.PostData;28                    var responseStatus = response.Status;29                    var responseHeaders = response.Headers;30                    var responseMimeType = response.MimeType;31                    var responseRemoteAddress = response.RemoteAddress;32                    var responseRemotePort = response.RemotePort;33                    var responseFromDiskCache = response.FromDiskCache;34                    var responseFromServiceWorker = response.FromServiceWorker;35                    var responseSecurityDetails = response.SecurityDetails;36                    var responseContent = await response.TextAsync();37                    var responseRequest = response.Request;38                    Console.WriteLine("Request Method: " + requestMethod);39                    Console.WriteLine("Request Url: " + requestUrl);40                    Console.WriteLine("Request Headers: " + requestHeaders);41                    Console.WriteLine("Request Post Data: " + requestPostData);42                    Console.WriteLine("Response Status: " + responseStatus);43                    Console.WriteLine("Response Headers: " + responseHeaders);44                    Console.WriteLine("Response Mime Type: " + responseMimeType);45                    Console.WriteLine("Response Remote Address: " + responseRemoteAddress);46                    Console.WriteLine("Response Remote Port: " + responseRemotePort);47                    Console.WriteLine("Response From Disk Cache: " + responseFromDiskCache);48                    Console.WriteLine("Response From Service Worker: " + responseFromServiceWorker);49                    Console.WriteLine("Response Security Details: " + responseSecurityDetails);50                    Console.WriteLine("Response Content: " + responseContent);51                    Console.WriteLine("Response Request: " + responseRequest);52                };53                await page.WaitForNavigationAsync();54            }55        }56    }57}

1var response = await page.FetchRequestPausedResponse(request);2await response.ContinueAsync();3var response = await page.FetchRequestPausedResponse(request);4await response.ContinueAsync();5var response = await page.FetchRequestPausedResponse(request);6await response.ContinueAsync();7var response = await page.FetchRequestPausedResponse(request);8await response.ContinueAsync();9var response = await page.FetchRequestPausedResponse(request);10await response.ContinueAsync();11var response = await page.FetchRequestPausedResponse(request);12await response.ContinueAsync();13var response = await page.FetchRequestPausedResponse(request);14await response.ContinueAsync();15var response = await page.FetchRequestPausedResponse(request);16await response.ContinueAsync();17var response = await page.FetchRequestPausedResponse(request);18await response.ContinueAsync();19var response = await page.FetchRequestPausedResponse(request);20await response.ContinueAsync();21var response = await page.FetchRequestPausedResponse(request);22await response.ContinueAsync();23var response = await page.FetchRequestPausedResponse(request);24await response.ContinueAsync();25var response = await page.FetchRequestPausedResponse(request);26await response.ContinueAsync();27var response = await page.FetchRequestPausedResponse(request);28await response.ContinueAsync();