NGRX Entity Effects Firestore - PullRequest
Новая
       36

NGRX Entity Effects Firestore

0 голосов
/ 28 октября 2018

Я следую этому уроку https://www.concretepage.com/angular-2/ngrx/ngrx-entity-example. У меня теперь Firestore в качестве моего бэкэнда. Я могу получить «LOAD_ALL_ARTICLES» из Firestore. Но мой код ломается, когда я пытаюсь прослушать действие «ДОБАВИТЬ». Есть идеи, пожалуйста?! 

import { Injectable } from '@angular/core';
import { Action } from '@ngrx/store';
import { Actions, Effect } from '@ngrx/effects';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/switchMap';
import 'rxjs/add/observable/fromPromise';
import 'rxjs/add/operator/mergeMap';
import * as fromActions from '../actions/article.actions';
import * as fromReducer from '../reducers/article.reducer';



//import { ArticleService } from '../services/article.service';
import { Article } from '../models/article';

import { AngularFirestore, AngularFirestoreCollection, AngularFirestoreDocument } from 'angularfire2/firestore';

@Injectable()
export class ArticleEffects {

  constructor(
    private actions$: Actions,
    private afs: AngularFirestore
  ) {}

  @Effect()
  loadAllArticles$: Observable<Action> = this.actions$
    .ofType(fromActions.ArticleActionTypes.LOAD_ALL_ARTICLES)
    .switchMap(() =>
      const ref = this.afs.collection<Article>('articles');
      return ref.snapshotChanges().map(arr => {
      return arr.map(action => {
        const data = action.payload.doc.data() as Article;
        const id = action.payload.doc.id;
        return { id, ...data };
      })
    })


  .map(data => new fromActions.LoadArticlesSuccess({ articles: data }));

//Listen for the 'ADD' action
        @Effect()
        addArticle$: Observable<Action> = this.actions$
        .ofType(fromActions.ArticleActionTypes.ADD_ARTICLE)
        .map((action: fromActions.AddArticle) => action.payload)
        .switchMap( payload => {
          const ref = this.afs.doc<Article>(`articles/${payload.article.id}`);
          return Observable.fromPromise(ref.set(payload.article));
        })


  }

}

1 Ответ

0 голосов
/ 01 февраля 2019

Я считаю, что вам нужно сначала переключить карту: 

@Effect()
    addArticle$: Observable<Action> = this.actions$
    .ofType(fromActions.ArticleActionTypes.ADD_ARTICLE)
    .switchMap((action: fromActions.AddArticle) => of(action.payload))
    .map( payload => {
      const ref = this.afs.doc<Article>(`articles/${payload.article.id}`);
      return Observable.fromPromise(ref.set(payload.article));
    })
...