CreateTableRequest::setReadCapacityUnits() - Code Metrics - Inspection of "Namespace is now Guillermoandrae\DynamoDb." - guillermoandrae/php-dynamodb - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 20a668...02e94f )

by Guillermo A.

created 2020-01-07 00:31 UTC

CreateTableRequest::setReadCapacityUnits() A

↳ Parent: CreateTableRequest

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

Metric	Value
eloc	2
dl	0
loc	4
c	0
b	0
f	0
ccs	3
cts	3
cp	1
rs	10
cc	1
nc	1
nop	1
crap	1

<?php

namespace Guillermoandrae\DynamoDb;

use Aws\DynamoDb\Marshaler;

final class CreateTableRequest extends AbstractTableAwareRequest
{
    /**
     * @var array Attributes describing the key schema.
     */
    private $attributeDefinitions = [];

    /**
     * @var array The primary key.
     */
    private $keySchema = [];
    
    /**
     * @var int The maximum number of strongly consistent reads consumed per second.
     */
    private $readCapacityUnits = 5;

    /**
     * @var int The maximum number of writes consumed per second.
     */
    private $writeCapacityUnits = 5;

    /**
     * @var string The billing mode.
     */
    private $billingMode = BillingModes::PROVISIONED;

    /**
     * @var array The server-side encryption settings.
     */
    private $sseSpecification = [];

    /**
     * @var array The tags.
     */
    private $tags = [];

    /**
     * Registers the Marshaler, table name, and key schema with this object.
     *
     * @param Marshaler $marshaler The Marshaler.
     * @param string $tableName The table name.
     * @param array $keySchema OPTIONAL The key schema.
     */
    public function __construct(Marshaler $marshaler, string $tableName, array $keySchema = [])
    {
        parent::__construct($marshaler, $tableName);
        if (!empty($keySchema)) {
            $this->setKeySchema($keySchema);
        }
    }

    /**
     * Registers the partition key.
     *
     * @param string $name The name of the partition key.
     * @param string $attributeType The attribute type.
     * @return CreateTableRequest This object.
     */
    public function setPartitionKey(string $name, string $attributeType): CreateTableRequest
    {
        $this->setKeySchema([
            $name => [
                'attributeType' => $attributeType,
                'keyType' => KeyTypes::HASH
            ]
        ]);
        return $this;
    }

    /**
     * Registers the sort key.
     *
     * @param string $name The name of the sort key.
     * @param string $attributeType The attribute type.
     * @return CreateTableRequest This object.
     */
    public function setSortKey(string $name, string $attributeType): CreateTableRequest
    {
        $this->setKeySchema([
            $name => [
                'attributeType' => $attributeType,
                'keyType' => KeyTypes::RANGE
            ]
        ]);
        return $this;
    }

    /**
     * Registers the key schema and attribute definitions.
     *
     * The key schema argument should be an associative array with the following keys:
     *
     * $keySchema = [
     *      'MyAttribute' => [ // this is the name of your attribute
     *          'attributeType' => 'S', // this can be one of the AttributeTypes constants
     *          'keyType' => 'HASH' // this can be either 'HASH' or 'RANGE' (or one of the KeyTypes constants)
     *     ]
     * ];
     *
     * This method will use the information available in the provided array to build the 'KeySchema' and
     * 'AttributeDefinitions' arrays needed for table creation requests.
     *
     * @param array $keySchema The key schema.
     * @return CreateTableRequest This object.
     */
    public function setKeySchema(array $keySchema): CreateTableRequest
    {
        foreach ($keySchema as $name => $data) {
            $this->keySchema[] = [
                'AttributeName' => $name,
                'KeyType' => $data['keyType']
            ];
            $this->attributeDefinitions[] = [
                'AttributeName' => $name,
                'AttributeType' => $data['attributeType']
            ];
        }
        return $this;
    }

    /**
     * Registers the maximum number of strongly consistent reads consumed per second.
     *
     * @param integer $readCapacityUnits The maximum number of strongly consistent reads consumed per second.
     * @return CreateTableRequest This object.
     */
    public function setReadCapacityUnits(int $readCapacityUnits): CreateTableRequest
    {
        $this->readCapacityUnits = $readCapacityUnits;
        return $this;
    }

    /**
     * Registers the maximum number of writes consumed per second.
     *
     * @param integer $writeCapacityUnits The maximum number of writes consumed per second.
     * @return CreateTableRequest This object.
     */
    public function setWriteCapacityUnits(int $writeCapacityUnits): CreateTableRequest
    {
        $this->writeCapacityUnits = $writeCapacityUnits;
        return $this;
    }

    /**
     * Registers the billing mode.
     *
     * @param string $billingMode The billing mode.
     * @return CreateTableRequest This object.
     */
    public function setBillingMode(string $billingMode)
    {
        $this->billingMode = $billingMode;
        return $this;
    }

    /**
     * Registers the server-side encryption settings.
     *
     * @param bool $isEnabled Whether or not SSE is enabled.
     * @param string $masterKeyId OPTIONAL The ID of the master key.
     * @return CreateTableRequest This object.
     */
    public function setSSESpecification(bool $isEnabled, string $masterKeyId = '')
    {
        $sseSpecification = [];
        if ($isEnabled) {
            $sseSpecification = [
                'Enabled' => $isEnabled,
                'SSEType' => 'KMS'
            ];
            if (!empty($masterKeyId)) {
                $sseSpecification['KMSMasterKeyId'] = $masterKeyId;
            }
        }
        $this->sseSpecification = $sseSpecification;
        return $this;
    }

    /**
     * Registers a tag.
     *
     * @param string $key The tag key.
     * @param string $value The tag value.
     * @return CreateTableRequest This object.
     */
    public function addTag(string $key, string $value)
    {
        $this->tags[] = [
            'Key' => $key,
            'Value' => $value
        ];
        return $this;
    }

    /**
     * {@inheritDoc}
     */
    public function get(): array
    {
        $query = parent::get();
        $query['KeySchema'] = $this->keySchema;
        $query['AttributeDefinitions'] = $this->attributeDefinitions;
        $query['BillingMode'] = $this->billingMode;
        $query['ProvisionedThroughput'] = [
            'ReadCapacityUnits' => $this->readCapacityUnits,
            'WriteCapacityUnits' => $this->writeCapacityUnits,
        ];
        if (!empty($this->sseSpecification)) {
            $query['SSESpecification'] = $this->sseSpecification;
        }
        if (!empty($this->tags)) {
            $query['Tags'] = $this->tags;
        }
        return $query;
    }
}


1		<?php
2
3		namespace Guillermoandrae\DynamoDb;
4
5		use Aws\DynamoDb\Marshaler;
6
7		final class CreateTableRequest extends AbstractTableAwareRequest
8		{
9		/**
10		* @var array Attributes describing the key schema.
11		*/
12		private $attributeDefinitions = [];
13
14		/**
15		* @var array The primary key.
16		*/
17		private $keySchema = [];
18
19		/**
20		* @var int The maximum number of strongly consistent reads consumed per second.
21		*/
22		private $readCapacityUnits = 5;
23
24		/**
25		* @var int The maximum number of writes consumed per second.
26		*/
27		private $writeCapacityUnits = 5;
28
29		/**
30		* @var string The billing mode.
31		*/
32		private $billingMode = BillingModes::PROVISIONED;
33
34		/**
35		* @var array The server-side encryption settings.
36		*/
37		private $sseSpecification = [];
38
39		/**
40		* @var array The tags.
41		*/
42		private $tags = [];
43
44		/**
45		* Registers the Marshaler, table name, and key schema with this object.
46		*
47		* @param Marshaler $marshaler The Marshaler.
48		* @param string $tableName The table name.
49		* @param array $keySchema OPTIONAL The key schema.
50		*/
51	17	public function __construct(Marshaler $marshaler, string $tableName, array $keySchema = [])
52		{
53	17	parent::__construct($marshaler, $tableName);
54	17	if (!empty($keySchema)) {
55	14	$this->setKeySchema($keySchema);
56		}
57	17	}
58
59		/**
60		* Registers the partition key.
61		*
62		* @param string $name The name of the partition key.
63		* @param string $attributeType The attribute type.
64		* @return CreateTableRequest This object.
65		*/
66	1	public function setPartitionKey(string $name, string $attributeType): CreateTableRequest
67		{
68	1	$this->setKeySchema([
69	1	$name => [
70	1	'attributeType' => $attributeType,
71		'keyType' => KeyTypes::HASH
72		]
73		]);
74	1	return $this;
75		}
76
77		/**
78		* Registers the sort key.
79		*
80		* @param string $name The name of the sort key.
81		* @param string $attributeType The attribute type.
82		* @return CreateTableRequest This object.
83		*/
84	1	public function setSortKey(string $name, string $attributeType): CreateTableRequest
85		{
86	1	$this->setKeySchema([
87	1	$name => [
88	1	'attributeType' => $attributeType,
89		'keyType' => KeyTypes::RANGE
90		]
91		]);
92	1	return $this;
93		}
94
95		/**
96		* Registers the key schema and attribute definitions.
97		*
98		* The key schema argument should be an associative array with the following keys:
99		*
100		* $keySchema = [
101		* 'MyAttribute' => [ // this is the name of your attribute
102		* 'attributeType' => 'S', // this can be one of the AttributeTypes constants
103		* 'keyType' => 'HASH' // this can be either 'HASH' or 'RANGE' (or one of the KeyTypes constants)
104		* ]
105		* ];
106		*
107		* This method will use the information available in the provided array to build the 'KeySchema' and
108		* 'AttributeDefinitions' arrays needed for table creation requests.
109		*
110		* @param array $keySchema The key schema.
111		* @return CreateTableRequest This object.
112		*/
113	16	public function setKeySchema(array $keySchema): CreateTableRequest
114		{
115	16	foreach ($keySchema as $name => $data) {
116	16	$this->keySchema[] = [
117	16	'AttributeName' => $name,
118	16	'KeyType' => $data['keyType']
119		];
120	16	$this->attributeDefinitions[] = [
121	16	'AttributeName' => $name,
122	16	'AttributeType' => $data['attributeType']
123		];
124		}
125	16	return $this;
126		}
127
128		/**
129		* Registers the maximum number of strongly consistent reads consumed per second.
130		*
131		* @param integer $readCapacityUnits The maximum number of strongly consistent reads consumed per second.
132		* @return CreateTableRequest This object.
133		*/
134	1	public function setReadCapacityUnits(int $readCapacityUnits): CreateTableRequest
135		{
136	1	$this->readCapacityUnits = $readCapacityUnits;
137	1	return $this;
138		}
139
140		/**
141		* Registers the maximum number of writes consumed per second.
142		*
143		* @param integer $writeCapacityUnits The maximum number of writes consumed per second.
144		* @return CreateTableRequest This object.
145		*/
146	1	public function setWriteCapacityUnits(int $writeCapacityUnits): CreateTableRequest
147		{
148	1	$this->writeCapacityUnits = $writeCapacityUnits;
149	1	return $this;
150		}
151
152		/**
153		* Registers the billing mode.
154		*
155		* @param string $billingMode The billing mode.
156		* @return CreateTableRequest This object.
157		*/
158	1	public function setBillingMode(string $billingMode)
159		{
160	1	$this->billingMode = $billingMode;
161	1	return $this;
162		}
163
164		/**
165		* Registers the server-side encryption settings.
166		*
167		* @param bool $isEnabled Whether or not SSE is enabled.
168		* @param string $masterKeyId OPTIONAL The ID of the master key.
169		* @return CreateTableRequest This object.
170		*/
171	1	public function setSSESpecification(bool $isEnabled, string $masterKeyId = '')
172		{
173	1	$sseSpecification = [];
174	1	if ($isEnabled) {
175		$sseSpecification = [
176	1	'Enabled' => $isEnabled,
177	1	'SSEType' => 'KMS'
178		];
179	1	if (!empty($masterKeyId)) {
180	1	$sseSpecification['KMSMasterKeyId'] = $masterKeyId;
181		}
182		}
183	1	$this->sseSpecification = $sseSpecification;
184	1	return $this;
185		}
186
187		/**
188		* Registers a tag.
189		*
190		* @param string $key The tag key.
191		* @param string $value The tag value.
192		* @return CreateTableRequest This object.
193		*/
194	1	public function addTag(string $key, string $value)
195		{
196	1	$this->tags[] = [
197	1	'Key' => $key,
198	1	'Value' => $value
199		];
200	1	return $this;
201		}
202
203		/**
204		* {@inheritDoc}
205		*/
206	17	public function get(): array
207		{
208	17	$query = parent::get();
209	17	$query['KeySchema'] = $this->keySchema;
210	17	$query['AttributeDefinitions'] = $this->attributeDefinitions;
211	17	$query['BillingMode'] = $this->billingMode;
212	17	$query['ProvisionedThroughput'] = [
213	17	'ReadCapacityUnits' => $this->readCapacityUnits,
214	17	'WriteCapacityUnits' => $this->writeCapacityUnits,
215		];
216	17	if (!empty($this->sseSpecification)) {
217	1	$query['SSESpecification'] = $this->sseSpecification;
218		}
219	17	if (!empty($this->tags)) {
220	1	$query['Tags'] = $this->tags;
221		}
222	17	return $query;
223		}
224		}
225

guillermoandrae / php-dynamodb

Push — master ( 20a668...02e94f )

CreateTableRequest::setReadCapacityUnits() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like