Update to Dapr Event Bus 1.3.1.

tonysneed · tonysneed · commit 254eb734a2ca · 2022-07-07T13:33:25.000-05:00
diff --git a/reference-architecture/Common/Common.csproj b/reference-architecture/Common/Common.csproj
@@ -8,7 +8,7 @@
 
     <ItemGroup>
         <PackageReference Include="EventDriven.CQRS.Extensions" Version="2.0.0" />
-        <PackageReference Include="EventDriven.EventBus.Abstractions" Version="1.2.0" />
+        <PackageReference Include="EventDriven.EventBus.Abstractions" Version="1.3.1" />
         <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="6.0.1" />
     </ItemGroup>
 
diff --git a/reference-architecture/CustomerService/CustomerService.csproj b/reference-architecture/CustomerService/CustomerService.csproj
@@ -11,10 +11,10 @@
     <PackageReference Include="EventDriven.CQRS.Abstractions" Version="2.0.0" />
     <PackageReference Include="EventDriven.CQRS.Extensions" Version="2.0.0" />
     <PackageReference Include="EventDriven.DependencyInjection.URF.Mongo" Version="1.1.0" />
-    <PackageReference Include="EventDriven.EventBus.Dapr" Version="1.2.0" />
-    <PackageReference Include="EventDriven.EventBus.Dapr.EventCache.Mongo" Version="1.2.0" />
-    <PackageReference Include="MongoDB.Driver" Version="2.15.0" />
-    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.3.0" />
+    <PackageReference Include="EventDriven.EventBus.Dapr" Version="1.3.1" />
+    <PackageReference Include="EventDriven.EventBus.Dapr.EventCache.Mongo" Version="1.3.1" />
+    <PackageReference Include="MongoDB.Driver" Version="2.16.1" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.3.1" />
     <PackageReference Include="URF.Core.Mongo" Version="6.0.1" />
   </ItemGroup>
 
diff --git a/reference-architecture/OrderService/OrderService.csproj b/reference-architecture/OrderService/OrderService.csproj
@@ -11,10 +11,10 @@
     <PackageReference Include="EventDriven.CQRS.Abstractions" Version="2.0.0" />
     <PackageReference Include="EventDriven.CQRS.Extensions" Version="2.0.0" />
     <PackageReference Include="EventDriven.DependencyInjection.URF.Mongo" Version="1.1.0" />
-    <PackageReference Include="EventDriven.EventBus.Dapr" Version="1.2.0" />
-    <PackageReference Include="EventDriven.EventBus.Dapr.EventCache.Mongo" Version="1.2.0" />
-    <PackageReference Include="MongoDB.Driver" Version="2.15.0" />
-    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.3.0" />
+    <PackageReference Include="EventDriven.EventBus.Dapr" Version="1.3.1" />
+    <PackageReference Include="EventDriven.EventBus.Dapr.EventCache.Mongo" Version="1.3.1" />
+    <PackageReference Include="MongoDB.Driver" Version="2.16.1" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.3.1" />
     <PackageReference Include="URF.Core.Mongo" Version="6.0.1" />
   </ItemGroup>
 
diff --git a/reference-architecture/OrderService/Program.cs b/reference-architecture/OrderService/Program.cs
@@ -55,7 +55,7 @@
     endpoints.MapDaprEventBus(eventBus =>
     {
         var customerAddressUpdatedEventHandler = app.Services.GetRequiredService<CustomerAddressUpdatedEventHandler>();
-        eventBus.Subscribe(customerAddressUpdatedEventHandler, null, "v1");
+        eventBus?.Subscribe(customerAddressUpdatedEventHandler, null, "v1");
     });
 });
 
diff --git a/test/CustomerService.Tests/CustomerService.Tests.csproj b/test/CustomerService.Tests/CustomerService.Tests.csproj
@@ -9,10 +9,10 @@
 
     <ItemGroup>
         <PackageReference Include="AutoFixture" Version="4.17.0" />
-        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.1.0" />
-        <PackageReference Include="Moq" Version="4.17.2" />
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.2.0" />
+        <PackageReference Include="Moq" Version="4.18.1" />
         <PackageReference Include="xunit" Version="2.4.1" />
-        <PackageReference Include="xunit.runner.visualstudio" Version="2.4.3">
+        <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5">
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>
diff --git a/test/CustomerService.Tests/Domain/CustomerAggregate/CommandHandlers/UpdateCustomerHandlerTests.cs b/test/CustomerService.Tests/Domain/CustomerAggregate/CommandHandlers/UpdateCustomerHandlerTests.cs
@@ -65,7 +65,8 @@ public async Task WhenTheAddressIsUpdated_ThenEventShouldBePublished()
         _repositoryMock.Setup(x => x.UpdateAsync(It.IsAny<Customer>()))
             .ReturnsAsync(updatedCustomer);
         var eventRaised = false;
-        _eventBusMock.Setup(x => x.PublishAsync(It.IsAny<CustomerAddressUpdated>(), It.IsAny<string>(), It.IsAny<string>()))
+        _eventBusMock.Setup(x => x.PublishAsync(
+        It.IsAny<CustomerAddressUpdated>(), It.IsAny<string?>(), It.IsAny<string?>(), It.IsAny<string?>()))
             .Callback(() => eventRaised = true);
         var handler = GetHandler();
 
@@ -83,7 +84,8 @@ public async Task WhenTheAddressIsNotUpdated_ThenEventShouldNotBePublished()
         _repositoryMock.Setup(x => x.UpdateAsync(It.IsAny<Customer>()))
             .ReturnsAsync(existingCustomer);
         var eventRaised = false;
-        _eventBusMock.Setup(x => x.PublishAsync(It.IsAny<CustomerAddressUpdated>(), It.IsAny<string>(), It.IsAny<string>()))
+        _eventBusMock.Setup(x => x.PublishAsync(
+        It.IsAny<CustomerAddressUpdated>(), It.IsAny<string?>(), It.IsAny<string?>(), It.IsAny<string?>()))
             .Callback(() => eventRaised = true);
         var handler = GetHandler();
 
diff --git a/test/EventDriven.ReferenceArchitecture.Specs/EventDriven.ReferenceArchitecture.Specs.csproj b/test/EventDriven.ReferenceArchitecture.Specs/EventDriven.ReferenceArchitecture.Specs.csproj
@@ -15,15 +15,15 @@
         <PackageReference Include="EventDriven.DependencyInjection.URF.Mongo" Version="1.1.0" />
         <PackageReference Include="MediatR.Extensions.Microsoft.DependencyInjection" Version="10.0.1" />
         <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="6.0.0" />
-        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.1.0" />
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.2.0" />
         <PackageReference Include="SpecFlow.Plus.LivingDocPlugin" Version="3.9.57" />
-        <PackageReference Include="SpecFlow.xUnit" Version="3.9.58" />
+        <PackageReference Include="SpecFlow.xUnit" Version="3.9.74" />
         <PackageReference Include="xunit" Version="2.4.1" />
-        <PackageReference Include="xunit.runner.visualstudio" Version="2.4.3">
+        <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5">
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>
-        <PackageReference Include="FluentAssertions" Version="6.5.1" />
+        <PackageReference Include="FluentAssertions" Version="6.7.0" />
     </ItemGroup>
 
     <ItemGroup>
diff --git a/test/OrderService.Tests/OrderService.Tests.csproj b/test/OrderService.Tests/OrderService.Tests.csproj
@@ -9,10 +9,10 @@
 
     <ItemGroup>
         <PackageReference Include="AutoFixture" Version="4.17.0" />
-        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.1.0" />
-        <PackageReference Include="Moq" Version="4.17.2" />
+        <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.2.0" />
+        <PackageReference Include="Moq" Version="4.18.1" />
         <PackageReference Include="xunit" Version="2.4.1" />
-        <PackageReference Include="xunit.runner.visualstudio" Version="2.4.3">
+        <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5">
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
             <PrivateAssets>all</PrivateAssets>
         </PackageReference>

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@`
`55`	`55`	`endpoints.MapDaprEventBus(eventBus =>`
`56`	`56`	`{`
`57`	`57`	`var customerAddressUpdatedEventHandler = app.Services.GetRequiredService<CustomerAddressUpdatedEventHandler>();`
`58`		`- eventBus.Subscribe(customerAddressUpdatedEventHandler, null, "v1");`
	`58`	`+ eventBus?.Subscribe(customerAddressUpdatedEventHandler, null, "v1");`
`59`	`59`	`});`
`60`	`60`	`});`
`61`	`61`