appinfomigration
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/dfd6d292 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/dfd6d292 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/dfd6d292 Branch: refs/heads/USERGRID-685 Commit: dfd6d292364978a112153285a3d7b9c27635c937 Parents: 6e1ef16 Author: Shawn Feldman <sfeld...@apache.org> Authored: Tue Jun 2 10:45:47 2015 -0600 Committer: Shawn Feldman <sfeld...@apache.org> Committed: Tue Jun 2 10:45:47 2015 -0600 ---------------------------------------------------------------------- .../corepersistence/migration/AppInfoMigrationPluginTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/dfd6d292/stack/services/src/test/java/org/apache/usergrid/corepersistence/migration/AppInfoMigrationPluginTest.java ---------------------------------------------------------------------- diff --git a/stack/services/src/test/java/org/apache/usergrid/corepersistence/migration/AppInfoMigrationPluginTest.java b/stack/services/src/test/java/org/apache/usergrid/corepersistence/migration/AppInfoMigrationPluginTest.java index a51630c..9c8f40f 100644 --- a/stack/services/src/test/java/org/apache/usergrid/corepersistence/migration/AppInfoMigrationPluginTest.java +++ b/stack/services/src/test/java/org/apache/usergrid/corepersistence/migration/AppInfoMigrationPluginTest.java @@ -39,6 +39,7 @@ import org.junit.Test; import org.mockito.Mockito; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import rx.Observable; import java.util.ArrayList; import java.util.HashMap; @@ -170,9 +171,10 @@ public class AppInfoMigrationPluginTest { new SimpleEntityRef("application", mgmtAppId), "appinfos", Query.fromQL("select *")); assertEquals( 0, appInfoResults.size() ); - final Results applicationInfoResults = rootEm.searchCollection( + final Results applicationInfoResults = rootEm.searchCollection( new SimpleEntityRef("application", mgmtAppId), "application_infos", Query.fromQL("select *")); - assertEquals( 10, applicationInfoResults.size() ); + int appCount = Observable.from(applicationInfoResults.getEntities()).filter(entity -> !entity.getName().startsWith("org.") && !entity.getName().startsWith("usergrid")).toList().toBlocking().last().size(); + assertEquals( appIds.size() - deletedApps.size(),appCount ); // test that 10 applications are no longer broken
