allow specifying nsCertType in config
[stack/cam.git] / cam / ca.py
1 import errno
2 import fcntl
3 import logging
4 import re
5 import os
6 import getpass
7 import random
8 import shutil
9 import tempfile
10 import time
11 from cam import openssl_wrap
12 from cam import utils
13
14 log = logging.getLogger(__name__)
15
16
17 class _CAFiles(object):
18
19     def __init__(self, basedir, **attrs):
20         for key, value in attrs.items():
21             setattr(self, key, os.path.join(basedir, value))
22
23
24 class CA(object):
25
26     def __init__(self, basedir, config, password=None):
27         self._pw = password
28         self.basedir = basedir
29         self.config = {'basedir': basedir, 'default_days': '365', 'ou': 'CA',
30                        'days': '3650', 'country': 'XX', 'crl_url': '',
31                        'bits': '4096'}
32         self.config.update(config)
33         self.files = _CAFiles(basedir, 
34                               conf='conf/ca.conf',
35                               public_key='public/ca.pem',
36                               private_key='private/ca.key',
37                               crl='public/ca.crl',
38                               serial='serial',
39                               crlnumber='crlnumber',
40                               index='index')
41         self._lock()
42
43     def _getpw(self):
44         if self._pw is None:
45             self._pw = getpass.getpass(prompt='CA Password: ')
46         return self._pw
47
48     def _lock(self):
49         self._lockfd = open(os.path.join(self.basedir, '_lock'), 'w+')
50         n = 3
51         while True:
52             try:
53                 fcntl.lockf(self._lockfd, fcntl.LOCK_EX | fcntl.LOCK_NB)
54                 break
55             except IOError, e:
56                 if e.errno in (errno.EACCES, errno.EAGAIN):
57                     n -= 1
58                     if n == 0:
59                         log.error('another instance is running')
60                         raise
61                     time.sleep(1)
62                     continue
63                 raise
64
65     def _unlock(self):
66         fcntl.lockf(self._lockfd, fcntl.LOCK_UN)
67         self._lockfd.close()
68
69     def _update_config(self):
70         # Create the OpenSSL configuration file.
71         utils.render(self.files.conf, 'openssl_config', self.config)
72
73     def close(self):
74         self._unlock()
75
76     def create(self):
77         old_umask = os.umask(077)
78
79         for pathext in ('', 'conf', 'public', 'public/certs',
80                         'public/crl', 'private', 'newcerts'):
81             fullpath = os.path.join(self.basedir, pathext)
82             if not os.path.isdir(fullpath):
83                 os.mkdir(fullpath)
84
85         if not os.path.exists(self.files.index):
86             log.info('creating new index file')
87             open(self.files.index, 'w').close()
88
89         if not os.path.exists(self.files.serial):
90             serial = random.randint(1, 1000000000)
91             log.info('initializing serial number (%d)', serial)
92             with open(self.files.serial, 'w') as fd:
93                 fd.write('%08X\n' % serial)
94
95         if not os.path.exists(self.files.crlnumber):
96             with open(self.files.crlnumber, 'w') as fd:
97                 fd.write('01\n')
98
99         self._update_config()
100
101         # Generate keys if they do not exist.
102         if not os.path.exists(self.files.public_key):
103             tmpdir = tempfile.mkdtemp()
104             csr_file = os.path.join(tmpdir, 'ca.csr')
105             log.info('creating new RSA CA CSR')
106             openssl_wrap.run_with_config(
107                 self.basedir, self.files.conf,
108                 'req', '-new',
109                 '-passout', 'pass:%s' % self._getpw(),
110                 '-keyout', self.files.private_key, '-out', csr_file)
111             log.info('self-signing RSA CA certificate')
112             openssl_wrap.run_with_config(
113                 self.basedir, self.files.conf,
114                 'ca', '-keyfile', self.files.private_key,
115                 '-key', self._getpw(),
116                 '-extensions', 'v3_ca', '-out', self.files.public_key,
117                 '-days', self.config.get('days', self.config['default_days']),
118                 '-selfsign', '-infiles', csr_file)
119             shutil.rmtree(tmpdir)
120
121         os.umask(old_umask)
122
123         # Make some files public.
124         for path in (os.path.join(self.basedir, 'public'),
125                      os.path.join(self.basedir, 'public/certs'),
126                      self.files.public_key):
127             if os.path.isdir(path):
128                 os.chmod(path, 0755)
129             else:
130                 os.chmod(path, 0644)
131
132     def gencrl(self):
133         log.info('generating CRL')
134
135         self._update_config()
136
137         # Write the CRL in PEM format to a temporary file.
138         tmpf = self.files.crl + '.tmp'
139         openssl_wrap.run_with_config(
140             self.basedir, self.files.conf,
141             'ca', '-gencrl', '-out', tmpf,
142             '-key', self._getpw())
143         # Convert to DER format for distribution.
144         openssl_wrap.run(
145             'crl', '-inform', 'PEM', '-outform', 'DER',
146             '-in', tmpf, '-out', self.files.crl)
147         os.remove(tmpf)
148         os.chmod(self.files.crl, 0644)
149
150     def revoke(self, cert):
151         log.info('revoking certificate %s', cert.name)
152         openssl_wrap.run_with_config(
153             self.basedir, self.files.conf,
154             'ca', '-revoke', cert.public_key_file,
155             '-key', self._getpw())
156         self.gencrl()
157
158     def generate(self, cert):
159         self._update_config()
160
161         expiry = cert.get_expiration_date()
162         if expiry and expiry > time.time():
163             log.warn('certificate is still valid, revoking previous version')
164             self.revoke(cert)
165
166         log.info('generating new certificate %s', cert.name)
167         tmpdir = tempfile.mkdtemp()
168         try:
169             csr_file = os.path.join(tmpdir, '%s.csr' % cert.name)
170             conf_file = os.path.join(tmpdir, '%s.conf' % cert.name)
171             ext_file = os.path.join(tmpdir, '%s-ext.conf' % cert.name)
172             conf = {'usage': 'client, server'}
173             conf.update(self.config)
174             conf['cn'] = cert.cn
175             conf['days'] = cert.days or self.config['default_days']
176             if cert.ou:
177                 conf['ou'] = cert.ou
178             conf['alt_names'] = ''.join(
179                 ['DNS.%d=%s\n' % (idx + 1, x) 
180                  for idx, x in enumerate(cert.alt_names)])
181             utils.render(conf_file, 'openssl_config', conf)
182             utils.render(ext_file, 'ext_config', conf)
183             openssl_wrap.run_with_config(
184                 self.basedir, conf_file,
185                 'req', '-new', '-keyout', cert.private_key_file,
186                 '-nodes', '-out', csr_file)
187             os.chmod(cert.private_key_file, 0600)
188             openssl_wrap.run_with_config(
189                 self.basedir, conf_file,
190                 'ca', '-days', conf['days'],
191                 '-key', self._getpw(),
192                 '-policy', 'policy_anything', '-out', cert.public_key_file,
193                 '-extfile', ext_file, '-infiles', csr_file)
194         finally:
195             shutil.rmtree(tmpdir)
196