##// END OF EJS Templates
helpers: use pre-comiled patterns for PRs for small speedup.
bart -
r4203:8c331388 stable
parent child Browse files
Show More
@@ -1,1951 +1,1954 b''
1 1 # -*- coding: utf-8 -*-
2 2
3 3 # Copyright (C) 2010-2019 RhodeCode GmbH
4 4 #
5 5 # This program is free software: you can redistribute it and/or modify
6 6 # it under the terms of the GNU Affero General Public License, version 3
7 7 # (only), as published by the Free Software Foundation.
8 8 #
9 9 # This program is distributed in the hope that it will be useful,
10 10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
11 11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 12 # GNU General Public License for more details.
13 13 #
14 14 # You should have received a copy of the GNU Affero General Public License
15 15 # along with this program. If not, see <http://www.gnu.org/licenses/>.
16 16 #
17 17 # This program is dual-licensed. If you wish to learn more about the
18 18 # RhodeCode Enterprise Edition, including its added features, Support services,
19 19 # and proprietary license terms, please see https://rhodecode.com/licenses/
20 20
21 21 """
22 22 Helper functions
23 23
24 24 Consists of functions to typically be used within templates, but also
25 25 available to Controllers. This module is available to both as 'h'.
26 26 """
27 27
28 28 import os
29 29 import random
30 30 import hashlib
31 31 import StringIO
32 32 import textwrap
33 33 import urllib
34 34 import math
35 35 import logging
36 36 import re
37 37 import time
38 38 import string
39 39 import hashlib
40 40 from collections import OrderedDict
41 41
42 42 import pygments
43 43 import itertools
44 44 import fnmatch
45 45 import bleach
46 46
47 47 from pyramid import compat
48 48 from datetime import datetime
49 49 from functools import partial
50 50 from pygments.formatters.html import HtmlFormatter
51 51 from pygments.lexers import (
52 52 get_lexer_by_name, get_lexer_for_filename, get_lexer_for_mimetype)
53 53
54 54 from pyramid.threadlocal import get_current_request
55 55
56 56 from webhelpers2.html import literal, HTML, escape
57 57 from webhelpers2.html._autolink import _auto_link_urls
58 58 from webhelpers2.html.tools import (
59 59 button_to, highlight, js_obfuscate, strip_links, strip_tags)
60 60
61 61 from webhelpers2.text import (
62 62 chop_at, collapse, convert_accented_entities,
63 63 convert_misc_entities, lchop, plural, rchop, remove_formatting,
64 64 replace_whitespace, urlify, truncate, wrap_paragraphs)
65 65 from webhelpers2.date import time_ago_in_words
66 66
67 67 from webhelpers2.html.tags import (
68 68 _input, NotGiven, _make_safe_id_component as safeid,
69 69 form as insecure_form,
70 70 auto_discovery_link, checkbox, end_form, file,
71 71 hidden, image, javascript_link, link_to, link_to_if, link_to_unless, ol,
72 72 select as raw_select, stylesheet_link, submit, text, password, textarea,
73 73 ul, radio, Options)
74 74
75 75 from webhelpers2.number import format_byte_size
76 76
77 77 from rhodecode.lib.action_parser import action_parser
78 78 from rhodecode.lib.pagination import Page, RepoPage, SqlPage
79 79 from rhodecode.lib.ext_json import json
80 80 from rhodecode.lib.utils import repo_name_slug, get_custom_lexer
81 81 from rhodecode.lib.utils2 import (
82 82 str2bool, safe_unicode, safe_str,
83 83 get_commit_safe, datetime_to_time, time_to_datetime, time_to_utcdatetime,
84 84 AttributeDict, safe_int, md5, md5_safe, get_host_info)
85 85 from rhodecode.lib.markup_renderer import MarkupRenderer, relative_links
86 86 from rhodecode.lib.vcs.exceptions import CommitDoesNotExistError
87 87 from rhodecode.lib.vcs.backends.base import BaseChangeset, EmptyCommit
88 88 from rhodecode.lib.index.search_utils import get_matching_line_offsets
89 89 from rhodecode.config.conf import DATE_FORMAT, DATETIME_FORMAT
90 90 from rhodecode.model.changeset_status import ChangesetStatusModel
91 91 from rhodecode.model.db import Permission, User, Repository
92 92 from rhodecode.model.repo_group import RepoGroupModel
93 93 from rhodecode.model.settings import IssueTrackerSettingsModel
94 94
95 95
96 96 log = logging.getLogger(__name__)
97 97
98 98
99 99 DEFAULT_USER = User.DEFAULT_USER
100 100 DEFAULT_USER_EMAIL = User.DEFAULT_USER_EMAIL
101 101
102 102
103 103 def asset(path, ver=None, **kwargs):
104 104 """
105 105 Helper to generate a static asset file path for rhodecode assets
106 106
107 107 eg. h.asset('images/image.png', ver='3923')
108 108
109 109 :param path: path of asset
110 110 :param ver: optional version query param to append as ?ver=
111 111 """
112 112 request = get_current_request()
113 113 query = {}
114 114 query.update(kwargs)
115 115 if ver:
116 116 query = {'ver': ver}
117 117 return request.static_path(
118 118 'rhodecode:public/{}'.format(path), _query=query)
119 119
120 120
121 121 default_html_escape_table = {
122 122 ord('&'): u'&amp;',
123 123 ord('<'): u'&lt;',
124 124 ord('>'): u'&gt;',
125 125 ord('"'): u'&quot;',
126 126 ord("'"): u'&#39;',
127 127 }
128 128
129 129
130 130 def html_escape(text, html_escape_table=default_html_escape_table):
131 131 """Produce entities within text."""
132 132 return text.translate(html_escape_table)
133 133
134 134
135 135 def chop_at_smart(s, sub, inclusive=False, suffix_if_chopped=None):
136 136 """
137 137 Truncate string ``s`` at the first occurrence of ``sub``.
138 138
139 139 If ``inclusive`` is true, truncate just after ``sub`` rather than at it.
140 140 """
141 141 suffix_if_chopped = suffix_if_chopped or ''
142 142 pos = s.find(sub)
143 143 if pos == -1:
144 144 return s
145 145
146 146 if inclusive:
147 147 pos += len(sub)
148 148
149 149 chopped = s[:pos]
150 150 left = s[pos:].strip()
151 151
152 152 if left and suffix_if_chopped:
153 153 chopped += suffix_if_chopped
154 154
155 155 return chopped
156 156
157 157
158 158 def shorter(text, size=20, prefix=False):
159 159 postfix = '...'
160 160 if len(text) > size:
161 161 if prefix:
162 162 # shorten in front
163 163 return postfix + text[-(size - len(postfix)):]
164 164 else:
165 165 return text[:size - len(postfix)] + postfix
166 166 return text
167 167
168 168
169 169 def reset(name, value=None, id=NotGiven, type="reset", **attrs):
170 170 """
171 171 Reset button
172 172 """
173 173 return _input(type, name, value, id, attrs)
174 174
175 175
176 176 def select(name, selected_values, options, id=NotGiven, **attrs):
177 177
178 178 if isinstance(options, (list, tuple)):
179 179 options_iter = options
180 180 # Handle old value,label lists ... where value also can be value,label lists
181 181 options = Options()
182 182 for opt in options_iter:
183 183 if isinstance(opt, tuple) and len(opt) == 2:
184 184 value, label = opt
185 185 elif isinstance(opt, basestring):
186 186 value = label = opt
187 187 else:
188 188 raise ValueError('invalid select option type %r' % type(opt))
189 189
190 190 if isinstance(value, (list, tuple)):
191 191 option_group = options.add_optgroup(label)
192 192 for opt2 in value:
193 193 if isinstance(opt2, tuple) and len(opt2) == 2:
194 194 group_value, group_label = opt2
195 195 elif isinstance(opt2, basestring):
196 196 group_value = group_label = opt2
197 197 else:
198 198 raise ValueError('invalid select option type %r' % type(opt2))
199 199
200 200 option_group.add_option(group_label, group_value)
201 201 else:
202 202 options.add_option(label, value)
203 203
204 204 return raw_select(name, selected_values, options, id=id, **attrs)
205 205
206 206
207 207 def branding(name, length=40):
208 208 return truncate(name, length, indicator="")
209 209
210 210
211 211 def FID(raw_id, path):
212 212 """
213 213 Creates a unique ID for filenode based on it's hash of path and commit
214 214 it's safe to use in urls
215 215
216 216 :param raw_id:
217 217 :param path:
218 218 """
219 219
220 220 return 'c-%s-%s' % (short_id(raw_id), md5_safe(path)[:12])
221 221
222 222
223 223 class _GetError(object):
224 224 """Get error from form_errors, and represent it as span wrapped error
225 225 message
226 226
227 227 :param field_name: field to fetch errors for
228 228 :param form_errors: form errors dict
229 229 """
230 230
231 231 def __call__(self, field_name, form_errors):
232 232 tmpl = """<span class="error_msg">%s</span>"""
233 233 if form_errors and field_name in form_errors:
234 234 return literal(tmpl % form_errors.get(field_name))
235 235
236 236
237 237 get_error = _GetError()
238 238
239 239
240 240 class _ToolTip(object):
241 241
242 242 def __call__(self, tooltip_title, trim_at=50):
243 243 """
244 244 Special function just to wrap our text into nice formatted
245 245 autowrapped text
246 246
247 247 :param tooltip_title:
248 248 """
249 249 tooltip_title = escape(tooltip_title)
250 250 tooltip_title = tooltip_title.replace('<', '&lt;').replace('>', '&gt;')
251 251 return tooltip_title
252 252
253 253
254 254 tooltip = _ToolTip()
255 255
256 256 files_icon = u'<i class="file-breadcrumb-copy tooltip icon-clipboard clipboard-action" data-clipboard-text="{}" title="Copy the full path"></i>'
257 257
258 258
259 259 def files_breadcrumbs(repo_name, commit_id, file_path, at_ref=None, limit_items=False, linkify_last_item=False):
260 260 if isinstance(file_path, str):
261 261 file_path = safe_unicode(file_path)
262 262
263 263 route_qry = {'at': at_ref} if at_ref else None
264 264
265 265 # first segment is a `..` link to repo files
266 266 root_name = literal(u'<i class="icon-home"></i>')
267 267 url_segments = [
268 268 link_to(
269 269 root_name,
270 270 route_path(
271 271 'repo_files',
272 272 repo_name=repo_name,
273 273 commit_id=commit_id,
274 274 f_path='',
275 275 _query=route_qry),
276 276 )]
277 277
278 278 path_segments = file_path.split('/')
279 279 last_cnt = len(path_segments) - 1
280 280 for cnt, segment in enumerate(path_segments):
281 281 if not segment:
282 282 continue
283 283 segment_html = escape(segment)
284 284
285 285 last_item = cnt == last_cnt
286 286
287 287 if last_item and linkify_last_item is False:
288 288 # plain version
289 289 url_segments.append(segment_html)
290 290 else:
291 291 url_segments.append(
292 292 link_to(
293 293 segment_html,
294 294 route_path(
295 295 'repo_files',
296 296 repo_name=repo_name,
297 297 commit_id=commit_id,
298 298 f_path='/'.join(path_segments[:cnt + 1]),
299 299 _query=route_qry),
300 300 ))
301 301
302 302 limited_url_segments = url_segments[:1] + ['...'] + url_segments[-5:]
303 303 if limit_items and len(limited_url_segments) < len(url_segments):
304 304 url_segments = limited_url_segments
305 305
306 306 full_path = file_path
307 307 icon = files_icon.format(escape(full_path))
308 308 if file_path == '':
309 309 return root_name
310 310 else:
311 311 return literal(' / '.join(url_segments) + icon)
312 312
313 313
314 314 def files_url_data(request):
315 315 matchdict = request.matchdict
316 316
317 317 if 'f_path' not in matchdict:
318 318 matchdict['f_path'] = ''
319 319
320 320 if 'commit_id' not in matchdict:
321 321 matchdict['commit_id'] = 'tip'
322 322
323 323 return json.dumps(matchdict)
324 324
325 325
326 326 def code_highlight(code, lexer, formatter, use_hl_filter=False):
327 327 """
328 328 Lex ``code`` with ``lexer`` and format it with the formatter ``formatter``.
329 329
330 330 If ``outfile`` is given and a valid file object (an object
331 331 with a ``write`` method), the result will be written to it, otherwise
332 332 it is returned as a string.
333 333 """
334 334 if use_hl_filter:
335 335 # add HL filter
336 336 from rhodecode.lib.index import search_utils
337 337 lexer.add_filter(search_utils.ElasticSearchHLFilter())
338 338 return pygments.format(pygments.lex(code, lexer), formatter)
339 339
340 340
341 341 class CodeHtmlFormatter(HtmlFormatter):
342 342 """
343 343 My code Html Formatter for source codes
344 344 """
345 345
346 346 def wrap(self, source, outfile):
347 347 return self._wrap_div(self._wrap_pre(self._wrap_code(source)))
348 348
349 349 def _wrap_code(self, source):
350 350 for cnt, it in enumerate(source):
351 351 i, t = it
352 352 t = '<div id="L%s">%s</div>' % (cnt + 1, t)
353 353 yield i, t
354 354
355 355 def _wrap_tablelinenos(self, inner):
356 356 dummyoutfile = StringIO.StringIO()
357 357 lncount = 0
358 358 for t, line in inner:
359 359 if t:
360 360 lncount += 1
361 361 dummyoutfile.write(line)
362 362
363 363 fl = self.linenostart
364 364 mw = len(str(lncount + fl - 1))
365 365 sp = self.linenospecial
366 366 st = self.linenostep
367 367 la = self.lineanchors
368 368 aln = self.anchorlinenos
369 369 nocls = self.noclasses
370 370 if sp:
371 371 lines = []
372 372
373 373 for i in range(fl, fl + lncount):
374 374 if i % st == 0:
375 375 if i % sp == 0:
376 376 if aln:
377 377 lines.append('<a href="#%s%d" class="special">%*d</a>' %
378 378 (la, i, mw, i))
379 379 else:
380 380 lines.append('<span class="special">%*d</span>' % (mw, i))
381 381 else:
382 382 if aln:
383 383 lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i))
384 384 else:
385 385 lines.append('%*d' % (mw, i))
386 386 else:
387 387 lines.append('')
388 388 ls = '\n'.join(lines)
389 389 else:
390 390 lines = []
391 391 for i in range(fl, fl + lncount):
392 392 if i % st == 0:
393 393 if aln:
394 394 lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i))
395 395 else:
396 396 lines.append('%*d' % (mw, i))
397 397 else:
398 398 lines.append('')
399 399 ls = '\n'.join(lines)
400 400
401 401 # in case you wonder about the seemingly redundant <div> here: since the
402 402 # content in the other cell also is wrapped in a div, some browsers in
403 403 # some configurations seem to mess up the formatting...
404 404 if nocls:
405 405 yield 0, ('<table class="%stable">' % self.cssclass +
406 406 '<tr><td><div class="linenodiv" '
407 407 'style="background-color: #f0f0f0; padding-right: 10px">'
408 408 '<pre style="line-height: 125%">' +
409 409 ls + '</pre></div></td><td id="hlcode" class="code">')
410 410 else:
411 411 yield 0, ('<table class="%stable">' % self.cssclass +
412 412 '<tr><td class="linenos"><div class="linenodiv"><pre>' +
413 413 ls + '</pre></div></td><td id="hlcode" class="code">')
414 414 yield 0, dummyoutfile.getvalue()
415 415 yield 0, '</td></tr></table>'
416 416
417 417
418 418 class SearchContentCodeHtmlFormatter(CodeHtmlFormatter):
419 419 def __init__(self, **kw):
420 420 # only show these line numbers if set
421 421 self.only_lines = kw.pop('only_line_numbers', [])
422 422 self.query_terms = kw.pop('query_terms', [])
423 423 self.max_lines = kw.pop('max_lines', 5)
424 424 self.line_context = kw.pop('line_context', 3)
425 425 self.url = kw.pop('url', None)
426 426
427 427 super(CodeHtmlFormatter, self).__init__(**kw)
428 428
429 429 def _wrap_code(self, source):
430 430 for cnt, it in enumerate(source):
431 431 i, t = it
432 432 t = '<pre>%s</pre>' % t
433 433 yield i, t
434 434
435 435 def _wrap_tablelinenos(self, inner):
436 436 yield 0, '<table class="code-highlight %stable">' % self.cssclass
437 437
438 438 last_shown_line_number = 0
439 439 current_line_number = 1
440 440
441 441 for t, line in inner:
442 442 if not t:
443 443 yield t, line
444 444 continue
445 445
446 446 if current_line_number in self.only_lines:
447 447 if last_shown_line_number + 1 != current_line_number:
448 448 yield 0, '<tr>'
449 449 yield 0, '<td class="line">...</td>'
450 450 yield 0, '<td id="hlcode" class="code"></td>'
451 451 yield 0, '</tr>'
452 452
453 453 yield 0, '<tr>'
454 454 if self.url:
455 455 yield 0, '<td class="line"><a href="%s#L%i">%i</a></td>' % (
456 456 self.url, current_line_number, current_line_number)
457 457 else:
458 458 yield 0, '<td class="line"><a href="">%i</a></td>' % (
459 459 current_line_number)
460 460 yield 0, '<td id="hlcode" class="code">' + line + '</td>'
461 461 yield 0, '</tr>'
462 462
463 463 last_shown_line_number = current_line_number
464 464
465 465 current_line_number += 1
466 466
467 467 yield 0, '</table>'
468 468
469 469
470 470 def hsv_to_rgb(h, s, v):
471 471 """ Convert hsv color values to rgb """
472 472
473 473 if s == 0.0:
474 474 return v, v, v
475 475 i = int(h * 6.0) # XXX assume int() truncates!
476 476 f = (h * 6.0) - i
477 477 p = v * (1.0 - s)
478 478 q = v * (1.0 - s * f)
479 479 t = v * (1.0 - s * (1.0 - f))
480 480 i = i % 6
481 481 if i == 0:
482 482 return v, t, p
483 483 if i == 1:
484 484 return q, v, p
485 485 if i == 2:
486 486 return p, v, t
487 487 if i == 3:
488 488 return p, q, v
489 489 if i == 4:
490 490 return t, p, v
491 491 if i == 5:
492 492 return v, p, q
493 493
494 494
495 495 def unique_color_generator(n=10000, saturation=0.10, lightness=0.95):
496 496 """
497 497 Generator for getting n of evenly distributed colors using
498 498 hsv color and golden ratio. It always return same order of colors
499 499
500 500 :param n: number of colors to generate
501 501 :param saturation: saturation of returned colors
502 502 :param lightness: lightness of returned colors
503 503 :returns: RGB tuple
504 504 """
505 505
506 506 golden_ratio = 0.618033988749895
507 507 h = 0.22717784590367374
508 508
509 509 for _ in xrange(n):
510 510 h += golden_ratio
511 511 h %= 1
512 512 HSV_tuple = [h, saturation, lightness]
513 513 RGB_tuple = hsv_to_rgb(*HSV_tuple)
514 514 yield map(lambda x: str(int(x * 256)), RGB_tuple)
515 515
516 516
517 517 def color_hasher(n=10000, saturation=0.10, lightness=0.95):
518 518 """
519 519 Returns a function which when called with an argument returns a unique
520 520 color for that argument, eg.
521 521
522 522 :param n: number of colors to generate
523 523 :param saturation: saturation of returned colors
524 524 :param lightness: lightness of returned colors
525 525 :returns: css RGB string
526 526
527 527 >>> color_hash = color_hasher()
528 528 >>> color_hash('hello')
529 529 'rgb(34, 12, 59)'
530 530 >>> color_hash('hello')
531 531 'rgb(34, 12, 59)'
532 532 >>> color_hash('other')
533 533 'rgb(90, 224, 159)'
534 534 """
535 535
536 536 color_dict = {}
537 537 cgenerator = unique_color_generator(
538 538 saturation=saturation, lightness=lightness)
539 539
540 540 def get_color_string(thing):
541 541 if thing in color_dict:
542 542 col = color_dict[thing]
543 543 else:
544 544 col = color_dict[thing] = cgenerator.next()
545 545 return "rgb(%s)" % (', '.join(col))
546 546
547 547 return get_color_string
548 548
549 549
550 550 def get_lexer_safe(mimetype=None, filepath=None):
551 551 """
552 552 Tries to return a relevant pygments lexer using mimetype/filepath name,
553 553 defaulting to plain text if none could be found
554 554 """
555 555 lexer = None
556 556 try:
557 557 if mimetype:
558 558 lexer = get_lexer_for_mimetype(mimetype)
559 559 if not lexer:
560 560 lexer = get_lexer_for_filename(filepath)
561 561 except pygments.util.ClassNotFound:
562 562 pass
563 563
564 564 if not lexer:
565 565 lexer = get_lexer_by_name('text')
566 566
567 567 return lexer
568 568
569 569
570 570 def get_lexer_for_filenode(filenode):
571 571 lexer = get_custom_lexer(filenode.extension) or filenode.lexer
572 572 return lexer
573 573
574 574
575 575 def pygmentize(filenode, **kwargs):
576 576 """
577 577 pygmentize function using pygments
578 578
579 579 :param filenode:
580 580 """
581 581 lexer = get_lexer_for_filenode(filenode)
582 582 return literal(code_highlight(filenode.content, lexer,
583 583 CodeHtmlFormatter(**kwargs)))
584 584
585 585
586 586 def is_following_repo(repo_name, user_id):
587 587 from rhodecode.model.scm import ScmModel
588 588 return ScmModel().is_following_repo(repo_name, user_id)
589 589
590 590
591 591 class _Message(object):
592 592 """A message returned by ``Flash.pop_messages()``.
593 593
594 594 Converting the message to a string returns the message text. Instances
595 595 also have the following attributes:
596 596
597 597 * ``message``: the message text.
598 598 * ``category``: the category specified when the message was created.
599 599 """
600 600
601 601 def __init__(self, category, message):
602 602 self.category = category
603 603 self.message = message
604 604
605 605 def __str__(self):
606 606 return self.message
607 607
608 608 __unicode__ = __str__
609 609
610 610 def __html__(self):
611 611 return escape(safe_unicode(self.message))
612 612
613 613
614 614 class Flash(object):
615 615 # List of allowed categories. If None, allow any category.
616 616 categories = ["warning", "notice", "error", "success"]
617 617
618 618 # Default category if none is specified.
619 619 default_category = "notice"
620 620
621 621 def __init__(self, session_key="flash", categories=None,
622 622 default_category=None):
623 623 """
624 624 Instantiate a ``Flash`` object.
625 625
626 626 ``session_key`` is the key to save the messages under in the user's
627 627 session.
628 628
629 629 ``categories`` is an optional list which overrides the default list
630 630 of categories.
631 631
632 632 ``default_category`` overrides the default category used for messages
633 633 when none is specified.
634 634 """
635 635 self.session_key = session_key
636 636 if categories is not None:
637 637 self.categories = categories
638 638 if default_category is not None:
639 639 self.default_category = default_category
640 640 if self.categories and self.default_category not in self.categories:
641 641 raise ValueError(
642 642 "unrecognized default category %r" % (self.default_category,))
643 643
644 644 def pop_messages(self, session=None, request=None):
645 645 """
646 646 Return all accumulated messages and delete them from the session.
647 647
648 648 The return value is a list of ``Message`` objects.
649 649 """
650 650 messages = []
651 651
652 652 if not session:
653 653 if not request:
654 654 request = get_current_request()
655 655 session = request.session
656 656
657 657 # Pop the 'old' pylons flash messages. They are tuples of the form
658 658 # (category, message)
659 659 for cat, msg in session.pop(self.session_key, []):
660 660 messages.append(_Message(cat, msg))
661 661
662 662 # Pop the 'new' pyramid flash messages for each category as list
663 663 # of strings.
664 664 for cat in self.categories:
665 665 for msg in session.pop_flash(queue=cat):
666 666 messages.append(_Message(cat, msg))
667 667 # Map messages from the default queue to the 'notice' category.
668 668 for msg in session.pop_flash():
669 669 messages.append(_Message('notice', msg))
670 670
671 671 session.save()
672 672 return messages
673 673
674 674 def json_alerts(self, session=None, request=None):
675 675 payloads = []
676 676 messages = flash.pop_messages(session=session, request=request)
677 677 if messages:
678 678 for message in messages:
679 679 subdata = {}
680 680 if hasattr(message.message, 'rsplit'):
681 681 flash_data = message.message.rsplit('|DELIM|', 1)
682 682 org_message = flash_data[0]
683 683 if len(flash_data) > 1:
684 684 subdata = json.loads(flash_data[1])
685 685 else:
686 686 org_message = message.message
687 687 payloads.append({
688 688 'message': {
689 689 'message': u'{}'.format(org_message),
690 690 'level': message.category,
691 691 'force': True,
692 692 'subdata': subdata
693 693 }
694 694 })
695 695 return json.dumps(payloads)
696 696
697 697 def __call__(self, message, category=None, ignore_duplicate=True,
698 698 session=None, request=None):
699 699
700 700 if not session:
701 701 if not request:
702 702 request = get_current_request()
703 703 session = request.session
704 704
705 705 session.flash(
706 706 message, queue=category, allow_duplicate=not ignore_duplicate)
707 707
708 708
709 709 flash = Flash()
710 710
711 711 #==============================================================================
712 712 # SCM FILTERS available via h.
713 713 #==============================================================================
714 714 from rhodecode.lib.vcs.utils import author_name, author_email
715 715 from rhodecode.lib.utils2 import credentials_filter, age, age_from_seconds
716 716 from rhodecode.model.db import User, ChangesetStatus
717 717
718 718 capitalize = lambda x: x.capitalize()
719 719 email = author_email
720 720 short_id = lambda x: x[:12]
721 721 hide_credentials = lambda x: ''.join(credentials_filter(x))
722 722
723 723
724 724 import pytz
725 725 import tzlocal
726 726 local_timezone = tzlocal.get_localzone()
727 727
728 728
729 729 def age_component(datetime_iso, value=None, time_is_local=False, tooltip=True):
730 730 title = value or format_date(datetime_iso)
731 731 tzinfo = '+00:00'
732 732
733 733 # detect if we have a timezone info, otherwise, add it
734 734 if time_is_local and isinstance(datetime_iso, datetime) and not datetime_iso.tzinfo:
735 735 force_timezone = os.environ.get('RC_TIMEZONE', '')
736 736 if force_timezone:
737 737 force_timezone = pytz.timezone(force_timezone)
738 738 timezone = force_timezone or local_timezone
739 739 offset = timezone.localize(datetime_iso).strftime('%z')
740 740 tzinfo = '{}:{}'.format(offset[:-2], offset[-2:])
741 741
742 742 return literal(
743 743 '<time class="timeago {cls}" title="{tt_title}" datetime="{dt}{tzinfo}">{title}</time>'.format(
744 744 cls='tooltip' if tooltip else '',
745 745 tt_title=('{title}{tzinfo}'.format(title=title, tzinfo=tzinfo)) if tooltip else '',
746 746 title=title, dt=datetime_iso, tzinfo=tzinfo
747 747 ))
748 748
749 749
750 750 def _shorten_commit_id(commit_id, commit_len=None):
751 751 if commit_len is None:
752 752 request = get_current_request()
753 753 commit_len = request.call_context.visual.show_sha_length
754 754 return commit_id[:commit_len]
755 755
756 756
757 757 def show_id(commit, show_idx=None, commit_len=None):
758 758 """
759 759 Configurable function that shows ID
760 760 by default it's r123:fffeeefffeee
761 761
762 762 :param commit: commit instance
763 763 """
764 764 if show_idx is None:
765 765 request = get_current_request()
766 766 show_idx = request.call_context.visual.show_revision_number
767 767
768 768 raw_id = _shorten_commit_id(commit.raw_id, commit_len=commit_len)
769 769 if show_idx:
770 770 return 'r%s:%s' % (commit.idx, raw_id)
771 771 else:
772 772 return '%s' % (raw_id, )
773 773
774 774
775 775 def format_date(date):
776 776 """
777 777 use a standardized formatting for dates used in RhodeCode
778 778
779 779 :param date: date/datetime object
780 780 :return: formatted date
781 781 """
782 782
783 783 if date:
784 784 _fmt = "%a, %d %b %Y %H:%M:%S"
785 785 return safe_unicode(date.strftime(_fmt))
786 786
787 787 return u""
788 788
789 789
790 790 class _RepoChecker(object):
791 791
792 792 def __init__(self, backend_alias):
793 793 self._backend_alias = backend_alias
794 794
795 795 def __call__(self, repository):
796 796 if hasattr(repository, 'alias'):
797 797 _type = repository.alias
798 798 elif hasattr(repository, 'repo_type'):
799 799 _type = repository.repo_type
800 800 else:
801 801 _type = repository
802 802 return _type == self._backend_alias
803 803
804 804
805 805 is_git = _RepoChecker('git')
806 806 is_hg = _RepoChecker('hg')
807 807 is_svn = _RepoChecker('svn')
808 808
809 809
810 810 def get_repo_type_by_name(repo_name):
811 811 repo = Repository.get_by_repo_name(repo_name)
812 812 if repo:
813 813 return repo.repo_type
814 814
815 815
816 816 def is_svn_without_proxy(repository):
817 817 if is_svn(repository):
818 818 from rhodecode.model.settings import VcsSettingsModel
819 819 conf = VcsSettingsModel().get_ui_settings_as_config_obj()
820 820 return not str2bool(conf.get('vcs_svn_proxy', 'http_requests_enabled'))
821 821 return False
822 822
823 823
824 824 def discover_user(author):
825 825 """
826 826 Tries to discover RhodeCode User based on the author string. Author string
827 827 is typically `FirstName LastName <email@address.com>`
828 828 """
829 829
830 830 # if author is already an instance use it for extraction
831 831 if isinstance(author, User):
832 832 return author
833 833
834 834 # Valid email in the attribute passed, see if they're in the system
835 835 _email = author_email(author)
836 836 if _email != '':
837 837 user = User.get_by_email(_email, case_insensitive=True, cache=True)
838 838 if user is not None:
839 839 return user
840 840
841 841 # Maybe it's a username, we try to extract it and fetch by username ?
842 842 _author = author_name(author)
843 843 user = User.get_by_username(_author, case_insensitive=True, cache=True)
844 844 if user is not None:
845 845 return user
846 846
847 847 return None
848 848
849 849
850 850 def email_or_none(author):
851 851 # extract email from the commit string
852 852 _email = author_email(author)
853 853
854 854 # If we have an email, use it, otherwise
855 855 # see if it contains a username we can get an email from
856 856 if _email != '':
857 857 return _email
858 858 else:
859 859 user = User.get_by_username(
860 860 author_name(author), case_insensitive=True, cache=True)
861 861
862 862 if user is not None:
863 863 return user.email
864 864
865 865 # No valid email, not a valid user in the system, none!
866 866 return None
867 867
868 868
869 869 def link_to_user(author, length=0, **kwargs):
870 870 user = discover_user(author)
871 871 # user can be None, but if we have it already it means we can re-use it
872 872 # in the person() function, so we save 1 intensive-query
873 873 if user:
874 874 author = user
875 875
876 876 display_person = person(author, 'username_or_name_or_email')
877 877 if length:
878 878 display_person = shorter(display_person, length)
879 879
880 880 if user:
881 881 return link_to(
882 882 escape(display_person),
883 883 route_path('user_profile', username=user.username),
884 884 **kwargs)
885 885 else:
886 886 return escape(display_person)
887 887
888 888
889 889 def link_to_group(users_group_name, **kwargs):
890 890 return link_to(
891 891 escape(users_group_name),
892 892 route_path('user_group_profile', user_group_name=users_group_name),
893 893 **kwargs)
894 894
895 895
896 896 def person(author, show_attr="username_and_name"):
897 897 user = discover_user(author)
898 898 if user:
899 899 return getattr(user, show_attr)
900 900 else:
901 901 _author = author_name(author)
902 902 _email = email(author)
903 903 return _author or _email
904 904
905 905
906 906 def author_string(email):
907 907 if email:
908 908 user = User.get_by_email(email, case_insensitive=True, cache=True)
909 909 if user:
910 910 if user.first_name or user.last_name:
911 911 return '%s %s &lt;%s&gt;' % (
912 912 user.first_name, user.last_name, email)
913 913 else:
914 914 return email
915 915 else:
916 916 return email
917 917 else:
918 918 return None
919 919
920 920
921 921 def person_by_id(id_, show_attr="username_and_name"):
922 922 # attr to return from fetched user
923 923 person_getter = lambda usr: getattr(usr, show_attr)
924 924
925 925 #maybe it's an ID ?
926 926 if str(id_).isdigit() or isinstance(id_, int):
927 927 id_ = int(id_)
928 928 user = User.get(id_)
929 929 if user is not None:
930 930 return person_getter(user)
931 931 return id_
932 932
933 933
934 934 def gravatar_with_user(request, author, show_disabled=False, tooltip=False):
935 935 _render = request.get_partial_renderer('rhodecode:templates/base/base.mako')
936 936 return _render('gravatar_with_user', author, show_disabled=show_disabled, tooltip=tooltip)
937 937
938 938
939 939 tags_paterns = OrderedDict((
940 940 ('lang', (re.compile(r'\[(lang|language)\ \=\&gt;\ *([a-zA-Z\-\/\#\+\.]*)\]'),
941 941 '<div class="metatag" tag="lang">\\2</div>')),
942 942
943 943 ('see', (re.compile(r'\[see\ \=\&gt;\ *([a-zA-Z0-9\/\=\?\&amp;\ \:\/\.\-]*)\]'),
944 944 '<div class="metatag" tag="see">see: \\1 </div>')),
945 945
946 946 ('url', (re.compile(r'\[url\ \=\&gt;\ \[([a-zA-Z0-9\ \.\-\_]+)\]\((http://|https://|/)(.*?)\)\]'),
947 947 '<div class="metatag" tag="url"> <a href="\\2\\3">\\1</a> </div>')),
948 948
949 949 ('license', (re.compile(r'\[license\ \=\&gt;\ *([a-zA-Z0-9\/\=\?\&amp;\ \:\/\.\-]*)\]'),
950 950 '<div class="metatag" tag="license"><a href="http:\/\/www.opensource.org/licenses/\\1">\\1</a></div>')),
951 951
952 952 ('ref', (re.compile(r'\[(requires|recommends|conflicts|base)\ \=\&gt;\ *([a-zA-Z0-9\-\/]*)\]'),
953 953 '<div class="metatag" tag="ref \\1">\\1: <a href="/\\2">\\2</a></div>')),
954 954
955 955 ('state', (re.compile(r'\[(stable|featured|stale|dead|dev|deprecated)\]'),
956 956 '<div class="metatag" tag="state \\1">\\1</div>')),
957 957
958 958 # label in grey
959 959 ('label', (re.compile(r'\[([a-z]+)\]'),
960 960 '<div class="metatag" tag="label">\\1</div>')),
961 961
962 962 # generic catch all in grey
963 963 ('generic', (re.compile(r'\[([a-zA-Z0-9\.\-\_]+)\]'),
964 964 '<div class="metatag" tag="generic">\\1</div>')),
965 965 ))
966 966
967 967
968 968 def extract_metatags(value):
969 969 """
970 970 Extract supported meta-tags from given text value
971 971 """
972 972 tags = []
973 973 if not value:
974 974 return tags, ''
975 975
976 976 for key, val in tags_paterns.items():
977 977 pat, replace_html = val
978 978 tags.extend([(key, x.group()) for x in pat.finditer(value)])
979 979 value = pat.sub('', value)
980 980
981 981 return tags, value
982 982
983 983
984 984 def style_metatag(tag_type, value):
985 985 """
986 986 converts tags from value into html equivalent
987 987 """
988 988 if not value:
989 989 return ''
990 990
991 991 html_value = value
992 992 tag_data = tags_paterns.get(tag_type)
993 993 if tag_data:
994 994 pat, replace_html = tag_data
995 995 # convert to plain `unicode` instead of a markup tag to be used in
996 996 # regex expressions. safe_unicode doesn't work here
997 997 html_value = pat.sub(replace_html, unicode(value))
998 998
999 999 return html_value
1000 1000
1001 1001
1002 1002 def bool2icon(value, show_at_false=True):
1003 1003 """
1004 1004 Returns boolean value of a given value, represented as html element with
1005 1005 classes that will represent icons
1006 1006
1007 1007 :param value: given value to convert to html node
1008 1008 """
1009 1009
1010 1010 if value: # does bool conversion
1011 1011 return HTML.tag('i', class_="icon-true", title='True')
1012 1012 else: # not true as bool
1013 1013 if show_at_false:
1014 1014 return HTML.tag('i', class_="icon-false", title='False')
1015 1015 return HTML.tag('i')
1016 1016
1017 1017 #==============================================================================
1018 1018 # PERMS
1019 1019 #==============================================================================
1020 1020 from rhodecode.lib.auth import (
1021 1021 HasPermissionAny, HasPermissionAll,
1022 1022 HasRepoPermissionAny, HasRepoPermissionAll, HasRepoGroupPermissionAll,
1023 1023 HasRepoGroupPermissionAny, HasRepoPermissionAnyApi, get_csrf_token,
1024 1024 csrf_token_key, AuthUser)
1025 1025
1026 1026
1027 1027 #==============================================================================
1028 1028 # GRAVATAR URL
1029 1029 #==============================================================================
1030 1030 class InitialsGravatar(object):
1031 1031 def __init__(self, email_address, first_name, last_name, size=30,
1032 1032 background=None, text_color='#fff'):
1033 1033 self.size = size
1034 1034 self.first_name = first_name
1035 1035 self.last_name = last_name
1036 1036 self.email_address = email_address
1037 1037 self.background = background or self.str2color(email_address)
1038 1038 self.text_color = text_color
1039 1039
1040 1040 def get_color_bank(self):
1041 1041 """
1042 1042 returns a predefined list of colors that gravatars can use.
1043 1043 Those are randomized distinct colors that guarantee readability and
1044 1044 uniqueness.
1045 1045
1046 1046 generated with: http://phrogz.net/css/distinct-colors.html
1047 1047 """
1048 1048 return [
1049 1049 '#bf3030', '#a67f53', '#00ff00', '#5989b3', '#392040', '#d90000',
1050 1050 '#402910', '#204020', '#79baf2', '#a700b3', '#bf6060', '#7f5320',
1051 1051 '#008000', '#003059', '#ee00ff', '#ff0000', '#8c4b00', '#007300',
1052 1052 '#005fb3', '#de73e6', '#ff4040', '#ffaa00', '#3df255', '#203140',
1053 1053 '#47004d', '#591616', '#664400', '#59b365', '#0d2133', '#83008c',
1054 1054 '#592d2d', '#bf9f60', '#73e682', '#1d3f73', '#73006b', '#402020',
1055 1055 '#b2862d', '#397341', '#597db3', '#e600d6', '#a60000', '#736039',
1056 1056 '#00b318', '#79aaf2', '#330d30', '#ff8080', '#403010', '#16591f',
1057 1057 '#002459', '#8c4688', '#e50000', '#ffbf40', '#00732e', '#102340',
1058 1058 '#bf60ac', '#8c4646', '#cc8800', '#00a642', '#1d3473', '#b32d98',
1059 1059 '#660e00', '#ffd580', '#80ffb2', '#7391e6', '#733967', '#d97b6c',
1060 1060 '#8c5e00', '#59b389', '#3967e6', '#590047', '#73281d', '#665200',
1061 1061 '#00e67a', '#2d50b3', '#8c2377', '#734139', '#b2982d', '#16593a',
1062 1062 '#001859', '#ff00aa', '#a65e53', '#ffcc00', '#0d3321', '#2d3959',
1063 1063 '#731d56', '#401610', '#4c3d00', '#468c6c', '#002ca6', '#d936a3',
1064 1064 '#d94c36', '#403920', '#36d9a3', '#0d1733', '#592d4a', '#993626',
1065 1065 '#cca300', '#00734d', '#46598c', '#8c005e', '#7f1100', '#8c7000',
1066 1066 '#00a66f', '#7382e6', '#b32d74', '#d9896c', '#ffe680', '#1d7362',
1067 1067 '#364cd9', '#73003d', '#d93a00', '#998a4d', '#59b3a1', '#5965b3',
1068 1068 '#e5007a', '#73341d', '#665f00', '#00b38f', '#0018b3', '#59163a',
1069 1069 '#b2502d', '#bfb960', '#00ffcc', '#23318c', '#a6537f', '#734939',
1070 1070 '#b2a700', '#104036', '#3d3df2', '#402031', '#e56739', '#736f39',
1071 1071 '#79f2ea', '#000059', '#401029', '#4c1400', '#ffee00', '#005953',
1072 1072 '#101040', '#990052', '#402820', '#403d10', '#00ffee', '#0000d9',
1073 1073 '#ff80c4', '#a66953', '#eeff00', '#00ccbe', '#8080ff', '#e673a1',
1074 1074 '#a62c00', '#474d00', '#1a3331', '#46468c', '#733950', '#662900',
1075 1075 '#858c23', '#238c85', '#0f0073', '#b20047', '#d9986c', '#becc00',
1076 1076 '#396f73', '#281d73', '#ff0066', '#ff6600', '#dee673', '#59adb3',
1077 1077 '#6559b3', '#590024', '#b2622d', '#98b32d', '#36ced9', '#332d59',
1078 1078 '#40001a', '#733f1d', '#526600', '#005359', '#242040', '#bf6079',
1079 1079 '#735039', '#cef23d', '#007780', '#5630bf', '#66001b', '#b24700',
1080 1080 '#acbf60', '#1d6273', '#25008c', '#731d34', '#a67453', '#50592d',
1081 1081 '#00ccff', '#6600ff', '#ff0044', '#4c1f00', '#8a994d', '#79daf2',
1082 1082 '#a173e6', '#d93662', '#402310', '#aaff00', '#2d98b3', '#8c40ff',
1083 1083 '#592d39', '#ff8c40', '#354020', '#103640', '#1a0040', '#331a20',
1084 1084 '#331400', '#334d00', '#1d5673', '#583973', '#7f0022', '#4c3626',
1085 1085 '#88cc00', '#36a3d9', '#3d0073', '#d9364c', '#33241a', '#698c23',
1086 1086 '#5995b3', '#300059', '#e57382', '#7f3300', '#366600', '#00aaff',
1087 1087 '#3a1659', '#733941', '#663600', '#74b32d', '#003c59', '#7f53a6',
1088 1088 '#73000f', '#ff8800', '#baf279', '#79caf2', '#291040', '#a6293a',
1089 1089 '#b2742d', '#587339', '#0077b3', '#632699', '#400009', '#d9a66c',
1090 1090 '#294010', '#2d4a59', '#aa00ff', '#4c131b', '#b25f00', '#5ce600',
1091 1091 '#267399', '#a336d9', '#990014', '#664e33', '#86bf60', '#0088ff',
1092 1092 '#7700b3', '#593a16', '#073300', '#1d4b73', '#ac60bf', '#e59539',
1093 1093 '#4f8c46', '#368dd9', '#5c0073'
1094 1094 ]
1095 1095
1096 1096 def rgb_to_hex_color(self, rgb_tuple):
1097 1097 """
1098 1098 Converts an rgb_tuple passed to an hex color.
1099 1099
1100 1100 :param rgb_tuple: tuple with 3 ints represents rgb color space
1101 1101 """
1102 1102 return '#' + ("".join(map(chr, rgb_tuple)).encode('hex'))
1103 1103
1104 1104 def email_to_int_list(self, email_str):
1105 1105 """
1106 1106 Get every byte of the hex digest value of email and turn it to integer.
1107 1107 It's going to be always between 0-255
1108 1108 """
1109 1109 digest = md5_safe(email_str.lower())
1110 1110 return [int(digest[i * 2:i * 2 + 2], 16) for i in range(16)]
1111 1111
1112 1112 def pick_color_bank_index(self, email_str, color_bank):
1113 1113 return self.email_to_int_list(email_str)[0] % len(color_bank)
1114 1114
1115 1115 def str2color(self, email_str):
1116 1116 """
1117 1117 Tries to map in a stable algorithm an email to color
1118 1118
1119 1119 :param email_str:
1120 1120 """
1121 1121 color_bank = self.get_color_bank()
1122 1122 # pick position (module it's length so we always find it in the
1123 1123 # bank even if it's smaller than 256 values
1124 1124 pos = self.pick_color_bank_index(email_str, color_bank)
1125 1125 return color_bank[pos]
1126 1126
1127 1127 def normalize_email(self, email_address):
1128 1128 import unicodedata
1129 1129 # default host used to fill in the fake/missing email
1130 1130 default_host = u'localhost'
1131 1131
1132 1132 if not email_address:
1133 1133 email_address = u'%s@%s' % (User.DEFAULT_USER, default_host)
1134 1134
1135 1135 email_address = safe_unicode(email_address)
1136 1136
1137 1137 if u'@' not in email_address:
1138 1138 email_address = u'%s@%s' % (email_address, default_host)
1139 1139
1140 1140 if email_address.endswith(u'@'):
1141 1141 email_address = u'%s%s' % (email_address, default_host)
1142 1142
1143 1143 email_address = unicodedata.normalize('NFKD', email_address)\
1144 1144 .encode('ascii', 'ignore')
1145 1145 return email_address
1146 1146
1147 1147 def get_initials(self):
1148 1148 """
1149 1149 Returns 2 letter initials calculated based on the input.
1150 1150 The algorithm picks first given email address, and takes first letter
1151 1151 of part before @, and then the first letter of server name. In case
1152 1152 the part before @ is in a format of `somestring.somestring2` it replaces
1153 1153 the server letter with first letter of somestring2
1154 1154
1155 1155 In case function was initialized with both first and lastname, this
1156 1156 overrides the extraction from email by first letter of the first and
1157 1157 last name. We add special logic to that functionality, In case Full name
1158 1158 is compound, like Guido Von Rossum, we use last part of the last name
1159 1159 (Von Rossum) picking `R`.
1160 1160
1161 1161 Function also normalizes the non-ascii characters to they ascii
1162 1162 representation, eg Δ„ => A
1163 1163 """
1164 1164 import unicodedata
1165 1165 # replace non-ascii to ascii
1166 1166 first_name = unicodedata.normalize(
1167 1167 'NFKD', safe_unicode(self.first_name)).encode('ascii', 'ignore')
1168 1168 last_name = unicodedata.normalize(
1169 1169 'NFKD', safe_unicode(self.last_name)).encode('ascii', 'ignore')
1170 1170
1171 1171 # do NFKD encoding, and also make sure email has proper format
1172 1172 email_address = self.normalize_email(self.email_address)
1173 1173
1174 1174 # first push the email initials
1175 1175 prefix, server = email_address.split('@', 1)
1176 1176
1177 1177 # check if prefix is maybe a 'first_name.last_name' syntax
1178 1178 _dot_split = prefix.rsplit('.', 1)
1179 1179 if len(_dot_split) == 2 and _dot_split[1]:
1180 1180 initials = [_dot_split[0][0], _dot_split[1][0]]
1181 1181 else:
1182 1182 initials = [prefix[0], server[0]]
1183 1183
1184 1184 # then try to replace either first_name or last_name
1185 1185 fn_letter = (first_name or " ")[0].strip()
1186 1186 ln_letter = (last_name.split(' ', 1)[-1] or " ")[0].strip()
1187 1187
1188 1188 if fn_letter:
1189 1189 initials[0] = fn_letter
1190 1190
1191 1191 if ln_letter:
1192 1192 initials[1] = ln_letter
1193 1193
1194 1194 return ''.join(initials).upper()
1195 1195
1196 1196 def get_img_data_by_type(self, font_family, img_type):
1197 1197 default_user = """
1198 1198 <svg xmlns="http://www.w3.org/2000/svg"
1199 1199 version="1.1" x="0px" y="0px" width="{size}" height="{size}"
1200 1200 viewBox="-15 -10 439.165 429.164"
1201 1201
1202 1202 xml:space="preserve"
1203 1203 style="background:{background};" >
1204 1204
1205 1205 <path d="M204.583,216.671c50.664,0,91.74-48.075,
1206 1206 91.74-107.378c0-82.237-41.074-107.377-91.74-107.377
1207 1207 c-50.668,0-91.74,25.14-91.74,107.377C112.844,
1208 1208 168.596,153.916,216.671,
1209 1209 204.583,216.671z" fill="{text_color}"/>
1210 1210 <path d="M407.164,374.717L360.88,
1211 1211 270.454c-2.117-4.771-5.836-8.728-10.465-11.138l-71.83-37.392
1212 1212 c-1.584-0.823-3.502-0.663-4.926,0.415c-20.316,
1213 1213 15.366-44.203,23.488-69.076,23.488c-24.877,
1214 1214 0-48.762-8.122-69.078-23.488
1215 1215 c-1.428-1.078-3.346-1.238-4.93-0.415L58.75,
1216 1216 259.316c-4.631,2.41-8.346,6.365-10.465,11.138L2.001,374.717
1217 1217 c-3.191,7.188-2.537,15.412,1.75,22.005c4.285,
1218 1218 6.592,11.537,10.526,19.4,10.526h362.861c7.863,0,15.117-3.936,
1219 1219 19.402-10.527 C409.699,390.129,
1220 1220 410.355,381.902,407.164,374.717z" fill="{text_color}"/>
1221 1221 </svg>""".format(
1222 1222 size=self.size,
1223 1223 background='#979797', # @grey4
1224 1224 text_color=self.text_color,
1225 1225 font_family=font_family)
1226 1226
1227 1227 return {
1228 1228 "default_user": default_user
1229 1229 }[img_type]
1230 1230
1231 1231 def get_img_data(self, svg_type=None):
1232 1232 """
1233 1233 generates the svg metadata for image
1234 1234 """
1235 1235 fonts = [
1236 1236 '-apple-system',
1237 1237 'BlinkMacSystemFont',
1238 1238 'Segoe UI',
1239 1239 'Roboto',
1240 1240 'Oxygen-Sans',
1241 1241 'Ubuntu',
1242 1242 'Cantarell',
1243 1243 'Helvetica Neue',
1244 1244 'sans-serif'
1245 1245 ]
1246 1246 font_family = ','.join(fonts)
1247 1247 if svg_type:
1248 1248 return self.get_img_data_by_type(font_family, svg_type)
1249 1249
1250 1250 initials = self.get_initials()
1251 1251 img_data = """
1252 1252 <svg xmlns="http://www.w3.org/2000/svg" pointer-events="none"
1253 1253 width="{size}" height="{size}"
1254 1254 style="width: 100%; height: 100%; background-color: {background}"
1255 1255 viewBox="0 0 {size} {size}">
1256 1256 <text text-anchor="middle" y="50%" x="50%" dy="0.35em"
1257 1257 pointer-events="auto" fill="{text_color}"
1258 1258 font-family="{font_family}"
1259 1259 style="font-weight: 400; font-size: {f_size}px;">{text}
1260 1260 </text>
1261 1261 </svg>""".format(
1262 1262 size=self.size,
1263 1263 f_size=self.size/2.05, # scale the text inside the box nicely
1264 1264 background=self.background,
1265 1265 text_color=self.text_color,
1266 1266 text=initials.upper(),
1267 1267 font_family=font_family)
1268 1268
1269 1269 return img_data
1270 1270
1271 1271 def generate_svg(self, svg_type=None):
1272 1272 img_data = self.get_img_data(svg_type)
1273 1273 return "data:image/svg+xml;base64,%s" % img_data.encode('base64')
1274 1274
1275 1275
1276 1276 def initials_gravatar(email_address, first_name, last_name, size=30):
1277 1277 svg_type = None
1278 1278 if email_address == User.DEFAULT_USER_EMAIL:
1279 1279 svg_type = 'default_user'
1280 1280 klass = InitialsGravatar(email_address, first_name, last_name, size)
1281 1281 return klass.generate_svg(svg_type=svg_type)
1282 1282
1283 1283
1284 1284 def gravatar_url(email_address, size=30, request=None):
1285 1285 request = get_current_request()
1286 1286 _use_gravatar = request.call_context.visual.use_gravatar
1287 1287 _gravatar_url = request.call_context.visual.gravatar_url
1288 1288
1289 1289 _gravatar_url = _gravatar_url or User.DEFAULT_GRAVATAR_URL
1290 1290
1291 1291 email_address = email_address or User.DEFAULT_USER_EMAIL
1292 1292 if isinstance(email_address, unicode):
1293 1293 # hashlib crashes on unicode items
1294 1294 email_address = safe_str(email_address)
1295 1295
1296 1296 # empty email or default user
1297 1297 if not email_address or email_address == User.DEFAULT_USER_EMAIL:
1298 1298 return initials_gravatar(User.DEFAULT_USER_EMAIL, '', '', size=size)
1299 1299
1300 1300 if _use_gravatar:
1301 1301 # TODO: Disuse pyramid thread locals. Think about another solution to
1302 1302 # get the host and schema here.
1303 1303 request = get_current_request()
1304 1304 tmpl = safe_str(_gravatar_url)
1305 1305 tmpl = tmpl.replace('{email}', email_address)\
1306 1306 .replace('{md5email}', md5_safe(email_address.lower())) \
1307 1307 .replace('{netloc}', request.host)\
1308 1308 .replace('{scheme}', request.scheme)\
1309 1309 .replace('{size}', safe_str(size))
1310 1310 return tmpl
1311 1311 else:
1312 1312 return initials_gravatar(email_address, '', '', size=size)
1313 1313
1314 1314
1315 1315 def breadcrumb_repo_link(repo):
1316 1316 """
1317 1317 Makes a breadcrumbs path link to repo
1318 1318
1319 1319 ex::
1320 1320 group >> subgroup >> repo
1321 1321
1322 1322 :param repo: a Repository instance
1323 1323 """
1324 1324
1325 1325 path = [
1326 1326 link_to(group.name, route_path('repo_group_home', repo_group_name=group.group_name),
1327 1327 title='last change:{}'.format(format_date(group.last_commit_change)))
1328 1328 for group in repo.groups_with_parents
1329 1329 ] + [
1330 1330 link_to(repo.just_name, route_path('repo_summary', repo_name=repo.repo_name),
1331 1331 title='last change:{}'.format(format_date(repo.last_commit_change)))
1332 1332 ]
1333 1333
1334 1334 return literal(' &raquo; '.join(path))
1335 1335
1336 1336
1337 1337 def breadcrumb_repo_group_link(repo_group):
1338 1338 """
1339 1339 Makes a breadcrumbs path link to repo
1340 1340
1341 1341 ex::
1342 1342 group >> subgroup
1343 1343
1344 1344 :param repo_group: a Repository Group instance
1345 1345 """
1346 1346
1347 1347 path = [
1348 1348 link_to(group.name,
1349 1349 route_path('repo_group_home', repo_group_name=group.group_name),
1350 1350 title='last change:{}'.format(format_date(group.last_commit_change)))
1351 1351 for group in repo_group.parents
1352 1352 ] + [
1353 1353 link_to(repo_group.name,
1354 1354 route_path('repo_group_home', repo_group_name=repo_group.group_name),
1355 1355 title='last change:{}'.format(format_date(repo_group.last_commit_change)))
1356 1356 ]
1357 1357
1358 1358 return literal(' &raquo; '.join(path))
1359 1359
1360 1360
1361 1361 def format_byte_size_binary(file_size):
1362 1362 """
1363 1363 Formats file/folder sizes to standard.
1364 1364 """
1365 1365 if file_size is None:
1366 1366 file_size = 0
1367 1367
1368 1368 formatted_size = format_byte_size(file_size, binary=True)
1369 1369 return formatted_size
1370 1370
1371 1371
1372 1372 def urlify_text(text_, safe=True, **href_attrs):
1373 1373 """
1374 1374 Extract urls from text and make html links out of them
1375 1375 """
1376 1376
1377 1377 url_pat = re.compile(r'''(http[s]?://(?:[a-zA-Z]|[0-9]|[$-_@#.&+]'''
1378 1378 '''|[!*\(\),]|(?:%[0-9a-fA-F][0-9a-fA-F]))+)''')
1379 1379
1380 1380 def url_func(match_obj):
1381 1381 url_full = match_obj.groups()[0]
1382 1382 a_options = dict(href_attrs)
1383 1383 a_options['href'] = url_full
1384 1384 a_text = url_full
1385 1385 return HTML.tag("a", a_text, **a_options)
1386 1386
1387 1387 _new_text = url_pat.sub(url_func, text_)
1388 1388
1389 1389 if safe:
1390 1390 return literal(_new_text)
1391 1391 return _new_text
1392 1392
1393 1393
1394 1394 def urlify_commits(text_, repo_name):
1395 1395 """
1396 1396 Extract commit ids from text and make link from them
1397 1397
1398 1398 :param text_:
1399 1399 :param repo_name: repo name to build the URL with
1400 1400 """
1401 1401
1402 1402 url_pat = re.compile(r'(^|\s)([0-9a-fA-F]{12,40})($|\s)')
1403 1403
1404 1404 def url_func(match_obj):
1405 1405 commit_id = match_obj.groups()[1]
1406 1406 pref = match_obj.groups()[0]
1407 1407 suf = match_obj.groups()[2]
1408 1408
1409 1409 tmpl = (
1410 1410 '%(pref)s<a class="tooltip-hovercard %(cls)s" href="%(url)s" data-hovercard-alt="%(hovercard_alt)s" data-hovercard-url="%(hovercard_url)s">'
1411 1411 '%(commit_id)s</a>%(suf)s'
1412 1412 )
1413 1413 return tmpl % {
1414 1414 'pref': pref,
1415 1415 'cls': 'revision-link',
1416 1416 'url': route_url(
1417 1417 'repo_commit', repo_name=repo_name, commit_id=commit_id),
1418 1418 'commit_id': commit_id,
1419 1419 'suf': suf,
1420 1420 'hovercard_alt': 'Commit: {}'.format(commit_id),
1421 1421 'hovercard_url': route_url(
1422 1422 'hovercard_repo_commit', repo_name=repo_name, commit_id=commit_id)
1423 1423 }
1424 1424
1425 1425 new_text = url_pat.sub(url_func, text_)
1426 1426
1427 1427 return new_text
1428 1428
1429 1429
1430 1430 def _process_url_func(match_obj, repo_name, uid, entry,
1431 1431 return_raw_data=False, link_format='html'):
1432 1432 pref = ''
1433 1433 if match_obj.group().startswith(' '):
1434 1434 pref = ' '
1435 1435
1436 1436 issue_id = ''.join(match_obj.groups())
1437 1437
1438 1438 if link_format == 'html':
1439 1439 tmpl = (
1440 1440 '%(pref)s<a class="tooltip %(cls)s" href="%(url)s" title="%(title)s">'
1441 1441 '%(issue-prefix)s%(id-repr)s'
1442 1442 '</a>')
1443 1443 elif link_format == 'html+hovercard':
1444 1444 tmpl = (
1445 1445 '%(pref)s<a class="tooltip-hovercard %(cls)s" href="%(url)s" data-hovercard-url="%(hovercard_url)s">'
1446 1446 '%(issue-prefix)s%(id-repr)s'
1447 1447 '</a>')
1448 1448 elif link_format in ['rst', 'rst+hovercard']:
1449 1449 tmpl = '`%(issue-prefix)s%(id-repr)s <%(url)s>`_'
1450 1450 elif link_format in ['markdown', 'markdown+hovercard']:
1451 1451 tmpl = '[%(pref)s%(issue-prefix)s%(id-repr)s](%(url)s)'
1452 1452 else:
1453 1453 raise ValueError('Bad link_format:{}'.format(link_format))
1454 1454
1455 1455 (repo_name_cleaned,
1456 1456 parent_group_name) = RepoGroupModel()._get_group_name_and_parent(repo_name)
1457 1457
1458 1458 # variables replacement
1459 1459 named_vars = {
1460 1460 'id': issue_id,
1461 1461 'repo': repo_name,
1462 1462 'repo_name': repo_name_cleaned,
1463 1463 'group_name': parent_group_name,
1464 1464 # set dummy keys so we always have them
1465 1465 'hostname': '',
1466 1466 'netloc': '',
1467 1467 'scheme': ''
1468 1468 }
1469 1469
1470 1470 request = get_current_request()
1471 1471 if request:
1472 1472 # exposes, hostname, netloc, scheme
1473 1473 host_data = get_host_info(request)
1474 1474 named_vars.update(host_data)
1475 1475
1476 1476 # named regex variables
1477 1477 named_vars.update(match_obj.groupdict())
1478 1478 _url = string.Template(entry['url']).safe_substitute(**named_vars)
1479 1479 desc = string.Template(entry['desc']).safe_substitute(**named_vars)
1480 1480 hovercard_url = string.Template(entry.get('hovercard_url', '')).safe_substitute(**named_vars)
1481 1481
1482 1482 def quote_cleaner(input_str):
1483 1483 """Remove quotes as it's HTML"""
1484 1484 return input_str.replace('"', '')
1485 1485
1486 1486 data = {
1487 1487 'pref': pref,
1488 1488 'cls': quote_cleaner('issue-tracker-link'),
1489 1489 'url': quote_cleaner(_url),
1490 1490 'id-repr': issue_id,
1491 1491 'issue-prefix': entry['pref'],
1492 1492 'serv': entry['url'],
1493 1493 'title': desc,
1494 1494 'hovercard_url': hovercard_url
1495 1495 }
1496 1496
1497 1497 if return_raw_data:
1498 1498 return {
1499 1499 'id': issue_id,
1500 1500 'url': _url
1501 1501 }
1502 1502 return tmpl % data
1503 1503
1504 1504
1505 1505 def get_active_pattern_entries(repo_name):
1506 1506 repo = None
1507 1507 if repo_name:
1508 1508 # Retrieving repo_name to avoid invalid repo_name to explode on
1509 1509 # IssueTrackerSettingsModel but still passing invalid name further down
1510 1510 repo = Repository.get_by_repo_name(repo_name, cache=True)
1511 1511
1512 1512 settings_model = IssueTrackerSettingsModel(repo=repo)
1513 1513 active_entries = settings_model.get_settings(cache=True)
1514 1514 return active_entries
1515 1515
1516 1516
1517 pr_pattern_re = re.compile(r'(?:(?:^!)|(?: !))(\d+)')
1518
1519
1517 1520 def process_patterns(text_string, repo_name, link_format='html', active_entries=None):
1518 1521
1519 1522 allowed_formats = ['html', 'rst', 'markdown',
1520 1523 'html+hovercard', 'rst+hovercard', 'markdown+hovercard']
1521 1524 if link_format not in allowed_formats:
1522 1525 raise ValueError('Link format can be only one of:{} got {}'.format(
1523 1526 allowed_formats, link_format))
1524 1527
1525 1528 if active_entries is None:
1526 1529 log.debug('Fetch active patterns for repo: %s', repo_name)
1527 1530 active_entries = get_active_pattern_entries(repo_name)
1528 1531
1529 1532 issues_data = []
1530 1533 new_text = text_string
1531 1534
1532 1535 log.debug('Got %s entries to process', len(active_entries))
1533 1536 for uid, entry in active_entries.items():
1534 1537 log.debug('found issue tracker entry with uid %s', uid)
1535 1538
1536 1539 if not (entry['pat'] and entry['url']):
1537 1540 log.debug('skipping due to missing data')
1538 1541 continue
1539 1542
1540 1543 log.debug('issue tracker entry: uid: `%s` PAT:%s URL:%s PREFIX:%s',
1541 1544 uid, entry['pat'], entry['url'], entry['pref'])
1542 1545
1543 1546 try:
1544 1547 pattern = re.compile(r'%s' % entry['pat'])
1545 1548 except re.error:
1546 1549 log.exception('issue tracker pattern: `%s` failed to compile', entry['pat'])
1547 1550 continue
1548 1551
1549 1552 data_func = partial(
1550 1553 _process_url_func, repo_name=repo_name, entry=entry, uid=uid,
1551 1554 return_raw_data=True)
1552 1555
1553 1556 for match_obj in pattern.finditer(text_string):
1554 1557 issues_data.append(data_func(match_obj))
1555 1558
1556 1559 url_func = partial(
1557 1560 _process_url_func, repo_name=repo_name, entry=entry, uid=uid,
1558 1561 link_format=link_format)
1559 1562
1560 1563 new_text = pattern.sub(url_func, new_text)
1561 1564 log.debug('processed prefix:uid `%s`', uid)
1562 1565
1563 1566 # finally use global replace, eg !123 -> pr-link, those will not catch
1564 1567 # if already similar pattern exists
1565 1568 server_url = '${scheme}://${netloc}'
1566 1569 pr_entry = {
1567 1570 'pref': '!',
1568 1571 'url': server_url + '/_admin/pull-requests/${id}',
1569 1572 'desc': 'Pull Request !${id}',
1570 1573 'hovercard_url': server_url + '/_hovercard/pull_request/${id}'
1571 1574 }
1572 1575 pr_url_func = partial(
1573 1576 _process_url_func, repo_name=repo_name, entry=pr_entry, uid=None,
1574 1577 link_format=link_format+'+hovercard')
1575 new_text = re.compile(r'(?:(?:^!)|(?: !))(\d+)').sub(pr_url_func, new_text)
1578 new_text = pr_pattern_re.sub(pr_url_func, new_text)
1576 1579 log.debug('processed !pr pattern')
1577 1580
1578 1581 return new_text, issues_data
1579 1582
1580 1583
1581 1584 def urlify_commit_message(commit_text, repository=None, active_pattern_entries=None):
1582 1585 """
1583 1586 Parses given text message and makes proper links.
1584 1587 issues are linked to given issue-server, and rest is a commit link
1585 1588 """
1586 1589
1587 1590 def escaper(_text):
1588 1591 return _text.replace('<', '&lt;').replace('>', '&gt;')
1589 1592
1590 1593 new_text = escaper(commit_text)
1591 1594
1592 1595 # extract http/https links and make them real urls
1593 1596 new_text = urlify_text(new_text, safe=False)
1594 1597
1595 1598 # urlify commits - extract commit ids and make link out of them, if we have
1596 1599 # the scope of repository present.
1597 1600 if repository:
1598 1601 new_text = urlify_commits(new_text, repository)
1599 1602
1600 1603 # process issue tracker patterns
1601 1604 new_text, issues = process_patterns(new_text, repository or '',
1602 1605 active_entries=active_pattern_entries)
1603 1606
1604 1607 return literal(new_text)
1605 1608
1606 1609
1607 1610 def render_binary(repo_name, file_obj):
1608 1611 """
1609 1612 Choose how to render a binary file
1610 1613 """
1611 1614
1612 1615 filename = file_obj.name
1613 1616
1614 1617 # images
1615 1618 for ext in ['*.png', '*.jpg', '*.ico', '*.gif']:
1616 1619 if fnmatch.fnmatch(filename, pat=ext):
1617 1620 alt = escape(filename)
1618 1621 src = route_path(
1619 1622 'repo_file_raw', repo_name=repo_name,
1620 1623 commit_id=file_obj.commit.raw_id,
1621 1624 f_path=file_obj.path)
1622 1625 return literal(
1623 1626 '<img class="rendered-binary" alt="{}" src="{}">'.format(alt, src))
1624 1627
1625 1628
1626 1629 def renderer_from_filename(filename, exclude=None):
1627 1630 """
1628 1631 choose a renderer based on filename, this works only for text based files
1629 1632 """
1630 1633
1631 1634 # ipython
1632 1635 for ext in ['*.ipynb']:
1633 1636 if fnmatch.fnmatch(filename, pat=ext):
1634 1637 return 'jupyter'
1635 1638
1636 1639 is_markup = MarkupRenderer.renderer_from_filename(filename, exclude=exclude)
1637 1640 if is_markup:
1638 1641 return is_markup
1639 1642 return None
1640 1643
1641 1644
1642 1645 def render(source, renderer='rst', mentions=False, relative_urls=None,
1643 1646 repo_name=None, active_pattern_entries=None):
1644 1647
1645 1648 def maybe_convert_relative_links(html_source):
1646 1649 if relative_urls:
1647 1650 return relative_links(html_source, relative_urls)
1648 1651 return html_source
1649 1652
1650 1653 if renderer == 'plain':
1651 1654 return literal(
1652 1655 MarkupRenderer.plain(source, leading_newline=False))
1653 1656
1654 1657 elif renderer == 'rst':
1655 1658 if repo_name:
1656 1659 # process patterns on comments if we pass in repo name
1657 1660 source, issues = process_patterns(
1658 1661 source, repo_name, link_format='rst',
1659 1662 active_entries=active_pattern_entries)
1660 1663
1661 1664 return literal(
1662 1665 '<div class="rst-block">%s</div>' %
1663 1666 maybe_convert_relative_links(
1664 1667 MarkupRenderer.rst(source, mentions=mentions)))
1665 1668
1666 1669 elif renderer == 'markdown':
1667 1670 if repo_name:
1668 1671 # process patterns on comments if we pass in repo name
1669 1672 source, issues = process_patterns(
1670 1673 source, repo_name, link_format='markdown',
1671 1674 active_entries=active_pattern_entries)
1672 1675
1673 1676 return literal(
1674 1677 '<div class="markdown-block">%s</div>' %
1675 1678 maybe_convert_relative_links(
1676 1679 MarkupRenderer.markdown(source, flavored=True,
1677 1680 mentions=mentions)))
1678 1681
1679 1682 elif renderer == 'jupyter':
1680 1683 return literal(
1681 1684 '<div class="ipynb">%s</div>' %
1682 1685 maybe_convert_relative_links(
1683 1686 MarkupRenderer.jupyter(source)))
1684 1687
1685 1688 # None means just show the file-source
1686 1689 return None
1687 1690
1688 1691
1689 1692 def commit_status(repo, commit_id):
1690 1693 return ChangesetStatusModel().get_status(repo, commit_id)
1691 1694
1692 1695
1693 1696 def commit_status_lbl(commit_status):
1694 1697 return dict(ChangesetStatus.STATUSES).get(commit_status)
1695 1698
1696 1699
1697 1700 def commit_time(repo_name, commit_id):
1698 1701 repo = Repository.get_by_repo_name(repo_name)
1699 1702 commit = repo.get_commit(commit_id=commit_id)
1700 1703 return commit.date
1701 1704
1702 1705
1703 1706 def get_permission_name(key):
1704 1707 return dict(Permission.PERMS).get(key)
1705 1708
1706 1709
1707 1710 def journal_filter_help(request):
1708 1711 _ = request.translate
1709 1712 from rhodecode.lib.audit_logger import ACTIONS
1710 1713 actions = '\n'.join(textwrap.wrap(', '.join(sorted(ACTIONS.keys())), 80))
1711 1714
1712 1715 return _(
1713 1716 'Example filter terms:\n' +
1714 1717 ' repository:vcs\n' +
1715 1718 ' username:marcin\n' +
1716 1719 ' username:(NOT marcin)\n' +
1717 1720 ' action:*push*\n' +
1718 1721 ' ip:127.0.0.1\n' +
1719 1722 ' date:20120101\n' +
1720 1723 ' date:[20120101100000 TO 20120102]\n' +
1721 1724 '\n' +
1722 1725 'Actions: {actions}\n' +
1723 1726 '\n' +
1724 1727 'Generate wildcards using \'*\' character:\n' +
1725 1728 ' "repository:vcs*" - search everything starting with \'vcs\'\n' +
1726 1729 ' "repository:*vcs*" - search for repository containing \'vcs\'\n' +
1727 1730 '\n' +
1728 1731 'Optional AND / OR operators in queries\n' +
1729 1732 ' "repository:vcs OR repository:test"\n' +
1730 1733 ' "username:test AND repository:test*"\n'
1731 1734 ).format(actions=actions)
1732 1735
1733 1736
1734 1737 def not_mapped_error(repo_name):
1735 1738 from rhodecode.translation import _
1736 1739 flash(_('%s repository is not mapped to db perhaps'
1737 1740 ' it was created or renamed from the filesystem'
1738 1741 ' please run the application again'
1739 1742 ' in order to rescan repositories') % repo_name, category='error')
1740 1743
1741 1744
1742 1745 def ip_range(ip_addr):
1743 1746 from rhodecode.model.db import UserIpMap
1744 1747 s, e = UserIpMap._get_ip_range(ip_addr)
1745 1748 return '%s - %s' % (s, e)
1746 1749
1747 1750
1748 1751 def form(url, method='post', needs_csrf_token=True, **attrs):
1749 1752 """Wrapper around webhelpers.tags.form to prevent CSRF attacks."""
1750 1753 if method.lower() != 'get' and needs_csrf_token:
1751 1754 raise Exception(
1752 1755 'Forms to POST/PUT/DELETE endpoints should have (in general) a ' +
1753 1756 'CSRF token. If the endpoint does not require such token you can ' +
1754 1757 'explicitly set the parameter needs_csrf_token to false.')
1755 1758
1756 1759 return insecure_form(url, method=method, **attrs)
1757 1760
1758 1761
1759 1762 def secure_form(form_url, method="POST", multipart=False, **attrs):
1760 1763 """Start a form tag that points the action to an url. This
1761 1764 form tag will also include the hidden field containing
1762 1765 the auth token.
1763 1766
1764 1767 The url options should be given either as a string, or as a
1765 1768 ``url()`` function. The method for the form defaults to POST.
1766 1769
1767 1770 Options:
1768 1771
1769 1772 ``multipart``
1770 1773 If set to True, the enctype is set to "multipart/form-data".
1771 1774 ``method``
1772 1775 The method to use when submitting the form, usually either
1773 1776 "GET" or "POST". If "PUT", "DELETE", or another verb is used, a
1774 1777 hidden input with name _method is added to simulate the verb
1775 1778 over POST.
1776 1779
1777 1780 """
1778 1781
1779 1782 if 'request' in attrs:
1780 1783 session = attrs['request'].session
1781 1784 del attrs['request']
1782 1785 else:
1783 1786 raise ValueError(
1784 1787 'Calling this form requires request= to be passed as argument')
1785 1788
1786 1789 _form = insecure_form(form_url, method, multipart, **attrs)
1787 1790 token = literal(
1788 1791 '<input type="hidden" name="{}" value="{}">'.format(
1789 1792 csrf_token_key, get_csrf_token(session)))
1790 1793
1791 1794 return literal("%s\n%s" % (_form, token))
1792 1795
1793 1796
1794 1797 def dropdownmenu(name, selected, options, enable_filter=False, **attrs):
1795 1798 select_html = select(name, selected, options, **attrs)
1796 1799
1797 1800 select2 = """
1798 1801 <script>
1799 1802 $(document).ready(function() {
1800 1803 $('#%s').select2({
1801 1804 containerCssClass: 'drop-menu %s',
1802 1805 dropdownCssClass: 'drop-menu-dropdown',
1803 1806 dropdownAutoWidth: true%s
1804 1807 });
1805 1808 });
1806 1809 </script>
1807 1810 """
1808 1811
1809 1812 filter_option = """,
1810 1813 minimumResultsForSearch: -1
1811 1814 """
1812 1815 input_id = attrs.get('id') or name
1813 1816 extra_classes = ' '.join(attrs.pop('extra_classes', []))
1814 1817 filter_enabled = "" if enable_filter else filter_option
1815 1818 select_script = literal(select2 % (input_id, extra_classes, filter_enabled))
1816 1819
1817 1820 return literal(select_html+select_script)
1818 1821
1819 1822
1820 1823 def get_visual_attr(tmpl_context_var, attr_name):
1821 1824 """
1822 1825 A safe way to get a variable from visual variable of template context
1823 1826
1824 1827 :param tmpl_context_var: instance of tmpl_context, usually present as `c`
1825 1828 :param attr_name: name of the attribute we fetch from the c.visual
1826 1829 """
1827 1830 visual = getattr(tmpl_context_var, 'visual', None)
1828 1831 if not visual:
1829 1832 return
1830 1833 else:
1831 1834 return getattr(visual, attr_name, None)
1832 1835
1833 1836
1834 1837 def get_last_path_part(file_node):
1835 1838 if not file_node.path:
1836 1839 return u'/'
1837 1840
1838 1841 path = safe_unicode(file_node.path.split('/')[-1])
1839 1842 return u'../' + path
1840 1843
1841 1844
1842 1845 def route_url(*args, **kwargs):
1843 1846 """
1844 1847 Wrapper around pyramids `route_url` (fully qualified url) function.
1845 1848 """
1846 1849 req = get_current_request()
1847 1850 return req.route_url(*args, **kwargs)
1848 1851
1849 1852
1850 1853 def route_path(*args, **kwargs):
1851 1854 """
1852 1855 Wrapper around pyramids `route_path` function.
1853 1856 """
1854 1857 req = get_current_request()
1855 1858 return req.route_path(*args, **kwargs)
1856 1859
1857 1860
1858 1861 def route_path_or_none(*args, **kwargs):
1859 1862 try:
1860 1863 return route_path(*args, **kwargs)
1861 1864 except KeyError:
1862 1865 return None
1863 1866
1864 1867
1865 1868 def current_route_path(request, **kw):
1866 1869 new_args = request.GET.mixed()
1867 1870 new_args.update(kw)
1868 1871 return request.current_route_path(_query=new_args)
1869 1872
1870 1873
1871 1874 def curl_api_example(method, args):
1872 1875 args_json = json.dumps(OrderedDict([
1873 1876 ('id', 1),
1874 1877 ('auth_token', 'SECRET'),
1875 1878 ('method', method),
1876 1879 ('args', args)
1877 1880 ]))
1878 1881
1879 1882 return "curl {api_url} -X POST -H 'content-type:text/plain' --data-binary '{args_json}'".format(
1880 1883 api_url=route_url('apiv2'),
1881 1884 args_json=args_json
1882 1885 )
1883 1886
1884 1887
1885 1888 def api_call_example(method, args):
1886 1889 """
1887 1890 Generates an API call example via CURL
1888 1891 """
1889 1892 curl_call = curl_api_example(method, args)
1890 1893
1891 1894 return literal(
1892 1895 curl_call +
1893 1896 "<br/><br/>SECRET can be found in <a href=\"{token_url}\">auth-tokens</a> page, "
1894 1897 "and needs to be of `api calls` role."
1895 1898 .format(token_url=route_url('my_account_auth_tokens')))
1896 1899
1897 1900
1898 1901 def notification_description(notification, request):
1899 1902 """
1900 1903 Generate notification human readable description based on notification type
1901 1904 """
1902 1905 from rhodecode.model.notification import NotificationModel
1903 1906 return NotificationModel().make_description(
1904 1907 notification, translate=request.translate)
1905 1908
1906 1909
1907 1910 def go_import_header(request, db_repo=None):
1908 1911 """
1909 1912 Creates a header for go-import functionality in Go Lang
1910 1913 """
1911 1914
1912 1915 if not db_repo:
1913 1916 return
1914 1917 if 'go-get' not in request.GET:
1915 1918 return
1916 1919
1917 1920 clone_url = db_repo.clone_url()
1918 1921 prefix = re.split(r'^https?:\/\/', clone_url)[-1]
1919 1922 # we have a repo and go-get flag,
1920 1923 return literal('<meta name="go-import" content="{} {} {}">'.format(
1921 1924 prefix, db_repo.repo_type, clone_url))
1922 1925
1923 1926
1924 1927 def reviewer_as_json(*args, **kwargs):
1925 1928 from rhodecode.apps.repository.utils import reviewer_as_json as _reviewer_as_json
1926 1929 return _reviewer_as_json(*args, **kwargs)
1927 1930
1928 1931
1929 1932 def get_repo_view_type(request):
1930 1933 route_name = request.matched_route.name
1931 1934 route_to_view_type = {
1932 1935 'repo_changelog': 'commits',
1933 1936 'repo_commits': 'commits',
1934 1937 'repo_files': 'files',
1935 1938 'repo_summary': 'summary',
1936 1939 'repo_commit': 'commit'
1937 1940 }
1938 1941
1939 1942 return route_to_view_type.get(route_name)
1940 1943
1941 1944
1942 1945 def is_active(menu_entry, selected):
1943 1946 """
1944 1947 Returns active class for selecting menus in templates
1945 1948 <li class=${h.is_active('settings', current_active)}></li>
1946 1949 """
1947 1950 if not isinstance(menu_entry, list):
1948 1951 menu_entry = [menu_entry]
1949 1952
1950 1953 if selected in menu_entry:
1951 1954 return "active"
General Comments 0
You need to be logged in to leave comments. Login now