Dapr Getting started: Setting up Service with Grpc and Http/1

[bobo-byte]

I have followed the HTTP/1 client sample in this commit. However, I'm still having trouble getting it to work with gRPC. I've successfully set up the server and the client using .proto files, but the client's requests are not being processed (Internal Server Error). I suspect this is because the default protocol is HTTP, and I either need to call the client using the gRPC endpoint or, in some cases, create an interceptor to send additional metadata for the routing service.

Is there a recommended approach that is guaranteed to work with Aspire? It would be helpful for others participating in this discussion, especially since the documentation is still relatively new and the sample projects often employ similar setups that do not function well with gRPC clients generated from protobuf files.

My current code setup samples:

AppHost

using CommunityToolkit.Aspire.Hosting.Dapr;
using System.Security.Cryptography;

var builder = DistributedApplication.CreateBuilder(args);

var stateStore = builder.AddDaprStateStore("statestore");
var pubSub = builder.AddDaprPubSub("pubsub");

var bytes = new byte[50];
RandomNumberGenerator.Fill(bytes);
var daprApiKey = string.Join("", bytes.Select(b => b.ToString("x2")));

builder.AddProject<Projects.TestService1>("service1")
    .WithDaprSidecar(b => b.WithOptions(new DaprSidecarOptions(){Config = $"../{nameof(Projects.TestService1)}/resources/dapr/config.yaml",}).WithAnnotation(new EnvironmentCallbackAnnotation("APP_API_TOKEN", () => daprApiKey)))
    .WithReference(stateStore)
    .WithEnvironment("APP_API_TOKEN", daprApiKey)
    .WithReference(pubSub);

builder.AddProject<Projects.TestService2>("service2")
    .WithDaprSidecar(b => b.WithOptions(new DaprSidecarOptions(){Config = $"../{nameof(Projects.TestService2)}/resources/dapr/config.yaml",}).WithAnnotation(new EnvironmentCallbackAnnotation("APP_API_TOKEN", () => daprApiKey)))
    .WithReference(stateStore)
    .WithEnvironment("APP_API_TOKEN", daprApiKey)
    .WithReference(pubSub);
 // ...
}

Service 1 (Server)

using Dapr.Client;
using Grpc.Core;
using Grpc.Net.Client;
using Microsoft.AspNetCore.Authentication;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using TestService1.Clients;
using TestService2;

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.
// Learn more about configuring OpenAPI at https://aka.ms/aspnet/openapi
builder.Services.AddOpenApi();
builder.Services.AddDaprClient();

// Adds Dapr authentication. By default, the token will be read from the APP_API_TOKEN environment variable.
builder.Services.AddAuthentication().AddDapr();

builder.Services.AddAuthorization(options =>
{
    // Adds Dapr authorization. The authentication scheme is "Dapr."
    options.AddDapr();
});

var invoker = DaprClient.CreateInvocationInvoker(appId: "service2", daprApiToken:Environment.GetEnvironmentVariable("APP_API_TOKEN"));
var greetClient = new Greeter.GreeterClient(invoker);

builder.Services.AddSingleton<Greeter.GreeterClient>(greetClient);

var app = builder.Build();

// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
    app.MapOpenApi();
}

app.UseHttpsRedirection();

app.MapGet("/weatherforecast", async (DaprClient client, [FromQuery] int pageSize = 10) =>
    {
        return await new WeatherClient(client).GetWeatherForecastAsync(pageSize);
    })
    .WithName("GetWeatherForecast");

app.MapGet("/greet", async (DaprClient client, [FromQuery] string name) =>
    {
        return await client.InvokeMethodGrpcAsync<HelloRequest, HelloReply>("service2", "SayHello", new HelloRequest { Name = name });
        //return await client.SayHelloAsync(new HelloRequest() { Name = name });
    })
    .WithName("GetGreet");

app.Run();

public record WeatherForecast(DateOnly Date, int TemperatureC, string? Summary)
{
    public int TemperatureF => 32 + (int)(TemperatureC / 0.5556);
}
//...

Service 1 project file

<Project Sdk="Microsoft.NET.Sdk.Web">

    <PropertyGroup>
        <TargetFramework>net9.0</TargetFramework>
        <Nullable>enable</Nullable>
        <ImplicitUsings>enable</ImplicitUsings>
    </PropertyGroup>

    <ItemGroup>
        <PackageReference Include="Dapr.AspNetCore" Version="1.15.2" />
        <PackageReference Include="Dapr.Client" Version="1.15.2" />
        <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.2"/>
        <PackageReference Include="Grpc.Tools" Version="2.36.1">
            <PrivateAssets>all</PrivateAssets>
            <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
        </PackageReference>
    </ItemGroup>

    <ItemGroup>
        <Protobuf Include="../TestService2/resources/protos/greet.proto" GrpcServices="Server,Client" />
    </ItemGroup>
</Project>

Service 2 (Client<->Server)

using Grpc.Net.Client;
using Microsoft.AspNetCore.Authentication;
using Microsoft.AspNetCore.Authorization;
using System.Reflection;
using TestService2.Controllers.GRPC;

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.
// Learn more about configuring OpenAPI at https://aka.ms/aspnet/openapi
builder.Services.AddOpenApi();
builder.Services.AddDaprClient();
builder.Services.AddGrpc();
builder.Services.AddControllers();

// Adds Dapr authentication. By default, the token will be read from the APP_API_TOKEN environment variable.
builder.Services.AddAuthentication().AddDapr();

builder.Services.AddAuthorization(options =>
{
    // Adds Dapr authorization. Authentication scheme is "Dapr"
    options.AddDapr();
});


var app = builder.Build();

// Configure the HTTP request pipeline.
if (app.Environment.IsDevelopment())
{
    app.MapOpenApi();
}

app.UseAuthentication();
app.UseAuthorization();

//app.UseHttpsRedirection();

//app.UseRouting();

app.MapGrpcService<GreeterService>();

app.MapGet("/", () => "Communication with gRPC endpoints must be made through a gRPC client. To learn how to create a client, visit: https://go.microsoft.com/fwlink/?linkid=2086909");

app.MapControllers();

app.Run();

Service 2 project file

<Project Sdk="Microsoft.NET.Sdk.Web">

    <PropertyGroup>
        <TargetFramework>net9.0</TargetFramework>
        <Nullable>enable</Nullable>
        <ImplicitUsings>enable</ImplicitUsings>
    </PropertyGroup>

    <ItemGroup>
        <PackageReference Include="Dapr.AspNetCore" Version="1.15.2" />
        <PackageReference Include="Grpc.AspNetCore.Server" Version="2.70.0" />
        <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.2"/>
        <PackageReference Include="Grpc.Tools" Version="2.36.1">
            <PrivateAssets>all</PrivateAssets>
            <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
        </PackageReference>
    </ItemGroup>

    <ItemGroup>
        <Protobuf Include="resources/protos/greet.proto" GrpcServices="Server,Client" />
    </ItemGroup>

</Project>

Client (Browser) Requests Server 2, which requests Server 1

Latest error with this setup:

RpcException: Status(StatusCode="Internal", Detail: "failed to invoke, id: service2, err: rpc error: code = Internal desc = error invoking app channel: rpc error: code = InvalidArgument desc = missing HTTP extension field")

InvocationException: An exception occurred while invoking method: 'SayHello' on app-id: 'service2'
Dapr.Client.DarpClientGrpc.InvokeMethodGrpcAsync<TRequest, TResponse>(string appId, string methodName, TRequest data, CancellationToken cancellationToken)