Added ClientPRMetaData test
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/3483b112 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/3483b112 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/3483b112 Branch: refs/heads/feature/GEODE-1571 Commit: 3483b11217dc408533fbac1fa963c9fac45739f7 Parents: ceabe8c Author: Kevin J. Duling <kdul...@pivotal.io> Authored: Mon Jun 27 15:23:23 2016 -0700 Committer: Kevin J. Duling <kdul...@pivotal.io> Committed: Mon Jun 27 15:23:23 2016 -0700 ---------------------------------------------------------------------- ...tGetClientPRMetaDataAuthDistributedTest.java | 62 ++++++++++++++++++++ ...ientPartitionAttrCmdAuthDistributedTest.java | 8 +-- 2 files changed, 65 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3483b112/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPRMetaDataAuthDistributedTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPRMetaDataAuthDistributedTest.java b/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPRMetaDataAuthDistributedTest.java new file mode 100644 index 0000000..899100e --- /dev/null +++ b/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPRMetaDataAuthDistributedTest.java @@ -0,0 +1,62 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.gemstone.gemfire.security; + +import org.junit.Test; +import org.junit.experimental.categories.Category; + +import com.gemstone.gemfire.cache.Region; +import com.gemstone.gemfire.cache.client.ClientCache; +import com.gemstone.gemfire.cache.client.ClientCacheFactory; +import com.gemstone.gemfire.cache.client.ClientRegionShortcut; +import com.gemstone.gemfire.cache.client.internal.ClientMetadataService; +import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; +import com.gemstone.gemfire.internal.cache.LocalRegion; +import com.gemstone.gemfire.test.junit.categories.DistributedTest; + +@Category(DistributedTest.class) +public class IntegratedClientGetClientPRMetaDataAuthDistributedTest extends AbstractIntegratedClientAuthDistributedTest { + + @Test + public void testGetClientPartitionAttrCmd() { + client1.invoke("logging in stranger", () -> { + ClientCache cache = new ClientCacheFactory(createClientProperties("stranger", "1234567")) + .setPoolSubscriptionEnabled(true) + .addPoolServer("localhost", serverPort) + .create(); + + Region region = cache.createClientRegionFactory(ClientRegionShortcut.PROXY).create(REGION_NAME); + + ClientMetadataService service = ((GemFireCacheImpl)cache).getClientMetadataService(); + assertNotAuthorized(() -> service.getClientPRMetadata((LocalRegion)cache.getRegion(region.getName())), "CLUSTER:READ"); + }); + + client2.invoke("logging in super-user", () -> { + ClientCache cache = new ClientCacheFactory(createClientProperties("super-user", "1234567")) + .setPoolSubscriptionEnabled(true) + .addPoolServer("localhost", serverPort) + .create(); + + Region region = cache.createClientRegionFactory(ClientRegionShortcut.PROXY).create(REGION_NAME); + + ClientMetadataService service = ((GemFireCacheImpl)cache).getClientMetadataService(); + service.getClientPRMetadata((LocalRegion)cache.getRegion(region.getName())); + }); + } +} + + http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/3483b112/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPartitionAttrCmdAuthDistributedTest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPartitionAttrCmdAuthDistributedTest.java b/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPartitionAttrCmdAuthDistributedTest.java index fbbdc05..edfa72a 100644 --- a/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPartitionAttrCmdAuthDistributedTest.java +++ b/geode-core/src/test/java/com/gemstone/gemfire/security/IntegratedClientGetClientPartitionAttrCmdAuthDistributedTest.java @@ -16,7 +16,8 @@ */ package com.gemstone.gemfire.security; -import java.util.Arrays; +import org.junit.Test; +import org.junit.experimental.categories.Category; import com.gemstone.gemfire.cache.Region; import com.gemstone.gemfire.cache.client.ClientCache; @@ -26,15 +27,12 @@ import com.gemstone.gemfire.cache.client.internal.GetClientPartitionAttributesOp import com.gemstone.gemfire.cache.client.internal.PoolImpl; import com.gemstone.gemfire.test.junit.categories.DistributedTest; -import org.junit.Test; -import org.junit.experimental.categories.Category; - @Category(DistributedTest.class) public class IntegratedClientGetClientPartitionAttrCmdAuthDistributedTest extends AbstractIntegratedClientAuthDistributedTest { @Test public void testGetClientPartitionAttrCmd() { - client1.invoke("logging in super-user with correct password", () -> { + client1.invoke("logging in stranger", () -> { ClientCache cache = new ClientCacheFactory(createClientProperties("stranger", "1234567")) .setPoolSubscriptionEnabled(true) .addPoolServer("localhost", serverPort)
