从另一个 Promise 调用 Promise 方法

问题描述

希望你们每个人都做得很好。我陷入了一个小问题。任何帮助将不胜感激。

我正在使用 ldapJS 并且我想从 LDAPJS 的 searchEntry 方法调用另一个承诺。当我编写与下面相同的代码时。它抛出一个错误

exports.getADUsers = async (reqst,resp,next) => {
    let flag = false;
    var finalList = [];
    let adConnStatus = await ConnectAD()
        .then().catch((errConnStatus) => {
            console.log("Error in connection with Active directory " + errConnStatus);
        });

    if (adConnStatus.status == 0) {
        let client = adConnStatus.client;
        const opts = {
            filter: '(ObjectClass=*)',scope: 'sub',attributes: ['cn','sid',"objectSid"]
        };
        client.search('dc=domain,dc=com',opts,(err,res) => {
            if (err) {
                console.log("Error: " + err);
            } else {
                res.on('searchEntry',(entry) => {
                    finalList = await searchEntry(entry);
                });
                res.on('searchReference',(referral) => {
                    console.log('referral: ' + referral.uris.join());
                });
                res.on('error',(err) => {
                    console.error('error: ' + err.message);
                });
                res.on('end',(result) => {
                    resp.send(finalList);
                    console.log(result);
                });
            }
        });
    }
}

错误：

finalList = await searchEntry(entry);
            ^^^^^

SyntaxError: await is only valid in async function

请帮忙！如何从一个承诺中调用另一个承诺。尽管该方法是异步的，为什么它会显示此消息？我做错了什么？

编辑

按照async的建议添加关键字@Punth后。还修改了一些代码。我的新代码如下。

exports.getADUsers = async (reqst,next) => {
    let adConnStatus = await ConnectAD()
        .then().catch((errConnStatus) => {
            console.log("Error in connection with Active directory " + errConnStatus);
        });

    if (adConnStatus.status == 0) {
        var adUsersList = [];
        let client = adConnStatus.client;
        const opts = {
            filter: '(ObjectClass=*)',async (entry) => {
                    var raw = entry.raw;
                    if (raw.objectSid != "undefined" && raw.objectSid != null && entry.object.cn != null && entry.object.cn != "undefined") {
                        let userData = {
                            "Name": entry.object.cn,"SSID": sidBufferToString(raw.objectSid)
                        }
                        var lmn = await ConnectAndGetUsersList(userData.SSID);
                        userData["XYZ"] = lmn.xyz;
                        userData["ABC"] = lmn.abc;
                        adUsersList.push(userData);
                    }
                });
                res.on('searchReference',(result) => {
                    console.log(result);
                    resp.send(adUsersList);
                });
            }
        });
    }
}

通过运行上面的代码，它没有显示任何内容。 res.on('end' ....) 在 res.on("searchEntry"....) 之前被调用，因此 adUsersList 的数组为空。

现在我的问题是如何resp.send最终的数组列表？？？

解决方法

按如下方式更新此行，要在回调中使用 async/await 语法调用 Promise，您需要使其异步

 res.on('searchEntry',async (entry) => {
   finalList = await searchEntry(entry);
 });