LDAP: proxy: configurable return to determine when to try the next LDAP server and when to return (multi server setup)

remotes/origin/stable6
Arthur Schiwon 11 years ago
parent d9347f2c9b
commit 3955388f20
  1. 5
      apps/user_ldap/group_proxy.php
  2. 7
      apps/user_ldap/lib/proxy.php
  3. 8
      apps/user_ldap/user_proxy.php

@ -67,16 +67,17 @@ class Group_Proxy extends lib\Proxy implements \OCP\GroupInterface {
* @param $gid string, the gid connected to the request * @param $gid string, the gid connected to the request
* @param $method string, the method of the group backend that shall be called * @param $method string, the method of the group backend that shall be called
* @param $parameters an array of parameters to be passed * @param $parameters an array of parameters to be passed
* @param $passOnWhen the result matches this variable
* @return mixed, the result of the method or false * @return mixed, the result of the method or false
*/ */
protected function callOnLastSeenOn($gid, $method, $parameters) { protected function callOnLastSeenOn($gid, $method, $parameters, $passOnWhen) {
$cacheKey = $this->getGroupCacheKey($gid);; $cacheKey = $this->getGroupCacheKey($gid);;
$prefix = $this->getFromCache($cacheKey); $prefix = $this->getFromCache($cacheKey);
//in case the uid has been found in the past, try this stored connection first //in case the uid has been found in the past, try this stored connection first
if(!is_null($prefix)) { if(!is_null($prefix)) {
if(isset($this->backends[$prefix])) { if(isset($this->backends[$prefix])) {
$result = call_user_func_array(array($this->backends[$prefix], $method), $parameters); $result = call_user_func_array(array($this->backends[$prefix], $method), $parameters);
if(!$result) { if($result === $passOnWhen) {
//not found here, reset cache to null if group vanished //not found here, reset cache to null if group vanished
//because sometimes methods return false with a reason //because sometimes methods return false with a reason
$groupExists = call_user_func_array( $groupExists = call_user_func_array(

@ -54,7 +54,7 @@ abstract class Proxy {
return 'group-'.$gid.'-lastSeenOn'; return 'group-'.$gid.'-lastSeenOn';
} }
abstract protected function callOnLastSeenOn($id, $method, $parameters); abstract protected function callOnLastSeenOn($id, $method, $parameters, $passOnWhen);
abstract protected function walkBackends($id, $method, $parameters); abstract protected function walkBackends($id, $method, $parameters);
/** /**
@ -64,8 +64,9 @@ abstract class Proxy {
* @param $parameters an array of parameters to be passed * @param $parameters an array of parameters to be passed
* @return mixed, the result of the specified method * @return mixed, the result of the specified method
*/ */
protected function handleRequest($id, $method, $parameters) { protected function handleRequest($id, $method, $parameters, $passOnWhen = false) {
if(!$result = $this->callOnLastSeenOn($id, $method, $parameters)) { $result = $this->callOnLastSeenOn($id, $method, $parameters, $passOnWhen);
if($result === $passOnWhen) {
$result = $this->walkBackends($id, $method, $parameters); $result = $this->walkBackends($id, $method, $parameters);
} }
return $result; return $result;

@ -54,6 +54,7 @@ class User_Proxy extends lib\Proxy implements \OCP\UserInterface {
protected function walkBackends($uid, $method, $parameters) { protected function walkBackends($uid, $method, $parameters) {
$cacheKey = $this->getUserCacheKey($uid); $cacheKey = $this->getUserCacheKey($uid);
foreach($this->backends as $configPrefix => $backend) { foreach($this->backends as $configPrefix => $backend) {
// print("walkBackend '$configPrefix'<br/>");
if($result = call_user_func_array(array($backend, $method), $parameters)) { if($result = call_user_func_array(array($backend, $method), $parameters)) {
$this->writeToCache($cacheKey, $configPrefix); $this->writeToCache($cacheKey, $configPrefix);
return $result; return $result;
@ -67,16 +68,17 @@ class User_Proxy extends lib\Proxy implements \OCP\UserInterface {
* @param $uid string, the uid connected to the request * @param $uid string, the uid connected to the request
* @param $method string, the method of the user backend that shall be called * @param $method string, the method of the user backend that shall be called
* @param $parameters an array of parameters to be passed * @param $parameters an array of parameters to be passed
* @param $passOnWhen the result matches this variable
* @return mixed, the result of the method or false * @return mixed, the result of the method or false
*/ */
protected function callOnLastSeenOn($uid, $method, $parameters) { protected function callOnLastSeenOn($uid, $method, $parameters, $passOnWhen) {
$cacheKey = $this->getUserCacheKey($uid); $cacheKey = $this->getUserCacheKey($uid);
$prefix = $this->getFromCache($cacheKey); $prefix = $this->getFromCache($cacheKey);
//in case the uid has been found in the past, try this stored connection first //in case the uid has been found in the past, try this stored connection first
if(!is_null($prefix)) { if(!is_null($prefix)) {
if(isset($this->backends[$prefix])) { if(isset($this->backends[$prefix])) {
$result = call_user_func_array(array($this->backends[$prefix], $method), $parameters); $result = call_user_func_array(array($this->backends[$prefix], $method), $parameters);
if(!$result) { if($result === $passOnWhen) {
//not found here, reset cache to null if user vanished //not found here, reset cache to null if user vanished
//because sometimes methods return false with a reason //because sometimes methods return false with a reason
$userExists = call_user_func_array( $userExists = call_user_func_array(
@ -169,7 +171,7 @@ class User_Proxy extends lib\Proxy implements \OCP\UserInterface {
* @return boolean either the user can or cannot * @return boolean either the user can or cannot
*/ */
public function canChangeAvatar($uid) { public function canChangeAvatar($uid) {
return $this->handleRequest($uid, 'canChangeAvatar', array($uid)); return $this->handleRequest($uid, 'canChangeAvatar', array($uid), true);
} }
/** /**

Loading…
Cancel
Save