Merge branch 'feature/kitchen-service-orchestration' into development

.gitignore

@@ -1,2 +1,4 @@
 .tasks/
 .agile/
+**/bin/
+**/obj/

Directory.Build.props

@@ -0,0 +1,10 @@
+<Project>
+  <PropertyGroup>
+    <Authors>AgileWebs</Authors>
+    <Company>AgileWebs</Company>
+    <RepositoryType>git</RepositoryType>
+    <RepositoryUrl>http://192.168.68.156:3000/AgileWebs/kitchen-service</RepositoryUrl>
+    <PackageProjectUrl>http://192.168.68.156:3000/AgileWebs/kitchen-service</PackageProjectUrl>
+    <PackageRequireLicenseAcceptance>false</PackageRequireLicenseAcceptance>
+  </PropertyGroup>
+</Project>

Kitchen.Service.slnx

@@ -0,0 +1,7 @@
+<Solution>
+  <Folder Name="/src/">
+    <Project Path="src/Kitchen.Service.Application/Kitchen.Service.Application.csproj" />
+    <Project Path="src/Kitchen.Service.Contracts/Kitchen.Service.Contracts.csproj" />
+    <Project Path="src/Kitchen.Service.Grpc/Kitchen.Service.Grpc.csproj" />
+  </Folder>
+</Solution>

src/Kitchen.Service.Application/Kitchen.Service.Application.csproj

@@ -0,0 +1,12 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Kitchen.Service.Contracts\Kitchen.Service.Contracts.csproj" />
+  </ItemGroup>
+</Project>

src/Kitchen.Service.Application/Ports/DefaultKitchenQueueReadPort.cs

@@ -0,0 +1,18 @@
+using Kitchen.Service.Contracts.Contracts;
+using Kitchen.Service.Contracts.Responses;
+
+namespace Kitchen.Service.Application.Ports;
+
+public sealed class DefaultKitchenQueueReadPort : IKitchenQueueReadPort
+{
+    public Task<GetKitchenQueueResponse> ReadQueueAsync(string queueName, int limit, CancellationToken cancellationToken)
+    {
+        var items = new[]
+        {
+            new KitchenQueueItemContract("WK-1001", "PrepareOrder", 3, "Queued"),
+            new KitchenQueueItemContract("WK-1002", "AssembleTray", 2, "Queued")
+        }.Take(Math.Max(limit, 0)).ToArray();
+
+        return Task.FromResult(new GetKitchenQueueResponse(items));
+    }
+}

src/Kitchen.Service.Application/Ports/IKitchenQueueReadPort.cs

@@ -0,0 +1,8 @@
+using Kitchen.Service.Contracts.Responses;
+
+namespace Kitchen.Service.Application.Ports;
+
+public interface IKitchenQueueReadPort
+{
+    Task<GetKitchenQueueResponse> ReadQueueAsync(string queueName, int limit, CancellationToken cancellationToken);
+}

src/Kitchen.Service.Application/UseCases/GetKitchenQueueUseCase.cs

@@ -0,0 +1,13 @@
+using Kitchen.Service.Application.Ports;
+using Kitchen.Service.Contracts.Requests;
+using Kitchen.Service.Contracts.Responses;
+
+namespace Kitchen.Service.Application.UseCases;
+
+public sealed class GetKitchenQueueUseCase(IKitchenQueueReadPort readPort) : IGetKitchenQueueUseCase
+{
+    public Task<GetKitchenQueueResponse> HandleAsync(GetKitchenQueueRequest request, CancellationToken cancellationToken)
+    {
+        return readPort.ReadQueueAsync(request.QueueName, request.Limit, cancellationToken);
+    }
+}

src/Kitchen.Service.Application/UseCases/IGetKitchenQueueUseCase.cs

@@ -0,0 +1,9 @@
+using Kitchen.Service.Contracts.Requests;
+using Kitchen.Service.Contracts.Responses;
+
+namespace Kitchen.Service.Application.UseCases;
+
+public interface IGetKitchenQueueUseCase
+{
+    Task<GetKitchenQueueResponse> HandleAsync(GetKitchenQueueRequest request, CancellationToken cancellationToken);
+}

src/Kitchen.Service.Contracts/Contracts/KitchenQueueItemContract.cs

@@ -0,0 +1,3 @@
+namespace Kitchen.Service.Contracts.Contracts;
+
+public sealed record KitchenQueueItemContract(string WorkItemId, string WorkType, int Priority, string State);

src/Kitchen.Service.Contracts/Kitchen.Service.Contracts.csproj

@@ -0,0 +1,9 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+</Project>

src/Kitchen.Service.Contracts/Requests/GetKitchenQueueRequest.cs

@@ -0,0 +1,3 @@
+namespace Kitchen.Service.Contracts.Requests;
+
+public sealed record GetKitchenQueueRequest(string QueueName, int Limit);

src/Kitchen.Service.Contracts/Responses/GetKitchenQueueResponse.cs

@@ -0,0 +1,5 @@
+using Kitchen.Service.Contracts.Contracts;
+
+namespace Kitchen.Service.Contracts.Responses;
+
+public sealed record GetKitchenQueueResponse(IReadOnlyCollection<KitchenQueueItemContract> Items);

src/Kitchen.Service.Grpc/Kitchen.Service.Grpc.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Kitchen.Service.Application\Kitchen.Service.Application.csproj" />
+    <ProjectReference Include="..\Kitchen.Service.Contracts\Kitchen.Service.Contracts.csproj" />
+  </ItemGroup>
+</Project>

src/Kitchen.Service.Grpc/Program.cs

@@ -0,0 +1,17 @@
+using Kitchen.Service.Application.Ports;
+using Kitchen.Service.Application.UseCases;
+using Kitchen.Service.Contracts.Requests;
+
+var builder = WebApplication.CreateBuilder(args);
+builder.Services.AddSingleton<IKitchenQueueReadPort, DefaultKitchenQueueReadPort>();
+builder.Services.AddSingleton<IGetKitchenQueueUseCase, GetKitchenQueueUseCase>();
+
+var app = builder.Build();
+
+app.MapGet("/internal/kitchen/queue", async (string queueName, int? limit, IGetKitchenQueueUseCase useCase, CancellationToken ct) =>
+{
+    var request = new GetKitchenQueueRequest(queueName, limit ?? 20);
+    return Results.Ok(await useCase.HandleAsync(request, ct));
+});
+
+app.Run();

src/Kitchen.Service.Grpc/Properties/launchSettings.json

@@ -0,0 +1,23 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:0",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:0;http://localhost:0",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

src/Kitchen.Service.Grpc/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

src/Kitchen.Service.Grpc/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}