异步拦截器 (gRPC dart)

Question

我正在为 dart 使用 gRPC 生成的客户端，我需要向每个请求添加 Authorization header。我知道有 ClientInterceptor 但我想问一下是否有任何方法可以在拦截器的方法中调用异步方法，因为我有这个用于检索令牌的异步方法：

static Future<String> getToken() async {
   final CognitoAuthSession session = await Amplify.Auth.fetchAuthSession(
     options: CognitoSessionOptions(getAWSCredentials: true)
   );
   return session.userPoolTokens.idToken;
}

Answer 1

经过更多谷歌搜索后，我发现 MetadataProvider return FutureOr<void>，因此您可以调用异步方法。

最终拦截器的代码

class AuthenticationInterceptor extends ClientInterceptor {
  FutureOr<void> _provider(Map<String, String> metadata, String uri) async {
    final token = await AuthenticationService.getToken();
    metadata['Authorization'] = "Bearer $token";
  }

  @override
  ResponseFuture<R> interceptUnary<Q, R>(ClientMethod<Q, R> method, Q request, CallOptions options, invoker) {
    return super.interceptUnary(
        method,
        request,
        options.mergedWith(CallOptions(providers: [_provider])),
        invoker
    );
  }
}

而且你可以像这样使用它

final client = YourGrpcClient(clientChannel, interceptors: [AuthenticationInterceptor()]);

异步拦截器 (gRPC dart)

Async interceptors (gRPC dart)

dart

grpc