Commit 21b74791 authored by Ilias Tsitsimpis's avatar Ilias Tsitsimpis
Browse files

snf-ci: Patch kamaki to use CA certificates

Patch kamaki clients to use ca_certs path found in kamakirc file or to
completely skip SSL verification using the '--ignore-ssl' flag.
parent e90b03b6
......@@ -138,6 +138,9 @@ def main(): # pylint: disable=too-many-statements, too-many-branches
parser.add_option("--no-colors", dest="use_colors",
default=True, action="store_false",
help="Don't use colorful output messages.")
parser.add_option("--ignore-ssl", "-k", dest="ignore_ssl",
default=False, action="store_true",
help="Don't verify SSL certificates.")
(options, args) = parser.parse_args()
......@@ -177,6 +180,7 @@ def main(): # pylint: disable=too-many-statements, too-many-branches
# ----------------------------------
# Initialize SynnefoCi
utils.USE_COLORS = options.use_colors
utils.IGNORE_SSL = options.ignore_ssl
config_file = options.config_file
if config_file is not None:
config_file = os.path.expanduser(config_file)
......@@ -36,12 +36,15 @@ from kamaki.clients.astakos import AstakosClient, parse_endpoints
from kamaki.clients.cyclades import CycladesClient, CycladesNetworkClient
from kamaki.clients.image import ImageClient
from kamaki.clients.compute import ComputeClient
from kamaki.clients.utils import https
from kamaki.clients import ClientError
import filelocker
DEFAULT_CONFIG_FILE = "ci_wheezy.conf"
# Is our terminal a colorful one?
# Ignore SSL verification
# UUID of owner of system images
"25ecced9-bf53-4145-91ee-cf47377e9fb2", # production (
......@@ -94,6 +97,26 @@ def _check_fabric(fun):
return wrapper
def _kamaki_ssl(ignore_ssl=None):
"""Patch kamaki to use the correct CA certificates
Read kamaki's config file and decide if we are going to use
CA certificates and patch kamaki clients accordingly.
config = kamaki_config.Config()
if ignore_ssl is None:
ignore_ssl = config.get("global", "ignore_ssl").lower() == "on"
ca_file = config.get("global", "ca_certs")
if ignore_ssl:
# Skip SSL verification
# Use ca_certs path found in kamakirc
def _check_kamaki(fun):
"""Check if kamaki has been initialized"""
def wrapper(self, *args, **kwargs):
......@@ -202,6 +225,9 @@ class SynnefoCI(object):
Setup cyclades_client, image_client and compute_client
# Patch kamaki for SSL verification
config = kamaki_config.Config()
if self.kamaki_cloud is None:
......@@ -215,7 +241,7 @@ class SynnefoCI(object):
auth_url = config.get_cloud(self.kamaki_cloud, "url")
self.logger.debug("Authentication URL is %s" % _green(auth_url))
token = config.get_cloud(self.kamaki_cloud, "token")
#self.logger.debug("Token is %s" % _green(token))
# self.logger.debug("Token is %s" % _green(token))
self.astakos_client = AstakosClient(auth_url, token)
endpoints = self.astakos_client.authenticate()
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment