ldapjs 处理 client.search 响应

Question

我有以下绑定到 LDAP 服务器的代码，我想返回我在“interviewees”组中添加了“ab”的用户（代码取自 ldapjs 客户端 api 页面）。我可以看到我正在从服务器返回带有预期 EventEmitter 对象的响应。我希望在 searchEntry 对象上调用 logging console.log() 时看到有关用户的信息。我似乎没有 searchEntry 对象。我的用户的 DN 是否正确？我目前不确定问题是否与我的查询有关，我没有得到任何数据，或者我是否未能正确处理响应？

    const client = ldap.createClient({ url: 'ldap://' + LDAP_SERVER + ':' + LDAP_PORT });
    
    // Connect and bind to the Active Directory.
    const connectToClient = async () => {
      const secret = LDAP_SECRET_KEY;
      return await new Promise((resolve, reject) => {
        client.bind(LDAP_USER, secret, function (err, res) {
          if (err) {
            console.error(err);
            reject('Failed to connect to LDAP server');
          } else {
            resolve('Connected to LDAP server');
          }
        });
      });
    };
    
    onst searchADForUser = async () => {
      return await new Promise((resolve, reject) => {
        client.search('CN=ab,OU=interviewees,OU=Users,OU=interview,DC=interview,DC=workspace,DC=com', function (err, res) {
          if (err) {
            console.error(err);
            reject('Error searching LDAP server');
          } else {
            res.on('searchEntry', function (entry) {
              console.log('entry: ' + JSON.stringify(entry.object));
            });
            res.on('searchReference', function (referral) {
              console.log('referral: ' + referral.uris.join());
            });
            res.on('error', function (err) {
              console.error('error: ' + err.message);
            });
            res.on('end', function (result) {
              console.log('status: ' + result.status);
            });
            resolve(res);
          }
        });
      });
    };
    
    const handler = async (event) => {
      try {
        return responses.success(
          await connectToClient().then(async function(event) {
            console.log(event);
            await searchADForUser().then(function(event) {
              console.log(event);
            }).catch(function(event) {
              console.log(event);
            })
          }).catch(function(event) {
            console.log(event);
          })
        );
      } catch (err) {
        console.error(err);
        return responses.error(err);
      } finally {
        client.unbind();
      }
    };

活动目录结构如下

Answer 1

我遇到的核心问题是了解如何处理从搜索函数返回的 EventEmitter 对象。我需要在每个 searchEntry 事件上添加一个数组，然后仅在 end 事件发生后在我的 resolve 回调函数中返回该条目。上面的代码会立即调用 resolve，因此还没有处理任何 searchEntry 事件或 end 事件。

我现在使用的代码如下：

function (err, res) {
        if (err) {
          console.error(err);
          reject(new Error('Error retrieving users from Active Directory'));
        } else {
          const entries = [];
          res.on('searchEntry', function (entry) {
            entries.push(entry);
          });
          res.on('searchReference', function (referral) {
            console.log('referral: ' + referral.uris.join());
          });
          res.on('error', function (err) {
            console.error('error: ' + err.message);
          });
          res.on('end', function (result) {
            console.log('status: ' + result.status);
            if (result.status !== 0) {
              reject(new Error('Error code received from Active Directory'));
            } else {
              resolve(entries);
            }
          });
        }
      }