C# Refit 客户端不发送授权 header

Question

我正在使用 C# Refit客户端让我的服务通过 http 相互通信。

我正在尝试通过 Authorization header 发送 Bearer token ，但根据错误消息，它没有在请求中设置 AZ header (见底部)。我已经尝试通过提供所有 header 并使用 [Authorize] 属性以及他们在自述文件中描述的所有其他方法来设置它。

这是我的 Refit 客户端 api 调用定义:

[Post(PresentationsBasePath + "/{presentationId}/cart")]
Task AddItemToCartAsync(long presentationId, ShoppingCartItemView item, [HeaderCollection] IDictionary<string, string> headers);

//calling it here:

await _api.AddItemToCartAsync(presentationId, item, GetTokenHeader(presentationId, token));

private Dictionary<string, string> GetTokenHeader(long presentationId, string token) => new()
{
    ["pres_id"] = presentationId.ToString(),
    [HeaderNames.Authorization] = $"Bearer {token}",
};

但是，我得到了 401，并且查看抛出的 Refit.ApiException，RequestMessage.Headers 不包含 Authorization header 。

下面是我如何注册 retrofit api IPresentationsApi。我没有在 DI 配置中做任何与身份验证相关的事情

var refitSettings = GetRefitSettings();

void Configure<T>() where T : class => services
    .AddRefitClient<T>()
    .ConfigureHttpClient(ConfigureHttpClient);

Configure<IMarsPresentationApi>();
//other apis configured below

    
    private static void ConfigureHttpClient(IServiceProvider sp, HttpClient client)
    {
        var config = sp.GetRequiredService<IMarsConfiguration>();
        if (config.BaseUrl == null)
            throw new InvalidOperationException("Mars:BaseUrl must be configured");
        client.BaseAddress = new Uri(config.BaseUrl);
    }

此处显示的错误 - 您可以看到我收到 401，并且请求中未设置 AZ header :

我做错了什么？如何让它发送 AZ header ？

Answer 1

第一次尝试:

services.AddRefitClient<T>(new RefitSettings { AuthorizationHeaderValueGetter = () => Task.FromResult("TestToken") }).ConfigureHttpClient(ConfigureHttpClient);

第二次尝试:

services.AddRefitClient<T>().ConfigureHttpClient(ConfigureHttpClient).AddHttpMessageHandler<AuthorizationMessageHandler>();

哪里:

  public class AuthorizationMessageHandler : DelegatingHandler
  {
    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancelToken)
    {
      HttpRequestHeaders headers = request.Headers;

      AuthenticationHeaderValue authHeader = headers.Authorization;

      if (authHeader != null)
        headers.Authorization = new AuthenticationHeaderValue(authHeader.Scheme, "TestToken");
        
      return await base.SendAsync(request, cancelToken);
    }
  }