|
| 1 | +import os |
| 2 | + |
| 3 | +from . import errors |
| 4 | +from .ssladapter import ssladapter |
| 5 | + |
| 6 | + |
| 7 | +class TLSConfig(object): |
| 8 | + def __init__(self, tls, tls_cert=None, tls_key=None, tls_verify=False, |
| 9 | + tls_ca_cert=None, ssl_version=None): |
| 10 | + # Argument compatibility/mapping with |
| 11 | + # http://docs.docker.com/examples/https/ |
| 12 | + # This diverges from the Docker CLI in that users can specify 'tls' |
| 13 | + # here, but also disable any public/default CA pool verification by |
| 14 | + # leaving tls_verify=False |
| 15 | + |
| 16 | + # urllib3 sets a default ssl_version if ssl_version is None |
| 17 | + # http://tinyurl.com/kxga8hb |
| 18 | + self.ssl_version = ssl_version |
| 19 | + |
| 20 | + # "tls" and "tls_verify" must have both or neither cert/key files |
| 21 | + # In either case, Alert the user when both are expected, but any are |
| 22 | + # missing. |
| 23 | + |
| 24 | + if tls_cert or tls_key: |
| 25 | + if not (tls_cert and tls_key) or (not os.path.isfile(tls_cert) or |
| 26 | + not os.path.isfile(tls_key)): |
| 27 | + raise errors.TLSParameterError( |
| 28 | + 'You must provide either both "tls_cert"/"tls_key" files, ' |
| 29 | + 'or neither, in order to use TLS.') |
| 30 | + self.cert = (tls_cert, tls_key) |
| 31 | + |
| 32 | + # Either set tls_verify to True (public/default CA checks) or to the |
| 33 | + # path of a CA Cert file. |
| 34 | + if tls_verify: |
| 35 | + if not tls_ca_cert: |
| 36 | + self.verify = True |
| 37 | + elif os.path.isfile(tls_ca_cert): |
| 38 | + self.verify = tls_ca_cert |
| 39 | + else: |
| 40 | + raise errors.TLSParameterError( |
| 41 | + 'If "tls_verify" is set, then "tls_ca_cert" must be blank' |
| 42 | + ' (to check public CA list) OR a path to a Cert File.' |
| 43 | + ) |
| 44 | + else: |
| 45 | + self.verify = False |
| 46 | + |
| 47 | + def configure_client(self, client): |
| 48 | + client.verify = self.verify |
| 49 | + client.ssl_version = self.ssl_version |
| 50 | + client.cert = self.cert |
| 51 | + self.mount('https://', ssladapter.SSLAdapter(self.ssl_version)) |
0 commit comments