changed amazon dependencies to quarkus dependencies

Author: EdWrld

build.gradle.kts

@@ -116,8 +116,8 @@ kotlin {
                 implementation("com.amazonaws:aws-java-sdk-sts:1.12.364")
                 implementation("com.amazonaws:aws-java-sdk-lambda:1.12.364")
 //                implementation("com.amazonaws:aws-java-sdk-dynamodb:1.12.364")
-                implementation("software.amazon.awssdk:dynamodb:2.19.21")
-                implementation("software.amazon.awssdk:dynamodb-enhanced:2.19.21")
+                implementation("io.quarkiverse.amazonservices:quarkus-amazon-dynamodb:1.4.0")
+                implementation("io.quarkiverse.amazonservices:quarkus-amazon-dynamodb-enhanced:1.4.0")
                 implementation("com.amazonaws:aws-java-sdk-sns:1.12.351")
                 implementation("org.apache.logging.log4j:log4j-core:2.19.0")
                 implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:1.4.1")

src/jvmMain/kotlin/bbs/priorityqueue/appdata/PriorityQueueElement.kt

@@ -7,7 +7,6 @@ import com.fasterxml.jackson.annotation.JsonInclude
 import com.fasterxml.jackson.annotation.JsonProperty
 import org.joda.time.DateTime
 import org.joda.time.LocalDate
-import java.util.logging.Logger
 
 @JsonInclude(JsonInclude.Include.NON_NULL)
 @DynamoDbBean

src/jvmMain/kotlin/bbs/priorityqueue/sdk/Dynamodb.kt

@@ -1,39 +1,20 @@
 package bbs.priorityqueue.sdk
 
-//import com.amazonaws.retry.PredefinedRetryPolicies
-//import com.amazonaws.retry.RetryPolicy
-
-
-//import com.amazonaws.services.dynamodbv2.AmazonDynamoDB
-//import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder
-//import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapper
-//import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig
-//import com.amazonaws.services.dynamodbv2.datamodeling.DynamoDBMapperConfig.TableNameOverride
-//import com.amazonaws.services.dynamodbv2.document.DynamoDB
-//import com.amazonaws.services.dynamodbv2.document.UpdateItemOutcome
-//import com.amazonaws.services.dynamodbv2.document.spec.UpdateItemSpec
-//import com.amazonaws.services.dynamodbv2.document.utils.NameMap
-//import com.amazonaws.services.dynamodbv2.document.utils.ValueMap
-//import com.amazonaws.services.dynamodbv2.model.AttributeValue
-//import com.amazonaws.services.dynamodbv2.model.QueryRequest
-//import com.amazonaws.services.dynamodbv2.model.ReturnValue
-
-
 import bbs.priorityqueue.Constants
 import bbs.priorityqueue.appdata.PriorityQueueElement
 import bbs.priorityqueue.model.QueueStats
 import bbs.priorityqueue.model.ReturnResult
 import bbs.priorityqueue.model.ReturnStatusEnum
 import bbs.priorityqueue.model.SystemInfo
 import bbs.priorityqueue.utils.Utils
-import com.amazonaws.auth.*
+
 import software.amazon.awssdk.auth.credentials.ProfileCredentialsProvider
 import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClient
 import software.amazon.awssdk.enhanced.dynamodb.DynamoDbTable
 import software.amazon.awssdk.enhanced.dynamodb.Key
 import software.amazon.awssdk.enhanced.dynamodb.TableSchema
 import software.amazon.awssdk.enhanced.dynamodb.model.GetItemEnhancedRequest
-import software.amazon.awssdk.enhanced.dynamodb.model.UpdateItemEnhancedRequest
+
 import software.amazon.awssdk.regions.Region
 import software.amazon.awssdk.services.dynamodb.DynamoDbClient
 import software.amazon.awssdk.services.dynamodb.model.AttributeValue
@@ -66,49 +47,16 @@ class Dynamodb(builder: Builder) : Database {
 
     override fun initialize() : Database {
         Locale.setDefault(Locale.ENGLISH)
-//        var accessKey = System.getenv("AWS_ACCESS_KEY_ID")
-//        var secretKey = System.getenv("AWS_SECRET_ACCESS_KEY")
-//
-//        // If the aws credentials aren't given via cli then checks Environment variables
-//        if (Utils.checkIfNotNullAndNotEmptyString(accessKey) && Utils.checkIfNotNullAndNotEmptyString(secretKey)) {
-//            if (Utils.checkIfNullOrEmptyString(accessKey)) accessKey = System.getenv("AWS_ACCESS_KEY_ID")
-//            if (Utils.checkIfNullOrEmptyString(secretKey)) secretKey = System.getenv("AWS_SECRET_ACCESS_KEY")
-//            credentials = BasicAWSCredentials(accessKey, secretKey)
-//        } else if (Utils.checkIfNotNullAndNotEmptyString(awsCredentialsProfileName)) {
-//          !!//(awsCredentialsProfileName).credentials
-//        }
-
-       // val credentialProvider: ProfileCredentialsProvider=  ProfileCredentialsProvider.create(awsCredentialsProfileName
-        // Creates a new instance of secure random everytime Dynamodb is instantiated
-        // Fix? to Random/SplittableRandom being stored in heap when library is being compiled for a native-image
 
         dynamoDB =DynamoDbClient.builder()
             .credentialsProvider(credentialProvider)
             .region(awsRegion)
             .build()
 
-
-
         dynamoDBEnhanced = DynamoDbEnhancedClient.builder()
             .dynamoDbClient(dynamoDB)
             .build()
 
-
-
-//            .clientconfiguration(
-//                ClientConfiguration()
-//                    .withMaxConnections(100)
-//                    .withConnectionTimeout(30000)
-//                    .withSecureRandom(secureRandom))
-
-
-//        val mapperConfig = DynamoDBMapperConfig.builder()
-//            .withSaveBehavior(DynamoDBMapperConfig.SaveBehavior.CLOBBER)
-//            .withConsistentReads(DynamoDBMapperConfig.ConsistentReads.CONSISTENT) //.withConsistentReads(DynamoDBMapperConfig.ConsistentReads.EVENTUAL)
-//            .withTableNameOverride(TableNameOverride(tableName))
-//            .withPaginationLoadingStrategy(DynamoDBMapperConfig.PaginationLoadingStrategy.EAGER_LOADING)
-//            .build()
-
         dbMapper = dynamoDBEnhanced?.table(tableName, TableSchema.fromBean(PriorityQueueElement::class.java))
         return this
     }

src/jvmTest/kotlin/bbs/priorityqueue/DynamoDBTests.kt

@@ -1,6 +1,5 @@
 package bbs.priorityqueue
 
-import com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration
 import bbs.priorityqueue.appdata.PriorityQueueElement
 import bbs.priorityqueue.sdk.Database
 import bbs.priorityqueue.sdk.Dynamodb
@@ -17,10 +16,11 @@ import java.net.URI
 
 class DynamoDBTests : AnnotationSpec() {
 
-    private final val endpoint = URI.create("http://localhost:4566/")
+    private val endpoint = URI.create("http://localhost:4566/")
     val client: Database? = Dynamodb.Builder()
         .withRegion(Region.US_EAST_2)
         .withTableName("priority_queue_table")
+        //.withCredentialsProfileName("default")
         .build(endpoint)
 
     // Data to Insert