Guillermoandrae\DynamoDb\DynamoDbAdapter

Complexity

Total Complexity

22

Size/Duplication

Total Lines	120
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	insert()	0	3	1
A	delete()	0	3	1
A	createTable()	0	6	2
A	__construct()	0	13	3
A	deleteTable()	0	6	2
A	findWhere()	0	5	1
A	findAll()	0	5	1
A	listTables()	0	3	1
A	update()	0	3	1
A	describeTable()	0	6	2
A	tableExists()	0	12	3
A	find()	0	8	3
A	useTable()	0	4	1

<?php

namespace Guillermoandrae\DynamoDb;

use Aws\DynamoDb\DynamoDbClient;
use Aws\DynamoDb\Marshaler;
use Guillermoandrae\Common\CollectionInterface;
use Guillermoandrae\DynamoDb\Contract\DynamoDbAdapterInterface;
use Guillermoandrae\DynamoDb\Contract\DynamoDbClientAwareTrait;
use Guillermoandrae\DynamoDb\Factory\DynamoDbClientFactory;
use Guillermoandrae\DynamoDb\Factory\MarshalerFactory;
use Guillermoandrae\DynamoDb\Factory\OperationFactory;
use Guillermoandrae\DynamoDb\Operation\QueryOperation;
use Guillermoandrae\DynamoDb\Operation\ScanOperation;
use MongoDB\Driver\Query;

/**
 * The DynamoDB adapter.
 *
 * @author Guillermo A. Fisher <me@guillermoandraefisher.com>
 */
final class DynamoDbAdapter implements DynamoDbAdapterInterface
{
    use DynamoDbClientAwareTrait;

    /**
     * @var string The table name.
     */
    private string $tableName;

    /**
     * DynamoDBAdapter constructor.
     *
     * Registers the AWS DynamoDB client and Marshaler with this object. If no arguments are provided, we use the
     * respective factories to generate the necessary objects.
     *
     * @param DynamoDbClient|null $client OPTIONAL The DynamoDB client.
     * @param Marshaler|null $marshaler OPTIONAL The Marshaler.
     */
    public function __construct(?DynamoDbClient $client = null, ?Marshaler $marshaler = null)
    {
        if (empty($client)) {
            $client = DynamoDbClientFactory::factory();
        }
        $this->setClient($client);
        OperationFactory::setClient($client);

        if (empty($marshaler)) {
            $marshaler = MarshalerFactory::factory();
        }
        $this->setMarshaler($marshaler);
        OperationFactory::setMarshaler($marshaler);
    }

    public function createTable(array $data, ?string $tableName = '', ?array $options = []): bool
    {
        if (empty($tableName)) {
            $tableName = $this->tableName;
        }
        return OperationFactory::factory('create-table', $tableName, $data)->execute();
    }

    public function deleteTable(?string $tableName = ''): bool
    {
        if (empty($tableName)) {
            $tableName = $this->tableName;
        }
        return OperationFactory::factory('delete-table', $tableName)->execute();
    }

    public function describeTable(?string $tableName = ''): ?array
    {
        if (empty($tableName)) {
            $tableName = $this->tableName;
        }
        return OperationFactory::factory('describe-table', $tableName)->execute();
    }

    public function tableExists(?string $tableName = ''): bool
    {
        if (empty($tableName)) {
            $tableName = $this->tableName;
        }
        $tables = $this->listTables();
        if (empty($tables)) {
            return false;
        }
        return in_array(
            strtolower($tableName),
            array_map('strtolower', $tables)
        );
    }

    public function listTables(): ?array
    {
        return OperationFactory::factory('list-tables')->execute();
    }

    public function useTable(string $tableName): DynamoDbAdapterInterface
    {
        $this->tableName = $tableName;
        return $this;
    }

    public function findWhere(array $conditions, int $offset = 0, ?int $limit = null): CollectionInterface
    {
        /** @var QueryOperation $queryOperation */
        $queryOperation = OperationFactory::factory('query', $this->tableName, $conditions);
        return $queryOperation->setOffset($offset)->setLimit($limit)->execute();
    }

    public function findAll(int $offset = 0, ?int $limit = null, ?array $conditions = []): CollectionInterface
    {
        /** @var ScanOperation $scanOperation */
        $scanOperation = OperationFactory::factory('scan', $this->tableName, $conditions);
        return $scanOperation->setOffset($offset)->setLimit($limit)->execute();
    }

    public function find(array $primaryKey): array
    {
        foreach ($primaryKey as $key => $value) {
            if (is_array($value)) {
                return OperationFactory::factory('batch-get-item', $primaryKey)->execute();
            }
        }
        return OperationFactory::factory('get-item', $this->tableName, $primaryKey)->execute();
    }

    public function insert(array $data): bool
    {
        return OperationFactory::factory('put-item', $this->tableName, $data)->execute();
    }

    public function update(array $primaryKey, array $data): bool
    {
        return OperationFactory::factory('update-item', $this->tableName, $primaryKey, $data)->execute();
    }

    public function delete($primaryKey): bool
    {
        return OperationFactory::factory('delete-item', $this->tableName, $primaryKey)->execute();
    }
}