Używasz strumienia Firebase jako danych wejściowych dla innego strumienia we Flutter?
Kontekst: Mam dwa strumienie Firebase, które działają poprawnie i pobierają i) listę profili użytkowników (zbiór „użytkowników”) oraz ii) listę lokalizacji należących do każdego profilu użytkownika (zbiór „lokalizacje”) oraz następnie odwzoruj je na niestandardowy model użytkownika i lokalizacji.
Strumień użytkowników:
class DatabaseService {
final String uid;
final String friendUid;
final String locationId;
DatabaseService({ this.uid, this.locationId, this.friendUid });
// collection reference for users
final CollectionReference userCollection = FirebaseFirestore.instance.collection('users');
// get users stream
Stream<List<CustomUserModel>> get users {
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
List<CustomUserModel> userList = [];
List<CustomUserModel> _streamMapper(DocumentSnapshot snapshot) {
CustomUserModel individualUser = CustomUserModel(
uid: snapshot.id,
name: snapshot.data()['name'],
username: snapshot.data()['username'],
email: snapshot.data()['email'],
);
userList.add(individualUser);
return userList;
}
return userCollection.doc(uid).snapshots().map(_streamMapper);
}
i strumień lokalizacji:
// collection reference for location
final CollectionReference locationCollection =
FirebaseFirestore.instance.collection('locations');
Stream<List<Location>> get locations {
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
List<Location> _locationListFromSnapshot(QuerySnapshot snapshot) {
List<Location> locationList = [];
snapshot.docs.forEach((element) {
Location individualLocation = Location(
locationId: element.id,
locationName: element.data()['locationName'],
city: element.data()['city'],
);
locationList.add(individualLocation);
});
return locationList;
}
return userLocationCollection.doc(uid).collection('locations').snapshots()
.map(_locationListFromSnapshot);
}
Chcę wygenerować niestandardowy strumień, który wyprowadza wszystkie lokalizacje dla wszystkich użytkowników - innymi słowy, aby użyć strumienia użytkowników jako danych wejściowych dla strumienia lokalizacji.
Nie jestem pewien, jakie podejście tutaj działa - rozważałem dodanie strumienia użytkowników jako parametru wejściowego do strumienia lokalizacji, a następnie utworzenie pętli for, coś takiego:
Stream<List<Location>> allLocations(Stream<List<CustomUserModel>> users) {
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
List<Location> locationList = [];
users.forEach((element) {
// append user's locations to empty list
locationList.add(locationCollection.doc(element.first.uid).collection('locations')
.snapshots().map(SOME FUNCTION TO MAP A DOCUMENT SNAPSHOT TO THE CUSTOM LOCATION MODEL)
}
return locationList;
ale oczywiście pojawia się błąd, ponieważ zwraca to listę, a nie strumień. Więc nie mam pojęcia, jak postępować ...
Odpowiedzi
Słyszę twój ból. Byłem tam. Byłeś całkiem blisko. Pozwól, że wyjaśnię, jak lubię to robić.
Przede wszystkim trochę posprzątać:
Wyglądało na to, że nie używasz ich w allLocations
funkcjach, więc je usunąłem
final FirebaseAuth auth = FirebaseAuth.instance;
final User user = auth.currentUser;
final uid = user.uid;
Po drugie, zmieniłem typ zwracania funkcji z Stream<List<Location>>
na, Stream<Map<String, List<Location>>
gdzie kluczem mapy byłby userId. Uważam, że ten typ jest przydatny, ponieważ nie musisz się martwić o kolejność synchronizacji użytkowników ze strumieniem.
Po trzecie, kiedy tworzysz strumienie, nie możesz wrócić, ale musisz ustąpić z funkcji. Musisz także zaznaczyć funkcję async*
(* nie jest literówką).
W związku z tym proponuję użyć czegoś takiego do swojej allLocations
funkcji:
class DataService {
List<Location> convertToLocations(QuerySnapshot snap) {
// This is the function to convert QuerySnapshot into List<Location>
return [Location()];
}
Stream<Map<String, List<Location>>> allLocations(
Stream<List<CustomUserModel>> usersStream) async* {
Map<String, List<Location>> locationsMap = {};
await for (List<CustomUserModel> users in usersStream) {
for (CustomUserModel user in users) {
final Stream<List<Location>> locationsStream = locationCollection
.doc(user.uid)
.collection('locations')
.snapshots()
.map(convertToLocations);
await for (List<Location> locations in locationsStream) {
locationsMap[user.uid] = locations;
yield locationsMap;
}
}
}
}
}
Mam nadzieję, że podoba Ci się ta metoda. Daj mi znać, jeśli coś nie jest tym, czego chcesz. Mogę wprowadzić poprawki.