using Microsoft.AspNetCore.SignalR.Client;

using System;

using System.Collections.Generic;

using System.Threading;

using System.Threading.Tasks;

using Newtonsoft.Json;

​

namespace SignalRStressTester

{

    class Program

    {

        // Configuration parameters (can be modified)

        private static int _numUsers = 100;       // Number of concurrent users

        private static int _connectDelayMs = 100;  // Delay between connect attempts

        private static int _bettingIntervalMs = 1000; // Interval between bets (per user)

        private static int _cashoutIntervalMs = 5000; // Interval between cashouts (per user)

        private static string _hubUrl = "YOUR_SIGNALR_HUB_URL"; // Replace with your SignalR hub URL

​

        // Shared Random

        private static readonly Random _random = new Random();

​

        static async Task Main(string[] args)

        {

            Console.WriteLine("SignalR Stress Tester");

             Console.WriteLine($"Configured for  {_numUsers} users, connect delay  {_connectDelayMs} ms, betting interval {_bettingIntervalMs} ms, cashout interval {_cashoutIntervalMs} ms");

            Console.WriteLine("Press any key to start...");

             Console.ReadKey();

​

            var tasks = new List<Task>();

​

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

            {

                tasks.Add(RunUserSimulator(i));

            }

​

            await Task.WhenAll(tasks);

​

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

             Console.ReadKey();

        }

​

        static async Task RunUserSimulator(int userId)

        {

            var connection = new HubConnectionBuilder()

                .WithUrl(_hubUrl)

                .Build();

​

             connection.On<string, Guid, double, double, decimal, bool>("broadcastMessage", (userHash,transactionId, wager, payout, multiplier,HasCashedOut) =>

            {

                Console.WriteLine($"User {userId} received broadcast: UserHash {userHash}, Transaction Id: {transactionId}, Wager: {wager}, Payout: {payout}, Mutliplier: {multiplier}, Has Cashed Out: {HasCashedOut}");

            });

​

            try

            {    

                // Attempt connection (with delay)

                while (true)

                {

                    try

                    {

                        await connection.StartAsync();

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

                        break;

                    }

                    catch(Exception ex)

                    {

                         Console.WriteLine($"User {userId} failed to connect attempting again : {ex.Message}");

                    }

                     await Task.Delay(_connectDelayMs);

                }

​

                    // Connect User

                 await ConnectUser(connection,userId);

​

​

                // Betting and Cashout

                while (true)

                {

​

                    await PlaceBets(connection, userId);

​

                      await Task.Delay(_bettingIntervalMs);

​

                    await CashOut(connection,userId);

​

                     await Task.Delay(_cashoutIntervalMs);

                }

​

​

            }

            catch (Exception ex)

            {

                Console.WriteLine($"User {userId} encountered an error: {ex.Message}");

            }

            finally

            {

                 await connection.StopAsync();

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

            }

​

        }

​

         static async Task ConnectUser(HubConnection connection, int userId)

        {

            var connectParams = new

            {

                GameId = 1,

                VariantId = 1,

                Token = Guid.NewGuid().ToString(),

                OperatorId = Guid.NewGuid(),

                Currency = "USD"

            };

              Console.WriteLine($"User {userId} Connecting User {JsonConvert.SerializeObject(connectParams)}");

​

            await connection.SendAsync("ConnectUser", connectParams);

        }

​

        static async Task PlaceBets(HubConnection connection, int userId)

        {

                   var bet = new

                    {

                        AutoCashoutMultiplier = 2.0m,

                        BetId = 1,

                        ChipSize = 100,

                        NumChips = 1

                    };

                     var placeBetsParams = new

                    {

                            GameId = 1,

                            VariantId = 1,

                            Token = Guid.NewGuid().ToString(),

                            OperatorId = Guid.NewGuid(),

                            Currency = "USD",

                            Data = new {

                           GameRequest=  new

                           {

                           Bets =  new [] { bet}

                            }

                           }

                   };

​

                    Console.WriteLine($"User {userId} Placing Bets {JsonConvert.SerializeObject(placeBetsParams)}");

​

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

        }

​

        static async Task CashOut(HubConnection connection, int userId)

        {

            var cashOutParams = new

            {

                GameId = 1,

                VariantId = 1,

                Token = Guid.NewGuid().ToString(),

                OperatorId = Guid.NewGuid(),

                Currency = "USD",

                Data = new

                {

                    GameRequest = new

                    {

                        Id = Guid.NewGuid()

                    }

                }

            };

             Console.WriteLine($"User {userId} Casting Out {JsonConvert.SerializeObject(cashOutParams)}");

​

           await  connection.SendAsync("CastOut", cashOutParams);

        }

    }

}