11// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
22// SPDX-License-Identifier: Apache-2.0
33
4- import aws.sdk.kotlin.runtime.auth.credentials.EnvironmentCredentialsProvider
54import aws.sdk.kotlin.services.secretsmanager.SecretsManagerClient
65import aws.sdk.kotlin.services.secretsmanager.model.GetSecretValueRequest
76import com.google.gson.Gson
@@ -20,10 +19,13 @@ import org.junit.jupiter.api.Order
2019import org.junit.jupiter.api.Test
2120import org.junit.jupiter.api.TestInstance
2221import org.junit.jupiter.api.TestMethodOrder
22+ import org.slf4j.Logger
23+ import org.slf4j.LoggerFactory
2324
2425@TestInstance(TestInstance .Lifecycle .PER_CLASS )
2526@TestMethodOrder(OrderAnnotation ::class )
2627class PipelineServiceTest {
28+ private val logger: Logger = LoggerFactory .getLogger(PipelineServiceTest ::class .java)
2729 private var name: String = " "
2830 private var roleArn: String = " "
2931 private var s3Bucket: String = " "
@@ -47,47 +49,47 @@ class PipelineServiceTest {
4749 fun createPipelineTest () =
4850 runBlocking {
4951 createNewPipeline(name, roleArn, s3Bucket, s3OutputBucket)
50- println (" \n Test 1 passed" )
52+ logger.info (" \n Test 1 passed" )
5153 }
5254
5355 @Test
5456 @Order(2 )
5557 fun startPipelineExecutionTest () =
5658 runBlocking {
5759 executePipeline(name)
58- println (" Test 2 passed" )
60+ logger.info (" Test 2 passed" )
5961 }
6062
6163 @Test
6264 @Order(3 )
6365 fun listPipelinesTest () =
6466 runBlocking {
6567 getAllPipelines()
66- println (" Test 3 passed" )
68+ logger.info (" Test 3 passed" )
6769 }
6870
6971 @Test
7072 @Order(4 )
7173 fun getPipelineTest () =
7274 runBlocking {
7375 getSpecificPipeline(name)
74- println (" Test 4 passed" )
76+ logger.info (" Test 4 passed" )
7577 }
7678
7779 @Test
7880 @Order(5 )
7981 fun listPipelineExecutionsTest () =
8082 runBlocking {
8183 listExecutions(name)
82- println (" Test 5 passed" )
84+ logger.info (" Test 5 passed" )
8385 }
8486
8587 @Test
8688 @Order(6 )
8789 fun deletePipelineTest () =
8890 runBlocking {
8991 deleteSpecificPipeline(name)
90- println (" Test 6 passed" )
92+ logger.info (" Test 6 passed" )
9193 }
9294
9395 private suspend fun getSecretValues (): String {
@@ -98,7 +100,6 @@ class PipelineServiceTest {
98100 }
99101 SecretsManagerClient {
100102 region = " us-east-1"
101- credentialsProvider = EnvironmentCredentialsProvider ()
102103 }.use { secretClient ->
103104 val valueResponse = secretClient.getSecretValue(valueRequest)
104105 return valueResponse.secretString.toString()
0 commit comments