Estoy usando AngularFire para administrar usuarios dentro de mi aplicación. Todavía estoy aprendiendo sobre observables y rxjs.
Estoy tratando de llamar al método signInWithEmailAndPassword , que devuelve una promesa, y recuperar un documento de una colección.
En mi servicio obtengo el documento usando este método:
getDbUser(uid): Observable<User> { return this.angularFirestore.collection<User>(USERS).doc(uid).valueChanges() }y entro como usuario con:
login(user: User) { // sign in con email e password return this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password) .then((result) => { if(result.user?.uid) { // get user doc return this.getDbUser(result.user.uid); } return null; }); }Con este código, llamar al método de inicio de sesión requiere resolver una promesa y luego suscribirse al observable, así:
this.userService.login(this.loginUser) .then((userObs) => { userObs.subscribe((user) => { console.log(user); }); }) Realmente me gustaría evitar esto, pero no estoy seguro de cómo hacerlo. Intenté usar el operador RxJs toPromise :
login(user: User) { // sign in con email e password return this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password) .then((result) => { if(result.user?.uid) { // recupero l'utente dal db return this.getDbUser(result.user.uid).toPromise(); } return null; }); }pero de alguna manera esto no funciona (la promesa nunca se resuelve).
La razón por la que toPromise() no funciona porque el observable permanece abierto. Use el primer operador o, si usa una versión posterior de rxjs, firstValueFrom . Lea más sobre esto en Conversion to Promises de la documentación de rxjs.
Dado que está utilizando valueChanges en lugar de get , entonces tal vez su intención sea mantener abierto el observable. Si ese es el caso, lo mejor que puede hacer es convertir el inicio de sesión en un observable usando from .
login(user: User) { return from(this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password)).pipe( switchMap(res => (res.user.uid) ? this.getDbuser(res.user.uid) : of(null)) ); }El primer comentario es la respuesta correcta:
Puede agregar
.pipe(first())antes.toPromise"
Si desea informar a cualquier consumidor observable que un usuario acaba de iniciar sesión solo después de que signInWithEmailAndPassword () haya regresado, me gustaría marcar un asunto y suscribirme al usuario $ de cualquier consumidor de servicio.
private userSubject$:Subject<string>=new Subject<string>(); public user$:Observable<string>=this.userSubject$.asObservable(); login(user: User) { // sign in con email e password return this.angularFireAuth.signInWithEmailAndPassword(user.email, user.password) .then((result) => { if(result.user?.uid) { // recupero l'utente dal db return this.userSubject$.next(result.user.uid); } return null; });} y desde fuera usarás el servicio:
this.userService.login(this.loginUser); this.userService.user$.subscribe(user=>console.log);