Как обновить поле Firestore из функции sub pub - PullRequest
Новая
       2

Как обновить поле Firestore из функции sub pub

0 голосов
/ 18 января 2020

Я настроил функцию pub / sub на срабатывание каждую минуту, и я хочу проверить, равно ли текущее время времени начала любой из сущностей Firestore, а затем изменить значение, если оно: 

exports.updateDraftStatus = (event, context) => {
  const pubsubMessage = event.data;
  console.log(Buffer.from(pubsubMessage, 'base64').toString());

  const db = admin.firestore();
  time = admin.firestore.Timestamp.fromMillis(Date.now())
  const snap = db.collection("leagues").where("startTime", time).get()
  await Promise.all(snap.docs.map(doc => doc.ref.update({Started: 'Off'})));
};

1 Ответ

1 голос
/ 18 января 2020

Метод .get() возвращает Promise<QuerySnapshot>, а не QuerySnapshot. Вам потребуется await снимок или использовать блок then(). 

exports.updateDraftStatus = async (event, context) => {
  const pubsubMessage = event.data;
  console.log(Buffer.from(pubsubMessage, 'base64').toString());

  const db = admin.firestore();
  time = admin.firestore.Timestamp.fromMillis(Date.now())
  const snap = await db.collection("leagues").where("startTime", time).get()
  await Promise.all(snap.docs.map(doc => doc.ref.update({Started: 'Off'})));
};

или 

exports.updateDraftStatus = (event, context) => {
  const pubsubMessage = event.data;
  console.log(Buffer.from(pubsubMessage, 'base64').toString());

  const db = admin.firestore();
  time = admin.firestore.Timestamp.fromMillis(Date.now())
  return db.collection("leagues").where("startTime", time).get().then((snap) => {
    return Promise.all(snap.docs.map(doc => doc.ref.update({Started: 'Off'})));
  })
};
...