Daikon\CouchDb\Migration\CouchDbMigrationTrait

Complexity

Total Complexity

13

Size/Duplication

Total Lines	71
Duplicated Lines	36.62 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	createDatabase()	13	13	4
A	deleteDatabase()	13	13	4
A	createDesignDoc()	0	17	2
A	deleteDesignDoc()	0	14	2
A	getDatabaseName()	0	5	1

<?php

namespace Daikon\CouchDb\Migration;

use Daikon\Dbal\Exception\MigrationException;
use Daikon\Dbal\Migration\MigrationTrait;
use GuzzleHttp\Exception\RequestException;

trait CouchDbMigrationTrait
{
    use MigrationTrait;

    private function createDatabase(): void

This method is not used, and could be removed.

This method seems to be duplicated in your project.

    {
        $client = $this->connector->getConnection();
        $databaseName = $this->getDatabaseName();

        try {
            $client->put('/'.$databaseName);
        } catch (RequestException $error) {
            if (!$error->hasResponse() || !$error->getResponse()->getStatusCode() === 409) {
                throw new MigrationException($error->getMessage());
            }
        }
    }

    private function deleteDatabase(): void

This method is not used, and could be removed.

This method seems to be duplicated in your project.

    {
        $client = $this->connector->getConnection();
        $databaseName = $this->getDatabaseName();

        try {
            $client->delete('/'.$databaseName);
        } catch (RequestException $error) {
            if (!$error->hasResponse() || !$error->getResponse()->getStatusCode() === 404) {
                throw new MigrationException($error->getMessage());
            }
        }
    }

    private function createDesignDoc(string $name, array $views): void

This method is not used, and could be removed.

    {
        $client = $this->connector->getConnection();
        $databaseName = $this->getDatabaseName();

        $body = [
            'language' => 'javascript',
            'views' => $views
        ];

        try {
            $requestPath = sprintf('/%s/_design/%s', $databaseName, $name);
            $client->put($requestPath, ['body' => json_encode($body)]);
        } catch (RequestException $error) {
            throw new MigrationException($error->getMessage());
        }
    }

    private function deleteDesignDoc(string $name): void

This method is not used, and could be removed.

    {
        $client = $this->connector->getConnection();
        $databaseName = $this->getDatabaseName();

        try {
            $requestPath = sprintf('/%s/_design/%s', $databaseName, $name);
            $response = $client->head($requestPath);
            $revision = trim(current($response->getHeader('ETag')), '"');
            $client->delete(sprintf('%s?rev=%s', $requestPath, $revision));
        } catch (RequestException $error) {
            throw new MigrationException($error->getMessage());
        }
    }

    private function getDatabaseName(): string
    {
        $connectorSettings = $this->connector->getSettings();
        return $connectorSettings['database'];
    }
}