如何通过云功能触发 Firestore 集合

Question

每当我在我的应用中单击以下按钮时，我想从现有的关注者收藏和视频收藏中触发一个新的收藏（时间线收藏）。

现在的问题是，Cloud Function 是从视图日志中创建的，但不会创建新的集合（时间线集合）。

下面是 Cloud Function 的代码，我在其中定位关注者集合和视频集合以创建新的时间线集合。我期待您的帮助。

• Videos collection

• Followers collection

• Cloud function view logs

const functions = require("firebase-functions");
    const admin = require("firebase-admin");
    admin.initializeApp();
    
    // // Create and Deploy Your First Cloud Functions
    // // https://firebase.google.com/docs/functions/write-firebase-functions
    //
    // exports.helloWorld = functions.https.onRequest((request, response) => {
    //  response.send("Hello from Firebase!");
    // });
    exports.onCreateFollower = functions.firestore
      .document("/followers/{userId}/userFollowers/{userfollowerId}")
      .onCreate(async (snapshot, context) => {
        console.log("The Event has Created The Follower", snapshot.id);
        const userId = context.params.userId;
        const userfollowerId = context.params.userfollowerId;
    
        // 1) Create followed users posts ref
        const followedUserVideosCollection = admin
          .firestore()
          .collection("videos")
          .doc(userId)
          .collection("userVideos"); 
    
        // 2) Create following user's timeline ref
        const timelineVideosCollection = admin
          .firestore()
          .collection("timeline")
          .doc(userfollowerId)
          .collection("timelinePosts");
    
        // 3) Get followed users posts
        const querySnapshot = await followedUserVideosCollection.get();
    
        // 4) Add each user post to following user's timeline
        querySnapshot.forEach(doc => {
          if (doc.exists) {
            const videoId = doc.id;
            const videoData = doc.data();
            timelineVideosCollection.doc(videoId).set(videoData);
          }
        });
      });

Answer 1

我找出了导致错误“querySnapshot.forEach 不是函数”的原因。根据to this answer，您需要先查询集合，因为get() 返回的是文档而不是快照。这是一个示例代码（见第 3 步）：

// 1) Create followed users posts ref
const followedUserVideosCollection = admin
    .firestore()
    .collection("videos")
    .doc("Videos 1") // I changed the value with your sample for test purposes and also because I'm not sure how you fill up this doc.
    .collection("userVideos");

// 2) Create following user's timeline ref
const timelineVideosCollection = admin
    .firestore()
    .collection("timeline")
    .doc(userfollowerId)
    .collection("timelinePosts");

// 3) Get followed users posts & Add each user post to following user's timeline
await followedUserVideosCollection.where('id', '==', 0).get().then((querySnapshot) => {
    if (querySnapshot) {
        querySnapshot.forEach(doc => {
            if (doc) {
                const videoId = doc.id;
                const videoData = doc.data();
                timelineVideosCollection.doc(videoId).set(videoData);
            }
        });
    }else {
        console.log("Document not found");
    }
}).catch((error) => {
    console.log(error);
});

一种解决方案是创建一个过滤器，并确保您要查找的文档与该过滤器匹配。例如，子集合 userVideos 中的文档应该有一个名为 id 的字段，其值为 0。

您可能必须改造您的数据库以修复我发表评论的行，但此代码应写入 timeline 集合。