b42fcfc19a
All OpenStack charms are now directly published to the charm store on landing; switch Amulet helper to resolve charms using the charm store rather than bzr branches, removing the lag between charm changes landing and being available for other charms to use for testing. This is also important for new layered charms where the charm must be build and published prior to being consumable. Change-Id: Ie9b1f1a3a52dacdf258863d505e9f3b00b093eec
78 lines
2.6 KiB
Python
78 lines
2.6 KiB
Python
# Copyright 2014-2015 Canonical Limited.
|
|
#
|
|
# This file is part of charm-helpers.
|
|
#
|
|
# charm-helpers is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU Lesser General Public License version 3 as
|
|
# published by the Free Software Foundation.
|
|
#
|
|
# charm-helpers 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 Lesser General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU Lesser General Public License
|
|
# along with charm-helpers. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
import os
|
|
from subprocess import check_call
|
|
from charmhelpers.fetch import (
|
|
BaseFetchHandler,
|
|
UnhandledSource,
|
|
filter_installed_packages,
|
|
apt_install,
|
|
)
|
|
from charmhelpers.core.host import mkdir
|
|
|
|
|
|
if filter_installed_packages(['bzr']) != []:
|
|
apt_install(['bzr'])
|
|
if filter_installed_packages(['bzr']) != []:
|
|
raise NotImplementedError('Unable to install bzr')
|
|
|
|
|
|
class BzrUrlFetchHandler(BaseFetchHandler):
|
|
"""Handler for bazaar branches via generic and lp URLs"""
|
|
def can_handle(self, source):
|
|
url_parts = self.parse_url(source)
|
|
if url_parts.scheme not in ('bzr+ssh', 'lp', ''):
|
|
return False
|
|
elif not url_parts.scheme:
|
|
return os.path.exists(os.path.join(source, '.bzr'))
|
|
else:
|
|
return True
|
|
|
|
def branch(self, source, dest, revno=None):
|
|
if not self.can_handle(source):
|
|
raise UnhandledSource("Cannot handle {}".format(source))
|
|
cmd_opts = []
|
|
if revno:
|
|
cmd_opts += ['-r', str(revno)]
|
|
if os.path.exists(dest):
|
|
cmd = ['bzr', 'pull']
|
|
cmd += cmd_opts
|
|
cmd += ['--overwrite', '-d', dest, source]
|
|
else:
|
|
cmd = ['bzr', 'branch']
|
|
cmd += cmd_opts
|
|
cmd += [source, dest]
|
|
check_call(cmd)
|
|
|
|
def install(self, source, dest=None, revno=None):
|
|
url_parts = self.parse_url(source)
|
|
branch_name = url_parts.path.strip("/").split("/")[-1]
|
|
if dest:
|
|
dest_dir = os.path.join(dest, branch_name)
|
|
else:
|
|
dest_dir = os.path.join(os.environ.get('CHARM_DIR'), "fetched",
|
|
branch_name)
|
|
|
|
if dest and not os.path.exists(dest):
|
|
mkdir(dest, perms=0o755)
|
|
|
|
try:
|
|
self.branch(source, dest_dir, revno)
|
|
except OSError as e:
|
|
raise UnhandledSource(e.strerror)
|
|
return dest_dir
|