##// END OF EJS Templates
subrepo: fix typo in help text
Jens Bäckman -
r10227:192c3958 default
parent child Browse files
Show More
@@ -1,340 +1,340 b''
1 # subrepo.py - sub-repository handling for Mercurial
1 # subrepo.py - sub-repository handling for Mercurial
2 #
2 #
3 # Copyright 2006, 2007 Matt Mackall <mpm@selenic.com>
3 # Copyright 2006, 2007 Matt Mackall <mpm@selenic.com>
4 #
4 #
5 # This software may be used and distributed according to the terms of the
5 # This software may be used and distributed according to the terms of the
6 # GNU General Public License version 2, incorporated herein by reference.
6 # GNU General Public License version 2, incorporated herein by reference.
7
7
8 import errno, os, re
8 import errno, os, re
9 from i18n import _
9 from i18n import _
10 import config, util, node, error
10 import config, util, node, error
11 hg = None
11 hg = None
12
12
13 nullstate = ('', '', 'empty')
13 nullstate = ('', '', 'empty')
14
14
15 def state(ctx):
15 def state(ctx):
16 p = config.config()
16 p = config.config()
17 def read(f, sections=None, remap=None):
17 def read(f, sections=None, remap=None):
18 if f in ctx:
18 if f in ctx:
19 p.parse(f, ctx[f].data(), sections, remap, read)
19 p.parse(f, ctx[f].data(), sections, remap, read)
20 else:
20 else:
21 raise util.Abort(_("subrepo spec file %s not found") % f)
21 raise util.Abort(_("subrepo spec file %s not found") % f)
22
22
23 if '.hgsub' in ctx:
23 if '.hgsub' in ctx:
24 read('.hgsub')
24 read('.hgsub')
25
25
26 rev = {}
26 rev = {}
27 if '.hgsubstate' in ctx:
27 if '.hgsubstate' in ctx:
28 try:
28 try:
29 for l in ctx['.hgsubstate'].data().splitlines():
29 for l in ctx['.hgsubstate'].data().splitlines():
30 revision, path = l.split(" ", 1)
30 revision, path = l.split(" ", 1)
31 rev[path] = revision
31 rev[path] = revision
32 except IOError, err:
32 except IOError, err:
33 if err.errno != errno.ENOENT:
33 if err.errno != errno.ENOENT:
34 raise
34 raise
35
35
36 state = {}
36 state = {}
37 for path, src in p[''].items():
37 for path, src in p[''].items():
38 kind = 'hg'
38 kind = 'hg'
39 if src.startswith('['):
39 if src.startswith('['):
40 if ']' not in src:
40 if ']' not in src:
41 raise util.Abort(_('missing ] in subrepo source'))
41 raise util.Abort(_('missing ] in subrepo source'))
42 kind, src = src.split(']', 1)
42 kind, src = src.split(']', 1)
43 kind = kind[1:]
43 kind = kind[1:]
44 state[path] = (src, rev.get(path, ''), kind)
44 state[path] = (src, rev.get(path, ''), kind)
45
45
46 return state
46 return state
47
47
48 def writestate(repo, state):
48 def writestate(repo, state):
49 repo.wwrite('.hgsubstate',
49 repo.wwrite('.hgsubstate',
50 ''.join(['%s %s\n' % (state[s][1], s)
50 ''.join(['%s %s\n' % (state[s][1], s)
51 for s in sorted(state)]), '')
51 for s in sorted(state)]), '')
52
52
53 def submerge(repo, wctx, mctx, actx):
53 def submerge(repo, wctx, mctx, actx):
54 # working context, merging context, ancestor context
54 # working context, merging context, ancestor context
55 if mctx == actx: # backwards?
55 if mctx == actx: # backwards?
56 actx = wctx.p1()
56 actx = wctx.p1()
57 s1 = wctx.substate
57 s1 = wctx.substate
58 s2 = mctx.substate
58 s2 = mctx.substate
59 sa = actx.substate
59 sa = actx.substate
60 sm = {}
60 sm = {}
61
61
62 repo.ui.debug("subrepo merge %s %s %s\n" % (wctx, mctx, actx))
62 repo.ui.debug("subrepo merge %s %s %s\n" % (wctx, mctx, actx))
63
63
64 def debug(s, msg, r=""):
64 def debug(s, msg, r=""):
65 if r:
65 if r:
66 r = "%s:%s:%s" % r
66 r = "%s:%s:%s" % r
67 repo.ui.debug(" subrepo %s: %s %s\n" % (s, msg, r))
67 repo.ui.debug(" subrepo %s: %s %s\n" % (s, msg, r))
68
68
69 for s, l in s1.items():
69 for s, l in s1.items():
70 if wctx != actx and wctx.sub(s).dirty():
70 if wctx != actx and wctx.sub(s).dirty():
71 l = (l[0], l[1] + "+")
71 l = (l[0], l[1] + "+")
72 a = sa.get(s, nullstate)
72 a = sa.get(s, nullstate)
73 if s in s2:
73 if s in s2:
74 r = s2[s]
74 r = s2[s]
75 if l == r or r == a: # no change or local is newer
75 if l == r or r == a: # no change or local is newer
76 sm[s] = l
76 sm[s] = l
77 continue
77 continue
78 elif l == a: # other side changed
78 elif l == a: # other side changed
79 debug(s, "other changed, get", r)
79 debug(s, "other changed, get", r)
80 wctx.sub(s).get(r)
80 wctx.sub(s).get(r)
81 sm[s] = r
81 sm[s] = r
82 elif l[0] != r[0]: # sources differ
82 elif l[0] != r[0]: # sources differ
83 if repo.ui.promptchoice(
83 if repo.ui.promptchoice(
84 _(' subrepository sources for %s differ\n'
84 _(' subrepository sources for %s differ\n'
85 'use (l)ocal source (%s) or (r)emote source (%s)?')
85 'use (l)ocal source (%s) or (r)emote source (%s)?')
86 % (s, l[0], r[0]),
86 % (s, l[0], r[0]),
87 (_('&Local'), _('&Remote')), 0):
87 (_('&Local'), _('&Remote')), 0):
88 debug(s, "prompt changed, get", r)
88 debug(s, "prompt changed, get", r)
89 wctx.sub(s).get(r)
89 wctx.sub(s).get(r)
90 sm[s] = r
90 sm[s] = r
91 elif l[1] == a[1]: # local side is unchanged
91 elif l[1] == a[1]: # local side is unchanged
92 debug(s, "other side changed, get", r)
92 debug(s, "other side changed, get", r)
93 wctx.sub(s).get(r)
93 wctx.sub(s).get(r)
94 sm[s] = r
94 sm[s] = r
95 else:
95 else:
96 debug(s, "both sides changed, merge with", r)
96 debug(s, "both sides changed, merge with", r)
97 wctx.sub(s).merge(r)
97 wctx.sub(s).merge(r)
98 sm[s] = l
98 sm[s] = l
99 elif l == a: # remote removed, local unchanged
99 elif l == a: # remote removed, local unchanged
100 debug(s, "remote removed, remove")
100 debug(s, "remote removed, remove")
101 wctx.sub(s).remove()
101 wctx.sub(s).remove()
102 else:
102 else:
103 if repo.ui.promptchoice(
103 if repo.ui.promptchoice(
104 _(' local changed subrepository %s which remote removed\n'
104 _(' local changed subrepository %s which remote removed\n'
105 'use (c)hanged version or (d)elete?') % s,
105 'use (c)hanged version or (d)elete?') % s,
106 (_('&Changed'), _('&Delete')), 0):
106 (_('&Changed'), _('&Delete')), 0):
107 debug(s, "prompt remove")
107 debug(s, "prompt remove")
108 wctx.sub(s).remove()
108 wctx.sub(s).remove()
109
109
110 for s, r in s2.items():
110 for s, r in s2.items():
111 if s in s1:
111 if s in s1:
112 continue
112 continue
113 elif s not in sa:
113 elif s not in sa:
114 debug(s, "remote added, get", r)
114 debug(s, "remote added, get", r)
115 mctx.sub(s).get(r)
115 mctx.sub(s).get(r)
116 sm[s] = r
116 sm[s] = r
117 elif r != sa[s]:
117 elif r != sa[s]:
118 if repo.ui.promptchoice(
118 if repo.ui.promptchoice(
119 _(' remote changed subrepository %s which local removed\n'
119 _(' remote changed subrepository %s which local removed\n'
120 'use (c)hanged version or (d)elete?') % s,
120 'use (c)hanged version or (d)elete?') % s,
121 (_('&Changed'), _('&Delete')), 0) == 0:
121 (_('&Changed'), _('&Delete')), 0) == 0:
122 debug(s, "prompt recreate", r)
122 debug(s, "prompt recreate", r)
123 wctx.sub(s).get(r)
123 wctx.sub(s).get(r)
124 sm[s] = r
124 sm[s] = r
125
125
126 # record merged .hgsubstate
126 # record merged .hgsubstate
127 writestate(repo, sm)
127 writestate(repo, sm)
128
128
129 def _abssource(repo, push=False):
129 def _abssource(repo, push=False):
130 if hasattr(repo, '_subparent'):
130 if hasattr(repo, '_subparent'):
131 source = repo._subsource
131 source = repo._subsource
132 if source.startswith('/') or '://' in source:
132 if source.startswith('/') or '://' in source:
133 return source
133 return source
134 parent = _abssource(repo._subparent)
134 parent = _abssource(repo._subparent)
135 if '://' in parent:
135 if '://' in parent:
136 if parent[-1] == '/':
136 if parent[-1] == '/':
137 parent = parent[:-1]
137 parent = parent[:-1]
138 return parent + '/' + source
138 return parent + '/' + source
139 return os.path.join(parent, repo._subsource)
139 return os.path.join(parent, repo._subsource)
140 if push and repo.ui.config('paths', 'default-push'):
140 if push and repo.ui.config('paths', 'default-push'):
141 return repo.ui.config('paths', 'default-push', repo.root)
141 return repo.ui.config('paths', 'default-push', repo.root)
142 return repo.ui.config('paths', 'default', repo.root)
142 return repo.ui.config('paths', 'default', repo.root)
143
143
144 def subrepo(ctx, path):
144 def subrepo(ctx, path):
145 # subrepo inherently violates our import layering rules
145 # subrepo inherently violates our import layering rules
146 # because it wants to make repo objects from deep inside the stack
146 # because it wants to make repo objects from deep inside the stack
147 # so we manually delay the circular imports to not break
147 # so we manually delay the circular imports to not break
148 # scripts that don't use our demand-loading
148 # scripts that don't use our demand-loading
149 global hg
149 global hg
150 import hg as h
150 import hg as h
151 hg = h
151 hg = h
152
152
153 util.path_auditor(ctx._repo.root)(path)
153 util.path_auditor(ctx._repo.root)(path)
154 state = ctx.substate.get(path, nullstate)
154 state = ctx.substate.get(path, nullstate)
155 if state[2] not in types:
155 if state[2] not in types:
156 raise util.Abort(_('unknown subrepo type %s') % t)
156 raise util.Abort(_('unknown subrepo type %s') % t)
157 return types[state[2]](ctx, path, state[:2])
157 return types[state[2]](ctx, path, state[:2])
158
158
159 # subrepo classes need to implement the following methods:
159 # subrepo classes need to implement the following methods:
160 # __init__(self, ctx, path, state)
160 # __init__(self, ctx, path, state)
161 # dirty(self): returns true if the dirstate of the subrepo
161 # dirty(self): returns true if the dirstate of the subrepo
162 # does not match current stored state
162 # does not match current stored state
163 # commit(self, text, user, date): commit the current changes
163 # commit(self, text, user, date): commit the current changes
164 # to the subrepo with the given log message. Use given
164 # to the subrepo with the given log message. Use given
165 # user and date if possible. Return the new state of the subrepo.
165 # user and date if possible. Return the new state of the subrepo.
166 # remove(self): remove the subrepo (should verify the dirstate
166 # remove(self): remove the subrepo (should verify the dirstate
167 # is not dirty first)
167 # is not dirty first)
168 # get(self, state): run whatever commands are needed to put the
168 # get(self, state): run whatever commands are needed to put the
169 # subrepo into this state
169 # subrepo into this state
170 # merge(self, state): merge currently-saved state with the new state.
170 # merge(self, state): merge currently-saved state with the new state.
171 # push(self, force): perform whatever action is analagous to 'hg push'
171 # push(self, force): perform whatever action is analagous to 'hg push'
172 # This may be a no-op on some systems.
172 # This may be a no-op on some systems.
173
173
174 class hgsubrepo(object):
174 class hgsubrepo(object):
175 def __init__(self, ctx, path, state):
175 def __init__(self, ctx, path, state):
176 self._path = path
176 self._path = path
177 self._state = state
177 self._state = state
178 r = ctx._repo
178 r = ctx._repo
179 root = r.wjoin(path)
179 root = r.wjoin(path)
180 if os.path.exists(os.path.join(root, '.hg')):
180 if os.path.exists(os.path.join(root, '.hg')):
181 self._repo = hg.repository(r.ui, root)
181 self._repo = hg.repository(r.ui, root)
182 else:
182 else:
183 util.makedirs(root)
183 util.makedirs(root)
184 self._repo = hg.repository(r.ui, root, create=True)
184 self._repo = hg.repository(r.ui, root, create=True)
185 f = file(os.path.join(root, '.hg', 'hgrc'), 'w')
185 f = file(os.path.join(root, '.hg', 'hgrc'), 'w')
186 f.write('[paths]\ndefault = %s\n' % state[0])
186 f.write('[paths]\ndefault = %s\n' % state[0])
187 f.close()
187 f.close()
188 self._repo._subparent = r
188 self._repo._subparent = r
189 self._repo._subsource = state[0]
189 self._repo._subsource = state[0]
190
190
191 def dirty(self):
191 def dirty(self):
192 r = self._state[1]
192 r = self._state[1]
193 if r == '':
193 if r == '':
194 return True
194 return True
195 w = self._repo[None]
195 w = self._repo[None]
196 if w.p1() != self._repo[r]: # version checked out changed
196 if w.p1() != self._repo[r]: # version checked out changed
197 return True
197 return True
198 return w.dirty() # working directory changed
198 return w.dirty() # working directory changed
199
199
200 def commit(self, text, user, date):
200 def commit(self, text, user, date):
201 self._repo.ui.debug("committing subrepo %s\n" % self._path)
201 self._repo.ui.debug("committing subrepo %s\n" % self._path)
202 n = self._repo.commit(text, user, date)
202 n = self._repo.commit(text, user, date)
203 if not n:
203 if not n:
204 return self._repo['.'].hex() # different version checked out
204 return self._repo['.'].hex() # different version checked out
205 return node.hex(n)
205 return node.hex(n)
206
206
207 def remove(self):
207 def remove(self):
208 # we can't fully delete the repository as it may contain
208 # we can't fully delete the repository as it may contain
209 # local-only history
209 # local-only history
210 self._repo.ui.note(_('removing subrepo %s\n') % self._path)
210 self._repo.ui.note(_('removing subrepo %s\n') % self._path)
211 hg.clean(self._repo, node.nullid, False)
211 hg.clean(self._repo, node.nullid, False)
212
212
213 def _get(self, state):
213 def _get(self, state):
214 source, revision, kind = state
214 source, revision, kind = state
215 try:
215 try:
216 self._repo.lookup(revision)
216 self._repo.lookup(revision)
217 except error.RepoError:
217 except error.RepoError:
218 self._repo._subsource = source
218 self._repo._subsource = source
219 self._repo.ui.status(_('pulling subrepo %s\n') % self._path)
219 self._repo.ui.status(_('pulling subrepo %s\n') % self._path)
220 srcurl = _abssource(self._repo)
220 srcurl = _abssource(self._repo)
221 other = hg.repository(self._repo.ui, srcurl)
221 other = hg.repository(self._repo.ui, srcurl)
222 self._repo.pull(other)
222 self._repo.pull(other)
223
223
224 def get(self, state):
224 def get(self, state):
225 self._get(state)
225 self._get(state)
226 source, revision, kind = state
226 source, revision, kind = state
227 self._repo.ui.debug("getting subrepo %s\n" % self._path)
227 self._repo.ui.debug("getting subrepo %s\n" % self._path)
228 hg.clean(self._repo, revision, False)
228 hg.clean(self._repo, revision, False)
229
229
230 def merge(self, state):
230 def merge(self, state):
231 self._get(state)
231 self._get(state)
232 cur = self._repo['.']
232 cur = self._repo['.']
233 dst = self._repo[state[1]]
233 dst = self._repo[state[1]]
234 if dst.ancestor(cur) == cur:
234 if dst.ancestor(cur) == cur:
235 self._repo.ui.debug("updating subrepo %s\n" % self._path)
235 self._repo.ui.debug("updating subrepo %s\n" % self._path)
236 hg.update(self._repo, state[1])
236 hg.update(self._repo, state[1])
237 else:
237 else:
238 self._repo.ui.debug("merging subrepo %s\n" % self._path)
238 self._repo.ui.debug("merging subrepo %s\n" % self._path)
239 hg.merge(self._repo, state[1], remind=False)
239 hg.merge(self._repo, state[1], remind=False)
240
240
241 def push(self, force):
241 def push(self, force):
242 # push subrepos depth-first for coherent ordering
242 # push subrepos depth-first for coherent ordering
243 c = self._repo['']
243 c = self._repo['']
244 subs = c.substate # only repos that are committed
244 subs = c.substate # only repos that are committed
245 for s in sorted(subs):
245 for s in sorted(subs):
246 c.sub(s).push(force)
246 c.sub(s).push(force)
247
247
248 self._repo.ui.status(_('pushing subrepo %s\n') % self._path)
248 self._repo.ui.status(_('pushing subrepo %s\n') % self._path)
249 dsturl = _abssource(self._repo, True)
249 dsturl = _abssource(self._repo, True)
250 other = hg.repository(self._repo.ui, dsturl)
250 other = hg.repository(self._repo.ui, dsturl)
251 self._repo.push(other, force)
251 self._repo.push(other, force)
252
252
253 class svnsubrepo(object):
253 class svnsubrepo(object):
254 def __init__(self, ctx, path, state):
254 def __init__(self, ctx, path, state):
255 self._path = path
255 self._path = path
256 self._state = state
256 self._state = state
257 self._ctx = ctx
257 self._ctx = ctx
258 self._ui = ctx._repo.ui
258 self._ui = ctx._repo.ui
259
259
260 def _svncommand(self, commands):
260 def _svncommand(self, commands):
261 cmd = ['svn'] + commands + [self._path]
261 cmd = ['svn'] + commands + [self._path]
262 cmd = [util.shellquote(arg) for arg in cmd]
262 cmd = [util.shellquote(arg) for arg in cmd]
263 cmd = util.quotecommand(' '.join(cmd))
263 cmd = util.quotecommand(' '.join(cmd))
264 env = dict(os.environ)
264 env = dict(os.environ)
265 for k in ('LANGUAGE', 'LANG', 'LC_ALL', 'LC_MESSAGES'):
265 for k in ('LANGUAGE', 'LANG', 'LC_ALL', 'LC_MESSAGES'):
266 env[k] = 'en_US.UTF-8'
266 env[k] = 'en_US.UTF-8'
267 write, read, err = util.popen3(cmd, env=env, newlines=True)
267 write, read, err = util.popen3(cmd, env=env, newlines=True)
268 retdata = read.read()
268 retdata = read.read()
269 err = err.read().strip()
269 err = err.read().strip()
270 if err:
270 if err:
271 raise util.Abort(err)
271 raise util.Abort(err)
272 return retdata
272 return retdata
273
273
274 def _wcrev(self):
274 def _wcrev(self):
275 info = self._svncommand(['info'])
275 info = self._svncommand(['info'])
276 mat = re.search('Revision: ([\d]+)\n', info)
276 mat = re.search('Revision: ([\d]+)\n', info)
277 if not mat:
277 if not mat:
278 return 0
278 return 0
279 return mat.groups()[0]
279 return mat.groups()[0]
280
280
281 def _url(self):
281 def _url(self):
282 info = self._svncommand(['info'])
282 info = self._svncommand(['info'])
283 mat = re.search('URL: ([^\n]+)\n', info)
283 mat = re.search('URL: ([^\n]+)\n', info)
284 if not mat:
284 if not mat:
285 return 0
285 return 0
286 return mat.groups()[0]
286 return mat.groups()[0]
287
287
288 def _wcclean(self):
288 def _wcclean(self):
289 status = self._svncommand(['status'])
289 status = self._svncommand(['status'])
290 status = '\n'.join([s for s in status.splitlines() if s[0] != '?'])
290 status = '\n'.join([s for s in status.splitlines() if s[0] != '?'])
291 if status.strip():
291 if status.strip():
292 return False
292 return False
293 return True
293 return True
294
294
295 def dirty(self):
295 def dirty(self):
296 if self._wcrev() == self._state[1] and self._wcclean():
296 if self._wcrev() == self._state[1] and self._wcclean():
297 return False
297 return False
298 return True
298 return True
299
299
300 def commit(self, text, user, date):
300 def commit(self, text, user, date):
301 # user and date are out of our hands since svn is centralized
301 # user and date are out of our hands since svn is centralized
302 if self._wcclean():
302 if self._wcclean():
303 return self._wcrev()
303 return self._wcrev()
304 commitinfo = self._svncommand(['commit', '-m', text])
304 commitinfo = self._svncommand(['commit', '-m', text])
305 self._ui.status(commitinfo)
305 self._ui.status(commitinfo)
306 newrev = re.search('Committed revision ([\d]+).', commitinfo)
306 newrev = re.search('Committed revision ([\d]+).', commitinfo)
307 if not newrev:
307 if not newrev:
308 raise util.Abort(commitinfo.splitlines()[-1])
308 raise util.Abort(commitinfo.splitlines()[-1])
309 newrev = newrev.groups()[0]
309 newrev = newrev.groups()[0]
310 self._ui.status(self._svncommand(['update', '-r', newrev]))
310 self._ui.status(self._svncommand(['update', '-r', newrev]))
311 return newrev
311 return newrev
312
312
313 def remove(self):
313 def remove(self):
314 if self.dirty():
314 if self.dirty():
315 self._repo.ui.warn(_('not removing repo %s because'
315 self._repo.ui.warn(_('not removing repo %s because '
316 'it has changes.\n' % self._path))
316 'it has changes.\n' % self._path))
317 return
317 return
318 self._repo.ui.note('removing subrepo %s\n' % self._path)
318 self._repo.ui.note('removing subrepo %s\n' % self._path)
319 shutil.rmtree(self._ctx.repo.join(self._path))
319 shutil.rmtree(self._ctx.repo.join(self._path))
320
320
321 def get(self, state):
321 def get(self, state):
322 status = self._svncommand(['checkout', state[0], '--revision', state[1]])
322 status = self._svncommand(['checkout', state[0], '--revision', state[1]])
323 if not re.search('Checked out revision [\d]+.', status):
323 if not re.search('Checked out revision [\d]+.', status):
324 raise util.Abort(status.splitlines()[-1])
324 raise util.Abort(status.splitlines()[-1])
325 self._ui.status(status)
325 self._ui.status(status)
326
326
327 def merge(self, state):
327 def merge(self, state):
328 old = int(self._state[1])
328 old = int(self._state[1])
329 new = int(state[1])
329 new = int(state[1])
330 if new > old:
330 if new > old:
331 self.get(state)
331 self.get(state)
332
332
333 def push(self, force):
333 def push(self, force):
334 # nothing for svn
334 # nothing for svn
335 pass
335 pass
336
336
337 types = {
337 types = {
338 'hg': hgsubrepo,
338 'hg': hgsubrepo,
339 'svn': svnsubrepo,
339 'svn': svnsubrepo,
340 }
340 }
General Comments 0
You need to be logged in to leave comments. Login now