Add KurrentDB gRPC persistence adapter for EventFlow 0.x

.github/workflows/pull-requests-v0.yml

@@ -29,10 +29,25 @@ jobs:
       run: |
         powershell -NoProfile -ExecutionPolicy unrestricted -Command ".\up-integration-environment.ps1"
 
+    - name: Install .NET SDK for KurrentDB adapter
+      uses: actions/setup-dotnet@v4
+      with:
+        dotnet-version: '8.0.x'
+
+    - name: Start isolated KurrentDB test databases
+      run: docker compose -p eventflow-kurrentdb-tests -f docker-compose.kurrentdb.yml up -d --wait --force-recreate
+
+    - name: Run KurrentDB adapter tests
+      run: dotnet test Source/EventFlow.EventStores.KurrentDB.Tests/EventFlow.EventStores.KurrentDB.Tests.csproj -c Release -f net8.0 --logger trx
+
     - name: Run Bake
       run: |
         bake run --build-version 0.85.${{ github.run_number }}
 
+    - name: Stop isolated KurrentDB test databases
+      if: always()
+      run: docker compose -p eventflow-kurrentdb-tests -f docker-compose.kurrentdb.yml down
+
     - name: Upload NuGet packages
       uses: actions/upload-artifact@v4
       if: success() || failure()

.github/workflows/release-v0.yml

@@ -36,12 +36,27 @@ jobs:
       run: |
         powershell -NoProfile -ExecutionPolicy unrestricted -Command ".\up-integration-environment.ps1"
 
+    - name: Install .NET SDK for KurrentDB adapter
+      uses: actions/setup-dotnet@v4
+      with:
+        dotnet-version: '8.0.x'
+
+    - name: Start isolated KurrentDB test databases
+      run: docker compose -p eventflow-kurrentdb-tests -f docker-compose.kurrentdb.yml up -d --wait --force-recreate
+
+    - name: Run KurrentDB adapter tests
+      run: dotnet test Source/EventFlow.EventStores.KurrentDB.Tests/EventFlow.EventStores.KurrentDB.Tests.csproj -c Release -f net8.0 --logger trx
+
     - name: Run Bake
       run: |
         declare -i REVISION
         REVISION=4714+$GITHUB_RUN_NUMBER
         bake run --convention=Release --build-version 0.85.$REVISION --destination="nuget>github,nuget,release>github"
 
+    - name: Stop isolated KurrentDB test databases
+      if: always()
+      run: docker compose -p eventflow-kurrentdb-tests -f docker-compose.kurrentdb.yml down
+
     - name: Upload NuGet packages
       uses: actions/upload-artifact@v4
       if: success() || failure()

EventFlow.sln

@@ -101,6 +101,12 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EventFlow.MongoDB", "Source
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EventFlow.MongoDB.Tests", "Source\EventFlow.MongoDB.Tests\EventFlow.MongoDB.Tests.csproj", "{2D837E47-E92B-422E-AC29-AB5607E9E6D1}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "KurrentDB", "KurrentDB", "{497AB91A-2753-E755-424A-31A4410A0CB4}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EventFlow.EventStores.KurrentDB", "Source\EventFlow.EventStores.KurrentDB\EventFlow.EventStores.KurrentDB.csproj", "{0B92ADF2-29EE-499B-9BBD-A31E3BFC4EF7}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "EventFlow.EventStores.KurrentDB.Tests", "Source\EventFlow.EventStores.KurrentDB.Tests\EventFlow.EventStores.KurrentDB.Tests.csproj", "{EF4EB55C-855B-41FB-B5CA-BBF5B2E718E9}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -243,6 +249,14 @@ Global
 		{2D837E47-E92B-422E-AC29-AB5607E9E6D1}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{2D837E47-E92B-422E-AC29-AB5607E9E6D1}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{2D837E47-E92B-422E-AC29-AB5607E9E6D1}.Release|Any CPU.Build.0 = Release|Any CPU
+		{0B92ADF2-29EE-499B-9BBD-A31E3BFC4EF7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{0B92ADF2-29EE-499B-9BBD-A31E3BFC4EF7}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{0B92ADF2-29EE-499B-9BBD-A31E3BFC4EF7}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{0B92ADF2-29EE-499B-9BBD-A31E3BFC4EF7}.Release|Any CPU.Build.0 = Release|Any CPU
+		{EF4EB55C-855B-41FB-B5CA-BBF5B2E718E9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{EF4EB55C-855B-41FB-B5CA-BBF5B2E718E9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{EF4EB55C-855B-41FB-B5CA-BBF5B2E718E9}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{EF4EB55C-855B-41FB-B5CA-BBF5B2E718E9}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -282,6 +296,8 @@ Global
 		{5B2706DA-B66C-4CD9-8441-8C9BDACB8348} = {92F3C263-8C0C-4D12-B41A-452E48D2E5E8}
 		{C34BFD0C-E7CD-4DEE-A1F4-8FBE9DE0B239} = {7832AC5E-5CE2-4694-BA43-E53222B75EDC}
 		{2D837E47-E92B-422E-AC29-AB5607E9E6D1} = {7832AC5E-5CE2-4694-BA43-E53222B75EDC}
+		{0B92ADF2-29EE-499B-9BBD-A31E3BFC4EF7} = {497AB91A-2753-E755-424A-31A4410A0CB4}
+		{EF4EB55C-855B-41FB-B5CA-BBF5B2E718E9} = {497AB91A-2753-E755-424A-31A4410A0CB4}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {17607E2C-4E8E-45A2-85BD-0A5808E1C0F3}

README.md

@@ -128,6 +128,7 @@ to the documentation.
   * SQLite
   * PostgreSQL
   * EventStore - [home page](https://eventstore.org/)
+  * [KurrentDB gRPC](Source/EventFlow.EventStores.KurrentDB/README.md) - .NET Framework 4.8 and .NET 8+
 * [**Subscribers:**](https://docs.geteventflow.net/Subscribers.html)
   Listeners that act on specific domain events. Useful if an specific action
   needs to be triggered after a domain event has been committed.

RELEASE_NOTES.md

@@ -1,5 +1,7 @@
 ### New in 0.85 (not released yet)
 
+* New: Added the separate `EventFlow.EventStores.KurrentDB` gRPC adapter for .NET Framework 4.8 and .NET 8, preserving the existing EventStore TCP adapter.
+
 * New: Update from `System.Data.SqlClient` to `Microsoft.Data.SqlClient` (thanks @janrybka)
 
 ### New in 0.84.4 (released 2024-11-26)

Source/EventFlow.EventStores.KurrentDB.Tests/EventFlow.EventStores.KurrentDB.Tests.csproj

@@ -0,0 +1,27 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <Import Project="../Common.props" />
+  <PropertyGroup>
+    <!-- Framework integration tests require Windows 11 HTTP/2 and the TLS profile. -->
+    <TargetFrameworks>net8.0</TargetFrameworks>
+    <TargetFrameworks Condition="'$(EnableNet48Tests)' == 'true'">net48;net8.0</TargetFrameworks>
+    <LangVersion>8.0</LangVersion>
+    <AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
+    <GenerateBindingRedirectsOutputType>true</GenerateBindingRedirectsOutputType>
+    <TreatWarningsAsErrors>True</TreatWarningsAsErrors>
+    <GenerateAssemblyInfo>False</GenerateAssemblyInfo>
+    <IsTestProject>true</IsTestProject>
+    <IsPackable>False</IsPackable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.8.0" />
+    <PackageReference Include="NUnit" Version="3.12.0" />
+    <PackageReference Include="NUnit3TestAdapter" Version="4.5.0" PrivateAssets="All" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\EventFlow.EventStores.KurrentDB\EventFlow.EventStores.KurrentDB.csproj" />
+    <ProjectReference Include="..\EventFlow.TestHelpers\EventFlow.TestHelpers.csproj" />
+    <ProjectReference Include="..\EventFlow.EventStores.EventStore\EventFlow.EventStores.EventStore.csproj" />
+  </ItemGroup>
+</Project>