NodeJS 承诺 Firebase

Question

喜欢 nodeJS 和异步特性！有了这个，我很困惑如何继续，因为我无法保持嵌套承诺，当然这是不行的，所以我举起双手，因为每一步都需要使用上一步的数据完成操作。

这就是我想要完成的，代码如下。

1. 一所新学院进入 /sessions/college
2. 获得该密钥的值后，寻找订阅该学院的顾问。
3. 为订阅顾问获取 FCM 代币
4. 显然还没有进入这部分，但向订阅者发送 FCM 通知。
5. 多田！

exports.newSessionNotifer = functions.database.ref('/sessions/college').onCreate((snap, context) => {
    const college = snap.val(); 
    var promises = [];
    var getAdvisors = admin.database().ref('colleges').child(college).once('value').then((snapshot) => {
        const people = snapshot.val();
        var advisors = Object.keys(people);
        return advisors;
    }).then((advisors) => {
        return advisors.forEach((token) => {
            var advisorToken = admin.database().ref('users').child(token).child('fcmtoken').child('token').once('value');
            return console.log(advisorToken);
        });
    });

    return Promise.all(promises).then((values) => {
        console.log(promises);
        return console.log('Hi');
    });

Answer 1

你在正确的轨道上。 once() 返回一个 Promise，它是来自重复调用的一组 Promise，必须收集并使用 Promise.all() 运行。

exports.newSessionNotifer = functions.database.ref('/sessions/college').onCreate((snap, context) => {
    const college = snap.val();
    return admin.database().ref('colleges').child(college).once('value');
}).then(snapshot => {
    const people = snapshot.val();
    let advisors = Object.keys(people);
    let promises = advisors.map(token => {
        return admin.database().ref('users').child(token).child('fcmtoken').child('token').once('value');
    });
    return Promise.all(promises);
});

EDIT 再次编辑，这次是 OP 的答案在手。关于样式，我不确定 lint 说什么，但我对不良嵌套样式的定义是 then() 块包含另一个 then() 块。同样关于风格，我让这些东西易于理解的方法是构建（和测试）小函数，每个异步任务一个。

在结构上，OP 的新答案不必要地在return advisors 之后链接了第二个块。由于顾问不是一个承诺，我们可以从那里继续使用同步代码。同样在结构上，OP 的解决方案创建了一系列承诺——每个顾问两个承诺（获取顾问令牌并推送）——但除非应用并返回 Promise.all，否则这些承诺不一定会完成。

综上所述，我的建议如下......

在创建时，获取学院的顾问，向每个人发送消息。

exports.newSessionNotifer = functions.database.ref('/sessions/{sessionID}/college').onCreate((snap, context) => {
    const college = snap.val(); 
    return advisorsForCollege(college).then(advisors => {
        let promises = advisors.map(advisor => sendAdvisorMessage(advisor, college));
        return Promise.all(promises);
    });
});

一所大学的顾问显然是该大学对象的钥匙

function advisorsForCollege(college) {
    return admin.database().ref('colleges').child(college).once('value').then(snapshot => Object.keys(snapshot.val()));
}

发送顾问消息意味着获取顾问令牌并进行推送。返回一个有两个承诺的链......

function sendAdvisorMessage(advisor, college) {
    return tokenForAdvisor(advisor).then(token => {
        let title = `There's a new session for ${college}!`;
        let body = 'Go to the middle tab and swipe right to accept the session before your peers do!'
        return sendToDevice(token, title, body);
    });
}

现在我们只需要一个来获取顾问的令牌，另一个来进行推送......

function tokenForAdvisor(advisor) {
    return admin.database().ref('users').child(advisor).child('fcmtoken').child('token').once('value');
}

function sendToDevice(token, title, body) {
    const payload = { notification: { title: title, body: body } };
    return admin.messaging().sendToDevice(token, payload);
};

我认为 lint 应该报告所有上述情况，即使打开了承诺嵌套警告。

Answer 2

感谢 danh，这是我的最终代码。评论/反馈！我决定在 lint 和 viola 中禁用 promise 嵌套选项！

exports.newSessionNotifer = functions.database.ref('/sessions/{sessionID}/college').onCreate((snap, context) => {
const college = snap.val(); 
return admin.database().ref('colleges').child(college).once('value').then((snapshot) => {
    const people = snapshot.val();  
    let advisors = Object.keys(people);
    return advisors;
}).then((advisors) => {
    return advisors.map(advisor => {
            return admin.database().ref('users').child(advisor).child('fcmtoken').child('token').once('value').then((snapshot) => {
            const token = snapshot.val();
            const payload = {
                    notification: {
                    title: `There's a new session for ${college}!`,
                    body: 'Go to the middle tab and swipe right to accept the session before your peers do!'
                    }
            };
            return admin.messaging().sendToDevice(token, payload);
        });
    });
});
});