Content Service: health check

Author: DedSec256

HwProj.APIGateway/HwProj.APIGateway.API/Controllers/SystemController.cs

@@ -1,6 +1,7 @@
 using System.Threading.Tasks;
 using HwProj.APIGateway.API.Models;
 using HwProj.AuthService.Client;
+using HwProj.ContentService.Client;
 using HwProj.CoursesService.Client;
 using HwProj.NotificationsService.Client;
 using HwProj.SolutionsService.Client;
@@ -15,16 +16,19 @@ public class SystemController : AggregationController
         private readonly ICoursesServiceClient _coursesServiceClient;
         private readonly INotificationsServiceClient _notificationsServiceClient;
         private readonly ISolutionsServiceClient _solutionsServiceClient;
+        private readonly IContentServiceClient _contentServiceClient;
 
         public SystemController(
             IAuthServiceClient authServiceClient,
             ICoursesServiceClient coursesServiceClient,
             INotificationsServiceClient notificationsServiceClient,
-            ISolutionsServiceClient solutionsServiceClient) : base(authServiceClient)
+            ISolutionsServiceClient solutionsServiceClient,
+            IContentServiceClient contentServiceClient) : base(authServiceClient)
         {
             _coursesServiceClient = coursesServiceClient;
             _notificationsServiceClient = notificationsServiceClient;
             _solutionsServiceClient = solutionsServiceClient;
+            _contentServiceClient = contentServiceClient;
         }
 
         [HttpGet("status")]
@@ -34,6 +38,7 @@ public async Task<SystemInfo[]> Status()
             var coursesPing = _coursesServiceClient.Ping();
             var notificationsPing = _notificationsServiceClient.Ping();
             var solutionsPing = _solutionsServiceClient.Ping();
+            var filesPing = _contentServiceClient.Ping();
 
             await Task.WhenAll(authPing, coursesPing, notificationsPing, solutionsPing);
 
@@ -59,6 +64,11 @@ public async Task<SystemInfo[]> Status()
                     Service = "Solutions Service",
                     IsAvailable = solutionsPing.Result
                 },
+                new SystemInfo
+                {
+                    Service = "Content Service",
+                    IsAvailable = filesPing.Result
+                },
             };
         }
     }

HwProj.ContentService/HwProj.ContentService.API/Controllers/SystemController.cs

@@ -0,0 +1,11 @@
+using Microsoft.AspNetCore.Mvc;
+
+namespace HwProj.ContentService.API.Controllers;
+
+[Route("api/[controller]")]
+[ApiController]
+public class SystemController : ControllerBase
+{
+    [HttpGet("status")]
+    public IActionResult Status() => Ok();
+}

HwProj.ContentService/HwProj.ContentService.Client/ContentServiceClient.cs

@@ -167,5 +167,18 @@ public async Task<Result> TransferFilesFromCourse(CourseFilesTransferDto filesTr
                 return Result.Failed("Не удалось перенести информацию о файлах — попробуйте повторить позже");
             }
         }
+
+        public async Task<bool> Ping()
+        {
+            try
+            {
+                await _httpClient.GetAsync(_contentServiceUri + "api/system/ping");
+                return true;
+            }
+            catch
+            {
+                return false;
+            }
+        }
     }
 }

HwProj.ContentService/HwProj.ContentService.Client/IContentServiceClient.cs

@@ -12,5 +12,6 @@ public interface IContentServiceClient
         Task<Result<FileInfoDTO[]>> GetFilesInfo(long courseId);
         Task<Result<FileInfoDTO[]>> GetUploadedFilesInfo(long courseId);
         Task<Result> TransferFilesFromCourse(CourseFilesTransferDto filesTransfer);
+        Task<bool> Ping();
     }
 }