ISPN-15069 More flexible SNI from the client

* Per-cluster SNI
* Implict SNI if not set
* Also add a method to return current cluster
* JMX equivalent of above
* Add TLS hostname validation

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCacheContainer.java

@@ -152,6 +152,13 @@ <K, V> RemoteCache<K, V> getCache(String cacheName, boolean forceReturnValue, Tr
     */
    boolean switchToDefaultCluster();
 
+   /**
+    * Returns the name of the currently active cluster.
+    *
+    * @return the name of the active cluster
+    */
+   String getCurrentClusterName();
+
    Marshaller getMarshaller();
 
    /**

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCacheManager.java

@@ -469,6 +469,11 @@ public boolean switchToDefaultCluster() {
       return channelFactory.manualSwitchToCluster(ChannelFactory.DEFAULT_CLUSTER_NAME);
    }
 
+   @Override
+   public String getCurrentClusterName() {
+      return channelFactory.getCurrentClusterName();
+   }
+
    private Properties loadFromStream(InputStream stream) {
       Properties properties = new Properties();
       try {

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/configuration/ClusterConfiguration.java

@@ -11,11 +11,13 @@ public class ClusterConfiguration {
    private final List<ServerConfiguration> serverCluster;
    private final String clusterName;
    private final ClientIntelligence intelligence;
+   private final String sniHostName;
 
-   public ClusterConfiguration(List<ServerConfiguration> serverCluster, String clusterName, ClientIntelligence intelligence) {
+   public ClusterConfiguration(List<ServerConfiguration> serverCluster, String clusterName, ClientIntelligence intelligence, String sniHostName) {
       this.serverCluster = serverCluster;
       this.clusterName = clusterName;
       this.intelligence = intelligence;
+      this.sniHostName = sniHostName;
    }
 
    public List<ServerConfiguration> getCluster() {
@@ -30,12 +32,17 @@ public ClientIntelligence getClientIntelligence() {
       return intelligence;
    }
 
+   public String sniHostName() {
+      return sniHostName;
+   }
+
    @Override
    public String toString() {
       return "ClusterConfiguration{" +
             "serverCluster=" + Util.toStr(serverCluster) +
             ", clusterName='" + clusterName + '\'' +
             ", intelligence=" + intelligence +
+            ", sniHostName=" + sniHostName +
             '}';
    }
 }

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/configuration/ClusterConfigurationBuilder.java

@@ -18,6 +18,7 @@ public class ClusterConfigurationBuilder extends AbstractConfigurationChildBuild
    private final List<ServerConfigurationBuilder> servers = new ArrayList<>();
    private final String clusterName;
    private ClientIntelligence intelligence;
+   private String sniHostName;
 
    protected ClusterConfigurationBuilder(ConfigurationBuilder builder, String clusterName) {
       super(builder);
@@ -53,6 +54,11 @@ public ClusterConfigurationBuilder clusterClientIntelligence(ClientIntelligence
       return this;
    }
 
+   public ClusterConfigurationBuilder clusterSniHostName(String clusterSniHostName) {
+      this.sniHostName = clusterSniHostName;
+      return this;
+   }
+
    @Override
    public void validate() {
       if (clusterName == null || clusterName.isEmpty()) {
@@ -70,7 +76,7 @@ public void validate() {
    public ClusterConfiguration create() {
       List<ServerConfiguration> serverCluster = servers.stream()
          .map(ServerConfigurationBuilder::create).collect(Collectors.toList());
-      return new ClusterConfiguration(serverCluster, clusterName, intelligence);
+      return new ClusterConfiguration(serverCluster, clusterName, intelligence, sniHostName);
    }
 
    @Override

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/configuration/SslConfiguration.java

@@ -26,10 +26,12 @@ public class SslConfiguration {
    private final String protocol;
    private final Collection<String> ciphers;
    private final String provider;
+   private final boolean hostnameValidation;
 
    SslConfiguration(boolean enabled, String keyStoreFileName, String keyStoreType, char[] keyStorePassword, char[] keyStoreCertificatePassword, String keyAlias,
                     SSLContext sslContext,
-                    String trustStoreFileName, String trustStorePath, String trustStoreType, char[] trustStorePassword, String sniHostName, String provider, String protocol, Collection<String> ciphers) {
+                    String trustStoreFileName, String trustStorePath, String trustStoreType, char[] trustStorePassword, String sniHostName, String provider, String protocol, Collection<String> ciphers,
+                    boolean hostnameValidation) {
       this.enabled = enabled;
       this.keyStoreFileName = keyStoreFileName;
       this.keyStoreType = keyStoreType;
@@ -45,6 +47,7 @@ public class SslConfiguration {
       this.provider = provider;
       this.protocol = protocol;
       this.ciphers = ciphers;
+      this.hostnameValidation = hostnameValidation;
    }
 
    public boolean enabled() {
@@ -107,6 +110,10 @@ public String provider() {
       return provider;
    }
 
+   public boolean hostnameValidation() {
+      return hostnameValidation;
+   }
+
    @Override
    public String toString() {
       return "SslConfiguration{" +
@@ -121,6 +128,7 @@ public String toString() {
             ", provider='" + provider +'\'' +
             ", protocol='" + protocol + '\'' +
             ", ciphers='" + ciphers  + '\'' +
+            ", hostnameValidation=" + hostnameValidation +
             '}';
    }
 }

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/configuration/SslConfigurationBuilder.java

@@ -39,6 +39,7 @@ public class SslConfigurationBuilder extends AbstractSecurityConfigurationChildB
    private String protocol;
    private Collection<String> ciphers;
    private String provider;
+   private boolean hostnameValidation = true;
 
    protected SslConfigurationBuilder(SecurityConfigurationBuilder builder) {
       super(builder);
@@ -223,6 +224,17 @@ public SslConfigurationBuilder ciphers(String... ciphers) {
       return enable();
    }
 
+   /**
+    * Configures whether to enable hostname validation according to <a href="https://datatracker.ietf.org/doc/html/rfc2818">RFC 2818</a>.
+    * This is enabled by default and requires that the server certificate includes a subjectAltName extension of type dNSName or iPAddress.
+    *
+    * @param hostnameValidation whether to enable hostname validation
+    */
+   public SslConfigurationBuilder hostnameValidation(boolean hostnameValidation) {
+      this.hostnameValidation = hostnameValidation;
+      return enable();
+   }
+
    @Override
    public void validate() {
       if (enabled) {
@@ -244,6 +256,9 @@ public void validate() {
                throw HOTROD.xorSSLContext();
             }
          }
+         if (hostnameValidation && sniHostName == null) {
+            throw HOTROD.missingSniHostName();
+         }
       }
    }
 
@@ -253,7 +268,7 @@ public SslConfiguration create() {
             keyStoreFileName, keyStoreType, keyStorePassword, keyStoreCertificatePassword, keyAlias,
             sslContext,
             trustStoreFileName, trustStorePath, trustStoreType, trustStorePassword,
-            sniHostName, provider, protocol, ciphers);
+            sniHostName, provider, protocol, ciphers, hostnameValidation);
    }
 
    @Override
@@ -273,6 +288,7 @@ public SslConfigurationBuilder read(SslConfiguration template, Combine combine)
       this.provider = template.provider();
       this.protocol = template.protocol();
       this.ciphers = template.ciphers() != null ? new ArrayList<>(template.ciphers()) : null;
+      this.hostnameValidation = template.hostnameValidation();
       return this;
    }
 
@@ -326,6 +342,9 @@ public ConfigurationBuilder withProperties(Properties properties) {
       if (typed.containsKey(ConfigurationProperties.USE_SSL))
          this.enabled(typed.getBooleanProperty(ConfigurationProperties.USE_SSL, enabled, true));
 
+      if (typed.containsKey(ConfigurationProperties.SSL_HOSTNAME_VALIDATION))
+         this.hostnameValidation(typed.getBooleanProperty(ConfigurationProperties.SSL_HOSTNAME_VALIDATION, hostnameValidation, true));
+
       return builder.getBuilder();
    }
 }

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/configuration/package-info.java

@@ -305,6 +305,12 @@
  *          For details about cipher lists and possible values, refer to OpenSSL documentation at <a href="https://www.openssl.org/docs/man1.1.1/man1/ciphers">https://www.openssl.org/docs/man1.1.1/man1/ciphers</a></td>
  *       </tr>
  *       <tr>
+ *          <td><b>infinispan.client.hotrod.ssl_hostname_validation</b></td>
+ *          <td>boolean</td>
+ *          <td>true</td>
+ *          <td>Whether to enable TLS hostname validation using the rules defined in RFC 2818.</td>
+ *       </tr>
+ *       <tr>
  *          <td><b>infinispan.client.hotrod.ssl_protocol</b></td>
  *          <td>String</td>
  *          <td>N/A</td>

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/ConfigurationProperties.java

@@ -69,6 +69,7 @@ public class ConfigurationProperties {
    public static final String SSL_PROTOCOL = ICH + "ssl_protocol";
    public static final String SSL_CIPHERS = ICH + "ssl_ciphers";
    public static final String SSL_CONTEXT = ICH + "ssl_context";
+   public static final String SSL_HOSTNAME_VALIDATION = ICH + "ssl_hostname_validation";
    public static final String MAX_RETRIES = ICH + "max_retries";
    // Authentication properties
    public static final String USE_AUTH = ICH + "use_auth";

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/topology/ClusterInfo.java

@@ -21,20 +21,22 @@ public class ClusterInfo {
    // updates won't be allowed to apply since they refer to older views.
    private final int topologyAge;
    private final ClientIntelligence intelligence;
+   private final String sniHostName;
 
-   public ClusterInfo(String clusterName, List<InetSocketAddress> servers, ClientIntelligence intelligence) {
-      this(clusterName, servers, -1, intelligence);
+   public ClusterInfo(String clusterName, List<InetSocketAddress> servers, ClientIntelligence intelligence, String sniHostName) {
+      this(clusterName, servers, -1, intelligence, sniHostName);
    }
 
-   private ClusterInfo(String clusterName, List<InetSocketAddress> servers, int topologyAge, ClientIntelligence intelligence) {
+   private ClusterInfo(String clusterName, List<InetSocketAddress> servers, int topologyAge, ClientIntelligence intelligence, String sniHostName) {
       this.clusterName = clusterName;
       this.servers = Immutables.immutableListCopy(servers);
       this.topologyAge = topologyAge;
       this.intelligence = Objects.requireNonNull(intelligence);
+      this.sniHostName = sniHostName;
    }
 
    public ClusterInfo withTopologyAge(int topologyAge) {
-      return new ClusterInfo(clusterName, servers, topologyAge, intelligence);
+      return new ClusterInfo(clusterName, servers, topologyAge, intelligence, sniHostName);
    }
 
    public String getName() {
@@ -53,13 +55,18 @@ public ClientIntelligence getIntelligence() {
       return intelligence;
    }
 
+   public String getSniHostName() {
+      return sniHostName;
+   }
+
    @Override
    public String toString() {
       return "ClusterInfo{" +
             "name='" + clusterName + '\'' +
             ", servers=" + servers +
             ", age=" + topologyAge +
             ", intelligence=" + intelligence +
+            ", sniHostname=" + sniHostName +
             '}';
    }
 }

client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/ChannelFactory.java

@@ -102,6 +102,7 @@ public class ChannelFactory {
    @GuardedBy("lock")
    private final Set<SocketAddress> failedServers = new HashSet<>();
    private final CodecHolder codecHolder;
+   private AddressResolverGroup<?> dnsResolver;
 
    public ChannelFactory(CodecHolder codecHolder) {
       this.codecHolder = codecHolder;
@@ -123,12 +124,17 @@ public void start(Configuration configuration, Marshaller marshaller, ExecutorSe
          // Note that each event loop opens a selector which counts
          int maxExecutors = Math.min(asyncThreads, eventLoopThreads);
          this.eventLoopGroup = configuration.transportFactory().createEventLoopGroup(maxExecutors, executorService);
+         DnsNameResolverBuilder builder = new DnsNameResolverBuilder()
+               .channelType(configuration.transportFactory().datagramChannelClass())
+               .ttl(configuration.dnsResolverMinTTL(), configuration.dnsResolverMaxTTL())
+               .negativeTtl(configuration.dnsResolverNegativeTTL());
+         this.dnsResolver = new RoundRobinDnsAddressResolverGroup(builder);
 
          List<InetSocketAddress> initialServers = new ArrayList<>();
          for (ServerConfiguration server : configuration.servers()) {
             initialServers.add(InetSocketAddress.createUnresolved(server.host(), server.port()));
          }
-         ClusterInfo mainCluster = new ClusterInfo(DEFAULT_CLUSTER_NAME, initialServers, configuration.clientIntelligence());
+         ClusterInfo mainCluster = new ClusterInfo(DEFAULT_CLUSTER_NAME, initialServers, configuration.clientIntelligence(), configuration.security().ssl().sniHostName());
          List<ClusterInfo> clustersDefinitions = new ArrayList<>();
          if (log.isDebugEnabled()) {
             log.debugf("Statically configured servers: %s", initialServers);
@@ -145,8 +151,10 @@ public void start(Configuration configuration, Marshaller marshaller, ExecutorSe
                ClientIntelligence intelligence = clusterConfiguration.getClientIntelligence() != null ?
                      clusterConfiguration.getClientIntelligence() :
                      configuration.clientIntelligence();
+
+               String sniHostName = clusterConfiguration.sniHostName() != null ? clusterConfiguration.sniHostName() : configuration.security().ssl().sniHostName();
                ClusterInfo alternateCluster =
-                     new ClusterInfo(clusterConfiguration.getClusterName(), alternateServers, intelligence);
+                     new ClusterInfo(clusterConfiguration.getClusterName(), alternateServers, intelligence, sniHostName);
                log.debugf("Add secondary cluster: %s", alternateCluster);
                clustersDefinitions.add(alternateCluster);
             }
@@ -187,12 +195,7 @@ public MarshallerRegistry getMarshallerRegistry() {
    }
 
    private ChannelPool newPool(SocketAddress address) {
-      log.debugf("Creating new channel pool for %s", address);
-      DnsNameResolverBuilder builder = new DnsNameResolverBuilder()
-            .channelType(configuration.transportFactory().datagramChannelClass())
-            .ttl(configuration.dnsResolverMinTTL(), configuration.dnsResolverMaxTTL())
-            .negativeTtl(configuration.dnsResolverNegativeTTL());
-      AddressResolverGroup<?> dnsResolver = new RoundRobinDnsAddressResolverGroup(builder);
+            log.debugf("Creating new channel pool for %s", address);
       Bootstrap bootstrap = new Bootstrap()
             .group(eventLoopGroup)
             .channel(configuration.transportFactory().socketChannelClass())
@@ -210,7 +213,7 @@ private ChannelPool newPool(SocketAddress address) {
    }
 
    public ChannelInitializer createChannelInitializer(SocketAddress address, Bootstrap bootstrap) {
-      return new ChannelInitializer(bootstrap, address, operationsFactory, configuration, this);
+      return new ChannelInitializer(bootstrap, address, operationsFactory, configuration, this, topologyInfo.getCluster());
    }
 
    protected ChannelPool createChannelPool(Bootstrap bootstrap, ChannelInitializer channelInitializer, SocketAddress address) {