Add example endpoint to connect with the database

src/Directory.Packages.props

@@ -1,5 +1,6 @@
 <Project>
   <ItemGroup>
+    <PackageVersion Include="Grpc.AspNetCore.Server.Reflection" Version="2.65.0" />
     <PackageVersion Include="Microsoft.AspNetCore.Mvc.Testing" Version="8.0.8" />
     <PackageVersion Include="Microsoft.AspNetCore.OpenApi" Version="8.0.8" />
     <PackageVersion Include="Microsoft.EntityFrameworkCore.Design" Version="8.0.8" />

src/Server.Controllers.Api.Grpc/Api.Grpc.csproj

@@ -7,11 +7,12 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <Protobuf Include="Protos\greet.proto" GrpcServices="Server"/>
+        <Protobuf Include="Protos\messagebus.proto" GrpcServices="Server"/>
     </ItemGroup>
 
     <ItemGroup>
         <PackageReference Include="Grpc.AspNetCore" />
+        <PackageReference Include="Grpc.AspNetCore.Server.Reflection" />
         <PackageReference Include="Microsoft.EntityFrameworkCore.Design">
           <PrivateAssets>all</PrivateAssets>
           <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

src/Server.Controllers.Api.Grpc/Program.cs

@@ -1,6 +1,6 @@
 using MadWorldNL.MantaRayPlan.Extensions;
 using MadWorldNL.MantaRayPlan.OpenTelemetry;
-using Server.Controllers.Api.Grpc.Services;
+using MadWorldNL.MantaRayPlan.Services;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -10,14 +10,21 @@
 builder.AddDefaultOpenTelemetry(openTelemetryConfig);
 
 builder.Services.AddGrpc();
+builder.Services.AddGrpcReflection();
+
 builder.AddDatabase();
 
 builder.Services.AddHealthChecks();
 
 var app = builder.Build();
 
-// Configure the HTTP request pipeline.
-app.MapGrpcService<GreeterService>();
+app.MapGrpcService<MessageBusServiceProxy>();
+
+if (app.Environment.IsDevelopment())
+{
+    app.MapGrpcReflectionService();
+}
+
 app.MapHealthChecks("/healthz");
 
 app.MapGet("/",

src/Server.Controllers.Api.Grpc/Protos/messagebus.proto

@@ -0,0 +1,16 @@
+syntax = "proto3";
+
+option csharp_namespace = "MantaRayPlan";
+
+package messagebus;
+
+import "google/protobuf/empty.proto";
+
+service MessageBusService {
+  rpc GetStatus (google.protobuf.Empty) returns (MessageBusStatusReply);
+}
+
+message MessageBusStatusReply {
+  string message = 1;
+  int32 counter = 2;
+}

src/Server.Controllers.Api.Grpc/Services/MessageBusServiceProxy.cs

@@ -0,0 +1,34 @@
+using Google.Protobuf.WellKnownTypes;
+using Grpc.Core;
+using MadWorldNL.MantaRayPlan.MessageBuses;
+using MantaRayPlan;
+
+namespace MadWorldNL.MantaRayPlan.Services;
+
+public class MessageBusServiceProxy(IMessageBusRepository messageBusRepository, ILogger<MessageBusServiceProxy> logger)
+        : MessageBusService.MessageBusServiceBase
+{
+    public override async Task<MessageBusStatusReply> GetStatus(Empty request, ServerCallContext context)
+    {
+        try
+        {
+            var status = await messageBusRepository.FindStatusAsync() ?? new MessageBusStatus();
+
+            return new MessageBusStatusReply()
+            {
+                Counter = status.Count
+            };
+        }
+        catch (Exception ex)
+        {
+            const string message = "Database error";
+
+            logger.LogError(ex, message);
+
+            return new MessageBusStatusReply()
+            {
+                Message = message
+            };
+        }
+    }
+}

src/Server.Controllers.Api.Grpc/appsettings.json

@@ -20,7 +20,7 @@
   },
   "Kestrel": {
     "EndpointDefaults": {
-      "Protocols": "Http1AndHttp2"
+      "Protocols": "Http2"
     }
   }
 }

src/Server.DataAccess.DataBase/MessageBuses/MessageBusRepository.cs

@@ -22,6 +22,7 @@ await _dbContext.MessageBusStatus
     public async Task<MessageBusStatus?> FindStatusAsync()
     {
         return await _dbContext.MessageBusStatus
+                .OrderBy(s => s.Id)
                 .LastOrDefaultAsync();
     }