Left: | ||
Right: |
OLD | NEW |
---|---|
1 #!/usr/bin/env python | 1 #!/usr/bin/env python |
2 # coding: utf-8 | 2 # coding: utf-8 |
3 | 3 |
4 # This Source Code Form is subject to the terms of the Mozilla Public | 4 # This Source Code Form is subject to the terms of the Mozilla Public |
5 # License, v. 2.0. If a copy of the MPL was not distributed with this | 5 # License, v. 2.0. If a copy of the MPL was not distributed with this |
6 # file, You can obtain one at http://mozilla.org/MPL/2.0/. | 6 # file, You can obtain one at http://mozilla.org/MPL/2.0/. |
7 | 7 |
8 import sys | 8 import sys |
9 import os | 9 import os |
10 import posixpath | 10 import posixpath |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
72 if not config.has_section("ui"): | 72 if not config.has_section("ui"): |
73 config.add_section("ui") | 73 config.add_section("ui") |
74 | 74 |
75 config.set("ui", "ignore.dependencies", ignore_path) | 75 config.set("ui", "ignore.dependencies", ignore_path) |
76 with open(config_path, "w") as stream: | 76 with open(config_path, "w") as stream: |
77 config.write(stream) | 77 config.write(stream) |
78 | 78 |
79 module = os.path.relpath(target, repo) | 79 module = os.path.relpath(target, repo) |
80 _ensure_line_exists(ignore_path, module) | 80 _ensure_line_exists(ignore_path, module) |
81 | 81 |
82 def postprocess_url(self, url): | |
83 return url | |
84 | |
82 class Git(): | 85 class Git(): |
83 def istype(self, repodir): | 86 def istype(self, repodir): |
84 return os.path.exists(os.path.join(repodir, ".git")) | 87 return os.path.exists(os.path.join(repodir, ".git")) |
85 | 88 |
86 def clone(self, source, target): | 89 def clone(self, source, target): |
87 source = source.rstrip("/") | 90 source = source.rstrip("/") |
88 if not source.endswith(".git"): | 91 if not source.endswith(".git"): |
89 source += ".git" | 92 source += ".git" |
90 subprocess.check_call(["git", "clone", "--quiet", source, target]) | 93 subprocess.check_call(["git", "clone", "--quiet", source, target]) |
91 | 94 |
92 def get_revision_id(self, repo, rev="HEAD"): | 95 def get_revision_id(self, repo, rev="HEAD"): |
93 command = ["git", "rev-parse", "--revs-only", rev + '^{commit}'] | 96 command = ["git", "rev-parse", "--revs-only", rev + '^{commit}'] |
94 return subprocess.check_output(command, cwd=repo).strip() | 97 return subprocess.check_output(command, cwd=repo).strip() |
95 | 98 |
96 def pull(self, repo): | 99 def pull(self, repo): |
97 subprocess.check_call(["git", "fetch", "--quiet", "--all", "--tags"], cwd=re po) | 100 subprocess.check_call(["git", "fetch", "--quiet", "--all", "--tags"], cwd=re po) |
98 | 101 |
99 def update(self, repo, rev): | 102 def update(self, repo, rev): |
100 subprocess.check_call(["git", "checkout", "--quiet", rev], cwd=repo) | 103 subprocess.check_call(["git", "checkout", "--quiet", rev], cwd=repo) |
101 | 104 |
102 def ignore(self, target, repo): | 105 def ignore(self, target, repo): |
103 module = os.path.relpath(target, repo) | 106 module = os.path.relpath(target, repo) |
104 exclude_file = os.path.join(repo, ".git", "info", "exclude") | 107 exclude_file = os.path.join(repo, ".git", "info", "exclude") |
105 _ensure_line_exists(exclude_file, module) | 108 _ensure_line_exists(exclude_file, module) |
106 | 109 |
110 def postprocess_url(self, url): | |
111 # Handle alternative syntax of SSH URLS | |
112 if "@" in url and ":" in url and not urlparse.urlsplit(url).scheme: | |
113 return "ssh://" + url.replace(":", "/", 1) | |
Sebastian Noack
2015/04/30 13:34:36
How does git URLs specify ports?
kzar
2015/04/30 14:45:29
Apparently they can't, you have to specify non-sta
| |
114 return url | |
115 | |
107 repo_types = OrderedDict(( | 116 repo_types = OrderedDict(( |
108 ("hg", Mercurial()), | 117 ("hg", Mercurial()), |
109 ("git", Git()), | 118 ("git", Git()), |
110 )) | 119 )) |
111 | 120 |
112 def parse_spec(path, line): | 121 def parse_spec(path, line): |
113 if "=" not in line: | 122 if "=" not in line: |
114 logging.warning("Invalid line in file %s: %s" % (path, line)) | 123 logging.warning("Invalid line in file %s: %s" % (path, line)) |
115 return None, None | 124 return None, None |
116 | 125 |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
180 return | 189 return |
181 | 190 |
182 parenttype = get_repo_type(parentrepo) | 191 parenttype = get_repo_type(parentrepo) |
183 type = None | 192 type = None |
184 for key in roots: | 193 for key in roots: |
185 if key == parenttype or (key in repo_types and type is None): | 194 if key == parenttype or (key in repo_types and type is None): |
186 type = key | 195 type = key |
187 if type is None: | 196 if type is None: |
188 raise Exception("No valid source found to create %s" % target) | 197 raise Exception("No valid source found to create %s" % target) |
189 | 198 |
190 if os.path.exists(roots[type]): | 199 root = repo_types[type].postprocess_url(roots[type]) |
Sebastian Noack
2015/04/30 13:34:36
Nit, don't repeat yourself:
postprocess_url = r
kzar
2015/04/30 14:45:29
Done.
Wladimir Palant
2015/04/30 15:48:30
Rather questionable advise in this context IMHO.
Sebastian Noack
2015/04/30 17:58:28
How is caching one variable lookup + one item look
Wladimir Palant
2015/04/30 18:34:07
If it provides a negligible performance gain while
Sebastian Noack
2015/04/30 18:43:31
I didn't even mention performance. "Don't repeat y
| |
191 url = os.path.join(roots[type], sourcename) | 200 sourcename = repo_types[type].postprocess_url(sourcename) |
201 | |
202 if os.path.exists(root): | |
203 url = os.path.join(root, sourcename) | |
192 else: | 204 else: |
193 url = urlparse.urljoin(roots[type], sourcename) | 205 url = urlparse.urljoin(root, sourcename) |
194 | 206 |
195 logging.info("Cloning repository %s into %s" % (url, target)) | 207 logging.info("Cloning repository %s into %s" % (url, target)) |
196 repo_types[type].clone(url, target) | 208 repo_types[type].clone(url, target) |
197 | 209 |
198 for repo in repo_types.itervalues(): | 210 for repo in repo_types.itervalues(): |
199 if repo.istype(parentrepo): | 211 if repo.istype(parentrepo): |
200 repo.ignore(target, parentrepo) | 212 repo.ignore(target, parentrepo) |
201 | 213 |
202 def update_repo(target, revisions): | 214 def update_repo(target, revisions): |
203 type = get_repo_type(target) | 215 type = get_repo_type(target) |
(...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
290 args = parser.parse_args() | 302 args = parser.parse_args() |
291 | 303 |
292 if args.quiet: | 304 if args.quiet: |
293 logging.disable(logging.INFO) | 305 logging.disable(logging.INFO) |
294 | 306 |
295 repos = args.repos | 307 repos = args.repos |
296 if not len(repos): | 308 if not len(repos): |
297 repos = [os.path.dirname(__file__)] | 309 repos = [os.path.dirname(__file__)] |
298 for repo in repos: | 310 for repo in repos: |
299 resolve_deps(repo) | 311 resolve_deps(repo) |
OLD | NEW |