RxJS 是一个比Promises 更灵活、更强大的异步编程框架。话虽如此,在使用 Firebase API 时使用 Observables 或 Promises 是一个偏好问题。
AngularFire 的开发目的是让 Firebase 更容易集成到 Angular 项目中。 AngularFire API 使用Observables 而不是Promises,因为RXJS 是事实上的Angular 异步编程标准。
如果您想为 Firebase 提供自己的 RXJS API,一种选择是创建 Angular 服务。下面的示例展示了如何包装 Firebase 函数 signInWithCustomToken,该函数返回 Promise<UserCredential>,并将其转换为返回 Observable<UserCredential>。
firebase-auth.service.ts
import { Injectable, Optional } from '@angular/core'
import { HttpClient } from '@angular/common/http'
import * as firebase from 'firebase/app'
import 'firebase/auth'
import { BehaviorSubject } from 'rxjs'
import { concatMap } from 'rxjs/operators'
@Injectable({
providedIn: 'root'
})
export class FirebaseAuthService {
public app: firebase.app.App;
public auth: firebase.auth.Auth;
public user$: BehaviorSubject<firebase.User> = new BehaviorSubject(null);
// Note: FirebaseConfig is a class to enable injecting the Firebase app
// initialization params when providing the service in app.module.ts.
constructor(@Optional() fb_config: FirebaseConfig, private http: HttpClient) {
// https://firebase.google.com/docs/reference/js/firebase.app.App
this.app = firebase.initializeApp(fb_config);
this.auth = firebase.auth(this.app);
this.auth.onAuthStateChanged(
(user: firebase.User) => {
if (user) {
this.user$.next(user);
console.log('User signed in');
} else {
this.user$.next(null);
console.log('User signed out');
}
},
(error: firebase.auth.Error) => {
// handle error
}
)
}
public signInWithCustomToken(uid: string, secret_auth_code: string):
Observable<firebase.auth.UserCredential> {
const params = new HttpParams()
.set('uid', uid)
.set('secret', secret_auth_code)
return this.http.get('/get-custom-token', {params: params}).pipe(
concatMap((json: any) => from(this.auth.signInWithCustomToken(json['custom_token'])))
)
}
// ...
}
组件
@Component({
moduleId: module.id,
selector: 'my-component',
templateUrl: 'my.component.html',
styleUrls: ['my.component.css']
})
export class MyComponent implements OnInit {
constructor(private authService: FirebaseAuthService) {}
// ...
}
模板
<ng-container *ngIf="( authService.user$ | async ) as user">
<div>Hello {{user.displayName}}</div>
</ng-container>