Используйте SnapshotChanges с CombineLatest

Я использую combLatest, чтобы объединить 3 разных запроса из Firestore. Однако я не хочу использовать valueChanges (), я хочу использовать snapshotChanges ().

const newRef = this.afs.collection('applications', ref => ref.orderBy('date_created_at', 'desc').where('status', '==', 'new')).snapshotChanges().pipe(
  map(changes => {
    return changes.map(a => {
      const data = a.payload.doc.data() as Application;
      const id = a.payload.doc.id;
      return {id, ...data};
    })
  })
);

const pendingRef = this.afs.collection('applications', ref => ref.orderBy('date_created_at', 'desc').where('status', '==', 'pending')).snapshotChanges().pipe(
  map(changes => {
    return changes.map(a => {
      const data = a.payload.doc.data() as Application;
      const id = a.payload.doc.id;
      return {id, ...data};
    })
  })
);

const inprogressRef = this.afs.collection('applications', ref => ref.orderBy('date_created_at', 'desc').where('status', '==', 'in-progress')).snapshotChanges().pipe(
  map(changes => {
    return changes.map(a => {
      const data = a.payload.doc.data() as Application;
      const id = a.payload.doc.id;
      return {id, ...data};
    })
  })
);

const result = combineLatest<any[]>(newRef, pendingRef, inprogressRef).pipe(
  map(arr => arr.reduce((acc, cur) => acc.concat(cur)))
);
return result;

Как мне объединить эти 3 запроса, чтобы получить соответствующий идентификатор документа? Нужно ли мне так писать 3 запроса или есть другой способ? Я хочу упростить коды.

В чем проблема с тем, что у вас сейчас?

— 18.11.2018 19:28

На самом деле все работает, но я хочу писать коды таким образом, чтобы мне не приходилось реплицировать блок кода snapshotChanges ().

— 18.11.2018 19:36

javascript firebase rxjs google-cloud-firestore angularfire2

18.11.2018 19:18

Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией

В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.

Концепция локализации и ее применение в приложениях React ⚡️

Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...

Улучшение производительности загрузки с помощью Google Tag Manager и атрибута Defer

В настоящее время производительность загрузки веб-сайта имеет решающее значение не только для удобства пользователей, но и для ранжирования в...

Безумие обратных вызовов в javascript [JS]

Здравствуйте! Юный падаван 🚀. Присоединяйся ко мне, чтобы разобраться в одной из самых запутанных концепций, когда вы начинаете изучать мир...

Система управления парковками с использованием HTML, CSS и JavaScript

Веб-сайт по управлению парковками был создан с использованием HTML, CSS и JavaScript. Это простой сайт, ничего вычурного. Основная цель -...

JavaScript Вопросы с множественным выбором и ответы

Если вы ищете платформу, которая предоставляет вам бесплатный тест JavaScript MCQ (Multiple Choice Questions With Answers) для оценки ваших знаний,...

236

Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Есть подходы многие для сокращения кода.

Очень простой ...

Определите функцию для выполнения работы:

function processChanges(changes) {
    return changes.map(a => {
      const data = a.payload.doc.data() as Application;
      const id = a.payload.doc.id;
      return {id, ...data};
    })
}

А затем используйте его 3 раза:

const newRef = this.afs.collection('applications', ref => ref.orderBy('date_created_at', 'desc').where('status', '==', 'new')).snapshotChanges().pipe(map(processChanges)));

const pendingRef = this.afs.collection('applications', ref => ref.orderBy('date_created_at', 'desc').where('status', '==', 'pending')).snapshotChanges().pipe(map(processChanges)));

const inprogressRef = this.afs.collection('applications', ref => ref.orderBy('date_created_at', 'desc').where('status', '==', 'in-progress')).snapshotChanges().pipe(map(processChanges)));

const result = combineLatest<any[]>(newRef, pendingRef, inprogressRef).pipe(
  map(arr => arr.reduce((acc, cur) => acc.concat(cur)))
);
return result;

В качестве альтернативы определите вспомогательную функцию и вызовите ее трижды:

function getApplicationsForStatus (status) {

return this.afs.collection('applications', ref => ref.orderBy('date_created_at', 'desc').where('status', '==', status)).snapshotChanges().pipe(
  map(changes => {
    return changes.map(a => {
      const data = a.payload.doc.data() as Application;
      const id = a.payload.doc.id;
      return {id, ...data};
    })
  })
);

И используйте его как:

const newRef = getApplicationsForStatus('new');
const pendingRef = getApplicationsForStatus('pending'); 
const inprogressRef = getApplicationsForStatus('progress');

const result = combineLatest<any[]>(newRef, pendingRef, inprogressRef).pipe(
  map(arr => arr.reduce((acc, cur) => acc.concat(cur)))
);
return result;

18.11.2018 19:42

Другие вопросы по теме

Отметка времени Firestore преобразуется в карту при обработке через облачную функцию

Пытаетесь сделать заказ по телефону по orderByChild (), но он не работает?

Облачные функции Firebase и оповещения безопасности Google

Триггер Firebase при удалении

В активности с вкладками получение данных из Firebase не работает

React-Native аутентификация Firebase

Обновление FirebaseUser DisplayName (аутентификация электронной почты) не обновляет экземпляр CurrentUser

База данных firebase как узнать, существует ли родитель?

Ошибка: тип программы уже присутствует: com.google.android.gms.measurement.internal.zzbn

Firebase - веб-приложение SPA - проблема с выходом из системы

Используйте SnapshotChanges с CombineLatest

Ответы 1

Другие вопросы по теме

Похожие вопросы