]> WPIA git - gigi.git/blob - src/org/cacert/gigi/pages/account/certs/CertificateIssueForm.java
[EMPTY] Organize all imports
[gigi.git] / src / org / cacert / gigi / pages / account / certs / CertificateIssueForm.java
1 package org.cacert.gigi.pages.account.certs;
2
3 import java.io.IOException;
4 import java.io.PrintWriter;
5 import java.security.GeneralSecurityException;
6 import java.security.PublicKey;
7 import java.security.interfaces.DSAPublicKey;
8 import java.security.interfaces.ECPublicKey;
9 import java.security.interfaces.RSAPublicKey;
10 import java.util.Base64;
11 import java.util.HashMap;
12 import java.util.LinkedHashSet;
13 import java.util.Map;
14 import java.util.Set;
15 import java.util.TreeSet;
16
17 import javax.servlet.http.HttpServletRequest;
18
19 import org.cacert.gigi.GigiApiException;
20 import org.cacert.gigi.crypto.SPKAC;
21 import org.cacert.gigi.dbObjects.Certificate;
22 import org.cacert.gigi.dbObjects.Certificate.CSRType;
23 import org.cacert.gigi.dbObjects.Certificate.SANType;
24 import org.cacert.gigi.dbObjects.Certificate.SubjectAlternateName;
25 import org.cacert.gigi.dbObjects.CertificateProfile;
26 import org.cacert.gigi.dbObjects.Digest;
27 import org.cacert.gigi.dbObjects.User;
28 import org.cacert.gigi.localisation.Language;
29 import org.cacert.gigi.output.CertificateValiditySelector;
30 import org.cacert.gigi.output.Form;
31 import org.cacert.gigi.output.template.HashAlgorithms;
32 import org.cacert.gigi.output.template.IterableDataset;
33 import org.cacert.gigi.output.template.Template;
34 import org.cacert.gigi.pages.LoginPage;
35 import org.cacert.gigi.pages.Page;
36 import org.cacert.gigi.util.PEM;
37 import org.cacert.gigi.util.RandomToken;
38
39 import sun.security.pkcs.PKCS9Attribute;
40 import sun.security.pkcs10.PKCS10;
41 import sun.security.pkcs10.PKCS10Attribute;
42 import sun.security.pkcs10.PKCS10Attributes;
43 import sun.security.util.DerInputStream;
44 import sun.security.util.DerValue;
45 import sun.security.util.ObjectIdentifier;
46 import sun.security.x509.AVA;
47 import sun.security.x509.AlgorithmId;
48 import sun.security.x509.CertificateExtensions;
49 import sun.security.x509.DNSName;
50 import sun.security.x509.ExtendedKeyUsageExtension;
51 import sun.security.x509.Extension;
52 import sun.security.x509.GeneralName;
53 import sun.security.x509.GeneralNameInterface;
54 import sun.security.x509.GeneralNames;
55 import sun.security.x509.PKIXExtensions;
56 import sun.security.x509.RDN;
57 import sun.security.x509.RFC822Name;
58 import sun.security.x509.SubjectAlternativeNameExtension;
59 import sun.security.x509.X500Name;
60
61 /**
62  * This class represents a form that is used for issuing certificates. This
63  * class uses "sun.security" and therefore needs "-XDignore.symbol.file"
64  */
65 public class CertificateIssueForm extends Form {
66
67     public static final String DEFAULT_CN = "CAcert WoT User";
68
69     private final static Template t = new Template(CertificateIssueForm.class.getResource("CertificateIssueForm.templ"));
70
71     private final static Template tIni = new Template(CertificateAdd.class.getResource("RequestCertificate.templ"));
72
73     public static final ObjectIdentifier OID_KEY_USAGE_SSL_SERVER = ObjectIdentifier.newInternal(new int[] {
74             1, 3, 6, 1, 5, 5, 7, 3, 1
75     });
76
77     public static final ObjectIdentifier OID_KEY_USAGE_SSL_CLIENT = ObjectIdentifier.newInternal(new int[] {
78             1, 3, 6, 1, 5, 5, 7, 3, 2
79     });
80
81     public static final ObjectIdentifier OID_KEY_USAGE_CODESIGN = ObjectIdentifier.newInternal(new int[] {
82             1, 3, 6, 1, 5, 5, 7, 3, 3
83     });
84
85     public static final ObjectIdentifier OID_KEY_USAGE_EMAIL_PROTECTION = ObjectIdentifier.newInternal(new int[] {
86             1, 3, 6, 1, 5, 5, 7, 3, 4
87     });
88
89     public static final ObjectIdentifier OID_KEY_USAGE_TIMESTAMP = ObjectIdentifier.newInternal(new int[] {
90             1, 3, 6, 1, 5, 5, 7, 3, 8
91     });
92
93     public static final ObjectIdentifier OID_KEY_USAGE_OCSP = ObjectIdentifier.newInternal(new int[] {
94             1, 3, 6, 1, 5, 5, 7, 3, 9
95     });
96
97     private User u;
98
99     private CSRType csrType;
100
101     private String csr;
102
103     private String spkacChallenge;
104
105     public String CN = DEFAULT_CN;
106
107     private Set<SubjectAlternateName> SANs = new LinkedHashSet<>();
108
109     private Digest selectedDigest = Digest.getDefault();
110
111     CertificateValiditySelector issueDate = new CertificateValiditySelector();
112
113     private boolean login;
114
115     private CertificateProfile profile = CertificateProfile.getById(1);
116
117     public CertificateIssueForm(HttpServletRequest hsr) {
118         super(hsr);
119         u = Page.getUser(hsr);
120         spkacChallenge = RandomToken.generateToken(16);
121     }
122
123     private Certificate result;
124
125     public Certificate getResult() {
126         return result;
127     }
128
129     @Override
130     public boolean submit(PrintWriter out, HttpServletRequest req) {
131         String csr = req.getParameter("CSR");
132         String spkac = req.getParameter("SPKAC");
133         try {
134             try {
135                 if (csr != null) {
136                     byte[] data = PEM.decode("(NEW )?CERTIFICATE REQUEST", csr);
137                     PKCS10 parsed = new PKCS10(data);
138                     PKCS10Attributes atts = parsed.getAttributes();
139
140                     for (PKCS10Attribute b : atts.getAttributes()) {
141
142                         if ( !b.getAttributeId().equals((Object) PKCS9Attribute.EXTENSION_REQUEST_OID)) {
143                             // unknown attrib
144                             continue;
145                         }
146
147                         for (RDN r : parsed.getSubjectName().rdns()) {
148                             for (AVA a : r.avas()) {
149                                 if (a.getObjectIdentifier().equals((Object) PKCS9Attribute.EMAIL_ADDRESS_OID)) {
150                                     SANs.add(new SubjectAlternateName(SANType.EMAIL, a.getValueString()));
151                                 } else if (a.getObjectIdentifier().equals((Object) X500Name.commonName_oid)) {
152                                     String value = a.getValueString();
153                                     if (value.contains(".") && !value.contains(" ")) {
154                                         SANs.add(new SubjectAlternateName(SANType.DNS, value));
155                                     } else {
156                                         CN = value;
157                                     }
158                                 } else if (a.getObjectIdentifier().equals((Object) PKIXExtensions.SubjectAlternativeName_Id)) {
159                                     // parse invalid SANs
160                                 }
161                             }
162                         }
163
164                         for (Extension c : ((CertificateExtensions) b.getAttributeValue()).getAllExtensions()) {
165                             if (c instanceof SubjectAlternativeNameExtension) {
166
167                                 SubjectAlternativeNameExtension san = (SubjectAlternativeNameExtension) c;
168                                 GeneralNames obj = san.get(SubjectAlternativeNameExtension.SUBJECT_NAME);
169                                 for (int i = 0; i < obj.size(); i++) {
170                                     GeneralName generalName = obj.get(i);
171                                     GeneralNameInterface peeled = generalName.getName();
172                                     if (peeled instanceof DNSName) {
173                                         SANs.add(new SubjectAlternateName(SANType.DNS, ((DNSName) peeled).getName()));
174                                     } else if (peeled instanceof RFC822Name) {
175                                         SANs.add(new SubjectAlternateName(SANType.EMAIL, ((RFC822Name) peeled).getName()));
176                                     }
177                                 }
178                             } else if (c instanceof ExtendedKeyUsageExtension) {
179                                 ExtendedKeyUsageExtension ekue = (ExtendedKeyUsageExtension) c;
180                                 for (String s : ekue.getExtendedKeyUsage()) {
181                                     if (s.equals(OID_KEY_USAGE_SSL_SERVER.toString())) {
182                                         // server
183                                         profile = CertificateProfile.getByName("server");
184                                     } else if (s.equals(OID_KEY_USAGE_SSL_CLIENT.toString())) {
185                                         // client
186                                         profile = CertificateProfile.getByName("client");
187                                     } else if (s.equals(OID_KEY_USAGE_CODESIGN.toString())) {
188                                         // code sign
189                                     } else if (s.equals(OID_KEY_USAGE_EMAIL_PROTECTION.toString())) {
190                                         // emailProtection
191                                         profile = CertificateProfile.getByName("mail");
192                                     } else if (s.equals(OID_KEY_USAGE_TIMESTAMP.toString())) {
193                                         // timestamp
194                                     } else if (s.equals(OID_KEY_USAGE_OCSP.toString())) {
195                                         // OCSP
196                                     }
197                                 }
198                             } else {
199                                 // Unknown requested extension
200                             }
201                         }
202
203                     }
204                     out.println(parsed.getSubjectName().getCommonName());
205                     out.println(parsed.getSubjectName().getCountry());
206
207                     out.println("CSR DN: " + parsed.getSubjectName() + "<br/>");
208                     PublicKey pk = parsed.getSubjectPublicKeyInfo();
209                     checkKeyStrength(pk, out);
210                     String sign = getSignatureAlgorithm(data);
211                     guessDigest(sign);
212
213                     out.println("<br/>digest: " + sign + "<br/>");
214
215                     this.csr = csr;
216                     this.csrType = CSRType.CSR;
217                 } else if (spkac != null) {
218                     String cleanedSPKAC = spkac.replaceAll("[\r\n]", "");
219                     byte[] data = Base64.getDecoder().decode(cleanedSPKAC);
220                     SPKAC parsed = new SPKAC(data);
221                     if ( !parsed.getChallenge().equals(spkacChallenge)) {
222                         throw new GigiApiException("Challenge mismatch");
223                     }
224                     checkKeyStrength(parsed.getPubkey(), out);
225                     String sign = getSignatureAlgorithm(data);
226                     guessDigest(sign);
227                     out.println("<br/>digest: " + sign + "<br/>");
228
229                     // spkacChallenge
230                     this.csr = "SPKAC=" + cleanedSPKAC;
231                     this.csrType = CSRType.SPKAC;
232
233                 } else {
234                     login = "1".equals(req.getParameter("login"));
235                     issueDate.update(req);
236                     CN = req.getParameter("CN");
237                     String hashAlg = req.getParameter("hash_alg");
238                     if (hashAlg != null) {
239                         selectedDigest = Digest.valueOf(hashAlg);
240                     }
241                     profile = CertificateProfile.getByName(req.getParameter("profile"));
242
243                     String pDNS = null;
244                     String pMail = null;
245                     Set<SubjectAlternateName> filteredSANs = new LinkedHashSet<>();
246                     boolean server = profile.getKeyName().equals("server");
247                     for (SubjectAlternateName san : parseSANBox(req.getParameter("SANs"))) {
248                         if (san.getType() == SANType.DNS) {
249                             if (u.isValidDomain(san.getName()) && server) {
250                                 if (pDNS == null) {
251                                     pDNS = san.getName();
252                                 }
253                                 filteredSANs.add(san);
254                                 continue;
255                             }
256                         } else if (san.getType() == SANType.EMAIL) {
257                             if (u.isValidEmail(san.getName()) && !server) {
258                                 if (pMail == null) {
259                                     pMail = san.getName();
260                                 }
261                                 filteredSANs.add(san);
262                                 continue;
263                             }
264                         }
265                         outputError(out, req, "The requested Subject alternate name \"%s\" has been removed.",//
266                                 san.getType().toString().toLowerCase() + ":" + san.getName());
267                     }
268                     SANs = filteredSANs;
269                     if ( !u.isValidName(CN) && !server && !CN.equals(DEFAULT_CN)) {
270                         CN = DEFAULT_CN;
271                         outputError(out, req, "The real name entered cannot be verified with your account.");
272                     }
273
274                     final StringBuffer subject = new StringBuffer();
275                     if (server && pDNS != null) {
276                         subject.append("/commonName=");
277                         subject.append(pDNS);
278                         if (pMail != null) {
279                             outputError(out, req, "No email is included in this certificate.");
280                         }
281                         if (CN.equals("")) {
282                             CN = "";
283                             outputError(out, req, "No real name is included in this certificate.");
284                         }
285                     } else {
286                         subject.append("/commonName=");
287                         subject.append(CN);
288                         if (pMail != null) {
289                             subject.append("/emailAddress=");
290                             subject.append(pMail);
291                         }
292                     }
293                     if (req.getParameter("CCA") == null) {
294                         outputError(out, req, "You need to accept the CCA.");
295                     }
296                     if (isFailed(out)) {
297                         return false;
298                     }
299
300                     result = new Certificate(LoginPage.getUser(req).getId(), subject.toString(), selectedDigest.toString(), //
301                             this.csr, this.csrType, profile, SANs.toArray(new SubjectAlternateName[SANs.size()]));
302                     result.issue(issueDate.getFrom(), issueDate.getTo()).waitFor(60000);
303                     return true;
304                 }
305             } catch (IOException e) {
306                 e.printStackTrace();
307             } catch (IllegalArgumentException e) {
308                 e.printStackTrace();
309                 throw new GigiApiException("Certificate Request format is invalid.");
310             } catch (GeneralSecurityException e) {
311                 e.printStackTrace();
312                 throw new GigiApiException("Certificate Request format is invalid.");
313             } catch (InterruptedException e) {
314                 e.printStackTrace();
315             }
316         } catch (GigiApiException e) {
317             e.format(out, Page.getLanguage(req));
318         }
319         return false;
320     }
321
322     private void guessDigest(String sign) {
323         if (sign.toLowerCase().startsWith("sha512")) {
324             selectedDigest = Digest.SHA512;
325         } else if (sign.toLowerCase().startsWith("sha384")) {
326             selectedDigest = Digest.SHA384;
327         }
328     }
329
330     private TreeSet<SubjectAlternateName> parseSANBox(String SANs) {
331         String[] SANparts = SANs.split("[\r\n]+|, *");
332         TreeSet<SubjectAlternateName> parsedNames = new TreeSet<>();
333         for (String SANline : SANparts) {
334             String[] parts = SANline.split(":", 2);
335             if (parts.length == 1) {
336                 if (parts[0].trim().equals("")) {
337                     continue;
338                 }
339                 if (parts[0].contains("@")) {
340                     parsedNames.add(new SubjectAlternateName(SANType.EMAIL, parts[0]));
341                 } else {
342                     parsedNames.add(new SubjectAlternateName(SANType.DNS, parts[0]));
343                 }
344                 continue;
345             }
346             try {
347                 SANType t = Certificate.SANType.valueOf(parts[0].toUpperCase());
348                 if (t == null) {
349                     continue;
350                 }
351                 parsedNames.add(new SubjectAlternateName(t, parts[1]));
352             } catch (IllegalArgumentException e) {
353                 // invalid enum type
354                 continue;
355             }
356         }
357         return parsedNames;
358     }
359
360     private void checkKeyStrength(PublicKey pk, PrintWriter out) {
361         out.println("Type: " + pk.getAlgorithm() + "<br/>");
362         if (pk instanceof RSAPublicKey) {
363             out.println("Exponent: " + ((RSAPublicKey) pk).getPublicExponent() + "<br/>");
364             out.println("Length: " + ((RSAPublicKey) pk).getModulus().bitLength());
365         } else if (pk instanceof DSAPublicKey) {
366             DSAPublicKey dpk = (DSAPublicKey) pk;
367             out.println("Length: " + dpk.getY().bitLength() + "<br/>");
368             out.println(dpk.getParams());
369         } else if (pk instanceof ECPublicKey) {
370             ECPublicKey epk = (ECPublicKey) pk;
371             out.println("Length-x: " + epk.getW().getAffineX().bitLength() + "<br/>");
372             out.println("Length-y: " + epk.getW().getAffineY().bitLength() + "<br/>");
373             out.println(epk.getParams().getCurve());
374         }
375     }
376
377     private static String getSignatureAlgorithm(byte[] data) throws IOException {
378         DerInputStream in = new DerInputStream(data);
379         DerValue[] seq = in.getSequence(3);
380         return AlgorithmId.parse(seq[1]).getName();
381     }
382
383     @Override
384     public void output(PrintWriter out, Language l, Map<String, Object> vars) {
385         if (csr == null) {
386             HashMap<String, Object> vars2 = new HashMap<String, Object>(vars);
387             vars2.put("csrf", getCSRFToken());
388             vars2.put("csrf_name", getCsrfFieldName());
389             vars2.put("spkacChallenge", spkacChallenge);
390             tIni.output(out, l, vars2);
391             return;
392         } else {
393             super.output(out, l, vars);
394         }
395     }
396
397     @Override
398     protected void outputContent(PrintWriter out, Language l, Map<String, Object> vars) {
399         HashMap<String, Object> vars2 = new HashMap<String, Object>(vars);
400         vars2.put("CCA", "<a href='/policy/CAcertCommunityAgreement.html'>CCA</a>");
401
402         StringBuffer content = new StringBuffer();
403         for (SubjectAlternateName SAN : SANs) {
404             content.append(SAN.getType().toString().toLowerCase());
405             content.append(':');
406             content.append(SAN.getName());
407             content.append('\n');
408         }
409
410         vars2.put("CN", CN);
411         vars2.put("validity", issueDate);
412         vars2.put("emails", content.toString());
413         vars2.put("hashs", new HashAlgorithms(selectedDigest));
414         vars2.put("profiles", new IterableDataset() {
415
416             int i = 1;
417
418             @Override
419             public boolean next(Language l, Map<String, Object> vars) {
420                 CertificateProfile cp = CertificateProfile.getById(i++);
421                 if (cp == null) {
422                     return false;
423                 }
424                 if (cp.getId() == profile.getId()) {
425                     vars.put("selected", " selected");
426                 } else {
427                     vars.put("selected", "");
428                 }
429                 vars.put("key", cp.getKeyName());
430                 vars.put("name", cp.getVisibleName());
431                 return true;
432             }
433         });
434         t.output(out, l, vars2);
435     }
436 }