How to use ConnectionResponse class of PuppeteerSharp.Messaging package

...151        {152            try153            {154                var response = e.Message;155                ConnectionResponse obj = null;156                if (response.Length > 0 && Delay > 0)157                {158                    await Task.Delay(Delay).ConfigureAwait(false);159                }160                try161                {162                    obj = JsonConvert.DeserializeObject<ConnectionResponse>(response, JsonHelper.DefaultJsonSerializerSettings);163                }164                catch (JsonException)165                {166                    return;167                }168                ProcessIncomingMessage(obj);169            }170            catch (Exception ex)171            {172                var message = $"Connection failed to process {e.Message}. {ex.Message}. {ex.StackTrace}";173                Close(message);174            }175        }176        private void ProcessIncomingMessage(ConnectionResponse obj)177        {178            var method = obj.Method;179            var param = obj.Params?.ToObject<ConnectionResponseParams>();180            if (method == "Target.attachedToTarget")181            {182                var sessionId = param.SessionId;183                var session = new CDPSession(this, param.TargetInfo.Type, sessionId);184                _asyncSessions.AddItem(sessionId, session);185            }186            else if (method == "Target.detachedFromTarget")187            {188                var sessionId = param.SessionId;189                if (_sessions.TryRemove(sessionId, out var session) && !session.IsClosed)190                {191                    session.Close("Target.detachedFromTarget");192                }193            }...

...160        }161        internal bool HasPendingCallbacks() => _callbacks.Count != 0;162        #endregion163        #region Private Methods164        internal void OnMessage(ConnectionResponse obj)165        {166            var id = obj.Id;167            if (id.HasValue && _callbacks.TryRemove(id.Value, out var callback))168            {169                if (obj.Error != null)170                {171                    callback.TaskWrapper.TrySetException(new MessageException(callback, obj.Error));172                }173                else174                {175                    callback.TaskWrapper.TrySetResult(obj.Result);176                }177            }178            else179            {180                var method = obj.Method;181                var param = obj.Params?.ToObject<ConnectionResponseParams>();182                MessageReceived?.Invoke(this, new MessageEventArgs183                {184                    MessageID = method,185                    MessageData = obj.Params186                });187            }188        }189        internal void Close(string closeReason)190        {191            if (IsClosed)192            {193                return;194            }195            CloseReason = closeReason;...

...22            _enqueueAsyncMessages = enqueueAsyncMessages;23            _logger = logger ?? NullLogger.Instance;24            _pendingTasks = new List<MessageTask>();25        }26        public void Enqueue(MessageTask callback, ConnectionResponse obj)27        {28            if (_disposed)29            {30                throw new ObjectDisposedException(GetType().FullName);31            }32            if (!_enqueueAsyncMessages)33            {34                HandleAsyncMessage(callback, obj);35                return;36            }37            // Keep a ref to this task until it completes. If it can't finish by the time we dispose this queue,38            // then we'll find it and cancel it.39            lock (_pendingTasks)40            {41                _pendingTasks.Add(callback);42            }43            var task = Task.Run(() => HandleAsyncMessage(callback, obj));44            // Unhandled error handler45            task.ContinueWith(46                t =>47                {48                    _logger.LogError(t.Exception, "Failed to complete async handling of SendAsync for {callback}", callback.Method);49                    callback.TaskWrapper.TrySetException(t.Exception!); // t.Exception is available since this runs only on faulted50                },51                CancellationToken.None,52                TaskContinuationOptions.OnlyOnFaulted,53                TaskScheduler.Default);54            // Always remove from the queue when done, regardless of outcome.55            task.ContinueWith(56                _ =>57                {58                    lock (_pendingTasks)59                    {60                        _pendingTasks.Remove(callback);61                    }62                },63                TaskScheduler.Default);64        }65        public void Dispose()66        {67            if (_disposed)68            {69                return;70            }71            // Ensure all tasks are finished since we're disposing now. Any pending tasks will be canceled.72            MessageTask[] pendingTasks;73            lock (_pendingTasks)74            {75                pendingTasks = _pendingTasks.ToArray();76                _pendingTasks.Clear();77            }78            foreach (var pendingTask in pendingTasks)79            {80                pendingTask.TaskWrapper.TrySetCanceled();81            }82            _disposed = true;83        }84        private static void HandleAsyncMessage(MessageTask callback, ConnectionResponse obj)85        {86            if (obj.Error != null)87            {88                callback.TaskWrapper.TrySetException(new MessageException(callback, obj.Error));89            }90            else91            {92                callback.TaskWrapper.TrySetResult(obj.Result);93            }94        }95    }96}...

1using Newtonsoft.Json.Linq;2namespace PuppeteerSharp.Messaging3{4    internal class ConnectionResponse5    {6        public int? Id { get; set; }7        public ConnectionError Error { get; set; }8        public JObject Result { get; set; }9        public string Method { get; set; }10        public JToken Params { get; set; }11        public string SessionId { get; set; }12    }13}...

1using PuppeteerSharp.Messaging;2using PuppeteerSharp;3using System.Net.Http;4using System.Net.Http.Headers;5using System.Text.Json;6using System.Threading.Tasks;7using System.Collections.Generic;8using System.Diagnostics;9{10    {11        private readonly HttpClient _client;12        private readonly Dictionary<int, TaskCompletionSource<ConnectionResponse>> _callbacks = new Dictionary<int, TaskCompletionSource<ConnectionResponse>>();13        private readonly Dictionary<string, List<EventHandler<ConnectionResponse>>> _callbacksForEvent = new Dictionary<string, List<EventHandler<ConnectionResponse>>>();14        private int _lastId = 0;15        public event EventHandler<ConnectionResponse> Disconnected;16        public Connection(string url)17        {18            _client = new HttpClient();19            _client.BaseAddress = new Uri(url);20            _client.DefaultRequestHeaders.Accept.Clear();21            _client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));22            _client.DefaultRequestHeaders.Add("User-Agent", "PuppeteerSharp");23            _client.DefaultRequestHeaders.Add("Connection", "keep-alive");24            _client.Timeout = Timeout.InfiniteTimeSpan;25            _client.MaxResponseContentBufferSize = 2147483647;26        }27        public async Task<ConnectionResponse> SendAsync(string method, dynamic args = null)28        {29            var id = _lastId++;30            {31            };32            var response = await _client.PostAsync("", new StringContent(JsonSerializer.Serialize(message)));33            var responseString = await response.Content.ReadAsStringAsync();34            var connectionResponse = JsonSerializer.Deserialize<ConnectionResponse>(responseString);35            connectionResponse.Id = id;36            connectionResponse.Method = method;37            connectionResponse.Params = args;38            if (connectionResponse.Error != null)39            {40                throw new ConnectionException(connectionResponse.Error);41            }42            return connectionResponse;43        }44        public Task<ConnectionResponse> SendAsync(string method, object args = null)45        {46            return SendAsync(method, (dynamic)args);47        }

1using PuppeteerSharp.Messaging;2private async Task<ConnectionResponse> GetResponseAsync(string id, int timeout = 30000)3{4    var tcs = new TaskCompletionSource<ConnectionResponse>();5    var task = tcs.Task;6    EventHandler<ConnectionResponse> handler = null;7    handler = (s, e) =>8    {9        if (e.Id == id)10        {11            tcs.TrySetResult(e);12            Connection.Response -= handler;13        }14    };15    Connection.Response += handler;16    if (await Task.WhenAny(task, Task.Delay(timeout)) != task)17    {18        Connection.Response -= handler;19        throw new TimeoutException();20    }21    return await task;22}23   at PuppeteerSharp.Connection.ProcessResponseAsync(ConnectionResponse message) in C:\Users\Me\puppeteer-sharp\lib\PuppeteerSharp\Connection.cs:line 16924   at PuppeteerSharp.Connection.OnMessageAsync(Object sender, String message) in C:\Users\Me\puppeteer-sharp\lib\PuppeteerSharp\Connection.cs:line 15325   at PuppeteerSharp.Connection.OnMessage(Object sender, MessageEventArgs e) in C:\Users\Me\puppeteer-sharp\lib\PuppeteerSharp\Connection.cs:line 14526   at WebSocketSharp.WebSocket.OnMessage(MessageEventArgs e)27   at WebSocketSharp.WebSocket.OnData(Byte[] data, Int32 length)28   at WebSocketSharp.WebSocket.read(Byte[] buffer, Int32 offset, Int32 length)29   at WebSocketSharp.WebSocket.readHandshake()30   at WebSocketSharp.WebSocket.doHandshake()31   at WebSocketSharp.WebSocket.connect()32   at WebSocketSharp.WebSocket.Connect()33   at PuppeteerSharp.Transport.WebSocketTransport.ConnectAsync() in C:\Users\Me\puppeteer-sharp\lib\PuppeteerSharp\Transport\WebSocketTransport.cs:line 3934   at PuppeteerSharp.Connection.ConnectAsync() in C:\Users\Me\puppeteer-sharp\lib\PuppeteerSharp\Connection.cs:line 10635   at PuppeteerSharp.Browser.ConnectAsync(ConnectOptions options) in C:\Users\Me\puppeteer-sharp\lib\P

1var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {2        return { id: 1, result: 'foo' };3    }");4var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {5        return { id: 1, result: 'foo' };6    }");7var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {8        return { id: 1, result: 'foo' };9    }");10var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {11        return { id: 1, result: 'foo' };12    }");13var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {14        return { id: 1, result: 'foo' };15    }");16var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {17        return { id: 1, result: 'foo' };18    }");19var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {20        return { id: 1, result: 'foo' };21    }");22var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {23        return { id: 1, result: 'foo' };24    }");25var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {26        return { id: 1, result: 'foo' };27    }");28var response = await page.EvaluateFunctionAsync<ConnectionResponse>("() => {29        return { id: 1, result: 'foo' };30    }");

1var connectionResponse = new ConnectionResponse();2connectionResponse.ConnectionId = "connectionId";3connectionResponse.Data = "data";4connectionResponse.Message = "message";5connectionResponse.Success = true;6connectionResponse.Version = "version";7connectionResponse.Url = "url";8connectionResponse.Error = "error";9connectionResponse.ErrorType = "errorType";10var connectionResponse = new ConnectionResponse();11connectionResponse.ConnectionId = "connectionId";12connectionResponse.Data = "data";13connectionResponse.Message = "message";14connectionResponse.Success = true;15connectionResponse.Version = "version";16connectionResponse.Url = "url";17connectionResponse.Error = "error";18connectionResponse.ErrorType = "errorType";19var connectionResponse = new ConnectionResponse();20connectionResponse.ConnectionId = "connectionId";21connectionResponse.Data = "data";22connectionResponse.Message = "message";23connectionResponse.Success = true;24connectionResponse.Version = "version";25connectionResponse.Url = "url";26connectionResponse.Error = "error";27connectionResponse.ErrorType = "errorType";28var connectionResponse = new ConnectionResponse();29connectionResponse.ConnectionId = "connectionId";30connectionResponse.Data = "data";31connectionResponse.Message = "message";32connectionResponse.Success = true;33connectionResponse.Version = "version";34connectionResponse.Url = "url";35connectionResponse.Error = "error";36connectionResponse.ErrorType = "errorType";37var connectionResponse = new ConnectionResponse();38connectionResponse.ConnectionId = "connectionId";39connectionResponse.Data = "data";40connectionResponse.Message = "message";41connectionResponse.Success = true;42connectionResponse.Version = "version";43connectionResponse.Url = "url";44connectionResponse.Error = "error";45connectionResponse.ErrorType = "errorType";46var connectionResponse = new ConnectionResponse();47connectionResponse.ConnectionId = "connectionId";48connectionResponse.Data = "data";49connectionResponse.Message = "message";50connectionResponse.Success = true;51connectionResponse.Version = "version";52connectionResponse.Url = "url";53connectionResponse.Error = "error";