Add Reaction for dapr output bindings

reactions/dapr/post-dapr-output-binding/Dockerfile

@@ -0,0 +1,32 @@
+# Build stage
+FROM mcr.microsoft.com/dotnet/sdk:9.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+
+# Copy solution and project files
+COPY post-dapr-output-binding.sln ./
+COPY Drasi.Reactions.PostDaprOutputBinding/Drasi.Reactions.PostDaprOutputBinding.csproj ./Drasi.Reactions.PostDaprOutputBinding/
+
+# Restore dependencies
+RUN dotnet restore "./Drasi.Reactions.PostDaprOutputBinding/Drasi.Reactions.PostDaprOutputBinding.csproj"
+
+# Copy only the source code
+COPY Drasi.Reactions.PostDaprOutputBinding/ ./Drasi.Reactions.PostDaprOutputBinding/
+
+# Build the reaction project
+WORKDIR /src/Drasi.Reactions.PostDaprOutputBinding
+RUN dotnet publish "./Drasi.Reactions.PostDaprOutputBinding.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+# Final stage/image
+FROM mcr.microsoft.com/dotnet/aspnet:9.0 AS final
+WORKDIR /app
+COPY --from=build /app/publish .
+
+# Set log levels for reaction in production
+ENV Logging__LogLevel__Default="Debug"
+ENV Logging__LogLevel__Microsoft="Warning"
+ENV Logging__LogLevel__Microsoft_Hosting_Lifetime="Information"
+ENV Logging__LogLevel__Drasi_Reactions_PostDaprOutputBinding "Debug"
+
+USER app
+ENTRYPOINT ["dotnet", "Drasi.Reactions.PostDaprOutputBinding.dll"]

reactions/dapr/post-dapr-output-binding/Dockerfile.debug

@@ -0,0 +1,33 @@
+# Build stage
+FROM mcr.microsoft.com/dotnet/sdk:9.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+
+# Copy solution and project files
+COPY post-dapr-output-binding.sln ./
+COPY Drasi.Reactions.PostDaprOutputBinding/Drasi.Reactions.PostDaprOutputBinding.csproj ./Drasi.Reactions.PostDaprOutputBinding/
+
+# Restore dependencies
+RUN dotnet restore "./Drasi.Reactions.PostDaprOutputBinding/Drasi.Reactions.PostDaprOutputBinding.csproj"
+
+# Copy only the source code
+COPY Drasi.Reactions.PostDaprOutputBinding/ ./Drasi.Reactions.PostDaprOutputBinding/
+
+# Build the reaction project
+WORKDIR /src/Drasi.Reactions.PostDaprOutputBinding
+RUN dotnet publish "./Drasi.Reactions.PostDaprOutputBinding.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+# Final stage/image
+FROM ubuntu:25.04 AS final
+RUN apt-get update && apt-get install -y bash curl dotnet-runtime-8.0 aspnetcore-runtime-8.0 && rm -rf /var/lib/apt/lists/*
+WORKDIR /app
+COPY --from=build /app/publish .
+
+# Set log levels for reaction in debug environment
+ENV Logging__LogLevel__Default="Debug"
+ENV Logging__LogLevel__Microsoft="Information"
+ENV Logging__LogLevel__Microsoft_Hosting_Lifetime="Information"
+ENV Logging__LogLevel__Drasi_Reactions_PostDaprPubSub="Debug"
+
+USER app
+ENTRYPOINT ["dotnet", "Drasi.Reactions.PostDaprOutputBinding.dll"]

reactions/dapr/post-dapr-output-binding/Drasi.Reactions.PostDaprOutputBinding.Tests/ChangeFormatterTests.cs

@@ -0,0 +1,183 @@
+// Copyright 2024 The Drasi Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using Drasi.Reaction.SDK.Models.QueryOutput;
+using Drasi.Reactions.PostDaprOutputBinding.Services;
+using Moq;
+using Xunit;
+
+namespace Drasi.Reactions.PostDaprOutputBinding.Tests;
+
+public class ChangeFormatterTests
+{
+    [Fact]
+    public void DrasiChangeFormatter_FormatEmptyChangeEvent_ShouldReturnEmptyCollection()
+    {
+        // Arrange
+        var formatter = new DrasiChangeFormatter();
+        var evt = new ChangeEvent
+        {
+            QueryId = "test-query",
+            Sequence = 1,
+            AddedResults = Array.Empty<Dictionary<string, object>>(),
+            UpdatedResults = Array.Empty<UpdatedResultElement>(),
+            DeletedResults = Array.Empty<Dictionary<string, object>>()
+        };
+
+        // Act
+        var result = formatter.Format(evt);
+
+        // Assert
+        Assert.Empty(result);
+    }
+
+    [Fact]
+    public void DrasiChangeFormatter_FormatAddedResults_ShouldReturnCorrectFormat()
+    {
+        // Arrange
+        var formatter = new DrasiChangeFormatter();
+        var addedItem = new Dictionary<string, object> { { "id", "123" }, { "name", "test" } };
+        var evt = new ChangeEvent
+        {
+            QueryId = "test-query",
+            Sequence = 1,
+            SourceTimeMs = 1000,
+            AddedResults = new[] { addedItem },
+            UpdatedResults = Array.Empty<UpdatedResultElement>(),
+            DeletedResults = Array.Empty<Dictionary<string, object>>()
+        };
+
+        // Act
+        var result = formatter.Format(evt).ToList();
+
+        // Assert
+        Assert.Single(result);
+        var json = result[0].GetRawText();
+        Assert.Contains("\"op\":\"i\"", json);
+        Assert.Contains("\"queryId\":\"test-query\"", json);
+        Assert.Contains("\"id\":\"123\"", json);
+        Assert.Contains("\"name\":\"test\"", json);
+    }
+
+    [Fact]
+    public void DrasiChangeFormatter_FormatUpdatedResults_ShouldReturnCorrectFormat()
+    {
+        // Arrange
+        var formatter = new DrasiChangeFormatter();
+        var beforeItem = new Dictionary<string, object> { { "id", "123" }, { "name", "before" } };
+        var afterItem = new Dictionary<string, object> { { "id", "123" }, { "name", "after" } };
+        var updatedElement = new UpdatedResultElement { Before = beforeItem, After = afterItem };
+
+        var evt = new ChangeEvent
+        {
+            QueryId = "test-query",
+            Sequence = 1,
+            SourceTimeMs = 1000,
+            AddedResults = Array.Empty<Dictionary<string, object>>(),
+            UpdatedResults = new[] { updatedElement },
+            DeletedResults = Array.Empty<Dictionary<string, object>>()
+        };
+
+        // Act
+        var result = formatter.Format(evt).ToList();
+
+        // Assert
+        Assert.Single(result);
+        var json = result[0].GetRawText();
+        Assert.Contains("\"op\":\"u\"", json);
+        Assert.Contains("\"queryId\":\"test-query\"", json);
+        Assert.Contains("\"before\":{", json);
+        Assert.Contains("\"after\":{", json);
+        Assert.Contains("\"name\":\"before\"", json);
+        Assert.Contains("\"name\":\"after\"", json);
+    }
+
+    [Fact]
+    public void DrasiChangeFormatter_FormatDeletedResults_ShouldReturnCorrectFormat()
+    {
+        // Arrange
+        var formatter = new DrasiChangeFormatter();
+        var deletedItem = new Dictionary<string, object> { { "id", "123" }, { "name", "test" } };
+        var evt = new ChangeEvent
+        {
+            QueryId = "test-query",
+            Sequence = 1,
+            SourceTimeMs = 1000,
+            AddedResults = Array.Empty<Dictionary<string, object>>(),
+            UpdatedResults = Array.Empty<UpdatedResultElement>(),
+            DeletedResults = new[] { deletedItem }
+        };
+
+        // Act
+        var result = formatter.Format(evt).ToList();
+
+        // Assert
+        Assert.Single(result);
+        var json = result[0].GetRawText();
+        Assert.Contains("\"op\":\"d\"", json);
+        Assert.Contains("\"queryId\":\"test-query\"", json);
+        Assert.Contains("\"before\":{", json);
+        Assert.Contains("\"id\":\"123\"", json);
+        Assert.DoesNotContain("\"after\":{", json);
+    }
+
+    [Fact]
+    public void DrasiChangeFormatter_FormatMultipleResults_ShouldReturnCorrectCount()
+    {
+        // Arrange
+        var formatter = new DrasiChangeFormatter();
+        var addedItem = new Dictionary<string, object> { { "id", "123" }, { "name", "test" } };
+        var deletedItem = new Dictionary<string, object> { { "id", "456" }, { "name", "deleted" } };
+        var beforeItem = new Dictionary<string, object> { { "id", "789" }, { "name", "before" } };
+        var afterItem = new Dictionary<string, object> { { "id", "789" }, { "name", "after" } };
+        var updatedElement = new UpdatedResultElement { Before = beforeItem, After = afterItem };
+
+        var evt = new ChangeEvent
+        {
+            QueryId = "test-query",
+            Sequence = 1,
+            SourceTimeMs = 1000,
+            AddedResults = new[] { addedItem },
+            UpdatedResults = new[] { updatedElement },
+            DeletedResults = new[] { deletedItem }
+        };
+
+        // Act
+        var result = formatter.Format(evt).ToList();
+
+        // Assert
+        Assert.Equal(3, result.Count);
+        Assert.Contains(result, r => r.GetRawText().Contains("\"op\":\"i\""));
+        Assert.Contains(result, r => r.GetRawText().Contains("\"op\":\"u\""));
+        Assert.Contains(result, r => r.GetRawText().Contains("\"op\":\"d\""));
+    }
+
+    [Fact]
+    public void ChangeFormatterFactory_GetFormatter_ShouldReturnDrasiFormatter()
+    {
+        // Arrange
+        var serviceProvider = new Mock<IServiceProvider>();
+        var drasiFormatter = new DrasiChangeFormatter();
+
+        serviceProvider.Setup(s => s.GetService(typeof(DrasiChangeFormatter))).Returns(drasiFormatter);
+
+        var factory = new ChangeFormatterFactory(serviceProvider.Object);
+
+        // Act
+        var drasiResult = factory.GetFormatter();
+
+        // Assert
+        Assert.Same(drasiFormatter, drasiResult);
+    }
+}