2012-04-14 20:05:29 +04:00
< ? php
/**
2012-07-25 14:37:39 +04:00
* ownCloud – LDAP Access
2012-04-14 20:05:29 +04:00
*
* @ author Arthur Schiwon
* @ copyright 2012 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 />.
*
*/
2012-07-25 14:37:39 +04:00
namespace OCA\user_ldap\lib ;
2012-04-15 15:37:35 +04:00
2012-07-25 14:37:39 +04:00
abstract class Access {
protected $connection ;
2012-10-26 23:53:56 +04:00
//never ever check this var directly, always use getPagedSearchResultState
protected $pagedSearchedSuccessful ;
2012-07-25 14:37:39 +04:00
public function setConnector ( Connection & $connection ) {
$this -> connection = $connection ;
}
private function checkConnection () {
return ( $this -> connection instanceof Connection );
2012-04-16 20:03:02 +04:00
}
2012-06-07 20:13:41 +04:00
2012-05-17 21:33:38 +04:00
/**
2012-07-25 14:37:39 +04:00
* @ brief reads a given attribute for an LDAP record identified by a DN
* @ param $dn the record in question
* @ param $attr the attribute that shall be retrieved
* @ returns the values in an array on success , false otherwise
2012-05-17 21:33:38 +04:00
*
2012-07-25 14:37:39 +04:00
* Reads an attribute from an LDAP entry
2012-05-17 21:33:38 +04:00
*/
2012-07-25 14:37:39 +04:00
public function readAttribute ( $dn , $attr ) {
if ( ! $this -> checkConnection ()) {
\OCP\Util :: writeLog ( 'user_ldap' , 'No LDAP Connector assigned, access impossible for readAttribute.' , \OCP\Util :: WARN );
return false ;
2012-06-07 20:13:41 +04:00
}
2012-07-25 14:37:39 +04:00
$cr = $this -> connection -> getConnectionResource ();
2012-07-25 20:40:48 +04:00
if ( ! is_resource ( $cr )) {
//LDAP not available
2012-08-23 20:29:43 +04:00
\OCP\Util :: writeLog ( 'user_ldap' , 'LDAP resource not available.' , \OCP\Util :: DEBUG );
2012-07-25 20:40:48 +04:00
return false ;
}
2012-07-25 14:54:23 +04:00
$rr = @ ldap_read ( $cr , $dn , 'objectClass=*' , array ( $attr ));
if ( ! is_resource ( $rr )) {
2012-08-23 20:29:43 +04:00
\OCP\Util :: writeLog ( 'user_ldap' , 'readAttribute ' . $attr . ' failed for DN ' . $dn , \OCP\Util :: DEBUG );
2012-07-25 14:54:23 +04:00
//in case an error occurs , e.g. object does not exist
return false ;
}
2012-07-25 14:37:39 +04:00
$er = ldap_first_entry ( $cr , $rr );
//LDAP attributes are not case sensitive
$result = \OCP\Util :: mb_array_change_key_case ( ldap_get_attributes ( $cr , $er ), MB_CASE_LOWER , 'UTF-8' );
$attr = mb_strtolower ( $attr , 'UTF-8' );
2012-04-14 20:05:29 +04:00
2012-07-25 15:18:31 +04:00
if ( isset ( $result [ $attr ]) && $result [ $attr ][ 'count' ] > 0 ) {
2012-07-25 14:37:39 +04:00
$values = array ();
for ( $i = 0 ; $i < $result [ $attr ][ 'count' ]; $i ++ ) {
$values [] = $this -> resemblesDN ( $attr ) ? $this -> sanitizeDN ( $result [ $attr ][ $i ]) : $result [ $attr ][ $i ];
}
return $values ;
}
2012-08-23 20:29:43 +04:00
\OCP\Util :: writeLog ( 'user_ldap' , 'Requested attribute ' . $attr . ' not found for ' . $dn , \OCP\Util :: DEBUG );
2012-07-25 14:37:39 +04:00
return false ;
2012-04-16 20:03:02 +04:00
}
2012-04-25 22:34:58 +04:00
/**
2012-07-25 14:37:39 +04:00
* @ brief checks wether the given attribute ` s valua is probably a DN
* @ param $attr the attribute in question
* @ return if so true , otherwise false
2012-04-25 22:34:58 +04:00
*/
2012-07-25 14:37:39 +04:00
private function resemblesDN ( $attr ) {
$resemblingAttributes = array (
'dn' ,
'uniquemember' ,
'member'
2012-04-16 15:27:20 +04:00
);
2012-07-25 14:37:39 +04:00
return in_array ( $attr , $resemblingAttributes );
}
2012-04-15 16:47:33 +04:00
2012-07-25 14:37:39 +04:00
/**
* @ brief sanitizes a DN received from the LDAP server
* @ param $dn the DN in question
* @ return the sanitized DN
*/
private function sanitizeDN ( $dn ) {
//OID sometimes gives back DNs with whitespace after the comma a la "uid=foo, cn=bar, dn=..." We need to tackle this!
2012-07-25 15:18:31 +04:00
$dn = preg_replace ( '/([^\\\]),(\s+)/u' , '\1,' , $dn );
2012-04-25 22:34:58 +04:00
2012-07-25 14:37:39 +04:00
//make comparisons and everything work
$dn = mb_strtolower ( $dn , 'UTF-8' );
return $dn ;
2012-04-25 22:34:58 +04:00
}
/**
* gives back the database table for the query
*/
2012-07-25 14:37:39 +04:00
private function getMapTable ( $isUser ) {
2012-04-25 22:34:58 +04:00
if ( $isUser ) {
return '*PREFIX*ldap_user_mapping' ;
} else {
return '*PREFIX*ldap_group_mapping' ;
}
}
/**
* @ brief returns the LDAP DN for the given internal ownCloud name of the group
* @ param $name the ownCloud name in question
* @ returns string with the LDAP DN on success , otherwise false
*
* returns the LDAP DN for the given internal ownCloud name of the group
*/
2012-07-25 14:37:39 +04:00
public function groupname2dn ( $name ) {
2012-10-01 20:27:52 +04:00
$dn = $this -> ocname2dn ( $name , false );
if ( $dn ) {
return $dn ;
}
return false ;
2012-04-25 22:34:58 +04:00
}
/**
* @ brief returns the LDAP DN for the given internal ownCloud name of the user
* @ param $name the ownCloud name in question
* @ returns string with the LDAP DN on success , otherwise false
*
* returns the LDAP DN for the given internal ownCloud name of the user
*/
2012-07-25 14:37:39 +04:00
public function username2dn ( $name ) {
$dn = $this -> ocname2dn ( $name , true );
2012-04-25 22:34:58 +04:00
if ( $dn ) {
return $dn ;
}
return false ;
}
2012-07-25 14:37:39 +04:00
/**
* @ brief returns the LDAP DN for the given internal ownCloud name
* @ param $name the ownCloud name in question
* @ param $isUser is it a user ? otherwise group
* @ returns string with the LDAP DN on success , otherwise false
*
* returns the LDAP DN for the given internal ownCloud name
*/
private function ocname2dn ( $name , $isUser ) {
$table = $this -> getMapTable ( $isUser );
2012-04-25 22:34:58 +04:00
2012-07-25 14:37:39 +04:00
$query = \OCP\DB :: prepare ( '
2012-08-25 03:52:27 +04:00
SELECT `ldap_dn`
FROM `'.$table.'`
WHERE `owncloud_name` = ?
2012-04-25 22:34:58 +04:00
' );
$record = $query -> execute ( array ( $name )) -> fetchOne ();
return $record ;
}
/**
* @ brief returns the internal ownCloud name for the given LDAP DN of the group
* @ param $dn the dn of the group object
* @ param $ldapname optional , the display name of the object
2012-06-19 03:15:58 +04:00
* @ returns string with with the name to use in ownCloud , false on DN outside of search DN
2012-04-25 22:34:58 +04:00
*
2012-07-30 19:42:33 +04:00
* returns the internal ownCloud name for the given LDAP DN of the group , false on DN outside of search DN or failure
2012-04-25 22:34:58 +04:00
*/
2012-07-25 14:37:39 +04:00
public function dn2groupname ( $dn , $ldapname = null ) {
2012-08-05 23:28:59 +04:00
if ( mb_strripos ( $dn , $this -> sanitizeDN ( $this -> connection -> ldapBaseGroups ), 0 , 'UTF-8' ) !== ( mb_strlen ( $dn , 'UTF-8' ) - mb_strlen ( $this -> sanitizeDN ( $this -> connection -> ldapBaseGroups ), 'UTF-8' ))) {
2012-06-19 03:15:58 +04:00
return false ;
}
2012-07-25 14:37:39 +04:00
return $this -> dn2ocname ( $dn , $ldapname , false );
2012-04-25 22:34:58 +04:00
}
/**
* @ brief returns the internal ownCloud name for the given LDAP DN of the user
* @ param $dn the dn of the user object
* @ param $ldapname optional , the display name of the object
* @ returns string with with the name to use in ownCloud
*
2012-07-30 19:42:33 +04:00
* returns the internal ownCloud name for the given LDAP DN of the user , false on DN outside of search DN or failure
2012-04-25 22:34:58 +04:00
*/
2012-07-25 14:37:39 +04:00
public function dn2username ( $dn , $ldapname = null ) {
2012-08-05 23:28:59 +04:00
if ( mb_strripos ( $dn , $this -> sanitizeDN ( $this -> connection -> ldapBaseUsers ), 0 , 'UTF-8' ) !== ( mb_strlen ( $dn , 'UTF-8' ) - mb_strlen ( $this -> sanitizeDN ( $this -> connection -> ldapBaseUsers ), 'UTF-8' ))) {
2012-06-19 03:15:58 +04:00
return false ;
}
2012-07-25 14:37:39 +04:00
return $this -> dn2ocname ( $dn , $ldapname , true );
2012-04-25 22:34:58 +04:00
}
2012-07-25 14:37:39 +04:00
/**
* @ brief returns an internal ownCloud name for the given LDAP DN
* @ param $dn the dn of the user object
* @ param $ldapname optional , the display name of the object
* @ param $isUser optional , wether it is a user object ( otherwise group assumed )
* @ returns string with with the name to use in ownCloud
*
* returns the internal ownCloud name for the given LDAP DN of the user , false on DN outside of search DN
*/
public function dn2ocname ( $dn , $ldapname = null , $isUser = true ) {
$dn = $this -> sanitizeDN ( $dn );
$table = $this -> getMapTable ( $isUser );
2012-04-25 22:34:58 +04:00
if ( $isUser ) {
2012-09-21 15:03:28 +04:00
$fncFindMappedName = 'findMappedUser' ;
2012-07-25 14:37:39 +04:00
$nameAttribute = $this -> connection -> ldapUserDisplayName ;
2012-04-25 22:34:58 +04:00
} else {
2012-09-21 15:03:28 +04:00
$fncFindMappedName = 'findMappedGroup' ;
2012-07-25 14:37:39 +04:00
$nameAttribute = $this -> connection -> ldapGroupDisplayName ;
2012-04-25 22:34:58 +04:00
}
2012-08-23 20:29:43 +04:00
//let's try to retrieve the ownCloud name from the mappings table
2012-09-21 15:03:28 +04:00
$ocname = $this -> $fncFindMappedName ( $dn );
if ( $ocname ) {
return $ocname ;
2012-04-25 22:34:58 +04:00
}
2012-08-23 20:29:43 +04:00
//second try: get the UUID and check if it is known. Then, update the DN and return the name.
$uuid = $this -> getUUID ( $dn );
if ( $uuid ) {
$query = \OCP\DB :: prepare ( '
2012-08-25 03:52:27 +04:00
SELECT `owncloud_name`
FROM `'.$table.'`
WHERE `directory_uuid` = ?
2012-08-23 20:29:43 +04:00
' );
$component = $query -> execute ( array ( $uuid )) -> fetchOne ();
if ( $component ) {
$query = \OCP\DB :: prepare ( '
2012-08-25 03:52:27 +04:00
UPDATE `'.$table.'`
SET `ldap_dn` = ?
WHERE `directory_uuid` = ?
2012-08-23 20:29:43 +04:00
' );
$query -> execute ( array ( $dn , $uuid ));
return $component ;
}
}
2012-04-25 22:34:58 +04:00
if ( is_null ( $ldapname )) {
2012-07-25 14:37:39 +04:00
$ldapname = $this -> readAttribute ( $dn , $nameAttribute );
2012-07-30 19:42:33 +04:00
if ( ! isset ( $ldapname [ 0 ]) && empty ( $ldapname [ 0 ])) {
\OCP\Util :: writeLog ( 'user_ldap' , 'No or empty name for ' . $dn . '.' , \OCP\Util :: INFO );
return false ;
}
2012-04-25 22:34:58 +04:00
$ldapname = $ldapname [ 0 ];
}
2012-07-25 14:37:39 +04:00
$ldapname = $this -> sanitizeUsername ( $ldapname );
2012-04-25 22:34:58 +04:00
//a new user/group! Then let's try to add it. We're shooting into the blue with the user/group name, assuming that in most cases there will not be a conflict. Otherwise an error will occur and we will continue with our second shot.
2012-08-29 03:23:36 +04:00
if (( $isUser && ! \OCP\User :: userExists ( $ldapname )) || ( ! $isUser && ! \OC_Group :: groupExists ( $ldapname ))) {
if ( $this -> mapComponent ( $dn , $ldapname , $isUser )) {
return $ldapname ;
}
2012-04-25 22:34:58 +04:00
}
//doh! There is a conflict. We need to distinguish between users/groups. Adding indexes is an idea, but not much of a help for the user. The DN is ugly, but for now the only reasonable way. But we transform it to a readable format and remove the first part to only give the path where this object is located.
2012-07-25 14:37:39 +04:00
$oc_name = $this -> alternateOwnCloudName ( $ldapname , $dn );
2012-08-29 03:23:36 +04:00
if (( $isUser && ! \OCP\User :: userExists ( $oc_name )) || ( ! $isUser && ! \OC_Group :: groupExists ( $oc_name ))) {
if ( $this -> mapComponent ( $dn , $oc_name , $isUser )) {
return $oc_name ;
}
2012-04-25 22:34:58 +04:00
}
2012-07-30 19:42:33 +04:00
//if everything else did not help..
2012-08-05 23:35:37 +04:00
\OCP\Util :: writeLog ( 'user_ldap' , 'Could not create unique ownCloud name for ' . $dn . '.' , \OCP\Util :: INFO );
2012-08-29 03:23:36 +04:00
return false ;
2012-04-25 22:34:58 +04:00
}
/**
* @ brief gives back the user names as they are used ownClod internally
* @ param $ldapGroups an array with the ldap Users result in style of array ( array ( 'dn' => foo , 'uid' => bar ), ... )
* @ returns an array with the user names to use in ownCloud
*
* gives back the user names as they are used ownClod internally
*/
2012-07-25 14:37:39 +04:00
public function ownCloudUserNames ( $ldapUsers ) {
return $this -> ldap2ownCloudNames ( $ldapUsers , true );
2012-04-25 22:34:58 +04:00
}
/**
* @ brief gives back the group names as they are used ownClod internally
* @ param $ldapGroups an array with the ldap Groups result in style of array ( array ( 'dn' => foo , 'cn' => bar ), ... )
* @ returns an array with the group names to use in ownCloud
*
* gives back the group names as they are used ownClod internally
*/
2012-07-25 14:37:39 +04:00
public function ownCloudGroupNames ( $ldapGroups ) {
return $this -> ldap2ownCloudNames ( $ldapGroups , false );
2012-04-25 22:34:58 +04:00
}
2012-09-21 15:03:28 +04:00
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 ;
}
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 ;
}
2012-07-25 14:37:39 +04:00
private function ldap2ownCloudNames ( $ldapObjects , $isUsers ) {
2012-04-25 22:34:58 +04:00
if ( $isUsers ) {
2012-07-25 14:37:39 +04:00
$nameAttribute = $this -> connection -> ldapUserDisplayName ;
2012-04-25 22:34:58 +04:00
} else {
2012-07-25 14:37:39 +04:00
$nameAttribute = $this -> connection -> ldapGroupDisplayName ;
2012-04-25 22:34:58 +04:00
}
$ownCloudNames = array ();
foreach ( $ldapObjects as $ldapObject ) {
2012-10-15 19:16:47 +04:00
$nameByLDAP = isset ( $ldapObject [ $nameAttribute ]) ? $ldapObject [ $nameAttribute ] : null ;
$ocname = $this -> dn2ocname ( $ldapObject [ 'dn' ], $nameByLDAP , $isUsers );
2012-08-29 03:23:36 +04:00
if ( $ocname ) {
2012-05-17 17:14:47 +04:00
$ownCloudNames [] = $ocname ;
2012-04-25 22:34:58 +04:00
}
2012-08-29 03:23:36 +04:00
continue ;
2012-04-25 22:34:58 +04:00
}
return $ownCloudNames ;
}
/**
* @ brief creates a hopefully unique name for owncloud based on the display name and the dn of the LDAP object
* @ param $name the display name of the object
* @ param $dn the dn of the object
* @ returns string with with the name to use in ownCloud
*
* creates a hopefully unique name for owncloud based on the display name and the dn of the LDAP object
*/
2012-07-25 14:37:39 +04:00
private function alternateOwnCloudName ( $name , $dn ) {
2012-04-25 22:34:58 +04:00
$ufn = ldap_dn2ufn ( $dn );
2012-07-25 14:37:39 +04:00
$name = $name . '@' . trim ( \OCP\Util :: mb_substr_replace ( $ufn , '' , 0 , mb_strpos ( $ufn , ',' , 0 , 'UTF-8' ), 'UTF-8' ));
$name = $this -> sanitizeUsername ( $name );
2012-05-17 17:14:47 +04:00
return $name ;
2012-04-25 22:34:58 +04:00
}
/**
* @ brief retrieves all known groups from the mappings table
* @ returns array with the results
*
* retrieves all known groups from the mappings table
*/
2012-07-25 14:37:39 +04:00
private function mappedGroups () {
return $this -> mappedComponents ( false );
2012-04-25 22:34:58 +04:00
}
/**
* @ brief retrieves all known users from the mappings table
* @ returns array with the results
*
* retrieves all known users from the mappings table
*/
2012-07-25 14:37:39 +04:00
private function mappedUsers () {
return $this -> mappedComponents ( true );
2012-04-25 22:34:58 +04:00
}
2012-07-25 14:37:39 +04:00
private function mappedComponents ( $isUsers ) {
$table = $this -> getMapTable ( $isUsers );
2012-04-25 22:34:58 +04:00
2012-07-25 14:37:39 +04:00
$query = \OCP\DB :: prepare ( '
2012-08-25 03:52:27 +04:00
SELECT `ldap_dn` , `owncloud_name`
FROM `'. $table . '` '
2012-04-25 22:34:58 +04:00
);
return $query -> execute () -> fetchAll ();
}
/**
* @ brief inserts a new user or group into the mappings table
* @ param $dn the record in question
* @ param $ocname the name to use in ownCloud
* @ param $isUser is it a user or a group ?
* @ returns true on success , false otherwise
*
* inserts a new user or group into the mappings table
*/
2012-07-25 14:37:39 +04:00
private function mapComponent ( $dn , $ocname , $isUser = true ) {
$table = $this -> getMapTable ( $isUser );
$dn = $this -> sanitizeDN ( $dn );
2012-04-25 22:34:58 +04:00
2012-05-31 15:06:27 +04:00
$sqlAdjustment = '' ;
2012-07-25 14:37:39 +04:00
$dbtype = \OCP\Config :: getSystemValue ( 'dbtype' );
2012-05-31 15:06:27 +04:00
if ( $dbtype == 'mysql' ) {
2012-09-18 00:50:08 +04:00
$sqlAdjustment = 'FROM DUAL' ;
2012-05-08 15:56:07 +04:00
}
2012-07-25 14:37:39 +04:00
$insert = \OCP\DB :: prepare ( '
2012-08-25 03:52:27 +04:00
INSERT INTO `'.$table.'` ( `ldap_dn` , `owncloud_name` , `directory_uuid` )
2012-08-23 20:29:43 +04:00
SELECT ? , ? , ?
2012-05-31 15:06:27 +04:00
'.$sqlAdjustment.'
WHERE NOT EXISTS (
SELECT 1
2012-08-25 03:52:27 +04:00
FROM `'.$table.'`
WHERE `ldap_dn` = ?
OR `owncloud_name` = ? )
2012-04-25 22:34:58 +04:00
' );
2012-08-23 20:29:43 +04:00
//feed the DB
$res = $insert -> execute ( array ( $dn , $ocname , $this -> getUUID ( $dn ), $dn , $ocname ));
2012-04-25 22:34:58 +04:00
2012-07-25 14:37:39 +04:00
if ( \OCP\DB :: isError ( $res )) {
2012-06-07 15:36:34 +04:00
return false ;
}
$insRows = $res -> numRows ();
if ( $insRows == 0 ) {
return false ;
}
return true ;
2012-04-15 16:47:33 +04:00
}
2012-10-26 23:53:56 +04:00
public function fetchListOfUsers ( $filter , $attr , $limit = null , $offset = null ) {
return $this -> fetchList ( $this -> searchUsers ( $filter , $attr , $limit , $offset ), ( count ( $attr ) > 1 ));
2012-05-04 01:38:55 +04:00
}
2012-10-26 23:53:56 +04:00
public function fetchListOfGroups ( $filter , $attr , $limit = null , $offset = null ) {
return $this -> fetchList ( $this -> searchGroups ( $filter , $attr , $limit , $offset ), ( count ( $attr ) > 1 ));
2012-05-04 01:38:55 +04:00
}
2012-07-25 14:37:39 +04:00
private function fetchList ( $list , $manyAttributes ) {
2012-05-04 01:38:55 +04:00
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 ();
}
2012-04-23 15:04:58 +04:00
/**
* @ brief executes an LDAP search , optimized for Users
* @ param $filter the LDAP filter for the search
* @ param $attr optional , when a certain attribute shall be filtered out
* @ returns array with the search result
*
* Executes an LDAP search
*/
2012-10-26 23:53:56 +04:00
public function searchUsers ( $filter , $attr = null , $limit = null , $offset = null ) {
return $this -> search ( $filter , $this -> connection -> ldapBaseUsers , $attr , $limit , $offset );
2012-04-23 15:04:58 +04:00
}
/**
* @ brief executes an LDAP search , optimized for Groups
* @ param $filter the LDAP filter for the search
* @ param $attr optional , when a certain attribute shall be filtered out
* @ returns array with the search result
*
* Executes an LDAP search
*/
2012-10-26 23:53:56 +04:00
public function searchGroups ( $filter , $attr = null , $limit = null , $offset = null ) {
return $this -> search ( $filter , $this -> connection -> ldapBaseGroups , $attr , $limit , $offset );
2012-04-23 15:04:58 +04:00
}
2012-04-14 20:26:46 +04:00
/**
* @ brief executes an LDAP search
* @ param $filter the LDAP filter for the search
2012-04-23 15:04:58 +04:00
* @ param $base the LDAP subtree that shall be searched
2012-04-14 20:26:46 +04:00
* @ param $attr optional , when a certain attribute shall be filtered out
* @ returns array with the search result
*
* Executes an LDAP search
*/
2012-10-26 23:53:56 +04:00
private function search ( $filter , $base , $attr = null , $limit = null , $offset = null , $skipHandling = false ) {
2012-04-25 22:34:58 +04:00
if ( ! is_null ( $attr ) && ! is_array ( $attr )) {
2012-07-02 22:31:07 +04:00
$attr = array ( mb_strtolower ( $attr , 'UTF-8' ));
2012-04-25 22:34:58 +04:00
}
2012-05-28 17:54:38 +04:00
2012-10-26 23:53:56 +04:00
// See if we have a resource, in case not cancel with message
2012-07-25 14:37:39 +04:00
$link_resource = $this -> connection -> getConnectionResource ();
2012-10-26 23:53:56 +04:00
if ( ! is_resource ( $link_resource )) {
2012-05-28 17:54:38 +04:00
// Seems like we didn't find any resource.
// Return an empty array just like before.
2012-07-25 14:37:39 +04:00
\OCP\Util :: writeLog ( 'user_ldap' , 'Could not search, because resource is missing.' , \OCP\Util :: DEBUG );
2012-05-01 14:17:33 +04:00
return array ();
}
2012-04-14 20:05:29 +04:00
2012-10-27 13:02:35 +04:00
//check wether paged search should be attempted
$pagedSearchOK = $this -> initPagedSearch ( $filter , $base , $attr , $limit , $offset );
2012-10-26 23:53:56 +04:00
$sr = ldap_search ( $link_resource , $base , $filter , $attr );
$findings = ldap_get_entries ( $link_resource , $sr );
if ( $pagedSearchOK ) {
\OCP\Util :: writeLog ( 'user_ldap' , 'Paged search successful' , \OCP\Util :: INFO );
ldap_control_paged_result_response ( $link_resource , $sr , $cookie );
\OCP\Util :: writeLog ( 'user_ldap' , 'Set paged search cookie ' . $cookie , \OCP\Util :: INFO );
$this -> setPagedResultCookie ( $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.
2012-10-27 13:02:35 +04:00
//TODO: Instead, slice findings or selection later
2012-10-26 23:53:56 +04:00
if ( $findings [ 'count' ] <= $limit ) {
$this -> pagedSearchedSuccessful = true ;
}
} else {
\OCP\Util :: writeLog ( 'user_ldap' , 'Paged search failed :(' , \OCP\Util :: INFO );
}
// 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 ();
}
2012-04-14 20:05:29 +04:00
if ( ! is_null ( $attr )) {
$selection = array ();
2012-04-25 22:34:58 +04:00
$multiarray = false ;
if ( count ( $attr ) > 1 ) {
$multiarray = true ;
$i = 0 ;
}
2012-04-14 20:05:29 +04:00
foreach ( $findings as $item ) {
2012-05-17 15:15:26 +04:00
if ( ! is_array ( $item )) {
continue ;
}
2012-07-25 14:37:39 +04:00
$item = \OCP\Util :: mb_array_change_key_case ( $item , MB_CASE_LOWER , 'UTF-8' );
2012-05-17 15:15:26 +04:00
2012-04-25 22:34:58 +04:00
if ( $multiarray ) {
foreach ( $attr as $key ) {
2012-07-02 22:31:07 +04:00
$key = mb_strtolower ( $key , 'UTF-8' );
2012-04-25 22:34:58 +04:00
if ( isset ( $item [ $key ])) {
2012-07-25 15:18:31 +04:00
if ( $key != 'dn' ) {
2012-07-25 14:37:39 +04:00
$selection [ $i ][ $key ] = $this -> resemblesDN ( $key ) ? $this -> sanitizeDN ( $item [ $key ][ 0 ]) : $item [ $key ][ 0 ];
2012-04-25 22:34:58 +04:00
} else {
2012-07-25 14:37:39 +04:00
$selection [ $i ][ $key ] = $this -> sanitizeDN ( $item [ $key ]);
2012-04-25 22:34:58 +04:00
}
}
}
$i ++ ;
} else {
2012-05-11 17:42:05 +04:00
//tribute to case insensitivity
2012-07-02 22:31:07 +04:00
$key = mb_strtolower ( $attr [ 0 ], 'UTF-8' );
2012-05-11 17:42:05 +04:00
if ( isset ( $item [ $key ])) {
2012-07-25 14:37:39 +04:00
if ( $this -> resemblesDN ( $key )) {
$selection [] = $this -> sanitizeDN ( $item [ $key ]);
2012-05-14 14:25:10 +04:00
} else {
$selection [] = $item [ $key ];
}
2012-04-25 22:34:58 +04:00
}
2012-04-14 20:05:29 +04:00
}
}
2012-10-27 14:18:50 +04:00
$findings = $selection ;
}
if ( ! $this -> pagedSearchedSuccessful
|| (
! is_null ( $limit )
|| ! is_null ( $offset )
)
) {
$findings = array_slice ( $findings , intval ( $offset ), $limit );
2012-04-14 20:05:29 +04:00
}
return $findings ;
}
2012-07-25 14:37:39 +04:00
public function sanitizeUsername ( $name ) {
if ( $this -> connection -> ldapIgnoreNamingRules ) {
2012-05-17 21:33:38 +04:00
return $name ;
}
2012-08-27 23:32:32 +04:00
// Translitaration
//latin characters to ASCII
$name = iconv ( 'UTF-8' , 'ASCII//TRANSLIT' , $name );
2012-05-17 17:14:47 +04:00
//REPLACEMENTS
2012-07-25 14:37:39 +04:00
$name = \OCP\Util :: mb_str_replace ( ' ' , '_' , $name , 'UTF-8' );
2012-05-17 17:14:47 +04:00
//every remaining unallowed characters will be removed
2012-07-02 22:31:07 +04:00
$name = preg_replace ( '/[^a-zA-Z0-9_.@-]/u' , '' , $name );
2012-05-17 17:14:47 +04:00
return $name ;
}
2012-04-15 15:37:35 +04:00
/**
* @ brief combines the input filters with AND
* @ param $filters array , the filters to connect
* @ returns the combined filter
*
* Combines Filter arguments with AND
*/
2012-07-25 14:37:39 +04:00
public function combineFilterWithAnd ( $filters ) {
2012-07-25 15:18:31 +04:00
return $this -> combineFilter ( $filters , '&' );
2012-04-15 15:37:35 +04:00
}
/**
* @ brief combines the input filters with AND
* @ param $filters array , the filters to connect
* @ returns the combined filter
*
* Combines Filter arguments with AND
*/
2012-07-25 14:37:39 +04:00
public function combineFilterWithOr ( $filters ) {
2012-07-25 15:18:31 +04:00
return $this -> combineFilter ( $filters , '|' );
2012-04-15 15:37:35 +04:00
}
/**
* @ brief combines the input filters with given operator
* @ param $filters array , the filters to connect
* @ param $operator either & or |
* @ returns the combined filter
*
* Combines Filter arguments with AND
*/
2012-07-25 14:37:39 +04:00
private function combineFilter ( $filters , $operator ) {
2012-04-15 15:37:35 +04:00
$combinedFilter = '(' . $operator ;
foreach ( $filters as $filter ) {
2012-06-08 23:23:25 +04:00
if ( $filter [ 0 ] != '(' ) {
2012-04-15 15:37:35 +04:00
$filter = '(' . $filter . ')' ;
}
$combinedFilter .= $filter ;
}
$combinedFilter .= ')' ;
return $combinedFilter ;
}
2012-07-25 14:37:39 +04:00
public function areCredentialsValid ( $name , $password ) {
$testConnection = clone $this -> connection ;
$credentials = array (
'ldapAgentName' => $name ,
'ldapAgentPassword' => $password
);
if ( ! $testConnection -> setConfiguration ( $credentials )) {
2012-04-16 19:28:58 +04:00
return false ;
}
2012-07-25 14:37:39 +04:00
return $testConnection -> bind ();
2012-04-25 22:34:58 +04:00
}
2012-08-23 20:29:43 +04:00
/**
* @ brief auto - detects the directory ' s UUID attribute
* @ param $dn a known DN used to check against
* @ param $force the detection should be run , even if it is not set to auto
* @ returns true on success , false otherwise
*/
private function detectUuidAttribute ( $dn , $force = false ) {
if (( $this -> connection -> ldapUuidAttribute != 'auto' ) && ! $force ) {
return true ;
}
//for now, supported (known) attributes are entryUUID, nsuniqueid, objectGUID
$testAttributes = array ( 'entryuuid' , 'nsuniqueid' , 'objectguid' );
foreach ( $testAttributes as $attribute ) {
\OCP\Util :: writeLog ( 'user_ldap' , 'Testing ' . $attribute . ' as UUID attr' , \OCP\Util :: DEBUG );
$value = $this -> readAttribute ( $dn , $attribute );
if ( is_array ( $value ) && isset ( $value [ 0 ]) && ! empty ( $value [ 0 ])) {
\OCP\Util :: writeLog ( 'user_ldap' , 'Setting ' . $attribute . ' as UUID attr' , \OCP\Util :: DEBUG );
$this -> connection -> ldapUuidAttribute = $attribute ;
return true ;
}
2012-10-24 00:53:54 +04:00
\OCP\Util :: writeLog ( 'user_ldap' , 'The looked for uuid attr is not ' . $attribute . ', result was ' . print_r ( $value , true ), \OCP\Util :: DEBUG );
2012-08-23 20:29:43 +04:00
}
return false ;
}
public function getUUID ( $dn ) {
if ( $this -> detectUuidAttribute ( $dn )) {
$uuid = $this -> readAttribute ( $dn , $this -> connection -> ldapUuidAttribute );
if ( ! is_array ( $uuid ) && $this -> connection -> ldapOverrideUuidAttribute ) {
$this -> detectUuidAttribute ( $dn , true );
$uuid = $this -> readAttribute ( $dn , $this -> connection -> ldapUuidAttribute );
}
if ( is_array ( $uuid ) && isset ( $uuid [ 0 ]) && ! empty ( $uuid [ 0 ])) {
$uuid = $uuid [ 0 ];
} else {
$uuid = false ;
}
} else {
$uuid = false ;
}
return $uuid ;
}
2012-10-26 23:53:56 +04:00
/**
* @ brief get a cookie for the next LDAP paged search
* @ param $filter the search filter to identify the correct search
* @ param $limit the limit ( or 'pageSize' ), to identify the correct search well
* @ param $offset the offset for the new search to identify the correct search really good
* @ returns string containing the key or empty if none is cached
*/
private function getPagedResultCookie ( $filter , $limit , $offset ) {
if ( $offset == 0 ) {
return '' ;
}
$offset -= $limit ;
//we work with cache here
$cachekey = 'lc' . dechex ( crc32 ( $filter )) . '-' . $limit . '-' . $offset ;
$cookie = $this -> connection -> getFromCache ( $cachekey );
if ( is_null ( $cookie )) {
$cookie = '' ;
}
return $cookie ;
}
/**
* @ brief set a cookie for LDAP paged search run
* @ param $filter the search filter to identify the correct search
* @ param $limit the limit ( or 'pageSize' ), to identify the correct search well
* @ param $offset the offset for the run search to identify the correct search really good
* @ param $cookie string containing the cookie returned by ldap_control_paged_result_response
* @ return void
*/
private function setPagedResultCookie ( $filter , $limit , $offset ) {
if ( ! empty ( $cookie )) {
$cachekey = 'lc' . dechex ( crc32 ( $filter )) . '-' . $limit . '-' . $offset ;
$cookie = $this -> connection -> writeToCache ( $cachekey , $cookie );
}
}
/**
* @ brief check wether the most recent paged search was successful . It flushed the state var . Use it always after a possible paged search .
* @ return true on success , null or false otherwise
*/
public function getPagedSearchResultState () {
$result = $this -> pagedSearchedSuccessful ;
$this -> pagedSearchedSuccessful = null ;
return $result ;
}
2012-10-27 13:02:35 +04:00
/**
* @ brief prepares a paged search , if possible
* @ param $filter the LDAP filter for the search
* @ param $base the LDAP subtree that shall be searched
* @ param $attr optional , when a certain attribute shall be filtered outside
* @ param $limit
* @ param $offset
*
*/
private function initPagedSearch ( $filter , $base , $attr , $limit , $offset ) {
$pagedSearchOK = false ;
if ( $this -> connection -> hasPagedResultSupport && ! is_null ( $limit )) {
$offset = intval ( $offset ); //can be null
//get the cookie from the search for the previous search, required by LDAP
$cookie = $this -> getPagedResultCookie ( $filter , $limit , $offset );
if ( empty ( $cookie ) && ( $offset > 0 )) {
//no cookie known, although the offset is not 0. Maybe cache run out. We need to start all over *sigh* (btw, Dear Reader, did you need LDAP paged searching was designed by MSFT?)
$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 , $base , $attr , $limit , $reOffset , true );
$cookie = $this -> getPagedResultCookie ( $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 ) {
\OCP\Util :: writeLog ( 'user_ldap' , 'Cookie ' . $cookie , \OCP\Util :: INFO );
}
$pagedSearchOK = ldap_control_paged_result ( $this -> connection -> getConnectionResource (), $limit , false , $cookie );
\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 ;
}
2012-07-25 14:37:39 +04:00
}