从具有 Angular 2 http 调用的函数返回 Promise，该函数返回一个 Observable

Question

我的服务中有一个方法可以从存储中读取令牌并返回一个承诺。

getToken() {
 return this.storage.get('access_token');
}

（storage.get 返回一个承诺）

我需要修改上述方法，使其首先从存储中读取访问令牌并检查其是否过期，如果未过期则立即返回，如果过期则从存储中读取 refresh_token 即 this.storage.get('refresh_token' ) 再次返回一个承诺，在检查它是否未过期后，我需要使用 Angular 2 http.post 向我的 api 发出 http 请求，这将返回一个新的访问令牌。一旦收到新的访问令牌，getToken 函数就会返回。

我虽然下面会工作，但它没有：

getToken() {
        var promise = new Promise(function (resolve, reject) {
            this.storage.get('access_token').then((accessToken) => {
                //check if the token is expired
                if (accessToken) {
                    if (!this.isExpired(accessToken)) {
                        resolve(accessToken);
                    }
                    else {
                        this.storage.get('refresh_token').then((refreshToken) => {
                            if (!this.isExpired(refreshToken)) {
                                this.http.post('/api/refresh/', { token:refreshToken })
                                    .subscribe((data) => {
                                        resolve(data);
                                    });
                            }
                            else {
                                resolve(null);
                            }
                        });
                    }
                } else {
                    resolve(null);
                }
            });
        });

        return promise;
    }

谁能指导一下，如何做到这一点？

Answer 1

我在你的回调function 中向你打赌have the wrong this，你将传递给new Promise 构造函数。

您也可以在那里使用箭头函数，或者您只需 avoid the promise construction antipattern 并完全删除它：

getToken() {
    return this.storage.get('access_token').then(accessToken => {
        if (!accessToken)
            return null;
        else if (!this.isExpired(accessToken))
            return accessToken;
        else
            return this.storage.get('refresh_token').then(refreshToken => {
                if (this.isExpired(refreshToken))
                     return null;
                else
                     return promiseFromObservable(this.http.post('/api/refresh/', { token:refreshToken }));
            });
    });
}

function promiseFromObservable(o) {
    return new Promise(resolve => o.subscribe(resolve));
}