RBT-1280 addd synchronised keyword to history table

Author: josie-atkins

graphql-database-manager-test/src/main/java/com/phocassoftware/graphql/database/manager/test/DynamoDbInitializer.java

@@ -17,11 +17,13 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.phocassoftware.graphql.database.manager.Database;
 import com.phocassoftware.graphql.database.manager.dynamo.DynamoDbManager;
+
 import java.io.IOException;
 import java.net.ServerSocket;
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.util.concurrent.ExecutionException;
+
 import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
 import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
 import software.amazon.awssdk.regions.Region;
@@ -100,38 +102,41 @@ static void createHistoryTable(final DynamoDbClient client, final String name) t
 			return;
 		}
 
-		client
-			.createTable(
-				t -> t
-					.tableName(name)
-					.keySchema(
-						KeySchemaElement.builder().attributeName("organisationIdType").keyType(KeyType.HASH).build(),
-						KeySchemaElement.builder().attributeName("idRevision").keyType(KeyType.RANGE).build()
-					)
-					.localSecondaryIndexes(
-						builder -> builder
-							.indexName("startsWithUpdatedAt")
-							.projection(b -> b.projectionType(ProjectionType.ALL))
-							.keySchema(
-								KeySchemaElement.builder().attributeName("organisationIdType").keyType(KeyType.HASH).build(),
-								KeySchemaElement.builder().attributeName("startsWithUpdatedAt").keyType(KeyType.RANGE).build()
-							),
-						builder -> builder
-							.indexName("idDate")
-							.projection(b -> b.projectionType(ProjectionType.ALL))
-							.keySchema(
-								KeySchemaElement.builder().attributeName("organisationIdType").keyType(KeyType.HASH).build(),
-								KeySchemaElement.builder().attributeName("idDate").keyType(KeyType.RANGE).build()
-							)
-					)
-					.attributeDefinitions(
-						AttributeDefinition.builder().attributeName("organisationIdType").attributeType(ScalarAttributeType.S).build(),
-						AttributeDefinition.builder().attributeName("idRevision").attributeType(ScalarAttributeType.B).build(),
-						AttributeDefinition.builder().attributeName("idDate").attributeType(ScalarAttributeType.B).build(),
-						AttributeDefinition.builder().attributeName("startsWithUpdatedAt").attributeType(ScalarAttributeType.B).build()
-					)
-					.provisionedThroughput(p -> p.readCapacityUnits(10L).writeCapacityUnits(10L).build())
-			);
+		// looks like bug within local dynamodb client around creating multiple tables at the same time
+		synchronized (DynamoDbInitializer.class) {
+			client
+				.createTable(
+					t -> t
+						.tableName(name)
+						.keySchema(
+							KeySchemaElement.builder().attributeName("organisationIdType").keyType(KeyType.HASH).build(),
+							KeySchemaElement.builder().attributeName("idRevision").keyType(KeyType.RANGE).build()
+						)
+						.localSecondaryIndexes(
+							builder -> builder
+								.indexName("startsWithUpdatedAt")
+								.projection(b -> b.projectionType(ProjectionType.ALL))
+								.keySchema(
+									KeySchemaElement.builder().attributeName("organisationIdType").keyType(KeyType.HASH).build(),
+									KeySchemaElement.builder().attributeName("startsWithUpdatedAt").keyType(KeyType.RANGE).build()
+								),
+							builder -> builder
+								.indexName("idDate")
+								.projection(b -> b.projectionType(ProjectionType.ALL))
+								.keySchema(
+									KeySchemaElement.builder().attributeName("organisationIdType").keyType(KeyType.HASH).build(),
+									KeySchemaElement.builder().attributeName("idDate").keyType(KeyType.RANGE).build()
+								)
+						)
+						.attributeDefinitions(
+							AttributeDefinition.builder().attributeName("organisationIdType").attributeType(ScalarAttributeType.S).build(),
+							AttributeDefinition.builder().attributeName("idRevision").attributeType(ScalarAttributeType.B).build(),
+							AttributeDefinition.builder().attributeName("idDate").attributeType(ScalarAttributeType.B).build(),
+							AttributeDefinition.builder().attributeName("startsWithUpdatedAt").attributeType(ScalarAttributeType.B).build()
+						)
+						.provisionedThroughput(p -> p.readCapacityUnits(10L).writeCapacityUnits(10L).build())
+				);
+		}
 	}
 
 	static synchronized DynamoDBProxyServer startDynamoServer(final String port) throws Exception {