_QUEUE_DIR = '/var/lib/invirt-dev/queue'
_REPO_DIR = '/srv/git'
_LOG_DIR = '/var/log/invirt/builds'
-_HOOKS_DIR = '/usr/share/invirt-dev/build.d'
+_HOOKS_DIR = '/usr/share/invirt-dev/build-hooks'
class InvalidBuild(ValueError):
"""Return the path to the git repo for a given package."""
return os.path.join(_REPO_DIR, 'invirt/packages', '%s.git' % package)
+def ensureValidPackage(package):
+ """Perform some basic sanity checks that the requested repo is in a
+ subdirectory of _REPO_DIR/invirt/packages. This prevents weirdness
+ such as submitting a package like '../prod/...git'. Also ensures that
+ the repo exists."""
+ # TODO: this might be easier just to regex
+ repo = os.path.abspath(getRepo(package))
+ parent_dir = os.path.dirname(repo)
+ prefix = os.path.join(_REPO_DIR, 'invirt/packages')
+ if not parent_dir.startswith(prefix):
+ raise InvalidBuild('Invalid package name %s' % package)
+ elif not os.path.exists(repo):
+ raise InvalidBuild('Nonexisting package %s' % package)
+
+def canonicalize_commit(package, commit, shorten=False):
+ if shorten:
+ flags = ['--short']
+ else:
+ flags = []
+ return c.captureOutput(['git', 'rev-parse'] + flags + [commit],
+ cwd=getRepo(package)).strip()
def pocketToGit(pocket):
"""Map a pocket in the configuration to a git branch."""
- return config.git.pockets[pocket].get('git', pocket)
+ return getattr(getattr(config.build.pockets, pocket), 'git', pocket)
def pocketToApt(pocket):
"""Map a pocket in the configuration to an apt repo pocket."""
- return config.git.pockets[pocket].get('apt', pocket)
+ return getattr(getattr(config.build.pockets, pocket), 'apt', pocket)
def getGitFile(package, ref, path):
"""Return the contents of a path from a git ref in a package."""
return c.captureOutput(['git', 'cat-file', 'blob', '%s:%s' % (ref, path)],
- cwd=getRepo(package))
+ cwd=getRepo(package))
def getChangelog(package, ref):
"""
return changelog.Changelog(getGitFile(package, ref, 'debian/changelog'))
+def runHook(hook, args=[], stdin_str=None):
+ """Run a named hook."""
+ hook = os.path.join(_HOOKS_DIR, hook)
+ try:
+ c.captureOutput([hook] + args, stdin_str=stdin_str)
+ except OSError:
+ pass
def getVersion(package, ref):
"""Get the version of a given package at a particular ref."""
another pocket, then this function returns that pocket. Otherwise,
it returns True.
"""
+ ensureValidPackage(package)
package_repo = getRepo(package)
new_version = getVersion(package, commit)
- for p in config.git.pockets:
+ ret = True
+
+ for p in config.build.pockets:
if p == pocket:
continue
b = pocketToGit(p)
current_commit = c.captureOutput(['git', 'rev-parse', b],
- cwd=package_repo)
+ cwd=package_repo).strip()
current_version = getVersion(package, b)
if current_version == new_version:
if current_commit == commit:
- return p
+ ret = p
else:
- raise InvalidBuild('Version %s of %s already available in '
+ raise InvalidBuild('Version %s of %s already available is in '
'pocket %s from commit %s' %
(new_version, package, p, current_commit))
- if config.git.pockets[pocket].get('allow_backtracking', False):
+ if not config.build.pockets[pocket].get('allow_backtracking', False):
branch = pocketToGit(pocket)
current_version = getVersion(package, branch)
if new_version <= current_version:
'commit currently in pocket %s' %
(commit, package, pocket))
-
+ return ret