##// END OF EJS Templates
fixes issue #674, alternative gravatar url had an error when there was no valid email in commit data
marcink -
r3080:39bbe5d3 beta
parent child Browse files
Show More
@@ -1,1158 +1,1159 b''
1 1 """Helper functions
2 2
3 3 Consists of functions to typically be used within templates, but also
4 4 available to Controllers. This module is available to both as 'h'.
5 5 """
6 6 import random
7 7 import hashlib
8 8 import StringIO
9 9 import urllib
10 10 import math
11 11 import logging
12 12 import re
13 13 import urlparse
14 14 import textwrap
15 15
16 16 from datetime import datetime
17 17 from pygments.formatters.html import HtmlFormatter
18 18 from pygments import highlight as code_highlight
19 19 from pylons import url, request, config
20 20 from pylons.i18n.translation import _, ungettext
21 21 from hashlib import md5
22 22
23 23 from webhelpers.html import literal, HTML, escape
24 24 from webhelpers.html.tools import *
25 25 from webhelpers.html.builder import make_tag
26 26 from webhelpers.html.tags import auto_discovery_link, checkbox, css_classes, \
27 27 end_form, file, form, hidden, image, javascript_link, link_to, \
28 28 link_to_if, link_to_unless, ol, required_legend, select, stylesheet_link, \
29 29 submit, text, password, textarea, title, ul, xml_declaration, radio
30 30 from webhelpers.html.tools import auto_link, button_to, highlight, \
31 31 js_obfuscate, mail_to, strip_links, strip_tags, tag_re
32 32 from webhelpers.number import format_byte_size, format_bit_size
33 33 from webhelpers.pylonslib import Flash as _Flash
34 34 from webhelpers.pylonslib.secure_form import secure_form
35 35 from webhelpers.text import chop_at, collapse, convert_accented_entities, \
36 36 convert_misc_entities, lchop, plural, rchop, remove_formatting, \
37 37 replace_whitespace, urlify, truncate, wrap_paragraphs
38 38 from webhelpers.date import time_ago_in_words
39 39 from webhelpers.paginate import Page
40 40 from webhelpers.html.tags import _set_input_attrs, _set_id_attr, \
41 41 convert_boolean_attrs, NotGiven, _make_safe_id_component
42 42
43 43 from rhodecode.lib.annotate import annotate_highlight
44 44 from rhodecode.lib.utils import repo_name_slug
45 45 from rhodecode.lib.utils2 import str2bool, safe_unicode, safe_str, \
46 46 get_changeset_safe, datetime_to_time, time_to_datetime, AttributeDict
47 47 from rhodecode.lib.markup_renderer import MarkupRenderer
48 48 from rhodecode.lib.vcs.exceptions import ChangesetDoesNotExistError
49 49 from rhodecode.lib.vcs.backends.base import BaseChangeset, EmptyChangeset
50 50 from rhodecode.config.conf import DATE_FORMAT, DATETIME_FORMAT
51 51 from rhodecode.model.changeset_status import ChangesetStatusModel
52 52 from rhodecode.model.db import URL_SEP, Permission
53 53
54 54 log = logging.getLogger(__name__)
55 55
56 56
57 57 html_escape_table = {
58 58 "&": "&",
59 59 '"': """,
60 60 "'": "'",
61 61 ">": ">",
62 62 "<": "&lt;",
63 63 }
64 64
65 65
66 66 def html_escape(text):
67 67 """Produce entities within text."""
68 68 return "".join(html_escape_table.get(c, c) for c in text)
69 69
70 70
71 71 def shorter(text, size=20):
72 72 postfix = '...'
73 73 if len(text) > size:
74 74 return text[:size - len(postfix)] + postfix
75 75 return text
76 76
77 77
78 78 def _reset(name, value=None, id=NotGiven, type="reset", **attrs):
79 79 """
80 80 Reset button
81 81 """
82 82 _set_input_attrs(attrs, type, name, value)
83 83 _set_id_attr(attrs, id, name)
84 84 convert_boolean_attrs(attrs, ["disabled"])
85 85 return HTML.input(**attrs)
86 86
87 87 reset = _reset
88 88 safeid = _make_safe_id_component
89 89
90 90
91 91 def FID(raw_id, path):
92 92 """
93 93 Creates a uniqe ID for filenode based on it's hash of path and revision
94 94 it's safe to use in urls
95 95
96 96 :param raw_id:
97 97 :param path:
98 98 """
99 99
100 100 return 'C-%s-%s' % (short_id(raw_id), md5(safe_str(path)).hexdigest()[:12])
101 101
102 102
103 103 def get_token():
104 104 """Return the current authentication token, creating one if one doesn't
105 105 already exist.
106 106 """
107 107 token_key = "_authentication_token"
108 108 from pylons import session
109 109 if not token_key in session:
110 110 try:
111 111 token = hashlib.sha1(str(random.getrandbits(128))).hexdigest()
112 112 except AttributeError: # Python < 2.4
113 113 token = hashlib.sha1(str(random.randrange(2 ** 128))).hexdigest()
114 114 session[token_key] = token
115 115 if hasattr(session, 'save'):
116 116 session.save()
117 117 return session[token_key]
118 118
119 119
120 120 class _GetError(object):
121 121 """Get error from form_errors, and represent it as span wrapped error
122 122 message
123 123
124 124 :param field_name: field to fetch errors for
125 125 :param form_errors: form errors dict
126 126 """
127 127
128 128 def __call__(self, field_name, form_errors):
129 129 tmpl = """<span class="error_msg">%s</span>"""
130 130 if form_errors and field_name in form_errors:
131 131 return literal(tmpl % form_errors.get(field_name))
132 132
133 133 get_error = _GetError()
134 134
135 135
136 136 class _ToolTip(object):
137 137
138 138 def __call__(self, tooltip_title, trim_at=50):
139 139 """
140 140 Special function just to wrap our text into nice formatted
141 141 autowrapped text
142 142
143 143 :param tooltip_title:
144 144 """
145 145 tooltip_title = escape(tooltip_title)
146 146 tooltip_title = tooltip_title.replace('<', '&lt;').replace('>', '&gt;')
147 147 return tooltip_title
148 148 tooltip = _ToolTip()
149 149
150 150
151 151 class _FilesBreadCrumbs(object):
152 152
153 153 def __call__(self, repo_name, rev, paths):
154 154 if isinstance(paths, str):
155 155 paths = safe_unicode(paths)
156 156 url_l = [link_to(repo_name, url('files_home',
157 157 repo_name=repo_name,
158 158 revision=rev, f_path=''),
159 159 class_='ypjax-link')]
160 160 paths_l = paths.split('/')
161 161 for cnt, p in enumerate(paths_l):
162 162 if p != '':
163 163 url_l.append(link_to(p,
164 164 url('files_home',
165 165 repo_name=repo_name,
166 166 revision=rev,
167 167 f_path='/'.join(paths_l[:cnt + 1])
168 168 ),
169 169 class_='ypjax-link'
170 170 )
171 171 )
172 172
173 173 return literal('/'.join(url_l))
174 174
175 175 files_breadcrumbs = _FilesBreadCrumbs()
176 176
177 177
178 178 class CodeHtmlFormatter(HtmlFormatter):
179 179 """
180 180 My code Html Formatter for source codes
181 181 """
182 182
183 183 def wrap(self, source, outfile):
184 184 return self._wrap_div(self._wrap_pre(self._wrap_code(source)))
185 185
186 186 def _wrap_code(self, source):
187 187 for cnt, it in enumerate(source):
188 188 i, t = it
189 189 t = '<div id="L%s">%s</div>' % (cnt + 1, t)
190 190 yield i, t
191 191
192 192 def _wrap_tablelinenos(self, inner):
193 193 dummyoutfile = StringIO.StringIO()
194 194 lncount = 0
195 195 for t, line in inner:
196 196 if t:
197 197 lncount += 1
198 198 dummyoutfile.write(line)
199 199
200 200 fl = self.linenostart
201 201 mw = len(str(lncount + fl - 1))
202 202 sp = self.linenospecial
203 203 st = self.linenostep
204 204 la = self.lineanchors
205 205 aln = self.anchorlinenos
206 206 nocls = self.noclasses
207 207 if sp:
208 208 lines = []
209 209
210 210 for i in range(fl, fl + lncount):
211 211 if i % st == 0:
212 212 if i % sp == 0:
213 213 if aln:
214 214 lines.append('<a href="#%s%d" class="special">%*d</a>' %
215 215 (la, i, mw, i))
216 216 else:
217 217 lines.append('<span class="special">%*d</span>' % (mw, i))
218 218 else:
219 219 if aln:
220 220 lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i))
221 221 else:
222 222 lines.append('%*d' % (mw, i))
223 223 else:
224 224 lines.append('')
225 225 ls = '\n'.join(lines)
226 226 else:
227 227 lines = []
228 228 for i in range(fl, fl + lncount):
229 229 if i % st == 0:
230 230 if aln:
231 231 lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i))
232 232 else:
233 233 lines.append('%*d' % (mw, i))
234 234 else:
235 235 lines.append('')
236 236 ls = '\n'.join(lines)
237 237
238 238 # in case you wonder about the seemingly redundant <div> here: since the
239 239 # content in the other cell also is wrapped in a div, some browsers in
240 240 # some configurations seem to mess up the formatting...
241 241 if nocls:
242 242 yield 0, ('<table class="%stable">' % self.cssclass +
243 243 '<tr><td><div class="linenodiv" '
244 244 'style="background-color: #f0f0f0; padding-right: 10px">'
245 245 '<pre style="line-height: 125%">' +
246 246 ls + '</pre></div></td><td id="hlcode" class="code">')
247 247 else:
248 248 yield 0, ('<table class="%stable">' % self.cssclass +
249 249 '<tr><td class="linenos"><div class="linenodiv"><pre>' +
250 250 ls + '</pre></div></td><td id="hlcode" class="code">')
251 251 yield 0, dummyoutfile.getvalue()
252 252 yield 0, '</td></tr></table>'
253 253
254 254
255 255 def pygmentize(filenode, **kwargs):
256 256 """pygmentize function using pygments
257 257
258 258 :param filenode:
259 259 """
260 260
261 261 return literal(code_highlight(filenode.content,
262 262 filenode.lexer, CodeHtmlFormatter(**kwargs)))
263 263
264 264
265 265 def pygmentize_annotation(repo_name, filenode, **kwargs):
266 266 """
267 267 pygmentize function for annotation
268 268
269 269 :param filenode:
270 270 """
271 271
272 272 color_dict = {}
273 273
274 274 def gen_color(n=10000):
275 275 """generator for getting n of evenly distributed colors using
276 276 hsv color and golden ratio. It always return same order of colors
277 277
278 278 :returns: RGB tuple
279 279 """
280 280
281 281 def hsv_to_rgb(h, s, v):
282 282 if s == 0.0:
283 283 return v, v, v
284 284 i = int(h * 6.0) # XXX assume int() truncates!
285 285 f = (h * 6.0) - i
286 286 p = v * (1.0 - s)
287 287 q = v * (1.0 - s * f)
288 288 t = v * (1.0 - s * (1.0 - f))
289 289 i = i % 6
290 290 if i == 0:
291 291 return v, t, p
292 292 if i == 1:
293 293 return q, v, p
294 294 if i == 2:
295 295 return p, v, t
296 296 if i == 3:
297 297 return p, q, v
298 298 if i == 4:
299 299 return t, p, v
300 300 if i == 5:
301 301 return v, p, q
302 302
303 303 golden_ratio = 0.618033988749895
304 304 h = 0.22717784590367374
305 305
306 306 for _ in xrange(n):
307 307 h += golden_ratio
308 308 h %= 1
309 309 HSV_tuple = [h, 0.95, 0.95]
310 310 RGB_tuple = hsv_to_rgb(*HSV_tuple)
311 311 yield map(lambda x: str(int(x * 256)), RGB_tuple)
312 312
313 313 cgenerator = gen_color()
314 314
315 315 def get_color_string(cs):
316 316 if cs in color_dict:
317 317 col = color_dict[cs]
318 318 else:
319 319 col = color_dict[cs] = cgenerator.next()
320 320 return "color: rgb(%s)! important;" % (', '.join(col))
321 321
322 322 def url_func(repo_name):
323 323
324 324 def _url_func(changeset):
325 325 author = changeset.author
326 326 date = changeset.date
327 327 message = tooltip(changeset.message)
328 328
329 329 tooltip_html = ("<div style='font-size:0.8em'><b>Author:</b>"
330 330 " %s<br/><b>Date:</b> %s</b><br/><b>Message:"
331 331 "</b> %s<br/></div>")
332 332
333 333 tooltip_html = tooltip_html % (author, date, message)
334 334 lnk_format = '%5s:%s' % ('r%s' % changeset.revision,
335 335 short_id(changeset.raw_id))
336 336 uri = link_to(
337 337 lnk_format,
338 338 url('changeset_home', repo_name=repo_name,
339 339 revision=changeset.raw_id),
340 340 style=get_color_string(changeset.raw_id),
341 341 class_='tooltip',
342 342 title=tooltip_html
343 343 )
344 344
345 345 uri += '\n'
346 346 return uri
347 347 return _url_func
348 348
349 349 return literal(annotate_highlight(filenode, url_func(repo_name), **kwargs))
350 350
351 351
352 352 def is_following_repo(repo_name, user_id):
353 353 from rhodecode.model.scm import ScmModel
354 354 return ScmModel().is_following_repo(repo_name, user_id)
355 355
356 356 flash = _Flash()
357 357
358 358 #==============================================================================
359 359 # SCM FILTERS available via h.
360 360 #==============================================================================
361 361 from rhodecode.lib.vcs.utils import author_name, author_email
362 362 from rhodecode.lib.utils2 import credentials_filter, age as _age
363 363 from rhodecode.model.db import User, ChangesetStatus
364 364
365 365 age = lambda x: _age(x)
366 366 capitalize = lambda x: x.capitalize()
367 367 email = author_email
368 368 short_id = lambda x: x[:12]
369 369 hide_credentials = lambda x: ''.join(credentials_filter(x))
370 370
371 371
372 372 def fmt_date(date):
373 373 if date:
374 374 _fmt = _(u"%a, %d %b %Y %H:%M:%S").encode('utf8')
375 375 return date.strftime(_fmt).decode('utf8')
376 376
377 377 return ""
378 378
379 379
380 380 def is_git(repository):
381 381 if hasattr(repository, 'alias'):
382 382 _type = repository.alias
383 383 elif hasattr(repository, 'repo_type'):
384 384 _type = repository.repo_type
385 385 else:
386 386 _type = repository
387 387 return _type == 'git'
388 388
389 389
390 390 def is_hg(repository):
391 391 if hasattr(repository, 'alias'):
392 392 _type = repository.alias
393 393 elif hasattr(repository, 'repo_type'):
394 394 _type = repository.repo_type
395 395 else:
396 396 _type = repository
397 397 return _type == 'hg'
398 398
399 399
400 400 def email_or_none(author):
401 401 # extract email from the commit string
402 402 _email = email(author)
403 403 if _email != '':
404 404 # check it against RhodeCode database, and use the MAIN email for this
405 405 # user
406 406 user = User.get_by_email(_email, case_insensitive=True, cache=True)
407 407 if user is not None:
408 408 return user.email
409 409 return _email
410 410
411 411 # See if it contains a username we can get an email from
412 412 user = User.get_by_username(author_name(author), case_insensitive=True,
413 413 cache=True)
414 414 if user is not None:
415 415 return user.email
416 416
417 417 # No valid email, not a valid user in the system, none!
418 418 return None
419 419
420 420
421 421 def person(author, show_attr="username_and_name"):
422 422 # attr to return from fetched user
423 423 person_getter = lambda usr: getattr(usr, show_attr)
424 424
425 425 # Valid email in the attribute passed, see if they're in the system
426 426 _email = email(author)
427 427 if _email != '':
428 428 user = User.get_by_email(_email, case_insensitive=True, cache=True)
429 429 if user is not None:
430 430 return person_getter(user)
431 431 return _email
432 432
433 433 # Maybe it's a username?
434 434 _author = author_name(author)
435 435 user = User.get_by_username(_author, case_insensitive=True,
436 436 cache=True)
437 437 if user is not None:
438 438 return person_getter(user)
439 439
440 440 # Still nothing? Just pass back the author name then
441 441 return _author
442 442
443 443
444 444 def person_by_id(id_, show_attr="username_and_name"):
445 445 # attr to return from fetched user
446 446 person_getter = lambda usr: getattr(usr, show_attr)
447 447
448 448 #maybe it's an ID ?
449 449 if str(id_).isdigit() or isinstance(id_, int):
450 450 id_ = int(id_)
451 451 user = User.get(id_)
452 452 if user is not None:
453 453 return person_getter(user)
454 454 return id_
455 455
456 456
457 457 def desc_stylize(value):
458 458 """
459 459 converts tags from value into html equivalent
460 460
461 461 :param value:
462 462 """
463 463 value = re.sub(r'\[see\ \=\>\ *([a-zA-Z0-9\/\=\?\&\ \:\/\.\-]*)\]',
464 464 '<div class="metatag" tag="see">see =&gt; \\1 </div>', value)
465 465 value = re.sub(r'\[license\ \=\>\ *([a-zA-Z0-9\/\=\?\&\ \:\/\.\-]*)\]',
466 466 '<div class="metatag" tag="license"><a href="http:\/\/www.opensource.org/licenses/\\1">\\1</a></div>', value)
467 467 value = re.sub(r'\[(requires|recommends|conflicts|base)\ \=\>\ *([a-zA-Z\-\/]*)\]',
468 468 '<div class="metatag" tag="\\1">\\1 =&gt; <a href="/\\2">\\2</a></div>', value)
469 469 value = re.sub(r'\[(lang|language)\ \=\>\ *([a-zA-Z\-\/\#\+]*)\]',
470 470 '<div class="metatag" tag="lang">\\2</div>', value)
471 471 value = re.sub(r'\[([a-z]+)\]',
472 472 '<div class="metatag" tag="\\1">\\1</div>', value)
473 473
474 474 return value
475 475
476 476
477 477 def bool2icon(value):
478 478 """Returns True/False values represented as small html image of true/false
479 479 icons
480 480
481 481 :param value: bool value
482 482 """
483 483
484 484 if value is True:
485 485 return HTML.tag('img', src=url("/images/icons/accept.png"),
486 486 alt=_('True'))
487 487
488 488 if value is False:
489 489 return HTML.tag('img', src=url("/images/icons/cancel.png"),
490 490 alt=_('False'))
491 491
492 492 return value
493 493
494 494
495 495 def action_parser(user_log, feed=False, parse_cs=False):
496 496 """
497 497 This helper will action_map the specified string action into translated
498 498 fancy names with icons and links
499 499
500 500 :param user_log: user log instance
501 501 :param feed: use output for feeds (no html and fancy icons)
502 502 :param parse_cs: parse Changesets into VCS instances
503 503 """
504 504
505 505 action = user_log.action
506 506 action_params = ' '
507 507
508 508 x = action.split(':')
509 509
510 510 if len(x) > 1:
511 511 action, action_params = x
512 512
513 513 def get_cs_links():
514 514 revs_limit = 3 # display this amount always
515 515 revs_top_limit = 50 # show upto this amount of changesets hidden
516 516 revs_ids = action_params.split(',')
517 517 deleted = user_log.repository is None
518 518 if deleted:
519 519 return ','.join(revs_ids)
520 520
521 521 repo_name = user_log.repository.repo_name
522 522
523 523 def lnk(rev, repo_name):
524 524 if isinstance(rev, BaseChangeset) or isinstance(rev, AttributeDict):
525 525 lazy_cs = True
526 526 if getattr(rev, 'op', None) and getattr(rev, 'ref_name', None):
527 527 lazy_cs = False
528 528 lbl = '?'
529 529 if rev.op == 'delete_branch':
530 530 lbl = '%s' % _('Deleted branch: %s') % rev.ref_name
531 531 title = ''
532 532 elif rev.op == 'tag':
533 533 lbl = '%s' % _('Created tag: %s') % rev.ref_name
534 534 title = ''
535 535 _url = '#'
536 536
537 537 else:
538 538 lbl = '%s' % (rev.short_id[:8])
539 539 _url = url('changeset_home', repo_name=repo_name,
540 540 revision=rev.raw_id)
541 541 title = tooltip(rev.message)
542 542 else:
543 543 ## changeset cannot be found/striped/removed etc.
544 544 lbl = ('%s' % rev)[:12]
545 545 _url = '#'
546 546 title = _('Changeset not found')
547 547 if parse_cs:
548 548 return link_to(lbl, _url, title=title, class_='tooltip')
549 549 return link_to(lbl, _url, raw_id=rev.raw_id, repo_name=repo_name,
550 550 class_='lazy-cs' if lazy_cs else '')
551 551
552 552 revs = []
553 553 if len(filter(lambda v: v != '', revs_ids)) > 0:
554 554 repo = None
555 555 for rev in revs_ids[:revs_top_limit]:
556 556 _op = _name = None
557 557 if len(rev.split('=>')) == 2:
558 558 _op, _name = rev.split('=>')
559 559
560 560 # we want parsed changesets, or new log store format is bad
561 561 if parse_cs:
562 562 try:
563 563 if repo is None:
564 564 repo = user_log.repository.scm_instance
565 565 _rev = repo.get_changeset(rev)
566 566 revs.append(_rev)
567 567 except ChangesetDoesNotExistError:
568 568 log.error('cannot find revision %s in this repo' % rev)
569 569 revs.append(rev)
570 570 continue
571 571 else:
572 572 _rev = AttributeDict({
573 573 'short_id': rev[:12],
574 574 'raw_id': rev,
575 575 'message': '',
576 576 'op': _op,
577 577 'ref_name': _name
578 578 })
579 579 revs.append(_rev)
580 580 cs_links = []
581 581 cs_links.append(" " + ', '.join(
582 582 [lnk(rev, repo_name) for rev in revs[:revs_limit]]
583 583 )
584 584 )
585 585
586 586 compare_view = (
587 587 ' <div class="compare_view tooltip" title="%s">'
588 588 '<a href="%s">%s</a> </div>' % (
589 589 _('Show all combined changesets %s->%s') % (
590 590 revs_ids[0][:12], revs_ids[-1][:12]
591 591 ),
592 592 url('changeset_home', repo_name=repo_name,
593 593 revision='%s...%s' % (revs_ids[0], revs_ids[-1])
594 594 ),
595 595 _('compare view')
596 596 )
597 597 )
598 598
599 599 # if we have exactly one more than normally displayed
600 600 # just display it, takes less space than displaying
601 601 # "and 1 more revisions"
602 602 if len(revs_ids) == revs_limit + 1:
603 603 rev = revs[revs_limit]
604 604 cs_links.append(", " + lnk(rev, repo_name))
605 605
606 606 # hidden-by-default ones
607 607 if len(revs_ids) > revs_limit + 1:
608 608 uniq_id = revs_ids[0]
609 609 html_tmpl = (
610 610 '<span> %s <a class="show_more" id="_%s" '
611 611 'href="#more">%s</a> %s</span>'
612 612 )
613 613 if not feed:
614 614 cs_links.append(html_tmpl % (
615 615 _('and'),
616 616 uniq_id, _('%s more') % (len(revs_ids) - revs_limit),
617 617 _('revisions')
618 618 )
619 619 )
620 620
621 621 if not feed:
622 622 html_tmpl = '<span id="%s" style="display:none">, %s </span>'
623 623 else:
624 624 html_tmpl = '<span id="%s"> %s </span>'
625 625
626 626 morelinks = ', '.join(
627 627 [lnk(rev, repo_name) for rev in revs[revs_limit:]]
628 628 )
629 629
630 630 if len(revs_ids) > revs_top_limit:
631 631 morelinks += ', ...'
632 632
633 633 cs_links.append(html_tmpl % (uniq_id, morelinks))
634 634 if len(revs) > 1:
635 635 cs_links.append(compare_view)
636 636 return ''.join(cs_links)
637 637
638 638 def get_fork_name():
639 639 repo_name = action_params
640 640 _url = url('summary_home', repo_name=repo_name)
641 641 return _('fork name %s') % link_to(action_params, _url)
642 642
643 643 def get_user_name():
644 644 user_name = action_params
645 645 return user_name
646 646
647 647 def get_users_group():
648 648 group_name = action_params
649 649 return group_name
650 650
651 651 def get_pull_request():
652 652 pull_request_id = action_params
653 653 deleted = user_log.repository is None
654 654 if deleted:
655 655 repo_name = user_log.repository_name
656 656 else:
657 657 repo_name = user_log.repository.repo_name
658 658 return link_to(_('Pull request #%s') % pull_request_id,
659 659 url('pullrequest_show', repo_name=repo_name,
660 660 pull_request_id=pull_request_id))
661 661
662 662 # action : translated str, callback(extractor), icon
663 663 action_map = {
664 664 'user_deleted_repo': (_('[deleted] repository'),
665 665 None, 'database_delete.png'),
666 666 'user_created_repo': (_('[created] repository'),
667 667 None, 'database_add.png'),
668 668 'user_created_fork': (_('[created] repository as fork'),
669 669 None, 'arrow_divide.png'),
670 670 'user_forked_repo': (_('[forked] repository'),
671 671 get_fork_name, 'arrow_divide.png'),
672 672 'user_updated_repo': (_('[updated] repository'),
673 673 None, 'database_edit.png'),
674 674 'admin_deleted_repo': (_('[delete] repository'),
675 675 None, 'database_delete.png'),
676 676 'admin_created_repo': (_('[created] repository'),
677 677 None, 'database_add.png'),
678 678 'admin_forked_repo': (_('[forked] repository'),
679 679 None, 'arrow_divide.png'),
680 680 'admin_updated_repo': (_('[updated] repository'),
681 681 None, 'database_edit.png'),
682 682 'admin_created_user': (_('[created] user'),
683 683 get_user_name, 'user_add.png'),
684 684 'admin_updated_user': (_('[updated] user'),
685 685 get_user_name, 'user_edit.png'),
686 686 'admin_created_users_group': (_('[created] users group'),
687 687 get_users_group, 'group_add.png'),
688 688 'admin_updated_users_group': (_('[updated] users group'),
689 689 get_users_group, 'group_edit.png'),
690 690 'user_commented_revision': (_('[commented] on revision in repository'),
691 691 get_cs_links, 'comment_add.png'),
692 692 'user_commented_pull_request': (_('[commented] on pull request for'),
693 693 get_pull_request, 'comment_add.png'),
694 694 'user_closed_pull_request': (_('[closed] pull request for'),
695 695 get_pull_request, 'tick.png'),
696 696 'push': (_('[pushed] into'),
697 697 get_cs_links, 'script_add.png'),
698 698 'push_local': (_('[committed via RhodeCode] into repository'),
699 699 get_cs_links, 'script_edit.png'),
700 700 'push_remote': (_('[pulled from remote] into repository'),
701 701 get_cs_links, 'connect.png'),
702 702 'pull': (_('[pulled] from'),
703 703 None, 'down_16.png'),
704 704 'started_following_repo': (_('[started following] repository'),
705 705 None, 'heart_add.png'),
706 706 'stopped_following_repo': (_('[stopped following] repository'),
707 707 None, 'heart_delete.png'),
708 708 }
709 709
710 710 action_str = action_map.get(action, action)
711 711 if feed:
712 712 action = action_str[0].replace('[', '').replace(']', '')
713 713 else:
714 714 action = action_str[0]\
715 715 .replace('[', '<span class="journal_highlight">')\
716 716 .replace(']', '</span>')
717 717
718 718 action_params_func = lambda: ""
719 719
720 720 if callable(action_str[1]):
721 721 action_params_func = action_str[1]
722 722
723 723 def action_parser_icon():
724 724 action = user_log.action
725 725 action_params = None
726 726 x = action.split(':')
727 727
728 728 if len(x) > 1:
729 729 action, action_params = x
730 730
731 731 tmpl = """<img src="%s%s" alt="%s"/>"""
732 732 ico = action_map.get(action, ['', '', ''])[2]
733 733 return literal(tmpl % ((url('/images/icons/')), ico, action))
734 734
735 735 # returned callbacks we need to call to get
736 736 return [lambda: literal(action), action_params_func, action_parser_icon]
737 737
738 738
739 739
740 740 #==============================================================================
741 741 # PERMS
742 742 #==============================================================================
743 743 from rhodecode.lib.auth import HasPermissionAny, HasPermissionAll, \
744 744 HasRepoPermissionAny, HasRepoPermissionAll
745 745
746 746
747 747 #==============================================================================
748 748 # GRAVATAR URL
749 749 #==============================================================================
750 750
751 751 def gravatar_url(email_address, size=30):
752 from pylons import url ## doh, we need to re-import url to mock it later
752 from pylons import url # doh, we need to re-import url to mock it later
753
754 if (not str2bool(config['app_conf'].get('use_gravatar')) or
755 not email_address or email_address == 'anonymous@rhodecode.org'):
756 f = lambda a, l: min(l, key=lambda x: abs(x - a))
757 return url("/images/user%s.png" % f(size, [14, 16, 20, 24, 30]))
758
753 759 if(str2bool(config['app_conf'].get('use_gravatar')) and
754 760 config['app_conf'].get('alternative_gravatar_url')):
755 761 tmpl = config['app_conf'].get('alternative_gravatar_url', '')
756 762 parsed_url = urlparse.urlparse(url.current(qualified=True))
757 763 tmpl = tmpl.replace('{email}', email_address)\
758 764 .replace('{md5email}', hashlib.md5(email_address.lower()).hexdigest()) \
759 765 .replace('{netloc}', parsed_url.netloc)\
760 766 .replace('{scheme}', parsed_url.scheme)\
761 767 .replace('{size}', str(size))
762 768 return tmpl
763 769
764 if (not str2bool(config['app_conf'].get('use_gravatar')) or
765 not email_address or email_address == 'anonymous@rhodecode.org'):
766 f = lambda a, l: min(l, key=lambda x: abs(x - a))
767 return url("/images/user%s.png" % f(size, [14, 16, 20, 24, 30]))
768
769 770 ssl_enabled = 'https' == request.environ.get('wsgi.url_scheme')
770 771 default = 'identicon'
771 772 baseurl_nossl = "http://www.gravatar.com/avatar/"
772 773 baseurl_ssl = "https://secure.gravatar.com/avatar/"
773 774 baseurl = baseurl_ssl if ssl_enabled else baseurl_nossl
774 775
775 776 if isinstance(email_address, unicode):
776 777 #hashlib crashes on unicode items
777 778 email_address = safe_str(email_address)
778 779 # construct the url
779 780 gravatar_url = baseurl + hashlib.md5(email_address.lower()).hexdigest() + "?"
780 781 gravatar_url += urllib.urlencode({'d': default, 's': str(size)})
781 782
782 783 return gravatar_url
783 784
784 785
785 786 #==============================================================================
786 787 # REPO PAGER, PAGER FOR REPOSITORY
787 788 #==============================================================================
788 789 class RepoPage(Page):
789 790
790 791 def __init__(self, collection, page=1, items_per_page=20,
791 792 item_count=None, url=None, **kwargs):
792 793
793 794 """Create a "RepoPage" instance. special pager for paging
794 795 repository
795 796 """
796 797 self._url_generator = url
797 798
798 799 # Safe the kwargs class-wide so they can be used in the pager() method
799 800 self.kwargs = kwargs
800 801
801 802 # Save a reference to the collection
802 803 self.original_collection = collection
803 804
804 805 self.collection = collection
805 806
806 807 # The self.page is the number of the current page.
807 808 # The first page has the number 1!
808 809 try:
809 810 self.page = int(page) # make it int() if we get it as a string
810 811 except (ValueError, TypeError):
811 812 self.page = 1
812 813
813 814 self.items_per_page = items_per_page
814 815
815 816 # Unless the user tells us how many items the collections has
816 817 # we calculate that ourselves.
817 818 if item_count is not None:
818 819 self.item_count = item_count
819 820 else:
820 821 self.item_count = len(self.collection)
821 822
822 823 # Compute the number of the first and last available page
823 824 if self.item_count > 0:
824 825 self.first_page = 1
825 826 self.page_count = int(math.ceil(float(self.item_count) /
826 827 self.items_per_page))
827 828 self.last_page = self.first_page + self.page_count - 1
828 829
829 830 # Make sure that the requested page number is the range of
830 831 # valid pages
831 832 if self.page > self.last_page:
832 833 self.page = self.last_page
833 834 elif self.page < self.first_page:
834 835 self.page = self.first_page
835 836
836 837 # Note: the number of items on this page can be less than
837 838 # items_per_page if the last page is not full
838 839 self.first_item = max(0, (self.item_count) - (self.page *
839 840 items_per_page))
840 841 self.last_item = ((self.item_count - 1) - items_per_page *
841 842 (self.page - 1))
842 843
843 844 self.items = list(self.collection[self.first_item:self.last_item + 1])
844 845
845 846 # Links to previous and next page
846 847 if self.page > self.first_page:
847 848 self.previous_page = self.page - 1
848 849 else:
849 850 self.previous_page = None
850 851
851 852 if self.page < self.last_page:
852 853 self.next_page = self.page + 1
853 854 else:
854 855 self.next_page = None
855 856
856 857 # No items available
857 858 else:
858 859 self.first_page = None
859 860 self.page_count = 0
860 861 self.last_page = None
861 862 self.first_item = None
862 863 self.last_item = None
863 864 self.previous_page = None
864 865 self.next_page = None
865 866 self.items = []
866 867
867 868 # This is a subclass of the 'list' type. Initialise the list now.
868 869 list.__init__(self, reversed(self.items))
869 870
870 871
871 872 def changed_tooltip(nodes):
872 873 """
873 874 Generates a html string for changed nodes in changeset page.
874 875 It limits the output to 30 entries
875 876
876 877 :param nodes: LazyNodesGenerator
877 878 """
878 879 if nodes:
879 880 pref = ': <br/> '
880 881 suf = ''
881 882 if len(nodes) > 30:
882 883 suf = '<br/>' + _(' and %s more') % (len(nodes) - 30)
883 884 return literal(pref + '<br/> '.join([safe_unicode(x.path)
884 885 for x in nodes[:30]]) + suf)
885 886 else:
886 887 return ': ' + _('No Files')
887 888
888 889
889 890 def repo_link(groups_and_repos, last_url=None):
890 891 """
891 892 Makes a breadcrumbs link to repo within a group
892 893 joins &raquo; on each group to create a fancy link
893 894
894 895 ex::
895 896 group >> subgroup >> repo
896 897
897 898 :param groups_and_repos:
898 899 :param last_url:
899 900 """
900 901 groups, repo_name = groups_and_repos
901 902 last_link = link_to(repo_name, last_url) if last_url else repo_name
902 903
903 904 if not groups:
904 905 if last_url:
905 906 return last_link
906 907 return repo_name
907 908 else:
908 909 def make_link(group):
909 910 return link_to(group.name,
910 911 url('repos_group_home', group_name=group.group_name))
911 912 return literal(' &raquo; '.join(map(make_link, groups) + [last_link]))
912 913
913 914
914 915 def fancy_file_stats(stats):
915 916 """
916 917 Displays a fancy two colored bar for number of added/deleted
917 918 lines of code on file
918 919
919 920 :param stats: two element list of added/deleted lines of code
920 921 """
921 922 def cgen(l_type, a_v, d_v):
922 923 mapping = {'tr': 'top-right-rounded-corner-mid',
923 924 'tl': 'top-left-rounded-corner-mid',
924 925 'br': 'bottom-right-rounded-corner-mid',
925 926 'bl': 'bottom-left-rounded-corner-mid'}
926 927 map_getter = lambda x: mapping[x]
927 928
928 929 if l_type == 'a' and d_v:
929 930 #case when added and deleted are present
930 931 return ' '.join(map(map_getter, ['tl', 'bl']))
931 932
932 933 if l_type == 'a' and not d_v:
933 934 return ' '.join(map(map_getter, ['tr', 'br', 'tl', 'bl']))
934 935
935 936 if l_type == 'd' and a_v:
936 937 return ' '.join(map(map_getter, ['tr', 'br']))
937 938
938 939 if l_type == 'd' and not a_v:
939 940 return ' '.join(map(map_getter, ['tr', 'br', 'tl', 'bl']))
940 941
941 942 a, d = stats[0], stats[1]
942 943 width = 100
943 944
944 945 if a == 'b':
945 946 #binary mode
946 947 b_d = '<div class="bin%s %s" style="width:100%%">%s</div>' % (d, cgen('a', a_v='', d_v=0), 'bin')
947 948 b_a = '<div class="bin1" style="width:0%%">%s</div>' % ('bin')
948 949 return literal('<div style="width:%spx">%s%s</div>' % (width, b_a, b_d))
949 950
950 951 t = stats[0] + stats[1]
951 952 unit = float(width) / (t or 1)
952 953
953 954 # needs > 9% of width to be visible or 0 to be hidden
954 955 a_p = max(9, unit * a) if a > 0 else 0
955 956 d_p = max(9, unit * d) if d > 0 else 0
956 957 p_sum = a_p + d_p
957 958
958 959 if p_sum > width:
959 960 #adjust the percentage to be == 100% since we adjusted to 9
960 961 if a_p > d_p:
961 962 a_p = a_p - (p_sum - width)
962 963 else:
963 964 d_p = d_p - (p_sum - width)
964 965
965 966 a_v = a if a > 0 else ''
966 967 d_v = d if d > 0 else ''
967 968
968 969 d_a = '<div class="added %s" style="width:%s%%">%s</div>' % (
969 970 cgen('a', a_v, d_v), a_p, a_v
970 971 )
971 972 d_d = '<div class="deleted %s" style="width:%s%%">%s</div>' % (
972 973 cgen('d', a_v, d_v), d_p, d_v
973 974 )
974 975 return literal('<div style="width:%spx">%s%s</div>' % (width, d_a, d_d))
975 976
976 977
977 978 def urlify_text(text_):
978 979
979 980 url_pat = re.compile(r'''(http[s]?://(?:[a-zA-Z]|[0-9]|[$-_@.&+]'''
980 981 '''|[!*\(\),]|(?:%[0-9a-fA-F][0-9a-fA-F]))+)''')
981 982
982 983 def url_func(match_obj):
983 984 url_full = match_obj.groups()[0]
984 985 return '<a href="%(url)s">%(url)s</a>' % ({'url': url_full})
985 986
986 987 return literal(url_pat.sub(url_func, text_))
987 988
988 989
989 990 def urlify_changesets(text_, repository):
990 991 """
991 992 Extract revision ids from changeset and make link from them
992 993
993 994 :param text_:
994 995 :param repository:
995 996 """
996 997
997 998 URL_PAT = re.compile(r'([0-9a-fA-F]{12,})')
998 999
999 1000 def url_func(match_obj):
1000 1001 rev = match_obj.groups()[0]
1001 1002 pref = ''
1002 1003 if match_obj.group().startswith(' '):
1003 1004 pref = ' '
1004 1005 tmpl = (
1005 1006 '%(pref)s<a class="%(cls)s" href="%(url)s">'
1006 1007 '%(rev)s'
1007 1008 '</a>'
1008 1009 )
1009 1010 return tmpl % {
1010 1011 'pref': pref,
1011 1012 'cls': 'revision-link',
1012 1013 'url': url('changeset_home', repo_name=repository, revision=rev),
1013 1014 'rev': rev,
1014 1015 }
1015 1016
1016 1017 newtext = URL_PAT.sub(url_func, text_)
1017 1018
1018 1019 return newtext
1019 1020
1020 1021
1021 1022 def urlify_commit(text_, repository=None, link_=None):
1022 1023 """
1023 1024 Parses given text message and makes proper links.
1024 1025 issues are linked to given issue-server, and rest is a changeset link
1025 1026 if link_ is given, in other case it's a plain text
1026 1027
1027 1028 :param text_:
1028 1029 :param repository:
1029 1030 :param link_: changeset link
1030 1031 """
1031 1032 import traceback
1032 1033
1033 1034 def escaper(string):
1034 1035 return string.replace('<', '&lt;').replace('>', '&gt;')
1035 1036
1036 1037 def linkify_others(t, l):
1037 1038 urls = re.compile(r'(\<a.*?\<\/a\>)',)
1038 1039 links = []
1039 1040 for e in urls.split(t):
1040 1041 if not urls.match(e):
1041 1042 links.append('<a class="message-link" href="%s">%s</a>' % (l, e))
1042 1043 else:
1043 1044 links.append(e)
1044 1045
1045 1046 return ''.join(links)
1046 1047
1047 1048 # urlify changesets - extrac revisions and make link out of them
1048 1049 newtext = urlify_changesets(escaper(text_), repository)
1049 1050
1050 1051 try:
1051 1052 conf = config['app_conf']
1052 1053
1053 1054 # allow multiple issue servers to be used
1054 1055 valid_indices = [
1055 1056 x.group(1)
1056 1057 for x in map(lambda x: re.match(r'issue_pat(.*)', x), conf.keys())
1057 1058 if x and 'issue_server_link%s' % x.group(1) in conf
1058 1059 and 'issue_prefix%s' % x.group(1) in conf
1059 1060 ]
1060 1061
1061 1062 log.debug('found issue server suffixes `%s` during valuation of: %s'
1062 1063 % (','.join(valid_indices), newtext))
1063 1064
1064 1065 for pattern_index in valid_indices:
1065 1066 ISSUE_PATTERN = conf.get('issue_pat%s' % pattern_index)
1066 1067 ISSUE_SERVER_LNK = conf.get('issue_server_link%s' % pattern_index)
1067 1068 ISSUE_PREFIX = conf.get('issue_prefix%s' % pattern_index)
1068 1069
1069 1070 log.debug('pattern suffix `%s` PAT:%s SERVER_LINK:%s PREFIX:%s'
1070 1071 % (pattern_index, ISSUE_PATTERN, ISSUE_SERVER_LNK,
1071 1072 ISSUE_PREFIX))
1072 1073
1073 1074 URL_PAT = re.compile(r'%s' % ISSUE_PATTERN)
1074 1075
1075 1076 def url_func(match_obj):
1076 1077 pref = ''
1077 1078 if match_obj.group().startswith(' '):
1078 1079 pref = ' '
1079 1080
1080 1081 issue_id = ''.join(match_obj.groups())
1081 1082 tmpl = (
1082 1083 '%(pref)s<a class="%(cls)s" href="%(url)s">'
1083 1084 '%(issue-prefix)s%(id-repr)s'
1084 1085 '</a>'
1085 1086 )
1086 1087 url = ISSUE_SERVER_LNK.replace('{id}', issue_id)
1087 1088 if repository:
1088 1089 url = url.replace('{repo}', repository)
1089 1090 repo_name = repository.split(URL_SEP)[-1]
1090 1091 url = url.replace('{repo_name}', repo_name)
1091 1092
1092 1093 return tmpl % {
1093 1094 'pref': pref,
1094 1095 'cls': 'issue-tracker-link',
1095 1096 'url': url,
1096 1097 'id-repr': issue_id,
1097 1098 'issue-prefix': ISSUE_PREFIX,
1098 1099 'serv': ISSUE_SERVER_LNK,
1099 1100 }
1100 1101 newtext = URL_PAT.sub(url_func, newtext)
1101 1102 log.debug('processed prefix:`%s` => %s' % (pattern_index, newtext))
1102 1103
1103 1104 # if we actually did something above
1104 1105 if link_:
1105 1106 # wrap not links into final link => link_
1106 1107 newtext = linkify_others(newtext, link_)
1107 1108 except:
1108 1109 log.error(traceback.format_exc())
1109 1110 pass
1110 1111
1111 1112 return literal(newtext)
1112 1113
1113 1114
1114 1115 def rst(source):
1115 1116 return literal('<div class="rst-block">%s</div>' %
1116 1117 MarkupRenderer.rst(source))
1117 1118
1118 1119
1119 1120 def rst_w_mentions(source):
1120 1121 """
1121 1122 Wrapped rst renderer with @mention highlighting
1122 1123
1123 1124 :param source:
1124 1125 """
1125 1126 return literal('<div class="rst-block">%s</div>' %
1126 1127 MarkupRenderer.rst_with_mentions(source))
1127 1128
1128 1129
1129 1130 def changeset_status(repo, revision):
1130 1131 return ChangesetStatusModel().get_status(repo, revision)
1131 1132
1132 1133
1133 1134 def changeset_status_lbl(changeset_status):
1134 1135 return dict(ChangesetStatus.STATUSES).get(changeset_status)
1135 1136
1136 1137
1137 1138 def get_permission_name(key):
1138 1139 return dict(Permission.PERMS).get(key)
1139 1140
1140 1141
1141 1142 def journal_filter_help():
1142 1143 return _(textwrap.dedent('''
1143 1144 Example filter terms:
1144 1145 repository:vcs
1145 1146 username:marcin
1146 1147 action:*push*
1147 1148 ip:127.0.0.1
1148 1149 date:20120101
1149 1150 date:[20120101100000 TO 20120102]
1150 1151
1151 1152 Generate wildcards using '*' character:
1152 1153 "repositroy:vcs*" - search everything starting with 'vcs'
1153 1154 "repository:*vcs*" - search for repository containing 'vcs'
1154 1155
1155 1156 Optional AND / OR operators in queries
1156 1157 "repository:vcs OR repository:test"
1157 1158 "username:test AND repository:test*"
1158 1159 '''))
General Comments 0
You need to be logged in to leave comments. Login now