0001
0002
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018 package org.apache.spark.network.util;
0019
0020 import java.util.Map;
0021 import java.util.Properties;
0022
0023 import com.google.common.collect.ImmutableMap;
0024 import org.junit.Test;
0025 import static org.junit.Assert.*;
0026
0027 public class CryptoUtilsSuite {
0028
0029 @Test
0030 public void testConfConversion() {
0031 String prefix = "my.prefix.commons.config.";
0032
0033 String confKey1 = prefix + "a.b.c";
0034 String confVal1 = "val1";
0035 String cryptoKey1 = CryptoUtils.COMMONS_CRYPTO_CONFIG_PREFIX + "a.b.c";
0036
0037 String confKey2 = prefix.substring(0, prefix.length() - 1) + "A.b.c";
0038 String confVal2 = "val2";
0039 String cryptoKey2 = CryptoUtils.COMMONS_CRYPTO_CONFIG_PREFIX + "A.b.c";
0040
0041 Map<String, String> conf = ImmutableMap.of(
0042 confKey1, confVal1,
0043 confKey2, confVal2);
0044
0045 Properties cryptoConf = CryptoUtils.toCryptoConf(prefix, conf.entrySet());
0046
0047 assertEquals(confVal1, cryptoConf.getProperty(cryptoKey1));
0048 assertFalse(cryptoConf.containsKey(cryptoKey2));
0049 }
0050
0051 }