This repository has been archived by the owner on Aug 5, 2021. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 38
/
exec.js
145 lines (122 loc) · 3.59 KB
/
exec.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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
const debug = require('debug')('openrecord:exec')
const ldap = require('ldapjs')
exports.definition = {
mixinCallback: function() {
var self = this
this.onFind(function(options, data) {
var chain = this
if (
options.filter &&
options.filter.filters &&
options.filter.filters.length === 0
) {
options.filter = null
}
options.controls = options.controls || []
for (var i = 0; i < options.controls.length; i++) {
if (!(options.controls[i] instanceof ldap.Control)) {
options.controls[i] = new ldap.Control(options.controls[i])
}
}
return new Promise(function(resolve, reject) {
chain.connection.search(
options.root,
options,
options.controls,
function(err, res) {
debug(
'Search ' +
options.root +
' (Scope=' +
options.scope +
', Filter=' +
options.filter.toString() +
', Attributes=' +
options.attributes
)
if (err) return reject(err)
var records = []
var rangeChecks = 0
// get search resutls
res.on('searchEntry', function(entry) {
rangeChecks++
var obj = entry.object
chain.checkRangeAttributes(entry, obj, function(error) {
if (error) return reject(error)
records.push(self.store.utils.mergeBinary(chain, entry, obj))
rangeChecks--
if (rangeChecks === 0) finished()
})
})
var done = false
var finished = function() {
if (done && rangeChecks === 0) {
data.result = records
resolve()
}
}
// finished search...
res.on('end', function() {
done = true
finished()
})
res.on('error', function(err) {
if (err instanceof ldap.NoSuchObjectError) {
return resolve() // if no object was found, it's an empty result
}
reject(err)
})
}
)
})
})
}
}
/*
* MODEL
*/
exports.model = {
getExecOptions: function() {
return {
filter: new ldap.AndFilter({ filters: [] })
}
},
checkRangeAttributes: function(entry, target, callback) {
var self = this
var obj = entry.object
var keys = Object.keys(obj)
var ranges = []
for (var i = 0; i < keys.length; i++) {
var key = keys[i]
var range = key.match(/(.+);range=(\d+)-(.+)?$/i)
if (range) {
var attr = range[1]
var low = parseInt(range[2])
var high = parseInt(range[3]) || null
// add values to original attribute
target[attr] = target[attr] || []
target[attr] = target[attr].concat(obj[key])
if (high != null && high !== low) {
var tmp = low
low = high + 1
high = high + (high - tmp) + 1
ranges.push(attr + ';range=' + low + '-' + (high || '*'))
}
}
}
if (ranges.length === 0) return callback()
this.connection.search(obj.dn, { attributes: ranges }, [], function(
error,
res
) {
if (error) return callback(error)
// get search results
res.on('searchEntry', function(entry) {
self.checkRangeAttributes(entry, target, callback)
})
res.on('error', function(error) {
callback(error)
})
})
}
}