helpers.py
590 lines
| 21.4 KiB
| text/x-python
|
PythonLexer
r547 | """Helper functions | |||
Consists of functions to typically be used within templates, but also | ||||
available to Controllers. This module is available to both as 'h'. | ||||
""" | ||||
r734 | import random | |||
import hashlib | ||||
r966 | import StringIO | |||
r547 | from pygments.formatters import HtmlFormatter | |||
from pygments import highlight as code_highlight | ||||
r1022 | from pylons import url | |||
r547 | from pylons.i18n.translation import _, ungettext | |||
from vcs.utils.annotate import annotate_highlight | ||||
r1022 | from rhodecode.lib.utils import repo_name_slug | |||
r547 | from webhelpers.html import literal, HTML, escape | |||
from webhelpers.html.tools import * | ||||
from webhelpers.html.builder import make_tag | ||||
from webhelpers.html.tags import auto_discovery_link, checkbox, css_classes, \ | ||||
end_form, file, form, hidden, image, javascript_link, link_to, link_to_if, \ | ||||
link_to_unless, ol, required_legend, select, stylesheet_link, submit, text, \ | ||||
password, textarea, title, ul, xml_declaration, radio | ||||
from webhelpers.html.tools import auto_link, button_to, highlight, js_obfuscate, \ | ||||
mail_to, strip_links, strip_tags, tag_re | ||||
from webhelpers.number import format_byte_size, format_bit_size | ||||
from webhelpers.pylonslib import Flash as _Flash | ||||
from webhelpers.pylonslib.secure_form import secure_form | ||||
from webhelpers.text import chop_at, collapse, convert_accented_entities, \ | ||||
convert_misc_entities, lchop, plural, rchop, remove_formatting, \ | ||||
replace_whitespace, urlify, truncate, wrap_paragraphs | ||||
r635 | from webhelpers.date import time_ago_in_words | |||
r547 | ||||
r698 | from webhelpers.html.tags import _set_input_attrs, _set_id_attr, \ | |||
convert_boolean_attrs, NotGiven | ||||
def _reset(name, value=None, id=NotGiven, type="reset", **attrs): | ||||
r899 | """Reset button | |||
""" | ||||
r698 | _set_input_attrs(attrs, type, name, value) | |||
_set_id_attr(attrs, id, name) | ||||
convert_boolean_attrs(attrs, ["disabled"]) | ||||
return HTML.input(**attrs) | ||||
reset = _reset | ||||
r734 | ||||
def get_token(): | ||||
"""Return the current authentication token, creating one if one doesn't | ||||
already exist. | ||||
""" | ||||
token_key = "_authentication_token" | ||||
from pylons import session | ||||
if not token_key in session: | ||||
try: | ||||
token = hashlib.sha1(str(random.getrandbits(128))).hexdigest() | ||||
except AttributeError: # Python < 2.4 | ||||
token = hashlib.sha1(str(random.randrange(2 ** 128))).hexdigest() | ||||
session[token_key] = token | ||||
if hasattr(session, 'save'): | ||||
session.save() | ||||
return session[token_key] | ||||
r547 | class _GetError(object): | |||
r899 | """Get error from form_errors, and represent it as span wrapped error | |||
message | ||||
:param field_name: field to fetch errors for | ||||
:param form_errors: form errors dict | ||||
""" | ||||
r547 | ||||
def __call__(self, field_name, form_errors): | ||||
tmpl = """<span class="error_msg">%s</span>""" | ||||
if form_errors and form_errors.has_key(field_name): | ||||
return literal(tmpl % form_errors.get(field_name)) | ||||
get_error = _GetError() | ||||
class _ToolTip(object): | ||||
r631 | ||||
r547 | def __call__(self, tooltip_title, trim_at=50): | |||
r905 | """Special function just to wrap our text into nice formatted | |||
autowrapped text | ||||
r604 | :param tooltip_title: | |||
r547 | """ | |||
r631 | ||||
r547 | return wrap_paragraphs(escape(tooltip_title), trim_at)\ | |||
.replace('\n', '<br/>') | ||||
r631 | ||||
r547 | def activate(self): | |||
r904 | """Adds tooltip mechanism to the given Html all tooltips have to have | |||
set class `tooltip` and set attribute `tooltip_title`. | ||||
Then a tooltip will be generated based on that. All with yui js tooltip | ||||
r547 | """ | |||
r631 | ||||
r547 | js = ''' | |||
YAHOO.util.Event.onDOMReady(function(){ | ||||
function toolTipsId(){ | ||||
var ids = []; | ||||
var tts = YAHOO.util.Dom.getElementsByClassName('tooltip'); | ||||
for (var i = 0; i < tts.length; i++) { | ||||
r904 | //if element doesn't not have and id autogenerate one for tooltip | |||
r547 | ||||
if (!tts[i].id){ | ||||
tts[i].id='tt'+i*100; | ||||
} | ||||
ids.push(tts[i].id); | ||||
} | ||||
return ids | ||||
}; | ||||
var myToolTips = new YAHOO.widget.Tooltip("tooltip", { | ||||
context: toolTipsId(), | ||||
monitorresize:false, | ||||
xyoffset :[0,0], | ||||
autodismissdelay:300000, | ||||
hidedelay:5, | ||||
showdelay:20, | ||||
}); | ||||
// Set the text for the tooltip just before we display it. Lazy method | ||||
myToolTips.contextTriggerEvent.subscribe( | ||||
function(type, args) { | ||||
var context = args[0]; | ||||
r904 | //positioning of tooltip | |||
var tt_w = this.element.clientWidth;//tooltip width | ||||
var tt_h = this.element.clientHeight;//tooltip height | ||||
r547 | ||||
var context_w = context.offsetWidth; | ||||
var context_h = context.offsetHeight; | ||||
var pos_x = YAHOO.util.Dom.getX(context); | ||||
var pos_y = YAHOO.util.Dom.getY(context); | ||||
r904 | var display_strategy = 'right'; | |||
r547 | var xy_pos = [0,0]; | |||
switch (display_strategy){ | ||||
case 'top': | ||||
var cur_x = (pos_x+context_w/2)-(tt_w/2); | ||||
r904 | var cur_y = (pos_y-tt_h-4); | |||
r547 | xy_pos = [cur_x,cur_y]; | |||
break; | ||||
case 'bottom': | ||||
var cur_x = (pos_x+context_w/2)-(tt_w/2); | ||||
var cur_y = pos_y+context_h+4; | ||||
xy_pos = [cur_x,cur_y]; | ||||
break; | ||||
case 'left': | ||||
var cur_x = (pos_x-tt_w-4); | ||||
var cur_y = pos_y-((tt_h/2)-context_h/2); | ||||
xy_pos = [cur_x,cur_y]; | ||||
break; | ||||
case 'right': | ||||
var cur_x = (pos_x+context_w+4); | ||||
var cur_y = pos_y-((tt_h/2)-context_h/2); | ||||
xy_pos = [cur_x,cur_y]; | ||||
break; | ||||
default: | ||||
var cur_x = (pos_x+context_w/2)-(tt_w/2); | ||||
var cur_y = pos_y-tt_h-4; | ||||
xy_pos = [cur_x,cur_y]; | ||||
break; | ||||
} | ||||
this.cfg.setProperty("xy",xy_pos); | ||||
}); | ||||
//Mouse out | ||||
myToolTips.contextMouseOutEvent.subscribe( | ||||
function(type, args) { | ||||
var context = args[0]; | ||||
}); | ||||
}); | ||||
r631 | ''' | |||
r547 | return literal(js) | |||
tooltip = _ToolTip() | ||||
class _FilesBreadCrumbs(object): | ||||
r631 | ||||
r547 | def __call__(self, repo_name, rev, paths): | |||
r955 | if isinstance(paths, str): | |||
paths = paths.decode('utf-8') | ||||
r547 | url_l = [link_to(repo_name, url('files_home', | |||
repo_name=repo_name, | ||||
revision=rev, f_path=''))] | ||||
paths_l = paths.split('/') | ||||
r740 | for cnt, p in enumerate(paths_l): | |||
r547 | if p != '': | |||
url_l.append(link_to(p, url('files_home', | ||||
repo_name=repo_name, | ||||
revision=rev, | ||||
r740 | f_path='/'.join(paths_l[:cnt + 1])))) | |||
r547 | ||||
return literal('/'.join(url_l)) | ||||
files_breadcrumbs = _FilesBreadCrumbs() | ||||
r899 | ||||
r547 | class CodeHtmlFormatter(HtmlFormatter): | |||
r966 | """My code Html Formatter for source codes | |||
""" | ||||
r547 | ||||
def wrap(self, source, outfile): | ||||
return self._wrap_div(self._wrap_pre(self._wrap_code(source))) | ||||
def _wrap_code(self, source): | ||||
r740 | for cnt, it in enumerate(source): | |||
r547 | i, t = it | |||
r966 | t = '<div id="L%s">%s</div>' % (cnt + 1, t) | |||
r547 | yield i, t | |||
r966 | ||||
def _wrap_tablelinenos(self, inner): | ||||
dummyoutfile = StringIO.StringIO() | ||||
lncount = 0 | ||||
for t, line in inner: | ||||
if t: | ||||
lncount += 1 | ||||
dummyoutfile.write(line) | ||||
fl = self.linenostart | ||||
mw = len(str(lncount + fl - 1)) | ||||
sp = self.linenospecial | ||||
st = self.linenostep | ||||
la = self.lineanchors | ||||
aln = self.anchorlinenos | ||||
nocls = self.noclasses | ||||
if sp: | ||||
lines = [] | ||||
for i in range(fl, fl + lncount): | ||||
if i % st == 0: | ||||
if i % sp == 0: | ||||
if aln: | ||||
lines.append('<a href="#%s%d" class="special">%*d</a>' % | ||||
(la, i, mw, i)) | ||||
else: | ||||
lines.append('<span class="special">%*d</span>' % (mw, i)) | ||||
else: | ||||
if aln: | ||||
lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i)) | ||||
else: | ||||
lines.append('%*d' % (mw, i)) | ||||
else: | ||||
lines.append('') | ||||
ls = '\n'.join(lines) | ||||
else: | ||||
lines = [] | ||||
for i in range(fl, fl + lncount): | ||||
if i % st == 0: | ||||
if aln: | ||||
lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i)) | ||||
else: | ||||
lines.append('%*d' % (mw, i)) | ||||
else: | ||||
lines.append('') | ||||
ls = '\n'.join(lines) | ||||
# in case you wonder about the seemingly redundant <div> here: since the | ||||
# content in the other cell also is wrapped in a div, some browsers in | ||||
# some configurations seem to mess up the formatting... | ||||
if nocls: | ||||
yield 0, ('<table class="%stable">' % self.cssclass + | ||||
'<tr><td><div class="linenodiv" ' | ||||
'style="background-color: #f0f0f0; padding-right: 10px">' | ||||
'<pre style="line-height: 125%">' + | ||||
ls + '</pre></div></td><td class="code">') | ||||
else: | ||||
yield 0, ('<table class="%stable">' % self.cssclass + | ||||
'<tr><td class="linenos"><div class="linenodiv"><pre>' + | ||||
ls + '</pre></div></td><td class="code">') | ||||
yield 0, dummyoutfile.getvalue() | ||||
yield 0, '</td></tr></table>' | ||||
r547 | def pygmentize(filenode, **kwargs): | |||
r899 | """pygmentize function using pygments | |||
r604 | :param filenode: | |||
r547 | """ | |||
r899 | ||||
r547 | return literal(code_highlight(filenode.content, | |||
filenode.lexer, CodeHtmlFormatter(**kwargs))) | ||||
def pygmentize_annotation(filenode, **kwargs): | ||||
r899 | """pygmentize function for annotation | |||
r604 | :param filenode: | |||
r547 | """ | |||
r631 | ||||
r547 | color_dict = {} | |||
r947 | def gen_color(n=10000): | |||
"""generator for getting n of evenly distributed colors using | ||||
hsv color and golden ratio. It always return same order of colors | ||||
:returns: RGB tuple | ||||
r631 | """ | |||
r547 | import colorsys | |||
golden_ratio = 0.618033988749895 | ||||
h = 0.22717784590367374 | ||||
r947 | ||||
r547 | for c in xrange(n): | |||
h += golden_ratio | ||||
h %= 1 | ||||
HSV_tuple = [h, 0.95, 0.95] | ||||
RGB_tuple = colorsys.hsv_to_rgb(*HSV_tuple) | ||||
r631 | yield map(lambda x:str(int(x * 256)), RGB_tuple) | |||
r547 | ||||
cgenerator = gen_color() | ||||
r631 | ||||
r547 | def get_color_string(cs): | |||
if color_dict.has_key(cs): | ||||
col = color_dict[cs] | ||||
else: | ||||
col = color_dict[cs] = cgenerator.next() | ||||
return "color: rgb(%s)! important;" % (', '.join(col)) | ||||
r631 | ||||
r547 | def url_func(changeset): | |||
tooltip_html = "<div style='font-size:0.8em'><b>Author:</b>" + \ | ||||
r631 | " %s<br/><b>Date:</b> %s</b><br/><b>Message:</b> %s<br/></div>" | |||
r547 | tooltip_html = tooltip_html % (changeset.author, | |||
changeset.date, | ||||
tooltip(changeset.message)) | ||||
r662 | lnk_format = '%5s:%s' % ('r%s' % changeset.revision, | |||
short_id(changeset.raw_id)) | ||||
r547 | uri = link_to( | |||
lnk_format, | ||||
url('changeset_home', repo_name=changeset.repository.name, | ||||
r636 | revision=changeset.raw_id), | |||
style=get_color_string(changeset.raw_id), | ||||
r547 | class_='tooltip', | |||
r904 | title=tooltip_html | |||
r547 | ) | |||
r631 | ||||
r547 | uri += '\n' | |||
r631 | return uri | |||
r547 | return literal(annotate_highlight(filenode, url_func, **kwargs)) | |||
r631 | ||||
r547 | def get_changeset_safe(repo, rev): | |||
from vcs.backends.base import BaseRepository | ||||
from vcs.exceptions import RepositoryError | ||||
if not isinstance(repo, BaseRepository): | ||||
raise Exception('You must pass an Repository ' | ||||
'object as first argument got %s', type(repo)) | ||||
r631 | ||||
r547 | try: | |||
cs = repo.get_changeset(rev) | ||||
except RepositoryError: | ||||
from rhodecode.lib.utils import EmptyChangeset | ||||
cs = EmptyChangeset() | ||||
return cs | ||||
r999 | def is_following_repo(repo_name, user_id): | |||
from rhodecode.model.scm import ScmModel | ||||
return ScmModel().is_following_repo(repo_name, user_id) | ||||
r547 | flash = _Flash() | |||
r635 | #============================================================================== | |||
r547 | # MERCURIAL FILTERS available via h. | |||
r635 | #============================================================================== | |||
r547 | from mercurial import util | |||
r635 | from mercurial.templatefilters import person as _person | |||
def _age(curdate): | ||||
"""turns a datetime into an age string.""" | ||||
r660 | ||||
r643 | if not curdate: | |||
return '' | ||||
r547 | ||||
r635 | from datetime import timedelta, datetime | |||
r643 | ||||
r635 | agescales = [("year", 3600 * 24 * 365), | |||
r653 | ("month", 3600 * 24 * 30), | |||
("day", 3600 * 24), | ||||
("hour", 3600), | ||||
("minute", 60), | ||||
("second", 1), ] | ||||
r635 | ||||
age = datetime.now() - curdate | ||||
age_seconds = (age.days * agescales[2][1]) + age.seconds | ||||
pos = 1 | ||||
for scale in agescales: | ||||
if scale[1] <= age_seconds: | ||||
r653 | if pos == 6:pos = 5 | |||
r668 | return time_ago_in_words(curdate, agescales[pos][0]) + ' ' + _('ago') | |||
r635 | pos += 1 | |||
r668 | return _('just now') | |||
r635 | age = lambda x:_age(x) | |||
r547 | capitalize = lambda x: x.capitalize() | |||
email = util.email | ||||
email_or_none = lambda x: util.email(x) if util.email(x) != x else None | ||||
person = lambda x: _person(x) | ||||
r636 | short_id = lambda x: x[:12] | |||
r547 | ||||
r660 | ||||
r712 | def bool2icon(value): | |||
r899 | """Returns True/False values represented as small html image of true/false | |||
r712 | icons | |||
r899 | ||||
r712 | :param value: bool value | |||
""" | ||||
if value is True: | ||||
r714 | return HTML.tag('img', src="/images/icons/accept.png", alt=_('True')) | |||
r712 | ||||
if value is False: | ||||
r714 | return HTML.tag('img', src="/images/icons/cancel.png", alt=_('False')) | |||
r712 | ||||
return value | ||||
r660 | def action_parser(user_log): | |||
r899 | """This helper will map the specified string action into translated | |||
r660 | fancy names with icons and links | |||
r899 | :param user_log: user log instance | |||
r660 | """ | |||
r899 | ||||
r660 | action = user_log.action | |||
r840 | action_params = ' ' | |||
r660 | ||||
x = action.split(':') | ||||
if len(x) > 1: | ||||
action, action_params = x | ||||
r718 | def get_cs_links(): | |||
r953 | revs_limit = 5 #display this amount always | |||
revs_top_limit = 50 #show upto this amount of changesets hidden | ||||
revs = action_params.split(',') | ||||
repo_name = user_log.repository.repo_name | ||||
from rhodecode.model.scm import ScmModel | ||||
r1040 | repo, dbrepo = ScmModel().get(repo_name, retval='repo') | |||
message = lambda rev: get_changeset_safe(repo, rev).message | ||||
r899 | ||||
r953 | cs_links = " " + ', '.join ([link_to(rev, | |||
url('changeset_home', | ||||
repo_name=repo_name, | ||||
revision=rev), title=tooltip(message(rev)), | ||||
class_='tooltip') for rev in revs[:revs_limit] ]) | ||||
r1009 | ||||
compare_view = (' <div class="compare_view tooltip" title="%s">' | ||||
'<a href="%s">%s</a> ' | ||||
'</div>' % (_('Show all combined changesets %s->%s' \ | ||||
% (revs[0], revs[-1])), | ||||
url('changeset_home', repo_name=repo_name, | ||||
revision='%s...%s' % (revs[0], revs[-1]) | ||||
), | ||||
_('compare view')) | ||||
) | ||||
r953 | if len(revs) > revs_limit: | |||
uniq_id = revs[0] | ||||
html_tmpl = ('<span> %s ' | ||||
r995 | '<a class="show_more" id="_%s" href="#more">%s</a> ' | |||
r953 | '%s</span>') | |||
cs_links += html_tmpl % (_('and'), uniq_id, _('%s more') \ | ||||
% (len(revs) - revs_limit), | ||||
_('revisions')) | ||||
r808 | ||||
r953 | html_tmpl = '<span id="%s" style="display:none"> %s </span>' | |||
cs_links += html_tmpl % (uniq_id, ', '.join([link_to(rev, | ||||
url('changeset_home', | ||||
repo_name=repo_name, revision=rev), | ||||
title=message(rev), class_='tooltip') | ||||
for rev in revs[revs_limit:revs_top_limit]])) | ||||
r1024 | if len(revs) > 1: | |||
cs_links += compare_view | ||||
r953 | return cs_links | |||
r734 | ||||
r718 | def get_fork_name(): | |||
r953 | from rhodecode.model.scm import ScmModel | |||
repo_name = action_params | ||||
r1038 | repo, dbrepo = ScmModel().get(repo_name) | |||
r953 | if repo is None: | |||
return repo_name | ||||
return link_to(action_params, url('summary_home', | ||||
repo_name=repo.name,), | ||||
r1038 | title=dbrepo.description) | |||
r953 | ||||
map = {'user_deleted_repo':(_('User [deleted] repository'), None), | ||||
'user_created_repo':(_('User [created] repository'), None), | ||||
'user_forked_repo':(_('User [forked] repository as:'), get_fork_name), | ||||
'user_updated_repo':(_('User [updated] repository'), None), | ||||
'admin_deleted_repo':(_('Admin [delete] repository'), None), | ||||
'admin_created_repo':(_('Admin [created] repository'), None), | ||||
'admin_forked_repo':(_('Admin [forked] repository'), None), | ||||
'admin_updated_repo':(_('Admin [updated] repository'), None), | ||||
'push':(_('[Pushed]'), get_cs_links), | ||||
'pull':(_('[Pulled]'), None), | ||||
'started_following_repo':(_('User [started following] repository'), None), | ||||
'stopped_following_repo':(_('User [stopped following] repository'), None), | ||||
r735 | } | |||
r660 | ||||
r764 | action_str = map.get(action, action) | |||
r953 | action = action_str[0].replace('[', '<span class="journal_highlight">')\ | |||
.replace(']', '</span>') | ||||
if action_str[1] is not None: | ||||
action = action + " " + action_str[1]() | ||||
return literal(action) | ||||
r808 | ||||
def action_parser_icon(user_log): | ||||
action = user_log.action | ||||
action_params = None | ||||
x = action.split(':') | ||||
if len(x) > 1: | ||||
action, action_params = x | ||||
r817 | tmpl = """<img src="/images/icons/%s" alt="%s"/>""" | |||
r808 | map = {'user_deleted_repo':'database_delete.png', | |||
'user_created_repo':'database_add.png', | ||||
'user_forked_repo':'arrow_divide.png', | ||||
'user_updated_repo':'database_edit.png', | ||||
'admin_deleted_repo':'database_delete.png', | ||||
r899 | 'admin_created_repo':'database_add.png', | |||
r808 | 'admin_forked_repo':'arrow_divide.png', | |||
'admin_updated_repo':'database_edit.png', | ||||
'push':'script_add.png', | ||||
'pull':'down_16.png', | ||||
'started_following_repo':'heart_add.png', | ||||
'stopped_following_repo':'heart_delete.png', | ||||
} | ||||
r817 | return literal(tmpl % (map.get(action, action), action)) | |||
r660 | ||||
r635 | #============================================================================== | |||
r547 | # PERMS | |||
r635 | #============================================================================== | |||
r547 | from rhodecode.lib.auth import HasPermissionAny, HasPermissionAll, \ | |||
HasRepoPermissionAny, HasRepoPermissionAll | ||||
r635 | #============================================================================== | |||
r547 | # GRAVATAR URL | |||
r635 | #============================================================================== | |||
r547 | import hashlib | |||
import urllib | ||||
from pylons import request | ||||
def gravatar_url(email_address, size=30): | ||||
r946 | ssl_enabled = 'https' == request.environ.get('wsgi.url_scheme') | |||
r547 | default = 'identicon' | |||
baseurl_nossl = "http://www.gravatar.com/avatar/" | ||||
baseurl_ssl = "https://secure.gravatar.com/avatar/" | ||||
baseurl = baseurl_ssl if ssl_enabled else baseurl_nossl | ||||
r631 | ||||
r547 | # construct the url | |||
gravatar_url = baseurl + hashlib.md5(email_address.lower()).hexdigest() + "?" | ||||
gravatar_url += urllib.urlencode({'d':default, 's':str(size)}) | ||||
return gravatar_url | ||||
def safe_unicode(str): | ||||
"""safe unicode function. In case of UnicodeDecode error we try to return | ||||
unicode with errors replace, if this failes we return unicode with | ||||
string_escape decoding """ | ||||
r631 | ||||
r547 | try: | |||
u_str = unicode(str) | ||||
except UnicodeDecodeError: | ||||
try: | ||||
u_str = unicode(str, 'utf-8', 'replace') | ||||
except UnicodeDecodeError: | ||||
#incase we have a decode error just represent as byte string | ||||
u_str = unicode(str(str).encode('string_escape')) | ||||
r631 | ||||
r547 | return u_str | |||
r990 | ||||
def changed_tooltip(nodes): | ||||
if nodes: | ||||
pref = ': <br/> ' | ||||
suf = '' | ||||
if len(nodes) > 30: | ||||
suf = '<br/>' + _(' and %s more') % (len(nodes) - 30) | ||||
return literal(pref + '<br/> '.join([x.path for x in nodes[:30]]) + suf) | ||||
else: | ||||
return ': ' + _('No Files') | ||||