Skip to content

Update example based on codegen enhancements since M0 #128

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
May 10, 2021
Merged

Update example based on codegen enhancements since M0 #128

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions examples/dynamodb-movies/src/main/kotlin/aws/sdk/kotlin/example/Main.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
package aws.sdk.kotlin.example

import aws.sdk.kotlin.runtime.AwsServiceException
import aws.sdk.kotlin.services.dynamodb.DynamodbClient
import aws.sdk.kotlin.services.dynamodb.DynamoDbClient
import aws.sdk.kotlin.services.dynamodb.model.*
import com.google.gson.JsonElement
import com.google.gson.JsonParser
Expand All @@ -17,7 +17,7 @@ import java.lang.IllegalStateException
* Partial implementation of: https://docs.amazonaws.cn/en_us/amazondynamodb/latest/developerguide/GettingStarted.Java.html
*/
fun main() = runBlocking {
val client = DynamodbClient { region = "us-east-2" }
val client = DynamoDbClient { region = "us-east-2" }

val tableName = "dynamo-movies-example"

Expand All @@ -44,7 +44,7 @@ fun main() = runBlocking {
client.close()
}

suspend fun createMoviesTable(client: DynamodbClient, name: String) {
suspend fun createMoviesTable(client: DynamoDbClient, name: String) {
val tableExists = client.listTables(ListTablesRequest {}).tableNames?.contains(name) ?: false
if (tableExists) return

Expand Down Expand Up @@ -82,7 +82,7 @@ suspend fun createMoviesTable(client: DynamodbClient, name: String) {
}

// no waiters support (yet)
suspend fun DynamodbClient.waitForTableReady(name: String) {
suspend fun DynamoDbClient.waitForTableReady(name: String) {
while (true) {
try {
val req = DescribeTableRequest { tableName = name }
Expand All @@ -91,14 +91,14 @@ suspend fun DynamodbClient.waitForTableReady(name: String) {
return
}
} catch (ex: AwsServiceException) {
if (!ex.isRetryable) throw ex
if (!ex.sdkErrorMetadata.isRetryable) throw ex
}
println("waiting for table to be ready...")
delay(1000)
}
}

suspend fun loadMoviesTable(client: DynamodbClient, name: String) {
suspend fun loadMoviesTable(client: DynamoDbClient, name: String) {
// load items into table
val data = getResourceAsText("data.json")
val elements = JsonParser.parseString(data).asJsonArray
Expand All @@ -114,7 +114,7 @@ suspend fun loadMoviesTable(client: DynamodbClient, name: String) {
}
}

suspend fun DynamodbClient.moviesInYear(name: String, year: Int): QueryResponse {
suspend fun DynamoDbClient.moviesInYear(name: String, year: Int): QueryResponse {
val req = QueryRequest {
tableName = name
keyConditionExpression = "#yr = :yyyy"
Expand All @@ -139,7 +139,7 @@ fun jsonElementToAttributeValue(element: JsonElement): AttributeValue = when {
element.isJsonPrimitive -> {
val primitive = element.asJsonPrimitive
when {
primitive.isBoolean -> AttributeValue.BOOL(primitive.asBoolean)
primitive.isBoolean -> AttributeValue.Bool(primitive.asBoolean)
primitive.isString -> AttributeValue.S(primitive.asString)
else -> {
check(primitive.isNumber) { "expected number" }
Expand Down