Skip to content

Commit

Permalink
clean up test
Browse files Browse the repository at this point in the history
  • Loading branch information
xiazhvera committed May 2, 2024
1 parent f091d79 commit 039fa2e
Showing 1 changed file with 7 additions and 13 deletions.
20 changes: 7 additions & 13 deletions Test/AwsCommonRuntimeKitTests/mqtt/Mqtt5ClientTests.swift
Original file line number Diff line number Diff line change
Expand Up @@ -608,6 +608,7 @@ class Mqtt5ClientTests: XCBaseTestCase {

// XCode could only take terminal environment variable
let tlsOptions = try TLSContextOptions.makeDefault()
tlsOptions.setVerifyPeer(false)
let tlsContext = try TLSContext(options: tlsOptions, mode: .client)

let clientOptions = MqttClientOptions(
Expand All @@ -616,9 +617,7 @@ class Mqtt5ClientTests: XCBaseTestCase {
tlsCtx: tlsContext)

let testContext = MqttTestContext()
let provider = try CredentialsProvider(source: .static(accessKey: getEnvironmentVarOrSkipTest(environmentVarName: "TEST_RUNNER_AWS_ACCESS_KEY_ID"), secret: getEnvironmentVarOrSkipTest(environmentVarName: "TEST_RUNNER_AWS_SECRET_ACCESS_KEY")))
testContext.withIoTSigv4WebsocketTransform(region: "us-east-1", provider: provider)
// testContext.withWebsocketTransform(isSuccess: true)
testContext.withWebsocketTransform(isSuccess: true)

let client = try createClient(clientOptions: clientOptions, testContext: testContext)
try connectClient(client: client, testContext: testContext)
Expand All @@ -628,19 +627,16 @@ class Mqtt5ClientTests: XCBaseTestCase {
/*
* [ConnWS-UC4] websocket connection with TLS, using sigv4
*/
#if os(Linux)
func testMqtt5WSConnectWithMutualTLS() throws {
try skipIfPlatformDoesntSupportTLS()
try skipifmacOS()

let inputHost = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_MQTT5_IOT_CORE_HOST")
let inputCert = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_MQTT5_IOT_CORE_RSA_CERT")
let inputKey = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_MQTT5_IOT_CORE_RSA_KEY")
let region = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_MQTT5_IOT_CORE_REGION")
let ca = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_TLS_ROOT_CERT_PATH")

let tlsOptions = try TLSContextOptions.makeDefault()
try tlsOptions.overrideDefaultTrustStore(caPath: nil, caFile: ca)
// try tlsOptions.overrideDefaultTrustStore(caPath: nil, caFile: ca)

let tlsContext = try TLSContext(options: tlsOptions, mode: .client)

Expand All @@ -656,21 +652,20 @@ class Mqtt5ClientTests: XCBaseTestCase {
port: UInt32(443),
bootstrap: bootstrap,
tlsCtx: tlsContext)

let testContext = MqttTestContext()



// setup role credential
let accessKey = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_MQTT5_ROLE_CREDENTIAL_ACCESS_KEY")
let secret = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_MQTT5_ROLE_CREDENTIAL_SECRET_ACCESS_KEY")
let sessionToken = try getEnvironmentVarOrSkipTest(environmentVarName: "AWS_TEST_MQTT5_ROLE_CREDENTIAL_SESSION_TOKEN")
print("key: \(accessKey) \n secret: \(secret)")

let provider = try CredentialsProvider(source: .static(
accessKey: accessKey,
secret: secret,
sessionToken: sessionToken))



let testContext = MqttTestContext()
testContext.withIoTSigv4WebsocketTransform(region: region, provider: provider)


Expand All @@ -679,7 +674,6 @@ class Mqtt5ClientTests: XCBaseTestCase {
try connectClient(client: client, testContext: testContext)
try disconnectClientCleanup(client:client, testContext: testContext)
}
#endif

/*===============================================================
NEGATIVE CONNECT TEST CASES
Expand Down

0 comments on commit 039fa2e

Please sign in to comment.