| 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 | 
 */  | 
 | 
 | 
 | 
package sun.security.ssl;  | 
 | 
 | 
 | 
import java.security.PrivateKey;  | 
 | 
import java.security.PublicKey;  | 
 | 
import java.security.cert.X509Certificate;  | 
 | 
import java.security.interfaces.ECKey;  | 
 | 
import java.security.interfaces.ECPublicKey;  | 
 | 
import java.security.spec.ECParameterSpec;  | 
 | 
import java.util.AbstractMap.SimpleImmutableEntry;  | 
 | 
import java.util.Map;  | 
 | 
import javax.net.ssl.SSLEngine;  | 
 | 
import javax.net.ssl.SSLSocket;  | 
 | 
import javax.net.ssl.X509ExtendedKeyManager;  | 
 | 
import sun.security.ssl.SupportedGroupsExtension.NamedGroup;  | 
 | 
import sun.security.ssl.SupportedGroupsExtension.SupportedGroups;  | 
 | 
 | 
 | 
enum X509Authentication implements SSLAuthentication { | 
 | 
      | 
 | 
    RSA         ("RSA",         new X509PossessionGenerator( | 
 | 
                                    new String[]{"RSA"})), | 
 | 
 | 
 | 
      | 
 | 
    RSASSA_PSS  ("RSASSA-PSS",  new X509PossessionGenerator( | 
 | 
                                    new String[] {"RSASSA-PSS"})), | 
 | 
 | 
 | 
    // Require rsaEncryption or RSASSA-PSS public key  | 
 | 
    //  | 
 | 
    // Note that this is a specifical scheme for TLS 1.2. (EC)DHE_RSA cipher  | 
 | 
    // suites of TLS 1.2 can use either rsaEncryption or RSASSA-PSS public  | 
 | 
      | 
 | 
    RSA_OR_PSS  ("RSA_OR_PSS",  new X509PossessionGenerator( | 
 | 
                                    new String[] {"RSA", "RSASSA-PSS"})), | 
 | 
 | 
 | 
      | 
 | 
    DSA         ("DSA",         new X509PossessionGenerator( | 
 | 
                                    new String[] {"DSA"})), | 
 | 
 | 
 | 
      | 
 | 
    EC          ("EC",          new X509PossessionGenerator( | 
 | 
                                    new String[] {"EC"})); | 
 | 
 | 
 | 
    final String keyType;  | 
 | 
    final SSLPossessionGenerator possessionGenerator;  | 
 | 
 | 
 | 
    private X509Authentication(String keyType,  | 
 | 
            SSLPossessionGenerator possessionGenerator) { | 
 | 
        this.keyType = keyType;  | 
 | 
        this.possessionGenerator = possessionGenerator;  | 
 | 
    }  | 
 | 
 | 
 | 
    static X509Authentication valueOf(SignatureScheme signatureScheme) { | 
 | 
        for (X509Authentication au : X509Authentication.values()) { | 
 | 
            if (au.keyType.equals(signatureScheme.keyAlgorithm)) { | 
 | 
                return au;  | 
 | 
            }  | 
 | 
        }  | 
 | 
 | 
 | 
        return null;  | 
 | 
    }  | 
 | 
 | 
 | 
    @Override  | 
 | 
    public SSLPossession createPossession(HandshakeContext handshakeContext) { | 
 | 
        return possessionGenerator.createPossession(handshakeContext);  | 
 | 
    }  | 
 | 
 | 
 | 
    @Override  | 
 | 
    public SSLHandshake[] getRelatedHandshakers(  | 
 | 
            HandshakeContext handshakeContext) { | 
 | 
        if (!handshakeContext.negotiatedProtocol.useTLS13PlusSpec()) { | 
 | 
            return new SSLHandshake[] { | 
 | 
                    SSLHandshake.CERTIFICATE,  | 
 | 
                    SSLHandshake.CERTIFICATE_REQUEST  | 
 | 
                };  | 
 | 
        }   // Otherwise, TLS 1.3 does not use this method.  | 
 | 
 | 
 | 
        return new SSLHandshake[0];  | 
 | 
    }  | 
 | 
 | 
 | 
    @SuppressWarnings({"unchecked", "rawtypes"}) | 
 | 
    @Override  | 
 | 
    public Map.Entry<Byte, HandshakeProducer>[] getHandshakeProducers(  | 
 | 
            HandshakeContext handshakeContext) { | 
 | 
        if (!handshakeContext.negotiatedProtocol.useTLS13PlusSpec()) { | 
 | 
            return (Map.Entry<Byte, HandshakeProducer>[])(new Map.Entry[] { | 
 | 
                    new SimpleImmutableEntry<Byte, HandshakeProducer>(  | 
 | 
                        SSLHandshake.CERTIFICATE.id,  | 
 | 
                        SSLHandshake.CERTIFICATE  | 
 | 
                    )  | 
 | 
                });  | 
 | 
        }   // Otherwise, TLS 1.3 does not use this method.  | 
 | 
 | 
 | 
        return (Map.Entry<Byte, HandshakeProducer>[])(new Map.Entry[0]);  | 
 | 
    }  | 
 | 
 | 
 | 
    static final class X509Possession implements SSLPossession { | 
 | 
        // Proof of possession of the private key corresponding to the public  | 
 | 
          | 
 | 
        final X509Certificate[]   popCerts;  | 
 | 
        final PrivateKey          popPrivateKey;  | 
 | 
 | 
 | 
        X509Possession(PrivateKey popPrivateKey,  | 
 | 
                X509Certificate[] popCerts) { | 
 | 
            this.popCerts = popCerts;  | 
 | 
            this.popPrivateKey = popPrivateKey;  | 
 | 
        }  | 
 | 
 | 
 | 
        ECParameterSpec getECParameterSpec() { | 
 | 
            if (popPrivateKey == null ||  | 
 | 
                    !"EC".equals(popPrivateKey.getAlgorithm())) { | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            if (popPrivateKey instanceof ECKey) { | 
 | 
                return ((ECKey)popPrivateKey).getParams();  | 
 | 
            } else if (popCerts != null && popCerts.length != 0) { | 
 | 
                // The private key not extractable, get the parameters from  | 
 | 
                  | 
 | 
                PublicKey publicKey = popCerts[0].getPublicKey();  | 
 | 
                if (publicKey instanceof ECKey) { | 
 | 
                    return ((ECKey)publicKey).getParams();  | 
 | 
                }  | 
 | 
            }  | 
 | 
 | 
 | 
            return null;  | 
 | 
        }  | 
 | 
    }  | 
 | 
 | 
 | 
    static final class X509Credentials implements SSLCredentials { | 
 | 
        final X509Certificate[]   popCerts;  | 
 | 
        final PublicKey           popPublicKey;  | 
 | 
 | 
 | 
        X509Credentials(PublicKey popPublicKey, X509Certificate[] popCerts) { | 
 | 
            this.popCerts = popCerts;  | 
 | 
            this.popPublicKey = popPublicKey;  | 
 | 
        }  | 
 | 
    }  | 
 | 
 | 
 | 
    private static final  | 
 | 
            class X509PossessionGenerator implements SSLPossessionGenerator { | 
 | 
        private final String[] keyTypes;  | 
 | 
 | 
 | 
        private X509PossessionGenerator(String[] keyTypes) { | 
 | 
            this.keyTypes = keyTypes;  | 
 | 
        }  | 
 | 
 | 
 | 
        @Override  | 
 | 
        public SSLPossession createPossession(HandshakeContext context) { | 
 | 
            if (context.sslConfig.isClientMode) { | 
 | 
                for (String keyType : keyTypes) { | 
 | 
                    SSLPossession poss = createClientPossession(  | 
 | 
                            (ClientHandshakeContext)context, keyType);  | 
 | 
                    if (poss != null) { | 
 | 
                        return poss;  | 
 | 
                    }  | 
 | 
                }  | 
 | 
            } else { | 
 | 
                for (String keyType : keyTypes) { | 
 | 
                    SSLPossession poss = createServerPossession(  | 
 | 
                            (ServerHandshakeContext)context, keyType);  | 
 | 
                    if (poss != null) { | 
 | 
                        return poss;  | 
 | 
                    }  | 
 | 
                }  | 
 | 
            }  | 
 | 
 | 
 | 
            return null;  | 
 | 
        }  | 
 | 
 | 
 | 
          | 
 | 
        private SSLPossession createClientPossession(  | 
 | 
                ClientHandshakeContext chc, String keyType) { | 
 | 
            X509ExtendedKeyManager km = chc.sslContext.getX509KeyManager();  | 
 | 
            String clientAlias = null;  | 
 | 
            if (chc.conContext.transport instanceof SSLSocketImpl) { | 
 | 
                clientAlias = km.chooseClientAlias(  | 
 | 
                        new String[] { keyType }, | 
 | 
                        chc.peerSupportedAuthorities,  | 
 | 
                        (SSLSocket)chc.conContext.transport);  | 
 | 
            } else if (chc.conContext.transport instanceof SSLEngineImpl) { | 
 | 
                clientAlias = km.chooseEngineClientAlias(  | 
 | 
                        new String[] { keyType }, | 
 | 
                        chc.peerSupportedAuthorities,  | 
 | 
                        (SSLEngine)chc.conContext.transport);  | 
 | 
            }  | 
 | 
 | 
 | 
            if (clientAlias == null) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.finest("No X.509 cert selected for " + keyType); | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            PrivateKey clientPrivateKey = km.getPrivateKey(clientAlias);  | 
 | 
            if (clientPrivateKey == null) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.finest(  | 
 | 
                            clientAlias + " is not a private key entry");  | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            X509Certificate[] clientCerts = km.getCertificateChain(clientAlias);  | 
 | 
            if ((clientCerts == null) || (clientCerts.length == 0)) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.finest(clientAlias +  | 
 | 
                        " is a private key entry with no cert chain stored");  | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            PublicKey clientPublicKey = clientCerts[0].getPublicKey();  | 
 | 
            if ((!clientPrivateKey.getAlgorithm().equals(keyType))  | 
 | 
                    || (!clientPublicKey.getAlgorithm().equals(keyType))) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.fine(  | 
 | 
                            clientAlias + " private or public key is not of " +  | 
 | 
                            keyType + " algorithm");  | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            return new X509Possession(clientPrivateKey, clientCerts);  | 
 | 
        }  | 
 | 
 | 
 | 
        private SSLPossession createServerPossession(  | 
 | 
                ServerHandshakeContext shc, String keyType) { | 
 | 
            X509ExtendedKeyManager km = shc.sslContext.getX509KeyManager();  | 
 | 
            String serverAlias = null;  | 
 | 
            if (shc.conContext.transport instanceof SSLSocketImpl) { | 
 | 
                serverAlias = km.chooseServerAlias(keyType,  | 
 | 
                        null, (SSLSocket)shc.conContext.transport);  | 
 | 
            } else if (shc.conContext.transport instanceof SSLEngineImpl) { | 
 | 
                serverAlias = km.chooseEngineServerAlias(keyType,  | 
 | 
                        null, (SSLEngine)shc.conContext.transport);  | 
 | 
            }  | 
 | 
 | 
 | 
            if (serverAlias == null) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.finest("No X.509 cert selected for " + keyType); | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            PrivateKey serverPrivateKey = km.getPrivateKey(serverAlias);  | 
 | 
            if (serverPrivateKey == null) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.finest(  | 
 | 
                            serverAlias + " is not a private key entry");  | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            X509Certificate[] serverCerts = km.getCertificateChain(serverAlias);  | 
 | 
            if ((serverCerts == null) || (serverCerts.length == 0)) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.finest(  | 
 | 
                            serverAlias + " is not a certificate entry");  | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            PublicKey serverPublicKey = serverCerts[0].getPublicKey();  | 
 | 
            if ((!serverPrivateKey.getAlgorithm().equals(keyType))  | 
 | 
                    || (!serverPublicKey.getAlgorithm().equals(keyType))) { | 
 | 
                if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                    SSLLogger.fine(  | 
 | 
                            serverAlias + " private or public key is not of " +  | 
 | 
                            keyType + " algorithm");  | 
 | 
                }  | 
 | 
                return null;  | 
 | 
            }  | 
 | 
 | 
 | 
            // For TLS 1.2 and prior versions, the public key of a EC cert  | 
 | 
            // MUST use a curve and point format supported by the client.  | 
 | 
            // But for TLS 1.3, signature algorithms are negotiated  | 
 | 
              | 
 | 
            if (!shc.negotiatedProtocol.useTLS13PlusSpec() &&  | 
 | 
                    keyType.equals("EC")) { | 
 | 
                if (!(serverPublicKey instanceof ECPublicKey)) { | 
 | 
                    if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                        SSLLogger.warning(serverAlias +  | 
 | 
                            " public key is not an instance of ECPublicKey");  | 
 | 
                    }  | 
 | 
                    return null;  | 
 | 
                }  | 
 | 
 | 
 | 
                // For ECC certs, check whether we support the EC domain  | 
 | 
                // parameters.  If the client sent a supported_groups  | 
 | 
                // ClientHello extension, check against that too for  | 
 | 
                  | 
 | 
                ECParameterSpec params =  | 
 | 
                        ((ECPublicKey)serverPublicKey).getParams();  | 
 | 
                NamedGroup namedGroup = NamedGroup.valueOf(params);  | 
 | 
                if ((namedGroup == null) ||  | 
 | 
                        (!SupportedGroups.isSupported(namedGroup)) ||  | 
 | 
                        ((shc.clientRequestedNamedGroups != null) &&  | 
 | 
                        !shc.clientRequestedNamedGroups.contains(namedGroup))) { | 
 | 
 | 
 | 
                    if (SSLLogger.isOn && SSLLogger.isOn("ssl")) { | 
 | 
                        SSLLogger.warning(  | 
 | 
                            "Unsupported named group (" + namedGroup + | 
 | 
                            ") used in the " + serverAlias + " certificate");  | 
 | 
                    }  | 
 | 
 | 
 | 
                    return null;  | 
 | 
                }  | 
 | 
            }  | 
 | 
 | 
 | 
            return new X509Possession(serverPrivateKey, serverCerts);  | 
 | 
        }  | 
 | 
    }  | 
 | 
}  |