DoL\LdapBundle\Ldap\LdapManager

Complexity

Total Complexity

25

Size/Duplication

Total Lines	153
Duplicated Lines	0 %

Test Coverage

Coverage

77.78%

Importance

Changes	3
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	findUserByUsername()	0	15	5
B	findUserBy()	0	26	7
A	__construct()	0	6	1
A	setLdapAttr()	0	13	3
A	bind()	0	17	4
A	buildFilter()	0	12	3
A	switchParameterSet()	0	9	2

<?php

namespace DoL\LdapBundle\Ldap;

use DoL\LdapBundle\Driver\LdapDriverInterface;
use DoL\LdapBundle\Event\SwitchParameterSetEvent;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\Security\Core\User\UserInterface;
use DoL\LdapBundle\Hydrator\HydratorInterface;

/**
 * Ldap manager for multi-domains.
 *
 * @author DarwinOnLine
 * @author Maks3w
 *
 * @see https://github.com/DarwinOnLine/DoLLdapBundle
 */
class LdapManager implements LdapManagerInterface
{
    protected $driver;
    protected $paramSets = [];

    protected $params = [];
    protected $ldapAttributes = [];
    protected $ldapUsernameAttr;
    /**
     * @var EventDispatcherInterface
     */
    protected $eventDispatcher;

    /**
     * @var HydratorInterface
     */
    protected $hydrator;

    public function __construct(LdapDriverInterface $driver, HydratorInterface $hydrator, EventDispatcherInterface $eventDispatcher, array $paramSets)
    {
        $this->driver = $driver;
        $this->hydrator = $hydrator;
        $this->eventDispatcher = $eventDispatcher;
        $this->paramSets = $paramSets;
    }

    /**
     * {@inheritdoc}
     */
    public function bind(UserInterface $user, $password)
    {
        if (!empty($this->params)) {
            return $this->driver->bind($user, $password);
        } else {
            foreach ($this->paramSets as $paramSet) {
                $this->driver->init($paramSet['driver']);

                if (false !== $this->driver->bind($user, $password)) {
                    $this->switchParameterSet($paramSet);

                    return true;
                }
            }
        }

        return false;
    }

    /**
     * {@inheritdoc}
     */
    public function findUserByUsername($username)
    {
        if (!empty($this->params)) {
            return $this->findUserBy([$this->ldapUsernameAttr => $username]);
        } else {
            foreach ($this->paramSets as $paramSet) {
                $this->driver->init($paramSet['driver']);
                $this->switchParameterSet($paramSet);

                $user = $this->findUserBy([$this->ldapUsernameAttr => $username]);
                if (false !== $user && $user instanceof UserInterface) {
                    return $user;
                }

                $this->switchParameterSet([]);
            }
        }
    }

    /**
     * {@inheritdoc}
     */
    public function findUserBy(array $criteria)
    {
        if (!empty($this->params)) {
            $filter = $this->buildFilter($criteria);
            $entries = $this->driver->search($this->params['baseDn'], $filter);
            if ($entries['count'] > 1) {
                throw new \Exception('This search can only return a single user');
            }

            if (0 == $entries['count']) {
                return null;
            }
            $user = $this->hydrator->hydrate($entries[0]);

            return $user;
        } else {
            foreach ($this->paramSets as $paramSet) {
                $this->driver->init($paramSet['driver']);
                $this->switchParameterSet($paramSet);

                $user = $this->findUserBy($criteria);
                if (false !== $user && $user instanceof UserInterface) {
                    return $user;
                }

                $this->switchParameterSet([]);
            }
        }
    }

    /**
     * Sets temp Ldap attributes.
     */
    private function setLdapAttr()
    {
        if (isset($this->params['attributes'])) {
            $this->hydrator->setAttributeMap($this->params['attributes']);

            foreach ($this->params['attributes'] as $attr) {
                $this->ldapAttributes[] = $attr['ldap_attr'];
            }

            $this->ldapUsernameAttr = $this->ldapAttributes[0];
        } else {
            $this->ldapAttributes = [];
            $this->ldapUsernameAttr = null;
        }
    }

    /**
     * Build Ldap filter.
     *
     * @param array  $criteria
     * @param string $condition
     *
     * @return string
     */
    protected function buildFilter(array $criteria, $condition = '&')
    {
        $filters = [];
        if (isset($this->params['filter'])) {
            $filters[] = $this->params['filter'];
        }
        foreach ($criteria as $key => $value) {
            $value = ldap_escape($value, '', LDAP_ESCAPE_FILTER);
            $filters[] = sprintf('(%s=%s)', $key, $value);
        }

        return sprintf('(%s%s)', $condition, implode($filters));
    }

    private function switchParameterSet(array $parameter)
    {
        if (isset($parameter['user'])) {
            $this->params = $parameter['user'];
        } else {
            $this->params = [];
        }
        $this->setLdapAttr();
        $this->eventDispatcher->dispatch(SwitchParameterSetEvent::PARAMETERSET, new SwitchParameterSetEvent($parameter));
    }
}