MockController Add method testing sirnalR

2023-12-01 16:26:18 +05:00 · 2023-12-01 16:26:18 +05:00 · 7436cfd11a
commit 7436cfd11a
parent 6ef0d62cb9
1 changed files with 103 additions and 56 deletions
--- a/AsbCloudWebApi/Controllers/MockController.cs
+++ b/AsbCloudWebApi/Controllers/MockController.cs
@ -1,72 +1,119 @@
-using Microsoft.AspNetCore.Mvc;
+using AsbCloudApp.Exceptions;
+using AsbCloudWebApi.SignalR;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.SignalR;
+using Microsoft.Extensions.DependencyInjection;
+using System;
 using System.Collections.Generic;
 using System.ComponentModel.DataAnnotations;
 using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;

-namespace AsbCloudWebApi.Controllers
+namespace AsbCloudWebApi.Controllers;
+
+/// <summary>
+/// Имитирует разные типы ответа сервера
+/// </summary>
+[Route("api/[controller]")]
+[ApiController]
+public class MockController : ControllerBase
 {
-    /// <summary>
-    /// Имитирует разные типы ответа сервера
-    /// </summary>
-    [Route("api/[controller]")]
-    [ApiController]
-    public class MockController : ControllerBase
+    private readonly IServiceProvider provider;
+
+    public MockController(IServiceProvider provider)
    {
-        /// <summary>
-        /// имитирует http-400
-        /// </summary>
-        [HttpGet("400")]
-        [ProducesResponseType(typeof(ValidationProblemDetails), (int)System.Net.HttpStatusCode.BadRequest)]
-        public IActionResult Get400([FromQuery, Required]IDictionary<string, string> args)
+        this.provider = provider;
+    }
+
+    /// <summary>
+    /// имитирует http-400
+    /// </summary>
+    [HttpGet("400")]
+    [ProducesResponseType(typeof(ValidationProblemDetails), (int)System.Net.HttpStatusCode.BadRequest)]
+    public IActionResult Get400([FromQuery, Required]IDictionary<string, string> args)
+    {
+        var errors = new Dictionary<string, string[]>();
+        
+        foreach (var arg in args)
        {
-            var errors = new Dictionary<string, string[]>();
+            var countOfErrors = ((arg.Key + arg.Value).Length % 3) + 1;
+            var errorsText = Enumerable.Range(0, countOfErrors)
+                .Select(i => $"{arg.Value} не соответствует критериям проверки № {i}");

-            foreach (var arg in args)
-            {
-                var countOfErrors = ((arg.Key + arg.Value).Length % 3) + 1;
-                var errorsText = Enumerable.Range(0, countOfErrors)
-                    .Select(i => $"{arg.Value} не соответствует критериям проверки № {i}");
-
-                errors.Add(arg.Key, errorsText.ToArray());                
-            }
-
-            if (errors.Any())
-            {
-                var problem = new ValidationProblemDetails(errors);                
-                return BadRequest(problem);
-            }
-            else
-            {
-                var problem = new ValidationProblemDetails { Detail = "at least one argument must be provided" };
-                return BadRequest(problem);
-            }
+            errors.Add(arg.Key, errorsText.ToArray());                
        }

-        /// <summary>
-        /// имитирует http-403
-        /// </summary>
-        [HttpGet("403")]
-        public IActionResult Get403()
+        if (errors.Any())
        {
-            return Forbid();
+            var problem = new ValidationProblemDetails(errors);                
+            return BadRequest(problem);
        }
-
-        /// <summary>
-        /// имитирует http-401
-        /// </summary>
-        [HttpGet("401")]
-        public IActionResult Get401()
+        else
        {
-            return Unauthorized();
-        }
-
-        /// <summary>
-        /// имитирует http-500
-        /// </summary>
-        [HttpGet("500")]
-        public IActionResult Get500()
-        {
-            throw new System.Exception("Это тестовое исключение");
+            var problem = new ValidationProblemDetails { Detail = "at least one argument must be provided" };
+            return BadRequest(problem);
        }
    }
+
+    /// <summary>
+    /// имитирует http-403
+    /// </summary>
+    [HttpGet("403")]
+    public IActionResult Get403()
+    {
+        return Forbid();
+    }
+
+    /// <summary>
+    /// имитирует http-401
+    /// </summary>
+    [HttpGet("401")]
+    public IActionResult Get401()
+    {
+        return Unauthorized();
+    }
+
+    /// <summary>
+    /// имитирует http-500
+    /// </summary>
+    [HttpGet("500")]
+    public IActionResult Get500()
+    {
+        throw new System.Exception("Это тестовое исключение");
+    }
+
+    /// <summary>
+    /// имитация отправки SignalR данных
+    /// </summary>
+    /// <example>
+    /// </example>
+    /// <param name="hubName">
+    /// Поддерживаемые hubЫ: wellInfo, notifications, telemetry, reports
+    /// </param>
+    /// <param name="methodName">Название вызываемого на клиенте метода. Прим.:"ReceiveDataSaub". Список методов см. в swagger definition signalr</param>
+    /// <param name="groupName">Группа пользователей. Прим.: "well_1". Если не задана - все пользователи. Шаблон формирования групп см. описание методов в swagger definition signalr</param>
+    /// <param name="body">передаваемая нагрузка. (json)</param>
+    /// <param name="token"></param>
+    /// <returns></returns>
+    [HttpPost("signalr/hubs/{hubName}/{methodName}/{groupName}")]
+    [Authorize]
+    public async Task<IActionResult> PostAsync(string hubName, string methodName, string? groupName, object body, CancellationToken token)
+    {
+        IHubClients clients = hubName.ToLower() switch {
+            "wellinfo" => provider.GetRequiredService<IHubContext<NotificationHub>>().Clients,
+            "notifications" => provider.GetRequiredService<IHubContext<NotificationHub>>().Clients,
+            "telemetry" => provider.GetRequiredService<IHubContext<TelemetryHub>>().Clients,
+            "reports" => provider.GetRequiredService<IHubContext<ReportsHub>>().Clients,
+            _ => throw new ArgumentInvalidException(nameof(hubName), "hubName does not listed"),
+        };
+
+        IClientProxy selectedClients = string.IsNullOrEmpty(groupName)
+            ? clients.All
+            : clients.Group(groupName);
+
+        await selectedClients.SendAsync(methodName, body, token);
+        return Ok();
+    }
 }