refactor: check if IEventBus is registered

Author: cnblogs-dudu

src/Cnblogs.Architecture.Ddd.EventBus.Dapr/EndPointExtensions.cs

@@ -2,6 +2,7 @@
 using Cnblogs.Architecture.Ddd.EventBus.Abstractions;
 using Cnblogs.Architecture.Ddd.EventBus.Dapr;
 using Microsoft.AspNetCore.Builder;
+using Microsoft.Extensions.DependencyInjection;
 
 // ReSharper disable once CheckNamespace
 namespace Microsoft.AspNetCore.Routing;
@@ -62,6 +63,14 @@ public static IEndpointConventionBuilder Subscribe<TEvent>(
         where TEvent : IntegrationEvent
     {
         EnsureDaprSubscribeHandlerMapped(builder);
+
+        var serviceCheck = builder.ServiceProvider.GetRequiredService<IServiceProviderIsService>();
+        if (!serviceCheck.IsService(typeof(IEventBus)))
+        {
+            throw new InvalidOperationException(
+                $"{nameof(IEventBus)} has not been registered. Please using AddDaprEventBus to register.");
+        }
+
         var result = builder
             .MapPost(route, (TEvent receivedEvent, IEventBus eventBus) => eventBus.ReceiveAsync(receivedEvent))
             .WithTopic(DaprOptions.PubSubName, DaprUtils.GetDaprTopicName<TEvent>(appName));

test/Cnblogs.Architecture.IntegrationTestProject/Program.cs

@@ -1,7 +1,5 @@
 using Cnblogs.Architecture.Ddd.Cqrs.AspNetCore;
-using Cnblogs.Architecture.Ddd.Cqrs.DependencyInjection;
 using Cnblogs.Architecture.Ddd.Cqrs.DependencyInjection.EventBus.Dapr;
-using Cnblogs.Architecture.Ddd.EventBus.Dapr;
 using Cnblogs.Architecture.IntegrationTestProject.Application.Commands;
 using Cnblogs.Architecture.IntegrationTestProject.Application.Queries;
 using Cnblogs.Architecture.IntegrationTestProject.Payloads;

test/Cnblogs.Architecture.TestIntegrationEvents/AssemblyInfo.cs

@@ -1,3 +1,3 @@
 using Cnblogs.Architecture.Ddd.EventBus.Abstractions;
 
-[assembly:AssemblyAppName("test")]
+[assembly: AssemblyAppName("test")]

test/Cnblogs.Architecture.UnitTests/Cnblogs.Architecture.UnitTests.csproj

@@ -15,6 +15,7 @@
     </ItemGroup>
 
     <ItemGroup>
+        <ProjectReference Include="..\..\src\Cnblogs.Architecture.Ddd.Cqrs.DependencyInjection.EventBus.Dapr\Cnblogs.Architecture.Ddd.Cqrs.DependencyInjection.EventBus.Dapr.csproj" />
         <ProjectReference Include="..\..\src\Cnblogs.Architecture.Ddd.Cqrs.EntityFramework\Cnblogs.Architecture.Ddd.Cqrs.EntityFramework.csproj" />
         <ProjectReference Include="..\..\src\Cnblogs.Architecture.Ddd.Cqrs.MongoDb\Cnblogs.Architecture.Ddd.Cqrs.MongoDb.csproj" />
         <ProjectReference Include="..\Cnblogs.Architecture.TestIntegrationEvents\Cnblogs.Architecture.TestIntegrationEvents.csproj" />

test/Cnblogs.Architecture.UnitTests/EventBus/AssemblyAttributeTests.cs

@@ -1,9 +1,8 @@
 using Cnblogs.Architecture.TestIntegrationEvents;
-
 using FluentAssertions;
-
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Routing;
+using Microsoft.Extensions.DependencyInjection;
 
 namespace Cnblogs.Architecture.UnitTests.EventBus;
 
@@ -14,6 +13,7 @@ public void SubscribeByAssemblyMeta_Success()
     {
         // Arrange
         var builder = WebApplication.CreateBuilder();
+        builder.Services.AddDaprEventBus(nameof(AssemblyAttributeTests));
         var app = builder.Build();
 
         // Act
@@ -22,4 +22,18 @@ public void SubscribeByAssemblyMeta_Success()
         // Assert
         act.Should().NotThrow();
     }
+
+    [Fact]
+    public void SubscribeByAssemblyMeta_Throw()
+    {
+        // Arrange
+        var builder = WebApplication.CreateBuilder();
+        var app = builder.Build();
+
+        // Act
+        var act = () => app.Subscribe<TestIntegrationEvent>();
+
+        // Assert
+        act.Should().Throw<InvalidOperationException>();
+    }
 }