using Microsoft.AspNetCore.SignalR.Client;

using System;

using System.Collections.Generic;

using System.Threading;

using System.Threading.Tasks;

using Newtonsoft.Json;

​

namespace SignalRStressTest

{

    class Program

    {

        // SignalR hub URL

        private static string hubUrl = "https://your-signalr-server.com/hub";

​

        // Number of simulated users

        private static int userCount = 100;

​

        // Message delay (to avoid sending too many requests too quickly)

        private static int messageDelay = 1000; // 1000ms (1 second)

​

        static async Task Main(string[] args)

        {

            Console.WriteLine("Starting SignalR stress test...");

​

            // Start multiple clients

            var tasks = new List<Task>();

            for (int i = 0; i < userCount; i++)

            {

                var userToken = Guid.NewGuid().ToString(); // Simulate unique tokens for each user

                tasks.Add(SimulateUser(userToken, i + 1));

            }

​

            // Wait for all clients to finish

            await Task.WhenAll(tasks);

​

            Console.WriteLine("Stress test completed.");

        }

​

        // Simulate a user interaction with SignalR

        private static async Task SimulateUser(string token, int userId)

        {

            // Create a connection to the SignalR hub

            var connection = new HubConnectionBuilder()

                .WithUrl(hubUrl)

                .WithAutomaticReconnect()

                .Build();

​

            // Define what to do when receiving broadcast messages from the server

            connection.On<string>("BroadcastMessage", (message) =>

            {

                Console.WriteLine($"User {userId} received broadcast: {message}");

            });

​

            try

            {

                // Start the connection

                await connection.StartAsync();

                Console.WriteLine($"User {userId} connected.");

​

                // Send ConnectUser message

                await SendConnectUserMessage(connection, userId, token);

                await Task.Delay(messageDelay);

​

                // Simulate betting

                for (int i = 0; i < 5; i++) // Example: each user places 5 bets

                {

                    await SendPlaceBetsMessage(connection, userId, token);

                    await Task.Delay(messageDelay); // Delay between each bet

                }

​

                // Simulate cashout

                await SendCashOutMessage(connection, userId, token);

                await Task.Delay(messageDelay);

​

                // Stop the connection after a while

                await connection.StopAsync();

                Console.WriteLine($"User {userId} disconnected.");

            }

            catch (Exception ex)

            {

                Console.WriteLine($"Error with user {userId}: {ex.Message}");

            }

        }

​

        private static async Task SendConnectUserMessage(HubConnection connection, int userId, string token)

        {

            var connectUserParams = new

            {

                GameId = 1,

                VariantId = 1,

                Token = token,

                OperatorId = Guid.NewGuid(),

                Currency = "USD"

            };

​

            Console.WriteLine($"User {userId} connecting...");

            await connection.InvokeAsync("ConnectUser", connectUserParams);

        }

​

        private static async Task SendPlaceBetsMessage(HubConnection connection, int userId, string token)

        {

            var placeBetsParams = new

            {

                GameId = 1,

                VariantId = 1,

                Token = token,

                OperatorId = Guid.NewGuid(),

                Currency = "USD",

                Data = new

                {

                    GameRequest = new

                    {

                        Bets = new[]

                        {

                            new

                            {

                                AutoCashoutMultiplier = 2.5m,

                                BetId = 1,

                                ChipSize = 1000L,

                                NumChips = 2L

                            }

                        }

                    }

                }

            };

​

            Console.WriteLine($"User {userId} placing bet...");

            await connection.InvokeAsync("PlaceBets", placeBetsParams);

        }

​

        private static async Task SendCashOutMessage(HubConnection connection, int userId, string token)

        {

            var castOutParams = new

            {

                GameId = 1,

                VariantId = 1,

                Token = token,

                OperatorId = Guid.NewGuid(),

                Currency = "USD",

                Data = new

                {

                    GameRequest = new

                    {

                        Id = Guid.NewGuid()

                    }

                }

            };

​

            Console.WriteLine($"User {userId} cashing out...");

            await connection.InvokeAsync("CastOut", castOutParams);

        }

    }

}