| | |
| | | public $readonly = true; |
| | | public $ready = false; |
| | | public $group_id = 0; |
| | | public $list_page = 1; |
| | | public $page_size = 10; |
| | | public $coltypes = array(); |
| | | |
| | | /** private properties */ |
| | |
| | | protected $filter = ''; |
| | | protected $result = null; |
| | | protected $ldap_result = null; |
| | | protected $sort_col = ''; |
| | | protected $mail_domain = ''; |
| | | protected $debug = false; |
| | | |
| | |
| | | } |
| | | |
| | | // use fieldmap to advertise supported coltypes to the application |
| | | foreach ($this->fieldmap as $col => $lf) { |
| | | list($col, $type) = explode(':', $col); |
| | | foreach ($this->fieldmap as $colv => $lfv) { |
| | | list($col, $type) = explode(':', $colv); |
| | | list($lf, $limit, $delim) = explode(':', $lfv); |
| | | |
| | | if ($limit == '*') $limit = null; |
| | | else $limit = max(1, intval($limit)); |
| | | |
| | | if (!is_array($this->coltypes[$col])) { |
| | | $subtypes = $type ? array($type) : null; |
| | | $this->coltypes[$col] = array('limit' => 2, 'subtypes' => $subtypes); |
| | | $this->coltypes[$col] = array('limit' => $limit, 'subtypes' => $subtypes, 'attributes' => array($lf)); |
| | | } |
| | | elseif ($type) { |
| | | $this->coltypes[$col]['subtypes'][] = $type; |
| | | $this->coltypes[$col]['limit']++; |
| | | $this->coltypes[$col]['attributes'][] = $lf; |
| | | $this->coltypes[$col]['limit'] += $limit; |
| | | } |
| | | if ($type && !$this->fieldmap[$col]) |
| | | $this->fieldmap[$col] = $lf; |
| | | |
| | | if ($delim) |
| | | $this->coltypes[$col]['serialized'][$type] = $delim; |
| | | |
| | | $this->fieldmap[$colv] = $lf; |
| | | } |
| | | |
| | | if ($this->fieldmap['street'] && $this->fieldmap['locality']) |
| | | $this->coltypes['address'] = array('limit' => 1); |
| | | else if ($this->coltypes['address']) |
| | | $this->coltypes['address'] = array('type' => 'textarea', 'childs' => null, 'limit' => 1, 'size' => 40); |
| | | if ($this->coltypes['street'] && $this->coltypes['locality']) { |
| | | $this->coltypes['address'] = array( |
| | | 'limit' => max(1, $this->coltypes['locality']['limit'] + $this->coltypes['address']['limit']), |
| | | 'subtypes' => array_merge((array)$this->coltypes['address']['subtypes'], $this->coltypes['locality']['subtypes']), |
| | | 'childs' => array(), |
| | | ) + (array)$this->coltypes['address']; |
| | | |
| | | foreach (array('street','locality','zipcode','region','country') as $childcol) { |
| | | if ($this->coltypes[$childcol]) { |
| | | $this->coltypes['address']['childs'][$childcol] = array('type' => 'text'); |
| | | unset($this->coltypes[$childcol]); // remove address child col from global coltypes list |
| | | } |
| | | } |
| | | } |
| | | else if ($this->coltypes['address']) { |
| | | $this->coltypes['address'] += array('type' => 'textarea', 'childs' => null, 'size' => 40); |
| | | |
| | | // 'serialized' means the UI has to present a composite address field |
| | | if ($this->coltypes['address']['serialized']) { |
| | | $childprop = array('type' => 'text'); |
| | | $this->coltypes['address']['type'] = 'composite'; |
| | | $this->coltypes['address']['childs'] = array('street' => $childprop, 'locality' => $childprop, 'zipcode' => $childprop, 'country' => $childprop); |
| | | } |
| | | } |
| | | |
| | | // make sure 'required_fields' is an array |
| | | if (!is_array($this->prop['required_fields'])) |
| | |
| | | |
| | | |
| | | /** |
| | | * Set internal list page |
| | | * Set internal sort settings |
| | | * |
| | | * @param number $page Page number to list |
| | | * @param string $sort_col Sort column |
| | | * @param string $sort_order Sort order |
| | | */ |
| | | function set_page($page) |
| | | function set_sort_order($sort_col, $sort_order = null) |
| | | { |
| | | $this->list_page = (int)$page; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Set internal page size |
| | | * |
| | | * @param number $size Number of messages to display on one page |
| | | */ |
| | | function set_pagesize($size) |
| | | { |
| | | $this->page_size = (int)$size; |
| | | if ($this->coltypes[$sort_col]['attributes']) |
| | | $this->sort_col = $this->coltypes[$sort_col]['attributes'][0]; |
| | | } |
| | | |
| | | |
| | |
| | | |
| | | for ($i=0; $i < $entry[$attr]['count']; $i++) |
| | | { |
| | | if (empty($entry[$attr][$i])) |
| | | continue; |
| | | |
| | | $result = @ldap_read($this->conn, $entry[$attr][$i], '(objectclass=*)', |
| | | $attrib, 0, (int)$this->prop['sizelimit'], (int)$this->prop['timelimit']); |
| | | |
| | |
| | | |
| | | for ($i = 0; $i < $entries['count']; $i++) { |
| | | $rec = $this->_ldap2result($entries[$i]); |
| | | foreach (array('email', 'name') as $f) { |
| | | $val = mb_strtolower($rec[$f]); |
| | | switch ($mode) { |
| | | case 1: |
| | | $got = ($val == $search); |
| | | break; |
| | | case 2: |
| | | $got = ($search == substr($val, 0, strlen($search))); |
| | | break; |
| | | default: |
| | | $got = (strpos($val, $search) !== false); |
| | | break; |
| | | } |
| | | foreach ($fields as $f) { |
| | | foreach ((array)$rec[$f] as $val) { |
| | | $val = mb_strtolower($val); |
| | | switch ($mode) { |
| | | case 1: |
| | | $got = ($val == $search); |
| | | break; |
| | | case 2: |
| | | $got = ($search == substr($val, 0, strlen($search))); |
| | | break; |
| | | default: |
| | | $got = (strpos($val, $search) !== false); |
| | | break; |
| | | } |
| | | |
| | | if ($got) { |
| | | $this->result->add($rec); |
| | | $this->result->count++; |
| | | break; |
| | | if ($got) { |
| | | $this->result->add($rec); |
| | | $this->result->count++; |
| | | break 2; |
| | | } |
| | | } |
| | | } |
| | | } |
| | |
| | | { |
| | | foreach ((array)$fields as $idx => $field) { |
| | | $val = is_array($value) ? $value[$idx] : $value; |
| | | if ($f = $this->_map_field($field)) { |
| | | $filter .= "($f=$wp" . $this->_quote_string($val) . "$ws)"; |
| | | if ($attrs = $this->_map_field($field)) { |
| | | if (count($attrs) > 1) |
| | | $filter .= '(|'; |
| | | foreach ($attrs as $f) |
| | | $filter .= "($f=$wp" . $this->_quote_string($val) . "$ws)"; |
| | | if (count($attrs) > 1) |
| | | $filter .= ')'; |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | // add required (non empty) fields filter |
| | | $req_filter = ''; |
| | | foreach ((array)$required as $field) |
| | | if ($f = $this->_map_field($field)) |
| | | $req_filter .= "($f=*)"; |
| | | foreach ((array)$required as $field) { |
| | | if ($attrs = $this->_map_field($field)) { |
| | | if (count($attrs) > 1) |
| | | $req_filter .= '(|'; |
| | | foreach ($attrs as $f) |
| | | $req_filter .= "($f=*)"; |
| | | if (count($attrs) > 1) |
| | | $req_filter .= ')'; |
| | | } |
| | | } |
| | | |
| | | if (!empty($req_filter)) |
| | | $filter = '(&' . $req_filter . $filter . ')'; |
| | |
| | | $dn = self::dn_encode($dn); |
| | | |
| | | // add new contact to the selected group |
| | | if ($this->groups) |
| | | if ($this->group_id) |
| | | $this->add_to_group($this->group_id, $dn); |
| | | |
| | | return $dn; |
| | |
| | | $attrs, 0, (int)$this->prop['sizelimit'], (int)$this->prop['timelimit']) |
| | | ) { |
| | | $entries_count = ldap_count_entries($this->conn, $this->ldap_result); |
| | | $this->_debug("S: $count_entries record(s)"); |
| | | $this->_debug("S: $entries_count record(s)"); |
| | | |
| | | return $count ? $count_entries : true; |
| | | return $count ? $entries_count : true; |
| | | } |
| | | else { |
| | | $this->_debug("S: ".ldap_error($this->conn)); |
| | |
| | | if (!($value = $rec[$lf][$i])) |
| | | continue; |
| | | |
| | | list($col, $subtype) = explode(':', $rf); |
| | | $out['_raw_attrib'][$lf][$i] = $value; |
| | | |
| | | if ($rf == 'email' && $this->mail_domain && !strpos($value, '@')) |
| | | if ($col == 'email' && $this->mail_domain && !strpos($value, '@')) |
| | | $out[$rf][] = sprintf('%s@%s', $value, $this->mail_domain); |
| | | else if (in_array($rf, array('street','zipcode','locality','country','region'))) |
| | | $out['address'][$i][$rf] = $value; |
| | | else if (in_array($col, array('street','zipcode','locality','country','region'))) |
| | | $out['address'.($subtype?':':'').$subtype][$i][$col] = $value; |
| | | else if ($col == 'address' && strpos($value, '$') !== false) // address data is represented as string separated with $ |
| | | list($out[$rf][$i]['street'], $out[$rf][$i]['locality'], $out[$rf][$i]['zipcode'], $out[$rf][$i]['country']) = explode('$', $value); |
| | | else if ($rec[$lf]['count'] > 1) |
| | | $out[$rf][] = $value; |
| | | else |
| | |
| | | |
| | | |
| | | /** |
| | | * Return real field name (from fields map) |
| | | * Return LDAP attribute(s) for the given field |
| | | */ |
| | | private function _map_field($field) |
| | | { |
| | | return $this->fieldmap[$field]; |
| | | return (array)$this->coltypes[$field]['attributes']; |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | // if addresses are to be saved as serialized string, do so |
| | | if (is_array($colprop['serialized'])) { |
| | | foreach ($colprop['serialized'] as $subtype => $delim) { |
| | | $key = $col.':'.$subtype; |
| | | foreach ((array)$save_cols[$key] as $i => $val) |
| | | $save_cols[$key][$i] = join($delim, array($val['street'], $val['locality'], $val['zipcode'], $val['country'])); |
| | | } |
| | | } |
| | | } |
| | | |
| | | $ldap_data = array(); |
| | | foreach ($this->fieldmap as $col => $fld) { |
| | | $val = $save_cols[$col]; |
| | | foreach ($this->fieldmap as $rf => $fld) { |
| | | $val = $save_cols[$rf]; |
| | | |
| | | // check for value in base field (eg.g email instead of email:foo) |
| | | list($col, $subtype) = explode(':', $rf); |
| | | if (!$val && !empty($save_cols[$col])) { |
| | | $val = $save_cols[$col]; |
| | | unset($save_cols[$col]); // only use this value once |
| | | } |
| | | else if (!$val && !$subtype) { // extract values from subtype cols |
| | | $val = $this->get_col_values($col, $save_cols, true); |
| | | } |
| | | |
| | | if (is_array($val)) |
| | | $val = array_filter($val); // remove empty entries |
| | | if ($fld && $val) { |
| | |
| | | $ldap_data[$fld] = $val; |
| | | } |
| | | } |
| | | |
| | | |
| | | return $ldap_data; |
| | | } |
| | | |
| | |
| | | /** |
| | | * Returns unified attribute name (resolving aliases) |
| | | */ |
| | | private static function _attr_name($name) |
| | | private static function _attr_name($namev) |
| | | { |
| | | // list of known attribute aliases |
| | | $aliases = array( |
| | | static $aliases = array( |
| | | 'gn' => 'givenname', |
| | | 'rfc822mailbox' => 'email', |
| | | 'userid' => 'uid', |
| | | 'emailaddress' => 'email', |
| | | 'pkcs9email' => 'email', |
| | | ); |
| | | return isset($aliases[$name]) ? $aliases[$name] : $name; |
| | | |
| | | list($name, $limit) = explode(':', $namev, 2); |
| | | $suffix = $limit ? ':'.$limit : ''; |
| | | |
| | | return (isset($aliases[$name]) ? $aliases[$name] : $name) . $suffix; |
| | | } |
| | | |
| | | |
| | |
| | | if (($group_cache = $this->cache->get('groups')) === null) |
| | | $group_cache = $this->_fetch_groups(); |
| | | |
| | | if (!is_array($contact_ids)) |
| | | $contact_ids = explode(',', $contact_ids); |
| | | |
| | | $base_dn = $this->groups_base_dn; |
| | | $group_name = $group_cache[$group_id]['name']; |
| | | $member_attr = $group_cache[$group_id]['member_attr']; |
| | | $group_dn = "cn=$group_name,$base_dn"; |
| | | |
| | | $new_attrs = array(); |
| | | foreach (explode(",", $contact_ids) as $id) |
| | | foreach ($contact_ids as $id) |
| | | $new_attrs[$member_attr][] = self::dn_decode($id); |
| | | |
| | | $this->_debug("C: Add [dn: $group_dn]: ".print_r($new_attrs, true)); |