Daikon\CouchDb\Storage\CouchDbStorageAdapter

Complexity

Total Complexity

11

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

<?php declare(strict_types=1);
use Daikon\Dbal\Exception\DbalException;
use Daikon\Dbal\Exception\DocumentConflict;
use Daikon\EventSourcing\EventStore\Commit\CommitSequence;
use Daikon\EventSourcing\EventStore\Commit\CommitSequenceInterface;
use Daikon\EventSourcing\EventStore\Storage\StorageAdapterInterface;
use GuzzleHttp\Exception\BadResponseException;
use GuzzleHttp\Psr7\Request;
use GuzzleHttp\Psr7\Response;

final class CouchDbStorageAdapter implements StorageAdapterInterface
{
    private CouchDbConnector $connector;

    private array $settings;

    public function __construct(CouchDbConnector $connector, array $settings = [])
    {
        $this->connector = $connector;
        $this->settings = $settings;
    }

    public function load(string $identifier, string $from = null, string $to = null): CommitSequenceInterface
    {
        $viewPath = sprintf(
            '/_design/%s/_view/%s',
            $this->settings['design_doc'],
            $this->settings['view_name'] ?? 'commit_stream'
        );

        $viewParams = [
            'startkey' => sprintf('["%s", %s]', $identifier, $from ?: '{}'),
            'endkey' => sprintf('["%s", %s]', $identifier, $to ?: 1),
            'include_docs' => 'true',
            'reduce' => 'false',
            'descending' => 'true',
            'limit' => 5000 //@todo use snapshot size config setting as soon as available
        ];

        /** @var Response $response */
        $response = $this->request($viewPath, 'GET', [], $viewParams);
        $rawResponse = json_decode((string)$response->getBody(), true);

        if (!isset($rawResponse['rows'])) {
            //@todo add error logging
            throw new DbalException('Failed to load data for '.$identifier);
        }

        return CommitSequence::fromNative(
            array_map(
                fn(array $commit): array => $commit['doc'],

A parse error occurred: Syntax error, unexpected ':', expecting T_DOUBLE_ARROW on line 61 at column 33

                array_reverse($rawResponse['rows'])
            )
        );
    }

    public function append(string $identifier, array $body): void
    {
        /** @var Response $response */
        $response = $this->request($identifier, 'PUT', $body);

        if ($response->getStatusCode() === 409) {
            throw new DocumentConflict;
        }

        $rawResponse = json_decode((string)$response->getBody(), true);
        if (!isset($rawResponse['ok']) || !isset($rawResponse['rev'])) {
            //@todo add error logging
            throw new DbalException('Failed to append data for '.$identifier);
        }
    }

    public function purge(string $identifier): void
    {
        throw new DbalException('Not implemented');
    }

    /** @return mixed */
    private function request(string $identifier, string $method, array $body = [], array $params = [])