add say verify

src/CoreLibs/HolyClient.StressTest/TestBehavior.cs → src/CoreLibs/HolyClient.StressTest/DefaultBehavior.cs

@@ -1,12 +1,21 @@
 using HolyClient.Abstractions.StressTest;
 using System.Reactive.Disposables;
+using System.Reactive.Linq;
+using System.Reactive.Threading.Tasks;
+using System.Text.RegularExpressions;
 
 namespace HolyClient.StressTest
 {
-	public class TestBehavior : IStressTestBehavior
+	public class DefaultBehavior : IStressTestBehavior
 	{
 		[System.ComponentModel.DisplayName("Spam text")]
-		public string SpamText { get; set; } = "Hello";
+		public string SpamText { get; set; } = "!Hello from Minecraft Holy Client";
+
+		[System.ComponentModel.DisplayName("Spam timeout")]
+		public int SpamTimeout { get; set; } = 5000;
+
+
+		private static Regex SayVerifyRegex = new(@"\.say \/verify (\d+)");
 
 		public Task Activate(CompositeDisposable disposables, IEnumerable<IStressTestBot> bots, CancellationToken cancellationToken)
 		{
@@ -47,13 +56,40 @@ public Task Activate(CompositeDisposable disposables, IEnumerable<IStressTestBot
 					cts = new();
 					try
 					{
+
+
 						await Task.Delay(500);
+
 						await bot.Client.SendChat("/reg 21qwerty 21qwerty");
 
+						try
+						{
+							using CancellationTokenSource cts = new CancellationTokenSource(TimeSpan.FromSeconds(5));
+							//{
+
+							var m = await bot.Client.OnChatMessage
+								.Where(x => x.Message.Contains("verify"))
+								.Skip(3)
+								.FirstAsync()
+								.ToTask(cts.Token);
+
+							var code = SayVerifyRegex.Match(m.Message).Value;
+
+							await bot.Client.SendChat(code);
+							//}
+						}
+						catch (Exception ex)
+						{
+							//Console.WriteLine(ex);
+						}
+
 						while (!cts.IsCancellationRequested)
 						{
 							await bot.Client.SendChat(SpamText);
-							await Task.Delay(1000);
+							if (SpamTimeout <= 0)
+								await Task.Delay(1000);
+							else
+								await Task.Delay(SpamTimeout);
 						}
 					}
 					catch (Exception ex)

src/CoreLibs/HolyClient.StressTest/StressTest.cs

@@ -251,7 +251,7 @@ public async Task Start(Serilog.ILogger logger)
 				}
 				else
 				{
-					TestBehavior testBehavior = new();
+					DefaultBehavior testBehavior = new();
 					await testBehavior.Activate(disposables, stressTestBots, cancellationTokenSource.Token);
 				}
 				CurrentState = StressTestServiceState.Running;

src/HolyClient/Services/PluginProvider.cs

@@ -65,7 +65,7 @@ public class DefaultPluginSource : IPluginSource
 
 		public T CreateInstance<T>() where T : IStressTestBehavior
 		{
-			IStressTestBehavior beh = new TestBehavior();
+			IStressTestBehavior beh = new DefaultBehavior();
 			return (T)beh;
 		}
 	}