Fathomminds\Rest\Database\DynamoDb\Database

Complexity

Total Complexity

14

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	3
A	createClient()	0	11	2
A	getFullDatabaseName()	0	4	1
A	get()	0	9	1
A	post()	0	9	1
A	patch()	0	9	1
A	put()	0	9	1
A	delete()	0	9	1
A	setDatabaseName()	0	4	1
A	getDatabaseName()	0	4	1
A	getClient()	0	4	1

<?php
namespace Fathomminds\Rest\Database\DynamoDb;

use Aws\Sdk;
use Aws\DynamoDb\DynamoDbClient as Client;
use Fathomminds\Rest\Contracts\IDatabase;
use Fathomminds\Rest\Database\DynamoDb\Resource;
use Fathomminds\Rest\Helpers\ReflectionHelper;

class Database implements IDatabase
{
    protected $client;
    protected $databaseName;

    public function __construct(Client $client = null, $databaseName = null)
    {
        $this->client = $client === null ? $this->createClient() : $client;
        $this->databaseName = $databaseName === null ? $this->getFullDatabaseName() : $databaseName;
    }

    private function createClient()
    {
        $sdk = new Sdk([
            'region' => getenv('AWS_SDK_REGION'),
            'version' => getenv('AWS_SDK_VERSION'),
            'http' => [
                'verify' => getenv('AWS_SDK_HTTP_VERIFY') === 'false' ? false : getenv('AWS_SDK_HTTP_VERIFY'),
            ]
        ]);
        return $sdk->createDynamoDb();
    }

    private function getFullDatabaseName()
    {
        return getenv('AWS_DYNAMODB_NAMESPACE') . '-' . getenv('AWS_DYNAMODB_DATABASE');
    }

    public function get($resourceName, $primaryKey, $resourceId = null)
    {
        return (new Resource(
            $resourceName,
            $primaryKey,
            $this->client,
            $this->databaseName
        ))->get($resourceId);
    }

    public function post($resourceName, $primaryKey, $newResource)
    {
        return (new Resource(
            $resourceName,
            $primaryKey,
            $this->client,
            $this->databaseName
        ))->post($newResource);
    }

    public function patch($resourceName, $primaryKey, $resourceId, $newResource)
    {
        return (new Resource(
            $resourceName,
            $primaryKey,
            $this->client,
            $this->databaseName
        ))->patch($resourceId, $newResource);
    }

    public function put($resourceName, $primaryKey, $resourceId, $newResource)
    {
        return (new Resource(
            $resourceName,
            $primaryKey,
            $this->client,
            $this->databaseName
        ))->put($resourceId, $newResource);
    }

    public function delete($resourceName, $primaryKey, $resourceId)
    {
        return (new Resource(
            $resourceName,
            $primaryKey,
            $this->client,
            $this->databaseName
        ))->delete($resourceId);
    }

    public function setDatabaseName($databaseName)
    {
        $this->databaseName = $databaseName;
    }

    public function getDatabaseName()
    {
        return $this->databaseName;
    }

    public function getClient()
    {
        return $this->client;
    }
}