Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use WebSocketTransport method of PuppeteerSharp.Transport.WebSocketTransport class

Best Puppeteer-sharp code snippet using PuppeteerSharp.Transport.WebSocketTransport.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;4{5    {6        static void Main(string[] args)7        {8            MainAsync().Wait();9        }10        static async Task MainAsync()11        {12            {13                Args = new string[] { "--no-sandbox" }14            };15            var browser = await Puppeteer.LaunchAsync(options);16            var page = await browser.NewPageAsync();17            await page.PdfAsync("C:\\Users\\Public\\Documents\\google.pdf");18            await browser.CloseAsync();19        }20    }21}

WebSocketTransport

Using AI Code Generation

1{2    {3        private readonly ClientWebSocket _webSocket;4        private readonly CancellationTokenSource _readerCts = new CancellationTokenSource();5        private readonly CancellationTokenSource _writerCts = new CancellationTokenSource();6        private readonly CancellationTokenSource _closeCts = new CancellationTokenSource();7        private readonly Task _readerTask;8        private readonly Task _writerTask;9        private readonly TaskCompletionSource<bool> _closeTcs = new TaskCompletionSource<bool>();10        private readonly ILogger _logger;11        private readonly ConcurrentQueue<Request> _sendQueue = new ConcurrentQueue<Request>();12        private readonly ConcurrentDictionary<int, Request> _requestIdToRequest = new ConcurrentDictionary<int, Request>();13        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();14        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources1 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();15        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources2 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();16        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources3 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();17        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources4 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();18        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources5 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();19        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources6 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();20        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources7 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();21        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources8 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();22        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources9 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();23        private readonly ConcurrentDictionary<int, TaskCompletionSource<Session>> _sessionTaskCompletionSources10 = new ConcurrentDictionary<int, TaskCompletionSource<Session>>();

WebSocketTransport

Using AI Code Generation

1using System;2using System.IO;3using System.Net;4using System.Threading.Tasks;5using PuppeteerSharp;6{7    {8        static void Main(string[] args)9        {10            MainAsync().Wait();11        }12        static async Task MainAsync()13        {14            var connection = await Puppeteer.ConnectAsync(new ConnectOptions15            {16            });17            var page = await connection.NewPageAsync();18            var title = await page.TitleAsync();19            Console.WriteLine(title);20            await connection.CloseAsync();21        }22    }23}24using System;25using System.IO;26using System.Net;27using System.Threading.Tasks;28using PuppeteerSharp;29{30    {31        static void Main(string[] args)32        {33            MainAsync().Wait();34        }35        static async Task MainAsync()36        {37            var connection = await Puppeteer.ConnectAsync(new ConnectOptions38            {

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.