Skip to content

Commit 8e01b8f

Browse files
authored
feat(datastore): Multiauth integration tests (#1349)
1 parent 80de559 commit 8e01b8f

35 files changed

+5947
-7
lines changed

aws-datastore/build.gradle

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,10 +39,14 @@ dependencies {
3939
androidTestImplementation project(path: ':testmodels')
4040
androidTestImplementation project(path: ':testutils')
4141
androidTestImplementation project(path: ':aws-api')
42+
androidTestImplementation project(path: ':aws-auth-cognito')
43+
androidTestImplementation dependency.aws.mobileclient
4244
androidTestImplementation dependency.androidx.annotation
4345
androidTestImplementation dependency.androidx.test.core
4446
androidTestImplementation dependency.androidx.test.runner
4547
androidTestImplementation dependency.androidx.test.junit
4648
androidTestImplementation dependency.rxjava
49+
androidTestImplementation dependency.okhttp
50+
androidTestImplementation dependency.oauth2
4751
}
4852

aws-datastore/src/androidTest/java/com/amplifyframework/datastore/DataStoreHubEventFilters.java

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
import com.amplifyframework.core.model.Model;
1919
import com.amplifyframework.datastore.appsync.ModelWithMetadata;
20+
import com.amplifyframework.datastore.events.NetworkStatusEvent;
2021
import com.amplifyframework.datastore.syncengine.OutboxMutationEvent;
2122
import com.amplifyframework.hub.HubEventFilter;
2223

@@ -72,4 +73,22 @@ public static HubEventFilter receiptOf(String modelId) {
7273
return modelId.equals(modelWithMetadata.getModel().getId());
7374
};
7475
}
76+
77+
/**
78+
* Expect a network status failure event to be emitted by the sync engione.
79+
* @return A filter that checks for network failure messages.
80+
*/
81+
public static HubEventFilter networkStatusFailure() {
82+
return event -> {
83+
if (!DataStoreChannelEventName.NETWORK_STATUS.toString().equals(event.getName())) {
84+
return false;
85+
}
86+
if (!(event.getData() instanceof NetworkStatusEvent)) {
87+
return false;
88+
}
89+
NetworkStatusEvent outboxMutationEvent = (NetworkStatusEvent) event.getData();
90+
91+
return !outboxMutationEvent.getActive();
92+
};
93+
}
7594
}

0 commit comments

Comments
 (0)