feat(furniture-service): wire grpc runtime and dal port adapters

src/Furniture.Service.Application/Adapters/FurnitureAvailabilityContractAdapter.cs

@@ -0,0 +1,56 @@
+using BuildingBlock.Catalog.Contracts.Conventions;
+using BuildingBlock.Catalog.Contracts.Products;
+using BuildingBlock.Catalog.Contracts.Responses;
+using BuildingBlock.Inventory.Contracts.Conventions;
+using BuildingBlock.Inventory.Contracts.Requests;
+using BuildingBlock.Inventory.Contracts.Responses;
+using Furniture.Service.Contracts.UseCases;
+
+namespace Furniture.Service.Application.Adapters;
+
+/// <summary>
+/// Default adapter implementation for furniture service contract composition.
+/// </summary>
+public sealed class FurnitureAvailabilityContractAdapter : IFurnitureAvailabilityContractAdapter
+{
+    private const string ContractVersion = "1.0.0";
+
+    /// <inheritdoc />
+    public InventoryItemLookupRequest ToInventoryRequest(GetFurnitureAvailabilityRequest request)
+    {
+        return new InventoryItemLookupRequest(
+            new InventoryContractEnvelope(ContractVersion, ResolveCorrelationId(request.CorrelationId)),
+            request.FurnitureId);
+    }
+
+    /// <inheritdoc />
+    public ProductContract ToCatalogRequest(GetFurnitureAvailabilityRequest request)
+    {
+        return new ProductContract(
+            new CatalogContractEnvelope(ContractVersion, ResolveCorrelationId(request.CorrelationId)),
+            request.FurnitureId,
+            string.Empty);
+    }
+
+    /// <inheritdoc />
+    public GetFurnitureAvailabilityResponse ToServiceResponse(
+        GetFurnitureAvailabilityRequest request,
+        ProductContractResponse catalogResponse,
+        InventoryItemLookupResponse inventoryResponse)
+    {
+        return new GetFurnitureAvailabilityResponse(
+            request.FurnitureId,
+            catalogResponse.DisplayName,
+            inventoryResponse.QuantityAvailable);
+    }
+
+    private static string ResolveCorrelationId(string correlationId)
+    {
+        if (!string.IsNullOrWhiteSpace(correlationId))
+        {
+            return correlationId;
+        }
+
+        return $"corr-{Guid.NewGuid():N}";
+    }
+}

src/Furniture.Service.Application/Adapters/FurnitureAvailabilityGrpcContractAdapter.cs

@@ -0,0 +1,36 @@
+using Furniture.Service.Application.Grpc;
+using Furniture.Service.Contracts.UseCases;
+
+namespace Furniture.Service.Application.Adapters;
+
+/// <summary>
+/// Default adapter implementation for furniture service gRPC contract translation.
+/// </summary>
+public sealed class FurnitureAvailabilityGrpcContractAdapter : IFurnitureAvailabilityGrpcContractAdapter
+{
+    /// <inheritdoc />
+    public GetFurnitureAvailabilityGrpcContract ToGrpc(GetFurnitureAvailabilityRequest request)
+    {
+        return new GetFurnitureAvailabilityGrpcContract(
+            request.FurnitureId,
+            ResolveCorrelationId(request.CorrelationId));
+    }
+
+    /// <inheritdoc />
+    public GetFurnitureAvailabilityRequest FromGrpc(GetFurnitureAvailabilityGrpcContract contract)
+    {
+        return new GetFurnitureAvailabilityRequest(
+            contract.FurnitureId,
+            ResolveCorrelationId(contract.CorrelationId));
+    }
+
+    private static string ResolveCorrelationId(string correlationId)
+    {
+        if (!string.IsNullOrWhiteSpace(correlationId))
+        {
+            return correlationId;
+        }
+
+        return $"corr-{Guid.NewGuid():N}";
+    }
+}

src/Furniture.Service.Application/DependencyInjection/FurnitureServiceRuntimeServiceCollectionExtensions.cs

@@ -0,0 +1,34 @@
+using Core.Blueprint.Common.DependencyInjection;
+using Furniture.DAL.DependencyInjection;
+using Furniture.Service.Application.Adapters;
+using Furniture.Service.Application.Ports;
+using Furniture.Service.Application.UseCases;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+
+namespace Furniture.Service.Application.DependencyInjection;
+
+/// <summary>
+/// Registers furniture-service runtime orchestration and DAL adapters.
+/// </summary>
+public static class FurnitureServiceRuntimeServiceCollectionExtensions
+{
+    /// <summary>
+    /// Adds furniture-service runtime wiring aligned with blueprint runtime and furniture-dal runtime.
+    /// </summary>
+    /// <param name="services">Service collection.</param>
+    /// <returns>Service collection for fluent chaining.</returns>
+    public static IServiceCollection AddFurnitureServiceRuntime(this IServiceCollection services)
+    {
+        services.AddBlueprintRuntimeCore();
+        services.AddFurnitureDalRuntime();
+
+        services.TryAddSingleton<IFurnitureAvailabilityContractAdapter, FurnitureAvailabilityContractAdapter>();
+        services.TryAddSingleton<IFurnitureAvailabilityGrpcContractAdapter, FurnitureAvailabilityGrpcContractAdapter>();
+        services.TryAddSingleton<IFurnitureAvailabilityReadPort, FurnitureAvailabilityReadPortDalAdapter>();
+        services.TryAddSingleton<ICatalogProductReadPort, CatalogProductReadPortDalAdapter>();
+        services.TryAddSingleton<IGetFurnitureAvailabilityUseCase, GetFurnitureAvailabilityUseCase>();
+
+        return services;
+    }
+}

src/Furniture.Service.Application/Furniture.Service.Application.csproj

@@ -5,8 +5,10 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
   <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="10.0.0" />
     <ProjectReference Include="..\..\..\building-block-catalog\src\BuildingBlock.Catalog.Contracts\BuildingBlock.Catalog.Contracts.csproj" />
     <ProjectReference Include="..\..\..\building-block-inventory\src\BuildingBlock.Inventory.Contracts\BuildingBlock.Inventory.Contracts.csproj" />
+    <ProjectReference Include="..\..\..\furniture-dal\src\Furniture.DAL\Furniture.DAL.csproj" />
     <ProjectReference Include="..\Furniture.Service.Contracts\Furniture.Service.Contracts.csproj" />
   </ItemGroup>
 </Project>

src/Furniture.Service.Application/Ports/CatalogProductReadPortDalAdapter.cs

@@ -0,0 +1,38 @@
+using BuildingBlock.Catalog.Contracts.Conventions;
+using BuildingBlock.Catalog.Contracts.Products;
+using BuildingBlock.Catalog.Contracts.Responses;
+using Furniture.DAL.Contracts;
+using Furniture.DAL.Repositories;
+
+namespace Furniture.Service.Application.Ports;
+
+/// <summary>
+/// Default DAL adapter for catalog product read port.
+/// </summary>
+public sealed class CatalogProductReadPortDalAdapter(ICatalogRepository catalogRepository) : ICatalogProductReadPort
+{
+    /// <inheritdoc />
+    public async Task<ProductContractResponse> ReadProductAsync(ProductContract request)
+    {
+        var lookupRequest = new CatalogProductLookupRequest(
+            new FurnitureDalContractEnvelope(
+                request.Envelope.ContractVersion,
+                request.Envelope.CorrelationId),
+            request.ProductId);
+
+        var projectionRecord = await catalogRepository.ReadProductAsync(lookupRequest);
+        if (projectionRecord is null)
+        {
+            return new ProductContractResponse(request.Envelope, request.ProductId, string.Empty);
+        }
+
+        var responseEnvelope = new CatalogContractEnvelope(
+            projectionRecord.Envelope.ContractVersion,
+            projectionRecord.Envelope.CorrelationId);
+
+        return new ProductContractResponse(
+            responseEnvelope,
+            projectionRecord.ProductId,
+            projectionRecord.DisplayName);
+    }
+}

src/Furniture.Service.Application/Ports/FurnitureAvailabilityReadPortDalAdapter.cs

@@ -0,0 +1,39 @@
+using BuildingBlock.Inventory.Contracts.Conventions;
+using BuildingBlock.Inventory.Contracts.Requests;
+using BuildingBlock.Inventory.Contracts.Responses;
+using Furniture.DAL.Contracts;
+using Furniture.DAL.Repositories;
+
+namespace Furniture.Service.Application.Ports;
+
+/// <summary>
+/// Default DAL adapter for furniture availability read port.
+/// </summary>
+public sealed class FurnitureAvailabilityReadPortDalAdapter(
+    IFurnitureRepository furnitureRepository) : IFurnitureAvailabilityReadPort
+{
+    /// <inheritdoc />
+    public async Task<InventoryItemLookupResponse> ReadAvailabilityAsync(InventoryItemLookupRequest request)
+    {
+        var lookupRequest = new FurnitureAvailabilityLookupRequest(
+            new FurnitureDalContractEnvelope(
+                request.Envelope.ContractVersion,
+                request.Envelope.CorrelationId),
+            request.ItemCode);
+
+        var availabilityRecord = await furnitureRepository.ReadAvailabilityAsync(lookupRequest);
+        if (availabilityRecord is null)
+        {
+            return new InventoryItemLookupResponse(request.Envelope, request.ItemCode, 0);
+        }
+
+        var responseEnvelope = new InventoryContractEnvelope(
+            availabilityRecord.Envelope.ContractVersion,
+            availabilityRecord.Envelope.CorrelationId);
+
+        return new InventoryItemLookupResponse(
+            responseEnvelope,
+            availabilityRecord.FurnitureId,
+            availabilityRecord.QuantityAvailable);
+    }
+}

src/Furniture.Service.Grpc/Furniture.Service.Grpc.csproj

@@ -4,6 +4,16 @@
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
   </PropertyGroup>
+  <ItemGroup>
+    <PackageReference Include="Grpc.AspNetCore" Version="2.71.0" />
+    <PackageReference Include="Grpc.Tools" Version="2.71.0">
+      <PrivateAssets>all</PrivateAssets>
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+    </PackageReference>
+  </ItemGroup>
+  <ItemGroup>
+    <Protobuf Include="Protos\furniture_runtime.proto" GrpcServices="Server" />
+  </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\Furniture.Service.Application\Furniture.Service.Application.csproj" />
     <ProjectReference Include="..\Furniture.Service.Contracts\Furniture.Service.Contracts.csproj" />

src/Furniture.Service.Grpc/Program.cs

@@ -1,6 +1,15 @@
+using Furniture.Service.Application.DependencyInjection;
+using Furniture.Service.Grpc.Services;
+
 var builder = WebApplication.CreateBuilder(args);
 
-// Stage 3 skeleton: keep a single active internal protocol policy (gRPC-first).
+builder.Services.AddGrpc();
+builder.Services.AddHealthChecks();
+builder.Services.AddFurnitureServiceRuntime();
+
 var app = builder.Build();
 
+app.MapGrpcService<FurnitureRuntimeGrpcService>();
+app.MapHealthChecks("/healthz");
+
 app.Run();

src/Furniture.Service.Grpc/Protos/furniture_runtime.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+
+option csharp_namespace = "Furniture.Service.Grpc";
+
+package furniture.service.grpc;
+
+service FurnitureRuntime {
+  rpc GetFurnitureAvailability (GetFurnitureAvailabilityGrpcRequest) returns (GetFurnitureAvailabilityGrpcResponse);
+}
+
+message GetFurnitureAvailabilityGrpcRequest {
+  string furniture_id = 1;
+  string correlation_id = 2;
+}
+
+message GetFurnitureAvailabilityGrpcResponse {
+  string furniture_id = 1;
+  string display_name = 2;
+  int32 quantity_available = 3;
+}

src/Furniture.Service.Grpc/Services/FurnitureRuntimeGrpcService.cs

@@ -0,0 +1,39 @@
+using Grpc.Core;
+using Furniture.Service.Application.Adapters;
+using Furniture.Service.Application.Grpc;
+using Furniture.Service.Application.UseCases;
+
+namespace Furniture.Service.Grpc.Services;
+
+/// <summary>
+/// Internal gRPC endpoint implementation for furniture runtime operations.
+/// </summary>
+public sealed class FurnitureRuntimeGrpcService(
+    IGetFurnitureAvailabilityUseCase getFurnitureAvailabilityUseCase,
+    IFurnitureAvailabilityGrpcContractAdapter grpcContractAdapter) : FurnitureRuntime.FurnitureRuntimeBase
+{
+    /// <summary>
+    /// Executes furniture availability lookup through service use-case orchestration.
+    /// </summary>
+    /// <param name="request">gRPC availability request.</param>
+    /// <param name="context">gRPC server call context.</param>
+    /// <returns>gRPC availability response.</returns>
+    public override async Task<GetFurnitureAvailabilityGrpcResponse> GetFurnitureAvailability(
+        GetFurnitureAvailabilityGrpcRequest request,
+        ServerCallContext context)
+    {
+        var grpcContract = new GetFurnitureAvailabilityGrpcContract(
+            request.FurnitureId,
+            request.CorrelationId);
+
+        var useCaseRequest = grpcContractAdapter.FromGrpc(grpcContract);
+        var useCaseResponse = await getFurnitureAvailabilityUseCase.HandleAsync(useCaseRequest);
+
+        return new GetFurnitureAvailabilityGrpcResponse
+        {
+            FurnitureId = useCaseResponse.FurnitureId,
+            DisplayName = useCaseResponse.DisplayName,
+            QuantityAvailable = useCaseResponse.QuantityAvailable
+        };
+    }
+}

tests/Furniture.Service.Application.UnitTests/Furniture.Service.Application.UnitTests.csproj

@@ -7,6 +7,7 @@
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="coverlet.collector" Version="6.0.4" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="10.0.0" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.14.1" />
     <PackageReference Include="xunit" Version="2.9.3" />
     <PackageReference Include="xunit.runner.visualstudio" Version="3.1.4" />

tests/Furniture.Service.Application.UnitTests/RuntimeWiringTests.cs

@@ -0,0 +1,51 @@
+using Furniture.Service.Application.Adapters;
+using Furniture.Service.Application.DependencyInjection;
+using Furniture.Service.Application.Grpc;
+using Furniture.Service.Application.UseCases;
+using Furniture.Service.Contracts.UseCases;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace Furniture.Service.Application.UnitTests;
+
+public class RuntimeWiringTests
+{
+    [Fact]
+    public async Task AddFurnitureServiceRuntime_WhenInvoked_ResolvesUseCase()
+    {
+        var services = new ServiceCollection();
+        services.AddFurnitureServiceRuntime();
+
+        using var provider = services.BuildServiceProvider();
+        var useCase = provider.GetRequiredService<IGetFurnitureAvailabilityUseCase>();
+
+        var response = await useCase.HandleAsync(new GetFurnitureAvailabilityRequest("FUR-001", "corr-123"));
+
+        Assert.Equal("FUR-001", response.FurnitureId);
+        Assert.Equal(8, response.QuantityAvailable);
+    }
+
+    [Fact]
+    public void FurnitureAvailabilityGrpcContractAdapter_WhenMapped_PreservesValues()
+    {
+        var adapter = new FurnitureAvailabilityGrpcContractAdapter();
+        var request = new GetFurnitureAvailabilityRequest("FUR-002", "corr-456");
+
+        var grpcContract = adapter.ToGrpc(request);
+        var roundtrip = adapter.FromGrpc(grpcContract);
+
+        Assert.Equal("FUR-002", roundtrip.FurnitureId);
+        Assert.Equal("corr-456", roundtrip.CorrelationId);
+    }
+
+    [Fact]
+    public void FurnitureAvailabilityGrpcContractAdapter_WhenCorrelationMissing_GeneratesCorrelation()
+    {
+        var adapter = new FurnitureAvailabilityGrpcContractAdapter();
+        var grpcContract = new GetFurnitureAvailabilityGrpcContract("FUR-003", string.Empty);
+
+        var mapped = adapter.FromGrpc(grpcContract);
+
+        Assert.Equal("FUR-003", mapped.FurnitureId);
+        Assert.NotEmpty(mapped.CorrelationId);
+    }
+}