X-Git-Url: https://git.ralfj.de/mass-build.git/blobdiff_plain/1c97a041534e9aacaba12939729eb1ab3ea3d798..e724c8e09f8d987d431db7d463624ee697e9e855:/vcs.py?ds=inline diff --git a/vcs.py b/vcs.py index 73ffb10..8d8d836 100644 --- a/vcs.py +++ b/vcs.py @@ -1,5 +1,5 @@ # mass-build - Easily Build Software Involving a Large Amount of Source Repositories -# Copyright (C) 2012 Ralf Jung +# Copyright (C) 2012-2013 Ralf Jung # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by @@ -15,7 +15,7 @@ # along with this program; if not, write to the Free Software # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. -import os, git, subprocess, re +import os, subprocess, re '''A VCS must have an "update" method with an optional "mode" parameter taking one of the three values below, a "version" method returning a version name (or None), @@ -30,6 +30,18 @@ def natural_sort_key(val): def get_non_digit_prefix(val): return re.match('[^0-9]*', val).group(0) +class GitCommand: + def __getattr__(self, name): + def call(*args): + cmd = ["git", name.replace('_', '-')] + list(args) + p = subprocess.Popen(cmd, stdout=subprocess.PIPE) # TODO use with + (stdout, stderr) = p.communicate() + if p.returncode != 0: + raise Exception("Running %s returned non-zero exit code %d" % (str(cmd), p.returncode)) + return filter(len, stdout.split('\n')) # return list of non-empty lines + return call +git = GitCommand() + # Fetch updates from git class Git: def __init__(self, folder, config): @@ -37,10 +49,6 @@ class Git: self.url = config['url'] self.commit = config['version'] - class _ProgressPrinter(git.remote.RemoteProgress): - def update(self, op_code, cur_count, max_count=None, message=''): - print self._cur_line+(" "*30)+"\r", - def update(self, mode = MODE_REBASE): isBranch = (self.commit.startswith('origin/')) if isBranch: @@ -50,36 +58,33 @@ class Git: # get us a git repository, and the "origin" remote if os.path.exists(self.folder): # load existing repo - repo = git.Repo(self.folder) - origin = repo.remotes.origin - origin.config_writer.set_value("url", self.url) # make sure we use the current URL + os.chdir(self.folder) + git.remote("set-url", "origin", self.url) # make sure we use the current URL else: # create a new one os.makedirs(self.folder) - repo = git.Repo.init(self.folder) - origin = repo.create_remote('origin', self.url) - origin.fetch(progress=Git._ProgressPrinter()) # download new data - print " "*80+"\r", # clean the line we are in + os.chdir(self.folder) + git.init() + git.remote("add", "origin", self.url) + git.fetch("origin") if mode == MODE_FETCH: return # create/find correct branch - if branchname in repo.heads: - branch = repo.heads[branchname] - else: - branch = repo.create_head(branchname, self.commit) - if isBranch: # track remote branch - branch.set_tracking_branch(origin.refs[branchname]) + if not git.branch("--list", branchname): # the branch does not yet exit + git.branch(branchname, self.commit) + if isBranch: # make sure we track remote branch + git.branch("-u", self.commit, branchname) # update it to the latest remote commit - branch.checkout() + git.checkout(branchname) if mode == MODE_RESET: - repo.head.reset(self.commit, working_tree=True) + git.reset("--hard", self.commit) else: - repo.git.rebase(self.commit) + git.rebase(self.commit) # update submodules - repo.git.submodule("update", "--init", "--recursive", "--rebase") + git.submodule("update", "--init", "--recursive", "--rebase") # done print "...done", - if repo.head.reference.commit != repo.commit(self.commit): + if git.rev_parse("HEAD")[0] != git.rev_parse(self.commit)[0]: print "(keeping local patches around)", print @@ -90,10 +95,9 @@ class Git: def checkVersions(self): self.update(mode = MODE_FETCH) - repo = git.Repo(self.folder) - currentVersion = repo.git.describe() + currentVersion = git.describe()[0] # get sorted list of tag names with the same non-digit prefix and higher version number - tags = map(str, repo.tags) + tags = git.tag() tags = filter(lambda t: get_non_digit_prefix(t) == get_non_digit_prefix(currentVersion) and natural_sort_key(t) > natural_sort_key(currentVersion), tags) if not tags: return tags.sort(key = natural_sort_key)