| /* |
| * Copyright (c) 2003, 2016, Oracle and/or its affiliates. All rights reserved. |
| * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
| * |
| * This code is free software; you can redistribute it and/or modify it |
| * under the terms of the GNU General Public License version 2 only, as |
| * published by the Free Software Foundation. |
| * |
| * This code is distributed in the hope that it will be useful, but WITHOUT |
| * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
| * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License |
| * version 2 for more details (a copy is included in the LICENSE file that |
| * accompanied this code). |
| * |
| * You should have received a copy of the GNU General Public License version |
| * 2 along with this work; if not, write to the Free Software Foundation, |
| * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. |
| * |
| * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
| * or visit www.oracle.com if you need additional information or have any |
| * questions. |
| */ |
| |
| import com.sun.net.httpserver.*; |
| import java.io.BufferedReader; |
| import java.io.ByteArrayOutputStream; |
| import java.io.FileInputStream; |
| import java.io.IOException; |
| import java.io.InputStream; |
| import java.io.InputStreamReader; |
| import java.io.OutputStream; |
| import java.math.BigInteger; |
| import java.net.InetSocketAddress; |
| import java.security.KeyStore; |
| import java.security.PrivateKey; |
| import java.security.Signature; |
| import java.security.cert.Certificate; |
| import java.security.cert.X509Certificate; |
| import java.util.Calendar; |
| import java.util.jar.JarEntry; |
| import java.util.jar.JarFile; |
| |
| import sun.misc.IOUtils; |
| import sun.security.pkcs.ContentInfo; |
| import sun.security.pkcs.PKCS7; |
| import sun.security.pkcs.PKCS9Attribute; |
| import sun.security.pkcs.SignerInfo; |
| import sun.security.timestamp.TimestampToken; |
| import sun.security.util.DerOutputStream; |
| import sun.security.util.DerValue; |
| import sun.security.util.ObjectIdentifier; |
| import sun.security.x509.AlgorithmId; |
| import sun.security.x509.X500Name; |
| |
| public class TimestampCheck { |
| static final String TSKS = "tsks"; |
| static final String JAR = "old.jar"; |
| |
| static final String defaultPolicyId = "2.3.4.5"; |
| |
| static class Handler implements HttpHandler, AutoCloseable { |
| |
| private final HttpServer httpServer; |
| private final String keystore; |
| |
| @Override |
| public void handle(HttpExchange t) throws IOException { |
| int len = 0; |
| for (String h: t.getRequestHeaders().keySet()) { |
| if (h.equalsIgnoreCase("Content-length")) { |
| len = Integer.valueOf(t.getRequestHeaders().get(h).get(0)); |
| } |
| } |
| byte[] input = new byte[len]; |
| t.getRequestBody().read(input); |
| |
| try { |
| int path = 0; |
| if (t.getRequestURI().getPath().length() > 1) { |
| path = Integer.parseInt( |
| t.getRequestURI().getPath().substring(1)); |
| } |
| byte[] output = sign(input, path); |
| Headers out = t.getResponseHeaders(); |
| out.set("Content-Type", "application/timestamp-reply"); |
| |
| t.sendResponseHeaders(200, output.length); |
| OutputStream os = t.getResponseBody(); |
| os.write(output); |
| } catch (Exception e) { |
| e.printStackTrace(); |
| t.sendResponseHeaders(500, 0); |
| } |
| t.close(); |
| } |
| |
| /** |
| * @param input The data to sign |
| * @param path different cases to simulate, impl on URL path |
| * 0: normal |
| * 1: Missing nonce |
| * 2: Different nonce |
| * 3: Bad digets octets in messageImprint |
| * 4: Different algorithmId in messageImprint |
| * 5: whole chain in cert set |
| * 6: extension is missing |
| * 7: extension is non-critical |
| * 8: extension does not have timestamping |
| * 9: no cert in response |
| * 10: normal |
| * 11: always return default policy id |
| * 12: normal |
| * otherwise: normal |
| * @returns the signed |
| */ |
| byte[] sign(byte[] input, int path) throws Exception { |
| // Read TSRequest |
| DerValue value = new DerValue(input); |
| System.err.println("\nIncoming Request\n==================="); |
| System.err.println("Version: " + value.data.getInteger()); |
| DerValue messageImprint = value.data.getDerValue(); |
| AlgorithmId aid = AlgorithmId.parse( |
| messageImprint.data.getDerValue()); |
| System.err.println("AlgorithmId: " + aid); |
| |
| ObjectIdentifier policyId = new ObjectIdentifier(defaultPolicyId); |
| BigInteger nonce = null; |
| while (value.data.available() > 0) { |
| DerValue v = value.data.getDerValue(); |
| if (v.tag == DerValue.tag_Integer) { |
| nonce = v.getBigInteger(); |
| System.err.println("nonce: " + nonce); |
| } else if (v.tag == DerValue.tag_Boolean) { |
| System.err.println("certReq: " + v.getBoolean()); |
| } else if (v.tag == DerValue.tag_ObjectId) { |
| policyId = v.getOID(); |
| System.err.println("PolicyID: " + policyId); |
| } |
| } |
| |
| // Write TSResponse |
| System.err.println("\nResponse\n==================="); |
| KeyStore ks = KeyStore.getInstance("JKS"); |
| try (FileInputStream fis = new FileInputStream(keystore)) { |
| ks.load(fis, "changeit".toCharArray()); |
| } |
| |
| String alias = "ts"; |
| if (path == 6) alias = "tsbad1"; |
| if (path == 7) alias = "tsbad2"; |
| if (path == 8) alias = "tsbad3"; |
| |
| if (path == 11) { |
| policyId = new ObjectIdentifier(defaultPolicyId); |
| } |
| |
| DerOutputStream statusInfo = new DerOutputStream(); |
| statusInfo.putInteger(0); |
| |
| DerOutputStream token = new DerOutputStream(); |
| AlgorithmId[] algorithms = {aid}; |
| Certificate[] chain = ks.getCertificateChain(alias); |
| X509Certificate[] signerCertificateChain = null; |
| X509Certificate signer = (X509Certificate)chain[0]; |
| if (path == 5) { // Only case 5 uses full chain |
| signerCertificateChain = new X509Certificate[chain.length]; |
| for (int i=0; i<chain.length; i++) { |
| signerCertificateChain[i] = (X509Certificate)chain[i]; |
| } |
| } else if (path == 9) { |
| signerCertificateChain = new X509Certificate[0]; |
| } else { |
| signerCertificateChain = new X509Certificate[1]; |
| signerCertificateChain[0] = (X509Certificate)chain[0]; |
| } |
| |
| DerOutputStream tst = new DerOutputStream(); |
| |
| tst.putInteger(1); |
| tst.putOID(policyId); |
| |
| if (path != 3 && path != 4) { |
| tst.putDerValue(messageImprint); |
| } else { |
| byte[] data = messageImprint.toByteArray(); |
| if (path == 4) { |
| data[6] = (byte)0x01; |
| } else { |
| data[data.length-1] = (byte)0x01; |
| data[data.length-2] = (byte)0x02; |
| data[data.length-3] = (byte)0x03; |
| } |
| tst.write(data); |
| } |
| |
| tst.putInteger(1); |
| |
| Calendar cal = Calendar.getInstance(); |
| tst.putGeneralizedTime(cal.getTime()); |
| |
| if (path == 2) { |
| tst.putInteger(1234); |
| } else if (path == 1) { |
| // do nothing |
| } else { |
| tst.putInteger(nonce); |
| } |
| |
| DerOutputStream tstInfo = new DerOutputStream(); |
| tstInfo.write(DerValue.tag_Sequence, tst); |
| |
| DerOutputStream tstInfo2 = new DerOutputStream(); |
| tstInfo2.putOctetString(tstInfo.toByteArray()); |
| |
| Signature sig = Signature.getInstance("SHA1withRSA"); |
| sig.initSign((PrivateKey)(ks.getKey( |
| alias, "changeit".toCharArray()))); |
| sig.update(tstInfo.toByteArray()); |
| |
| ContentInfo contentInfo = new ContentInfo(new ObjectIdentifier( |
| "1.2.840.113549.1.9.16.1.4"), |
| new DerValue(tstInfo2.toByteArray())); |
| |
| System.err.println("Signing..."); |
| System.err.println(new X500Name(signer |
| .getIssuerX500Principal().getName())); |
| System.err.println(signer.getSerialNumber()); |
| |
| SignerInfo signerInfo = new SignerInfo( |
| new X500Name(signer.getIssuerX500Principal().getName()), |
| signer.getSerialNumber(), |
| aid, AlgorithmId.get("RSA"), sig.sign()); |
| |
| SignerInfo[] signerInfos = {signerInfo}; |
| PKCS7 p7 = |
| new PKCS7(algorithms, contentInfo, signerCertificateChain, |
| signerInfos); |
| ByteArrayOutputStream p7out = new ByteArrayOutputStream(); |
| p7.encodeSignedData(p7out); |
| |
| DerOutputStream response = new DerOutputStream(); |
| response.write(DerValue.tag_Sequence, statusInfo); |
| response.putDerValue(new DerValue(p7out.toByteArray())); |
| |
| DerOutputStream out = new DerOutputStream(); |
| out.write(DerValue.tag_Sequence, response); |
| |
| return out.toByteArray(); |
| } |
| |
| private Handler(HttpServer httpServer, String keystore) { |
| this.httpServer = httpServer; |
| this.keystore = keystore; |
| } |
| |
| /** |
| * Initialize TSA instance. |
| * |
| * Extended Key Info extension of certificate that is used for |
| * signing TSA responses should contain timeStamping value. |
| */ |
| static Handler init(int port, String keystore) throws IOException { |
| HttpServer httpServer = HttpServer.create( |
| new InetSocketAddress(port), 0); |
| Handler tsa = new Handler(httpServer, keystore); |
| httpServer.createContext("/", tsa); |
| return tsa; |
| } |
| |
| /** |
| * Start TSA service. |
| */ |
| void start() { |
| httpServer.start(); |
| } |
| |
| /** |
| * Stop TSA service. |
| */ |
| void stop() { |
| httpServer.stop(0); |
| } |
| |
| /** |
| * Return server port number. |
| */ |
| int getPort() { |
| return httpServer.getAddress().getPort(); |
| } |
| |
| @Override |
| public void close() throws Exception { |
| stop(); |
| } |
| } |
| public static void main(String[] args) throws Exception { |
| try (Handler tsa = Handler.init(0, TSKS);) { |
| tsa.start(); |
| int port = tsa.getPort(); |
| |
| String cmd; |
| // Use -J-Djava.security.egd=file:/dev/./urandom to speed up |
| // nonce generation in timestamping request. Not avaibale on |
| // Windows and defaults to thread seed generator, not too bad. |
| if (System.getProperty("java.home").endsWith("jre")) { |
| cmd = System.getProperty("java.home") + "/../bin/jarsigner"; |
| } else { |
| cmd = System.getProperty("java.home") + "/bin/jarsigner"; |
| } |
| |
| cmd += " -J-Djava.security.egd=file:/dev/./urandom" |
| + " -debug -keystore " + TSKS + " -storepass changeit" |
| + " -tsa http://localhost:" + port + "/%d" |
| + " -signedjar new_%d.jar " + JAR + " old"; |
| |
| if (args.length == 0) { // Run this test |
| jarsigner(cmd, 0, true); // Success, normal call |
| jarsigner(cmd, 1, false); // These 4 should fail |
| jarsigner(cmd, 2, false); |
| jarsigner(cmd, 3, false); |
| jarsigner(cmd, 4, false); |
| jarsigner(cmd, 5, true); // Success, 6543440 solved. |
| jarsigner(cmd, 6, false); // tsbad1 |
| jarsigner(cmd, 7, false); // tsbad2 |
| jarsigner(cmd, 8, false); // tsbad3 |
| jarsigner(cmd, 9, false); // no cert in timestamp |
| jarsigner(cmd + " -tsapolicyid 1.2.3.4", 10, true); |
| checkTimestamp("new_10.jar", "1.2.3.4", "SHA-256"); |
| jarsigner(cmd + " -tsapolicyid 1.2.3.5", 11, false); |
| jarsigner(cmd + " -tsadigestalg SHA", 12, true); |
| checkTimestamp("new_12.jar", defaultPolicyId, "SHA-1"); |
| } else { // Run as a standalone server |
| System.err.println("Press Enter to quit server"); |
| System.in.read(); |
| } |
| } |
| } |
| |
| static void checkTimestamp(String file, String policyId, String digestAlg) |
| throws Exception { |
| try (JarFile jf = new JarFile(file)) { |
| JarEntry je = jf.getJarEntry("META-INF/OLD.RSA"); |
| try (InputStream is = jf.getInputStream(je)) { |
| byte[] content = IOUtils.readFully(is, -1, true); |
| PKCS7 p7 = new PKCS7(content); |
| SignerInfo[] si = p7.getSignerInfos(); |
| if (si == null || si.length == 0) { |
| throw new Exception("Not signed"); |
| } |
| PKCS9Attribute p9 = si[0].getUnauthenticatedAttributes() |
| .getAttribute(PKCS9Attribute.SIGNATURE_TIMESTAMP_TOKEN_OID); |
| PKCS7 tsToken = new PKCS7((byte[]) p9.getValue()); |
| TimestampToken tt = |
| new TimestampToken(tsToken.getContentInfo().getData()); |
| if (!tt.getHashAlgorithm().toString().equals(digestAlg)) { |
| throw new Exception("Digest alg different"); |
| } |
| if (!tt.getPolicyID().equals(policyId)) { |
| throw new Exception("policyId different"); |
| } |
| } |
| } |
| } |
| |
| /** |
| * @param cmd the command line (with a hole to plug in) |
| * @param path the path in the URL, i.e, http://localhost/path |
| * @param expected if this command should succeed |
| */ |
| static void jarsigner(String cmd, int path, boolean expected) |
| throws Exception { |
| System.err.println("Test " + path); |
| Process p = Runtime.getRuntime().exec(String.format(cmd, path, path)); |
| BufferedReader reader = new BufferedReader( |
| new InputStreamReader(p.getErrorStream())); |
| while (true) { |
| String s = reader.readLine(); |
| if (s == null) break; |
| System.err.println(s); |
| } |
| |
| // Will not see noTimestamp warning |
| boolean seeWarning = false; |
| reader = new BufferedReader( |
| new InputStreamReader(p.getInputStream())); |
| while (true) { |
| String s = reader.readLine(); |
| if (s == null) break; |
| System.err.println(s); |
| if (s.indexOf("Warning:") >= 0) { |
| seeWarning = true; |
| } |
| } |
| int result = p.waitFor(); |
| if (expected && result != 0 || !expected && result == 0) { |
| throw new Exception("Failed"); |
| } |
| if (seeWarning) { |
| throw new Exception("See warning"); |
| } |
| } |
| } |