How to use WebSocketTransport class of PuppeteerSharp.Transport package

Best Puppeteer-sharp code snippet using PuppeteerSharp.Transport.WebSocketTransport

PuppeteerLaunchTests.cs

Source:PuppeteerLaunchTests.cs

...300            var customSocketCreated = false;301            options.WebSocketFactory = (uri, socketOptions, cancellationToken) =>302            {303                customSocketCreated = true;304                return WebSocketTransport.DefaultWebSocketFactory(uri, socketOptions, cancellationToken);305            };306            using (await Puppeteer.LaunchAsync(options, TestConstants.LoggerFactory))307            {308                Assert.True(customSocketCreated);309            }310        }311        [Fact]312        public async Task ShouldSupportCustomTransport()313        {314            var customTransportCreated = false;315            var options = TestConstants.DefaultBrowserOptions();316            options.TransportFactory = (url, opt, cancellationToken) =>317            {318                customTransportCreated = true;319                return WebSocketTransport.DefaultTransportFactory(url, opt, cancellationToken);320            };321            using (await Puppeteer.LaunchAsync(options, TestConstants.LoggerFactory))322            {323                Assert.True(customTransportCreated);324            }325        }326    }327}...

Connection.cs

Source:Connection.cs

...226        #region Static Methods227        /// <summary>228        /// Gets default web socket factory implementation.229        /// </summary>230        [Obsolete("Use " + nameof(WebSocketTransport) + "." + nameof(WebSocketTransport.DefaultWebSocketFactory) + " instead")]231        public static readonly WebSocketFactory DefaultWebSocketFactory = WebSocketTransport.DefaultWebSocketFactory;232        internal static async Task<Connection> Create(string url, IConnectionOptions connectionOptions, CancellationToken cancellationToken = default)233        {234#pragma warning disable 618235            var transport = connectionOptions.Transport;236#pragma warning restore 618237            if (transport == null)238            {239                var transportFactory = connectionOptions.TransportFactory ?? WebSocketTransport.DefaultTransportFactory;240                transport = await transportFactory(new Uri(url), connectionOptions, cancellationToken).ConfigureAwait(false);241            }242            return new Connection(url, connectionOptions.SlowMo, transport);243        }244        /// <inheritdoc />245        public void Dispose()246        {247            Dispose(true);248            GC.SuppressFinalize(this);249        }250        /// <summary>251        /// Releases all resource used by the <see cref="Connection"/> object.252        /// It will raise the <see cref="Disconnected"/> event and dispose <see cref="Transport"/>.253        /// </summary>...

PuppeteerConnectTests.cs

Source:PuppeteerConnectTests.cs

...126                BrowserWSEndpoint = Browser.WebSocketEndpoint,127                WebSocketFactory = (uri, socketOptions, cancellationToken) =>128                {129                    customSocketCreated = true;130                    return WebSocketTransport.DefaultWebSocketFactory(uri, socketOptions, cancellationToken);131                }132            };133            using (await Puppeteer.ConnectAsync(options, TestConstants.LoggerFactory))134            {135                Assert.True(customSocketCreated);136            }137        }138        [Fact]139        public async Task ShouldSupportCustomTransport()140        {141            var customTransportCreated = false;142            var options = new ConnectOptions()143            {144                BrowserWSEndpoint = Browser.WebSocketEndpoint,145                TransportFactory = (url, opt, cancellationToken) =>146                {147                    customTransportCreated = true;148                    return WebSocketTransport.DefaultTransportFactory(url, opt, cancellationToken);149                }150            };151            using (await Puppeteer.ConnectAsync(options, TestConstants.LoggerFactory))152            {153                Assert.True(customTransportCreated);154            }155        }156    }157}...

LaunchOptions.cs

Source:LaunchOptions.cs

...92        /// </summary>93        /// <value>The default Viewport.</value>94        public ViewPortOptions DefaultViewport { get; set; } = ViewPortOptions.Default;95        /// <summary>96        /// If not <see cref="Transport"/> is set this will be use to determine is the default <see cref="WebSocketTransport"/> will enqueue messages.97        /// </summary>98        /// <remarks>99        /// It's set to <c>true</c> by default because it's the safest way to send commands to Chromium.100        /// Setting this to <c>false</c> proved to work in .NET Core but it tends to fail on .NET Framework.101        /// </remarks>102        public bool EnqueueTransportMessages { get; set; } = true;103    }104}...

WebSocketTransport.cs

Source:WebSocketTransport.cs

...8{9    /// <summary>10    /// Default web socket transport.11    /// </summary>12    public class WebSocketTransport : IConnectionTransport13    {14        private readonly WebSocket _client;15        private readonly bool _queueRequests;16        private readonly TaskQueue _socketQueue;17        private CancellationTokenSource _readerCancellationSource { get; }18        /// <summary>19        /// Gets a value indicating whether this <see cref="PuppeteerSharp.Transport.IConnectionTransport"/> is closed.20        /// </summary>21        public bool IsClosed { get; private set; }22        /// <summary>23        /// Occurs when the transport is closed.24        /// </summary>25        public event EventHandler Closed;26        /// <summary>27        /// Occurs when a message is received.28        /// </summary>29        public event EventHandler<MessageReceivedEventArgs> MessageReceived;30        /// <summary>31        /// Initializes a new instance of the <see cref="PuppeteerSharp.Transport.WebSocketTransport"/> class.32        /// </summary>33        /// <param name="wsClient">WebSocket client.</param>34        /// <param name="queueRequests">If set to <c>true</c> to queue requests.</param>35        public WebSocketTransport(WebSocket wsClient, bool queueRequests = true)36        {37            _client = wsClient;38            _queueRequests = queueRequests;39            _socketQueue = new TaskQueue();40            _readerCancellationSource = new CancellationTokenSource();41            Task.Factory.StartNew(GetResponseAsync);42        }43        /// <summary>44        /// Sends a message using the transport.45        /// </summary>46        /// <returns>The task.</returns>47        /// <param name="message">Message to send.</param>48        public Task SendAsync(string message)49        {...

ConnectOptions.cs

Source:ConnectOptions.cs

...45        /// Optional connection transport.46        /// </summary>47        public IConnectionTransport Transport { get; set; }48        /// <summary>49        /// If not <see cref="Transport"/> is set this will be use to determine is the default <see cref="WebSocketTransport"/> will enqueue messages.50        /// </summary>51        /// <remarks>52        /// It's set to <c>true</c> by default because it's the safest way to send commands to Chromium.53        /// Setting this to <c>false</c> proved to work in .NET Core but it tends to fail on .NET Framework.54        /// </remarks>55        public bool EnqueueTransportMessages { get; set; } = true;56    }57}...

AspNetWebSocketTransport.cs

Source:AspNetWebSocketTransport.cs

...5using System.Web.Hosting;6using PuppeteerSharp.Transport;7namespace PuppeteerSharp.AspNetFramework8{9    public class AspNetWebSocketTransport : WebSocketTransport10    {11        #region Static fields12        /// <summary>13        /// Gets a <see cref="TransportFactory"/> that creates <see cref="AspNetWebSocketTransport"/> instances.14        /// </summary>15        public static readonly TransportFactory AspNetTransportFactory = CreateAspNetTransport;16        /// <summary>17        /// Gets a <see cref="TransportTaskScheduler"/> that uses ASP.NET <see cref="HostingEnvironment.QueueBackgroundWorkItem(Func{CancellationToken,Task})"/>18        /// for scheduling of tasks.19        /// </summary>20        public static readonly TransportTaskScheduler AspNetTransportScheduler = ScheduleBackgroundTask;21        #endregion22        #region Static methods23        private static async Task<IConnectionTransport> CreateAspNetTransport(Uri url, IConnectionOptions connectionOptions, CancellationToken cancellationToken)24        {25            var webSocketFactory = connectionOptions.WebSocketFactory ?? DefaultWebSocketFactory;26            var webSocket = await webSocketFactory(url, connectionOptions, cancellationToken);27            return new AspNetWebSocketTransport(webSocket, connectionOptions.EnqueueTransportMessages);28        }29        private static void ScheduleBackgroundTask(Func<CancellationToken, Task> taskFactory, CancellationToken cancellationToken)30        {31            Task ExecuteAsync(CancellationToken hostingCancellationToken)32                => taskFactory(CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, hostingCancellationToken).Token);33            HostingEnvironment.QueueBackgroundWorkItem(ExecuteAsync);34        }35        #endregion36        #region Constructor(s)37        /// <inheritdoc />38        public AspNetWebSocketTransport(WebSocket client, bool queueRequests) 39            : base(client, AspNetTransportScheduler, queueRequests)40        { }41        #endregion42    }43}...

IConnectionOptions.cs

Source:IConnectionOptions.cs

...25        /// Optional factory for <see cref="IConnectionTransport"/> implementations.26        /// </summary>27        TransportFactory TransportFactory { get; set; }28        /// <summary>29        /// If not <see cref="Transport"/> is set this will be use to determine is the default <see cref="WebSocketTransport"/> will enqueue messages.30        /// </summary>31        bool EnqueueTransportMessages { get; set; }32    }33}...

WebSocketTransport

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using PuppeteerSharp.Transport;4{5    {6        static async Task Main(string[] args)7        {8            Console.WriteLine("Hello World!");9            await transport.ConnectAsync();10            await transport.SendAsync("Target.activateTarget", new { targetId = "2a6f7f6d-2c3f-4a3e-9d0b-0a6f8d6b3f1a" });11            Console.WriteLine(response);12        }13    }14}15using System;16using System.Threading.Tasks;17using PuppeteerSharp.Transport;18{19    {20        static async Task Main(string[] args)21        {22            Console.WriteLine("Hello World!");23            await transport.ConnectAsync();24            await transport.SendAsync("Target.activateTarget", new { targetId = "2a6f7f6d-2c3f-4a3e-9d0b-0a6f8d6b3f1a" });25            Console.WriteLine(response);26        }27    }28}29using System;30using System.Threading.Tasks;31using PuppeteerSharp.Transport;32{33    {34        static async Task Main(string[] args)35        {36            Console.WriteLine("Hello World!");

WebSocketTransport

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Threading.Tasks;4using PuppeteerSharp.Transport;5using PuppeteerSharp.Transport.Channels;6using PuppeteerSharp.Transport.Protocol;7{8    {9        static void Main(string[] args)10        {11            var browser = new Browser(connection, new BrowserContextChannel(connection, "1", null));12            var page = browser.Pages[0];13            page.EvaluateExpressionAsync("document.querySelector('title').innerText").Wait();14        }15    }16}17using System;18using System.Collections.Generic;19using System.Threading.Tasks;20using PuppeteerSharp;21{22    {23        static void Main(string[] args)24        {25            var browser = new BrowserFetcher().DownloadAsync(BrowserFetcher.DefaultRevision).Result;26            var browser = new Browser(connection, new BrowserContextChannel(connection, "1", null));27            var page = browser.Pages[0];28            page.EvaluateExpressionAsync("document.querySelector('title').innerText").Wait();29        }30    }31}

WebSocketTransport

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using PuppeteerSharp.Transport;4using PuppeteerSharp.Transport.Channels;5using PuppeteerSharp.Transport.Protocol;6using PuppeteerSharp.Transport.Protocol.Input;7using PuppeteerSharp.Transport.Protocol.Page;8{9    {10        static async Task Main(string[] args)11        {12            await transport.ConnectAsync();13            var connection = new Connection(transport);14            var client = new CDPSession(connection);15            await client.SendAsync(new InputDispatchKeyEventRequest16            {17            });18            await Task.Delay(1000);19            await client.SendAsync(new InputDispatchKeyEventRequest20            {21            });22            Console.ReadLine();23        }24    }25}26using System;27using System.Threading.Tasks;28using PuppeteerSharp.Transport;29using PuppeteerSharp.Transport.Channels;30using PuppeteerSharp.Transport.Protocol;31using PuppeteerSharp.Transport.Protocol.Input;32using PuppeteerSharp.Transport.Protocol.Page;33{34    {35        static async Task Main(string[] args)36        {37            await transport.ConnectAsync();38            var connection = new Connection(transport);39            var client = new CDPSession(connection);40            await client.SendAsync(new InputDispatchKeyEventRequest41            {42            });43            await Task.Delay(1000

WebSocketTransport

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using PuppeteerSharp.Transport;4using PuppeteerSharp.Transport.Channels;5using PuppeteerSharp.Transport.Protocol;6using PuppeteerSharp.Transport.Protocol.Network;7using PuppeteerSharp.Transport.Protocol.Page;8{9    {10        static async Task Main(string[] args)11        {

WebSocketTransport

Using AI Code Generation

1await transport.ConnectAsync();2await transport.ConnectAsync();3await transport.ConnectAsync();4await transport.ConnectAsync();5await transport.ConnectAsync();6await transport.ConnectAsync();7await transport.ConnectAsync();8await transport.ConnectAsync();9await transport.ConnectAsync();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.