1

在文档(https://www.apollographql.com/docs/angular/recipes/authentication/)中有一个例子。但是,如果您有一个 angular-apollo watch().valueChanges 或 fetch() 作为返回的 Observable,这不起作用...

我的代码是:

const auth = setContext(async (_, {headers}) => {
      let token = authService.getAccessToken();

      if (!authService.hasValidAccessToken()) {
        if (authService.hasRefreshToken()) {
         
          await this.authService.refreshToken().pipe(first()).toPromise(); //Does not work...
          
          token = authService.getAccessToken();
        }
      }
      // Return the headers as usual
      return {
        headers: {
          Authorization: `Bearer ${token}`,
        },
      };
    });

authService.refreshToken() 方法返回这个:

refreshToken(): Observable<any> {
    this.removeAccessToken();
    if (this.hasRefreshToken()) {
      return this.refreshGQL.fetch({
         refreshToken: this.getRefreshToken()
      }).pipe(
        tap(next => {
            this.storeTokens(next.data.refresh);
          }
        )
      );
}

问题是,不能调用订阅,这将启动 Observable。你有解决方案吗?

4

1 回答 1

0

好的,它与 await for promise 和 observable to promise 无关。这是完全正确的。

这只是一个典型的僵局。

如果没有有效的访问令牌,它将尝试接收一个新的令牌,从而产生一个 gql 请求,它也没有有效的访问令牌,它将尝试在每个 gql 请求等中接收一个新的令牌......

如果操作名称等于刷新突变或查询,只需跳过逻辑即可解决。

于 2020-04-17T19:10:28.043 回答