diff options
Diffstat (limited to 'apps/user_ldap/lib/Proxy.php')
| -rw-r--r-- | apps/user_ldap/lib/Proxy.php | 204 |
1 files changed, 204 insertions, 0 deletions
diff --git a/apps/user_ldap/lib/Proxy.php b/apps/user_ldap/lib/Proxy.php new file mode 100644 index 00000000000..dd7cd97b6f9 --- /dev/null +++ b/apps/user_ldap/lib/Proxy.php @@ -0,0 +1,204 @@ +<?php +/** + * @author Arthur Schiwon <blizzz@owncloud.com> + * @author Bart Visscher <bartv@thisnet.nl> + * @author Christopher Schäpers <kondou@ts.unde.re> + * @author Jörn Friedrich Dreyer <jfd@butonic.de> + * @author Lukas Reschke <lukas@owncloud.com> + * @author Morris Jobke <hey@morrisjobke.de> + * @author Robin McCorkell <robin@mccorkell.me.uk> + * @author Thomas Müller <thomas.mueller@tmit.eu> + * + * @copyright Copyright (c) 2016, ownCloud, Inc. + * @license AGPL-3.0 + * + * This code is free software: you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License, version 3, + * as published by the Free Software Foundation. + * + * This program 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, version 3, + * along with this program. If not, see <http://www.gnu.org/licenses/> + * + */ + +namespace OCA\User_LDAP; + +use OCA\user_ldap\lib\Access; +use OCA\user_ldap\lib\Connection; +use OCA\user_ldap\lib\FilesystemHelper; +use OCA\user_ldap\lib\ILDAPWrapper; +use OCA\user_ldap\lib\LogWrapper; +use OCA\User_LDAP\Mapping\UserMapping; +use OCA\User_LDAP\Mapping\GroupMapping; + +abstract class Proxy { + static private $accesses = array(); + private $ldap = null; + + /** @var \OCP\ICache|null */ + private $cache; + + /** + * @param ILDAPWrapper $ldap + */ + public function __construct(ILDAPWrapper $ldap) { + $this->ldap = $ldap; + $memcache = \OC::$server->getMemCacheFactory(); + if($memcache->isAvailable()) { + $this->cache = $memcache->create(); + } + } + + /** + * @param string $configPrefix + */ + private function addAccess($configPrefix) { + static $ocConfig; + static $fs; + static $log; + static $avatarM; + static $userMap; + static $groupMap; + static $db; + static $coreUserManager; + if(is_null($fs)) { + $ocConfig = \OC::$server->getConfig(); + $fs = new FilesystemHelper(); + $log = new LogWrapper(); + $avatarM = \OC::$server->getAvatarManager(); + $db = \OC::$server->getDatabaseConnection(); + $userMap = new UserMapping($db); + $groupMap = new GroupMapping($db); + $coreUserManager = \OC::$server->getUserManager(); + } + $userManager = + new user\Manager($ocConfig, $fs, $log, $avatarM, new \OCP\Image(), $db, $coreUserManager); + $connector = new Connection($this->ldap, $configPrefix); + $access = new Access($connector, $this->ldap, $userManager); + $access->setUserMapper($userMap); + $access->setGroupMapper($groupMap); + self::$accesses[$configPrefix] = $access; + } + + /** + * @param string $configPrefix + * @return mixed + */ + protected function getAccess($configPrefix) { + if(!isset(self::$accesses[$configPrefix])) { + $this->addAccess($configPrefix); + } + return self::$accesses[$configPrefix]; + } + + /** + * @param string $uid + * @return string + */ + protected function getUserCacheKey($uid) { + return 'user-'.$uid.'-lastSeenOn'; + } + + /** + * @param string $gid + * @return string + */ + protected function getGroupCacheKey($gid) { + return 'group-'.$gid.'-lastSeenOn'; + } + + /** + * @param string $id + * @param string $method + * @param array $parameters + * @param bool $passOnWhen + * @return mixed + */ + abstract protected function callOnLastSeenOn($id, $method, $parameters, $passOnWhen); + + /** + * @param string $id + * @param string $method + * @param array $parameters + * @return mixed + */ + abstract protected function walkBackends($id, $method, $parameters); + + /** + * Takes care of the request to the User backend + * @param string $id + * @param string $method string, the method of the user backend that shall be called + * @param array $parameters an array of parameters to be passed + * @param bool $passOnWhen + * @return mixed, the result of the specified method + */ + protected function handleRequest($id, $method, $parameters, $passOnWhen = false) { + $result = $this->callOnLastSeenOn($id, $method, $parameters, $passOnWhen); + if($result === $passOnWhen) { + $result = $this->walkBackends($id, $method, $parameters); + } + return $result; + } + + /** + * @param string|null $key + * @return string + */ + private function getCacheKey($key) { + $prefix = 'LDAP-Proxy-'; + if(is_null($key)) { + return $prefix; + } + return $prefix.md5($key); + } + + /** + * @param string $key + * @return mixed|null + */ + public function getFromCache($key) { + if(is_null($this->cache) || !$this->isCached($key)) { + return null; + } + $key = $this->getCacheKey($key); + + return json_decode(base64_decode($this->cache->get($key))); + } + + /** + * @param string $key + * @return bool + */ + public function isCached($key) { + if(is_null($this->cache)) { + return false; + } + $key = $this->getCacheKey($key); + return $this->cache->hasKey($key); + } + + /** + * @param string $key + * @param mixed $value + */ + public function writeToCache($key, $value) { + if(is_null($this->cache)) { + return; + } + $key = $this->getCacheKey($key); + $value = base64_encode(json_encode($value)); + $this->cache->set($key, $value, '2592000'); + } + + public function clearCache() { + if(is_null($this->cache)) { + return; + } + $this->cache->clear($this->getCacheKey(null)); + } +} |