| /** |
| * 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 |
| * <p> |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * <p> |
| * 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 org.apache.hadoop.ozone.s3.util; |
| |
| import org.apache.hadoop.hdds.conf.OzoneConfiguration; |
| import org.apache.hadoop.ozone.OmUtils; |
| import org.apache.hadoop.ozone.om.OMConfigKeys; |
| import org.apache.hadoop.security.SecurityUtil; |
| import org.apache.hadoop.test.GenericTestUtils; |
| import org.junit.Assert; |
| import org.junit.Before; |
| import org.junit.Test; |
| |
| import java.util.Collection; |
| |
| import static org.apache.hadoop.fs.CommonConfigurationKeys.HADOOP_SECURITY_TOKEN_SERVICE_USE_IP; |
| import static org.junit.Assert.fail; |
| |
| /** |
| * Class used to test OzoneS3Util. |
| */ |
| public class TestOzoneS3Util { |
| |
| |
| private OzoneConfiguration configuration; |
| private String serviceID = "omService"; |
| |
| @Before |
| public void setConf() { |
| configuration = new OzoneConfiguration(); |
| |
| String nodeIDs = "om1,om2,om3"; |
| configuration.set(OMConfigKeys.OZONE_OM_SERVICE_IDS_KEY, serviceID); |
| configuration.set(OMConfigKeys.OZONE_OM_NODES_KEY + "." + serviceID, |
| nodeIDs); |
| configuration.setBoolean(HADOOP_SECURITY_TOKEN_SERVICE_USE_IP, false); |
| } |
| |
| @Test |
| public void testBuildServiceNameForToken() { |
| |
| Collection<String> nodeIDList = OmUtils.getOMNodeIds(configuration, |
| serviceID); |
| |
| configuration.set(OmUtils.addKeySuffixes(OMConfigKeys.OZONE_OM_ADDRESS_KEY, |
| serviceID, "om1"), "om1:9862"); |
| configuration.set(OmUtils.addKeySuffixes(OMConfigKeys.OZONE_OM_ADDRESS_KEY, |
| serviceID, "om2"), "om2:9862"); |
| configuration.set(OmUtils.addKeySuffixes(OMConfigKeys.OZONE_OM_ADDRESS_KEY, |
| serviceID, "om3"), "om3:9862"); |
| |
| String expectedOmServiceAddress = buildServiceAddress(nodeIDList); |
| |
| SecurityUtil.setConfiguration(configuration); |
| String omserviceAddr = OzoneS3Util.buildServiceNameForToken(configuration, |
| serviceID, nodeIDList); |
| |
| Assert.assertEquals(expectedOmServiceAddress, omserviceAddr); |
| } |
| |
| |
| @Test |
| public void testBuildServiceNameForTokenIncorrectConfig() { |
| |
| Collection<String> nodeIDList = OmUtils.getOMNodeIds(configuration, |
| serviceID); |
| |
| // Don't set om3 node rpc address. Here we are skipping setting of one of |
| // the OM address. So buildServiceNameForToken will fail. |
| configuration.set(OmUtils.addKeySuffixes(OMConfigKeys.OZONE_OM_ADDRESS_KEY, |
| serviceID, "om1"), "om1:9862"); |
| configuration.set(OmUtils.addKeySuffixes(OMConfigKeys.OZONE_OM_ADDRESS_KEY, |
| serviceID, "om2"), "om2:9862"); |
| |
| |
| SecurityUtil.setConfiguration(configuration); |
| |
| try { |
| OzoneS3Util.buildServiceNameForToken(configuration, |
| serviceID, nodeIDList); |
| fail("testBuildServiceNameForTokenIncorrectConfig failed"); |
| } catch (IllegalArgumentException ex) { |
| GenericTestUtils.assertExceptionContains("Could not find rpcAddress " + |
| "for", ex); |
| } |
| |
| |
| } |
| |
| /** |
| * Build serviceName from list of node ids. |
| * @param nodeIDList |
| * @return service name for token. |
| */ |
| private String buildServiceAddress(Collection<String> nodeIDList) { |
| StringBuilder omServiceAddrBuilder = new StringBuilder(); |
| int nodesLength = nodeIDList.size(); |
| int counter = 0; |
| for (String nodeID : nodeIDList) { |
| counter++; |
| String addr = configuration.get(OmUtils.addKeySuffixes( |
| OMConfigKeys.OZONE_OM_ADDRESS_KEY, serviceID, nodeID)); |
| |
| if (counter != nodesLength) { |
| omServiceAddrBuilder.append(addr + ","); |
| } else { |
| omServiceAddrBuilder.append(addr); |
| } |
| } |
| |
| return omServiceAddrBuilder.toString(); |
| } |
| |
| } |