/*
* Copyright (C) 2007 The Android Open Source Project
*
* Licensed 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 tests.api.javax.net.ssl;
import dalvik.annotation.AndroidOnly;
import dalvik.annotation.TestTargetClass;
import dalvik.annotation.TestTargets;
import dalvik.annotation.TestLevel;
import dalvik.annotation.TestTargetNew;
import javax.net.ssl.*;
import javax.security.cert.X509Certificate;
import java.net.*;
import java.security.KeyStore;
import java.lang.String;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import junit.framework.TestCase;
import org.apache.harmony.luni.util.Base64;
import tests.api.javax.net.ssl.HandshakeCompletedEventTest.TestTrustManager;
import tests.support.Support_PortManager;
@TestTargetClass(SSLSocket.class)
public class SSLSocketTest extends TestCase {
public class HandshakeCL implements HandshakeCompletedListener {
HandshakeCL() {
super();
}
public void handshakeCompleted(HandshakeCompletedEvent event) {
}
}
/**
* @tests javax.net.ssl.SSLSocket#SSLSocket()
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "SSLSocket",
args = {}
)
public void testConstructor_01() {
try {
SSLSocket ssl = getSSLSocket();
} catch (Exception e) {
fail("Unexpected exception " + e);
}
}
/**
* @throws IOException
* @throws UnknownHostException
* @tests javax.net.ssl.SSLSocket#SSLSocket(InetAddress address, int port)
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "SSLSocket",
args = {java.net.InetAddress.class, int.class}
)
public void testConstructor_02() throws UnknownHostException, IOException {
SSLSocket ssl;
int sport = startServer("Cons InetAddress,I");
int[] invalidPort = {-1, Integer.MIN_VALUE, 65536, Integer.MAX_VALUE};
ssl = getSSLSocket(InetAddress.getLocalHost(), sport);
assertNotNull(ssl);
assertEquals(sport, ssl.getPort());
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), sport + 1);
fail("IOException wasn't thrown ...");
} catch (IOException e) {
//expected
}
for (int i = 0; i < invalidPort.length; i++) {
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), invalidPort[i]);
fail("IllegalArgumentException wasn't thrown for " + invalidPort[i]);
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for " + invalidPort[i]);
}
}
}
/**
* @throws IOException
* @throws UnknownHostException
* @tests javax.net.ssl.SSLSocket#SSLSocket(InetAddress address, int port,
* InetAddress clientAddress, int clientPort)
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "SSLSocket",
args = {java.net.InetAddress.class, int.class, java.net.InetAddress.class, int.class}
)
public void testConstructor_03() throws UnknownHostException, IOException {
SSLSocket ssl;
int sport = startServer("Cons InetAddress,I,InetAddress,I");
int portNumber = Support_PortManager.getNextPort();
ssl = getSSLSocket(InetAddress.getLocalHost(), sport,
InetAddress.getLocalHost(), portNumber);
assertNotNull(ssl);
assertEquals(sport, ssl.getPort());
assertEquals(portNumber, ssl.getLocalPort());
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), 8081, InetAddress.getLocalHost(), 8082);
fail("IOException wasn't thrown ...");
} catch (IOException e) {
//expected
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), -1,
InetAddress.getLocalHost(), sport + 1);
fail("IllegalArgumentException wasn't thrown for -1");
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for -1");
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), sport,
InetAddress.getLocalHost(), -1);
fail("IllegalArgumentException wasn't thrown for -1");
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for -1");
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), Integer.MIN_VALUE,
InetAddress.getLocalHost(), sport + 1);
fail("IOException wasn't thrown for " + Integer.MIN_VALUE);
} catch (IOException ioe) {
// expected on RI
} catch (IllegalArgumentException iae) {
// expected on Android
} catch (Exception e) {
fail(e + " was thrown instead of IOException for "
+ Integer.MIN_VALUE);
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), sport,
InetAddress.getLocalHost(), Integer.MIN_VALUE);
fail("IllegalArgumentException wasn't thrown for "
+ Integer.MIN_VALUE);
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for "
+ Integer.MIN_VALUE);
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), 65536,
InetAddress.getLocalHost(), sport + 1);
fail("IOException wasn't thrown for 65536");
} catch (IOException ioe) {
// expected on RI
} catch (IllegalArgumentException iae) {
// expected on Android
} catch (Exception e) {
fail(e + " was thrown instead of IOException for 65536");
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), sport,
InetAddress.getLocalHost(), 65536);
fail("IllegalArgumentException wasn't thrown for 65536");
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for 65536");
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), Integer.MAX_VALUE,
InetAddress.getLocalHost(), sport + 1);
fail("IOException wasn't thrown for " + Integer.MAX_VALUE);
} catch (IOException ioe) {
// expected on RI
} catch (IllegalArgumentException iae) {
// expected on Android
} catch (Exception e) {
fail(e + " was thrown instead of IOException for "
+ Integer.MAX_VALUE);
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost(), sport,
InetAddress.getLocalHost(), Integer.MAX_VALUE);
fail("IllegalArgumentException wasn't thrown for "
+ Integer.MAX_VALUE);
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for "
+ Integer.MAX_VALUE);
}
}
/**
* @throws IOException
* @throws UnknownHostException
* @tests javax.net.ssl.SSLSocket#SSLSocket(String host, int port)
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "SSLSocket",
args = {java.lang.String.class, int.class}
)
public void testConstructor_04() throws UnknownHostException, IOException {
SSLSocket ssl;
int sport = startServer("Cons String,I");
int[] invalidPort = {-1, Integer.MIN_VALUE, 65536, Integer.MAX_VALUE};
ssl = getSSLSocket(InetAddress.getLocalHost().getHostName(), sport);
assertNotNull(ssl);
assertEquals(sport, ssl.getPort());
try {
ssl = getSSLSocket("localhost", 8082);
fail("IOException wasn't thrown ...");
} catch (IOException e) {
//expected
}
for (int i = 0; i < invalidPort.length; i++) {
try {
ssl = getSSLSocket(InetAddress.getLocalHost().getHostName(), invalidPort[i]);
fail("IllegalArgumentException wasn't thrown for " + invalidPort[i]);
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for " + invalidPort[i]);
}
}
try {
ssl = getSSLSocket("bla-bla", sport);
fail("UnknownHostException wasn't thrown");
} catch (UnknownHostException uhp) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of UnknownHostException");
}
}
/**
* @throws IOException
* @throws UnknownHostException
* @tests javax.net.ssl.SSLSocket#SSLSocket(String host, int port, InetAddress clientAddress,
* int clientPort)
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "SSLSocket",
args = {java.lang.String.class, int.class, java.net.InetAddress.class, int.class}
)
public void testConstructor_05() throws UnknownHostException, IOException {
SSLSocket ssl;
int sport = startServer("Cons String,I,InetAddress,I");
int portNumber = Support_PortManager.getNextPort();
int[] invalidPort = {-1, Integer.MIN_VALUE, 65536, Integer.MAX_VALUE};
ssl = getSSLSocket(InetAddress.getLocalHost().getHostName(), sport,
InetAddress.getLocalHost(), portNumber);
assertNotNull(ssl);
assertEquals(sport, ssl.getPort());
assertEquals(portNumber, ssl.getLocalPort());
try {
ssl = getSSLSocket("localhost", 8081, InetAddress.getLocalHost(), 8082);
fail("IOException wasn't thrown ...");
} catch (IOException e) {
//expected
}
for (int i = 0; i < invalidPort.length; i++) {
portNumber = Support_PortManager.getNextPort();
try {
ssl = getSSLSocket(InetAddress.getLocalHost().getHostName(), invalidPort[i],
InetAddress.getLocalHost(), portNumber);
fail("IllegalArgumentException wasn't thrown for " + invalidPort[i]);
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for " + invalidPort[i]);
}
try {
ssl = getSSLSocket(InetAddress.getLocalHost().getHostName(), sport,
InetAddress.getLocalHost(), invalidPort[i]);
fail("IllegalArgumentException wasn't thrown for " + invalidPort[i]);
} catch (IllegalArgumentException iae) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException for " + invalidPort[i]);
}
}
portNumber = Support_PortManager.getNextPort();
try {
ssl = getSSLSocket("bla-bla", sport, InetAddress.getLocalHost(), portNumber);
fail("UnknownHostException wasn't thrown");
} catch (UnknownHostException uhp) {
// expected
} catch (Exception e) {
fail(e + " was thrown instead of UnknownHostException");
}
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#addHandshakeCompletedListener(HandshakeCompletedListener listener)
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "addHandshakeCompletedListener",
args = {javax.net.ssl.HandshakeCompletedListener.class}
)
@AndroidOnly("RI doesn't throw the specified IAE")
public void test_addHandshakeCompletedListener() throws IOException {
SSLSocket ssl = getSSLSocket();
HandshakeCompletedListener ls = new HandshakeCL();
try {
ssl.addHandshakeCompletedListener(null);
fail("IllegalArgumentException wasn't thrown");
} catch (IllegalArgumentException iae) {
//expected
}
try {
ssl.addHandshakeCompletedListener(ls);
} catch (Exception e) {
fail("Unexpected exception " + e);
}
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#removeHandshakeCompletedListener(HandshakeCompletedListener listener)
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "removeHandshakeCompletedListener",
args = {javax.net.ssl.HandshakeCompletedListener.class}
)
public void test_removeHandshakeCompletedListener() throws IOException {
SSLSocket ssl = getSSLSocket();
HandshakeCompletedListener ls = new HandshakeCL();
try {
ssl.removeHandshakeCompletedListener(null);
fail("IllegalArgumentException wasn't thrown");
} catch (IllegalArgumentException iae) {
//expected
}
try {
ssl.removeHandshakeCompletedListener(ls);
} catch (IllegalArgumentException iae) {
//expected
} catch (Exception e) {
fail("Unexpected exception " + e);
}
ssl.addHandshakeCompletedListener(ls);
try {
ssl.removeHandshakeCompletedListener(ls);
} catch (Exception e) {
fail("Unexpected exception " + e);
}
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#setEnableSessionCreation(boolean flag)
* @tests javax.net.ssl.SSLSocket#getEnableSessionCreation()
*/
@TestTargets({
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getEnableSessionCreation",
args = {}
),
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "setEnableSessionCreation",
args = {boolean.class}
)
})
public void test_EnableSessionCreation() throws IOException {
SSLSocket ssl = getSSLSocket();
assertTrue(ssl.getEnableSessionCreation());
ssl.setEnableSessionCreation(false);
assertFalse(ssl.getEnableSessionCreation());
ssl.setEnableSessionCreation(true);
assertTrue(ssl.getEnableSessionCreation());
}
/**
* @throws IOException
* @throws UnknownHostException
* @tests javax.net.ssl.SSLSocket#setNeedClientAuth(boolean need)
* @tests javax.net.ssl.SSLSocket#getNeedClientAuthCreation()
*/
@TestTargets({
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "setNeedClientAuth",
args = {boolean.class}
),
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getNeedClientAuth",
args = {}
)
})
public void test_NeedClientAuth() throws UnknownHostException, IOException {
SSLSocket ssl = getSSLSocket();
ssl.setNeedClientAuth(true);
assertTrue(ssl.getNeedClientAuth());
ssl.setNeedClientAuth(false);
assertFalse(ssl.getNeedClientAuth());
}
/**
* @throws IOException
* @throws UnknownHostException
* @tests javax.net.ssl.SSLSocket#setWantClientAuth(boolean want)
* @tests javax.net.ssl.SSLSocket#getWantClientAuthCreation()
*/
@TestTargets({
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "setWantClientAuth",
args = {boolean.class}
),
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getWantClientAuth",
args = {}
)
})
public void test_WantClientAuth() throws UnknownHostException, IOException {
SSLSocket ssl = getSSLSocket();
ssl.setWantClientAuth(true);
assertTrue(ssl.getWantClientAuth());
ssl.setWantClientAuth(false);
assertFalse(ssl.getWantClientAuth());
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#getSupportedProtocols()
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getSupportedProtocols",
args = {}
)
public void test_getSupportedProtocols() throws IOException {
SSLSocket ssl = getSSLSocket();
String[] res = ssl.getSupportedProtocols();
assertTrue("No supported protocols found", res.length > 0);
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#getEnabledProtocols()
* @tests javax.net.ssl.SSLSocket#setEnabledProtocols(String[] protocols)
*/
@TestTargets({
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "setEnabledProtocols",
args = {java.lang.String[].class}
),
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getEnabledProtocols",
args = {}
)
})
public void test_EnabledProtocols() throws IOException {
SSLSocket ssl = getSSLSocket();
try {
ssl.setEnabledProtocols(null);
} catch (IllegalArgumentException iae) {
//expected
}
try {
ssl.setEnabledProtocols(new String[] {});
} catch (IllegalArgumentException iae) {
//expected
}
try {
ssl.setEnabledProtocols(new String[] {"blubb"});
} catch (IllegalArgumentException iae) {
//expected
}
ssl.setEnabledProtocols(ssl.getEnabledProtocols());
String[] res = ssl.getEnabledProtocols();
assertEquals("no enabled protocols set",
ssl.getEnabledProtocols().length, res.length);
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#getSession()
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getSession",
args = {}
)
public void test_getSession() throws IOException {
SSLSocket ssl = getSSLSocket();
try {
assertNotNull(ssl.getSession());
} catch (Exception e) {
fail("Unexpected exception " + e);
}
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#getSupportedCipherSuites()
*/
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getSupportedCipherSuites",
args = {}
)
public void test_getSupportedCipherSuites() throws IOException {
SSLSocket ssl = getSSLSocket();
String[] res = ssl.getSupportedCipherSuites();
assertTrue("no supported cipher suites", res.length > 0);
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#getEnabledCipherSuites()
* @tests javax.net.ssl.SSLSocket#setEnabledCipherSuites(String[] suites)
*/
@TestTargets({
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getEnabledCipherSuites",
args = {}
),
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "setEnabledCipherSuites",
args = {java.lang.String[].class}
)
})
public void test_EnabledCipherSuites() throws IOException {
SSLSocket ssl = getSSLSocket();
try {
ssl.setEnabledCipherSuites(null);
} catch (IllegalArgumentException iae) {
//expected
}
try {
ssl.setEnabledCipherSuites(new String[] {});
} catch (IllegalArgumentException iae) {
//expected
}
try {
ssl.setEnabledCipherSuites(new String[] {"blubb"});
} catch (IllegalArgumentException iae) {
//expected
}
ssl.setEnabledCipherSuites(ssl.getSupportedCipherSuites());
String[] res = ssl.getEnabledCipherSuites();
assertEquals("not all supported cipher suites where enabled",
ssl.getSupportedCipherSuites().length, res.length);
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#getUseClientMode()
* @tests javax.net.ssl.SSLSocket#setUseClientMode(boolean mode)
*/
@TestTargets({
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "getUseClientMode",
args = {}
),
@TestTargetNew(
level = TestLevel.COMPLETE,
notes = "",
method = "setUseClientMode",
args = {boolean.class}
)
})
public void test_UseClientMode() throws IOException {
SSLSocket ssl = getSSLSocket();
assertTrue(ssl.getUseClientMode());
ssl.setUseClientMode(false);
assertFalse(ssl.getUseClientMode());
ssl = getSSLSocket("localhost", startServer("UseClientMode"));
try {
ssl.startHandshake();
} catch (IOException ioe) {
//fail(ioe + " was thrown for method startHandshake()");
}
try {
ssl.setUseClientMode(false);
fail("IllegalArgumentException wasn't thrown");
} catch (IllegalArgumentException iae) {
//expected
} catch (Exception e) {
fail(e + " was thrown instead of IllegalArgumentException");
}
}
/**
* @throws IOException
* @tests javax.net.ssl.SSLSocket#startHandshake()
*/
@TestTargetNew(
level = TestLevel.PARTIAL_COMPLETE,
notes = "",
method = "startHandshake",
args = {}
)
public void test_startHandshake() throws IOException {
SSLSocket ssl = getSSLSocket();
try {
ssl.startHandshake();
fail("IOException wasn't thrown");
} catch (IOException ioe) {
//expected
} catch (Exception e) {
fail(e + " was thrown instead of IOException");
}
}
// Change this to false if on RI
boolean useBKS = true;
private String PASSWORD = "android";
private int port = Support_PortManager.getNextPort();
private boolean serverReady = false;
/**
* Defines the keystore contents for the server, BKS version. Holds just a
* single self-generated key. The subject name is "Test Server".
*/
private static final String SERVER_KEYS_BKS =
"AAAAAQAAABQDkebzoP1XwqyWKRCJEpn/t8dqIQAABDkEAAVteWtleQAAARpYl20nAAAAAQAFWC41" +
"MDkAAAJNMIICSTCCAbKgAwIBAgIESEfU1jANBgkqhkiG9w0BAQUFADBpMQswCQYDVQQGEwJVUzET" +
"MBEGA1UECBMKQ2FsaWZvcm5pYTEMMAoGA1UEBxMDTVRWMQ8wDQYDVQQKEwZHb29nbGUxEDAOBgNV" +
"BAsTB0FuZHJvaWQxFDASBgNVBAMTC1Rlc3QgU2VydmVyMB4XDTA4MDYwNTExNTgxNFoXDTA4MDkw" +
"MzExNTgxNFowaTELMAkGA1UEBhMCVVMxEzARBgNVBAgTCkNhbGlmb3JuaWExDDAKBgNVBAcTA01U" +
"VjEPMA0GA1UEChMGR29vZ2xlMRAwDgYDVQQLEwdBbmRyb2lkMRQwEgYDVQQDEwtUZXN0IFNlcnZl" +
"cjCBnzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEA0LIdKaIr9/vsTq8BZlA3R+NFWRaH4lGsTAQy" +
"DPMF9ZqEDOaL6DJuu0colSBBBQ85hQTPa9m9nyJoN3pEi1hgamqOvQIWcXBk+SOpUGRZZFXwniJV" +
"zDKU5nE9MYgn2B9AoiH3CSuMz6HRqgVaqtppIe1jhukMc/kHVJvlKRNy9XMCAwEAATANBgkqhkiG" +
"9w0BAQUFAAOBgQC7yBmJ9O/eWDGtSH9BH0R3dh2NdST3W9hNZ8hIa8U8klhNHbUCSSktZmZkvbPU" +
"hse5LI3dh6RyNDuqDrbYwcqzKbFJaq/jX9kCoeb3vgbQElMRX8D2ID1vRjxwlALFISrtaN4VpWzV" +
"yeoHPW4xldeZmoVtjn8zXNzQhLuBqX2MmAAAAqwAAAAUvkUScfw9yCSmALruURNmtBai7kQAAAZx" +
"4Jmijxs/l8EBaleaUru6EOPioWkUAEVWCxjM/TxbGHOi2VMsQWqRr/DZ3wsDmtQgw3QTrUK666sR" +
"MBnbqdnyCyvM1J2V1xxLXPUeRBmR2CXorYGF9Dye7NkgVdfA+9g9L/0Au6Ugn+2Cj5leoIgkgApN" +
"vuEcZegFlNOUPVEs3SlBgUF1BY6OBM0UBHTPwGGxFBBcetcuMRbUnu65vyDG0pslT59qpaR0TMVs" +
"P+tcheEzhyjbfM32/vwhnL9dBEgM8qMt0sqF6itNOQU/F4WGkK2Cm2v4CYEyKYw325fEhzTXosck" +
"MhbqmcyLab8EPceWF3dweoUT76+jEZx8lV2dapR+CmczQI43tV9btsd1xiBbBHAKvymm9Ep9bPzM" +
"J0MQi+OtURL9Lxke/70/MRueqbPeUlOaGvANTmXQD2OnW7PISwJ9lpeLfTG0LcqkoqkbtLKQLYHI" +
"rQfV5j0j+wmvmpMxzjN3uvNajLa4zQ8l0Eok9SFaRr2RL0gN8Q2JegfOL4pUiHPsh64WWya2NB7f" +
"V+1s65eA5ospXYsShRjo046QhGTmymwXXzdzuxu8IlnTEont6P4+J+GsWk6cldGbl20hctuUKzyx" +
"OptjEPOKejV60iDCYGmHbCWAzQ8h5MILV82IclzNViZmzAapeeCnexhpXhWTs+xDEYSKEiG/camt" +
"bhmZc3BcyVJrW23PktSfpBQ6D8ZxoMfF0L7V2GQMaUg+3r7ucrx82kpqotjv0xHghNIm95aBr1Qw" +
"1gaEjsC/0wGmmBDg1dTDH+F1p9TInzr3EFuYD0YiQ7YlAHq3cPuyGoLXJ5dXYuSBfhDXJSeddUkl" +
"k1ufZyOOcskeInQge7jzaRfmKg3U94r+spMEvb0AzDQVOKvjjo1ivxMSgFRZaDb/4qw=";
/**
* Defines the keystore contents for the server, JKS version. Holds just a
* single self-generated key. The subject name is "Test Server".
*/
private static final String SERVER_KEYS_JKS =
"/u3+7QAAAAIAAAABAAAAAQAFbXlrZXkAAAEaWFfBeAAAArowggK2MA4GCisGAQQBKgIRAQEFAASC" +
"AqI2kp5XjnF8YZkhcF92YsJNQkvsmH7zqMM87j23zSoV4DwyE3XeC/gZWq1ToScIhoqZkzlbWcu4" +
"T/Zfc/DrfGk/rKbBL1uWKGZ8fMtlZk8KoAhxZk1JSyJvdkyKxqmzUbxk1OFMlN2VJNu97FPVH+du" +
"dvjTvmpdoM81INWBW/1fZJeQeDvn4mMbbe0IxgpiLnI9WSevlaDP/sm1X3iO9yEyzHLL+M5Erspo" +
"Cwa558fOu5DdsICMXhvDQxjWFKFhPHnKtGe+VvwkG9/bAaDgx3kfhk0w5zvdnkKb+8Ed9ylNRzdk" +
"ocAa/mxlMTOsTvDKXjjsBupNPIIj7OP4GNnZaxkJjSs98pEO67op1GX2qhy6FSOPNuq8k/65HzUc" +
"PYn6voEeh6vm02U/sjEnzRevQ2+2wXoAdp0EwtQ/DlMe+NvcwPGWKuMgX4A4L93DZGb04N2VmAU3" +
"YLOtZwTO0LbuWrcCM/q99G/7LcczkxIVrO2I/rh8RXVczlf9QzcrFObFv4ATuspWJ8xG7DhsMbnk" +
"rT94Pq6TogYeoz8o8ZMykesAqN6mt/9+ToIemmXv+e+KU1hI5oLwWMnUG6dXM6hIvrULY6o+QCPH" +
"172YQJMa+68HAeS+itBTAF4Clm/bLn6reHCGGU6vNdwU0lYldpiOj9cB3t+u2UuLo6tiFWjLf5Zs" +
"EQJETd4g/EK9nHxJn0GAKrWnTw7pEHQJ08elzUuy04C/jEEG+4QXU1InzS4o/kR0Sqz2WTGDoSoq" +
"ewuPRU5bzQs/b9daq3mXrnPtRBL6HfSDAdpTK76iHqLCGdqx3avHjVSBm4zFvEuYBCev+3iKOBmg" +
"yh7eQRTjz4UOWfy85omMBr7lK8PtfVBDzOXpasxS0uBgdUyBDX4tO6k9jZ8a1kmQRQAAAAEABVgu" +
"NTA5AAACSDCCAkQwggGtAgRIR8SKMA0GCSqGSIb3DQEBBAUAMGkxCzAJBgNVBAYTAlVTMRMwEQYD" +
"VQQIEwpDYWxpZm9ybmlhMQwwCgYDVQQHEwNNVFYxDzANBgNVBAoTBkdvb2dsZTEQMA4GA1UECxMH" +
"QW5kcm9pZDEUMBIGA1UEAxMLVGVzdCBTZXJ2ZXIwHhcNMDgwNjA1MTA0ODQyWhcNMDgwOTAzMTA0" +
"ODQyWjBpMQswCQYDVQQGEwJVUzETMBEGA1UECBMKQ2FsaWZvcm5pYTEMMAoGA1UEBxMDTVRWMQ8w" +
"DQYDVQQKEwZHb29nbGUxEDAOBgNVBAsTB0FuZHJvaWQxFDASBgNVBAMTC1Rlc3QgU2VydmVyMIGf" +
"MA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCwoC6chqCI84rj1PrXuJgbiit4EV909zR6N0jNlYfg" +
"itwB39bP39wH03rFm8T59b3mbSptnGmCIpLZn25KPPFsYD3JJ+wFlmiUdEP9H05flfwtFQJnw9uT" +
"3rRIdYVMPcQ3RoZzwAMliGr882I2thIDbA6xjGU/1nRIdvk0LtxH3QIDAQABMA0GCSqGSIb3DQEB" +
"BAUAA4GBAJn+6YgUlY18Ie+0+Vt8oEi81DNi/bfPrAUAh63fhhBikx/3R9dl3wh09Z6p7cIdNxjW" +
"n2ll+cRW9eqF7z75F0Omm0C7/KAEPjukVbszmzeU5VqzkpSt0j84YWi+TfcHRrfvhLbrlmGITVpY" +
"ol5pHLDyqGmDs53pgwipWqsn/nEXEBgj3EoqPeqHbDf7YaP8h/5BSt0=";
protected int startServer(String name) {
String keys = useBKS ? SERVER_KEYS_BKS : SERVER_KEYS_JKS;
TestServer server = new TestServer(true, keys);
Thread serverThread = new Thread(server);
serverThread.start();
try {
while (!serverReady) {
Thread.currentThread().sleep(50);
}
// give the server 100 millis to accept
Thread.currentThread().sleep(100);
} catch (InterruptedException e) {
// ignore
}
return server.sport;
}
/**
* Implements a test SSL socket server. It wait for a connection on a given
* port, requests client authentication (if specified), and read 256 bytes
* from the socket.
*/
class TestServer implements Runnable {
public static final int CLIENT_AUTH_NONE = 0;
public static final int CLIENT_AUTH_WANTED = 1;
public static final int CLIENT_AUTH_NEEDED = 2;
private TestTrustManager trustManager;
private Exception exception;
String keys;
private boolean provideKeys;
int sport;
public TestServer(boolean provideKeys, String keys) {
this.keys = keys;
this.provideKeys = provideKeys;
trustManager = new TestTrustManager();
}
public void run() {
try {
KeyManager[] keyManagers = provideKeys ? getKeyManagers(keys) : null;
TrustManager[] trustManagers = new TrustManager[] { trustManager };
SSLContext sslContext = SSLContext.getInstance("TLS");
sslContext.init(keyManagers, trustManagers, null);
SSLServerSocket serverSocket = (SSLServerSocket)sslContext.getServerSocketFactory().createServerSocket();
serverSocket.bind(new InetSocketAddress(port));
sport = serverSocket.getLocalPort();
serverReady = true;
SSLSocket clientSocket = (SSLSocket)serverSocket.accept();
InputStream stream = clientSocket.getInputStream();
for (int i = 0; i < 256; i++) {
int j = stream.read();
if (i != j) {
throw new RuntimeException("Error reading socket, expected " + i + ", got " + j);
}
}
stream.close();
clientSocket.close();
serverSocket.close();
} catch (Exception ex) {
exception = ex;
}
}
public Exception getException() {
return exception;
}
public X509Certificate[] getChain() {
return trustManager.getChain();
}
}
/**
* Loads a keystore from a base64-encoded String. Returns the KeyManager[]
* for the result.
*/
private KeyManager[] getKeyManagers(String keys) throws Exception {
byte[] bytes = new Base64().decode(keys.getBytes());
InputStream inputStream = new ByteArrayInputStream(bytes);
KeyStore keyStore = KeyStore.getInstance(KeyStore.getDefaultType());
keyStore.load(inputStream, PASSWORD.toCharArray());
inputStream.close();
String algorithm = KeyManagerFactory.getDefaultAlgorithm();
KeyManagerFactory keyManagerFactory = KeyManagerFactory.getInstance(algorithm);
keyManagerFactory.init(keyStore, PASSWORD.toCharArray());
return keyManagerFactory.getKeyManagers();
}
private SSLSocket getSSLSocket() throws IOException {
SSLSocket ssl = null;
ssl = (SSLSocket) SSLSocketFactory.getDefault().createSocket();
return ssl;
}
private SSLSocket getSSLSocket(InetAddress host, int port) throws IOException {
SSLSocket ssl = null;
ssl = (SSLSocket) SSLSocketFactory.getDefault().createSocket(host, port);
return ssl;
}
private SSLSocket getSSLSocket(String host, int port) throws UnknownHostException, IOException {
SSLSocket ssl = null;
ssl = (SSLSocket) SSLSocketFactory.getDefault().createSocket(host, port);
return ssl;
}
private SSLSocket getSSLSocket(InetAddress host, int port, InetAddress localHost, int localPort) throws IOException {
SSLSocket ssl = null;
ssl = (SSLSocket) SSLSocketFactory.getDefault().createSocket(host, port, localHost, localPort);
return ssl;
}
private SSLSocket getSSLSocket(String host, int port, InetAddress localHost, int localPort) throws UnknownHostException, IOException {
SSLSocket ssl = null;
ssl = (SSLSocket) SSLSocketFactory.getDefault().createSocket(host, port, localHost, localPort);
return ssl;
}
}
|
