Review debug reaction

cli/service/resources/default-reaction-providers.yaml

@@ -116,7 +116,7 @@ spec:
   services:
     reaction:
       image: reaction-result
-      dapr:
+      dapr: 
         app-port: "8080"
       endpoints:
         gateway:

reactions/platform/debug-reaction/.dockerignore

@@ -1,25 +1,7 @@
-**/.classpath
-**/.dockerignore
-**/.env
-**/.git
-**/.gitignore
-**/.project
-**/.settings
-**/.toolstarget
-**/.vs
-**/.vscode
-**/*.*proj.user
-**/*.dbmdl
-**/*.jfm
-**/azds.yaml
-**/bin
-**/charts
-**/docker-compose*
-**/Dockerfile*
-**/node_modules
-**/npm-debug.log
-**/obj
-**/secrets.dev.yaml
-**/values.dev.yaml
-LICENSE
-README.md
+**/.classpath
+**/.dockerignore
+**/.env
+**/.git
+**/.gitignore
+**/bin
+**/obj

reactions/platform/debug-reaction/.gitignore

@@ -1,2 +1,2 @@
-bin
-obj
+/appsettings.Development.json
+.vs

reactions/platform/debug-reaction/Controllers/QueriesController.cs

@@ -0,0 +1,65 @@
+// Copyright 2025 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.
+
+namespace Drasi.Reactions.Debug.Server.Controllers;
+using Microsoft.AspNetCore.Mvc;
+using Drasi.Reactions.Debug.Server.Services;
+
+[ApiController]
+[Route("api/queries")]
+public class QueryController : ControllerBase
+{
+	private readonly IQueryDebugService _debugService;
+
+	private readonly string _configDirectory;
+
+	public QueryController(IQueryDebugService debugService, IConfiguration configuration)
+	{
+		_debugService = debugService;
+		_configDirectory = configuration.GetValue<string>("QueryConfigPath", "/etc/queries")!;
+	}
+
+	// GET queries
+	// This endpoint returns a list of active queries.
+	[HttpGet]
+	public IEnumerable<string> GetQueries()
+	{
+		var queryList = new List<string>();
+		foreach (var qpath in Directory.GetFiles(_configDirectory))
+		{
+			var queryId = Path.GetFileName(qpath);
+			queryList.Add(queryId);
+		}
+		return queryList;
+	}
+
+
+	// GET queries/{queryId}
+	// This endpoint returns the current result of a specific query.
+	[HttpGet("{queryId}")]
+	public async Task<IActionResult> GetQueryResult(string queryId)
+	{
+		var result = await _debugService.GetQueryResult(queryId);
+		return Ok(result);
+	}
+
+	// GET queries/{queryId}/debug-information
+	// This endpoint returns the debug information for a specific query.
+	[HttpGet("{queryId}/debug-information")]
+	public async Task<IActionResult> GetDebugInfo(string queryId)
+	{
+		var result = await _debugService.GetDebugInfo(queryId);
+		return Ok(result);
+	}
+}

reactions/platform/debug-reaction/Controllers/WebSocketController.cs

@@ -0,0 +1,115 @@
+// Copyright 2025 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 Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
+using System.Net.WebSockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using Drasi.Reactions.Debug.Server.Models;
+using Drasi.Reactions.Debug.Server.Services;
+
+
+[Route("api/ws")]
+public class WebSocketController : ControllerBase
+{
+	private readonly IChangeBroadcaster _webSocketService;
+	private readonly ILogger<WebSocketController> _logger;
+
+	public WebSocketController(IChangeBroadcaster webSocketService, ILogger<WebSocketController> logger)
+	{
+		_webSocketService = webSocketService;
+		_logger = logger;
+	}
+
+	[Route("query/{queryId?}")]
+	public async Task Query(string? queryId)
+	{
+		if (!HttpContext.WebSockets.IsWebSocketRequest)
+		{
+			HttpContext.Response.StatusCode = StatusCodes.Status400BadRequest;
+			return;
+		}
+
+		if (string.IsNullOrEmpty(queryId))
+		{
+			using var webSocket = await HttpContext.WebSockets.AcceptWebSocketAsync();
+			await webSocket.CloseAsync(WebSocketCloseStatus.InvalidPayloadData, "Invalid queryId", CancellationToken.None);
+			return;
+		}
+
+		using var webSocketQuery = await HttpContext.WebSockets.AcceptWebSocketAsync();
+		_webSocketService.AddConnection(queryId, webSocketQuery);
+		_logger.LogInformation($"WebSocket connected for queryId: {queryId}");
+
+		var buffer = new byte[1024 * 4];
+		var lastPingTime = DateTime.Now;
+
+		try
+		{
+			while (webSocketQuery.State == WebSocketState.Open)
+			{
+				var result = await webSocketQuery.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
+				if (result.MessageType == WebSocketMessageType.Close)
+				{
+					_logger.LogInformation($"WebSocket closing for queryId: {queryId}");
+					await webSocketQuery.CloseAsync(WebSocketCloseStatus.NormalClosure, "Client closed connection", CancellationToken.None);
+					return;
+				}
+			}
+		}
+		catch (Exception ex)
+		{
+			_logger.LogError(ex, $"WebSocket error for queryId: {queryId}");
+			await webSocketQuery.CloseAsync(WebSocketCloseStatus.InternalServerError, "Server error", CancellationToken.None);
+		}
+	}
+
+	[Route("stream")]
+	public async Task Stream()
+	{
+		if (!HttpContext.WebSockets.IsWebSocketRequest)
+		{
+			HttpContext.Response.StatusCode = StatusCodes.Status400BadRequest;
+			return;
+		}
+
+		using var webSocketStream = await HttpContext.WebSockets.AcceptWebSocketAsync();
+		_webSocketService.AddConnection("stream", webSocketStream);
+		_logger.LogInformation($"WebSocket connected for Event Stream");
+
+		var buffer = new byte[1024 * 4];
+
+		try
+		{
+			while (webSocketStream.State == WebSocketState.Open)
+			{
+				var result = await webSocketStream.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
+				if (result.MessageType == WebSocketMessageType.Close)
+				{
+					_logger.LogInformation($"WebSocket closing for Event Stream");
+					await webSocketStream.CloseAsync(WebSocketCloseStatus.NormalClosure, "Client closed connection", CancellationToken.None);
+					return;
+				}
+			}
+		}
+		catch (Exception ex)
+		{
+			_logger.LogError(ex, "WebSocket error for Event Stream");
+			await webSocketStream.CloseAsync(WebSocketCloseStatus.InternalServerError, "Server error", CancellationToken.None);
+		}
+	}
+}

reactions/platform/debug-reaction/Dockerfile

@@ -12,26 +12,28 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-#See https://aka.ms/containerfastmode to understand how Visual Studio uses this Dockerfile to build your images for faster debugging.
-
-FROM --platform=$TARGETPLATFORM mcr.microsoft.com/dotnet/aspnet@sha256:22414f335b79654fb42257326e7f17f18edf8f912578fc33a55c5dd609bd022e AS base
-# mcr.microsoft.com/dotnet/aspnet:6.0
-WORKDIR /app
-EXPOSE 80
-
-FROM --platform=$BUILDPLATFORM mcr.microsoft.com/dotnet/sdk@sha256:6df1177e48b55272316d08f19cb383483af82aca5cdc67a76c414bc200847624 AS build
-# mcr.microsoft.com/dotnet/sdk:6.0
-WORKDIR /src
-COPY ["debug-reaction.csproj", "."]
-RUN dotnet restore "./debug-reaction.csproj"
-COPY . .
-WORKDIR "/src/."
-RUN dotnet build "debug-reaction.csproj" -c Release -o /app/build
-
-FROM build AS publish
-RUN dotnet publish "debug-reaction.csproj" -c Release -o /app/publish /p:UseAppHost=false
-
-FROM base AS final
-WORKDIR /app
-COPY --from=publish /app/publish .
-ENTRYPOINT ["dotnet", "debug-reaction.dll"]
+#See https://aka.ms/containerfastmode to understand how Visual Studio uses this Dockerfile to build your images for faster debugging.
+
+# Stage 1: Build React frontend
+FROM node:18 AS frontend
+WORKDIR /app/debug-reaction.client
+COPY ./debug-reaction.client/package.json ./debug-reaction.client/package-lock.json ./
+RUN npm install
+COPY ./debug-reaction.client/ ./
+RUN npm run build
+
+# Stage 2: Build .NET backend
+FROM mcr.microsoft.com/dotnet/sdk:8.0 AS backend
+WORKDIR /app/debug-reaction.Server
+COPY ./debug-reaction.Server.csproj ./
+RUN dotnet restore
+COPY . ./
+COPY --from=frontend /app/debug-reaction.client/dist ./wwwroot/
+RUN dotnet publish -c Release -o /app/publish
+
+# Stage 3: Run the app
+FROM mcr.microsoft.com/dotnet/aspnet:8.0
+WORKDIR /app
+COPY --from=backend /app/publish .
+EXPOSE 5195
+ENTRYPOINT ["dotnet", "debug-reaction.Server.dll"]

reactions/platform/debug-reaction/Makefile

@@ -1,4 +1,4 @@
-.PHONY: default docker-build kind-load
+.PHONY: default docker-build kind-load generate-types
 
 CLUSTER_NAME ?= kind
 IMAGE_PREFIX ?= drasi-project
@@ -17,4 +17,9 @@ test:
 	@echo "No tests to run yet"
 
 lint-check:
-	@echo "No lint checks to run yet"
+	@echo "No lint checks to run yet"
+
+generate-types:
+	npm run clean --prefix ../../../../typespec
+	npm run build ./output-unpacked --prefix ../../../../typespec
+	quicktype --src-lang schema -l cs -o Models/Unpacked.generated.cs ../../../../typespec/output-unpacked/_generated/@typespec/json-schema/*.yaml --framework SystemTextJson --namespace Drasi.Reactions.Debug.Servers.Models.Unpacked