##// END OF EJS Templates
Merge with jeffpc
mpm@selenic.com -
r981:4f81068e merge default
parent child Browse files
Show More
@@ -1,877 +1,896 b''
1 1 # hgweb.py - web interface to a mercurial repository
2 2 #
3 3 # Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
4 4 # Copyright 2005 Matt Mackall <mpm@selenic.com>
5 5 #
6 6 # This software may be used and distributed according to the terms
7 7 # of the GNU General Public License, incorporated herein by reference.
8 8
9 9 import os, cgi, time, re, difflib, socket, sys, zlib
10 10 from mercurial.hg import *
11 11 from mercurial.ui import *
12 12
13 13 def templatepath():
14 14 for f in "templates", "../templates":
15 15 p = os.path.join(os.path.dirname(__file__), f)
16 16 if os.path.isdir(p): return p
17 17
18 18 def age(t):
19 19 def plural(t, c):
20 20 if c == 1: return t
21 21 return t + "s"
22 22 def fmt(t, c):
23 23 return "%d %s" % (c, plural(t, c))
24 24
25 25 now = time.time()
26 26 delta = max(1, int(now - t))
27 27
28 28 scales = [["second", 1],
29 29 ["minute", 60],
30 30 ["hour", 3600],
31 31 ["day", 3600 * 24],
32 32 ["week", 3600 * 24 * 7],
33 33 ["month", 3600 * 24 * 30],
34 34 ["year", 3600 * 24 * 365]]
35 35
36 36 scales.reverse()
37 37
38 38 for t, s in scales:
39 39 n = delta / s
40 40 if n >= 2 or s == 1: return fmt(t, n)
41 41
42 42 def nl2br(text):
43 43 return text.replace('\n', '<br/>\n')
44 44
45 45 def obfuscate(text):
46 46 return ''.join([ '&#%d;' % ord(c) for c in text ])
47 47
48 48 def up(p):
49 49 if p[0] != "/": p = "/" + p
50 50 if p[-1] == "/": p = p[:-1]
51 51 up = os.path.dirname(p)
52 52 if up == "/":
53 53 return "/"
54 54 return up + "/"
55 55
56 56 def httphdr(type):
57 57 sys.stdout.write('Content-type: %s\n\n' % type)
58 58
59 59 def write(*things):
60 60 for thing in things:
61 61 if hasattr(thing, "__iter__"):
62 62 for part in thing:
63 63 write(part)
64 64 else:
65 65 sys.stdout.write(str(thing))
66 66
67 def template(tmpl, filters = {}, **map):
68 while tmpl:
69 m = re.search(r"#([a-zA-Z0-9]+)((\|[a-zA-Z0-9]+)*)#", tmpl)
70 if m:
71 yield tmpl[:m.start(0)]
72 v = map.get(m.group(1), "")
73 v = callable(v) and v(**map) or v
74
75 fl = m.group(2)
76 if fl:
77 for f in fl.split("|")[1:]:
78 v = filters[f](v)
79
80 yield v
81 tmpl = tmpl[m.end(0):]
82 else:
83 yield tmpl
84 return
85
86 67 class templater:
87 68 def __init__(self, mapfile, filters = {}, defaults = {}):
88 69 self.cache = {}
89 70 self.map = {}
90 71 self.base = os.path.dirname(mapfile)
91 72 self.filters = filters
92 73 self.defaults = defaults
93 74
94 75 for l in file(mapfile):
95 76 m = re.match(r'(\S+)\s*=\s*"(.*)"$', l)
96 77 if m:
97 78 self.cache[m.group(1)] = m.group(2)
98 79 else:
99 80 m = re.match(r'(\S+)\s*=\s*(\S+)', l)
100 81 if m:
101 82 self.map[m.group(1)] = os.path.join(self.base, m.group(2))
102 83 else:
103 84 raise "unknown map entry '%s'" % l
104 85
105 86 def __call__(self, t, **map):
106 87 m = self.defaults.copy()
107 88 m.update(map)
108 89 try:
109 90 tmpl = self.cache[t]
110 91 except KeyError:
111 92 tmpl = self.cache[t] = file(self.map[t]).read()
112 return template(tmpl, self.filters, **m)
93 return self.template(tmpl, self.filters, **m)
94
95 def template(self, tmpl, filters = {}, **map):
96 while tmpl:
97 m = re.search(r"#([a-zA-Z0-9]+)((%[a-zA-Z0-9]+)*)((\|[a-zA-Z0-9]+)*)#", tmpl)
98 if m:
99 yield tmpl[:m.start(0)]
100 v = map.get(m.group(1), "")
101 v = callable(v) and v(**map) or v
102
103 format = m.group(2)
104 fl = m.group(4)
105
106 if format:
107 q = v.__iter__
108 for i in q():
109 lm = map.copy()
110 lm.update(i)
111 yield self(format[1:], **lm)
112
113 v = ""
114
115 elif fl:
116 for f in fl.split("|")[1:]:
117 v = filters[f](v)
118
119 yield v
120 tmpl = tmpl[m.end(0):]
121 else:
122 yield tmpl
123 return
113 124
114 125 def rfc822date(x):
115 126 return time.strftime("%a, %d %b %Y %H:%M:%S +0000", time.gmtime(x))
116 127
117 128 common_filters = {
118 129 "escape": cgi.escape,
119 130 "age": age,
120 131 "date": (lambda x: time.asctime(time.gmtime(x))),
121 132 "addbreaks": nl2br,
122 133 "obfuscate": obfuscate,
123 134 "short": (lambda x: x[:12]),
124 135 "firstline": (lambda x: x.splitlines(1)[0]),
125 136 "permissions": (lambda x: x and "-rwxr-xr-x" or "-rw-r--r--"),
126 137 "rfc822date": rfc822date,
127 138 }
128 139
129 140 class hgweb:
130 141
131 142 def __init__(self, path, name=None, templates=""):
132 143 self.templates = templates
133 144 self.reponame = name
134 145 self.path = path
135 146 self.mtime = -1
136 147 self.viewonly = 0
137 148
138 149 def refresh(self):
139 150 s = os.stat(os.path.join(self.path, ".hg", "00changelog.i"))
140 151 if s.st_mtime != self.mtime:
141 152 self.mtime = s.st_mtime
142 153 self.repo = repository(ui(), self.path)
143 154 self.maxchanges = self.repo.ui.config("web", "maxchanges", 10)
144 155 self.maxfiles = self.repo.ui.config("web", "maxchanges", 10)
145 156 self.allowpull = self.repo.ui.configbool("web", "allowpull", True)
146 157
147 158 def date(self, cs):
148 159 return time.asctime(time.gmtime(float(cs[2].split(' ')[0])))
149 160
150 161 def listfiles(self, files, mf):
151 162 for f in files[:self.maxfiles]:
152 163 yield self.t("filenodelink", node = hex(mf[f]), file = f)
153 164 if len(files) > self.maxfiles:
154 165 yield self.t("fileellipses")
155 166
156 167 def listfilediffs(self, files, changeset):
157 168 for f in files[:self.maxfiles]:
158 169 yield self.t("filedifflink", node = hex(changeset), file = f)
159 170 if len(files) > self.maxfiles:
160 171 yield self.t("fileellipses")
161 172
162 173 def parents(self, t1, nodes=[], rev=None,**args):
163 174 if not rev: rev = lambda x: ""
164 175 for node in nodes:
165 176 if node != nullid:
166 177 yield self.t(t1, node = hex(node), rev = rev(node), **args)
167 178
168 179 def showtag(self, t1, node=nullid, **args):
169 180 for t in self.repo.nodetags(node):
170 181 yield self.t(t1, tag = t, **args)
171 182
172 183 def diff(self, node1, node2, files):
173 184 def filterfiles(list, files):
174 185 l = [ x for x in list if x in files ]
175 186
176 187 for f in files:
177 188 if f[-1] != os.sep: f += os.sep
178 189 l += [ x for x in list if x.startswith(f) ]
179 190 return l
180 191
181 192 parity = [0]
182 193 def diffblock(diff, f, fn):
183 194 yield self.t("diffblock",
184 195 lines = prettyprintlines(diff),
185 196 parity = parity[0],
186 197 file = f,
187 198 filenode = hex(fn or nullid))
188 199 parity[0] = 1 - parity[0]
189 200
190 201 def prettyprintlines(diff):
191 202 for l in diff.splitlines(1):
192 203 if l.startswith('+'):
193 204 yield self.t("difflineplus", line = l)
194 205 elif l.startswith('-'):
195 206 yield self.t("difflineminus", line = l)
196 207 elif l.startswith('@'):
197 208 yield self.t("difflineat", line = l)
198 209 else:
199 210 yield self.t("diffline", line = l)
200 211
201 212 r = self.repo
202 213 cl = r.changelog
203 214 mf = r.manifest
204 215 change1 = cl.read(node1)
205 216 change2 = cl.read(node2)
206 217 mmap1 = mf.read(change1[0])
207 218 mmap2 = mf.read(change2[0])
208 219 date1 = self.date(change1)
209 220 date2 = self.date(change2)
210 221
211 222 c, a, d, u = r.changes(node1, node2)
212 223 if files:
213 224 c, a, d = map(lambda x: filterfiles(x, files), (c, a, d))
214 225
215 226 for f in c:
216 227 to = r.file(f).read(mmap1[f])
217 228 tn = r.file(f).read(mmap2[f])
218 229 yield diffblock(mdiff.unidiff(to, date1, tn, date2, f), f, tn)
219 230 for f in a:
220 231 to = None
221 232 tn = r.file(f).read(mmap2[f])
222 233 yield diffblock(mdiff.unidiff(to, date1, tn, date2, f), f, tn)
223 234 for f in d:
224 235 to = r.file(f).read(mmap1[f])
225 236 tn = None
226 237 yield diffblock(mdiff.unidiff(to, date1, tn, date2, f), f, tn)
227 238
228 239 def changelog(self, pos):
229 240 def changenav(**map):
230 241 def seq(factor = 1):
231 242 yield 1 * factor
232 243 yield 3 * factor
233 244 #yield 5 * factor
234 245 for f in seq(factor * 10):
235 246 yield f
236 247
237 248 l = []
238 249 for f in seq():
239 250 if f < self.maxchanges / 2: continue
240 251 if f > count: break
241 252 r = "%d" % f
242 253 if pos + f < count: l.append(("+" + r, pos + f))
243 254 if pos - f >= 0: l.insert(0, ("-" + r, pos - f))
244 255
245 yield self.t("naventry", rev = 0, label="(0)")
256 yield {"rev": 0, "label": "(0)"}
246 257
247 258 for label, rev in l:
248 yield self.t("naventry", label = label, rev = rev)
259 yield {"label": label, "rev": rev}
249 260
250 yield self.t("naventry", label="tip")
261 yield {"label": "tip", "rev": ""}
251 262
252 263 def changelist(**map):
253 264 parity = (start - end) & 1
254 265 cl = self.repo.changelog
255 266 l = [] # build a list in forward order for efficiency
256 267 for i in range(start, end):
257 268 n = cl.node(i)
258 269 changes = cl.read(n)
259 270 hn = hex(n)
260 271 t = float(changes[2].split(' ')[0])
261 272
262 l.insert(0, self.t(
263 'changelogentry',
264 parity = parity,
265 author = changes[1],
266 parent = self.parents("changelogparent",
273 l.insert(0, {
274 "parity": parity,
275 "author": changes[1],
276 "parent": self.parents("changelogparent",
267 277 cl.parents(n), cl.rev),
268 changelogtag = self.showtag("changelogtag",n),
269 manifest = hex(changes[0]),
270 desc = changes[4],
271 date = t,
272 files = self.listfilediffs(changes[3], n),
273 rev = i,
274 node = hn))
278 "changelogtag": self.showtag("changelogtag",n),
279 "manifest": hex(changes[0]),
280 "desc": changes[4],
281 "date": t,
282 "files": self.listfilediffs(changes[3], n),
283 "rev": i,
284 "node": hn})
275 285 parity = 1 - parity
276 286
277 yield l
287 for e in l: yield e
278 288
279 289 cl = self.repo.changelog
280 290 mf = cl.read(cl.tip())[0]
281 291 count = cl.count()
282 292 start = max(0, pos - self.maxchanges + 1)
283 293 end = min(count, start + self.maxchanges)
284 294 pos = end - 1
285 295
286 296 yield self.t('changelog',
287 297 changenav = changenav,
288 298 manifest = hex(mf),
289 299 rev = pos, changesets = count, entries = changelist)
290 300
291 301 def search(self, query):
292 302
293 303 def changelist(**map):
294 304 cl = self.repo.changelog
295 305 count = 0
296 306 qw = query.lower().split()
297 307
298 308 def revgen():
299 309 for i in range(cl.count() - 1, 0, -100):
300 310 l = []
301 311 for j in range(max(0, i - 100), i):
302 312 n = cl.node(j)
303 313 changes = cl.read(n)
304 314 l.insert(0, (n, j, changes))
305 315 for e in l:
306 316 yield e
307 317
308 318 for n, i, changes in revgen():
309 319 miss = 0
310 320 for q in qw:
311 321 if not (q in changes[1].lower() or
312 322 q in changes[4].lower() or
313 323 q in " ".join(changes[3][:20]).lower()):
314 324 miss = 1
315 325 break
316 326 if miss: continue
317 327
318 328 count += 1
319 329 hn = hex(n)
320 330 t = float(changes[2].split(' ')[0])
321 331
322 332 yield self.t(
323 333 'searchentry',
324 334 parity = count & 1,
325 335 author = changes[1],
326 336 parent = self.parents("changelogparent",
327 337 cl.parents(n), cl.rev),
328 338 changelogtag = self.showtag("changelogtag",n),
329 339 manifest = hex(changes[0]),
330 340 desc = changes[4],
331 341 date = t,
332 342 files = self.listfilediffs(changes[3], n),
333 343 rev = i,
334 344 node = hn)
335 345
336 346 if count >= self.maxchanges: break
337 347
338 348 cl = self.repo.changelog
339 349 mf = cl.read(cl.tip())[0]
340 350
341 351 yield self.t('search',
342 352 query = query,
343 353 manifest = hex(mf),
344 354 entries = changelist)
345 355
346 356 def changeset(self, nodeid):
347 357 n = bin(nodeid)
348 358 cl = self.repo.changelog
349 359 changes = cl.read(n)
350 360 p1 = cl.parents(n)[0]
351 361 t = float(changes[2].split(' ')[0])
352 362
353 363 files = []
354 364 mf = self.repo.manifest.read(changes[0])
355 365 for f in changes[3]:
356 366 files.append(self.t("filenodelink",
357 367 filenode = hex(mf.get(f, nullid)), file = f))
358 368
359 369 def diff(**map):
360 370 yield self.diff(p1, n, None)
361 371
362 372 yield self.t('changeset',
363 373 diff = diff,
364 374 rev = cl.rev(n),
365 375 node = nodeid,
366 376 parent = self.parents("changesetparent",
367 377 cl.parents(n), cl.rev),
368 378 changesettag = self.showtag("changesettag",n),
369 379 manifest = hex(changes[0]),
370 380 author = changes[1],
371 381 desc = changes[4],
372 382 date = t,
373 383 files = files)
374 384
375 385 def filelog(self, f, filenode):
376 386 cl = self.repo.changelog
377 387 fl = self.repo.file(f)
378 388 count = fl.count()
379 389
380 390 def entries(**map):
381 391 l = []
382 392 parity = (count - 1) & 1
383 393
384 394 for i in range(count):
385 395
386 396 n = fl.node(i)
387 397 lr = fl.linkrev(n)
388 398 cn = cl.node(lr)
389 399 cs = cl.read(cl.node(lr))
390 400 t = float(cs[2].split(' ')[0])
391 401
392 l.insert(0, self.t("filelogentry",
393 parity = parity,
394 filenode = hex(n),
395 filerev = i,
396 file = f,
397 node = hex(cn),
398 author = cs[1],
399 date = t,
400 parent = self.parents("filelogparent",
402 l.insert(0, {"parity": parity,
403 "filenode": hex(n),
404 "filerev": i,
405 "file": f,
406 "node": hex(cn),
407 "author": cs[1],
408 "date": t,
409 "parent": self.parents("filelogparent",
401 410 fl.parents(n), fl.rev, file=f),
402 desc = cs[4]))
411 "desc": cs[4]})
403 412 parity = 1 - parity
404 413
405 yield l
414 for e in l: yield e
406 415
407 416 yield self.t("filelog",
408 417 file = f,
409 418 filenode = filenode,
410 419 entries = entries)
411 420
412 421 def filerevision(self, f, node):
413 422 fl = self.repo.file(f)
414 423 n = bin(node)
415 424 text = fl.read(n)
416 425 changerev = fl.linkrev(n)
417 426 cl = self.repo.changelog
418 427 cn = cl.node(changerev)
419 428 cs = cl.read(cn)
420 429 t = float(cs[2].split(' ')[0])
421 430 mfn = cs[0]
422 431
423 432 def lines():
424 433 for l, t in enumerate(text.splitlines(1)):
425 yield self.t("fileline", line = t,
426 linenumber = "% 6d" % (l + 1),
427 parity = l & 1)
434 yield {"line": t,
435 "linenumber": "% 6d" % (l + 1),
436 "parity": l & 1}
428 437
429 438 yield self.t("filerevision", file = f,
430 439 filenode = node,
431 440 path = up(f),
432 441 text = lines(),
433 442 rev = changerev,
434 443 node = hex(cn),
435 444 manifest = hex(mfn),
436 445 author = cs[1],
437 446 date = t,
438 447 parent = self.parents("filerevparent",
439 448 fl.parents(n), fl.rev, file=f),
440 449 permissions = self.repo.manifest.readflags(mfn)[f])
441 450
442 451 def fileannotate(self, f, node):
443 452 bcache = {}
444 453 ncache = {}
445 454 fl = self.repo.file(f)
446 455 n = bin(node)
447 456 changerev = fl.linkrev(n)
448 457
449 458 cl = self.repo.changelog
450 459 cn = cl.node(changerev)
451 460 cs = cl.read(cn)
452 461 t = float(cs[2].split(' ')[0])
453 462 mfn = cs[0]
454 463
455 464 def annotate(**map):
456 465 parity = 1
457 466 last = None
458 467 for r, l in fl.annotate(n):
459 468 try:
460 469 cnode = ncache[r]
461 470 except KeyError:
462 471 cnode = ncache[r] = self.repo.changelog.node(r)
463 472
464 473 try:
465 474 name = bcache[r]
466 475 except KeyError:
467 476 cl = self.repo.changelog.read(cnode)
468 477 name = cl[1]
469 478 f = name.find('@')
470 479 if f >= 0:
471 480 name = name[:f]
472 481 f = name.find('<')
473 482 if f >= 0:
474 483 name = name[f+1:]
475 484 bcache[r] = name
476 485
477 486 if last != cnode:
478 487 parity = 1 - parity
479 488 last = cnode
480 489
481 yield self.t("annotateline",
482 parity = parity,
483 node = hex(cnode),
484 rev = r,
485 author = name,
486 file = f,
487 line = l)
490 yield {"parity": parity,
491 "node": hex(cnode),
492 "rev": r,
493 "author": name,
494 "file": f,
495 "line": l}
488 496
489 497 yield self.t("fileannotate",
490 498 file = f,
491 499 filenode = node,
492 500 annotate = annotate,
493 501 path = up(f),
494 502 rev = changerev,
495 503 node = hex(cn),
496 504 manifest = hex(mfn),
497 505 author = cs[1],
498 506 date = t,
499 507 parent = self.parents("fileannotateparent",
500 508 fl.parents(n), fl.rev, file=f),
501 509 permissions = self.repo.manifest.readflags(mfn)[f])
502 510
503 511 def manifest(self, mnode, path):
504 512 mf = self.repo.manifest.read(bin(mnode))
505 513 rev = self.repo.manifest.rev(bin(mnode))
506 514 node = self.repo.changelog.node(rev)
507 515 mff=self.repo.manifest.readflags(bin(mnode))
508 516
509 517 files = {}
510 518
511 519 p = path[1:]
512 520 l = len(p)
513 521
514 522 for f,n in mf.items():
515 523 if f[:l] != p:
516 524 continue
517 525 remain = f[l:]
518 526 if "/" in remain:
519 527 short = remain[:remain.find("/") + 1] # bleah
520 528 files[short] = (f, None)
521 529 else:
522 530 short = os.path.basename(remain)
523 531 files[short] = (f, n)
524 532
525 533 def filelist(**map):
526 534 parity = 0
527 535 fl = files.keys()
528 536 fl.sort()
529 537 for f in fl:
530 538 full, fnode = files[f]
539 if not fnode:
540 continue
541
542 yield {"file": full,
543 "manifest": mnode,
544 "filenode": hex(fnode),
545 "parity": parity,
546 "basename": f,
547 "permissions": mff[full]}
548 parity = 1 - parity
549
550 def dirlist(**map):
551 parity = 0
552 fl = files.keys()
553 fl.sort()
554 for f in fl:
555 full, fnode = files[f]
531 556 if fnode:
532 yield self.t("manifestfileentry",
533 file = full,
534 manifest = mnode,
535 filenode = hex(fnode),
536 parity = parity,
537 basename = f,
538 permissions = mff[full])
539 else:
540 yield self.t("manifestdirentry",
541 parity = parity,
542 path = os.path.join(path, f),
543 manifest = mnode, basename = f[:-1])
557 continue
558
559 yield {"parity": parity,
560 "path": os.path.join(path, f),
561 "manifest": mnode,
562 "basename": f[:-1]}
544 563 parity = 1 - parity
545 564
546 565 yield self.t("manifest",
547 566 manifest = mnode,
548 567 rev = rev,
549 568 node = hex(node),
550 569 path = path,
551 570 up = up(path),
552 entries = filelist)
571 fentries = filelist,
572 dentries = dirlist)
553 573
554 574 def tags(self):
555 575 cl = self.repo.changelog
556 576 mf = cl.read(cl.tip())[0]
557 577
558 578 i = self.repo.tagslist()
559 579 i.reverse()
560 580
561 581 def entries(**map):
562 582 parity = 0
563 583 for k,n in i:
564 yield self.t("tagentry",
565 parity = parity,
566 tag = k,
567 node = hex(n))
584 yield {"parity": parity,
585 "tag": k,
586 "node": hex(n)}
568 587 parity = 1 - parity
569 588
570 589 yield self.t("tags",
571 590 manifest = hex(mf),
572 591 entries = entries)
573 592
574 593 def filediff(self, file, changeset):
575 594 n = bin(changeset)
576 595 cl = self.repo.changelog
577 596 p1 = cl.parents(n)[0]
578 597 cs = cl.read(n)
579 598 mf = self.repo.manifest.read(cs[0])
580 599
581 600 def diff(**map):
582 601 yield self.diff(p1, n, file)
583 602
584 603 yield self.t("filediff",
585 604 file = file,
586 605 filenode = hex(mf.get(file, nullid)),
587 606 node = changeset,
588 607 rev = self.repo.changelog.rev(n),
589 608 parent = self.parents("filediffparent",
590 609 cl.parents(n), cl.rev),
591 610 diff = diff)
592 611
593 612 # add tags to things
594 613 # tags -> list of changesets corresponding to tags
595 614 # find tag, changeset, file
596 615
597 616 def run(self):
598 617 def header(**map):
599 618 yield self.t("header", **map)
600 619
601 620 def footer(**map):
602 621 yield self.t("footer", **map)
603 622
604 623 self.refresh()
605 624 args = cgi.parse()
606 625
607 626 t = self.templates or self.repo.ui.config("web", "templates",
608 627 templatepath())
609 628 m = os.path.join(t, "map")
610 629 if args.has_key('style'):
611 630 b = os.path.basename("map-" + args['style'][0])
612 631 p = os.path.join(self.templates, b)
613 632 if os.path.isfile(p): m = p
614 633
615 634 port = os.environ["SERVER_PORT"]
616 635 port = port != "80" and (":" + port) or ""
617 636 uri = os.environ["REQUEST_URI"]
618 637 if "?" in uri: uri = uri.split("?")[0]
619 638 url = "http://%s%s%s" % (os.environ["SERVER_NAME"], port, uri)
620 639
621 640 name = self.reponame or self.repo.ui.config("web", "name", os.getcwd())
622 641
623 642 self.t = templater(m, common_filters,
624 643 {"url":url,
625 644 "repo":name,
626 645 "header":header,
627 646 "footer":footer,
628 647 })
629 648
630 649 if not args.has_key('cmd'):
631 650 args['cmd'] = [self.t.cache['default'],]
632 651
633 652 if args['cmd'][0] == 'changelog':
634 653 c = self.repo.changelog.count() - 1
635 654 hi = c
636 655 if args.has_key('rev'):
637 656 hi = args['rev'][0]
638 657 try:
639 658 hi = self.repo.changelog.rev(self.repo.lookup(hi))
640 659 except RepoError:
641 660 write(self.search(hi))
642 661 return
643 662
644 663 write(self.changelog(hi))
645 664
646 665 elif args['cmd'][0] == 'changeset':
647 666 write(self.changeset(args['node'][0]))
648 667
649 668 elif args['cmd'][0] == 'manifest':
650 669 write(self.manifest(args['manifest'][0], args['path'][0]))
651 670
652 671 elif args['cmd'][0] == 'tags':
653 672 write(self.tags())
654 673
655 674 elif args['cmd'][0] == 'filediff':
656 675 write(self.filediff(args['file'][0], args['node'][0]))
657 676
658 677 elif args['cmd'][0] == 'file':
659 678 write(self.filerevision(args['file'][0], args['filenode'][0]))
660 679
661 680 elif args['cmd'][0] == 'annotate':
662 681 write(self.fileannotate(args['file'][0], args['filenode'][0]))
663 682
664 683 elif args['cmd'][0] == 'filelog':
665 684 write(self.filelog(args['file'][0], args['filenode'][0]))
666 685
667 686 elif args['cmd'][0] == 'heads':
668 687 httphdr("application/mercurial-0.1")
669 688 h = self.repo.heads()
670 689 sys.stdout.write(" ".join(map(hex, h)) + "\n")
671 690
672 691 elif args['cmd'][0] == 'branches':
673 692 httphdr("application/mercurial-0.1")
674 693 nodes = []
675 694 if args.has_key('nodes'):
676 695 nodes = map(bin, args['nodes'][0].split(" "))
677 696 for b in self.repo.branches(nodes):
678 697 sys.stdout.write(" ".join(map(hex, b)) + "\n")
679 698
680 699 elif args['cmd'][0] == 'between':
681 700 httphdr("application/mercurial-0.1")
682 701 nodes = []
683 702 if args.has_key('pairs'):
684 703 pairs = [ map(bin, p.split("-"))
685 704 for p in args['pairs'][0].split(" ") ]
686 705 for b in self.repo.between(pairs):
687 706 sys.stdout.write(" ".join(map(hex, b)) + "\n")
688 707
689 708 elif args['cmd'][0] == 'changegroup':
690 709 httphdr("application/mercurial-0.1")
691 710 nodes = []
692 711 if not self.allowpull:
693 712 return
694 713
695 714 if args.has_key('roots'):
696 715 nodes = map(bin, args['roots'][0].split(" "))
697 716
698 717 z = zlib.compressobj()
699 718 f = self.repo.changegroup(nodes)
700 719 while 1:
701 720 chunk = f.read(4096)
702 721 if not chunk: break
703 722 sys.stdout.write(z.compress(chunk))
704 723
705 724 sys.stdout.write(z.flush())
706 725
707 726 else:
708 727 write(self.t("error"))
709 728
710 729 def create_server(path, name, templates, address, port, use_ipv6 = False,
711 730 accesslog = sys.stdout, errorlog = sys.stderr):
712 731
713 732 def openlog(opt, default):
714 733 if opt and opt != '-':
715 734 return open(opt, 'w')
716 735 return default
717 736
718 737 u = ui()
719 738 repo = repository(u, path)
720 739 if not address:
721 740 address = u.config("web", "address", "")
722 741 if not port:
723 742 port = int(u.config("web", "port", 8000))
724 743 if not use_ipv6:
725 744 use_ipv6 = u.configbool("web", "ipv6")
726 745
727 746 accesslog = openlog(accesslog or u.config("web", "accesslog", "-"),
728 747 sys.stdout)
729 748 errorlog = openlog(errorlog or u.config("web", "errorlog", "-"),
730 749 sys.stderr)
731 750
732 751 import BaseHTTPServer
733 752
734 753 class IPv6HTTPServer(BaseHTTPServer.HTTPServer):
735 754 address_family = getattr(socket, 'AF_INET6', None)
736 755
737 756 def __init__(self, *args, **kwargs):
738 757 if self.address_family is None:
739 758 raise RepoError('IPv6 not available on this system')
740 759 BaseHTTPServer.HTTPServer.__init__(self, *args, **kwargs)
741 760
742 761 class hgwebhandler(BaseHTTPServer.BaseHTTPRequestHandler):
743 762 def log_error(self, format, *args):
744 763 errorlog.write("%s - - [%s] %s\n" % (self.address_string(),
745 764 self.log_date_time_string(),
746 765 format % args))
747 766
748 767 def log_message(self, format, *args):
749 768 accesslog.write("%s - - [%s] %s\n" % (self.address_string(),
750 769 self.log_date_time_string(),
751 770 format % args))
752 771
753 772 def do_POST(self):
754 773 try:
755 774 self.do_hgweb()
756 775 except socket.error, inst:
757 776 if inst.args[0] != 32: raise
758 777
759 778 def do_GET(self):
760 779 self.do_POST()
761 780
762 781 def do_hgweb(self):
763 782 query = ""
764 783 p = self.path.find("?")
765 784 if p:
766 785 query = self.path[p + 1:]
767 786 query = query.replace('+', ' ')
768 787
769 788 env = {}
770 789 env['GATEWAY_INTERFACE'] = 'CGI/1.1'
771 790 env['REQUEST_METHOD'] = self.command
772 791 env['SERVER_NAME'] = self.server.server_name
773 792 env['SERVER_PORT'] = str(self.server.server_port)
774 793 env['REQUEST_URI'] = "/"
775 794 if query:
776 795 env['QUERY_STRING'] = query
777 796 host = self.address_string()
778 797 if host != self.client_address[0]:
779 798 env['REMOTE_HOST'] = host
780 799 env['REMOTE_ADDR'] = self.client_address[0]
781 800
782 801 if self.headers.typeheader is None:
783 802 env['CONTENT_TYPE'] = self.headers.type
784 803 else:
785 804 env['CONTENT_TYPE'] = self.headers.typeheader
786 805 length = self.headers.getheader('content-length')
787 806 if length:
788 807 env['CONTENT_LENGTH'] = length
789 808 accept = []
790 809 for line in self.headers.getallmatchingheaders('accept'):
791 810 if line[:1] in "\t\n\r ":
792 811 accept.append(line.strip())
793 812 else:
794 813 accept = accept + line[7:].split(',')
795 814 env['HTTP_ACCEPT'] = ','.join(accept)
796 815
797 816 os.environ.update(env)
798 817
799 818 save = sys.argv, sys.stdin, sys.stdout, sys.stderr
800 819 try:
801 820 sys.stdin = self.rfile
802 821 sys.stdout = self.wfile
803 822 sys.argv = ["hgweb.py"]
804 823 if '=' not in query:
805 824 sys.argv.append(query)
806 825 self.send_response(200, "Script output follows")
807 826 hg.run()
808 827 finally:
809 828 sys.argv, sys.stdin, sys.stdout, sys.stderr = save
810 829
811 830 hg = hgweb(path, name, templates)
812 831 if use_ipv6:
813 832 return IPv6HTTPServer((address, port), hgwebhandler)
814 833 else:
815 834 return BaseHTTPServer.HTTPServer((address, port), hgwebhandler)
816 835
817 836 def server(path, name, templates, address, port, use_ipv6 = False,
818 837 accesslog = sys.stdout, errorlog = sys.stderr):
819 838 httpd = create_server(path, name, templates, address, port, use_ipv6,
820 839 accesslog, errorlog)
821 840 httpd.serve_forever()
822 841
823 842 # This is a stopgap
824 843 class hgwebdir:
825 844 def __init__(self, config):
826 845 self.cp = ConfigParser.SafeConfigParser()
827 846 self.cp.read(config)
828 847
829 848 def run(self):
830 849 try:
831 850 virtual = os.environ["PATH_INFO"]
832 851 except:
833 852 virtual = ""
834 853
835 854 if virtual:
836 855 real = self.cp.get("paths", virtual[1:])
837 856 h = hgweb(real)
838 857 h.run()
839 858 return
840 859
841 860 def header(**map):
842 861 yield tmpl("header", **map)
843 862
844 863 def footer(**map):
845 864 yield tmpl("footer", **map)
846 865
847 866 templates = templatepath()
848 867 m = os.path.join(templates, "map")
849 868 tmpl = templater(m, common_filters,
850 869 {"header": header, "footer": footer})
851 870
852 871 def entries(**map):
853 872 parity = 0
854 873 l = self.cp.items("paths")
855 874 l.sort()
856 875 for v,r in l:
857 876 cp2 = ConfigParser.SafeConfigParser()
858 877 cp2.read(os.path.join(r, ".hg", "hgrc"))
859 878
860 879 def get(sec, val, default):
861 880 try:
862 881 return cp2.get(sec, val)
863 882 except:
864 883 return default
865 884
866 885 yield tmpl("indexentry",
867 886 author = get("web", "author", "unknown"),
868 887 name = get("web", "name", v),
869 888 url = os.environ["REQUEST_URI"] + "/" + v,
870 889 parity = parity,
871 890 shortdesc = get("web", "description", "unknown"),
872 891 lastupdate = os.stat(os.path.join(r, ".hg",
873 892 "00changelog.d")).st_mtime)
874 893
875 894 parity = 1 - parity
876 895
877 896 write(tmpl("index", entries = entries))
@@ -1,36 +1,36 b''
1 1 #header#
2 2 <title>#repo|escape#: changelog</title>
3 3 <link rel="alternate" type="application/rss+xml"
4 4 href="?cmd=changelog;style=rss" title="RSS feed for #repo|escape#">
5 5 </head>
6 6 <body>
7 7
8 8 <div class="buttons">
9 9 <a href="?cmd=tags">tags</a>
10 10 <a href="?cmd=manifest;manifest=#manifest#;path=/">manifest</a>
11 11 <a type="application/rss+xml" href="?cmd=changelog;style=rss">rss</a>
12 12 </div>
13 13
14 14 <h2>changelog for #repo|escape#</h2>
15 15
16 16 <form action="#">
17 17 <p>
18 18 <label for="search1">search:</label>
19 19 <input type="hidden" name="cmd" value="changelog">
20 20 <input name="rev" id="search1" type="text" size="30">
21 navigate: <small>#changenav#</small>
21 navigate: <small>#changenav%naventry#</small>
22 22 </p>
23 23 </form>
24 24
25 #entries#
25 #entries%changelogentry#
26 26
27 27 <form action="#">
28 28 <p>
29 29 <label for="search2">search:</label>
30 30 <input type="hidden" name="cmd" value="changelog">
31 31 <input name="rev" id="search2" type="text" size="30">
32 navigate: <small>#changenav#</small>
32 navigate: <small>#changenav%naventry#</small>
33 33 </p>
34 34 </form>
35 35
36 36 #footer#
@@ -1,42 +1,42 b''
1 1 #header#
2 2 <title>#repo|escape#: #file# annotate</title>
3 3 </head>
4 4 <body>
5 5
6 6 <div class="buttons">
7 7 <a href="?cmd=changelog;rev=#rev#">changelog</a>
8 8 <a href="?cmd=tags">tags</a>
9 9 <a href="?cmd=changeset;node=#node#">changeset</a>
10 10 <a href="?cmd=manifest;manifest=#manifest#;path=#path#">manifest</a>
11 11 <a href="?cmd=file;file=#file#;filenode=#filenode#">file</a>
12 12 <a href="?cmd=filelog;file=#file#;filenode=#filenode#">revisions</a>
13 13 </div>
14 14
15 15 <h2>Annotate #file# (#filenode|short#)</h2>
16 16
17 17 <table>
18 18 <tr>
19 19 <td class="metatag">changeset #rev#:</td>
20 20 <td><a href="?cmd=changeset;node=#node#">#node|short#</a></td></tr>
21 21 #parent#
22 22 <tr>
23 23 <td class="metatag">manifest:</td>
24 24 <td><a href="?cmd=manifest;manifest=#manifest#;path=/">#manifest|short#</a></td></tr>
25 25 <tr>
26 26 <td class="metatag">author:</td>
27 27 <td>#author|obfuscate#</td></tr>
28 28 <tr>
29 29 <td class="metatag">date:</td>
30 30 <td>#date|date# (#date|age# ago)</td></tr>
31 31 <tr>
32 32 <td class="metatag">permissions:</td>
33 33 <td>#permissions|permissions#</td></tr>
34 34 </table>
35 35
36 36 <br/>
37 37
38 38 <table cellspacing="0" cellpadding="0">
39 #annotate#
39 #annotate%annotateline#
40 40 </table>
41 41
42 42 #footer#
@@ -1,21 +1,21 b''
1 1 #header#
2 2 <title>#repo|escape#: #file# history</title>
3 3 <link rel="alternate" type="application/rss+xml"
4 4 href="?cmd=filelog;file=#file#;filenode=0;style=rss" title="RSS feed for #repo|escape#:#file#">
5 5 </head>
6 6 </head>
7 7 <body>
8 8
9 9 <div class="buttons">
10 10 <a href="?cmd=changelog">changelog</a>
11 11 <a href="?cmd=tags">tags</a>
12 12 <a href="?cmd=file;file=#file#;filenode=#filenode#">file</a>
13 13 <a href="?cmd=annotate;file=#file#;filenode=#filenode#">annotate</a>
14 14 <a type="application/rss+xml" href="?cmd=filelog;file=#file#;filenode=0;style=rss">rss</a>
15 15 </div>
16 16
17 17 <h2>#file# revision history</h2>
18 18
19 #entries#
19 #entries%filelogentry#
20 20
21 21 #footer#
@@ -1,41 +1,41 b''
1 1 #header#
2 2 <title>#repo|escape#:#file#</title>
3 3 </head>
4 4 <body>
5 5
6 6 <div class="buttons">
7 7 <a href="?cmd=changelog;rev=#rev#">changelog</a>
8 8 <a href="?cmd=tags">tags</a>
9 9 <a href="?cmd=changeset;node=#node#">changeset</a>
10 10 <a href="?cmd=manifest;manifest=#manifest#;path=#path#">manifest</a>
11 11 <a href="?cmd=filelog;file=#file#;filenode=#filenode#">revisions</a>
12 12 <a href="?cmd=annotate;file=#file#;filenode=#filenode#">annotate</a>
13 13 <a href="?cmd=file;file=#file#;filenode=#filenode#;style=raw">raw</a>
14 14 </div>
15 15
16 16 <h2>#file# (revision #filenode|short#)</h2>
17 17
18 18 <table>
19 19 <tr>
20 20 <td class="metatag">changeset #rev#:</td>
21 21 <td><a href="?cmd=changeset;node=#node#">#node|short#</a></td></tr>
22 22 #parent#
23 23 <tr>
24 24 <td class="metatag">manifest:</td>
25 25 <td><a href="?cmd=manifest;manifest=#manifest#;path=/">#manifest|short#</a></td></tr>
26 26 <tr>
27 27 <td class="metatag">author:</td>
28 28 <td>#author|obfuscate#</td></tr>
29 29 <tr>
30 30 <td class="metatag">date:</td>
31 31 <td>#date|date# (#date|age# ago)</td></tr>
32 32 <tr>
33 33 <td class="metatag">permissions:</td>
34 34 <td>#permissions|permissions#</td></tr>
35 35 </table>
36 36
37 37 <pre>
38 #text#
38 #text%fileline#
39 39 </pre>
40 40
41 41 #footer#
@@ -1,20 +1,21 b''
1 1 #header#
2 2 <title>#repo|escape#: manifest #manifest|short#</title>
3 3 </head>
4 4 <body>
5 5
6 6 <div class="buttons">
7 7 <a href="?cmd=changelog;rev=#rev#">changelog</a>
8 8 <a href="?cmd=tags">tags</a>
9 9 <a href="?cmd=changeset;node=#node#">changeset</a>
10 10 </div>
11 11
12 12 <h2>manifest #manifest|short#: #path#</h2>
13 13
14 14 <table cellpadding="0" cellspacing="0">
15 15 <tr class="parity1">
16 16 <td><tt>drwxr-xr-x</tt>&nbsp;
17 17 <td><a href="?cmd=manifest;manifest=#manifest#;path=#up#">[up]</a>
18 #entries#
18 #dentries%manifestdirentry#
19 #fentries%manifestfileentry#
19 20 </table>
20 21 #footer#
@@ -1,17 +1,17 b''
1 1 #header#
2 2 <title>#repo#: tags</title>
3 3 </head>
4 4 <body>
5 5
6 6 <div class="buttons">
7 7 <a href="?cmd=changelog;rev=#rev#">changelog</a>
8 8 <a href="?cmd=manifest;manifest=#manifest#;path=/">manifest</a>
9 9 </div>
10 10
11 11 <h2>tags:</h2>
12 12
13 13 <ul id="tagEntries">
14 #entries#
14 #entries%tagentry#
15 15 </ul>
16 16
17 17 #footer#
General Comments 0
You need to be logged in to leave comments. Login now