Mercurial > repos > shellac > guppy_basecaller

comparison env/lib/python3.7/site-packages/planemo/git.py @ 5:9b1c78e6ba9c draft default tip

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
"planemo upload commit 6c0a8142489327ece472c84e558c47da711a9142"
author shellac
date Mon, 01 Jun 2020 08:59:25 -0400
parents 79f47841a781
children
comparison
equal deleted inserted replaced
4:79f47841a781 5:9b1c78e6ba9c
1 """Utilities for interacting with git using planemo abstractions."""
2 from __future__ import absolute_import
3
4 import os
5 import subprocess
6
7 from galaxy.util import unicodify
8
9 from planemo import io
10
11
12 def git_env_for(path):
13 """Setup env dictionary to target specified git repo with git commands."""
14 env = {
15 "GIT_WORK_DIR": path,
16 "GIT_DIR": os.path.join(path, ".git")
17 }
18 return env
19
20
21 def add(ctx, repo_path, file_path):
22 env = git_env_for(repo_path)
23 io.communicate("cd '%s' && git add '%s'" % (repo_path, os.path.abspath(file_path)), env=env)
24
25
26 def commit(ctx, repo_path, message=""):
27 env = git_env_for(repo_path)
28 io.communicate(["git", "commit", "-m", message], env=env)
29
30
31 def push(ctx, repo_path, to, branch, force=False):
32 env = git_env_for(repo_path)
33 cmd = ["git", "push"]
34 if force:
35 cmd += ["--force"]
36 cmd += [to, branch]
37 io.communicate(cmd, env=env)
38
39
40 def branch(ctx, repo_path, branch, from_branch=None):
41 env = git_env_for(repo_path)
42 cmd = ["git", "checkout", "-b", branch]
43 if from_branch is not None:
44 cmd.append(from_branch)
45 io.communicate(cmd, env=env)
46
47
48 def checkout(ctx, remote_repo, local_path, branch=None, remote="origin", from_branch="master"):
49 """Checkout a new branch from a remote repository."""
50 env = git_env_for(local_path)
51 if not os.path.exists(local_path):
52 io.communicate(command_clone(ctx, remote_repo, local_path))
53 else:
54 io.communicate(["git", "fetch", remote], env=env)
55
56 if branch:
57 io.communicate(["git", "checkout", "%s/%s" % (remote, from_branch), "-b", branch], env=env)
58 else:
59 io.communicate(["git", "merge", "--ff-only", "%s/%s" % (remote, from_branch)], env=env)
60
61
62 def command_clone(ctx, src, dest, mirror=False, branch=None):
63 """Produce a command-line string to clone a repository.
64
65 Take in ``ctx`` to allow more configurability down the road.
66 """
67 cmd = ['git', 'clone']
68 if mirror:
69 cmd.append("--mirror")
70 if branch is not None:
71 cmd.extend(["--branch", branch])
72 cmd.extend([src, dest])
73 return cmd
74
75
76 def diff(ctx, directory, range):
77 """Produce a list of diff-ed files for commit range."""
78 cmd_template = "cd '%s' && git diff --name-only '%s' --"
79 cmd = cmd_template % (directory, range)
80 stdout, _ = io.communicate(
81 cmd,
82 stdout=subprocess.PIPE, stderr=subprocess.PIPE,
83 universal_newlines=True
84 )
85 return [l.strip() for l in unicodify(stdout).splitlines() if l]
86
87
88 def clone(*args, **kwds):
89 """Clone a git repository.
90
91 See :func:`command_clone` for description of arguments.
92 """
93 command = command_clone(*args, **kwds)
94 return io.communicate(command)
95
96
97 def rev(ctx, directory):
98 """Raw revision for git directory specified.
99
100 Throws ``RuntimeError`` if not a git directory.
101 """
102 cmd_template = "cd '%s' && git rev-parse HEAD"
103 cmd = cmd_template % directory
104 stdout, _ = io.communicate(
105 cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE
106 )
107 return unicodify(stdout).strip()
108
109
110 def is_rev_dirty(ctx, directory):
111 """Check if specified git repository has uncommitted changes."""
112 return io.shell(['git', 'diff', '--quiet'], cwd=directory) != 0
113
114
115 def rev_if_git(ctx, directory):
116 """Determine git revision (or ``None``)."""
117 try:
118 the_rev = rev(ctx, directory)
119 is_dirty = is_rev_dirty(ctx, directory)
120 if is_dirty:
121 the_rev += "-dirty"
122 return the_rev
123 except RuntimeError:
124 return None