All files / node-activedirectory/lib/services/internal/search service.search.onSearchEntry.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
1x
1x
1x
1x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1x
const parseRangeAttributes      = require('../service.parseRangeAttributes');
const pendingRangeRetrievals    = require('./service.search.pendingRangeRetrievals');
const log                       = require('../service.log');
const onSearchEnd               = require('./service.onSearchEnd');
 
/**
* Occurs when a search entry is received. Cleans up the search entry and pushes it to the result set.
* @param {Object} entry The entry received.
* @param {Object} self The ActiveDirectory Object
* @param {Object} opts Options
* @param {Function} resolve Resolve the search
* @param {Function} reject Reject the search
*/
function onSearchEntry(entry, client, baseDN, self, opts, isDone, results, resolve, reject) {
    /**
    * The default entry parser to use. Does not modifications.
    * @params {Object} entry The original / raw ldapjs entry to augment
    * @params {Function} callback The callback to execute when complete.
    */
    let entryParser = (opts || {}).entryParser || (self.opts || {}).entryParser || function onEntryParser(item, raw, callback) {
        callback(item);
    };
 
    log.trace('onSearchEntry(%j)', entry);
    let result = entry.object;
    delete result.controls; // Remove the controls array returned as part of the SearchEntry
 
    // Some attributes can have range attributes (paging). Execute the query
    // again to get additional items.
    pendingRangeRetrievals.addOne();
    parseRangeAttributes.call(self, result, opts, function (err, item) {
        pendingRangeRetrievals.substractOne();
 
        if (err) item = entry.object;
        entryParser(item, entry.raw, function (item) {
            if (item) results.push(item);
            if ((!pendingRangeRetrievals.get()) && (isDone)) {
                onSearchEnd(client, baseDN, opts, results, resolve, reject);
            }
        });
    });
}
 
module.exports = onSearchEntry;