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.

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

Jump to bottom

chore: fix inconsistency with endpointWithAttributes test #2196

Merged
merged 8 commits into from Dec 21, 2022
Merged

chore: fix inconsistency with endpointWithAttributes test #2196

Changes from 7 commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
8e22ade
add retry for pinpoint tests
sdhuka Dec 21, 2022
7afec43
add logging
sdhuka Dec 21, 2022
f94747e
add logging
sdhuka Dec 21, 2022
d5114db
added retry
sdhuka Dec 21, 2022
275c115
just run for pinpoint
sdhuka Dec 21, 2022
4ea193d
revert instrumentation changes
sdhuka Dec 21, 2022
36d766f
Merge branch 'main' into sdhuka/fix-endpoint-test
sdhuka Dec 21, 2022
515a414
address comments
sdhuka Dec 21, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
13 changes: 10 additions & 3 deletions ...Test/java/com/amplifyframework/analytics/pinpoint/PinpointAnalyticsInstrumentationTest.kt
View file
Open in desktop
Expand Up @@ -282,9 +282,16 @@ class PinpointAnalyticsInstrumentationTest {
.customProperties(properties)
.userAttributes(userAttributes)
.build()
Amplify.Analytics.identifyUser(UUID.randomUUID().toString(), pinpointUserProfile)
val uuid = UUID.randomUUID().toString()
Amplify.Analytics.identifyUser(uuid, pinpointUserProfile)
Sleep.milliseconds(PINPOINT_ROUNDTRIP_TIMEOUT)
val endpointResponse = fetchEndpointResponse()
var endpointResponse = fetchEndpointResponse()
var retry_count = 0
while (retry_count < 10 && (endpointResponse.attributes == null || endpointResponse.attributes?.size == 0)) {
Sleep.milliseconds(5 * 1000L)
tjleing marked this conversation as resolved.
Show resolved Hide resolved
endpointResponse = fetchEndpointResponse()
retry_count++
}
assertCommonEndpointResponseProperties(endpointResponse)
Assert.assertEquals(
"User attribute value",
Expand All @@ -310,7 +317,7 @@ class PinpointAnalyticsInstrumentationTest {
}

private fun assertCommonEndpointResponseProperties(endpointResponse: EndpointResponse) {
Log.i("DEBUG", endpointResponse.toString())
Log.d("PinpointAnalyticsInstrumentationTest", endpointResponse.toString())
val attributes = endpointResponse.attributes!!
Assert.assertEquals("user@test.com", attributes["email"]!![0])
Assert.assertEquals("test-user", attributes["name"]!![0])
Expand Down