DMK\MKSamlAuth\EntityDescriptor\IdpEntityDescriptorStore

Complexity

Total Complexity

7

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	has()	0	3	1
A	__construct()	0	3	1
A	all()	0	17	2
A	get()	0	12	2
A	map()	0	12	1

<?php

declare(strict_types=1);

namespace DMK\MKSamlAuth\EntityDescriptor;

use LightSaml\Builder\EntityDescriptor\SimpleEntityDescriptorBuilder;
use LightSaml\Credential\X509Certificate;
use LightSaml\Model\Metadata\EntityDescriptor;
use LightSaml\Model\XmlDSig\SignatureStringReader;
use LightSaml\Store\EntityDescriptor\EntityDescriptorStoreInterface;
use TYPO3\CMS\Core\Database\ConnectionPool;
use TYPO3\CMS\Core\SingletonInterface;
use TYPO3\CMS\Core\Utility\GeneralUtility;

class IdpEntityDescriptorStore implements EntityDescriptorStoreInterface, SingletonInterface
{
    /**
     * @var ConnectionPool
     */
    private $pool;

    public function __construct(ConnectionPool $connectionPool)
    {
        $this->pool = $connectionPool;
    }

    public function get($entityId)
    {
        $conn = $this->pool->getConnectionForTable('tx_mksamlauth_domain_model_identityprovider');
        $qb = $conn->createQueryBuilder();
        $qb->select('i.*');
        $qb->from('tx_mksamlauth_domain_model_identityprovider', 'i');
        $qb->where($qb->expr()->eq('i.idp_entity_id', ':id'));
        $qb->setParameter(':id', $entityId);

        $row = $qb->execute()->fetch();

        return $row ? $this->map($row) : null;
    }

    public function has($entityId)
    {
        return $this->get($entityId) !== null;
    }

    public function all()
    {
        $conn = $this->pool->getConnectionForTable('tx_mksamlauth_domain_model_identityprovider');
        $qb = $conn->createQueryBuilder();
        $qb->select('i.*');
        $qb->from('tx_mksamlauth_domain_model_identityprovider', 'i');
        $qb->groupBy('i.idp_entity_id');

        $stmt = $qb->execute();

        $result = [];

        foreach ($stmt->fetchAll() as $row) {
            $result[] = $this->map($row);
        }

        return $result;
    }

    private function map(array $row): EntityDescriptor
    {
        $certificate = new X509Certificate();
        $certificate->loadPem($row['idp_certificate']);

        return GeneralUtility::makeInstance(
            SimpleEntityDescriptorBuilder::class,
            $row['idp_entity_id'],
            null,
            $row['url'],
            $certificate
        )->get();
    }
}