Skip to content
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.

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

Kotlin Add lintered files and update the Kotlin Build to 1.2.28 #6530

Merged
merged 23 commits into from
Jun 11, 2024
Merged

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
@@ -1,68 +1,75 @@
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

package com.kotlin.mediaconvert

// snippet-start:[mediaconvert.kotlin.get_job.import]
import aws.sdk.kotlin.services.mediaconvert.MediaConvertClient
import aws.sdk.kotlin.services.mediaconvert.endpoints.MediaConvertEndpointProvider
import aws.sdk.kotlin.services.mediaconvert.model.DescribeEndpointsRequest
import aws.sdk.kotlin.services.mediaconvert.model.GetJobRequest
import aws.sdk.kotlin.services.mediaconvert.model.GetJobResponse
import aws.smithy.kotlin.runtime.client.endpoints.Endpoint
import kotlin.system.exitProcess
// snippet-end:[mediaconvert.kotlin.get_job.import]

/**
Before running this Kotlin code example, set up your development environment,
including your credentials.

For more information, see the following documentation topic:
https://docs.aws.amazon.com/sdk-for-kotlin/latest/developer-guide/setup.html
*/
suspend fun main(args: Array<String>) {
val usage = """
GetJob <jobId>

Where:
jobId - the job id value.
"""

if (args.size != 1) {
println(usage)
exitProcess(0)
}

val jobId = args[0]
val mcClient = MediaConvertClient { region = "us-west-2" }
getSpecificJob(mcClient, jobId)
}

// snippet-start:[mediaconvert.kotlin.get_job.main]
suspend fun getSpecificJob(mcClient: MediaConvertClient, jobId: String?) {
val describeEndpoints = DescribeEndpointsRequest {
maxResults = 20
}

val res = mcClient.describeEndpoints(describeEndpoints)
if (res.endpoints?.size!! <= 0) {
println("Cannot find MediaConvert service endpoint URL!")
exitProcess(0)
}

val endpointURL = res.endpoints!!.get(0).url!!
val mediaConvert = MediaConvertClient.fromEnvironment {
region = "us-west-2"
endpointProvider = MediaConvertEndpointProvider {
Endpoint(endpointURL)
}
}

val jobRequest = GetJobRequest {
id = jobId
}

val response: GetJobResponse = mediaConvert.getJob(jobRequest)
println("The ARN of the job is ${response.job?.arn}.")
}
// snippet-end:[mediaconvert.kotlin.get_job.main]
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

package com.kotlin.mediaconvert

// snippet-start:[mediaconvert.kotlin.get_job.import]
import aws.sdk.kotlin.services.mediaconvert.MediaConvertClient
import aws.sdk.kotlin.services.mediaconvert.endpoints.MediaConvertEndpointProvider
import aws.sdk.kotlin.services.mediaconvert.model.DescribeEndpointsRequest
import aws.sdk.kotlin.services.mediaconvert.model.GetJobRequest
import aws.sdk.kotlin.services.mediaconvert.model.GetJobResponse
import aws.smithy.kotlin.runtime.client.endpoints.Endpoint
import kotlin.system.exitProcess
// snippet-end:[mediaconvert.kotlin.get_job.import]

/**
Before running this Kotlin code example, set up your development environment,
including your credentials.

For more information, see the following documentation topic:
https://docs.aws.amazon.com/sdk-for-kotlin/latest/developer-guide/setup.html
*/
suspend fun main(args: Array<String>) {
val usage = """
GetJob <jobId>

Where:
jobId - the job id value.
"""

if (args.size != 1) {
println(usage)
exitProcess(0)
}

val jobId = args[0]
val mcClient = MediaConvertClient { region = "us-west-2" }
getSpecificJob(mcClient, jobId)
}

// snippet-start:[mediaconvert.kotlin.get_job.main]
suspend fun getSpecificJob(
mcClient: MediaConvertClient,
jobId: String?
) {
val describeEndpoints =
DescribeEndpointsRequest {
maxResults = 20
}

val res = mcClient.describeEndpoints(describeEndpoints)
if (res.endpoints?.size!! <= 0) {
println("Cannot find MediaConvert service endpoint URL!")
exitProcess(0)
}

val endpointURL = res.endpoints!!.get(0).url!!
val mediaConvert =
MediaConvertClient.fromEnvironment {
region = "us-west-2"
endpointProvider =
MediaConvertEndpointProvider {
Endpoint(endpointURL)
}
}

val jobRequest =
GetJobRequest {
id = jobId
}

val response: GetJobResponse = mediaConvert.getJob(jobRequest)
println("The ARN of the job is ${response.job?.arn}.")
}
// snippet-end:[mediaconvert.kotlin.get_job.main]
Original file line number Diff line number Diff line change
@@ -1,60 +1,64 @@
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

package com.kotlin.mediaconvert

// snippet-start:[mediaconvert.kotlin.list_jobs.import]
import aws.sdk.kotlin.services.mediaconvert.MediaConvertClient
import aws.sdk.kotlin.services.mediaconvert.endpoints.MediaConvertEndpointProvider
import aws.sdk.kotlin.services.mediaconvert.model.DescribeEndpointsRequest
import aws.sdk.kotlin.services.mediaconvert.model.JobStatus
import aws.sdk.kotlin.services.mediaconvert.model.ListJobsRequest
import aws.smithy.kotlin.runtime.client.endpoints.Endpoint
import kotlin.system.exitProcess
// snippet-end:[mediaconvert.kotlin.list_jobs.import]

/**
Before running this Kotlin code example, set up your development environment,
including your credentials.

For more information, see the following documentation topic:
https://docs.aws.amazon.com/sdk-for-kotlin/latest/developer-guide/setup.html
*/
suspend fun main() {
val mcClient = MediaConvertClient { region = "us-west-2" }
listCompleteJobs(mcClient)
}

// snippet-start:[mediaconvert.kotlin.list_jobs.main]
suspend fun listCompleteJobs(mcClient: MediaConvertClient) {
val describeEndpoints = DescribeEndpointsRequest {
maxResults = 20
}

val res = mcClient.describeEndpoints(describeEndpoints)
if (res.endpoints?.size!! <= 0) {
println("Cannot find MediaConvert service endpoint URL!")
exitProcess(0)
}
val endpointURL = res.endpoints!![0].url!!
val mediaConvert = MediaConvertClient.fromEnvironment {
region = "us-west-2"
endpointProvider = MediaConvertEndpointProvider {
Endpoint(endpointURL)
}
}

val jobsRequest = ListJobsRequest {
maxResults = 10
status = JobStatus.fromValue("COMPLETE")
}

val jobsResponse = mediaConvert.listJobs(jobsRequest)
val jobs = jobsResponse.jobs
if (jobs != null) {
for (job in jobs) {
println("The JOB ARN is ${job.arn}")
}
}
}
// snippet-end:[mediaconvert.kotlin.list_jobs.main]
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

package com.kotlin.mediaconvert

// snippet-start:[mediaconvert.kotlin.list_jobs.import]
import aws.sdk.kotlin.services.mediaconvert.MediaConvertClient
import aws.sdk.kotlin.services.mediaconvert.endpoints.MediaConvertEndpointProvider
import aws.sdk.kotlin.services.mediaconvert.model.DescribeEndpointsRequest
import aws.sdk.kotlin.services.mediaconvert.model.JobStatus
import aws.sdk.kotlin.services.mediaconvert.model.ListJobsRequest
import aws.smithy.kotlin.runtime.client.endpoints.Endpoint
import kotlin.system.exitProcess
// snippet-end:[mediaconvert.kotlin.list_jobs.import]

/**
Before running this Kotlin code example, set up your development environment,
including your credentials.

For more information, see the following documentation topic:
https://docs.aws.amazon.com/sdk-for-kotlin/latest/developer-guide/setup.html
*/
suspend fun main() {
val mcClient = MediaConvertClient { region = "us-west-2" }
listCompleteJobs(mcClient)
}

// snippet-start:[mediaconvert.kotlin.list_jobs.main]
suspend fun listCompleteJobs(mcClient: MediaConvertClient) {
val describeEndpoints =
DescribeEndpointsRequest {
maxResults = 20
}

val res = mcClient.describeEndpoints(describeEndpoints)
if (res.endpoints?.size!! <= 0) {
println("Cannot find MediaConvert service endpoint URL!")
exitProcess(0)
}
val endpointURL = res.endpoints!![0].url!!
val mediaConvert =
MediaConvertClient.fromEnvironment {
region = "us-west-2"
endpointProvider =
MediaConvertEndpointProvider {
Endpoint(endpointURL)
}
}

val jobsRequest =
ListJobsRequest {
maxResults = 10
status = JobStatus.fromValue("COMPLETE")
}

val jobsResponse = mediaConvert.listJobs(jobsRequest)
val jobs = jobsResponse.jobs
if (jobs != null) {
for (job in jobs) {
println("The JOB ARN is ${job.arn}")
}
}
}
// snippet-end:[mediaconvert.kotlin.list_jobs.main]
66 changes: 35 additions & 31 deletions kotlin/services/mediaconvert/src/test/kotlin/MCTest.kt
Original file line number Diff line number Diff line change
@@ -1,9 +1,6 @@
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

import aws.sdk.kotlin.runtime.auth.credentials.EnvironmentCredentialsProvider
import aws.sdk.kotlin.services.mediaconvert.MediaConvertClient
import aws.sdk.kotlin.services.secretsmanager.SecretsManagerClient
import aws.sdk.kotlin.services.secretsmanager.model.GetSecretValueRequest
import com.google.gson.Gson
import com.kotlin.mediaconvert.createMediaJob
Expand All @@ -20,7 +17,6 @@ import org.junit.jupiter.api.Test
import org.junit.jupiter.api.TestInstance
import org.junit.jupiter.api.TestMethodOrder
import java.io.IOException
import java.util.*

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@TestMethodOrder(OrderAnnotation::class)
Expand All @@ -32,52 +28,60 @@ class MCTest {

@BeforeAll
@Throws(IOException::class)
fun setUp() = runBlocking {
mcClient = MediaConvertClient { region = "us-west-2" }
// Get the values to run these tests from AWS Secrets Manager.
val gson = Gson()
val json: String = getSecretValues()
val values = gson.fromJson(json, SecretValues::class.java)
mcRoleARN = values.mcRoleARN.toString()
fileInput = values.fileInput.toString()
fun setUp() =
runBlocking {
mcClient = MediaConvertClient { region = "us-west-2" }
// Get the values to run these tests from AWS Secrets Manager.
val gson = Gson()
val json: String = getSecretValues()
val values = gson.fromJson(json, SecretValues::class.java)
mcRoleARN = values.mcRoleARN.toString()
fileInput = values.fileInput.toString()
/*

val input: InputStream = this.javaClass.getClassLoader().getResourceAsStream("config.properties")
val prop = Properties()
prop.load(input)
mcRoleARN = prop.getProperty("mcRoleARN")
fileInput = prop.getProperty("fileInput")
*/
}
*/
}

@Test
@Order(2)
fun createJobTest() = runBlocking {
jobId = createMediaJob(mcClient, mcRoleARN, fileInput).toString()
assertTrue(!jobId.isEmpty()).toString()
println("Test 2 passed")
}
fun createJobTest() =
runBlocking {
jobId = createMediaJob(mcClient, mcRoleARN, fileInput).toString()
assertTrue(!jobId.isEmpty()).toString()
println("Test 2 passed")
}

@Test
@Order(3)
fun listJobsTest() = runBlocking {
listCompleteJobs(mcClient)
println("Test 3 passed")
}
fun listJobsTest() =
runBlocking {
listCompleteJobs(mcClient)
println("Test 3 passed")
}

@Test
@Order(4)
fun getJobTest() = runBlocking {
getSpecificJob(mcClient, jobId)
println("Test 4 passed")
}
fun getJobTest() =
runBlocking {
getSpecificJob(mcClient, jobId)
println("Test 4 passed")
}

private suspend fun getSecretValues(): String {
val secretName = "test/mediaconvert"
val valueRequest = GetSecretValueRequest {
secretId = secretName
}
SecretsManagerClient { region = "us-east-1"; credentialsProvider = EnvironmentCredentialsProvider() }.use { secretClient ->
val valueRequest =
GetSecretValueRequest {
secretId = secretName
}
SecretsManagerClient {
region = "us-east-1"
credentialsProvider = EnvironmentCredentialsProvider()
}.use { secretClient ->
val valueResponse = secretClient.getSecretValue(valueRequest)
return valueResponse.secretString.toString()
}
Expand Down
2 changes: 1 addition & 1 deletion kotlin/services/mediastore/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ repositories {
}
apply(plugin = "org.jlleitschuh.gradle.ktlint")
dependencies {
implementation("aws.sdk.kotlin:mediastore:1.0.30")
implementation("aws.sdk.kotlin:mediastore:1.2.28")
implementation("aws.smithy.kotlin:http-client-engine-okhttp:0.30.0")
implementation("aws.smithy.kotlin:http-client-engine-crt:0.30.0")
testImplementation("org.junit.jupiter:junit-jupiter:5.9.0")
Expand Down
Loading
Loading