Angulaire Firebase - fusionner deux Observables en un

Question

Luttant un peu trop longtemps ici. J'ai deux tables à Firebase:

accounts 
    LJHGGKJH 
    prop1: 'val' 
    prop2: 'val' 
    IUYIUTJF 
    prop1: 'val' 
    prop2: 'val' 

locations_per_account 
    LJHGGKJH 
    0: [1, 5, 6] 
    IUYIUTJF 
    0: [5, 2, 8] 

Comme vous le voyez accounts points clés de point unique à clé unique de locations_per_account article - si elles correspondent ils appartiennent au même utilisateur.

Maintenant, je veux faire une méthode dans mon service qui me fournirait observable de chaque compte et de ses emplacements, de sorte que je pourrais utiliser async pipe dans mon modèle et extraire les données.

Ici, je reçois tous les comptes:

getAllAccounts() { 
    return this.afDb.list('accounts/', { 
     query: { 
     orderByChild: 'hasAccount', 
     equalTo: true 
     } 
    })  
    } 

Ici je reçois des emplacements de compte en particulier:

getAccountLocations(optionalUid : string) { 
    let uid : any; 
    this.authService.authInfo$.subscribe(val => uid = val.$uid); 
    if (typeof optionalUid === 'undefined') 
     return this.afDb.object('locations-per-account/' + uid); 
    return this.afDb.object('locations-per-account/' + optionalUid); 
    } 

donc j'ai besoin de fusionner ces flux en un seul et en fusionnant je construire la nouvelle forme de retour d'objet. (L'ordre des deux tables est symétrique (si c'est le bon mot), mais je ne suis pas sûr qu'il restera le même dans le futur, donc je voudrais vérifier si les deux clés correspondent). Aussi à noter - comme vous pouvez le voir, je pourrais ajouter des emplacements array à chaque compte, mais je le fais dans une table séparée parce que j'essaie de rendre ma base de données Firebase aussi plate que possible, pour éviter des choses comme "Full table scan" . S'il vous plaît avis si des pensées - je suis assez nouveau dans la construction de bases de données.

Answer 1

Utilisez forkJoin d'attendre pour les deux requêtes, la carte puis les deux définit ensemble sur id:

Rx.Observable.forkJoin([accounts$, locations$]).subscribe(results => { 
    const [accounts, locations] = results 
    const joined = accounts.map(account => { 
    return { 
     id: account.id, 
     prop1: account.prop1, 
     prop2: account.prop2, 
     locations: locations.filter(location => location.id === account.id)[0].loc   }; 
    }) 
    console.log(joined); 
}); 

Cela suppose que Firebase émet une valeur unique pour chaque demande de recherche, chacun d'eux est un a rray (ce que je pense qu'il fait, à partir des docs).

Présuppose également un compte et un emplacement par ID, sinon le mappage devrait être plus compliqué.

Voici un CodePen qui simule le scénario. CodePen

Answer 2

donc dans votre cas, le code de pseudo pourrait ressembler à ceci:

Observable.forkJoin([this.getAllAccounts(), this.getAccountLocations()]) 
    .subscribe(results => { 
     console.log(results) 
    } 
); 

quelques articles sur la gestion des observables: Cory Rylan, Tor