5

我已经构建了一个HttpInterceptor紧跟 Angular 文档中的那个。

但是,我需要将异步调用作为拦截器的一部分。我用代码的简化版本(但语义相同)创建了一个StackBlitz 。

拦截器看起来像:

export class AuthInterceptor implements HttpInterceptor {
    constructor(private session: SessionService, private config: ConfigurationService) {}

    intercept(req: HttpRequest<any>, next: HttpHandler) {
        const apiRoot = this.config.apiUrl;
        if (apiRoot && req.url.startsWith(apiRoot)) {
            return this.addAuth(req).pipe(switchMap(x => next.handle(x)));
        } else {
            return next.handle(req);
        }
    }

    private addAuth(original: HttpRequest<any>): Observable<HttpRequest<any>> {
        return from(this.session.getToken()).pipe(
            map(token => {
                const req = original.clone({
                    setHeaders: { Authorization: `Bearer ${token}` }
                });
                return req;
            })
        );
    }
}

这很简单:

  • 检查我们调用的 URL 是否需要我们的令牌 ( req.url.startsWith())
  • 如果是,则获取我们的令牌并将其添加为标头
  • 如果没有,只需继续管道

有一个名为的ConfigurationService简单string属性apiUrlSessionService有一个几乎同样简单的名为的方法,getToken()它返回一个Promise<string>.

代码按预期工作: 带有授权标头的响应

但是,我很难测试这个......

我的实际测试很简单:

it('should add authorization header for API call', () => {
    http.get('bar').subscribe();
    httpMock.expectOne(req => req.headers.has('Authorization'));
});

我已经正确地嘲笑了getToken()and apiUrl,所以apiUrl='bar'getToken()返回Promise.resolve('foobar')。问题似乎只是在通过addAuth()路径时。如果我测试反例,它会起作用:

it('should NOT add authorization header for non-API call', () => {
    http.get('baz').subscribe();
    httpMock.expectOne(req => !req.headers.has('Authorization'));
});
4

1 回答 1

2

因此,正如我的评论之一所述,修复似乎是这样的fakeAsync()使用tick()

beforeEach(()=>{
    spyOn(sessionService, 'getToken').and.returnValue(Promise.resolve('foobar'));
});
it('should add authorization header for API call', fakeAsync(() => {
    http.get('bar').subscribe();
    tick();
    httpMock.expectOne(req => req.headers.has('Authorization'));
}));

虽然这是有道理的,但如果有人能澄清我为什么需要tick()......我认为解决承诺就足够了。我确实尝试过使用await http.get().toPromise();(并使用async关键字 - 而不是函数),但这不起作用。

于 2019-02-18T20:57:14.157 回答