Balloon\App\Webauthn\CredentialRepository

Complexity

Total Complexity

12

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	findOneByCredentialId()	0	14	2
A	findAllForUserEntity()	0	4	1
A	saveCredentialSource()	0	11	1
A	getDescriptorsByUser()	0	10	2
A	has()	0	3	1
A	get()	0	3	1
A	getUserHandleFor()	0	3	1
A	getCounterFor()	0	3	1
A	updateCounterFor()	0	3	1

<?php

declare(strict_types=1);

/**
 * balloon
 *
 * @copyright   Copryright (c) 2012-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\App\Webauthn;

use Base64Url\Base64Url;
use Generator;
use MongoDB\BSON\ObjectId;
use MongoDB\BSON\ObjectIdInterface;
use MongoDB\BSON\UTCDateTime;
use MongoDB\Database;
use Webauthn\AttestedCredentialData;
use Webauthn\PublicKeyCredentialSource;
use Webauthn\PublicKeyCredentialSourceRepository;
use Webauthn\PublicKeyCredentialUserEntity;

class CredentialRepository implements PublicKeyCredentialSourceRepository
{
    /**
     * Database.
     *
     * @var Database
     */
    protected $db;

    /**
     * Initialize.
     */
    public function __construct(Database $db)
    {
        $this->db = $db;
    }

    /**
     * {@inheritdoc}
     */
    public function findOneByCredentialId(string $publicKeyCredentialId): ?PublicKeyCredentialSource
    {
        $result = $this->db->devices->findOne([
            'key.publicKeyCredentialId' => Base64Url::encode($publicKeyCredentialId),
        ]);

        if ($result === null) {
            return null;
        }

        $result['key']['credentialPublicKey'] = Base64Url::decode($result['key']['credentialPublicKey']);

        return PublicKeyCredentialSource::createFromArray($result['key']);
    }

    /**
     * {@inheritdoc}
     */
    public function findAllForUserEntity(PublicKeyCredentialUserEntity $publicKeyCredentialUserEntity): array
    {
        return [];
    }

    /**
     * {@inheritdoc}
     */
    public function saveCredentialSource(PublicKeyCredentialSource $publicKeyCredentialSource): void
    {
        $key = json_decode(json_encode($publicKeyCredentialSource));
        $record = [
            'created' => new UTCDateTime(),
            'owner' => new ObjectId(base64_decode($key->userHandle)),
            'key' => $key,
        ];

        $this->db->devices->insertOne($record);
    }

    /**
     * Get credentials by user.
     */
    public function getDescriptorsByUser(ObjectIdInterface $user): Generator
    {
        $result = $this->db->devices->find([
            'owner' => $user,
        ]);

        foreach ($result as $resource) {
            yield PublicKeyCredentialSource::createFromArray($resource['key'])->getPublicKeyCredentialDescriptor();
        }
    }

    /**
     * Depreacted interface methods.
     */
    public function has(string $credentialId): bool
    {
    }

    public function get(string $credentialId): AttestedCredentialData
    {
    }

    public function getUserHandleFor(string $credentialId): string
    {
    }

    public function getCounterFor(string $credentialId): int
    {
    }

    public function updateCounterFor(string $credentialId, int $newCounter): void
    {
    }
}