Add integration test via localstack (#941)

Author: jderusse

Makefile

@@ -2,12 +2,15 @@
 
 initialize: start-docker
 start-docker:
-	docker pull amazon/dynamodb-local
-	docker start async_aws_dynamodb || docker run -d -p 8000:8000 --name async_aws_dynamodb amazon/dynamodb-local
+	docker start async_aws_localstack && exit 0 || \
+	docker start async_aws_localstack-dynamodb && exit 0 || \
+	docker pull localstack/localstack && \
+	docker run -d -p 4575:4566 -e SERVICES=dynamodb -v /var/run/docker.sock:/var/run/docker.sock --name async_aws_localstack-dynamodb localstack/localstack && \
+	docker run --rm --link async_aws_localstack-dynamodb:localstack martin/wait -c localstack:4566
 
 test: initialize
 	./vendor/bin/simple-phpunit
 
 clean: stop-docker
 stop-docker:
-	docker stop async_aws_dynamodb || true
+	docker stop async_aws_localstack-dynamodb || true

composer.json

@@ -16,6 +16,9 @@
         "ext-json": "*",
         "async-aws/core": "^1.2"
     },
+    "conflict": {
+        "symfony/http-client": "<4.4.16,<5.1.7"
+    },
     "extra": {
         "branch-alias": {
             "dev-master": "1.1-dev"

tests/Integration/DynamoDbClientTest.php

@@ -15,6 +15,7 @@
 use AsyncAws\DynamoDb\Input\DescribeTableInput;
 use AsyncAws\DynamoDb\Input\GetItemInput;
 use AsyncAws\DynamoDb\Input\ListTablesInput;
+use AsyncAws\DynamoDb\Input\PutItemInput;
 use AsyncAws\DynamoDb\Input\QueryInput;
 use AsyncAws\DynamoDb\Input\ScanInput;
 use AsyncAws\DynamoDb\Input\UpdateItemInput;
@@ -191,7 +192,32 @@ public function testBatchGetItem(): void
 
     public function testCreateTable(): void
     {
-        self::markTestSkipped('This is tested in setUp()');
+        $client = $this->getClient();
+
+        $input = new CreateTableInput([
+            'TableName' => 'demo',
+            'AttributeDefinitions' => [
+                new AttributeDefinition(['AttributeName' => 'ForumName', 'AttributeType' => 'S']),
+            ],
+            'KeySchema' => [
+                new KeySchemaElement(['AttributeName' => 'ForumName', 'KeyType' => KeyType::HASH]),
+            ],
+            'ProvisionedThroughput' => new ProvisionedThroughput([
+                'ReadCapacityUnits' => 5,
+                'WriteCapacityUnits' => 5,
+            ]),
+        ]);
+
+        $result = $client->createTable($input);
+        $result->resolve();
+
+        try {
+            self::assertSame('arn:aws:dynamodb:us-east-1:000000000000:table/demo', $result->getTableDescription()->getTableArn());
+            self::assertSame('0', $result->getTableDescription()->getItemCount());
+            self::assertTrue($client->tableExists(['TableName' => 'demo'])->isSuccess());
+        } finally {
+            $this->getClient()->deleteTable(['TableName' => 'demo']);
+        }
     }
 
     public function testDeleteItem(): void
@@ -216,7 +242,28 @@ public function testDeleteItem(): void
 
     public function testDeleteTable(): void
     {
-        self::markTestSkipped('This is tested in tearDown()');
+        $client = $this->getClient();
+
+        $input = new CreateTableInput([
+            'TableName' => 'demo',
+            'AttributeDefinitions' => [
+                new AttributeDefinition(['AttributeName' => 'ForumName', 'AttributeType' => 'S']),
+            ],
+            'KeySchema' => [
+                new KeySchemaElement(['AttributeName' => 'ForumName', 'KeyType' => KeyType::HASH]),
+            ],
+            'ProvisionedThroughput' => new ProvisionedThroughput([
+                'ReadCapacityUnits' => 5,
+                'WriteCapacityUnits' => 5,
+            ]),
+        ]);
+
+        $client->createTable($input);
+
+        $result = $client->deleteTable(['TableName' => 'demo']);
+        $result->resolve();
+
+        self::assertFalse($client->tableExists(['TableName' => 'demo'])->isSuccess());
     }
 
     public function testDescribeTable(): void
@@ -267,7 +314,22 @@ public function testListTables(): void
 
     public function testPutItem(): void
     {
-        self::markTestSkipped('This is tested in setUp()');
+        $client = $this->getClient();
+
+        $input = new PutItemInput([
+            'TableName' => $this->tableName,
+            'Item' => [
+                'LastPostDateTime' => ['S' => '201303190422'],
+                'Tags' => ['SS' => ['Update', 'Multiple Items', 'HelpMe']],
+                'ForumName' => ['S' => 'Amazon DynamoDB'],
+                'Message' => ['S' => 'I want to update multiple items in a single call. What\'s the best way to do that?'],
+                'Subject' => ['S' => 'How do I update multiple items?'],
+                'LastPostedBy' => ['S' => '[email protected]'],
+            ],
+        ]);
+
+        $result = $client->putItem($input);
+        self::assertSame(1.0, $result->getConsumedCapacity()->getCapacityUnits());
     }
 
     public function testQuery(): void
@@ -413,7 +475,7 @@ private function getClient(): DynamoDbClient
         }
 
         return $this->client = new DynamoDbClient([
-            'endpoint' => 'http://localhost:8000',
+            'endpoint' => 'http://localhost:4575',
         ], new Credentials('aws_id', 'aws_secret'));
     }
 }