Blame view

sources/apps/user_ldap/lib/access.php 44.5 KB
03e52840d   Kload   Init
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
  <?php
  
  /**
   * ownCloud – LDAP Access
   *
   * @author Arthur Schiwon
   * @copyright 2012, 2013 Arthur Schiwon blizzz@owncloud.com
   *
   * This library is free software; you can redistribute it and/or
   * modify it under the terms of the GNU AFFERO GENERAL PUBLIC LICENSE
   * License as published by the Free Software Foundation; either
   * version 3 of the License, or any later version.
   *
   * This library is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU AFFERO GENERAL PUBLIC LICENSE for more details.
   *
   * You should have received a copy of the GNU Affero General Public
   * License along with this library.  If not, see <http://www.gnu.org/licenses/>.
   *
   */
  
  namespace OCA\user_ldap\lib;
6d9380f96   Cédric Dupont   Update sources OC...
25
26
27
28
29
30
31
32
  /**
   * Class Access
   * @package OCA\user_ldap\lib
   */
  class Access extends LDAPUtility implements user\IUserTools {
  	/**
  	 * @var \OCA\user_ldap\lib\Connection
  	 */
31b7f2792   Kload   Upgrade to ownclo...
33
  	public $connection;
6d9380f96   Cédric Dupont   Update sources OC...
34
  	public $userManager;
03e52840d   Kload   Init
35
36
37
38
  	//never ever check this var directly, always use getPagedSearchResultState
  	protected $pagedSearchedSuccessful;
  
  	protected $cookies = array();
6d9380f96   Cédric Dupont   Update sources OC...
39
40
41
  
  	public function __construct(Connection $connection, ILDAPWrapper $ldap,
  		user\Manager $userManager) {
31b7f2792   Kload   Upgrade to ownclo...
42
  		parent::__construct($ldap);
03e52840d   Kload   Init
43
  		$this->connection = $connection;
6d9380f96   Cédric Dupont   Update sources OC...
44
45
  		$this->userManager = $userManager;
  		$this->userManager->setLdapAccess($this);
03e52840d   Kload   Init
46
  	}
6d9380f96   Cédric Dupont   Update sources OC...
47
48
49
  	/**
  	 * @return bool
  	 */
03e52840d   Kload   Init
50
51
52
53
54
  	private function checkConnection() {
  		return ($this->connection instanceof Connection);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
55
56
57
58
59
60
61
62
63
64
65
  	 * returns the Connection instance
  	 * @return \OCA\user_ldap\lib\Connection
  	 */
  	public function getConnection() {
  		return $this->connection;
  	}
  
  	/**
  	 * reads a given attribute for an LDAP record identified by a DN
  	 * @param string $dn the record in question
  	 * @param string $attr the attribute that shall be retrieved
03e52840d   Kload   Init
66
  	 *        if empty, just check the record's existence
6d9380f96   Cédric Dupont   Update sources OC...
67
68
  	 * @param string $filter
  	 * @return array|false an array of values on success or an empty
03e52840d   Kload   Init
69
  	 *          array if $attr is empty, false otherwise
03e52840d   Kload   Init
70
71
72
73
74
75
76
77
78
  	 */
  	public function readAttribute($dn, $attr, $filter = 'objectClass=*') {
  		if(!$this->checkConnection()) {
  			\OCP\Util::writeLog('user_ldap',
  				'No LDAP Connector assigned, access impossible for readAttribute.',
  				\OCP\Util::WARN);
  			return false;
  		}
  		$cr = $this->connection->getConnectionResource();
31b7f2792   Kload   Upgrade to ownclo...
79
  		if(!$this->ldap->isResource($cr)) {
03e52840d   Kload   Init
80
81
82
83
84
  			//LDAP not available
  			\OCP\Util::writeLog('user_ldap', 'LDAP resource not available.', \OCP\Util::DEBUG);
  			return false;
  		}
  		//all or nothing! otherwise we get in trouble with.
03e52840d   Kload   Init
85
  		$dn = $this->DNasBaseParameter($dn);
31b7f2792   Kload   Upgrade to ownclo...
86
87
  		$rr = @$this->ldap->read($cr, $dn, $filter, array($attr));
  		if(!$this->ldap->isResource($rr)) {
03e52840d   Kload   Init
88
89
90
91
92
93
94
95
96
97
98
  			if(!empty($attr)) {
  				//do not throw this message on userExists check, irritates
  				\OCP\Util::writeLog('user_ldap', 'readAttribute failed for DN '.$dn, \OCP\Util::DEBUG);
  			}
  			//in case an error occurs , e.g. object does not exist
  			return false;
  		}
  		if (empty($attr)) {
  			\OCP\Util::writeLog('user_ldap', 'readAttribute: '.$dn.' found', \OCP\Util::DEBUG);
  			return array();
  		}
31b7f2792   Kload   Upgrade to ownclo...
99
100
  		$er = $this->ldap->firstEntry($cr, $rr);
  		if(!$this->ldap->isResource($er)) {
03e52840d   Kload   Init
101
102
103
104
  			//did not match the filter, return false
  			return false;
  		}
  		//LDAP attributes are not case sensitive
31b7f2792   Kload   Upgrade to ownclo...
105
106
  		$result = \OCP\Util::mb_array_change_key_case(
  				$this->ldap->getAttributes($cr, $er), MB_CASE_LOWER, 'UTF-8');
03e52840d   Kload   Init
107
108
109
110
111
112
113
  		$attr = mb_strtolower($attr, 'UTF-8');
  
  		if(isset($result[$attr]) && $result[$attr]['count'] > 0) {
  			$values = array();
  			for($i=0;$i<$result[$attr]['count'];$i++) {
  				if($this->resemblesDN($attr)) {
  					$values[] = $this->sanitizeDN($result[$attr][$i]);
31b7f2792   Kload   Upgrade to ownclo...
114
  				} elseif(strtolower($attr) === 'objectguid' || strtolower($attr) === 'guid') {
03e52840d   Kload   Init
115
116
117
118
119
120
121
122
123
124
125
126
  					$values[] = $this->convertObjectGUID2Str($result[$attr][$i]);
  				} else {
  					$values[] = $result[$attr][$i];
  				}
  			}
  			return $values;
  		}
  		\OCP\Util::writeLog('user_ldap', 'Requested attribute '.$attr.' not found for '.$dn, \OCP\Util::DEBUG);
  		return false;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
127
128
129
  	 * checks whether the given attributes value is probably a DN
  	 * @param string $attr the attribute in question
  	 * @return boolean if so true, otherwise false
03e52840d   Kload   Init
130
131
132
133
134
135
136
137
138
139
140
  	 */
  	private function resemblesDN($attr) {
  		$resemblingAttributes = array(
  			'dn',
  			'uniquemember',
  			'member'
  		);
  		return in_array($attr, $resemblingAttributes);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
141
142
143
  	 * sanitizes a DN received from the LDAP server
  	 * @param array $dn the DN in question
  	 * @return array the sanitized DN
03e52840d   Kload   Init
144
145
146
147
148
149
  	 */
  	private function sanitizeDN($dn) {
  		//treating multiple base DNs
  		if(is_array($dn)) {
  			$result = array();
  			foreach($dn as $singleDN) {
6d9380f96   Cédric Dupont   Update sources OC...
150
  				$result[] = $this->sanitizeDN($singleDN);
03e52840d   Kload   Init
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
  			}
  			return $result;
  		}
  
  		//OID sometimes gives back DNs with whitespace after the comma
  		// a la "uid=foo, cn=bar, dn=..." We need to tackle this!
  		$dn = preg_replace('/([^\\\]),(\s+)/u', '\1,', $dn);
  
  		//make comparisons and everything work
  		$dn = mb_strtolower($dn, 'UTF-8');
  
  		//escape DN values according to RFC 2253 – this is already done by ldap_explode_dn
  		//to use the DN in search filters, \ needs to be escaped to \5c additionally
  		//to use them in bases, we convert them back to simple backslashes in readAttribute()
  		$replacements = array(
  			'\,' => '\5c2C',
  			'\=' => '\5c3D',
  			'\+' => '\5c2B',
  			'\<' => '\5c3C',
  			'\>' => '\5c3E',
  			'\;' => '\5c3B',
  			'\"' => '\5c22',
  			'\#' => '\5c23',
  			'('  => '\28',
  			')'  => '\29',
  			'*'  => '\2A',
  		);
  		$dn = str_replace(array_keys($replacements), array_values($replacements), $dn);
  
  		return $dn;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
  	 * returns a DN-string that is cleaned from not domain parts, e.g.
  	 * cn=foo,cn=bar,dc=foobar,dc=server,dc=org
  	 * becomes dc=foobar,dc=server,dc=org
  	 * @param string $dn
  	 * @return string
  	 */
  	public function getDomainDNFromDN($dn) {
  		$allParts = $this->ldap->explodeDN($dn, 0);
  		if($allParts === false) {
  			//not a valid DN
  			return '';
  		}
  		$domainParts = array();
  		$dcFound = false;
  		foreach($allParts as $part) {
  			if(!$dcFound && strpos($part, 'dc=') === 0) {
  				$dcFound = true;
  			}
  			if($dcFound) {
  				$domainParts[] = $part;
  			}
  		}
  		$domainDN = implode(',', $domainParts);
  		return $domainDN;
  	}
  
  	/**
03e52840d   Kload   Init
211
  	 * gives back the database table for the query
6d9380f96   Cédric Dupont   Update sources OC...
212
213
  	 * @param bool $isUser
  	 * @return string
03e52840d   Kload   Init
214
215
216
217
218
219
220
221
222
223
  	 */
  	private function getMapTable($isUser) {
  		if($isUser) {
  			return '*PREFIX*ldap_user_mapping';
  		} else {
  			return '*PREFIX*ldap_group_mapping';
  		}
  	}
  
  	/**
03e52840d   Kload   Init
224
  	 * returns the LDAP DN for the given internal ownCloud name of the group
6d9380f96   Cédric Dupont   Update sources OC...
225
226
  	 * @param string $name the ownCloud name in question
  	 * @return string with the LDAP DN on success, otherwise false
03e52840d   Kload   Init
227
228
229
230
231
232
233
234
235
236
237
238
  	 */
  	public function groupname2dn($name) {
  		$dn = $this->ocname2dn($name, false);
  
  		if($dn) {
  			return $dn;
  		}
  
  		return false;
  	}
  
  	/**
03e52840d   Kload   Init
239
  	 * returns the LDAP DN for the given internal ownCloud name of the user
6d9380f96   Cédric Dupont   Update sources OC...
240
241
  	 * @param string $name the ownCloud name in question
  	 * @return string with the LDAP DN on success, otherwise false
03e52840d   Kload   Init
242
243
244
  	 */
  	public function username2dn($name) {
  		$dn = $this->ocname2dn($name, true);
31b7f2792   Kload   Upgrade to ownclo...
245
246
247
  		//Check whether the DN belongs to the Base, to avoid issues on multi-
  		//server setups
  		if($dn && $this->isDNPartOfBase($dn, $this->connection->ldapBaseUsers)) {
03e52840d   Kload   Init
248
249
250
251
252
253
254
  			return $dn;
  		}
  
  		return false;
  	}
  
  	/**
03e52840d   Kload   Init
255
  	 * returns the LDAP DN for the given internal ownCloud name
6d9380f96   Cédric Dupont   Update sources OC...
256
257
258
  	 * @param string $name the ownCloud name in question
  	 * @param boolean $isUser is it a user? otherwise group
  	 * @return string with the LDAP DN on success, otherwise false
03e52840d   Kload   Init
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
  	 */
  	private function ocname2dn($name, $isUser) {
  		$table = $this->getMapTable($isUser);
  
  		$query = \OCP\DB::prepare('
  			SELECT `ldap_dn`
  			FROM `'.$table.'`
  			WHERE `owncloud_name` = ?
  		');
  
  		$record = $query->execute(array($name))->fetchOne();
  		return $record;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
274
275
276
277
  	 * returns the internal ownCloud name for the given LDAP DN of the group, false on DN outside of search DN or failure
  	 * @param string $dn the dn of the group object
  	 * @param string $ldapName optional, the display name of the object
  	 * @return string with the name to use in ownCloud, false on DN outside of search DN
03e52840d   Kload   Init
278
  	 */
6d9380f96   Cédric Dupont   Update sources OC...
279
  	public function dn2groupname($dn, $ldapName = null) {
03e52840d   Kload   Init
280
281
282
283
284
285
  		//To avoid bypassing the base DN settings under certain circumstances
  		//with the group support, check whether the provided DN matches one of
  		//the given Bases
  		if(!$this->isDNPartOfBase($dn, $this->connection->ldapBaseGroups)) {
  			return false;
  		}
6d9380f96   Cédric Dupont   Update sources OC...
286
  		return $this->dn2ocname($dn, $ldapName, false);
03e52840d   Kload   Init
287
288
289
  	}
  
  	/**
03e52840d   Kload   Init
290
  	 * returns the internal ownCloud name for the given LDAP DN of the user, false on DN outside of search DN or failure
6d9380f96   Cédric Dupont   Update sources OC...
291
292
293
  	 * @param string $dn the dn of the user object
  	 * @param string $ldapName optional, the display name of the object
  	 * @return string with with the name to use in ownCloud
03e52840d   Kload   Init
294
  	 */
6d9380f96   Cédric Dupont   Update sources OC...
295
  	public function dn2username($dn, $ldapName = null) {
03e52840d   Kload   Init
296
297
298
299
300
301
  		//To avoid bypassing the base DN settings under certain circumstances
  		//with the group support, check whether the provided DN matches one of
  		//the given Bases
  		if(!$this->isDNPartOfBase($dn, $this->connection->ldapBaseUsers)) {
  			return false;
  		}
6d9380f96   Cédric Dupont   Update sources OC...
302
  		return $this->dn2ocname($dn, $ldapName, true);
03e52840d   Kload   Init
303
304
305
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
306
307
308
309
310
  	 * returns an internal ownCloud name for the given LDAP DN, false on DN outside of search DN
  	 * @param string $dn the dn of the user object
  	 * @param string $ldapName optional, the display name of the object
  	 * @param bool $isUser optional, whether it is a user object (otherwise group assumed)
  	 * @return string with with the name to use in ownCloud
03e52840d   Kload   Init
311
  	 */
6d9380f96   Cédric Dupont   Update sources OC...
312
  	public function dn2ocname($dn, $ldapName = null, $isUser = true) {
03e52840d   Kload   Init
313
314
315
316
317
318
319
320
321
322
  		$table = $this->getMapTable($isUser);
  		if($isUser) {
  			$fncFindMappedName = 'findMappedUser';
  			$nameAttribute = $this->connection->ldapUserDisplayName;
  		} else {
  			$fncFindMappedName = 'findMappedGroup';
  			$nameAttribute = $this->connection->ldapGroupDisplayName;
  		}
  
  		//let's try to retrieve the ownCloud name from the mappings table
6d9380f96   Cédric Dupont   Update sources OC...
323
324
325
  		$ocName = $this->$fncFindMappedName($dn);
  		if($ocName) {
  			return $ocName;
03e52840d   Kload   Init
326
327
328
  		}
  
  		//second try: get the UUID and check if it is known. Then, update the DN and return the name.
31b7f2792   Kload   Upgrade to ownclo...
329
  		$uuid = $this->getUUID($dn, $isUser);
03e52840d   Kload   Init
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
  		if($uuid) {
  			$query = \OCP\DB::prepare('
  				SELECT `owncloud_name`
  				FROM `'.$table.'`
  				WHERE `directory_uuid` = ?
  			');
  			$component = $query->execute(array($uuid))->fetchOne();
  			if($component) {
  				$query = \OCP\DB::prepare('
  					UPDATE `'.$table.'`
  					SET `ldap_dn` = ?
  					WHERE `directory_uuid` = ?
  				');
  				$query->execute(array($dn, $uuid));
  				return $component;
  			}
  		} else {
  			//If the UUID can't be detected something is foul.
  			\OCP\Util::writeLog('user_ldap', 'Cannot determine UUID for '.$dn.'. Skipping.', \OCP\Util::INFO);
  			return false;
  		}
6d9380f96   Cédric Dupont   Update sources OC...
351
352
353
  		if(is_null($ldapName)) {
  			$ldapName = $this->readAttribute($dn, $nameAttribute);
  			if(!isset($ldapName[0]) && empty($ldapName[0])) {
03e52840d   Kload   Init
354
355
356
  				\OCP\Util::writeLog('user_ldap', 'No or empty name for '.$dn.'.', \OCP\Util::INFO);
  				return false;
  			}
6d9380f96   Cédric Dupont   Update sources OC...
357
  			$ldapName = $ldapName[0];
03e52840d   Kload   Init
358
359
360
361
362
363
364
365
366
367
  		}
  
  		if($isUser) {
  			$usernameAttribute = $this->connection->ldapExpertUsernameAttr;
  			if(!emptY($usernameAttribute)) {
  				$username = $this->readAttribute($dn, $usernameAttribute);
  				$username = $username[0];
  			} else {
  				$username = $uuid;
  			}
6d9380f96   Cédric Dupont   Update sources OC...
368
  			$intName = $this->sanitizeUsername($username);
03e52840d   Kload   Init
369
  		} else {
6d9380f96   Cédric Dupont   Update sources OC...
370
  			$intName = $ldapName;
03e52840d   Kload   Init
371
372
373
374
375
376
  		}
  
  		//a new user/group! Add it only if it doesn't conflict with other backend's users or existing groups
  		//disabling Cache is required to avoid that the new user is cached as not-existing in fooExists check
  		$originalTTL = $this->connection->ldapCacheTTL;
  		$this->connection->setConfiguration(array('ldapCacheTTL' => 0));
6d9380f96   Cédric Dupont   Update sources OC...
377
378
379
  		if(($isUser && !\OCP\User::userExists($intName))
  			|| (!$isUser && !\OC_Group::groupExists($intName))) {
  			if($this->mapComponent($dn, $intName, $isUser)) {
03e52840d   Kload   Init
380
  				$this->connection->setConfiguration(array('ldapCacheTTL' => $originalTTL));
6d9380f96   Cédric Dupont   Update sources OC...
381
  				return $intName;
03e52840d   Kload   Init
382
383
384
  			}
  		}
  		$this->connection->setConfiguration(array('ldapCacheTTL' => $originalTTL));
6d9380f96   Cédric Dupont   Update sources OC...
385
386
387
  		$altName = $this->createAltInternalOwnCloudName($intName, $isUser);
  		if($this->mapComponent($dn, $altName, $isUser)) {
  			return $altName;
03e52840d   Kload   Init
388
389
390
  		}
  
  		//if everything else did not help..
31b7f2792   Kload   Upgrade to ownclo...
391
  		\OCP\Util::writeLog('user_ldap', 'Could not create unique name for '.$dn.'.', \OCP\Util::INFO);
03e52840d   Kload   Init
392
393
394
395
  		return false;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
396
397
398
  	 * gives back the user names as they are used ownClod internally
  	 * @param array $ldapUsers an array with the ldap Users result in style of array ( array ('dn' => foo, 'uid' => bar), ... )
  	 * @return array an array with the user names to use in ownCloud
03e52840d   Kload   Init
399
400
401
402
403
404
405
406
  	 *
  	 * gives back the user names as they are used ownClod internally
  	 */
  	public function ownCloudUserNames($ldapUsers) {
  		return $this->ldap2ownCloudNames($ldapUsers, true);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
407
408
409
  	 * gives back the group names as they are used ownClod internally
  	 * @param array $ldapGroups an array with the ldap Groups result in style of array ( array ('dn' => foo, 'cn' => bar), ... )
  	 * @return array an array with the group names to use in ownCloud
03e52840d   Kload   Init
410
411
412
413
414
415
  	 *
  	 * gives back the group names as they are used ownClod internally
  	 */
  	public function ownCloudGroupNames($ldapGroups) {
  		return $this->ldap2ownCloudNames($ldapGroups, false);
  	}
6d9380f96   Cédric Dupont   Update sources OC...
416
417
418
419
  	/**
  	 * @param string $dn
  	 * @return bool|string
  	 */
03e52840d   Kload   Init
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
  	private function findMappedUser($dn) {
  		static $query = null;
  		if(is_null($query)) {
  			$query = \OCP\DB::prepare('
  				SELECT `owncloud_name`
  				FROM `'.$this->getMapTable(true).'`
  				WHERE `ldap_dn` = ?'
  			);
  		}
  		$res = $query->execute(array($dn))->fetchOne();
  		if($res) {
  			return  $res;
  		}
  		return false;
  	}
6d9380f96   Cédric Dupont   Update sources OC...
435
436
437
438
  	/**
  	 * @param string $dn
  	 * @return bool|string
  	 */
03e52840d   Kload   Init
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
  	private function findMappedGroup($dn) {
  		static $query = null;
  		if(is_null($query)) {
  			$query = \OCP\DB::prepare('
  					SELECT `owncloud_name`
  					FROM `'.$this->getMapTable(false).'`
  					WHERE `ldap_dn` = ?'
  			);
  		}
  		$res = $query->execute(array($dn))->fetchOne();
  		if($res) {
  			return  $res;
  		}
  		return false;
  	}
6d9380f96   Cédric Dupont   Update sources OC...
454
455
456
457
458
  	/**
  	 * @param array $ldapObjects
  	 * @param bool $isUsers
  	 * @return array
  	 */
03e52840d   Kload   Init
459
460
461
462
463
464
465
466
467
468
  	private function ldap2ownCloudNames($ldapObjects, $isUsers) {
  		if($isUsers) {
  			$nameAttribute = $this->connection->ldapUserDisplayName;
  		} else {
  			$nameAttribute = $this->connection->ldapGroupDisplayName;
  		}
  		$ownCloudNames = array();
  
  		foreach($ldapObjects as $ldapObject) {
  			$nameByLDAP = isset($ldapObject[$nameAttribute]) ? $ldapObject[$nameAttribute] : null;
6d9380f96   Cédric Dupont   Update sources OC...
469
470
471
  			$ocName = $this->dn2ocname($ldapObject['dn'], $nameByLDAP, $isUsers);
  			if($ocName) {
  				$ownCloudNames[] = $ocName;
837968727   Kload   [enh] Upgrade to ...
472
473
474
  				if($isUsers) {
  					//cache the user names so it does not need to be retrieved
  					//again later (e.g. sharing dialogue).
6d9380f96   Cédric Dupont   Update sources OC...
475
  					$this->cacheUserDisplayName($ocName, $nameByLDAP);
837968727   Kload   [enh] Upgrade to ...
476
  				}
03e52840d   Kload   Init
477
478
479
480
481
482
483
  			}
  			continue;
  		}
  		return $ownCloudNames;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
484
485
486
  	 * caches the user display name
  	 * @param string $ocName the internal ownCloud username
  	 * @param string $displayName the display name
837968727   Kload   [enh] Upgrade to ...
487
  	 */
6d9380f96   Cédric Dupont   Update sources OC...
488
  	public function cacheUserDisplayName($ocName, $displayName) {
837968727   Kload   [enh] Upgrade to ...
489
  		$cacheKeyTrunk = 'getDisplayName';
6d9380f96   Cédric Dupont   Update sources OC...
490
  		$this->connection->writeToCache($cacheKeyTrunk.$ocName, $displayName);
837968727   Kload   [enh] Upgrade to ...
491
492
493
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
494
495
496
  	 * creates a unique name for internal ownCloud use for users. Don't call it directly.
  	 * @param string $name the display name of the object
  	 * @return string with with the name to use in ownCloud or false if unsuccessful
03e52840d   Kload   Init
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
  	 *
  	 * Instead of using this method directly, call
  	 * createAltInternalOwnCloudName($name, true)
  	 */
  	private function _createAltInternalOwnCloudNameForUsers($name) {
  		$attempts = 0;
  		//while loop is just a precaution. If a name is not generated within
  		//20 attempts, something else is very wrong. Avoids infinite loop.
  		while($attempts < 20){
  			$altName = $name . '_' . rand(1000,9999);
  			if(!\OCP\User::userExists($altName)) {
  				return $altName;
  			}
  			$attempts++;
  		}
  		return false;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
516
517
518
  	 * creates a unique name for internal ownCloud use for groups. Don't call it directly.
  	 * @param string $name the display name of the object
  	 * @return string with with the name to use in ownCloud or false if unsuccessful.
03e52840d   Kload   Init
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
  	 *
  	 * Instead of using this method directly, call
  	 * createAltInternalOwnCloudName($name, false)
  	 *
  	 * Group names are also used as display names, so we do a sequential
  	 * numbering, e.g. Developers_42 when there are 41 other groups called
  	 * "Developers"
  	 */
  	private function _createAltInternalOwnCloudNameForGroups($name) {
  		$query = \OCP\DB::prepare('
  			SELECT `owncloud_name`
  			FROM `'.$this->getMapTable(false).'`
  			WHERE `owncloud_name` LIKE ?
  		');
  
  		$usedNames = array();
  		$res = $query->execute(array($name.'_%'));
  		while($row = $res->fetchRow()) {
  			$usedNames[] = $row['owncloud_name'];
  		}
31b7f2792   Kload   Upgrade to ownclo...
539
  		if(!($usedNames) || count($usedNames) === 0) {
03e52840d   Kload   Init
540
541
542
  			$lastNo = 1; //will become name_2
  		} else {
  			natsort($usedNames);
6d9380f96   Cédric Dupont   Update sources OC...
543
544
  			$lastName = array_pop($usedNames);
  			$lastNo = intval(substr($lastName, strrpos($lastName, '_') + 1));
03e52840d   Kload   Init
545
546
547
548
549
550
  		}
  		$altName = $name.'_'.strval($lastNo+1);
  		unset($usedNames);
  
  		$attempts = 1;
  		while($attempts < 21){
6d9380f96   Cédric Dupont   Update sources OC...
551
552
553
  			// Check to be really sure it is unique
  			// while loop is just a precaution. If a name is not generated within
  			// 20 attempts, something else is very wrong. Avoids infinite loop.
03e52840d   Kload   Init
554
555
556
  			if(!\OC_Group::groupExists($altName)) {
  				return $altName;
  			}
6d9380f96   Cédric Dupont   Update sources OC...
557
  			$altName = $name . '_' . ($lastNo + $attempts);
03e52840d   Kload   Init
558
559
560
561
562
563
  			$attempts++;
  		}
  		return false;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
564
565
566
567
  	 * creates a unique name for internal ownCloud use.
  	 * @param string $name the display name of the object
  	 * @param boolean $isUser whether name should be created for a user (true) or a group (false)
  	 * @return string with with the name to use in ownCloud or false if unsuccessful
03e52840d   Kload   Init
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
  	 */
  	private function createAltInternalOwnCloudName($name, $isUser) {
  		$originalTTL = $this->connection->ldapCacheTTL;
  		$this->connection->setConfiguration(array('ldapCacheTTL' => 0));
  		if($isUser) {
  			$altName = $this->_createAltInternalOwnCloudNameForUsers($name);
  		} else {
  			$altName = $this->_createAltInternalOwnCloudNameForGroups($name);
  		}
  		$this->connection->setConfiguration(array('ldapCacheTTL' => $originalTTL));
  
  		return $altName;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
583
584
  	 * retrieves all known groups from the mappings table
  	 * @return array with the results
03e52840d   Kload   Init
585
586
587
588
589
590
591
592
  	 *
  	 * retrieves all known groups from the mappings table
  	 */
  	private function mappedGroups() {
  		return $this->mappedComponents(false);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
593
594
  	 * retrieves all known users from the mappings table
  	 * @return array with the results
03e52840d   Kload   Init
595
596
597
598
599
600
  	 *
  	 * retrieves all known users from the mappings table
  	 */
  	private function mappedUsers() {
  		return $this->mappedComponents(true);
  	}
6d9380f96   Cédric Dupont   Update sources OC...
601
602
603
604
  	/**
  	 * @param boolean $isUsers
  	 * @return array
  	 */
03e52840d   Kload   Init
605
606
607
608
609
610
611
612
613
614
615
616
  	private function mappedComponents($isUsers) {
  		$table = $this->getMapTable($isUsers);
  
  		$query = \OCP\DB::prepare('
  			SELECT `ldap_dn`, `owncloud_name`
  			FROM `'. $table . '`'
  		);
  
  		return $query->execute()->fetchAll();
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
617
618
619
620
621
  	 * inserts a new user or group into the mappings table
  	 * @param string $dn the record in question
  	 * @param string $ocName the name to use in ownCloud
  	 * @param bool $isUser is it a user or a group?
  	 * @return bool true on success, false otherwise
03e52840d   Kload   Init
622
623
624
  	 *
  	 * inserts a new user or group into the mappings table
  	 */
6d9380f96   Cédric Dupont   Update sources OC...
625
  	private function mapComponent($dn, $ocName, $isUser = true) {
03e52840d   Kload   Init
626
627
628
  		$table = $this->getMapTable($isUser);
  
  		$sqlAdjustment = '';
6d9380f96   Cédric Dupont   Update sources OC...
629
630
  		$dbType = \OCP\Config::getSystemValue('dbtype');
  		if($dbType === 'mysql' || $dbType == 'oci') {
03e52840d   Kload   Init
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
  			$sqlAdjustment = 'FROM DUAL';
  		}
  
  		$insert = \OCP\DB::prepare('
  			INSERT INTO `'.$table.'` (`ldap_dn`, `owncloud_name`, `directory_uuid`)
  				SELECT ?,?,?
  				'.$sqlAdjustment.'
  				WHERE NOT EXISTS (
  					SELECT 1
  					FROM `'.$table.'`
  					WHERE `ldap_dn` = ?
  						OR `owncloud_name` = ?)
  		');
  
  		//feed the DB
6d9380f96   Cédric Dupont   Update sources OC...
646
  		$insRows = $insert->execute(array($dn, $ocName,
31b7f2792   Kload   Upgrade to ownclo...
647
  										  $this->getUUID($dn, $isUser), $dn,
6d9380f96   Cédric Dupont   Update sources OC...
648
  										  $ocName));
03e52840d   Kload   Init
649
650
651
652
  
  		if(\OCP\DB::isError($insRows)) {
  			return false;
  		}
31b7f2792   Kload   Upgrade to ownclo...
653
  		if($insRows === 0) {
03e52840d   Kload   Init
654
655
  			return false;
  		}
837968727   Kload   [enh] Upgrade to ...
656
  		if($isUser) {
6d9380f96   Cédric Dupont   Update sources OC...
657
658
659
  			//make sure that email address is retrieved prior to login, so user
  			//will be notified when something is shared with him
  			$this->userManager->get($ocName)->update();
837968727   Kload   [enh] Upgrade to ...
660
  		}
03e52840d   Kload   Init
661
662
  		return true;
  	}
6d9380f96   Cédric Dupont   Update sources OC...
663
664
665
666
667
668
669
  	/**
  	 * @param string $filter
  	 * @param string|string[] $attr
  	 * @param int $limit
  	 * @param int $offset
  	 * @return array
  	 */
03e52840d   Kload   Init
670
671
672
  	public function fetchListOfUsers($filter, $attr, $limit = null, $offset = null) {
  		return $this->fetchList($this->searchUsers($filter, $attr, $limit, $offset), (count($attr) > 1));
  	}
6d9380f96   Cédric Dupont   Update sources OC...
673
674
675
676
677
678
679
  	/**
  	 * @param string $filter
  	 * @param string|string[] $attr
  	 * @param int $limit
  	 * @param int $offset
  	 * @return array
  	 */
03e52840d   Kload   Init
680
681
682
  	public function fetchListOfGroups($filter, $attr, $limit = null, $offset = null) {
  		return $this->fetchList($this->searchGroups($filter, $attr, $limit, $offset), (count($attr) > 1));
  	}
6d9380f96   Cédric Dupont   Update sources OC...
683
684
685
686
687
  	/**
  	 * @param array $list
  	 * @param bool $manyAttributes
  	 * @return array
  	 */
03e52840d   Kload   Init
688
689
690
691
692
693
694
695
696
697
698
699
700
701
  	private function fetchList($list, $manyAttributes) {
  		if(is_array($list)) {
  			if($manyAttributes) {
  				return $list;
  			} else {
  				return array_unique($list, SORT_LOCALE_STRING);
  			}
  		}
  
  		//error cause actually, maybe throw an exception in future.
  		return array();
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
702
703
704
705
706
707
  	 * executes an LDAP search, optimized for Users
  	 * @param string $filter the LDAP filter for the search
  	 * @param string|string[] $attr optional, when a certain attribute shall be filtered out
  	 * @param integer $limit
  	 * @param integer $offset
  	 * @return array with the search result
03e52840d   Kload   Init
708
709
710
711
712
713
  	 *
  	 * Executes an LDAP search
  	 */
  	public function searchUsers($filter, $attr = null, $limit = null, $offset = null) {
  		return $this->search($filter, $this->connection->ldapBaseUsers, $attr, $limit, $offset);
  	}
6d9380f96   Cédric Dupont   Update sources OC...
714
715
716
717
718
719
720
  	/**
  	 * @param string $filter
  	 * @param string|string[] $attr
  	 * @param int $limit
  	 * @param int $offset
  	 * @return false|int
  	 */
a293d369c   Kload   Update sources to...
721
  	public function countUsers($filter, $attr = array('dn'), $limit = null, $offset = null) {
837968727   Kload   [enh] Upgrade to ...
722
  		return $this->count($filter, $this->connection->ldapBaseUsers, $attr, $limit, $offset);
a293d369c   Kload   Update sources to...
723
  	}
03e52840d   Kload   Init
724
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
725
726
727
728
729
730
  	 * executes an LDAP search, optimized for Groups
  	 * @param string $filter the LDAP filter for the search
  	 * @param string|string[] $attr optional, when a certain attribute shall be filtered out
  	 * @param integer $limit
  	 * @param integer $offset
  	 * @return array with the search result
03e52840d   Kload   Init
731
732
733
734
735
736
737
738
  	 *
  	 * Executes an LDAP search
  	 */
  	public function searchGroups($filter, $attr = null, $limit = null, $offset = null) {
  		return $this->search($filter, $this->connection->ldapBaseGroups, $attr, $limit, $offset);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
739
740
741
742
743
744
745
746
747
748
749
750
  	 * returns the number of available groups
  	 * @param string $filter the LDAP search filter
  	 * @param string[] $attr optional
  	 * @param int|null $limit
  	 * @param int|null $offset
  	 * @return int|bool
  	 */
  	public function countGroups($filter, $attr = array('dn'), $limit = null, $offset = null) {
  		return $this->count($filter, $this->connection->ldapBaseGroups, $attr, $limit, $offset);
  	}
  
  	/**
03e52840d   Kload   Init
751
  	 * retrieved. Results will according to the order in the array.
6d9380f96   Cédric Dupont   Update sources OC...
752
753
754
  	 * @param int $limit optional, maximum results to be counted
  	 * @param int $offset optional, a starting point
  	 * @return array|false array with the search result as first value and pagedSearchOK as
a293d369c   Kload   Update sources to...
755
  	 * second | false if not successful
03e52840d   Kload   Init
756
  	 */
a293d369c   Kload   Update sources to...
757
  	private function executeSearch($filter, $base, &$attr = null, $limit = null, $offset = null) {
03e52840d   Kload   Init
758
759
760
761
762
  		if(!is_null($attr) && !is_array($attr)) {
  			$attr = array(mb_strtolower($attr, 'UTF-8'));
  		}
  
  		// See if we have a resource, in case not cancel with message
a293d369c   Kload   Update sources to...
763
764
  		$cr = $this->connection->getConnectionResource();
  		if(!$this->ldap->isResource($cr)) {
03e52840d   Kload   Init
765
766
767
  			// Seems like we didn't find any resource.
  			// Return an empty array just like before.
  			\OCP\Util::writeLog('user_ldap', 'Could not search, because resource is missing.', \OCP\Util::DEBUG);
a293d369c   Kload   Update sources to...
768
  			return false;
03e52840d   Kload   Init
769
  		}
6d9380f96   Cédric Dupont   Update sources OC...
770
  		//check whether paged search should be attempted
03e52840d   Kload   Init
771
  		$pagedSearchOK = $this->initPagedSearch($filter, $base, $attr, $limit, $offset);
a293d369c   Kload   Update sources to...
772
  		$linkResources = array_pad(array(), count($base), $cr);
31b7f2792   Kload   Upgrade to ownclo...
773
  		$sr = $this->ldap->search($linkResources, $base, $filter, $attr);
a293d369c   Kload   Update sources to...
774
  		$error = $this->ldap->errno($cr);
6d9380f96   Cédric Dupont   Update sources OC...
775
776
777
  		if ($pagedSearchOK) {
  			$this->ldap->controlPagedResult($cr, 999999, false, "");
  		}
31b7f2792   Kload   Upgrade to ownclo...
778
  		if(!is_array($sr) || $error !== 0) {
03e52840d   Kload   Init
779
  			\OCP\Util::writeLog('user_ldap',
a293d369c   Kload   Update sources to...
780
781
  				'Error when searching: '.$this->ldap->error($cr).
  					' code '.$this->ldap->errno($cr),
03e52840d   Kload   Init
782
783
  				\OCP\Util::ERROR);
  			\OCP\Util::writeLog('user_ldap', 'Attempt for Paging?  '.print_r($pagedSearchOK, true), \OCP\Util::ERROR);
a293d369c   Kload   Update sources to...
784
  			return false;
03e52840d   Kload   Init
785
  		}
a293d369c   Kload   Update sources to...
786
787
  		return array($sr, $pagedSearchOK);
  	}
03e52840d   Kload   Init
788

a293d369c   Kload   Update sources to...
789
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
790
791
792
793
794
795
796
797
798
  	 * processes an LDAP paged search operation
  	 * @param array $sr the array containing the LDAP search resources
  	 * @param string $filter the LDAP filter for the search
  	 * @param array $base an array containing the LDAP subtree(s) that shall be searched
  	 * @param int $iFoundItems number of results in the search operation
  	 * @param int $limit maximum results to be counted
  	 * @param int $offset a starting point
  	 * @param bool $pagedSearchOK whether a paged search has been executed
  	 * @param bool $skipHandling required for paged search when cookies to
a293d369c   Kload   Update sources to...
799
  	 * prior results need to be gained
6d9380f96   Cédric Dupont   Update sources OC...
800
  	 * @return array|false array with the search result as first value and pagedSearchOK as
a293d369c   Kload   Update sources to...
801
802
803
  	 * second | false if not successful
  	 */
  	private function processPagedSearchStatus($sr, $filter, $base, $iFoundItems, $limit, $offset, $pagedSearchOK, $skipHandling) {
03e52840d   Kload   Init
804
  		if($pagedSearchOK) {
a293d369c   Kload   Update sources to...
805
  			$cr = $this->connection->getConnectionResource();
03e52840d   Kload   Init
806
807
  			foreach($sr as $key => $res) {
  				$cookie = null;
a293d369c   Kload   Update sources to...
808
  				if($this->ldap->controlPagedResultResponse($cr, $res, $cookie)) {
03e52840d   Kload   Init
809
810
811
812
813
814
815
816
817
818
819
  					$this->setPagedResultCookie($base[$key], $filter, $limit, $offset, $cookie);
  				}
  			}
  
  			//browsing through prior pages to get the cookie for the new one
  			if($skipHandling) {
  				return;
  			}
  			// if count is bigger, then the server does not support
  			// paged search. Instead, he did a normal search. We set a
  			// flag here, so the callee knows how to deal with it.
a293d369c   Kload   Update sources to...
820
  			if($iFoundItems <= $limit) {
03e52840d   Kload   Init
821
822
823
824
  				$this->pagedSearchedSuccessful = true;
  			}
  		} else {
  			if(!is_null($limit)) {
a293d369c   Kload   Update sources to...
825
  				\OCP\Util::writeLog('user_ldap', 'Paged search was not available', \OCP\Util::INFO);
03e52840d   Kload   Init
826
827
  			}
  		}
a293d369c   Kload   Update sources to...
828
829
830
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
831
832
833
834
  	 * executes an LDAP search, but counts the results only
  	 * @param string $filter the LDAP filter for the search
  	 * @param array $base an array containing the LDAP subtree(s) that shall be searched
  	 * @param string|string[] $attr optional, array, one or more attributes that shall be
a293d369c   Kload   Update sources to...
835
  	 * retrieved. Results will according to the order in the array.
6d9380f96   Cédric Dupont   Update sources OC...
836
837
838
  	 * @param int $limit optional, maximum results to be counted
  	 * @param int $offset optional, a starting point
  	 * @param bool $skipHandling indicates whether the pages search operation is
a293d369c   Kload   Update sources to...
839
  	 * completed
6d9380f96   Cédric Dupont   Update sources OC...
840
  	 * @return int|false Integer or false if the search could not be initialized
a293d369c   Kload   Update sources to...
841
842
843
844
  	 *
  	 */
  	private function count($filter, $base, $attr = null, $limit = null, $offset = null, $skipHandling = false) {
  		\OCP\Util::writeLog('user_ldap', 'Count filter:  '.print_r($filter, true), \OCP\Util::DEBUG);
837968727   Kload   [enh] Upgrade to ...
845

6d9380f96   Cédric Dupont   Update sources OC...
846
847
  		if(is_null($limit) || $limit <= 0) {
  			$limit = intval($this->connection->ldapPagingSize);
a293d369c   Kload   Update sources to...
848
  		}
837968727   Kload   [enh] Upgrade to ...
849

a293d369c   Kload   Update sources to...
850
  		$counter = 0;
837968727   Kload   [enh] Upgrade to ...
851
  		$count = null;
6d9380f96   Cédric Dupont   Update sources OC...
852
  		$this->connection->getConnectionResource();
837968727   Kload   [enh] Upgrade to ...
853
854
855
856
857
858
859
  
  		do {
  			$continue = false;
  			$search = $this->executeSearch($filter, $base, $attr,
  										   $limit, $offset);
  			if($search === false) {
  				return $counter > 0 ? $counter : false;
a293d369c   Kload   Update sources to...
860
  			}
837968727   Kload   [enh] Upgrade to ...
861
862
863
864
  			list($sr, $pagedSearchOK) = $search;
  
  			$count = $this->countEntriesInSearchResults($sr, $limit, $continue);
  			$counter += $count;
a293d369c   Kload   Update sources to...
865

837968727   Kload   [enh] Upgrade to ...
866
  			$this->processPagedSearchStatus($sr, $filter, $base, $count, $limit,
a293d369c   Kload   Update sources to...
867
  										$offset, $pagedSearchOK, $skipHandling);
837968727   Kload   [enh] Upgrade to ...
868
869
870
871
872
  			$offset += $limit;
  		} while($continue);
  
  		return $counter;
  	}
6d9380f96   Cédric Dupont   Update sources OC...
873
874
875
876
877
878
879
  	/**
  	 * @param array $searchResults
  	 * @param int $limit
  	 * @param bool $hasHitLimit
  	 * @return int
  	 */
  	private function countEntriesInSearchResults($searchResults, $limit, &$hasHitLimit) {
837968727   Kload   [enh] Upgrade to ...
880
  		$cr = $this->connection->getConnectionResource();
6d9380f96   Cédric Dupont   Update sources OC...
881
  		$counter = 0;
837968727   Kload   [enh] Upgrade to ...
882
883
884
885
886
887
888
889
  
  		foreach($searchResults as $res) {
  			$count = intval($this->ldap->countEntries($cr, $res));
  			$counter += $count;
  			if($count === $limit) {
  				$hasHitLimit = true;
  			}
  		}
a293d369c   Kload   Update sources to...
890
891
892
893
894
  
  		return $counter;
  	}
  
  	/**
a293d369c   Kload   Update sources to...
895
  	 * Executes an LDAP search
6d9380f96   Cédric Dupont   Update sources OC...
896
897
898
899
900
901
902
  	 * @param string $filter the LDAP filter for the search
  	 * @param array $base an array containing the LDAP subtree(s) that shall be searched
  	 * @param string|string[] $attr optional, array, one or more attributes that shall be
  	 * @param int $limit
  	 * @param int $offset
  	 * @param bool $skipHandling
  	 * @return array with the search result
a293d369c   Kload   Update sources to...
903
904
  	 */
  	private function search($filter, $base, $attr = null, $limit = null, $offset = null, $skipHandling = false) {
6d9380f96   Cédric Dupont   Update sources OC...
905
906
907
908
  		if($limit <= 0) {
  			//otherwise search will fail
  			$limit = null;
  		}
a293d369c   Kload   Update sources to...
909
910
911
912
913
914
915
916
917
918
919
920
921
922
  		$search = $this->executeSearch($filter, $base, $attr, $limit, $offset);
  		if($search === false) {
  			return array();
  		}
  		list($sr, $pagedSearchOK) = $search;
  		$cr = $this->connection->getConnectionResource();
  
  		if($skipHandling) {
  			//i.e. result do not need to be fetched, we just need the cookie
  			//thus pass 1 or any other value as $iFoundItems because it is not
  			//used
  			$this->processPagedSearchStatus($sr, $filter, $base, 1, $limit,
  											$offset, $pagedSearchOK,
  											$skipHandling);
6d9380f96   Cédric Dupont   Update sources OC...
923
  			return array();
a293d369c   Kload   Update sources to...
924
925
926
927
928
929
930
931
932
933
  		}
  
  		// Do the server-side sorting
  		foreach(array_reverse($attr) as $sortAttr){
  			foreach($sr as $searchResource) {
  				$this->ldap->sort($cr, $searchResource, $sortAttr);
  			}
  		}
  
  		$findings = array();
6d9380f96   Cédric Dupont   Update sources OC...
934
935
  		foreach($sr as $res) {
  			$findings = array_merge($findings, $this->ldap->getEntries($cr	, $res ));
a293d369c   Kload   Update sources to...
936
937
938
939
940
  		}
  
  		$this->processPagedSearchStatus($sr, $filter, $base, $findings['count'],
  										$limit, $offset, $pagedSearchOK,
  										$skipHandling);
03e52840d   Kload   Init
941
942
943
944
945
946
947
948
949
  
  		// if we're here, probably no connection resource is returned.
  		// to make ownCloud behave nicely, we simply give back an empty array.
  		if(is_null($findings)) {
  			return array();
  		}
  
  		if(!is_null($attr)) {
  			$selection = array();
6d9380f96   Cédric Dupont   Update sources OC...
950
  			$multiArray = false;
03e52840d   Kload   Init
951
  			if(count($attr) > 1) {
6d9380f96   Cédric Dupont   Update sources OC...
952
  				$multiArray = true;
03e52840d   Kload   Init
953
954
955
956
957
958
959
  				$i = 0;
  			}
  			foreach($findings as $item) {
  				if(!is_array($item)) {
  					continue;
  				}
  				$item = \OCP\Util::mb_array_change_key_case($item, MB_CASE_LOWER, 'UTF-8');
6d9380f96   Cédric Dupont   Update sources OC...
960
  				if($multiArray) {
03e52840d   Kload   Init
961
962
963
  					foreach($attr as $key) {
  						$key = mb_strtolower($key, 'UTF-8');
  						if(isset($item[$key])) {
31b7f2792   Kload   Upgrade to ownclo...
964
  							if($key !== 'dn') {
03e52840d   Kload   Init
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
  								$selection[$i][$key] = $this->resemblesDN($key) ?
  									$this->sanitizeDN($item[$key][0])
  									: $item[$key][0];
  							} else {
  								$selection[$i][$key] = $this->sanitizeDN($item[$key]);
  							}
  						}
  
  					}
  					$i++;
  				} else {
  					//tribute to case insensitivity
  					$key = mb_strtolower($attr[0], 'UTF-8');
  
  					if(isset($item[$key])) {
  						if($this->resemblesDN($key)) {
  							$selection[] = $this->sanitizeDN($item[$key]);
  						} else {
  							$selection[] = $item[$key];
  						}
  					}
  				}
  			}
  			$findings = $selection;
  		}
  		//we slice the findings, when
6d9380f96   Cédric Dupont   Update sources OC...
991
  		//a) paged search unsuccessful, though attempted
03e52840d   Kload   Init
992
  		//b) no paged search, but limit set
837968727   Kload   [enh] Upgrade to ...
993
  		if((!$this->getPagedSearchResultState()
03e52840d   Kload   Init
994
995
996
997
998
999
1000
1001
1002
1003
  			&& $pagedSearchOK)
  			|| (
  				!$pagedSearchOK
  				&& !is_null($limit)
  			)
  		) {
  			$findings = array_slice($findings, intval($offset), $limit);
  		}
  		return $findings;
  	}
6d9380f96   Cédric Dupont   Update sources OC...
1004
1005
1006
1007
  	/**
  	 * @param string $name
  	 * @return bool|mixed|string
  	 */
03e52840d   Kload   Init
1008
1009
1010
1011
  	public function sanitizeUsername($name) {
  		if($this->connection->ldapIgnoreNamingRules) {
  			return $name;
  		}
6d9380f96   Cédric Dupont   Update sources OC...
1012
1013
  		// Transliteration
  		// latin characters to ASCII
03e52840d   Kload   Init
1014
  		$name = iconv('UTF-8', 'ASCII//TRANSLIT', $name);
6d9380f96   Cédric Dupont   Update sources OC...
1015
  		// Replacements
03e52840d   Kload   Init
1016
  		$name = \OCP\Util::mb_str_replace(' ', '_', $name, 'UTF-8');
6d9380f96   Cédric Dupont   Update sources OC...
1017
  		// Every remaining disallowed characters will be removed
03e52840d   Kload   Init
1018
1019
1020
1021
1022
1023
  		$name = preg_replace('/[^a-zA-Z0-9_.@-]/u', '', $name);
  
  		return $name;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1024
1025
1026
  	* escapes (user provided) parts for LDAP filter
  	* @param string $input, the provided value
  	* @return string the escaped string
a293d369c   Kload   Update sources to...
1027
1028
1029
1030
1031
1032
1033
1034
  	*/
  	public function escapeFilterPart($input) {
  		$search  = array('*', '\\', '(', ')');
  		$replace = array('\\*', '\\\\', '\\(', '\\)');
  		return str_replace($search, $replace, $input);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1035
1036
1037
  	 * combines the input filters with AND
  	 * @param string[] $filters the filters to connect
  	 * @return string the combined filter
03e52840d   Kload   Init
1038
1039
1040
1041
1042
1043
  	 */
  	public function combineFilterWithAnd($filters) {
  		return $this->combineFilter($filters, '&');
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1044
1045
1046
1047
  	 * combines the input filters with OR
  	 * @param string[] $filters the filters to connect
  	 * @return string the combined filter
  	 * Combines Filter arguments with OR
03e52840d   Kload   Init
1048
1049
1050
1051
1052
1053
  	 */
  	public function combineFilterWithOr($filters) {
  		return $this->combineFilter($filters, '|');
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1054
1055
1056
1057
  	 * combines the input filters with given operator
  	 * @param string[] $filters the filters to connect
  	 * @param string $operator either & or |
  	 * @return string the combined filter
03e52840d   Kload   Init
1058
1059
1060
1061
  	 */
  	private function combineFilter($filters, $operator) {
  		$combinedFilter = '('.$operator;
  		foreach($filters as $filter) {
6d9380f96   Cédric Dupont   Update sources OC...
1062
  			if(!empty($filter) && $filter[0] !== '(') {
03e52840d   Kload   Init
1063
  				$filter = '('.$filter.')';
6d9380f96   Cédric Dupont   Update sources OC...
1064
1065
  			}
  			$combinedFilter.=$filter;
03e52840d   Kload   Init
1066
1067
1068
1069
1070
1071
  		}
  		$combinedFilter.=')';
  		return $combinedFilter;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1072
  	 * creates a filter part for to perform search for users
03e52840d   Kload   Init
1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
  	 * @param string $search the search term
  	 * @return string the final filter part to use in LDAP searches
  	 */
  	public function getFilterPartForUserSearch($search) {
  		return $this->getFilterPartForSearch($search,
  			$this->connection->ldapAttributesForUserSearch,
  			$this->connection->ldapUserDisplayName);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1083
  	 * creates a filter part for to perform search for groups
03e52840d   Kload   Init
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
  	 * @param string $search the search term
  	 * @return string the final filter part to use in LDAP searches
  	 */
  	public function getFilterPartForGroupSearch($search) {
  		return $this->getFilterPartForSearch($search,
  			$this->connection->ldapAttributesForGroupSearch,
  			$this->connection->ldapGroupDisplayName);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1094
  	 * creates a filter part for searches
03e52840d   Kload   Init
1095
  	 * @param string $search the search term
6d9380f96   Cédric Dupont   Update sources OC...
1096
  	 * @param string[]|null $searchAttributes
03e52840d   Kload   Init
1097
1098
  	 * @param string $fallbackAttribute a fallback attribute in case the user
  	 * did not define search attributes. Typically the display name attribute.
6d9380f96   Cédric Dupont   Update sources OC...
1099
  	 * @return string the final filter part to use in LDAP searches
03e52840d   Kload   Init
1100
1101
1102
1103
  	 */
  	private function getFilterPartForSearch($search, $searchAttributes, $fallbackAttribute) {
  		$filter = array();
  		$search = empty($search) ? '*' : '*'.$search.'*';
31b7f2792   Kload   Upgrade to ownclo...
1104
  		if(!is_array($searchAttributes) || count($searchAttributes) === 0) {
03e52840d   Kload   Init
1105
1106
1107
1108
1109
1110
1111
1112
1113
  			if(empty($fallbackAttribute)) {
  				return '';
  			}
  			$filter[] = $fallbackAttribute . '=' . $search;
  		} else {
  			foreach($searchAttributes as $attribute) {
  				$filter[] = $attribute . '=' . $search;
  			}
  		}
31b7f2792   Kload   Upgrade to ownclo...
1114
  		if(count($filter) === 1) {
03e52840d   Kload   Init
1115
1116
1117
1118
  			return '('.$filter[0].')';
  		}
  		return $this->combineFilterWithOr($filter);
  	}
6d9380f96   Cédric Dupont   Update sources OC...
1119
1120
1121
1122
1123
  	/**
  	 * @param string $name
  	 * @param string $password
  	 * @return bool
  	 */
03e52840d   Kload   Init
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
  	public function areCredentialsValid($name, $password) {
  		$name = $this->DNasBaseParameter($name);
  		$testConnection = clone $this->connection;
  		$credentials = array(
  			'ldapAgentName' => $name,
  			'ldapAgentPassword' => $password
  		);
  		if(!$testConnection->setConfiguration($credentials)) {
  			return false;
  		}
  		$result=$testConnection->bind();
  		$this->connection->bind();
  		return $result;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1140
1141
1142
1143
1144
  	 * auto-detects the directory's UUID attribute
  	 * @param string $dn a known DN used to check against
  	 * @param bool $isUser
  	 * @param bool $force the detection should be run, even if it is not set to auto
  	 * @return bool true on success, false otherwise
03e52840d   Kload   Init
1145
  	 */
31b7f2792   Kload   Upgrade to ownclo...
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
  	private function detectUuidAttribute($dn, $isUser = true, $force = false) {
  		if($isUser) {
  			$uuidAttr     = 'ldapUuidUserAttribute';
  			$uuidOverride = $this->connection->ldapExpertUUIDUserAttr;
  		} else {
  			$uuidAttr     = 'ldapUuidGroupAttribute';
  			$uuidOverride = $this->connection->ldapExpertUUIDGroupAttr;
  		}
  
  		if(($this->connection->$uuidAttr !== 'auto') && !$force) {
03e52840d   Kload   Init
1156
1157
  			return true;
  		}
31b7f2792   Kload   Upgrade to ownclo...
1158
1159
  		if(!empty($uuidOverride) && !$force) {
  			$this->connection->$uuidAttr = $uuidOverride;
03e52840d   Kload   Init
1160
1161
  			return true;
  		}
6d9380f96   Cédric Dupont   Update sources OC...
1162
  		// for now, supported attributes are entryUUID, nsuniqueid, objectGUID, ipaUniqueID
837968727   Kload   [enh] Upgrade to ...
1163
  		$testAttributes = array('entryuuid', 'nsuniqueid', 'objectguid', 'guid', 'ipauniqueid');
03e52840d   Kload   Init
1164
1165
  
  		foreach($testAttributes as $attribute) {
03e52840d   Kload   Init
1166
1167
  			$value = $this->readAttribute($dn, $attribute);
  			if(is_array($value) && isset($value[0]) && !empty($value[0])) {
31b7f2792   Kload   Upgrade to ownclo...
1168
1169
1170
1171
  				\OCP\Util::writeLog('user_ldap',
  									'Setting '.$attribute.' as '.$uuidAttr,
  									\OCP\Util::DEBUG);
  				$this->connection->$uuidAttr = $attribute;
03e52840d   Kload   Init
1172
1173
  				return true;
  			}
03e52840d   Kload   Init
1174
  		}
31b7f2792   Kload   Upgrade to ownclo...
1175
1176
1177
  		\OCP\Util::writeLog('user_ldap',
  							'Could not autodetect the UUID attribute',
  							\OCP\Util::ERROR);
03e52840d   Kload   Init
1178
1179
1180
  
  		return false;
  	}
6d9380f96   Cédric Dupont   Update sources OC...
1181
1182
1183
1184
1185
  	/**
  	 * @param string $dn
  	 * @param bool $isUser
  	 * @return array|bool|false
  	 */
31b7f2792   Kload   Upgrade to ownclo...
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
1200
1201
1202
  	public function getUUID($dn, $isUser = true) {
  		if($isUser) {
  			$uuidAttr     = 'ldapUuidUserAttribute';
  			$uuidOverride = $this->connection->ldapExpertUUIDUserAttr;
  		} else {
  			$uuidAttr     = 'ldapUuidGroupAttribute';
  			$uuidOverride = $this->connection->ldapExpertUUIDGroupAttr;
  		}
  
  		$uuid = false;
  		if($this->detectUuidAttribute($dn, $isUser)) {
  			$uuid = $this->readAttribute($dn, $this->connection->$uuidAttr);
  			if( !is_array($uuid)
  				&& !empty($uuidOverride)
  				&& $this->detectUuidAttribute($dn, $isUser, true)) {
  					$uuid = $this->readAttribute($dn,
  												 $this->connection->$uuidAttr);
03e52840d   Kload   Init
1203
1204
1205
  			}
  			if(is_array($uuid) && isset($uuid[0]) && !empty($uuid[0])) {
  				$uuid = $uuid[0];
03e52840d   Kload   Init
1206
  			}
03e52840d   Kload   Init
1207
  		}
31b7f2792   Kload   Upgrade to ownclo...
1208

03e52840d   Kload   Init
1209
1210
1211
1212
  		return $uuid;
  	}
  
  	/**
03e52840d   Kload   Init
1213
  	 * converts a binary ObjectGUID into a string representation
6d9380f96   Cédric Dupont   Update sources OC...
1214
1215
1216
  	 * @param string $oguid the ObjectGUID in it's binary form as retrieved from AD
  	 * @return string
  	 * @link http://www.php.net/manual/en/function.ldap-get-values-len.php#73198
03e52840d   Kload   Init
1217
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
1234
1235
1236
1237
1238
  	 */
  	private function convertObjectGUID2Str($oguid) {
  		$hex_guid = bin2hex($oguid);
  		$hex_guid_to_guid_str = '';
  		for($k = 1; $k <= 4; ++$k) {
  			$hex_guid_to_guid_str .= substr($hex_guid, 8 - 2 * $k, 2);
  		}
  		$hex_guid_to_guid_str .= '-';
  		for($k = 1; $k <= 2; ++$k) {
  			$hex_guid_to_guid_str .= substr($hex_guid, 12 - 2 * $k, 2);
  		}
  		$hex_guid_to_guid_str .= '-';
  		for($k = 1; $k <= 2; ++$k) {
  			$hex_guid_to_guid_str .= substr($hex_guid, 16 - 2 * $k, 2);
  		}
  		$hex_guid_to_guid_str .= '-' . substr($hex_guid, 16, 4);
  		$hex_guid_to_guid_str .= '-' . substr($hex_guid, 20);
  
  		return strtoupper($hex_guid_to_guid_str);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1239
1240
1241
1242
1243
1244
1245
1246
1247
1248
1249
1250
1251
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
  	 * gets a SID of the domain of the given dn
  	 * @param string $dn
  	 * @return string|bool
  	 */
  	public function getSID($dn) {
  		$domainDN = $this->getDomainDNFromDN($dn);
  		$cacheKey = 'getSID-'.$domainDN;
  		if($this->connection->isCached($cacheKey)) {
  			return $this->connection->getFromCache($cacheKey);
  		}
  
  		$objectSid = $this->readAttribute($domainDN, 'objectsid');
  		if(!is_array($objectSid) || empty($objectSid)) {
  			$this->connection->writeToCache($cacheKey, false);
  			return false;
  		}
  		$domainObjectSid = $this->convertSID2Str($objectSid[0]);
  		$this->connection->writeToCache($cacheKey, $domainObjectSid);
  
  		return $domainObjectSid;
  	}
  
  	/**
  	 * converts a binary SID into a string representation
  	 * @param string $sid
  	 * @return string
  	 * @link http://blogs.freebsdish.org/tmclaugh/2010/07/21/finding-a-users-primary-group-in-ad/#comment-2855
  	 */
  	public function convertSID2Str($sid) {
  		try {
  			if(!function_exists('bcadd')) {
  				\OCP\Util::writeLog('user_ldap',
  					'You need to install bcmath module for PHP to have support ' .
  					'for AD primary groups', \OCP\Util::WARN);
  				throw new \Exception('missing bcmath module');
  			}
  			$srl = ord($sid[0]);
  			$numberSubID = ord($sid[1]);
  			$x = substr($sid, 2, 6);
  			$h = unpack('N', "\x0\x0" . substr($x,0,2));
  			$l = unpack('N', substr($x,2,6));
  			$iav = bcadd(bcmul($h[1], bcpow(2,32)), $l[1]);
  			$subIDs = array();
  			for ($i=0; $i<$numberSubID; $i++) {
  				$subID = unpack('V', substr($sid, 8+4*$i, 4));
  				$subIDs[] = $subID[1];
  			}
  		} catch (\Exception $e) {
  			return '';
  		}
  
  		return sprintf('S-%d-%d-%s', $srl, $iav, implode('-', $subIDs));
  	}
  
  	/**
  	 * converts a stored DN so it can be used as base parameter for LDAP queries, internally we store them for usage in LDAP filters
  	 * @param string $dn the DN
  	 * @return string
03e52840d   Kload   Init
1297
1298
1299
1300
1301
1302
  	 */
  	private function DNasBaseParameter($dn) {
  		return str_ireplace('\\5c', '\\', $dn);
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1303
1304
1305
1306
  	 * checks if the given DN is part of the given base DN(s)
  	 * @param string $dn the DN
  	 * @param string[] $bases array containing the allowed base DN or DNs
  	 * @return bool
03e52840d   Kload   Init
1307
1308
  	 */
  	private function isDNPartOfBase($dn, $bases) {
6d9380f96   Cédric Dupont   Update sources OC...
1309
  		$belongsToBase = false;
03e52840d   Kload   Init
1310
  		$bases = $this->sanitizeDN($bases);
6d9380f96   Cédric Dupont   Update sources OC...
1311

03e52840d   Kload   Init
1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
  		foreach($bases as $base) {
  			$belongsToBase = true;
  			if(mb_strripos($dn, $base, 0, 'UTF-8') !== (mb_strlen($dn, 'UTF-8')-mb_strlen($base, 'UTF-8'))) {
  				$belongsToBase = false;
  			}
  			if($belongsToBase) {
  				break;
  			}
  		}
  		return $belongsToBase;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1325
1326
1327
1328
1329
1330
  	 * get a cookie for the next LDAP paged search
  	 * @param string $base a string with the base DN for the search
  	 * @param string $filter the search filter to identify the correct search
  	 * @param int $limit the limit (or 'pageSize'), to identify the correct search well
  	 * @param int $offset the offset for the new search to identify the correct search really good
  	 * @return string containing the key or empty if none is cached
03e52840d   Kload   Init
1331
1332
  	 */
  	private function getPagedResultCookie($base, $filter, $limit, $offset) {
31b7f2792   Kload   Upgrade to ownclo...
1333
  		if($offset === 0) {
03e52840d   Kload   Init
1334
1335
1336
1337
  			return '';
  		}
  		$offset -= $limit;
  		//we work with cache here
6d9380f96   Cédric Dupont   Update sources OC...
1338
  		$cacheKey = 'lc' . crc32($base) . '-' . crc32($filter) . '-' . intval($limit) . '-' . intval($offset);
03e52840d   Kload   Init
1339
  		$cookie = '';
6d9380f96   Cédric Dupont   Update sources OC...
1340
1341
  		if(isset($this->cookies[$cacheKey])) {
  			$cookie = $this->cookies[$cacheKey];
03e52840d   Kload   Init
1342
1343
1344
1345
1346
1347
1348
1349
  			if(is_null($cookie)) {
  				$cookie = '';
  			}
  		}
  		return $cookie;
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1350
1351
1352
1353
1354
1355
  	 * set a cookie for LDAP paged search run
  	 * @param string $base a string with the base DN for the search
  	 * @param string $filter the search filter to identify the correct search
  	 * @param int $limit the limit (or 'pageSize'), to identify the correct search well
  	 * @param int $offset the offset for the run search to identify the correct search really good
  	 * @param string $cookie string containing the cookie returned by ldap_control_paged_result_response
03e52840d   Kload   Init
1356
1357
1358
1359
  	 * @return void
  	 */
  	private function setPagedResultCookie($base, $filter, $limit, $offset, $cookie) {
  		if(!empty($cookie)) {
6d9380f96   Cédric Dupont   Update sources OC...
1360
1361
  			$cacheKey = 'lc' . crc32($base) . '-' . crc32($filter) . '-' .intval($limit) . '-' . intval($offset);
  			$this->cookies[$cacheKey] = $cookie;
03e52840d   Kload   Init
1362
1363
1364
1365
  		}
  	}
  
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1366
1367
  	 * Check whether the most recent paged search was successful. It flushed the state var. Use it always after a possible paged search.
  	 * @return boolean|null true on success, null or false otherwise
03e52840d   Kload   Init
1368
1369
1370
1371
1372
1373
  	 */
  	public function getPagedSearchResultState() {
  		$result = $this->pagedSearchedSuccessful;
  		$this->pagedSearchedSuccessful = null;
  		return $result;
  	}
03e52840d   Kload   Init
1374
  	/**
6d9380f96   Cédric Dupont   Update sources OC...
1375
1376
1377
1378
1379
1380
1381
  	 * Prepares a paged search, if possible
  	 * @param string $filter the LDAP filter for the search
  	 * @param string[] $bases an array containing the LDAP subtree(s) that shall be searched
  	 * @param string[] $attr optional, when a certain attribute shall be filtered outside
  	 * @param int $limit
  	 * @param int $offset
  	 * @return bool|true
03e52840d   Kload   Init
1382
1383
1384
1385
1386
1387
  	 */
  	private function initPagedSearch($filter, $bases, $attr, $limit, $offset) {
  		$pagedSearchOK = false;
  		if($this->connection->hasPagedResultSupport && !is_null($limit)) {
  			$offset = intval($offset); //can be null
  			\OCP\Util::writeLog('user_ldap',
6d9380f96   Cédric Dupont   Update sources OC...
1388
  				'initializing paged search for  Filter '.$filter.' base '.print_r($bases, true)
03e52840d   Kload   Init
1389
  				.' attr '.print_r($attr, true). ' limit ' .$limit.' offset '.$offset,
6d9380f96   Cédric Dupont   Update sources OC...
1390
  				\OCP\Util::DEBUG);
03e52840d   Kload   Init
1391
1392
1393
1394
1395
1396
  			//get the cookie from the search for the previous search, required by LDAP
  			foreach($bases as $base) {
  
  				$cookie = $this->getPagedResultCookie($base, $filter, $limit, $offset);
  				if(empty($cookie) && ($offset > 0)) {
  					// no cookie known, although the offset is not 0. Maybe cache run out. We need
6d9380f96   Cédric Dupont   Update sources OC...
1397
  					// to start all over *sigh* (btw, Dear Reader, did you know LDAP paged
03e52840d   Kload   Init
1398
  					// searching was designed by MSFT?)
6d9380f96   Cédric Dupont   Update sources OC...
1399
  					// 		Lukas: No, but thanks to reading that source I finally know!
03e52840d   Kload   Init
1400
1401
1402
1403
1404
1405
1406
1407
1408
1409
1410
1411
1412
  					$reOffset = ($offset - $limit) < 0 ? 0 : $offset - $limit;
  					//a bit recursive, $offset of 0 is the exit
  					\OCP\Util::writeLog('user_ldap', 'Looking for cookie L/O '.$limit.'/'.$reOffset, \OCP\Util::INFO);
  					$this->search($filter, array($base), $attr, $limit, $reOffset, true);
  					$cookie = $this->getPagedResultCookie($base, $filter, $limit, $offset);
  					//still no cookie? obviously, the server does not like us. Let's skip paging efforts.
  					//TODO: remember this, probably does not change in the next request...
  					if(empty($cookie)) {
  						$cookie = null;
  					}
  				}
  				if(!is_null($cookie)) {
  					if($offset > 0) {
6d9380f96   Cédric Dupont   Update sources OC...
1413
  						\OCP\Util::writeLog('user_ldap', 'Cookie '.CRC32($cookie), \OCP\Util::INFO);
03e52840d   Kload   Init
1414
  					}
31b7f2792   Kload   Upgrade to ownclo...
1415
1416
1417
  					$pagedSearchOK = $this->ldap->controlPagedResult(
  						$this->connection->getConnectionResource(), $limit,
  						false, $cookie);
03e52840d   Kload   Init
1418
1419
1420
1421
1422
1423
1424
1425
1426
1427
1428
1429
1430
1431
1432
1433
1434
  					if(!$pagedSearchOK) {
  						return false;
  					}
  					\OCP\Util::writeLog('user_ldap', 'Ready for a paged search', \OCP\Util::INFO);
  				} else {
  					\OCP\Util::writeLog('user_ldap',
  						'No paged search for us, Cpt., Limit '.$limit.' Offset '.$offset,
  						\OCP\Util::INFO);
  				}
  
  			}
  		}
  
  		return $pagedSearchOK;
  	}
  
  }