异步拦截器（gRPC Dart）

Question

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

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

- Batangaming

Answer 1

经过一些搜索，我发现MetadataProvider返回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()]);

- Batangaming