Show More
@@ -0,0 +1,38 b'' | |||
|
1 | ||
|
2 | # Copyright (C) 2010-2023 RhodeCode GmbH | |
|
3 | # | |
|
4 | # This program is free software: you can redistribute it and/or modify | |
|
5 | # it under the terms of the GNU Affero General Public License, version 3 | |
|
6 | # (only), as published by the Free Software Foundation. | |
|
7 | # | |
|
8 | # This program is distributed in the hope that it will be useful, | |
|
9 | # but WITHOUT ANY WARRANTY; without even the implied warranty of | |
|
10 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
|
11 | # GNU General Public License for more details. | |
|
12 | # | |
|
13 | # You should have received a copy of the GNU Affero General Public License | |
|
14 | # along with this program. If not, see <http://www.gnu.org/licenses/>. | |
|
15 | # | |
|
16 | # This program is dual-licensed. If you wish to learn more about the | |
|
17 | # RhodeCode Enterprise Edition, including its added features, Support services, | |
|
18 | # and proprietary license terms, please see https://rhodecode.com/licenses/ | |
|
19 | ||
|
20 | import pytest | |
|
21 | ||
|
22 | from rhodecode.lib.html_filters import sanitize_html | |
|
23 | ||
|
24 | ||
|
25 | @pytest.mark.parametrize( | |
|
26 | "src_html, expected_html", | |
|
27 | [ | |
|
28 | ('<div>ITEM</div>', '<div>ITEM</div>'), | |
|
29 | ('<div>ITEM</div> <!-- comment here -->', '<div>ITEM</div> <!-- comment here -->'), | |
|
30 | ('<div style="not-allowed:true">ITEM</div>', '<div style="">ITEM</div>'), | |
|
31 | ('<div onload="ACTION">ITEM</div>', '<div>ITEM</div>'), | |
|
32 | ('<a onload="ACTION" style="color:red">ITEM</a>', '<a style="color:red;">ITEM</a>'), | |
|
33 | ('<img src="/file.png"></img>', '<img src="/file.png">'), | |
|
34 | ('<img src="/file.png"></img>', '<img src="/file.png">'), | |
|
35 | ]) | |
|
36 | def test_html_sanitizer_options(src_html, expected_html): | |
|
37 | parsed_html = sanitize_html(src_html) | |
|
38 | assert parsed_html == expected_html |
@@ -1,2160 +1,2160 b'' | |||
|
1 | 1 | # Copyright (C) 2010-2023 RhodeCode GmbH |
|
2 | 2 | # |
|
3 | 3 | # This program is free software: you can redistribute it and/or modify |
|
4 | 4 | # it under the terms of the GNU Affero General Public License, version 3 |
|
5 | 5 | # (only), as published by the Free Software Foundation. |
|
6 | 6 | # |
|
7 | 7 | # This program is distributed in the hope that it will be useful, |
|
8 | 8 | # but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
9 | 9 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
10 | 10 | # GNU General Public License for more details. |
|
11 | 11 | # |
|
12 | 12 | # You should have received a copy of the GNU Affero General Public License |
|
13 | 13 | # along with this program. If not, see <http://www.gnu.org/licenses/>. |
|
14 | 14 | # |
|
15 | 15 | # This program is dual-licensed. If you wish to learn more about the |
|
16 | 16 | # RhodeCode Enterprise Edition, including its added features, Support services, |
|
17 | 17 | # and proprietary license terms, please see https://rhodecode.com/licenses/ |
|
18 | 18 | |
|
19 | 19 | """ |
|
20 | 20 | Helper functions |
|
21 | 21 | |
|
22 | 22 | Consists of functions to typically be used within templates, but also |
|
23 | 23 | available to Controllers. This module is available to both as 'h'. |
|
24 | 24 | """ |
|
25 | 25 | import base64 |
|
26 | 26 | import collections |
|
27 | 27 | |
|
28 | 28 | import os |
|
29 | 29 | import random |
|
30 | 30 | import hashlib |
|
31 | 31 | import io |
|
32 | 32 | import textwrap |
|
33 | 33 | import urllib.request |
|
34 | 34 | import urllib.parse |
|
35 | 35 | import urllib.error |
|
36 | 36 | import math |
|
37 | 37 | import logging |
|
38 | 38 | import re |
|
39 | 39 | import time |
|
40 | 40 | import string |
|
41 | 41 | import regex |
|
42 | 42 | from collections import OrderedDict |
|
43 | 43 | |
|
44 | 44 | import pygments |
|
45 | 45 | import itertools |
|
46 | 46 | import fnmatch |
|
47 | import bleach | |
|
48 | 47 | |
|
49 | 48 | from datetime import datetime |
|
50 | 49 | from functools import partial |
|
51 | 50 | from pygments.formatters.html import HtmlFormatter |
|
52 | 51 | from pygments.lexers import ( |
|
53 | 52 | get_lexer_by_name, get_lexer_for_filename, get_lexer_for_mimetype) |
|
54 | 53 | |
|
55 | 54 | from pyramid.threadlocal import get_current_request |
|
56 | 55 | from tempita import looper |
|
57 | 56 | from webhelpers2.html import literal, HTML, escape |
|
58 | 57 | from webhelpers2.html._autolink import _auto_link_urls |
|
59 | 58 | from webhelpers2.html.tools import ( |
|
60 | 59 | button_to, highlight, js_obfuscate, strip_links, strip_tags) |
|
61 | 60 | |
|
62 | 61 | from webhelpers2.text import ( |
|
63 | 62 | chop_at, collapse, convert_accented_entities, |
|
64 | 63 | convert_misc_entities, lchop, plural, rchop, remove_formatting, |
|
65 | 64 | replace_whitespace, urlify, truncate, wrap_paragraphs) |
|
66 | 65 | from webhelpers2.date import time_ago_in_words |
|
67 | 66 | |
|
68 | 67 | from webhelpers2.html.tags import ( |
|
69 | 68 | _input, NotGiven, _make_safe_id_component as safeid, |
|
70 | 69 | form as insecure_form, |
|
71 | 70 | auto_discovery_link, checkbox, end_form, file, |
|
72 | 71 | hidden, image, javascript_link, link_to, link_to_if, link_to_unless, ol, |
|
73 | 72 | stylesheet_link, submit, text, password, textarea, |
|
74 | 73 | ul, radio, Options) |
|
75 | 74 | |
|
76 | 75 | from webhelpers2.number import format_byte_size |
|
77 | 76 | # python3.11 backport fixes for webhelpers2 |
|
78 | 77 | from rhodecode.lib._vendor.webhelpers_backports import raw_select |
|
79 | 78 | |
|
80 | 79 | from rhodecode.lib.action_parser import action_parser |
|
80 | from rhodecode.lib.html_filters import sanitize_html | |
|
81 | 81 | from rhodecode.lib.pagination import Page, RepoPage, SqlPage |
|
82 | 82 | from rhodecode.lib import ext_json |
|
83 | 83 | from rhodecode.lib.ext_json import json |
|
84 | 84 | from rhodecode.lib.str_utils import safe_bytes, convert_special_chars |
|
85 | 85 | from rhodecode.lib.utils import repo_name_slug, get_custom_lexer |
|
86 | 86 | from rhodecode.lib.str_utils import safe_str |
|
87 | 87 | from rhodecode.lib.utils2 import ( |
|
88 | 88 | str2bool, |
|
89 | 89 | get_commit_safe, datetime_to_time, time_to_datetime, time_to_utcdatetime, |
|
90 | 90 | AttributeDict, safe_int, md5, md5_safe, get_host_info) |
|
91 | 91 | from rhodecode.lib.markup_renderer import MarkupRenderer, relative_links |
|
92 | 92 | from rhodecode.lib.vcs.exceptions import CommitDoesNotExistError |
|
93 | 93 | from rhodecode.lib.vcs.backends.base import BaseChangeset, EmptyCommit |
|
94 | 94 | from rhodecode.lib.vcs.conf.settings import ARCHIVE_SPECS |
|
95 | 95 | from rhodecode.lib.index.search_utils import get_matching_line_offsets |
|
96 | 96 | from rhodecode.config.conf import DATE_FORMAT, DATETIME_FORMAT |
|
97 | 97 | from rhodecode.model.changeset_status import ChangesetStatusModel |
|
98 | 98 | from rhodecode.model.db import Permission, User, Repository, UserApiKeys, FileStore |
|
99 | 99 | from rhodecode.model.repo_group import RepoGroupModel |
|
100 | 100 | from rhodecode.model.settings import IssueTrackerSettingsModel |
|
101 | 101 | |
|
102 | 102 | |
|
103 | 103 | log = logging.getLogger(__name__) |
|
104 | 104 | |
|
105 | 105 | |
|
106 | 106 | DEFAULT_USER = User.DEFAULT_USER |
|
107 | 107 | DEFAULT_USER_EMAIL = User.DEFAULT_USER_EMAIL |
|
108 | 108 | |
|
109 | 109 | |
|
110 | 110 | def asset(path, ver=None, **kwargs): |
|
111 | 111 | """ |
|
112 | 112 | Helper to generate a static asset file path for rhodecode assets |
|
113 | 113 | |
|
114 | 114 | eg. h.asset('images/image.png', ver='3923') |
|
115 | 115 | |
|
116 | 116 | :param path: path of asset |
|
117 | 117 | :param ver: optional version query param to append as ?ver= |
|
118 | 118 | """ |
|
119 | 119 | request = get_current_request() |
|
120 | 120 | query = {} |
|
121 | 121 | query.update(kwargs) |
|
122 | 122 | if ver: |
|
123 | 123 | query = {'ver': ver} |
|
124 | 124 | return request.static_path( |
|
125 | 125 | f'rhodecode:public/{path}', _query=query) |
|
126 | 126 | |
|
127 | 127 | |
|
128 | 128 | default_html_escape_table = { |
|
129 | 129 | ord('&'): '&', |
|
130 | 130 | ord('<'): '<', |
|
131 | 131 | ord('>'): '>', |
|
132 | 132 | ord('"'): '"', |
|
133 | 133 | ord("'"): ''', |
|
134 | 134 | } |
|
135 | 135 | |
|
136 | 136 | |
|
137 | 137 | def html_escape(text, html_escape_table=default_html_escape_table): |
|
138 | 138 | """Produce entities within text.""" |
|
139 | 139 | return text.translate(html_escape_table) |
|
140 | 140 | |
|
141 | 141 | |
|
142 | 142 | def str_json(*args, **kwargs): |
|
143 | 143 | return ext_json.str_json(*args, **kwargs) |
|
144 | 144 | |
|
145 | 145 | |
|
146 | 146 | def formatted_str_json(*args, **kwargs): |
|
147 | 147 | return ext_json.formatted_str_json(*args, **kwargs) |
|
148 | 148 | |
|
149 | 149 | |
|
150 | 150 | def chop_at_smart(s, sub, inclusive=False, suffix_if_chopped=None): |
|
151 | 151 | """ |
|
152 | 152 | Truncate string ``s`` at the first occurrence of ``sub``. |
|
153 | 153 | |
|
154 | 154 | If ``inclusive`` is true, truncate just after ``sub`` rather than at it. |
|
155 | 155 | """ |
|
156 | 156 | suffix_if_chopped = suffix_if_chopped or '' |
|
157 | 157 | pos = s.find(sub) |
|
158 | 158 | if pos == -1: |
|
159 | 159 | return s |
|
160 | 160 | |
|
161 | 161 | if inclusive: |
|
162 | 162 | pos += len(sub) |
|
163 | 163 | |
|
164 | 164 | chopped = s[:pos] |
|
165 | 165 | left = s[pos:].strip() |
|
166 | 166 | |
|
167 | 167 | if left and suffix_if_chopped: |
|
168 | 168 | chopped += suffix_if_chopped |
|
169 | 169 | |
|
170 | 170 | return chopped |
|
171 | 171 | |
|
172 | 172 | |
|
173 | 173 | def shorter(text, size=20, prefix=False): |
|
174 | 174 | postfix = '...' |
|
175 | 175 | if len(text) > size: |
|
176 | 176 | if prefix: |
|
177 | 177 | # shorten in front |
|
178 | 178 | return postfix + text[-(size - len(postfix)):] |
|
179 | 179 | else: |
|
180 | 180 | return text[:size - len(postfix)] + postfix |
|
181 | 181 | return text |
|
182 | 182 | |
|
183 | 183 | |
|
184 | 184 | def reset(name, value=None, id=NotGiven, type="reset", **attrs): |
|
185 | 185 | """ |
|
186 | 186 | Reset button |
|
187 | 187 | """ |
|
188 | 188 | return _input(type, name, value, id, attrs) |
|
189 | 189 | |
|
190 | 190 | |
|
191 | 191 | def select(name, selected_values, options, id=NotGiven, **attrs): |
|
192 | 192 | |
|
193 | 193 | if isinstance(options, (list, tuple)): |
|
194 | 194 | options_iter = options |
|
195 | 195 | # Handle old value,label lists ... where value also can be value,label lists |
|
196 | 196 | options = Options() |
|
197 | 197 | for opt in options_iter: |
|
198 | 198 | if isinstance(opt, tuple) and len(opt) == 2: |
|
199 | 199 | value, label = opt |
|
200 | 200 | elif isinstance(opt, str): |
|
201 | 201 | value = label = opt |
|
202 | 202 | else: |
|
203 | 203 | raise ValueError('invalid select option type %r' % type(opt)) |
|
204 | 204 | |
|
205 | 205 | if isinstance(value, (list, tuple)): |
|
206 | 206 | option_group = options.add_optgroup(label) |
|
207 | 207 | for opt2 in value: |
|
208 | 208 | if isinstance(opt2, tuple) and len(opt2) == 2: |
|
209 | 209 | group_value, group_label = opt2 |
|
210 | 210 | elif isinstance(opt2, str): |
|
211 | 211 | group_value = group_label = opt2 |
|
212 | 212 | else: |
|
213 | 213 | raise ValueError('invalid select option type %r' % type(opt2)) |
|
214 | 214 | |
|
215 | 215 | option_group.add_option(group_label, group_value) |
|
216 | 216 | else: |
|
217 | 217 | options.add_option(label, value) |
|
218 | 218 | |
|
219 | 219 | return raw_select(name, selected_values, options, id=id, **attrs) |
|
220 | 220 | |
|
221 | 221 | |
|
222 | 222 | def branding(name, length=40): |
|
223 | 223 | return truncate(name, length, indicator="") |
|
224 | 224 | |
|
225 | 225 | |
|
226 | 226 | def FID(raw_id, path): |
|
227 | 227 | """ |
|
228 | 228 | Creates a unique ID for filenode based on it's hash of path and commit |
|
229 | 229 | it's safe to use in urls |
|
230 | 230 | |
|
231 | 231 | :param raw_id: |
|
232 | 232 | :param path: |
|
233 | 233 | """ |
|
234 | 234 | |
|
235 | 235 | return 'c-%s-%s' % (short_id(raw_id), md5_safe(path)[:12]) |
|
236 | 236 | |
|
237 | 237 | |
|
238 | 238 | class _GetError(object): |
|
239 | 239 | """Get error from form_errors, and represent it as span wrapped error |
|
240 | 240 | message |
|
241 | 241 | |
|
242 | 242 | :param field_name: field to fetch errors for |
|
243 | 243 | :param form_errors: form errors dict |
|
244 | 244 | """ |
|
245 | 245 | |
|
246 | 246 | def __call__(self, field_name, form_errors): |
|
247 | 247 | tmpl = """<span class="error_msg">%s</span>""" |
|
248 | 248 | if form_errors and field_name in form_errors: |
|
249 | 249 | return literal(tmpl % form_errors.get(field_name)) |
|
250 | 250 | |
|
251 | 251 | |
|
252 | 252 | get_error = _GetError() |
|
253 | 253 | |
|
254 | 254 | |
|
255 | 255 | class _ToolTip(object): |
|
256 | 256 | |
|
257 | 257 | def __call__(self, tooltip_title, trim_at=50): |
|
258 | 258 | """ |
|
259 | 259 | Special function just to wrap our text into nice formatted |
|
260 | 260 | autowrapped text |
|
261 | 261 | |
|
262 | 262 | :param tooltip_title: |
|
263 | 263 | """ |
|
264 | 264 | tooltip_title = escape(tooltip_title) |
|
265 | 265 | tooltip_title = tooltip_title.replace('<', '<').replace('>', '>') |
|
266 | 266 | return tooltip_title |
|
267 | 267 | |
|
268 | 268 | |
|
269 | 269 | tooltip = _ToolTip() |
|
270 | 270 | |
|
271 | 271 | files_icon = '<i class="file-breadcrumb-copy tooltip icon-clipboard clipboard-action" data-clipboard-text="{}" title="Copy file path"></i>' |
|
272 | 272 | |
|
273 | 273 | |
|
274 | 274 | def files_breadcrumbs(repo_name, repo_type, commit_id, file_path, landing_ref_name=None, at_ref=None, |
|
275 | 275 | limit_items=False, linkify_last_item=False, hide_last_item=False, |
|
276 | 276 | copy_path_icon=True): |
|
277 | 277 | |
|
278 | 278 | if at_ref: |
|
279 | 279 | route_qry = {'at': at_ref} |
|
280 | 280 | default_landing_ref = at_ref or landing_ref_name or commit_id |
|
281 | 281 | else: |
|
282 | 282 | route_qry = None |
|
283 | 283 | default_landing_ref = commit_id |
|
284 | 284 | |
|
285 | 285 | # first segment is a `HOME` link to repo files root location |
|
286 | 286 | root_name = literal('<i class="icon-home"></i>') |
|
287 | 287 | |
|
288 | 288 | url_segments = [ |
|
289 | 289 | link_to( |
|
290 | 290 | root_name, |
|
291 | 291 | repo_files_by_ref_url( |
|
292 | 292 | repo_name, |
|
293 | 293 | repo_type, |
|
294 | 294 | f_path=None, # None here is a special case for SVN repos, |
|
295 | 295 | # that won't prefix with a ref |
|
296 | 296 | ref_name=default_landing_ref, |
|
297 | 297 | commit_id=commit_id, |
|
298 | 298 | query=route_qry |
|
299 | 299 | ) |
|
300 | 300 | )] |
|
301 | 301 | |
|
302 | 302 | path_segments = file_path.split('/') |
|
303 | 303 | last_cnt = len(path_segments) - 1 |
|
304 | 304 | for cnt, segment in enumerate(path_segments): |
|
305 | 305 | if not segment: |
|
306 | 306 | continue |
|
307 | 307 | segment_html = escape(segment) |
|
308 | 308 | |
|
309 | 309 | last_item = cnt == last_cnt |
|
310 | 310 | |
|
311 | 311 | if last_item and hide_last_item: |
|
312 | 312 | # iterate over and hide last element |
|
313 | 313 | continue |
|
314 | 314 | |
|
315 | 315 | if last_item and linkify_last_item is False: |
|
316 | 316 | # plain version |
|
317 | 317 | url_segments.append(segment_html) |
|
318 | 318 | else: |
|
319 | 319 | url_segments.append( |
|
320 | 320 | link_to( |
|
321 | 321 | segment_html, |
|
322 | 322 | repo_files_by_ref_url( |
|
323 | 323 | repo_name, |
|
324 | 324 | repo_type, |
|
325 | 325 | f_path='/'.join(path_segments[:cnt + 1]), |
|
326 | 326 | ref_name=default_landing_ref, |
|
327 | 327 | commit_id=commit_id, |
|
328 | 328 | query=route_qry |
|
329 | 329 | ), |
|
330 | 330 | )) |
|
331 | 331 | |
|
332 | 332 | limited_url_segments = url_segments[:1] + ['...'] + url_segments[-5:] |
|
333 | 333 | if limit_items and len(limited_url_segments) < len(url_segments): |
|
334 | 334 | url_segments = limited_url_segments |
|
335 | 335 | |
|
336 | 336 | full_path = file_path |
|
337 | 337 | if copy_path_icon: |
|
338 | 338 | icon = files_icon.format(escape(full_path)) |
|
339 | 339 | else: |
|
340 | 340 | icon = '' |
|
341 | 341 | |
|
342 | 342 | if file_path == '': |
|
343 | 343 | return root_name |
|
344 | 344 | else: |
|
345 | 345 | return literal(' / '.join(url_segments) + icon) |
|
346 | 346 | |
|
347 | 347 | |
|
348 | 348 | def files_url_data(request): |
|
349 | 349 | matchdict = request.matchdict |
|
350 | 350 | |
|
351 | 351 | if 'f_path' not in matchdict: |
|
352 | 352 | matchdict['f_path'] = '' |
|
353 | 353 | else: |
|
354 | 354 | matchdict['f_path'] = urllib.parse.quote(safe_str(matchdict['f_path'])) |
|
355 | 355 | if 'commit_id' not in matchdict: |
|
356 | 356 | matchdict['commit_id'] = 'tip' |
|
357 | 357 | |
|
358 | 358 | return ext_json.str_json(matchdict) |
|
359 | 359 | |
|
360 | 360 | |
|
361 | 361 | def repo_files_by_ref_url(db_repo_name, db_repo_type, f_path, ref_name, commit_id, query=None, ): |
|
362 | 362 | _is_svn = is_svn(db_repo_type) |
|
363 | 363 | final_f_path = f_path |
|
364 | 364 | |
|
365 | 365 | if _is_svn: |
|
366 | 366 | """ |
|
367 | 367 | For SVN the ref_name cannot be used as a commit_id, it needs to be prefixed with |
|
368 | 368 | actually commit_id followed by the ref_name. This should be done only in case |
|
369 | 369 | This is a initial landing url, without additional paths. |
|
370 | 370 | |
|
371 | 371 | like: /1000/tags/1.0.0/?at=tags/1.0.0 |
|
372 | 372 | """ |
|
373 | 373 | |
|
374 | 374 | if ref_name and ref_name != 'tip': |
|
375 | 375 | # NOTE(marcink): for svn the ref_name is actually the stored path, so we prefix it |
|
376 | 376 | # for SVN we only do this magic prefix if it's root, .eg landing revision |
|
377 | 377 | # of files link. If we are in the tree we don't need this since we traverse the url |
|
378 | 378 | # that has everything stored |
|
379 | 379 | if f_path in ['', '/']: |
|
380 | 380 | final_f_path = '/'.join([ref_name, f_path]) |
|
381 | 381 | |
|
382 | 382 | # SVN always needs a commit_id explicitly, without a named REF |
|
383 | 383 | default_commit_id = commit_id |
|
384 | 384 | else: |
|
385 | 385 | """ |
|
386 | 386 | For git and mercurial we construct a new URL using the names instead of commit_id |
|
387 | 387 | like: /master/some_path?at=master |
|
388 | 388 | """ |
|
389 | 389 | # We currently do not support branches with slashes |
|
390 | 390 | if '/' in ref_name: |
|
391 | 391 | default_commit_id = commit_id |
|
392 | 392 | else: |
|
393 | 393 | default_commit_id = ref_name |
|
394 | 394 | |
|
395 | 395 | # sometimes we pass f_path as None, to indicate explicit no prefix, |
|
396 | 396 | # we translate it to string to not have None |
|
397 | 397 | final_f_path = final_f_path or '' |
|
398 | 398 | |
|
399 | 399 | files_url = route_path( |
|
400 | 400 | 'repo_files', |
|
401 | 401 | repo_name=db_repo_name, |
|
402 | 402 | commit_id=default_commit_id, |
|
403 | 403 | f_path=final_f_path, |
|
404 | 404 | _query=query |
|
405 | 405 | ) |
|
406 | 406 | return files_url |
|
407 | 407 | |
|
408 | 408 | |
|
409 | 409 | def code_highlight(code, lexer, formatter, use_hl_filter=False): |
|
410 | 410 | """ |
|
411 | 411 | Lex ``code`` with ``lexer`` and format it with the formatter ``formatter``. |
|
412 | 412 | |
|
413 | 413 | If ``outfile`` is given and a valid file object (an object |
|
414 | 414 | with a ``write`` method), the result will be written to it, otherwise |
|
415 | 415 | it is returned as a string. |
|
416 | 416 | """ |
|
417 | 417 | if use_hl_filter: |
|
418 | 418 | # add HL filter |
|
419 | 419 | from rhodecode.lib.index import search_utils |
|
420 | 420 | lexer.add_filter(search_utils.ElasticSearchHLFilter()) |
|
421 | 421 | return pygments.format(pygments.lex(code, lexer), formatter) |
|
422 | 422 | |
|
423 | 423 | |
|
424 | 424 | class CodeHtmlFormatter(HtmlFormatter): |
|
425 | 425 | """ |
|
426 | 426 | My code Html Formatter for source codes |
|
427 | 427 | """ |
|
428 | 428 | |
|
429 | 429 | def wrap(self, source): |
|
430 | 430 | return self._wrap_div(self._wrap_pre(self._wrap_code(source))) |
|
431 | 431 | |
|
432 | 432 | def _wrap_code(self, source): |
|
433 | 433 | for cnt, it in enumerate(source): |
|
434 | 434 | i, t = it |
|
435 | 435 | t = f'<div id="L{cnt+1}">{t}</div>' |
|
436 | 436 | yield i, t |
|
437 | 437 | |
|
438 | 438 | def _wrap_tablelinenos(self, inner): |
|
439 | 439 | dummyoutfile = io.StringIO() |
|
440 | 440 | lncount = 0 |
|
441 | 441 | for t, line in inner: |
|
442 | 442 | if t: |
|
443 | 443 | lncount += 1 |
|
444 | 444 | dummyoutfile.write(line) |
|
445 | 445 | |
|
446 | 446 | fl = self.linenostart |
|
447 | 447 | mw = len(str(lncount + fl - 1)) |
|
448 | 448 | sp = self.linenospecial |
|
449 | 449 | st = self.linenostep |
|
450 | 450 | la = self.lineanchors |
|
451 | 451 | aln = self.anchorlinenos |
|
452 | 452 | nocls = self.noclasses |
|
453 | 453 | if sp: |
|
454 | 454 | lines = [] |
|
455 | 455 | |
|
456 | 456 | for i in range(fl, fl + lncount): |
|
457 | 457 | if i % st == 0: |
|
458 | 458 | if i % sp == 0: |
|
459 | 459 | if aln: |
|
460 | 460 | lines.append('<a href="#%s%d" class="special">%*d</a>' % |
|
461 | 461 | (la, i, mw, i)) |
|
462 | 462 | else: |
|
463 | 463 | lines.append('<span class="special">%*d</span>' % (mw, i)) |
|
464 | 464 | else: |
|
465 | 465 | if aln: |
|
466 | 466 | lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i)) |
|
467 | 467 | else: |
|
468 | 468 | lines.append('%*d' % (mw, i)) |
|
469 | 469 | else: |
|
470 | 470 | lines.append('') |
|
471 | 471 | ls = '\n'.join(lines) |
|
472 | 472 | else: |
|
473 | 473 | lines = [] |
|
474 | 474 | for i in range(fl, fl + lncount): |
|
475 | 475 | if i % st == 0: |
|
476 | 476 | if aln: |
|
477 | 477 | lines.append('<a href="#%s%d">%*d</a>' % (la, i, mw, i)) |
|
478 | 478 | else: |
|
479 | 479 | lines.append('%*d' % (mw, i)) |
|
480 | 480 | else: |
|
481 | 481 | lines.append('') |
|
482 | 482 | ls = '\n'.join(lines) |
|
483 | 483 | |
|
484 | 484 | # in case you wonder about the seemingly redundant <div> here: since the |
|
485 | 485 | # content in the other cell also is wrapped in a div, some browsers in |
|
486 | 486 | # some configurations seem to mess up the formatting... |
|
487 | 487 | if nocls: |
|
488 | 488 | yield 0, ('<table class="%stable">' % self.cssclass + |
|
489 | 489 | '<tr><td><div class="linenodiv" ' |
|
490 | 490 | 'style="background-color: #f0f0f0; padding-right: 10px">' |
|
491 | 491 | '<pre style="line-height: 125%">' + |
|
492 | 492 | ls + '</pre></div></td><td id="hlcode" class="code">') |
|
493 | 493 | else: |
|
494 | 494 | yield 0, ('<table class="%stable">' % self.cssclass + |
|
495 | 495 | '<tr><td class="linenos"><div class="linenodiv"><pre>' + |
|
496 | 496 | ls + '</pre></div></td><td id="hlcode" class="code">') |
|
497 | 497 | yield 0, dummyoutfile.getvalue() |
|
498 | 498 | yield 0, '</td></tr></table>' |
|
499 | 499 | |
|
500 | 500 | |
|
501 | 501 | class SearchContentCodeHtmlFormatter(CodeHtmlFormatter): |
|
502 | 502 | def __init__(self, **kw): |
|
503 | 503 | # only show these line numbers if set |
|
504 | 504 | self.only_lines = kw.pop('only_line_numbers', []) |
|
505 | 505 | self.query_terms = kw.pop('query_terms', []) |
|
506 | 506 | self.max_lines = kw.pop('max_lines', 5) |
|
507 | 507 | self.line_context = kw.pop('line_context', 3) |
|
508 | 508 | self.url = kw.pop('url', None) |
|
509 | 509 | |
|
510 | 510 | super(CodeHtmlFormatter, self).__init__(**kw) |
|
511 | 511 | |
|
512 | 512 | def _wrap_code(self, source): |
|
513 | 513 | for cnt, it in enumerate(source): |
|
514 | 514 | i, t = it |
|
515 | 515 | t = '<pre>%s</pre>' % t |
|
516 | 516 | yield i, t |
|
517 | 517 | |
|
518 | 518 | def _wrap_tablelinenos(self, inner): |
|
519 | 519 | yield 0, '<table class="code-highlight %stable">' % self.cssclass |
|
520 | 520 | |
|
521 | 521 | last_shown_line_number = 0 |
|
522 | 522 | current_line_number = 1 |
|
523 | 523 | |
|
524 | 524 | for t, line in inner: |
|
525 | 525 | if not t: |
|
526 | 526 | yield t, line |
|
527 | 527 | continue |
|
528 | 528 | |
|
529 | 529 | if current_line_number in self.only_lines: |
|
530 | 530 | if last_shown_line_number + 1 != current_line_number: |
|
531 | 531 | yield 0, '<tr>' |
|
532 | 532 | yield 0, '<td class="line">...</td>' |
|
533 | 533 | yield 0, '<td id="hlcode" class="code"></td>' |
|
534 | 534 | yield 0, '</tr>' |
|
535 | 535 | |
|
536 | 536 | yield 0, '<tr>' |
|
537 | 537 | if self.url: |
|
538 | 538 | yield 0, '<td class="line"><a href="%s#L%i">%i</a></td>' % ( |
|
539 | 539 | self.url, current_line_number, current_line_number) |
|
540 | 540 | else: |
|
541 | 541 | yield 0, '<td class="line"><a href="">%i</a></td>' % ( |
|
542 | 542 | current_line_number) |
|
543 | 543 | yield 0, '<td id="hlcode" class="code">' + line + '</td>' |
|
544 | 544 | yield 0, '</tr>' |
|
545 | 545 | |
|
546 | 546 | last_shown_line_number = current_line_number |
|
547 | 547 | |
|
548 | 548 | current_line_number += 1 |
|
549 | 549 | |
|
550 | 550 | yield 0, '</table>' |
|
551 | 551 | |
|
552 | 552 | |
|
553 | 553 | def hsv_to_rgb(h, s, v): |
|
554 | 554 | """ Convert hsv color values to rgb """ |
|
555 | 555 | |
|
556 | 556 | if s == 0.0: |
|
557 | 557 | return v, v, v |
|
558 | 558 | i = int(h * 6.0) # XXX assume int() truncates! |
|
559 | 559 | f = (h * 6.0) - i |
|
560 | 560 | p = v * (1.0 - s) |
|
561 | 561 | q = v * (1.0 - s * f) |
|
562 | 562 | t = v * (1.0 - s * (1.0 - f)) |
|
563 | 563 | i = i % 6 |
|
564 | 564 | if i == 0: |
|
565 | 565 | return v, t, p |
|
566 | 566 | if i == 1: |
|
567 | 567 | return q, v, p |
|
568 | 568 | if i == 2: |
|
569 | 569 | return p, v, t |
|
570 | 570 | if i == 3: |
|
571 | 571 | return p, q, v |
|
572 | 572 | if i == 4: |
|
573 | 573 | return t, p, v |
|
574 | 574 | if i == 5: |
|
575 | 575 | return v, p, q |
|
576 | 576 | |
|
577 | 577 | |
|
578 | 578 | def unique_color_generator(n=10000, saturation=0.10, lightness=0.95): |
|
579 | 579 | """ |
|
580 | 580 | Generator for getting n of evenly distributed colors using |
|
581 | 581 | hsv color and golden ratio. It always return same order of colors |
|
582 | 582 | |
|
583 | 583 | :param n: number of colors to generate |
|
584 | 584 | :param saturation: saturation of returned colors |
|
585 | 585 | :param lightness: lightness of returned colors |
|
586 | 586 | :returns: RGB tuple |
|
587 | 587 | """ |
|
588 | 588 | |
|
589 | 589 | golden_ratio = 0.618033988749895 |
|
590 | 590 | h = 0.22717784590367374 |
|
591 | 591 | |
|
592 | 592 | for _ in range(n): |
|
593 | 593 | h += golden_ratio |
|
594 | 594 | h %= 1 |
|
595 | 595 | HSV_tuple = [h, saturation, lightness] |
|
596 | 596 | RGB_tuple = hsv_to_rgb(*HSV_tuple) |
|
597 | 597 | yield [str(int(x * 256)) for x in RGB_tuple] |
|
598 | 598 | |
|
599 | 599 | |
|
600 | 600 | def color_hasher(n=10000, saturation=0.10, lightness=0.95): |
|
601 | 601 | """ |
|
602 | 602 | Returns a function which when called with an argument returns a unique |
|
603 | 603 | color for that argument, eg. |
|
604 | 604 | |
|
605 | 605 | :param n: number of colors to generate |
|
606 | 606 | :param saturation: saturation of returned colors |
|
607 | 607 | :param lightness: lightness of returned colors |
|
608 | 608 | :returns: css RGB string |
|
609 | 609 | |
|
610 | 610 | >>> color_hash = color_hasher() |
|
611 | 611 | >>> color_hash('hello') |
|
612 | 612 | 'rgb(34, 12, 59)' |
|
613 | 613 | >>> color_hash('hello') |
|
614 | 614 | 'rgb(34, 12, 59)' |
|
615 | 615 | >>> color_hash('other') |
|
616 | 616 | 'rgb(90, 224, 159)' |
|
617 | 617 | """ |
|
618 | 618 | |
|
619 | 619 | color_dict = {} |
|
620 | 620 | cgenerator = unique_color_generator( |
|
621 | 621 | saturation=saturation, lightness=lightness) |
|
622 | 622 | |
|
623 | 623 | def get_color_string(thing): |
|
624 | 624 | if thing in color_dict: |
|
625 | 625 | col = color_dict[thing] |
|
626 | 626 | else: |
|
627 | 627 | col = color_dict[thing] = next(cgenerator) |
|
628 | 628 | return "rgb(%s)" % (', '.join(col)) |
|
629 | 629 | |
|
630 | 630 | return get_color_string |
|
631 | 631 | |
|
632 | 632 | |
|
633 | 633 | def get_lexer_safe(mimetype=None, filepath=None): |
|
634 | 634 | """ |
|
635 | 635 | Tries to return a relevant pygments lexer using mimetype/filepath name, |
|
636 | 636 | defaulting to plain text if none could be found |
|
637 | 637 | """ |
|
638 | 638 | lexer = None |
|
639 | 639 | try: |
|
640 | 640 | if mimetype: |
|
641 | 641 | lexer = get_lexer_for_mimetype(mimetype) |
|
642 | 642 | if not lexer: |
|
643 | 643 | lexer = get_lexer_for_filename(filepath) |
|
644 | 644 | except pygments.util.ClassNotFound: |
|
645 | 645 | pass |
|
646 | 646 | |
|
647 | 647 | if not lexer: |
|
648 | 648 | lexer = get_lexer_by_name('text') |
|
649 | 649 | |
|
650 | 650 | return lexer |
|
651 | 651 | |
|
652 | 652 | |
|
653 | 653 | def get_lexer_for_filenode(filenode): |
|
654 | 654 | lexer = get_custom_lexer(filenode.extension) or filenode.lexer |
|
655 | 655 | return lexer |
|
656 | 656 | |
|
657 | 657 | |
|
658 | 658 | def pygmentize(filenode, **kwargs): |
|
659 | 659 | """ |
|
660 | 660 | pygmentize function using pygments |
|
661 | 661 | |
|
662 | 662 | :param filenode: |
|
663 | 663 | """ |
|
664 | 664 | lexer = get_lexer_for_filenode(filenode) |
|
665 | 665 | return literal(code_highlight(filenode.content, lexer, |
|
666 | 666 | CodeHtmlFormatter(**kwargs))) |
|
667 | 667 | |
|
668 | 668 | |
|
669 | 669 | def is_following_repo(repo_name, user_id): |
|
670 | 670 | from rhodecode.model.scm import ScmModel |
|
671 | 671 | return ScmModel().is_following_repo(repo_name, user_id) |
|
672 | 672 | |
|
673 | 673 | |
|
674 | 674 | class _Message(object): |
|
675 | 675 | """A message returned by ``Flash.pop_messages()``. |
|
676 | 676 | |
|
677 | 677 | Converting the message to a string returns the message text. Instances |
|
678 | 678 | also have the following attributes: |
|
679 | 679 | |
|
680 | 680 | * ``message``: the message text. |
|
681 | 681 | * ``category``: the category specified when the message was created. |
|
682 | 682 | """ |
|
683 | 683 | |
|
684 | 684 | def __init__(self, category, message, sub_data=None): |
|
685 | 685 | self.category = category |
|
686 | 686 | self.message = message |
|
687 | 687 | self.sub_data = sub_data or {} |
|
688 | 688 | |
|
689 | 689 | def __str__(self): |
|
690 | 690 | return self.message |
|
691 | 691 | |
|
692 | 692 | __unicode__ = __str__ |
|
693 | 693 | |
|
694 | 694 | def __html__(self): |
|
695 | 695 | return escape(safe_str(self.message)) |
|
696 | 696 | |
|
697 | 697 | |
|
698 | 698 | class Flash(object): |
|
699 | 699 | # List of allowed categories. If None, allow any category. |
|
700 | 700 | categories = ["warning", "notice", "error", "success"] |
|
701 | 701 | |
|
702 | 702 | # Default category if none is specified. |
|
703 | 703 | default_category = "notice" |
|
704 | 704 | |
|
705 | 705 | def __init__(self, session_key="flash", categories=None, |
|
706 | 706 | default_category=None): |
|
707 | 707 | """ |
|
708 | 708 | Instantiate a ``Flash`` object. |
|
709 | 709 | |
|
710 | 710 | ``session_key`` is the key to save the messages under in the user's |
|
711 | 711 | session. |
|
712 | 712 | |
|
713 | 713 | ``categories`` is an optional list which overrides the default list |
|
714 | 714 | of categories. |
|
715 | 715 | |
|
716 | 716 | ``default_category`` overrides the default category used for messages |
|
717 | 717 | when none is specified. |
|
718 | 718 | """ |
|
719 | 719 | self.session_key = session_key |
|
720 | 720 | if categories is not None: |
|
721 | 721 | self.categories = categories |
|
722 | 722 | if default_category is not None: |
|
723 | 723 | self.default_category = default_category |
|
724 | 724 | if self.categories and self.default_category not in self.categories: |
|
725 | 725 | raise ValueError( |
|
726 | 726 | "unrecognized default category %r" % (self.default_category,)) |
|
727 | 727 | |
|
728 | 728 | def pop_messages(self, session=None, request=None): |
|
729 | 729 | """ |
|
730 | 730 | Return all accumulated messages and delete them from the session. |
|
731 | 731 | |
|
732 | 732 | The return value is a list of ``Message`` objects. |
|
733 | 733 | """ |
|
734 | 734 | messages = [] |
|
735 | 735 | |
|
736 | 736 | if not session: |
|
737 | 737 | if not request: |
|
738 | 738 | request = get_current_request() |
|
739 | 739 | session = request.session |
|
740 | 740 | |
|
741 | 741 | # Pop the 'old' pylons flash messages. They are tuples of the form |
|
742 | 742 | # (category, message) |
|
743 | 743 | for cat, msg in session.pop(self.session_key, []): |
|
744 | 744 | messages.append(_Message(cat, msg)) |
|
745 | 745 | |
|
746 | 746 | # Pop the 'new' pyramid flash messages for each category as list |
|
747 | 747 | # of strings. |
|
748 | 748 | for cat in self.categories: |
|
749 | 749 | for msg in session.pop_flash(queue=cat): |
|
750 | 750 | sub_data = {} |
|
751 | 751 | if hasattr(msg, 'rsplit'): |
|
752 | 752 | flash_data = msg.rsplit('|DELIM|', 1) |
|
753 | 753 | org_message = flash_data[0] |
|
754 | 754 | if len(flash_data) > 1: |
|
755 | 755 | sub_data = json.loads(flash_data[1]) |
|
756 | 756 | else: |
|
757 | 757 | org_message = msg |
|
758 | 758 | |
|
759 | 759 | messages.append(_Message(cat, org_message, sub_data=sub_data)) |
|
760 | 760 | |
|
761 | 761 | # Map messages from the default queue to the 'notice' category. |
|
762 | 762 | for msg in session.pop_flash(): |
|
763 | 763 | messages.append(_Message('notice', msg)) |
|
764 | 764 | |
|
765 | 765 | session.save() |
|
766 | 766 | return messages |
|
767 | 767 | |
|
768 | 768 | def json_alerts(self, session=None, request=None): |
|
769 | 769 | payloads = [] |
|
770 | 770 | messages = flash.pop_messages(session=session, request=request) or [] |
|
771 | 771 | for message in messages: |
|
772 | 772 | payloads.append({ |
|
773 | 773 | 'message': { |
|
774 | 774 | 'message': '{}'.format(message.message), |
|
775 | 775 | 'level': message.category, |
|
776 | 776 | 'force': True, |
|
777 | 777 | 'subdata': message.sub_data |
|
778 | 778 | } |
|
779 | 779 | }) |
|
780 | 780 | return safe_str(json.dumps(payloads)) |
|
781 | 781 | |
|
782 | 782 | def __call__(self, message, category=None, ignore_duplicate=True, |
|
783 | 783 | session=None, request=None): |
|
784 | 784 | |
|
785 | 785 | if not session: |
|
786 | 786 | if not request: |
|
787 | 787 | request = get_current_request() |
|
788 | 788 | session = request.session |
|
789 | 789 | |
|
790 | 790 | session.flash( |
|
791 | 791 | message, queue=category, allow_duplicate=not ignore_duplicate) |
|
792 | 792 | |
|
793 | 793 | |
|
794 | 794 | flash = Flash() |
|
795 | 795 | |
|
796 | 796 | #============================================================================== |
|
797 | 797 | # SCM FILTERS available via h. |
|
798 | 798 | #============================================================================== |
|
799 | 799 | from rhodecode.lib.vcs.utils import author_name, author_email |
|
800 | 800 | from rhodecode.lib.utils2 import age, age_from_seconds |
|
801 | 801 | from rhodecode.model.db import User, ChangesetStatus |
|
802 | 802 | |
|
803 | 803 | |
|
804 | 804 | email = author_email |
|
805 | 805 | |
|
806 | 806 | |
|
807 | 807 | def capitalize(raw_text): |
|
808 | 808 | return raw_text.capitalize() |
|
809 | 809 | |
|
810 | 810 | |
|
811 | 811 | def short_id(long_id): |
|
812 | 812 | return long_id[:12] |
|
813 | 813 | |
|
814 | 814 | |
|
815 | 815 | def hide_credentials(url): |
|
816 | 816 | from rhodecode.lib.utils2 import credentials_filter |
|
817 | 817 | return credentials_filter(url) |
|
818 | 818 | |
|
819 | 819 | import zoneinfo |
|
820 | 820 | import tzlocal |
|
821 | 821 | local_timezone = tzlocal.get_localzone() |
|
822 | 822 | |
|
823 | 823 | |
|
824 | 824 | def get_timezone(datetime_iso, time_is_local=False): |
|
825 | 825 | tzinfo = '+00:00' |
|
826 | 826 | |
|
827 | 827 | # detect if we have a timezone info, otherwise, add it |
|
828 | 828 | if time_is_local and isinstance(datetime_iso, datetime) and not datetime_iso.tzinfo: |
|
829 | 829 | force_timezone = os.environ.get('RC_TIMEZONE', '') |
|
830 | 830 | if force_timezone: |
|
831 | 831 | force_timezone = zoneinfo.ZoneInfo(force_timezone) |
|
832 | 832 | timezone = force_timezone or local_timezone |
|
833 | 833 | |
|
834 | 834 | offset = datetime_iso.replace(tzinfo=timezone).strftime('%z') |
|
835 | 835 | tzinfo = '{}:{}'.format(offset[:-2], offset[-2:]) |
|
836 | 836 | return tzinfo |
|
837 | 837 | |
|
838 | 838 | |
|
839 | 839 | def age_component(datetime_iso, value=None, time_is_local=False, tooltip=True): |
|
840 | 840 | title = value or format_date(datetime_iso) |
|
841 | 841 | tzinfo = get_timezone(datetime_iso, time_is_local=time_is_local) |
|
842 | 842 | |
|
843 | 843 | return literal( |
|
844 | 844 | '<time class="timeago {cls}" title="{tt_title}" datetime="{dt}{tzinfo}">{title}</time>'.format( |
|
845 | 845 | cls='tooltip' if tooltip else '', |
|
846 | 846 | tt_title=('{title}{tzinfo}'.format(title=title, tzinfo=tzinfo)) if tooltip else '', |
|
847 | 847 | title=title, dt=datetime_iso, tzinfo=tzinfo |
|
848 | 848 | )) |
|
849 | 849 | |
|
850 | 850 | |
|
851 | 851 | def _shorten_commit_id(commit_id, commit_len=None): |
|
852 | 852 | if commit_len is None: |
|
853 | 853 | request = get_current_request() |
|
854 | 854 | commit_len = request.call_context.visual.show_sha_length |
|
855 | 855 | return commit_id[:commit_len] |
|
856 | 856 | |
|
857 | 857 | |
|
858 | 858 | def show_id(commit, show_idx=None, commit_len=None): |
|
859 | 859 | """ |
|
860 | 860 | Configurable function that shows ID |
|
861 | 861 | by default it's r123:fffeeefffeee |
|
862 | 862 | |
|
863 | 863 | :param commit: commit instance |
|
864 | 864 | """ |
|
865 | 865 | if show_idx is None: |
|
866 | 866 | request = get_current_request() |
|
867 | 867 | show_idx = request.call_context.visual.show_revision_number |
|
868 | 868 | |
|
869 | 869 | raw_id = _shorten_commit_id(commit.raw_id, commit_len=commit_len) |
|
870 | 870 | if show_idx: |
|
871 | 871 | return 'r%s:%s' % (commit.idx, raw_id) |
|
872 | 872 | else: |
|
873 | 873 | return '%s' % (raw_id, ) |
|
874 | 874 | |
|
875 | 875 | |
|
876 | 876 | def format_date(date): |
|
877 | 877 | """ |
|
878 | 878 | use a standardized formatting for dates used in RhodeCode |
|
879 | 879 | |
|
880 | 880 | :param date: date/datetime object |
|
881 | 881 | :return: formatted date |
|
882 | 882 | """ |
|
883 | 883 | |
|
884 | 884 | if date: |
|
885 | 885 | _fmt = "%a, %d %b %Y %H:%M:%S" |
|
886 | 886 | return safe_str(date.strftime(_fmt)) |
|
887 | 887 | |
|
888 | 888 | return "" |
|
889 | 889 | |
|
890 | 890 | |
|
891 | 891 | class _RepoChecker(object): |
|
892 | 892 | |
|
893 | 893 | def __init__(self, backend_alias): |
|
894 | 894 | self._backend_alias = backend_alias |
|
895 | 895 | |
|
896 | 896 | def __call__(self, repository): |
|
897 | 897 | if hasattr(repository, 'alias'): |
|
898 | 898 | _type = repository.alias |
|
899 | 899 | elif hasattr(repository, 'repo_type'): |
|
900 | 900 | _type = repository.repo_type |
|
901 | 901 | else: |
|
902 | 902 | _type = repository |
|
903 | 903 | return _type == self._backend_alias |
|
904 | 904 | |
|
905 | 905 | |
|
906 | 906 | is_git = _RepoChecker('git') |
|
907 | 907 | is_hg = _RepoChecker('hg') |
|
908 | 908 | is_svn = _RepoChecker('svn') |
|
909 | 909 | |
|
910 | 910 | |
|
911 | 911 | def get_repo_type_by_name(repo_name): |
|
912 | 912 | repo = Repository.get_by_repo_name(repo_name) |
|
913 | 913 | if repo: |
|
914 | 914 | return repo.repo_type |
|
915 | 915 | |
|
916 | 916 | |
|
917 | 917 | def is_svn_without_proxy(repository): |
|
918 | 918 | if is_svn(repository): |
|
919 | 919 | from rhodecode.model.settings import VcsSettingsModel |
|
920 | 920 | conf = VcsSettingsModel().get_ui_settings_as_config_obj() |
|
921 | 921 | return not str2bool(conf.get('vcs_svn_proxy', 'http_requests_enabled')) |
|
922 | 922 | return False |
|
923 | 923 | |
|
924 | 924 | |
|
925 | 925 | def discover_user(author): |
|
926 | 926 | """ |
|
927 | 927 | Tries to discover RhodeCode User based on the author string. Author string |
|
928 | 928 | is typically `FirstName LastName <email@address.com>` |
|
929 | 929 | """ |
|
930 | 930 | |
|
931 | 931 | # if author is already an instance use it for extraction |
|
932 | 932 | if isinstance(author, User): |
|
933 | 933 | return author |
|
934 | 934 | |
|
935 | 935 | # Valid email in the attribute passed, see if they're in the system |
|
936 | 936 | _email = author_email(author) |
|
937 | 937 | if _email != '': |
|
938 | 938 | user = User.get_by_email(_email, case_insensitive=True, cache=True) |
|
939 | 939 | if user is not None: |
|
940 | 940 | return user |
|
941 | 941 | |
|
942 | 942 | # Maybe it's a username, we try to extract it and fetch by username ? |
|
943 | 943 | _author = author_name(author) |
|
944 | 944 | user = User.get_by_username(_author, case_insensitive=True, cache=True) |
|
945 | 945 | if user is not None: |
|
946 | 946 | return user |
|
947 | 947 | |
|
948 | 948 | return None |
|
949 | 949 | |
|
950 | 950 | |
|
951 | 951 | def email_or_none(author): |
|
952 | 952 | # extract email from the commit string |
|
953 | 953 | _email = author_email(author) |
|
954 | 954 | |
|
955 | 955 | # If we have an email, use it, otherwise |
|
956 | 956 | # see if it contains a username we can get an email from |
|
957 | 957 | if _email != '': |
|
958 | 958 | return _email |
|
959 | 959 | else: |
|
960 | 960 | user = User.get_by_username( |
|
961 | 961 | author_name(author), case_insensitive=True, cache=True) |
|
962 | 962 | |
|
963 | 963 | if user is not None: |
|
964 | 964 | return user.email |
|
965 | 965 | |
|
966 | 966 | # No valid email, not a valid user in the system, none! |
|
967 | 967 | return None |
|
968 | 968 | |
|
969 | 969 | |
|
970 | 970 | def link_to_user(author, length=0, **kwargs): |
|
971 | 971 | user = discover_user(author) |
|
972 | 972 | # user can be None, but if we have it already it means we can re-use it |
|
973 | 973 | # in the person() function, so we save 1 intensive-query |
|
974 | 974 | if user: |
|
975 | 975 | author = user |
|
976 | 976 | |
|
977 | 977 | display_person = person(author, 'username_or_name_or_email') |
|
978 | 978 | if length: |
|
979 | 979 | display_person = shorter(display_person, length) |
|
980 | 980 | |
|
981 | 981 | if user and user.username != user.DEFAULT_USER: |
|
982 | 982 | return link_to( |
|
983 | 983 | escape(display_person), |
|
984 | 984 | route_path('user_profile', username=user.username), |
|
985 | 985 | **kwargs) |
|
986 | 986 | else: |
|
987 | 987 | return escape(display_person) |
|
988 | 988 | |
|
989 | 989 | |
|
990 | 990 | def link_to_group(users_group_name, **kwargs): |
|
991 | 991 | return link_to( |
|
992 | 992 | escape(users_group_name), |
|
993 | 993 | route_path('user_group_profile', user_group_name=users_group_name), |
|
994 | 994 | **kwargs) |
|
995 | 995 | |
|
996 | 996 | |
|
997 | 997 | def person(author, show_attr="username_and_name"): |
|
998 | 998 | user = discover_user(author) |
|
999 | 999 | if user: |
|
1000 | 1000 | return getattr(user, show_attr) |
|
1001 | 1001 | else: |
|
1002 | 1002 | _author = author_name(author) |
|
1003 | 1003 | _email = email(author) |
|
1004 | 1004 | return _author or _email |
|
1005 | 1005 | |
|
1006 | 1006 | |
|
1007 | 1007 | def author_string(email): |
|
1008 | 1008 | if email: |
|
1009 | 1009 | user = User.get_by_email(email, case_insensitive=True, cache=True) |
|
1010 | 1010 | if user: |
|
1011 | 1011 | if user.first_name or user.last_name: |
|
1012 | 1012 | return '%s %s <%s>' % ( |
|
1013 | 1013 | user.first_name, user.last_name, email) |
|
1014 | 1014 | else: |
|
1015 | 1015 | return email |
|
1016 | 1016 | else: |
|
1017 | 1017 | return email |
|
1018 | 1018 | else: |
|
1019 | 1019 | return None |
|
1020 | 1020 | |
|
1021 | 1021 | |
|
1022 | 1022 | def person_by_id(id_, show_attr="username_and_name"): |
|
1023 | 1023 | # attr to return from fetched user |
|
1024 | 1024 | def person_getter(usr): |
|
1025 | 1025 | return getattr(usr, show_attr) |
|
1026 | 1026 | |
|
1027 | 1027 | #maybe it's an ID ? |
|
1028 | 1028 | if str(id_).isdigit() or isinstance(id_, int): |
|
1029 | 1029 | id_ = int(id_) |
|
1030 | 1030 | user = User.get(id_) |
|
1031 | 1031 | if user is not None: |
|
1032 | 1032 | return person_getter(user) |
|
1033 | 1033 | return id_ |
|
1034 | 1034 | |
|
1035 | 1035 | |
|
1036 | 1036 | def gravatar_with_user(request, author, show_disabled=False, tooltip=False): |
|
1037 | 1037 | _render = request.get_partial_renderer('rhodecode:templates/base/base.mako') |
|
1038 | 1038 | return _render('gravatar_with_user', author, show_disabled=show_disabled, tooltip=tooltip) |
|
1039 | 1039 | |
|
1040 | 1040 | |
|
1041 | 1041 | tags_paterns = OrderedDict(( |
|
1042 | 1042 | ('lang', (re.compile(r'\[(lang|language)\ \=\>\ *([a-zA-Z\-\/\#\+\.]*)\]'), |
|
1043 | 1043 | '<div class="metatag" tag="lang">\\2</div>')), |
|
1044 | 1044 | |
|
1045 | 1045 | ('see', (re.compile(r'\[see\ \=\>\ *([a-zA-Z0-9\/\=\?\&\ \:\/\.\-]*)\]'), |
|
1046 | 1046 | '<div class="metatag" tag="see">see: \\1 </div>')), |
|
1047 | 1047 | |
|
1048 | 1048 | ('url', (re.compile(r'\[url\ \=\>\ \[([a-zA-Z0-9\ \.\-\_]+)\]\((http://|https://|/)(.*?)\)\]'), |
|
1049 | 1049 | '<div class="metatag" tag="url"> <a href="\\2\\3">\\1</a> </div>')), |
|
1050 | 1050 | |
|
1051 | 1051 | ('license', (re.compile(r'\[license\ \=\>\ *([a-zA-Z0-9\/\=\?\&\ \:\/\.\-]*)\]'), |
|
1052 | 1052 | '<div class="metatag" tag="license"><a href="http:\/\/www.opensource.org/licenses/\\1">\\1</a></div>')), |
|
1053 | 1053 | |
|
1054 | 1054 | ('ref', (re.compile(r'\[(requires|recommends|conflicts|base)\ \=\>\ *([a-zA-Z0-9\-\/]*)\]'), |
|
1055 | 1055 | '<div class="metatag" tag="ref \\1">\\1: <a href="/\\2">\\2</a></div>')), |
|
1056 | 1056 | |
|
1057 | 1057 | ('state', (re.compile(r'\[(stable|featured|stale|dead|dev|deprecated)\]'), |
|
1058 | 1058 | '<div class="metatag" tag="state \\1">\\1</div>')), |
|
1059 | 1059 | |
|
1060 | 1060 | # label in grey |
|
1061 | 1061 | ('label', (re.compile(r'\[([a-z]+)\]'), |
|
1062 | 1062 | '<div class="metatag" tag="label">\\1</div>')), |
|
1063 | 1063 | |
|
1064 | 1064 | # generic catch all in grey |
|
1065 | 1065 | ('generic', (re.compile(r'\[([a-zA-Z0-9\.\-\_]+)\]'), |
|
1066 | 1066 | '<div class="metatag" tag="generic">\\1</div>')), |
|
1067 | 1067 | )) |
|
1068 | 1068 | |
|
1069 | 1069 | |
|
1070 | 1070 | def extract_metatags(value): |
|
1071 | 1071 | """ |
|
1072 | 1072 | Extract supported meta-tags from given text value |
|
1073 | 1073 | """ |
|
1074 | 1074 | tags = [] |
|
1075 | 1075 | if not value: |
|
1076 | 1076 | return tags, '' |
|
1077 | 1077 | |
|
1078 | 1078 | for key, val in list(tags_paterns.items()): |
|
1079 | 1079 | pat, replace_html = val |
|
1080 | 1080 | tags.extend([(key, x.group()) for x in pat.finditer(value)]) |
|
1081 | 1081 | value = pat.sub('', value) |
|
1082 | 1082 | |
|
1083 | 1083 | return tags, value |
|
1084 | 1084 | |
|
1085 | 1085 | |
|
1086 | 1086 | def style_metatag(tag_type, value): |
|
1087 | 1087 | """ |
|
1088 | 1088 | converts tags from value into html equivalent |
|
1089 | 1089 | """ |
|
1090 | 1090 | if not value: |
|
1091 | 1091 | return '' |
|
1092 | 1092 | |
|
1093 | 1093 | html_value = value |
|
1094 | 1094 | tag_data = tags_paterns.get(tag_type) |
|
1095 | 1095 | if tag_data: |
|
1096 | 1096 | pat, replace_html = tag_data |
|
1097 | 1097 | # convert to plain `str` instead of a markup tag to be used in |
|
1098 | 1098 | # regex expressions. safe_str doesn't work here |
|
1099 | 1099 | html_value = pat.sub(replace_html, value) |
|
1100 | 1100 | |
|
1101 | 1101 | return html_value |
|
1102 | 1102 | |
|
1103 | 1103 | |
|
1104 | 1104 | def bool2icon(value, show_at_false=True): |
|
1105 | 1105 | """ |
|
1106 | 1106 | Returns boolean value of a given value, represented as html element with |
|
1107 | 1107 | classes that will represent icons |
|
1108 | 1108 | |
|
1109 | 1109 | :param value: given value to convert to html node |
|
1110 | 1110 | """ |
|
1111 | 1111 | |
|
1112 | 1112 | if value: # does bool conversion |
|
1113 | 1113 | return HTML.tag('i', class_="icon-true", title='True') |
|
1114 | 1114 | else: # not true as bool |
|
1115 | 1115 | if show_at_false: |
|
1116 | 1116 | return HTML.tag('i', class_="icon-false", title='False') |
|
1117 | 1117 | return HTML.tag('i') |
|
1118 | 1118 | |
|
1119 | 1119 | |
|
1120 | 1120 | def b64(inp): |
|
1121 | 1121 | return base64.b64encode(safe_bytes(inp)) |
|
1122 | 1122 | |
|
1123 | 1123 | #============================================================================== |
|
1124 | 1124 | # PERMS |
|
1125 | 1125 | #============================================================================== |
|
1126 | 1126 | from rhodecode.lib.auth import ( |
|
1127 | 1127 | HasPermissionAny, HasPermissionAll, |
|
1128 | 1128 | HasRepoPermissionAny, HasRepoPermissionAll, HasRepoGroupPermissionAll, |
|
1129 | 1129 | HasRepoGroupPermissionAny, HasRepoPermissionAnyApi, get_csrf_token, |
|
1130 | 1130 | csrf_token_key, AuthUser) |
|
1131 | 1131 | |
|
1132 | 1132 | |
|
1133 | 1133 | #============================================================================== |
|
1134 | 1134 | # GRAVATAR URL |
|
1135 | 1135 | #============================================================================== |
|
1136 | 1136 | class InitialsGravatar(object): |
|
1137 | 1137 | def __init__(self, email_address, first_name, last_name, size=30, |
|
1138 | 1138 | background=None, text_color='#fff'): |
|
1139 | 1139 | self.size = size |
|
1140 | 1140 | self.first_name = first_name |
|
1141 | 1141 | self.last_name = last_name |
|
1142 | 1142 | self.email_address = email_address |
|
1143 | 1143 | self.background = background or self.str2color(email_address) |
|
1144 | 1144 | self.text_color = text_color |
|
1145 | 1145 | |
|
1146 | 1146 | def get_color_bank(self): |
|
1147 | 1147 | """ |
|
1148 | 1148 | returns a predefined list of colors that gravatars can use. |
|
1149 | 1149 | Those are randomized distinct colors that guarantee readability and |
|
1150 | 1150 | uniqueness. |
|
1151 | 1151 | |
|
1152 | 1152 | generated with: http://phrogz.net/css/distinct-colors.html |
|
1153 | 1153 | """ |
|
1154 | 1154 | return [ |
|
1155 | 1155 | '#bf3030', '#a67f53', '#00ff00', '#5989b3', '#392040', '#d90000', |
|
1156 | 1156 | '#402910', '#204020', '#79baf2', '#a700b3', '#bf6060', '#7f5320', |
|
1157 | 1157 | '#008000', '#003059', '#ee00ff', '#ff0000', '#8c4b00', '#007300', |
|
1158 | 1158 | '#005fb3', '#de73e6', '#ff4040', '#ffaa00', '#3df255', '#203140', |
|
1159 | 1159 | '#47004d', '#591616', '#664400', '#59b365', '#0d2133', '#83008c', |
|
1160 | 1160 | '#592d2d', '#bf9f60', '#73e682', '#1d3f73', '#73006b', '#402020', |
|
1161 | 1161 | '#b2862d', '#397341', '#597db3', '#e600d6', '#a60000', '#736039', |
|
1162 | 1162 | '#00b318', '#79aaf2', '#330d30', '#ff8080', '#403010', '#16591f', |
|
1163 | 1163 | '#002459', '#8c4688', '#e50000', '#ffbf40', '#00732e', '#102340', |
|
1164 | 1164 | '#bf60ac', '#8c4646', '#cc8800', '#00a642', '#1d3473', '#b32d98', |
|
1165 | 1165 | '#660e00', '#ffd580', '#80ffb2', '#7391e6', '#733967', '#d97b6c', |
|
1166 | 1166 | '#8c5e00', '#59b389', '#3967e6', '#590047', '#73281d', '#665200', |
|
1167 | 1167 | '#00e67a', '#2d50b3', '#8c2377', '#734139', '#b2982d', '#16593a', |
|
1168 | 1168 | '#001859', '#ff00aa', '#a65e53', '#ffcc00', '#0d3321', '#2d3959', |
|
1169 | 1169 | '#731d56', '#401610', '#4c3d00', '#468c6c', '#002ca6', '#d936a3', |
|
1170 | 1170 | '#d94c36', '#403920', '#36d9a3', '#0d1733', '#592d4a', '#993626', |
|
1171 | 1171 | '#cca300', '#00734d', '#46598c', '#8c005e', '#7f1100', '#8c7000', |
|
1172 | 1172 | '#00a66f', '#7382e6', '#b32d74', '#d9896c', '#ffe680', '#1d7362', |
|
1173 | 1173 | '#364cd9', '#73003d', '#d93a00', '#998a4d', '#59b3a1', '#5965b3', |
|
1174 | 1174 | '#e5007a', '#73341d', '#665f00', '#00b38f', '#0018b3', '#59163a', |
|
1175 | 1175 | '#b2502d', '#bfb960', '#00ffcc', '#23318c', '#a6537f', '#734939', |
|
1176 | 1176 | '#b2a700', '#104036', '#3d3df2', '#402031', '#e56739', '#736f39', |
|
1177 | 1177 | '#79f2ea', '#000059', '#401029', '#4c1400', '#ffee00', '#005953', |
|
1178 | 1178 | '#101040', '#990052', '#402820', '#403d10', '#00ffee', '#0000d9', |
|
1179 | 1179 | '#ff80c4', '#a66953', '#eeff00', '#00ccbe', '#8080ff', '#e673a1', |
|
1180 | 1180 | '#a62c00', '#474d00', '#1a3331', '#46468c', '#733950', '#662900', |
|
1181 | 1181 | '#858c23', '#238c85', '#0f0073', '#b20047', '#d9986c', '#becc00', |
|
1182 | 1182 | '#396f73', '#281d73', '#ff0066', '#ff6600', '#dee673', '#59adb3', |
|
1183 | 1183 | '#6559b3', '#590024', '#b2622d', '#98b32d', '#36ced9', '#332d59', |
|
1184 | 1184 | '#40001a', '#733f1d', '#526600', '#005359', '#242040', '#bf6079', |
|
1185 | 1185 | '#735039', '#cef23d', '#007780', '#5630bf', '#66001b', '#b24700', |
|
1186 | 1186 | '#acbf60', '#1d6273', '#25008c', '#731d34', '#a67453', '#50592d', |
|
1187 | 1187 | '#00ccff', '#6600ff', '#ff0044', '#4c1f00', '#8a994d', '#79daf2', |
|
1188 | 1188 | '#a173e6', '#d93662', '#402310', '#aaff00', '#2d98b3', '#8c40ff', |
|
1189 | 1189 | '#592d39', '#ff8c40', '#354020', '#103640', '#1a0040', '#331a20', |
|
1190 | 1190 | '#331400', '#334d00', '#1d5673', '#583973', '#7f0022', '#4c3626', |
|
1191 | 1191 | '#88cc00', '#36a3d9', '#3d0073', '#d9364c', '#33241a', '#698c23', |
|
1192 | 1192 | '#5995b3', '#300059', '#e57382', '#7f3300', '#366600', '#00aaff', |
|
1193 | 1193 | '#3a1659', '#733941', '#663600', '#74b32d', '#003c59', '#7f53a6', |
|
1194 | 1194 | '#73000f', '#ff8800', '#baf279', '#79caf2', '#291040', '#a6293a', |
|
1195 | 1195 | '#b2742d', '#587339', '#0077b3', '#632699', '#400009', '#d9a66c', |
|
1196 | 1196 | '#294010', '#2d4a59', '#aa00ff', '#4c131b', '#b25f00', '#5ce600', |
|
1197 | 1197 | '#267399', '#a336d9', '#990014', '#664e33', '#86bf60', '#0088ff', |
|
1198 | 1198 | '#7700b3', '#593a16', '#073300', '#1d4b73', '#ac60bf', '#e59539', |
|
1199 | 1199 | '#4f8c46', '#368dd9', '#5c0073' |
|
1200 | 1200 | ] |
|
1201 | 1201 | |
|
1202 | 1202 | def rgb_to_hex_color(self, rgb_tuple): |
|
1203 | 1203 | """ |
|
1204 | 1204 | Converts an rgb_tuple passed to an hex color. |
|
1205 | 1205 | |
|
1206 | 1206 | :param rgb_tuple: tuple with 3 ints represents rgb color space |
|
1207 | 1207 | """ |
|
1208 | 1208 | return '#' + ("".join(map(chr, rgb_tuple)).encode('hex')) |
|
1209 | 1209 | |
|
1210 | 1210 | def email_to_int_list(self, email_str): |
|
1211 | 1211 | """ |
|
1212 | 1212 | Get every byte of the hex digest value of email and turn it to integer. |
|
1213 | 1213 | It's going to be always between 0-255 |
|
1214 | 1214 | """ |
|
1215 | 1215 | digest = md5_safe(email_str.lower()) |
|
1216 | 1216 | return [int(digest[i * 2:i * 2 + 2], 16) for i in range(16)] |
|
1217 | 1217 | |
|
1218 | 1218 | def pick_color_bank_index(self, email_str, color_bank): |
|
1219 | 1219 | return self.email_to_int_list(email_str)[0] % len(color_bank) |
|
1220 | 1220 | |
|
1221 | 1221 | def str2color(self, email_str): |
|
1222 | 1222 | """ |
|
1223 | 1223 | Tries to map in a stable algorithm an email to color |
|
1224 | 1224 | |
|
1225 | 1225 | :param email_str: |
|
1226 | 1226 | """ |
|
1227 | 1227 | color_bank = self.get_color_bank() |
|
1228 | 1228 | # pick position (module it's length so we always find it in the |
|
1229 | 1229 | # bank even if it's smaller than 256 values |
|
1230 | 1230 | pos = self.pick_color_bank_index(email_str, color_bank) |
|
1231 | 1231 | return color_bank[pos] |
|
1232 | 1232 | |
|
1233 | 1233 | def normalize_email(self, email_address): |
|
1234 | 1234 | # default host used to fill in the fake/missing email |
|
1235 | 1235 | default_host = 'localhost' |
|
1236 | 1236 | |
|
1237 | 1237 | if not email_address: |
|
1238 | 1238 | email_address = f'{User.DEFAULT_USER}@{default_host}' |
|
1239 | 1239 | |
|
1240 | 1240 | email_address = safe_str(email_address) |
|
1241 | 1241 | |
|
1242 | 1242 | if '@' not in email_address: |
|
1243 | 1243 | email_address = f'{email_address}@{default_host}' |
|
1244 | 1244 | |
|
1245 | 1245 | if email_address.endswith('@'): |
|
1246 | 1246 | email_address = f'{email_address}{default_host}' |
|
1247 | 1247 | |
|
1248 | 1248 | email_address = convert_special_chars(email_address) |
|
1249 | 1249 | |
|
1250 | 1250 | return email_address |
|
1251 | 1251 | |
|
1252 | 1252 | def get_initials(self): |
|
1253 | 1253 | """ |
|
1254 | 1254 | Returns 2 letter initials calculated based on the input. |
|
1255 | 1255 | The algorithm picks first given email address, and takes first letter |
|
1256 | 1256 | of part before @, and then the first letter of server name. In case |
|
1257 | 1257 | the part before @ is in a format of `somestring.somestring2` it replaces |
|
1258 | 1258 | the server letter with first letter of somestring2 |
|
1259 | 1259 | |
|
1260 | 1260 | In case function was initialized with both first and lastname, this |
|
1261 | 1261 | overrides the extraction from email by first letter of the first and |
|
1262 | 1262 | last name. We add special logic to that functionality, In case Full name |
|
1263 | 1263 | is compound, like Guido Von Rossum, we use last part of the last name |
|
1264 | 1264 | (Von Rossum) picking `R`. |
|
1265 | 1265 | |
|
1266 | 1266 | Function also normalizes the non-ascii characters to they ascii |
|
1267 | 1267 | representation, eg Δ => A |
|
1268 | 1268 | """ |
|
1269 | 1269 | # replace non-ascii to ascii |
|
1270 | 1270 | first_name = convert_special_chars(self.first_name) |
|
1271 | 1271 | last_name = convert_special_chars(self.last_name) |
|
1272 | 1272 | # multi word last names, Guido Von Rossum, we take the last part only |
|
1273 | 1273 | last_name = last_name.split(' ', 1)[-1] |
|
1274 | 1274 | |
|
1275 | 1275 | # do NFKD encoding, and also make sure email has proper format |
|
1276 | 1276 | email_address = self.normalize_email(self.email_address) |
|
1277 | 1277 | |
|
1278 | 1278 | # first push the email initials |
|
1279 | 1279 | prefix, server = email_address.split('@', 1) |
|
1280 | 1280 | |
|
1281 | 1281 | # check if prefix is maybe a 'first_name.last_name' syntax |
|
1282 | 1282 | _dot_split = prefix.rsplit('.', 1) |
|
1283 | 1283 | if len(_dot_split) == 2 and _dot_split[1]: |
|
1284 | 1284 | initials = [_dot_split[0][0], _dot_split[1][0]] |
|
1285 | 1285 | else: |
|
1286 | 1286 | initials = [prefix[0], server[0]] |
|
1287 | 1287 | |
|
1288 | 1288 | # get first letter of first and last names to create initials |
|
1289 | 1289 | fn_letter = (first_name or " ")[0].strip() |
|
1290 | 1290 | ln_letter = (last_name or " ")[0].strip() |
|
1291 | 1291 | |
|
1292 | 1292 | if fn_letter: |
|
1293 | 1293 | initials[0] = fn_letter |
|
1294 | 1294 | |
|
1295 | 1295 | if ln_letter: |
|
1296 | 1296 | initials[1] = ln_letter |
|
1297 | 1297 | |
|
1298 | 1298 | return ''.join(initials).upper() |
|
1299 | 1299 | |
|
1300 | 1300 | def get_img_data_by_type(self, font_family, img_type): |
|
1301 | 1301 | default_user = """ |
|
1302 | 1302 | <svg xmlns="http://www.w3.org/2000/svg" |
|
1303 | 1303 | version="1.1" x="0px" y="0px" width="{size}" height="{size}" |
|
1304 | 1304 | viewBox="-15 -10 439.165 429.164" |
|
1305 | 1305 | |
|
1306 | 1306 | xml:space="preserve" |
|
1307 | 1307 | font-family="{font_family} |
|
1308 | 1308 | style="background:{background};" > |
|
1309 | 1309 | |
|
1310 | 1310 | <path d="M204.583,216.671c50.664,0,91.74-48.075, |
|
1311 | 1311 | 91.74-107.378c0-82.237-41.074-107.377-91.74-107.377 |
|
1312 | 1312 | c-50.668,0-91.74,25.14-91.74,107.377C112.844, |
|
1313 | 1313 | 168.596,153.916,216.671, |
|
1314 | 1314 | 204.583,216.671z" fill="{text_color}"/> |
|
1315 | 1315 | <path d="M407.164,374.717L360.88, |
|
1316 | 1316 | 270.454c-2.117-4.771-5.836-8.728-10.465-11.138l-71.83-37.392 |
|
1317 | 1317 | c-1.584-0.823-3.502-0.663-4.926,0.415c-20.316, |
|
1318 | 1318 | 15.366-44.203,23.488-69.076,23.488c-24.877, |
|
1319 | 1319 | 0-48.762-8.122-69.078-23.488 |
|
1320 | 1320 | c-1.428-1.078-3.346-1.238-4.93-0.415L58.75, |
|
1321 | 1321 | 259.316c-4.631,2.41-8.346,6.365-10.465,11.138L2.001,374.717 |
|
1322 | 1322 | c-3.191,7.188-2.537,15.412,1.75,22.005c4.285, |
|
1323 | 1323 | 6.592,11.537,10.526,19.4,10.526h362.861c7.863,0,15.117-3.936, |
|
1324 | 1324 | 19.402-10.527 C409.699,390.129, |
|
1325 | 1325 | 410.355,381.902,407.164,374.717z" fill="{text_color}"/> |
|
1326 | 1326 | </svg>""".format( |
|
1327 | 1327 | size=self.size, |
|
1328 | 1328 | background='#979797', # @grey4 |
|
1329 | 1329 | text_color=self.text_color, |
|
1330 | 1330 | font_family=font_family) |
|
1331 | 1331 | |
|
1332 | 1332 | return { |
|
1333 | 1333 | "default_user": default_user |
|
1334 | 1334 | }[img_type] |
|
1335 | 1335 | |
|
1336 | 1336 | def get_img_data(self, svg_type=None): |
|
1337 | 1337 | """ |
|
1338 | 1338 | generates the svg metadata for image |
|
1339 | 1339 | """ |
|
1340 | 1340 | fonts = [ |
|
1341 | 1341 | '-apple-system', |
|
1342 | 1342 | 'BlinkMacSystemFont', |
|
1343 | 1343 | 'Segoe UI', |
|
1344 | 1344 | 'Roboto', |
|
1345 | 1345 | 'Oxygen-Sans', |
|
1346 | 1346 | 'Ubuntu', |
|
1347 | 1347 | 'Cantarell', |
|
1348 | 1348 | 'Helvetica Neue', |
|
1349 | 1349 | 'sans-serif' |
|
1350 | 1350 | ] |
|
1351 | 1351 | font_family = ','.join(fonts) |
|
1352 | 1352 | if svg_type: |
|
1353 | 1353 | return self.get_img_data_by_type(font_family, svg_type) |
|
1354 | 1354 | |
|
1355 | 1355 | initials = self.get_initials() |
|
1356 | 1356 | img_data = """ |
|
1357 | 1357 | <svg xmlns="http://www.w3.org/2000/svg" pointer-events="none" |
|
1358 | 1358 | width="{size}" height="{size}" |
|
1359 | 1359 | style="width: 100%; height: 100%; background-color: {background}" |
|
1360 | 1360 | viewBox="0 0 {size} {size}"> |
|
1361 | 1361 | <text text-anchor="middle" y="50%" x="50%" dy="0.35em" |
|
1362 | 1362 | pointer-events="auto" fill="{text_color}" |
|
1363 | 1363 | font-family="{font_family}" |
|
1364 | 1364 | style="font-weight: 400; font-size: {f_size}px;">{text} |
|
1365 | 1365 | </text> |
|
1366 | 1366 | </svg>""".format( |
|
1367 | 1367 | size=self.size, |
|
1368 | 1368 | f_size=self.size/2.05, # scale the text inside the box nicely |
|
1369 | 1369 | background=self.background, |
|
1370 | 1370 | text_color=self.text_color, |
|
1371 | 1371 | text=initials.upper(), |
|
1372 | 1372 | font_family=font_family) |
|
1373 | 1373 | |
|
1374 | 1374 | return img_data |
|
1375 | 1375 | |
|
1376 | 1376 | def generate_svg(self, svg_type=None): |
|
1377 | 1377 | img_data = safe_bytes(self.get_img_data(svg_type)) |
|
1378 | 1378 | return "data:image/svg+xml;base64,%s" % safe_str(base64.b64encode(img_data)) |
|
1379 | 1379 | |
|
1380 | 1380 | |
|
1381 | 1381 | def initials_gravatar(request, email_address, first_name, last_name, size=30, store_on_disk=False): |
|
1382 | 1382 | |
|
1383 | 1383 | svg_type = None |
|
1384 | 1384 | if email_address == User.DEFAULT_USER_EMAIL: |
|
1385 | 1385 | svg_type = 'default_user' |
|
1386 | 1386 | |
|
1387 | 1387 | klass = InitialsGravatar(email_address, first_name, last_name, size) |
|
1388 | 1388 | |
|
1389 | 1389 | if store_on_disk: |
|
1390 | 1390 | from rhodecode.apps.file_store import utils as store_utils |
|
1391 | 1391 | from rhodecode.apps.file_store.exceptions import FileNotAllowedException, \ |
|
1392 | 1392 | FileOverSizeException |
|
1393 | 1393 | from rhodecode.model.db import Session |
|
1394 | 1394 | |
|
1395 | 1395 | image_key = md5_safe(email_address.lower() |
|
1396 | 1396 | + first_name.lower() + last_name.lower()) |
|
1397 | 1397 | |
|
1398 | 1398 | storage = store_utils.get_file_storage(request.registry.settings) |
|
1399 | 1399 | filename = '{}.svg'.format(image_key) |
|
1400 | 1400 | subdir = 'gravatars' |
|
1401 | 1401 | # since final name has a counter, we apply the 0 |
|
1402 | 1402 | uid = storage.apply_counter(0, store_utils.uid_filename(filename, randomized=False)) |
|
1403 | 1403 | store_uid = os.path.join(subdir, uid) |
|
1404 | 1404 | |
|
1405 | 1405 | db_entry = FileStore.get_by_store_uid(store_uid) |
|
1406 | 1406 | if db_entry: |
|
1407 | 1407 | return request.route_path('download_file', fid=store_uid) |
|
1408 | 1408 | |
|
1409 | 1409 | img_data = klass.get_img_data(svg_type=svg_type) |
|
1410 | 1410 | img_file = store_utils.bytes_to_file_obj(img_data) |
|
1411 | 1411 | |
|
1412 | 1412 | try: |
|
1413 | 1413 | store_uid, metadata = storage.save_file( |
|
1414 | 1414 | img_file, filename, directory=subdir, |
|
1415 | 1415 | extensions=['.svg'], randomized_name=False) |
|
1416 | 1416 | except (FileNotAllowedException, FileOverSizeException): |
|
1417 | 1417 | raise |
|
1418 | 1418 | |
|
1419 | 1419 | try: |
|
1420 | 1420 | entry = FileStore.create( |
|
1421 | 1421 | file_uid=store_uid, filename=metadata["filename"], |
|
1422 | 1422 | file_hash=metadata["sha256"], file_size=metadata["size"], |
|
1423 | 1423 | file_display_name=filename, |
|
1424 | 1424 | file_description=f'user gravatar `{safe_str(filename)}`', |
|
1425 | 1425 | hidden=True, check_acl=False, user_id=1 |
|
1426 | 1426 | ) |
|
1427 | 1427 | Session().add(entry) |
|
1428 | 1428 | Session().commit() |
|
1429 | 1429 | log.debug('Stored upload in DB as %s', entry) |
|
1430 | 1430 | except Exception: |
|
1431 | 1431 | raise |
|
1432 | 1432 | |
|
1433 | 1433 | return request.route_path('download_file', fid=store_uid) |
|
1434 | 1434 | |
|
1435 | 1435 | else: |
|
1436 | 1436 | return klass.generate_svg(svg_type=svg_type) |
|
1437 | 1437 | |
|
1438 | 1438 | |
|
1439 | 1439 | def gravatar_external(request, gravatar_url_tmpl, email_address, size=30): |
|
1440 | 1440 | return safe_str(gravatar_url_tmpl)\ |
|
1441 | 1441 | .replace('{email}', email_address) \ |
|
1442 | 1442 | .replace('{md5email}', md5_safe(email_address.lower())) \ |
|
1443 | 1443 | .replace('{netloc}', request.host) \ |
|
1444 | 1444 | .replace('{scheme}', request.scheme) \ |
|
1445 | 1445 | .replace('{size}', safe_str(size)) |
|
1446 | 1446 | |
|
1447 | 1447 | |
|
1448 | 1448 | def gravatar_url(email_address, size=30, request=None): |
|
1449 | 1449 | request = request or get_current_request() |
|
1450 | 1450 | _use_gravatar = request.call_context.visual.use_gravatar |
|
1451 | 1451 | |
|
1452 | 1452 | email_address = email_address or User.DEFAULT_USER_EMAIL |
|
1453 | 1453 | if isinstance(email_address, str): |
|
1454 | 1454 | # hashlib crashes on unicode items |
|
1455 | 1455 | email_address = safe_str(email_address) |
|
1456 | 1456 | |
|
1457 | 1457 | # empty email or default user |
|
1458 | 1458 | if not email_address or email_address == User.DEFAULT_USER_EMAIL: |
|
1459 | 1459 | return initials_gravatar(request, User.DEFAULT_USER_EMAIL, '', '', size=size) |
|
1460 | 1460 | |
|
1461 | 1461 | if _use_gravatar: |
|
1462 | 1462 | gravatar_url_tmpl = request.call_context.visual.gravatar_url \ |
|
1463 | 1463 | or User.DEFAULT_GRAVATAR_URL |
|
1464 | 1464 | return gravatar_external(request, gravatar_url_tmpl, email_address, size=size) |
|
1465 | 1465 | |
|
1466 | 1466 | else: |
|
1467 | 1467 | return initials_gravatar(request, email_address, '', '', size=size) |
|
1468 | 1468 | |
|
1469 | 1469 | |
|
1470 | 1470 | def breadcrumb_repo_link(repo): |
|
1471 | 1471 | """ |
|
1472 | 1472 | Makes a breadcrumbs path link to repo |
|
1473 | 1473 | |
|
1474 | 1474 | ex:: |
|
1475 | 1475 | group >> subgroup >> repo |
|
1476 | 1476 | |
|
1477 | 1477 | :param repo: a Repository instance |
|
1478 | 1478 | """ |
|
1479 | 1479 | |
|
1480 | 1480 | path = [ |
|
1481 | 1481 | link_to(group.name, route_path('repo_group_home', repo_group_name=group.group_name), |
|
1482 | 1482 | title='last change:{}'.format(format_date(group.last_commit_change))) |
|
1483 | 1483 | for group in repo.groups_with_parents |
|
1484 | 1484 | ] + [ |
|
1485 | 1485 | link_to(repo.just_name, route_path('repo_summary', repo_name=repo.repo_name), |
|
1486 | 1486 | title='last change:{}'.format(format_date(repo.last_commit_change))) |
|
1487 | 1487 | ] |
|
1488 | 1488 | |
|
1489 | 1489 | return literal(' » '.join(path)) |
|
1490 | 1490 | |
|
1491 | 1491 | |
|
1492 | 1492 | def breadcrumb_repo_group_link(repo_group): |
|
1493 | 1493 | """ |
|
1494 | 1494 | Makes a breadcrumbs path link to repo |
|
1495 | 1495 | |
|
1496 | 1496 | ex:: |
|
1497 | 1497 | group >> subgroup |
|
1498 | 1498 | |
|
1499 | 1499 | :param repo_group: a Repository Group instance |
|
1500 | 1500 | """ |
|
1501 | 1501 | |
|
1502 | 1502 | path = [ |
|
1503 | 1503 | link_to(group.name, |
|
1504 | 1504 | route_path('repo_group_home', repo_group_name=group.group_name), |
|
1505 | 1505 | title='last change:{}'.format(format_date(group.last_commit_change))) |
|
1506 | 1506 | for group in repo_group.parents |
|
1507 | 1507 | ] + [ |
|
1508 | 1508 | link_to(repo_group.name, |
|
1509 | 1509 | route_path('repo_group_home', repo_group_name=repo_group.group_name), |
|
1510 | 1510 | title='last change:{}'.format(format_date(repo_group.last_commit_change))) |
|
1511 | 1511 | ] |
|
1512 | 1512 | |
|
1513 | 1513 | return literal(' » '.join(path)) |
|
1514 | 1514 | |
|
1515 | 1515 | |
|
1516 | 1516 | def format_byte_size_binary(file_size): |
|
1517 | 1517 | """ |
|
1518 | 1518 | Formats file/folder sizes to standard. |
|
1519 | 1519 | """ |
|
1520 | 1520 | if file_size is None: |
|
1521 | 1521 | file_size = 0 |
|
1522 | 1522 | |
|
1523 | 1523 | formatted_size = format_byte_size(file_size, binary=True) |
|
1524 | 1524 | return formatted_size |
|
1525 | 1525 | |
|
1526 | 1526 | |
|
1527 | 1527 | def urlify_text(text_, safe=True, **href_attrs): |
|
1528 | 1528 | """ |
|
1529 | 1529 | Extract urls from text and make html links out of them |
|
1530 | 1530 | """ |
|
1531 | 1531 | |
|
1532 | 1532 | url_pat = re.compile(r'''(http[s]?://(?:[a-zA-Z]|[0-9]|[$-_@#.&+]''' |
|
1533 | 1533 | '''|[!*\(\),]|(?:%[0-9a-fA-F][0-9a-fA-F]))+)''') |
|
1534 | 1534 | |
|
1535 | 1535 | def url_func(match_obj): |
|
1536 | 1536 | url_full = match_obj.groups()[0] |
|
1537 | 1537 | a_options = dict(href_attrs) |
|
1538 | 1538 | a_options['href'] = url_full |
|
1539 | 1539 | a_text = url_full |
|
1540 | 1540 | return HTML.tag("a", a_text, **a_options) |
|
1541 | 1541 | |
|
1542 | 1542 | _new_text = url_pat.sub(url_func, text_) |
|
1543 | 1543 | |
|
1544 | 1544 | if safe: |
|
1545 | 1545 | return literal(_new_text) |
|
1546 | 1546 | return _new_text |
|
1547 | 1547 | |
|
1548 | 1548 | |
|
1549 | 1549 | def urlify_commits(text_, repo_name): |
|
1550 | 1550 | """ |
|
1551 | 1551 | Extract commit ids from text and make link from them |
|
1552 | 1552 | |
|
1553 | 1553 | :param text_: |
|
1554 | 1554 | :param repo_name: repo name to build the URL with |
|
1555 | 1555 | """ |
|
1556 | 1556 | |
|
1557 | 1557 | url_pat = re.compile(r'(^|\s)([0-9a-fA-F]{12,40})($|\s)') |
|
1558 | 1558 | |
|
1559 | 1559 | def url_func(match_obj): |
|
1560 | 1560 | commit_id = match_obj.groups()[1] |
|
1561 | 1561 | pref = match_obj.groups()[0] |
|
1562 | 1562 | suf = match_obj.groups()[2] |
|
1563 | 1563 | |
|
1564 | 1564 | tmpl = ( |
|
1565 | 1565 | '%(pref)s<a class="tooltip-hovercard %(cls)s" href="%(url)s" data-hovercard-alt="%(hovercard_alt)s" data-hovercard-url="%(hovercard_url)s">' |
|
1566 | 1566 | '%(commit_id)s</a>%(suf)s' |
|
1567 | 1567 | ) |
|
1568 | 1568 | return tmpl % { |
|
1569 | 1569 | 'pref': pref, |
|
1570 | 1570 | 'cls': 'revision-link', |
|
1571 | 1571 | 'url': route_url( |
|
1572 | 1572 | 'repo_commit', repo_name=repo_name, commit_id=commit_id), |
|
1573 | 1573 | 'commit_id': commit_id, |
|
1574 | 1574 | 'suf': suf, |
|
1575 | 1575 | 'hovercard_alt': 'Commit: {}'.format(commit_id), |
|
1576 | 1576 | 'hovercard_url': route_url( |
|
1577 | 1577 | 'hovercard_repo_commit', repo_name=repo_name, commit_id=commit_id) |
|
1578 | 1578 | } |
|
1579 | 1579 | |
|
1580 | 1580 | new_text = url_pat.sub(url_func, text_) |
|
1581 | 1581 | |
|
1582 | 1582 | return new_text |
|
1583 | 1583 | |
|
1584 | 1584 | |
|
1585 | 1585 | def _process_url_func(match_obj, repo_name, uid, entry, |
|
1586 | 1586 | return_raw_data=False, link_format='html'): |
|
1587 | 1587 | pref = '' |
|
1588 | 1588 | if match_obj.group().startswith(' '): |
|
1589 | 1589 | pref = ' ' |
|
1590 | 1590 | |
|
1591 | 1591 | issue_id = ''.join(match_obj.groups()) |
|
1592 | 1592 | |
|
1593 | 1593 | if link_format == 'html': |
|
1594 | 1594 | tmpl = ( |
|
1595 | 1595 | '%(pref)s<a class="tooltip %(cls)s" href="%(url)s" title="%(title)s">' |
|
1596 | 1596 | '%(issue-prefix)s%(id-repr)s' |
|
1597 | 1597 | '</a>') |
|
1598 | 1598 | elif link_format == 'html+hovercard': |
|
1599 | 1599 | tmpl = ( |
|
1600 | 1600 | '%(pref)s<a class="tooltip-hovercard %(cls)s" href="%(url)s" data-hovercard-url="%(hovercard_url)s">' |
|
1601 | 1601 | '%(issue-prefix)s%(id-repr)s' |
|
1602 | 1602 | '</a>') |
|
1603 | 1603 | elif link_format in ['rst', 'rst+hovercard']: |
|
1604 | 1604 | tmpl = '`%(issue-prefix)s%(id-repr)s <%(url)s>`_' |
|
1605 | 1605 | elif link_format in ['markdown', 'markdown+hovercard']: |
|
1606 | 1606 | tmpl = '[%(pref)s%(issue-prefix)s%(id-repr)s](%(url)s)' |
|
1607 | 1607 | else: |
|
1608 | 1608 | raise ValueError('Bad link_format:{}'.format(link_format)) |
|
1609 | 1609 | |
|
1610 | 1610 | (repo_name_cleaned, |
|
1611 | 1611 | parent_group_name) = RepoGroupModel()._get_group_name_and_parent(repo_name) |
|
1612 | 1612 | |
|
1613 | 1613 | # variables replacement |
|
1614 | 1614 | named_vars = { |
|
1615 | 1615 | 'id': issue_id, |
|
1616 | 1616 | 'repo': repo_name, |
|
1617 | 1617 | 'repo_name': repo_name_cleaned, |
|
1618 | 1618 | 'group_name': parent_group_name, |
|
1619 | 1619 | # set dummy keys so we always have them |
|
1620 | 1620 | 'hostname': '', |
|
1621 | 1621 | 'netloc': '', |
|
1622 | 1622 | 'scheme': '' |
|
1623 | 1623 | } |
|
1624 | 1624 | |
|
1625 | 1625 | request = get_current_request() |
|
1626 | 1626 | if request: |
|
1627 | 1627 | # exposes, hostname, netloc, scheme |
|
1628 | 1628 | host_data = get_host_info(request) |
|
1629 | 1629 | named_vars.update(host_data) |
|
1630 | 1630 | |
|
1631 | 1631 | # named regex variables |
|
1632 | 1632 | named_vars.update(match_obj.groupdict()) |
|
1633 | 1633 | _url = string.Template(entry['url']).safe_substitute(**named_vars) |
|
1634 | 1634 | desc = string.Template(escape(entry['desc'])).safe_substitute(**named_vars) |
|
1635 | 1635 | hovercard_url = string.Template(entry.get('hovercard_url', '')).safe_substitute(**named_vars) |
|
1636 | 1636 | |
|
1637 | 1637 | def quote_cleaner(input_str): |
|
1638 | 1638 | """Remove quotes as it's HTML""" |
|
1639 | 1639 | return input_str.replace('"', '') |
|
1640 | 1640 | |
|
1641 | 1641 | data = { |
|
1642 | 1642 | 'pref': pref, |
|
1643 | 1643 | 'cls': quote_cleaner('issue-tracker-link'), |
|
1644 | 1644 | 'url': quote_cleaner(_url), |
|
1645 | 1645 | 'id-repr': issue_id, |
|
1646 | 1646 | 'issue-prefix': entry['pref'], |
|
1647 | 1647 | 'serv': entry['url'], |
|
1648 |
'title': |
|
|
1648 | 'title': sanitize_html(desc, strip=True), | |
|
1649 | 1649 | 'hovercard_url': hovercard_url |
|
1650 | 1650 | } |
|
1651 | 1651 | |
|
1652 | 1652 | if return_raw_data: |
|
1653 | 1653 | return { |
|
1654 | 1654 | 'id': issue_id, |
|
1655 | 1655 | 'url': _url |
|
1656 | 1656 | } |
|
1657 | 1657 | return tmpl % data |
|
1658 | 1658 | |
|
1659 | 1659 | |
|
1660 | 1660 | def get_active_pattern_entries(repo_name): |
|
1661 | 1661 | repo = None |
|
1662 | 1662 | if repo_name: |
|
1663 | 1663 | # Retrieving repo_name to avoid invalid repo_name to explode on |
|
1664 | 1664 | # IssueTrackerSettingsModel but still passing invalid name further down |
|
1665 | 1665 | repo = Repository.get_by_repo_name(repo_name, cache=True) |
|
1666 | 1666 | |
|
1667 | 1667 | settings_model = IssueTrackerSettingsModel(repo=repo) |
|
1668 | 1668 | active_entries = settings_model.get_settings(cache=True) |
|
1669 | 1669 | return active_entries |
|
1670 | 1670 | |
|
1671 | 1671 | |
|
1672 | 1672 | pr_pattern_re = regex.compile(r'(?:(?:^!)|(?: !))(\d+)') |
|
1673 | 1673 | |
|
1674 | 1674 | allowed_link_formats = [ |
|
1675 | 1675 | 'html', 'rst', 'markdown', 'html+hovercard', 'rst+hovercard', 'markdown+hovercard'] |
|
1676 | 1676 | |
|
1677 | 1677 | compile_cache = { |
|
1678 | 1678 | |
|
1679 | 1679 | } |
|
1680 | 1680 | |
|
1681 | 1681 | |
|
1682 | 1682 | def process_patterns(text_string, repo_name, link_format='html', active_entries=None): |
|
1683 | 1683 | |
|
1684 | 1684 | if link_format not in allowed_link_formats: |
|
1685 | 1685 | raise ValueError('Link format can be only one of:{} got {}'.format( |
|
1686 | 1686 | allowed_link_formats, link_format)) |
|
1687 | 1687 | issues_data = [] |
|
1688 | 1688 | errors = [] |
|
1689 | 1689 | new_text = text_string |
|
1690 | 1690 | |
|
1691 | 1691 | if active_entries is None: |
|
1692 | 1692 | log.debug('Fetch active issue tracker patterns for repo: %s', repo_name) |
|
1693 | 1693 | active_entries = get_active_pattern_entries(repo_name) |
|
1694 | 1694 | |
|
1695 | 1695 | log.debug('Got %s pattern entries to process', len(active_entries)) |
|
1696 | 1696 | |
|
1697 | 1697 | for uid, entry in list(active_entries.items()): |
|
1698 | 1698 | |
|
1699 | 1699 | if not (entry['pat'] and entry['url']): |
|
1700 | 1700 | log.debug('skipping due to missing data') |
|
1701 | 1701 | continue |
|
1702 | 1702 | |
|
1703 | 1703 | log.debug('issue tracker entry: uid: `%s` PAT:%s URL:%s PREFIX:%s', |
|
1704 | 1704 | uid, entry['pat'], entry['url'], entry['pref']) |
|
1705 | 1705 | |
|
1706 | 1706 | if entry.get('pat_compiled'): |
|
1707 | 1707 | pattern = entry['pat_compiled'] |
|
1708 | 1708 | elif entry['pat'] in compile_cache: |
|
1709 | 1709 | pattern = compile_cache[entry['pat']] |
|
1710 | 1710 | else: |
|
1711 | 1711 | try: |
|
1712 | 1712 | pattern = regex.compile(r'%s' % entry['pat']) |
|
1713 | 1713 | except regex.error as e: |
|
1714 | 1714 | regex_err = ValueError('{}:{}'.format(entry['pat'], e)) |
|
1715 | 1715 | log.exception('issue tracker pattern: `%s` failed to compile', regex_err) |
|
1716 | 1716 | errors.append(regex_err) |
|
1717 | 1717 | continue |
|
1718 | 1718 | compile_cache[entry['pat']] = pattern |
|
1719 | 1719 | |
|
1720 | 1720 | data_func = partial( |
|
1721 | 1721 | _process_url_func, repo_name=repo_name, entry=entry, uid=uid, |
|
1722 | 1722 | return_raw_data=True) |
|
1723 | 1723 | |
|
1724 | 1724 | for match_obj in pattern.finditer(text_string): |
|
1725 | 1725 | issues_data.append(data_func(match_obj)) |
|
1726 | 1726 | |
|
1727 | 1727 | url_func = partial( |
|
1728 | 1728 | _process_url_func, repo_name=repo_name, entry=entry, uid=uid, |
|
1729 | 1729 | link_format=link_format) |
|
1730 | 1730 | |
|
1731 | 1731 | new_text = pattern.sub(url_func, new_text) |
|
1732 | 1732 | log.debug('processed prefix:uid `%s`', uid) |
|
1733 | 1733 | |
|
1734 | 1734 | # finally use global replace, eg !123 -> pr-link, those will not catch |
|
1735 | 1735 | # if already similar pattern exists |
|
1736 | 1736 | server_url = '${scheme}://${netloc}' |
|
1737 | 1737 | pr_entry = { |
|
1738 | 1738 | 'pref': '!', |
|
1739 | 1739 | 'url': server_url + '/_admin/pull-requests/${id}', |
|
1740 | 1740 | 'desc': 'Pull Request !${id}', |
|
1741 | 1741 | 'hovercard_url': server_url + '/_hovercard/pull_request/${id}' |
|
1742 | 1742 | } |
|
1743 | 1743 | pr_url_func = partial( |
|
1744 | 1744 | _process_url_func, repo_name=repo_name, entry=pr_entry, uid=None, |
|
1745 | 1745 | link_format=link_format+'+hovercard') |
|
1746 | 1746 | new_text = pr_pattern_re.sub(pr_url_func, new_text) |
|
1747 | 1747 | log.debug('processed !pr pattern') |
|
1748 | 1748 | |
|
1749 | 1749 | return new_text, issues_data, errors |
|
1750 | 1750 | |
|
1751 | 1751 | |
|
1752 | 1752 | def urlify_commit_message(commit_text, repository=None, active_pattern_entries=None, |
|
1753 | 1753 | issues_container_callback=None, error_container=None): |
|
1754 | 1754 | """ |
|
1755 | 1755 | Parses given text message and makes proper links. |
|
1756 | 1756 | issues are linked to given issue-server, and rest is a commit link |
|
1757 | 1757 | """ |
|
1758 | 1758 | |
|
1759 | 1759 | def escaper(_text): |
|
1760 | 1760 | return _text.replace('<', '<').replace('>', '>') |
|
1761 | 1761 | |
|
1762 | 1762 | new_text = escaper(commit_text) |
|
1763 | 1763 | |
|
1764 | 1764 | # extract http/https links and make them real urls |
|
1765 | 1765 | new_text = urlify_text(new_text, safe=False) |
|
1766 | 1766 | |
|
1767 | 1767 | # urlify commits - extract commit ids and make link out of them, if we have |
|
1768 | 1768 | # the scope of repository present. |
|
1769 | 1769 | if repository: |
|
1770 | 1770 | new_text = urlify_commits(new_text, repository) |
|
1771 | 1771 | |
|
1772 | 1772 | # process issue tracker patterns |
|
1773 | 1773 | new_text, issues, errors = process_patterns( |
|
1774 | 1774 | new_text, repository or '', active_entries=active_pattern_entries) |
|
1775 | 1775 | |
|
1776 | 1776 | if issues_container_callback is not None: |
|
1777 | 1777 | for issue in issues: |
|
1778 | 1778 | issues_container_callback(issue) |
|
1779 | 1779 | |
|
1780 | 1780 | if error_container is not None: |
|
1781 | 1781 | error_container.extend(errors) |
|
1782 | 1782 | |
|
1783 | 1783 | return literal(new_text) |
|
1784 | 1784 | |
|
1785 | 1785 | |
|
1786 | 1786 | def render_binary(repo_name, file_obj): |
|
1787 | 1787 | """ |
|
1788 | 1788 | Choose how to render a binary file |
|
1789 | 1789 | """ |
|
1790 | 1790 | |
|
1791 | 1791 | # unicode |
|
1792 | 1792 | filename = file_obj.name |
|
1793 | 1793 | |
|
1794 | 1794 | # images |
|
1795 | 1795 | for ext in ['*.png', '*.jpeg', '*.jpg', '*.ico', '*.gif']: |
|
1796 | 1796 | if fnmatch.fnmatch(filename, pat=ext): |
|
1797 | 1797 | src = route_path( |
|
1798 | 1798 | 'repo_file_raw', repo_name=repo_name, |
|
1799 | 1799 | commit_id=file_obj.commit.raw_id, |
|
1800 | 1800 | f_path=file_obj.path) |
|
1801 | 1801 | |
|
1802 | 1802 | return literal( |
|
1803 | 1803 | '<img class="rendered-binary" alt="rendered-image" src="{}">'.format(src)) |
|
1804 | 1804 | |
|
1805 | 1805 | |
|
1806 | 1806 | def renderer_from_filename(filename, exclude=None): |
|
1807 | 1807 | """ |
|
1808 | 1808 | choose a renderer based on filename, this works only for text based files |
|
1809 | 1809 | """ |
|
1810 | 1810 | |
|
1811 | 1811 | # ipython |
|
1812 | 1812 | for ext in ['*.ipynb']: |
|
1813 | 1813 | if fnmatch.fnmatch(filename, pat=ext): |
|
1814 | 1814 | return 'jupyter' |
|
1815 | 1815 | |
|
1816 | 1816 | is_markup = MarkupRenderer.renderer_from_filename(filename, exclude=exclude) |
|
1817 | 1817 | if is_markup: |
|
1818 | 1818 | return is_markup |
|
1819 | 1819 | return None |
|
1820 | 1820 | |
|
1821 | 1821 | |
|
1822 | 1822 | def render(source, renderer='rst', mentions=False, relative_urls=None, |
|
1823 | 1823 | repo_name=None, active_pattern_entries=None, issues_container_callback=None): |
|
1824 | 1824 | |
|
1825 | 1825 | def maybe_convert_relative_links(html_source): |
|
1826 | 1826 | if relative_urls: |
|
1827 | 1827 | return relative_links(html_source, relative_urls) |
|
1828 | 1828 | return html_source |
|
1829 | 1829 | |
|
1830 | 1830 | if renderer == 'plain': |
|
1831 | 1831 | return literal( |
|
1832 | 1832 | MarkupRenderer.plain(source, leading_newline=False)) |
|
1833 | 1833 | |
|
1834 | 1834 | elif renderer == 'rst': |
|
1835 | 1835 | if repo_name: |
|
1836 | 1836 | # process patterns on comments if we pass in repo name |
|
1837 | 1837 | source, issues, errors = process_patterns( |
|
1838 | 1838 | source, repo_name, link_format='rst', |
|
1839 | 1839 | active_entries=active_pattern_entries) |
|
1840 | 1840 | if issues_container_callback is not None: |
|
1841 | 1841 | for issue in issues: |
|
1842 | 1842 | issues_container_callback(issue) |
|
1843 | 1843 | |
|
1844 | 1844 | rendered_block = maybe_convert_relative_links( |
|
1845 | 1845 | MarkupRenderer.rst(source, mentions=mentions)) |
|
1846 | 1846 | |
|
1847 | 1847 | return literal(f'<div class="rst-block">{rendered_block}</div>') |
|
1848 | 1848 | |
|
1849 | 1849 | elif renderer == 'markdown': |
|
1850 | 1850 | if repo_name: |
|
1851 | 1851 | # process patterns on comments if we pass in repo name |
|
1852 | 1852 | source, issues, errors = process_patterns( |
|
1853 | 1853 | source, repo_name, link_format='markdown', |
|
1854 | 1854 | active_entries=active_pattern_entries) |
|
1855 | 1855 | if issues_container_callback is not None: |
|
1856 | 1856 | for issue in issues: |
|
1857 | 1857 | issues_container_callback(issue) |
|
1858 | 1858 | |
|
1859 | 1859 | rendered_block = maybe_convert_relative_links( |
|
1860 | 1860 | MarkupRenderer.markdown(source, flavored=True, mentions=mentions)) |
|
1861 | 1861 | return literal(f'<div class="markdown-block">{rendered_block}</div>') |
|
1862 | 1862 | |
|
1863 | 1863 | elif renderer == 'jupyter': |
|
1864 | 1864 | rendered_block = maybe_convert_relative_links( |
|
1865 | 1865 | MarkupRenderer.jupyter(source)) |
|
1866 | 1866 | return literal(f'<div class="ipynb">{rendered_block}</div>') |
|
1867 | 1867 | |
|
1868 | 1868 | # None means just show the file-source |
|
1869 | 1869 | return None |
|
1870 | 1870 | |
|
1871 | 1871 | |
|
1872 | 1872 | def commit_status(repo, commit_id): |
|
1873 | 1873 | return ChangesetStatusModel().get_status(repo, commit_id) |
|
1874 | 1874 | |
|
1875 | 1875 | |
|
1876 | 1876 | def commit_status_lbl(commit_status): |
|
1877 | 1877 | return dict(ChangesetStatus.STATUSES).get(commit_status) |
|
1878 | 1878 | |
|
1879 | 1879 | |
|
1880 | 1880 | def commit_time(repo_name, commit_id): |
|
1881 | 1881 | repo = Repository.get_by_repo_name(repo_name) |
|
1882 | 1882 | commit = repo.get_commit(commit_id=commit_id) |
|
1883 | 1883 | return commit.date |
|
1884 | 1884 | |
|
1885 | 1885 | |
|
1886 | 1886 | def get_permission_name(key): |
|
1887 | 1887 | return dict(Permission.PERMS).get(key) |
|
1888 | 1888 | |
|
1889 | 1889 | |
|
1890 | 1890 | def journal_filter_help(request): |
|
1891 | 1891 | _ = request.translate |
|
1892 | 1892 | from rhodecode.lib.audit_logger import ACTIONS |
|
1893 | 1893 | actions = '\n'.join(textwrap.wrap(', '.join(sorted(ACTIONS.keys())), 80)) |
|
1894 | 1894 | |
|
1895 | 1895 | return _( |
|
1896 | 1896 | 'Example filter terms:\n' + |
|
1897 | 1897 | ' repository:vcs\n' + |
|
1898 | 1898 | ' username:marcin\n' + |
|
1899 | 1899 | ' username:(NOT marcin)\n' + |
|
1900 | 1900 | ' action:*push*\n' + |
|
1901 | 1901 | ' ip:127.0.0.1\n' + |
|
1902 | 1902 | ' date:20120101\n' + |
|
1903 | 1903 | ' date:[20120101100000 TO 20120102]\n' + |
|
1904 | 1904 | '\n' + |
|
1905 | 1905 | 'Actions: {actions}\n' + |
|
1906 | 1906 | '\n' + |
|
1907 | 1907 | 'Generate wildcards using \'*\' character:\n' + |
|
1908 | 1908 | ' "repository:vcs*" - search everything starting with \'vcs\'\n' + |
|
1909 | 1909 | ' "repository:*vcs*" - search for repository containing \'vcs\'\n' + |
|
1910 | 1910 | '\n' + |
|
1911 | 1911 | 'Optional AND / OR operators in queries\n' + |
|
1912 | 1912 | ' "repository:vcs OR repository:test"\n' + |
|
1913 | 1913 | ' "username:test AND repository:test*"\n' |
|
1914 | 1914 | ).format(actions=actions) |
|
1915 | 1915 | |
|
1916 | 1916 | |
|
1917 | 1917 | def not_mapped_error(repo_name): |
|
1918 | 1918 | from rhodecode.translation import _ |
|
1919 | 1919 | flash(_('%s repository is not mapped to db perhaps' |
|
1920 | 1920 | ' it was created or renamed from the filesystem' |
|
1921 | 1921 | ' please run the application again' |
|
1922 | 1922 | ' in order to rescan repositories') % repo_name, category='error') |
|
1923 | 1923 | |
|
1924 | 1924 | |
|
1925 | 1925 | def ip_range(ip_addr): |
|
1926 | 1926 | from rhodecode.model.db import UserIpMap |
|
1927 | 1927 | s, e = UserIpMap._get_ip_range(ip_addr) |
|
1928 | 1928 | return '%s - %s' % (s, e) |
|
1929 | 1929 | |
|
1930 | 1930 | |
|
1931 | 1931 | def form(url, method='post', needs_csrf_token=True, **attrs): |
|
1932 | 1932 | """Wrapper around webhelpers.tags.form to prevent CSRF attacks.""" |
|
1933 | 1933 | if method.lower() != 'get' and needs_csrf_token: |
|
1934 | 1934 | raise Exception( |
|
1935 | 1935 | 'Forms to POST/PUT/DELETE endpoints should have (in general) a ' + |
|
1936 | 1936 | 'CSRF token. If the endpoint does not require such token you can ' + |
|
1937 | 1937 | 'explicitly set the parameter needs_csrf_token to false.') |
|
1938 | 1938 | |
|
1939 | 1939 | return insecure_form(url, method=method, **attrs) |
|
1940 | 1940 | |
|
1941 | 1941 | |
|
1942 | 1942 | def secure_form(form_url, method="POST", multipart=False, **attrs): |
|
1943 | 1943 | """Start a form tag that points the action to an url. This |
|
1944 | 1944 | form tag will also include the hidden field containing |
|
1945 | 1945 | the auth token. |
|
1946 | 1946 | |
|
1947 | 1947 | The url options should be given either as a string, or as a |
|
1948 | 1948 | ``url()`` function. The method for the form defaults to POST. |
|
1949 | 1949 | |
|
1950 | 1950 | Options: |
|
1951 | 1951 | |
|
1952 | 1952 | ``multipart`` |
|
1953 | 1953 | If set to True, the enctype is set to "multipart/form-data". |
|
1954 | 1954 | ``method`` |
|
1955 | 1955 | The method to use when submitting the form, usually either |
|
1956 | 1956 | "GET" or "POST". If "PUT", "DELETE", or another verb is used, a |
|
1957 | 1957 | hidden input with name _method is added to simulate the verb |
|
1958 | 1958 | over POST. |
|
1959 | 1959 | |
|
1960 | 1960 | """ |
|
1961 | 1961 | |
|
1962 | 1962 | if 'request' in attrs: |
|
1963 | 1963 | session = attrs['request'].session |
|
1964 | 1964 | del attrs['request'] |
|
1965 | 1965 | else: |
|
1966 | 1966 | raise ValueError( |
|
1967 | 1967 | 'Calling this form requires request= to be passed as argument') |
|
1968 | 1968 | |
|
1969 | 1969 | _form = insecure_form(form_url, method, multipart, **attrs) |
|
1970 | 1970 | token = literal( |
|
1971 | 1971 | '<input type="hidden" name="{}" value="{}">'.format( |
|
1972 | 1972 | csrf_token_key, get_csrf_token(session))) |
|
1973 | 1973 | |
|
1974 | 1974 | return literal("%s\n%s" % (_form, token)) |
|
1975 | 1975 | |
|
1976 | 1976 | |
|
1977 | 1977 | def dropdownmenu(name, selected, options, enable_filter=False, **attrs): |
|
1978 | 1978 | select_html = select(name, selected, options, **attrs) |
|
1979 | 1979 | |
|
1980 | 1980 | select2 = """ |
|
1981 | 1981 | <script> |
|
1982 | 1982 | $(document).ready(function() { |
|
1983 | 1983 | $('#%s').select2({ |
|
1984 | 1984 | containerCssClass: 'drop-menu %s', |
|
1985 | 1985 | dropdownCssClass: 'drop-menu-dropdown', |
|
1986 | 1986 | dropdownAutoWidth: true%s |
|
1987 | 1987 | }); |
|
1988 | 1988 | }); |
|
1989 | 1989 | </script> |
|
1990 | 1990 | """ |
|
1991 | 1991 | |
|
1992 | 1992 | filter_option = """, |
|
1993 | 1993 | minimumResultsForSearch: -1 |
|
1994 | 1994 | """ |
|
1995 | 1995 | input_id = attrs.get('id') or name |
|
1996 | 1996 | extra_classes = ' '.join(attrs.pop('extra_classes', [])) |
|
1997 | 1997 | filter_enabled = "" if enable_filter else filter_option |
|
1998 | 1998 | select_script = literal(select2 % (input_id, extra_classes, filter_enabled)) |
|
1999 | 1999 | |
|
2000 | 2000 | return literal(select_html+select_script) |
|
2001 | 2001 | |
|
2002 | 2002 | |
|
2003 | 2003 | def get_visual_attr(tmpl_context_var, attr_name): |
|
2004 | 2004 | """ |
|
2005 | 2005 | A safe way to get a variable from visual variable of template context |
|
2006 | 2006 | |
|
2007 | 2007 | :param tmpl_context_var: instance of tmpl_context, usually present as `c` |
|
2008 | 2008 | :param attr_name: name of the attribute we fetch from the c.visual |
|
2009 | 2009 | """ |
|
2010 | 2010 | visual = getattr(tmpl_context_var, 'visual', None) |
|
2011 | 2011 | if not visual: |
|
2012 | 2012 | return |
|
2013 | 2013 | else: |
|
2014 | 2014 | return getattr(visual, attr_name, None) |
|
2015 | 2015 | |
|
2016 | 2016 | |
|
2017 | 2017 | def get_last_path_part(file_node): |
|
2018 | 2018 | if not file_node.path: |
|
2019 | 2019 | return '/' |
|
2020 | 2020 | |
|
2021 | 2021 | path = safe_str(file_node.path.split('/')[-1]) |
|
2022 | 2022 | return '../' + path |
|
2023 | 2023 | |
|
2024 | 2024 | |
|
2025 | 2025 | def route_url(*args, **kwargs): |
|
2026 | 2026 | """ |
|
2027 | 2027 | Wrapper around pyramids `route_url` (fully qualified url) function. |
|
2028 | 2028 | """ |
|
2029 | 2029 | req = get_current_request() |
|
2030 | 2030 | return req.route_url(*args, **kwargs) |
|
2031 | 2031 | |
|
2032 | 2032 | |
|
2033 | 2033 | def route_path(*args, **kwargs): |
|
2034 | 2034 | """ |
|
2035 | 2035 | Wrapper around pyramids `route_path` function. |
|
2036 | 2036 | """ |
|
2037 | 2037 | req = get_current_request() |
|
2038 | 2038 | return req.route_path(*args, **kwargs) |
|
2039 | 2039 | |
|
2040 | 2040 | |
|
2041 | 2041 | def route_path_or_none(*args, **kwargs): |
|
2042 | 2042 | try: |
|
2043 | 2043 | return route_path(*args, **kwargs) |
|
2044 | 2044 | except KeyError: |
|
2045 | 2045 | return None |
|
2046 | 2046 | |
|
2047 | 2047 | |
|
2048 | 2048 | def current_route_path(request, **kw): |
|
2049 | 2049 | new_args = request.GET.mixed() |
|
2050 | 2050 | new_args.update(kw) |
|
2051 | 2051 | return request.current_route_path(_query=new_args) |
|
2052 | 2052 | |
|
2053 | 2053 | |
|
2054 | 2054 | def curl_api_example(method, args): |
|
2055 | 2055 | args_json = json.dumps(OrderedDict([ |
|
2056 | 2056 | ('id', 1), |
|
2057 | 2057 | ('auth_token', 'SECRET'), |
|
2058 | 2058 | ('method', method), |
|
2059 | 2059 | ('args', args) |
|
2060 | 2060 | ])) |
|
2061 | 2061 | |
|
2062 | 2062 | return "curl {api_url} -X POST -H 'content-type:text/plain' --data-binary '{args_json}'".format( |
|
2063 | 2063 | api_url=route_url('apiv2'), |
|
2064 | 2064 | args_json=args_json |
|
2065 | 2065 | ) |
|
2066 | 2066 | |
|
2067 | 2067 | |
|
2068 | 2068 | def api_call_example(method, args): |
|
2069 | 2069 | """ |
|
2070 | 2070 | Generates an API call example via CURL |
|
2071 | 2071 | """ |
|
2072 | 2072 | curl_call = curl_api_example(method, args) |
|
2073 | 2073 | |
|
2074 | 2074 | return literal( |
|
2075 | 2075 | curl_call + |
|
2076 | 2076 | "<br/><br/>SECRET can be found in <a href=\"{token_url}\">auth-tokens</a> page, " |
|
2077 | 2077 | "and needs to be of `api calls` role." |
|
2078 | 2078 | .format(token_url=route_url('my_account_auth_tokens'))) |
|
2079 | 2079 | |
|
2080 | 2080 | |
|
2081 | 2081 | def notification_description(notification, request): |
|
2082 | 2082 | """ |
|
2083 | 2083 | Generate notification human readable description based on notification type |
|
2084 | 2084 | """ |
|
2085 | 2085 | from rhodecode.model.notification import NotificationModel |
|
2086 | 2086 | return NotificationModel().make_description( |
|
2087 | 2087 | notification, translate=request.translate) |
|
2088 | 2088 | |
|
2089 | 2089 | |
|
2090 | 2090 | def go_import_header(request, db_repo=None): |
|
2091 | 2091 | """ |
|
2092 | 2092 | Creates a header for go-import functionality in Go Lang |
|
2093 | 2093 | """ |
|
2094 | 2094 | |
|
2095 | 2095 | if not db_repo: |
|
2096 | 2096 | return |
|
2097 | 2097 | if 'go-get' not in request.GET: |
|
2098 | 2098 | return |
|
2099 | 2099 | |
|
2100 | 2100 | clone_url = db_repo.clone_url() |
|
2101 | 2101 | prefix = re.split(r'^https?:\/\/', clone_url)[-1] |
|
2102 | 2102 | # we have a repo and go-get flag, |
|
2103 | 2103 | return literal('<meta name="go-import" content="{} {} {}">'.format( |
|
2104 | 2104 | prefix, db_repo.repo_type, clone_url)) |
|
2105 | 2105 | |
|
2106 | 2106 | |
|
2107 | 2107 | def reviewer_as_json(*args, **kwargs): |
|
2108 | 2108 | from rhodecode.apps.repository.utils import reviewer_as_json as _reviewer_as_json |
|
2109 | 2109 | return _reviewer_as_json(*args, **kwargs) |
|
2110 | 2110 | |
|
2111 | 2111 | |
|
2112 | 2112 | def get_repo_view_type(request): |
|
2113 | 2113 | route_name = request.matched_route.name |
|
2114 | 2114 | route_to_view_type = { |
|
2115 | 2115 | 'repo_changelog': 'commits', |
|
2116 | 2116 | 'repo_commits': 'commits', |
|
2117 | 2117 | 'repo_files': 'files', |
|
2118 | 2118 | 'repo_summary': 'summary', |
|
2119 | 2119 | 'repo_commit': 'commit' |
|
2120 | 2120 | } |
|
2121 | 2121 | |
|
2122 | 2122 | return route_to_view_type.get(route_name) |
|
2123 | 2123 | |
|
2124 | 2124 | |
|
2125 | 2125 | def is_active(menu_entry, selected): |
|
2126 | 2126 | """ |
|
2127 | 2127 | Returns active class for selecting menus in templates |
|
2128 | 2128 | <li class=${h.is_active('settings', current_active)}></li> |
|
2129 | 2129 | """ |
|
2130 | 2130 | if not isinstance(menu_entry, list): |
|
2131 | 2131 | menu_entry = [menu_entry] |
|
2132 | 2132 | |
|
2133 | 2133 | if selected in menu_entry: |
|
2134 | 2134 | return "active" |
|
2135 | 2135 | |
|
2136 | 2136 | |
|
2137 | 2137 | class IssuesRegistry(object): |
|
2138 | 2138 | """ |
|
2139 | 2139 | issue_registry = IssuesRegistry() |
|
2140 | 2140 | some_func(issues_callback=issues_registry(...)) |
|
2141 | 2141 | """ |
|
2142 | 2142 | |
|
2143 | 2143 | def __init__(self): |
|
2144 | 2144 | self.issues = [] |
|
2145 | 2145 | self.unique_issues = collections.defaultdict(lambda: []) |
|
2146 | 2146 | |
|
2147 | 2147 | def __call__(self, commit_dict=None): |
|
2148 | 2148 | def callback(issue): |
|
2149 | 2149 | if commit_dict and issue: |
|
2150 | 2150 | issue['commit'] = commit_dict |
|
2151 | 2151 | self.issues.append(issue) |
|
2152 | 2152 | self.unique_issues[issue['id']].append(issue) |
|
2153 | 2153 | return callback |
|
2154 | 2154 | |
|
2155 | 2155 | def get_issues(self): |
|
2156 | 2156 | return self.issues |
|
2157 | 2157 | |
|
2158 | 2158 | @property |
|
2159 | 2159 | def issues_unique_count(self): |
|
2160 | 2160 | return len(set(i['id'] for i in self.issues)) |
@@ -1,23 +1,62 b'' | |||
|
1 | 1 | # Copyright (C) 2020-2023 RhodeCode GmbH |
|
2 | 2 | # |
|
3 | 3 | # This program is free software: you can redistribute it and/or modify |
|
4 | 4 | # it under the terms of the GNU Affero General Public License, version 3 |
|
5 | 5 | # (only), as published by the Free Software Foundation. |
|
6 | 6 | # |
|
7 | 7 | # This program is distributed in the hope that it will be useful, |
|
8 | 8 | # but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
9 | 9 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
10 | 10 | # GNU General Public License for more details. |
|
11 | 11 | # |
|
12 | 12 | # You should have received a copy of the GNU Affero General Public License |
|
13 | 13 | # along with this program. If not, see <http://www.gnu.org/licenses/>. |
|
14 | 14 | # |
|
15 | 15 | # This program is dual-licensed. If you wish to learn more about the |
|
16 | 16 | # RhodeCode Enterprise Edition, including its added features, Support services, |
|
17 | 17 | # and proprietary license terms, please see https://rhodecode.com/licenses/ |
|
18 | 18 | |
|
19 | import functools | |
|
20 | import logging | |
|
21 | from .html_sanitizer_defs import markdown_attrs, markdown_tags, all_tags, all_styles | |
|
22 | ||
|
23 | ||
|
24 | log = logging.getLogger(__name__) | |
|
25 | ||
|
26 | ||
|
19 | 27 | # base64 filter e.g ${ example | base64,n } |
|
20 | 28 | def base64(text): |
|
21 | 29 | from rhodecode.lib.str_utils import base64_to_str |
|
22 | 30 | return base64_to_str(text) |
|
23 | 31 | |
|
32 | ||
|
33 | def sanitize_html(text, **kwargs): | |
|
34 | # TODO: replace this with https://nh3.readthedocs.io/en/latest | |
|
35 | # bleach is abandoned and deprecated :/ | |
|
36 | import bleach | |
|
37 | from bleach.css_sanitizer import CSSSanitizer | |
|
38 | ||
|
39 | css_sanitizer = CSSSanitizer(allowed_css_properties=all_styles) | |
|
40 | ||
|
41 | markdown = kwargs.pop('markdown', False) | |
|
42 | ||
|
43 | allowed_attrs = markdown_attrs | |
|
44 | ||
|
45 | cleaner = functools.partial(bleach.clean, | |
|
46 | tags=all_tags, | |
|
47 | attributes=allowed_attrs, | |
|
48 | css_sanitizer=css_sanitizer, | |
|
49 | strip_comments=False, **kwargs) | |
|
50 | ||
|
51 | if markdown: | |
|
52 | cleaner = functools.partial(bleach.clean, | |
|
53 | tags=markdown_tags, | |
|
54 | attributes=markdown_attrs, | |
|
55 | css_sanitizer=css_sanitizer, | |
|
56 | strip_comments=False, **kwargs) | |
|
57 | ||
|
58 | try: | |
|
59 | return cleaner(text) | |
|
60 | except Exception: | |
|
61 | log.exception('Failed to sanitize html') | |
|
62 | return 'TEXT CANNOT BE PARSED USING HTML SANITIZE' |
@@ -1,408 +1,409 b'' | |||
|
1 | 1 | all_tags = [ |
|
2 | 2 | "a", "abbr", "acronym", "address", "applet", "area", "article", "aside", "audio", |
|
3 | 3 | "b", "base", "basefont", "bdi", "bdo", "bgsound", "big", "blink", "blockquote", "body", "br", "button", |
|
4 | 4 | "canvas", "caption", "center", "cite", "code", "col", "colgroup", "command", "content", |
|
5 | 5 | "data", "datalist", "dd", "del", "detals", "dfn", "dialog", "dir", "div", "dl", "dt", |
|
6 | 6 | "element", "em", "embed", |
|
7 | 7 | "fieldset", "figcaption", "figure", "font", "footer", "form", "frame", "frameset", |
|
8 | 8 | "h1", "h2", "h3", "h4", "h5", "h6", "head", "header", "hgroup", "hr", "html", |
|
9 | 9 | "i", "iframe", "image", "img", "input", "ins", "isindex", |
|
10 | 10 | "kbd", "keygen", |
|
11 | 11 | "label", "legend", "li", "link", "listing", |
|
12 | 12 | "main", "map", "mark", "marquee", "menu", "menuitem", "meta", "meter", "multicol", |
|
13 | 13 | "nav", "nobr", "noembed", "noframes", "noscript", |
|
14 | 14 | "object", "ol", "optgroup", "option", "output", |
|
15 | 15 | "p", "param", "picture", "plaintext", "pre", "progress", |
|
16 | 16 | "q", |
|
17 | 17 | "rp", "rt", "ruby", |
|
18 | 18 | "s", "samp", "script", "section", "select", "shadow", "small", "source", "spacer", "span", "strike", "strong", "style", "sub", "summary", "sup", |
|
19 | 19 | "table", "tbody", "td", "template", "textarea", "tfoot", "th", "thead", "time", "title", "tr", "track", "tt", |
|
20 | 20 | "u", "ul", |
|
21 | 21 | "var", "video", |
|
22 | 22 | "wbr", |
|
23 | 23 | "xmp", |
|
24 | 24 | ] |
|
25 | 25 | |
|
26 | 26 | # List tags that, if included in a page, could break markup or open XSS. |
|
27 | 27 | generally_xss_unsafe = [ |
|
28 | 28 | "applet", "audio", |
|
29 | 29 | "bgsound", "body", |
|
30 | 30 | "canvas", |
|
31 | 31 | "embed", |
|
32 | 32 | "frame", "frameset", |
|
33 | 33 | "head", "html", |
|
34 | 34 | "iframe", |
|
35 | 35 | "link", |
|
36 | 36 | "meta", |
|
37 | 37 | "object", |
|
38 | 38 | "param", |
|
39 | 39 | "source", "script", |
|
40 | 40 | "ruby", "rt", |
|
41 | 41 | "title", "track", |
|
42 | 42 | "video", |
|
43 | 43 | "xmp" |
|
44 | 44 | ] |
|
45 | 45 | |
|
46 | 46 | # Tags that, if included on the page, will probably not break markup or open |
|
47 | 47 | # XSS. Note that these must be combined with attribute whitelisting, or things |
|
48 | 48 | # like <img> and <style> could still be unsafe. |
|
49 | 49 | generally_xss_safe = list(set(all_tags) - set(generally_xss_unsafe)) |
|
50 | 50 | generally_xss_safe.sort() |
|
51 | 51 | |
|
52 | 52 | # Tags suitable for rendering markdown |
|
53 | 53 | markdown_tags = [ |
|
54 | 54 | "h1", "h2", "h3", "h4", "h5", "h6", |
|
55 | 55 | "b", "i", "strong", "em", "tt", |
|
56 | 56 | "p", "br", |
|
57 | 57 | "span", "div", "blockquote", "code", "hr", "pre", "del", |
|
58 | 58 | "ul", "ol", "li", |
|
59 | 59 | "dl", "dd", "dt", |
|
60 | 60 | "table", "thead", "tbody", "tfoot", "tr", "th", "td", |
|
61 | 61 | "img", |
|
62 | 62 | "a", |
|
63 | 63 | "input", |
|
64 | 64 | "details", |
|
65 | "summary" | |
|
65 | "summary", | |
|
66 | "div" | |
|
66 | 67 | ] |
|
67 | 68 | |
|
68 | 69 | markdown_attrs = { |
|
69 | 70 | "*": ["class", "style", "align"], |
|
70 | 71 | "img": ["src", "alt", "title", "width", "height", "hspace", "align"], |
|
71 | 72 | "a": ["href", "alt", "title", "name", "data-hovercard-alt", "data-hovercard-url"], |
|
72 | 73 | "abbr": ["title"], |
|
73 | 74 | "acronym": ["title"], |
|
74 | 75 | "pre": ["lang"], |
|
75 | 76 | "input": ["type", "disabled", "checked"], |
|
76 | 77 | "strong": ["title", "data-hovercard-alt", "data-hovercard-url"], |
|
77 | 78 | } |
|
78 | 79 | |
|
79 | 80 | standard_styles = [ |
|
80 | 81 | # Taken from https://developer.mozilla.org/en-US/docs/Web/CSS/Reference |
|
81 | 82 | # This includes pseudo-classes, pseudo-elements, @-rules, units, and |
|
82 | 83 | # selectors in addition to properties, but it doesn't matter for our |
|
83 | 84 | # purposes -- we don't need to filter styles.. |
|
84 | 85 | ":active", "::after (:after)", "align-content", "align-items", "align-self", |
|
85 | 86 | "all", "<angle>", "animation", "animation-delay", "animation-direction", |
|
86 | 87 | "animation-duration", "animation-fill-mode", "animation-iteration-count", |
|
87 | 88 | "animation-name", "animation-play-state", "animation-timing-function", |
|
88 | 89 | "@annotation", "annotation()", "attr()", "::backdrop", "backface-visibility", |
|
89 | 90 | "background", "background-attachment", "background-blend-mode", |
|
90 | 91 | "background-clip", "background-color", "background-image", "background-origin", |
|
91 | 92 | "background-position", "background-repeat", "background-size", "<basic-shape>", |
|
92 | 93 | "::before (:before)", "<blend-mode>", "blur()", "border", "border-bottom", |
|
93 | 94 | "border-bottom-color", "border-bottom-left-radius", |
|
94 | 95 | "border-bottom-right-radius", "border-bottom-style", "border-bottom-width", |
|
95 | 96 | "border-collapse", "border-color", "border-image", "border-image-outset", |
|
96 | 97 | "border-image-repeat", "border-image-slice", "border-image-source", |
|
97 | 98 | "border-image-width", "border-left", "border-left-color", "border-left-style", |
|
98 | 99 | "border-left-width", "border-radius", "border-right", "border-right-color", |
|
99 | 100 | "border-right-style", "border-right-width", "border-spacing", "border-style", |
|
100 | 101 | "border-top", "border-top-color", "border-top-left-radius", |
|
101 | 102 | "border-top-right-radius", "border-top-style", "border-top-width", |
|
102 | 103 | "border-width", "bottom", "box-decoration-break", "box-shadow", "box-sizing", |
|
103 | 104 | "break-after", "break-before", "break-inside", "brightness()", "calc()", |
|
104 | 105 | "caption-side", "ch", "@character-variant", "character-variant()", "@charset", |
|
105 | 106 | ":checked", "circle()", "clear", "clip", "clip-path", "cm", "color", "<color>", |
|
106 | 107 | "columns", "column-count", "column-fill", "column-gap", "column-rule", |
|
107 | 108 | "column-rule-color", "column-rule-style", "column-rule-width", "column-span", |
|
108 | 109 | "column-width", "content", "contrast()", "<counter>", "counter-increment", |
|
109 | 110 | "counter-reset", "@counter-style", "cubic-bezier()", "cursor", |
|
110 | 111 | "<custom-ident>", ":default", "deg", ":dir()", "direction", ":disabled", |
|
111 | 112 | "display", "@document", "dpcm", "dpi", "dppx", "drop-shadow()", "element()", |
|
112 | 113 | "ellipse()", "em", ":empty", "empty-cells", ":enabled", "ex", "filter", |
|
113 | 114 | ":first", ":first-child", "::first-letter", "::first-line", |
|
114 | 115 | ":first-of-type", "flex", "flex-basis", "flex-direction", |
|
115 | 116 | "flex-flow", "flex-grow", "flex-shrink", "flex-wrap", "float", ":focus", |
|
116 | 117 | "font", "@font-face", "font-family", "font-feature-settings", |
|
117 | 118 | "@font-feature-values", "font-kerning", "font-language-override", "font-size", |
|
118 | 119 | "font-size-adjust", "font-stretch", "font-style", "font-synthesis", |
|
119 | 120 | "font-variant", "font-variant-alternates", "font-variant-caps", |
|
120 | 121 | "font-variant-east-asian", "font-variant-ligatures", "font-variant-numeric", |
|
121 | 122 | "font-variant-position", "font-weight", "<frequency>", ":fullscreen", "grad", |
|
122 | 123 | "<gradient>", "grayscale()", "grid", "grid-area", "grid-auto-columns", |
|
123 | 124 | "grid-auto-flow", "grid-auto-position", "grid-auto-rows", "grid-column", |
|
124 | 125 | "grid-column-start", "grid-column-end", "grid-row", "grid-row-start", |
|
125 | 126 | "grid-row-end", "grid-template", "grid-template-areas", "grid-template-rows", |
|
126 | 127 | "grid-template-columns", "height", ":hover", "hsl()", "hsla()", "hue-rotate()", |
|
127 | 128 | "hyphens", "hz", "<image>", "image()", "image-rendering", "image-resolution", |
|
128 | 129 | "image-orientation", "ime-mode", "@import", "in", ":indeterminate", "inherit", |
|
129 | 130 | "initial", ":in-range", "inset()", "<integer>", ":invalid", "invert()", |
|
130 | 131 | "isolation", "justify-content", "@keyframes", "khz", ":lang()", ":last-child", |
|
131 | 132 | ":last-of-type", "left", ":left", "<length>", "letter-spacing", |
|
132 | 133 | "linear-gradient()", "line-break", "line-height", ":link", "list-style", |
|
133 | 134 | "list-style-image", "list-style-position", "list-style-type", "margin", |
|
134 | 135 | "margin-bottom", "margin-left", "margin-right", "margin-top", "marks", "mask", |
|
135 | 136 | "mask-type", "matrix()", "matrix3d()", "max-height", "max-width", "@media", |
|
136 | 137 | "min-height", "minmax()", "min-width", "mix-blend-mode", "mm", "ms", |
|
137 | 138 | "@namespace", ":not()", ":nth-child()", ":nth-last-child()", |
|
138 | 139 | ":nth-last-of-type()", ":nth-of-type()", "<number>", "object-fit", |
|
139 | 140 | "object-position", ":only-child", ":only-of-type", "opacity", "opacity()", |
|
140 | 141 | ":optional", "order", "@ornaments", "ornaments()", "orphans", "outline", |
|
141 | 142 | "outline-color", "outline-offset", "outline-style", "outline-width", |
|
142 | 143 | ":out-of-range", "overflow", "overflow-wrap", "overflow-x", "overflow-y", |
|
143 | 144 | "padding", "padding-bottom", "padding-left", "padding-right", "padding-top", |
|
144 | 145 | "@page", "page-break-after", "page-break-before", "page-break-inside", "pc", |
|
145 | 146 | "<percentage>", "perspective", "perspective()", "perspective-origin", |
|
146 | 147 | "pointer-events", "polygon()", "position", "<position>", "pt", "px", "quotes", |
|
147 | 148 | "rad", "radial-gradient()", "<ratio>", ":read-only", ":read-write", "rect()", |
|
148 | 149 | "rem", "repeat()", "::repeat-index", "::repeat-item", |
|
149 | 150 | "repeating-linear-gradient()", "repeating-radial-gradient()", ":required", |
|
150 | 151 | "resize", "<resolution>", "rgb()", "rgba()", "right", ":right", ":root", |
|
151 | 152 | "rotate()", "rotatex()", "rotatey()", "rotatez()", "rotate3d()", "ruby-align", |
|
152 | 153 | "ruby-merge", "ruby-position", "s", "saturate()", "scale()", "scalex()", |
|
153 | 154 | "scaley()", "scalez()", "scale3d()", ":scope", "scroll-behavior", |
|
154 | 155 | "::selection", "sepia()", "<shape>", "shape-image-threshold", "shape-margin", |
|
155 | 156 | "shape-outside", "skew()", "skewx()", "skewy()", "steps()", "<string>", |
|
156 | 157 | "@styleset", "styleset()", "@stylistic", "stylistic()", "@supports", "@swash", |
|
157 | 158 | "swash()", "symbol()", "table-layout", "tab-size", ":target", "text-align", |
|
158 | 159 | "text-align-last", "text-combine-upright", "text-decoration", |
|
159 | 160 | "text-decoration-color", "text-decoration-line", "text-decoration-style", |
|
160 | 161 | "text-indent", "text-orientation", "text-overflow", "text-rendering", |
|
161 | 162 | "text-shadow", "text-transform", "text-underline-position", "<time>", |
|
162 | 163 | "<timing-function>", "top", "touch-action", "transform", "transform-origin", |
|
163 | 164 | "transform-style", "transition", "transition-delay", "transition-duration", |
|
164 | 165 | "transition-property", "transition-timing-function", "translate()", |
|
165 | 166 | "translatex()", "translatey()", "translatez()", "translate3d()", "turn", |
|
166 | 167 | "unicode-bidi", "unicode-range", "unset", "<uri>", "url()", "<user-ident>", |
|
167 | 168 | ":valid", "::value", "var()", "vertical-align", "vh", "@viewport", |
|
168 | 169 | "visibility", ":visited", "vmax", "vmin", "vw", "white-space", "widows", |
|
169 | 170 | "width", "will-change", "word-break", "word-spacing", "word-wrap", |
|
170 | 171 | "writing-mode", "z-index", |
|
171 | 172 | |
|
172 | 173 | ] |
|
173 | 174 | |
|
174 | 175 | webkit_prefixed_styles = [ |
|
175 | 176 | # Webkit-prefixed styles |
|
176 | 177 | # https://developer.mozilla.org/en-US/docs/Web/CSS/Reference/Webkit_Extensions |
|
177 | 178 | "-webkit-animation", "-webkit-animation-delay", "-webkit-animation-direction", |
|
178 | 179 | "-webkit-animation-duration", "-webkit-animation-fill-mode", |
|
179 | 180 | "-webkit-animation-iteration-count", "-webkit-animation-name", |
|
180 | 181 | "-webkit-animation-play-state", "-webkit-animation-timing-function", |
|
181 | 182 | "-webkit-backface-visibility", "-webkit-border-image", "-webkit-column-count", |
|
182 | 183 | "-webkit-column-gap", "-webkit-column-width", "-webkit-column-rule", |
|
183 | 184 | "-webkit-column-rule-width", "-webkit-column-rule-style", |
|
184 | 185 | "-webkit-column-rule-color", "-webkit-columns", "-webkit-column-span", |
|
185 | 186 | "-webkit-font-feature-settings", "-webkit-font-kerning", |
|
186 | 187 | "-webkit-font-size-delta", "-webkit-font-variant-ligatures", |
|
187 | 188 | "-webkit-grid-column", "-webkit-grid-row", "-webkit-hyphens", "-webkit-mask", |
|
188 | 189 | "-webkit-mask-clip", "-webkit-mask-composite", "-webkit-mask-image", |
|
189 | 190 | "-webkit-mask-origin", "-webkit-mask-position", "-webkit-mask-repeat", |
|
190 | 191 | "-webkit-mask-size", "-webkit-perspective", "-webkit-perspective-origin", |
|
191 | 192 | "-webkit-region-fragment", "-webkit-shape-outside", "-webkit-text-emphasis", |
|
192 | 193 | "-webkit-text-emphasis-color", "-webkit-text-emphasis-position", |
|
193 | 194 | "-webkit-text-emphasis-style", "-webkit-transform", "-webkit-transform-origin", |
|
194 | 195 | "-webkit-transform-style", "-webkit-transition", "-webkit-transition-delay", |
|
195 | 196 | "-webkit-transition-duration", "-webkit-transition-property", |
|
196 | 197 | "-webkit-transition-timing-function", "-epub-word-break", "-epub-writing-mode", |
|
197 | 198 | # WebKit-prefixed properties with an unprefixed counterpart |
|
198 | 199 | "-webkit-background-clip", "-webkit-background-origin", |
|
199 | 200 | "-webkit-background-size", "-webkit-border-bottom-left-radius", |
|
200 | 201 | "-webkit-border-bottom-right-radius", "-webkit-border-radius", |
|
201 | 202 | "-webkit-border-top-left-radius", "-webkit-border-top-right-radius", |
|
202 | 203 | "-webkit-box-sizing", "-epub-caption-side", "-webkit-opacity", |
|
203 | 204 | "-epub-text-transform", |
|
204 | 205 | ] |
|
205 | 206 | |
|
206 | 207 | mozilla_prefixed_styles = [ |
|
207 | 208 | "-moz-column-count", "-moz-column-fill", "-moz-column-gap", |
|
208 | 209 | "-moz-column-width", "-moz-column-rule", "-moz-column-rule-width", |
|
209 | 210 | "-moz-column-rule-style", "-moz-column-rule-color", |
|
210 | 211 | "-moz-font-feature-settings", "-moz-font-language-override", "-moz-hyphens", |
|
211 | 212 | "-moz-text-align-last", "-moz-text-decoration-color", |
|
212 | 213 | "-moz-text-decoration-line", "-moz-text-decoration-style", |
|
213 | 214 | ] |
|
214 | 215 | |
|
215 | 216 | all_prefixed_styles = [ |
|
216 | 217 | # From http://peter.sh/experiments/vendor-prefixed-css-property-overview/ |
|
217 | 218 | "-ms-accelerator", "-webkit-app-region", "-webkit-appearance", |
|
218 | 219 | "-webkit-appearance", "-moz-appearance", "-webkit-aspect-ratio", |
|
219 | 220 | "-webkit-backdrop-filter", "backface-visibility", |
|
220 | 221 | "-webkit-backface-visibility", "backface-visibility", "backface-visibility", |
|
221 | 222 | "-webkit-background-composite", "-webkit-background-composite", "-moz-binding", |
|
222 | 223 | "-ms-block-progression", "-webkit-border-after", "-webkit-border-after", |
|
223 | 224 | "-webkit-border-after-color", "-webkit-border-after-color", |
|
224 | 225 | "-webkit-border-after-style", "-webkit-border-after-style", |
|
225 | 226 | "-webkit-border-after-width", "-webkit-border-after-width", |
|
226 | 227 | "-webkit-border-before", "-webkit-border-before", |
|
227 | 228 | "-webkit-border-before-color", "-webkit-border-before-color", |
|
228 | 229 | "-webkit-border-before-style", "-webkit-border-before-style", |
|
229 | 230 | "-webkit-border-before-width", "-webkit-border-before-width", |
|
230 | 231 | "-moz-border-bottom-colors", "-webkit-border-end", "-webkit-border-end", |
|
231 | 232 | "-moz-border-end", "-webkit-border-end-color", "-webkit-border-end-color", |
|
232 | 233 | "-moz-border-end-color", "-webkit-border-end-style", |
|
233 | 234 | "-webkit-border-end-style", "-moz-border-end-style", |
|
234 | 235 | "-webkit-border-end-width", "-webkit-border-end-width", |
|
235 | 236 | "-moz-border-end-width", "-webkit-border-fit", |
|
236 | 237 | "-webkit-border-horizontal-spacing", "-webkit-border-horizontal-spacing", |
|
237 | 238 | "-moz-border-left-colors", "-moz-border-right-colors", "-webkit-border-start", |
|
238 | 239 | "-webkit-border-start", "-moz-border-start", "-webkit-border-start-color", |
|
239 | 240 | "-webkit-border-start-color", "-moz-border-start-color", |
|
240 | 241 | "-webkit-border-start-style", "-webkit-border-start-style", |
|
241 | 242 | "-moz-border-start-style", "-webkit-border-start-width", |
|
242 | 243 | "-webkit-border-start-width", "-moz-border-start-width", |
|
243 | 244 | "-moz-border-top-colors", "-webkit-border-vertical-spacing", |
|
244 | 245 | "-webkit-border-vertical-spacing", "-webkit-box-align", "-webkit-box-align", |
|
245 | 246 | "-moz-box-align", "-webkit-box-decoration-break", |
|
246 | 247 | "-webkit-box-decoration-break", "box-decoration-break", |
|
247 | 248 | "-webkit-box-direction", "-webkit-box-direction", "-moz-box-direction", |
|
248 | 249 | "-webkit-box-flex", "-webkit-box-flex", "-moz-box-flex", |
|
249 | 250 | "-webkit-box-flex-group", "-webkit-box-flex-group", "-webkit-box-lines", |
|
250 | 251 | "-webkit-box-lines", "-webkit-box-ordinal-group", "-webkit-box-ordinal-group", |
|
251 | 252 | "-moz-box-ordinal-group", "-webkit-box-orient", "-webkit-box-orient", |
|
252 | 253 | "-moz-box-orient", "-webkit-box-pack", "-webkit-box-pack", "-moz-box-pack", |
|
253 | 254 | "-webkit-box-reflect", "-webkit-box-reflect", "clip-path", "-webkit-clip-path", |
|
254 | 255 | "clip-path", "clip-path", "-webkit-color-correction", "-webkit-column-axis", |
|
255 | 256 | "-webkit-column-break-after", "-webkit-column-break-after", |
|
256 | 257 | "-webkit-column-break-before", "-webkit-column-break-before", |
|
257 | 258 | "-webkit-column-break-inside", "-webkit-column-break-inside", |
|
258 | 259 | "-webkit-column-count", "column-count", "-moz-column-count", "column-count", |
|
259 | 260 | "column-fill", "column-fill", "-moz-column-fill", "column-fill", |
|
260 | 261 | "-webkit-column-gap", "column-gap", "-moz-column-gap", "column-gap", |
|
261 | 262 | "-webkit-column-rule", "column-rule", "-moz-column-rule", "column-rule", |
|
262 | 263 | "-webkit-column-rule-color", "column-rule-color", "-moz-column-rule-color", |
|
263 | 264 | "column-rule-color", "-webkit-column-rule-style", "column-rule-style", |
|
264 | 265 | "-moz-column-rule-style", "column-rule-style", "-webkit-column-rule-width", |
|
265 | 266 | "column-rule-width", "-moz-column-rule-width", "column-rule-width", |
|
266 | 267 | "-webkit-column-span", "column-span", "column-span", "-webkit-column-width", |
|
267 | 268 | "column-width", "-moz-column-width", "column-width", "-webkit-columns", |
|
268 | 269 | "columns", "-moz-columns", "columns", "-ms-content-zoom-chaining", |
|
269 | 270 | "-ms-content-zoom-limit", "-ms-content-zoom-limit-max", |
|
270 | 271 | "-ms-content-zoom-limit-min", "-ms-content-zoom-snap", |
|
271 | 272 | "-ms-content-zoom-snap-points", "-ms-content-zoom-snap-type", |
|
272 | 273 | "-ms-content-zooming", "-moz-control-character-visibility", |
|
273 | 274 | "-webkit-cursor-visibility", "-webkit-dashboard-region", "filter", |
|
274 | 275 | "-webkit-filter", "filter", "filter", "-ms-flex-align", "-ms-flex-item-align", |
|
275 | 276 | "-ms-flex-line-pack", "-ms-flex-negative", "-ms-flex-order", "-ms-flex-pack", |
|
276 | 277 | "-ms-flex-positive", "-ms-flex-preferred-size", "-moz-float-edge", |
|
277 | 278 | "-webkit-flow-from", "-ms-flow-from", "-webkit-flow-into", "-ms-flow-into", |
|
278 | 279 | "-webkit-font-feature-settings", "-webkit-font-feature-settings", |
|
279 | 280 | "font-feature-settings", "font-feature-settings", "font-kerning", |
|
280 | 281 | "-webkit-font-kerning", "font-kerning", "-webkit-font-size-delta", |
|
281 | 282 | "-webkit-font-size-delta", "-webkit-font-smoothing", "-webkit-font-smoothing", |
|
282 | 283 | "font-variant-ligatures", "-webkit-font-variant-ligatures", |
|
283 | 284 | "font-variant-ligatures", "-moz-force-broken-image-icon", "grid", |
|
284 | 285 | "-webkit-grid", "grid", "grid-area", "-webkit-grid-area", "grid-area", |
|
285 | 286 | "grid-auto-columns", "-webkit-grid-auto-columns", "grid-auto-columns", |
|
286 | 287 | "grid-auto-flow", "-webkit-grid-auto-flow", "grid-auto-flow", "grid-auto-rows", |
|
287 | 288 | "-webkit-grid-auto-rows", "grid-auto-rows", "grid-column", |
|
288 | 289 | "-webkit-grid-column", "grid-column", "-ms-grid-column", |
|
289 | 290 | "-ms-grid-column-align", "grid-column-end", "-webkit-grid-column-end", |
|
290 | 291 | "grid-column-end", "-ms-grid-column-span", "grid-column-start", |
|
291 | 292 | "-webkit-grid-column-start", "grid-column-start", "-ms-grid-columns", |
|
292 | 293 | "grid-row", "-webkit-grid-row", "grid-row", "-ms-grid-row", |
|
293 | 294 | "-ms-grid-row-align", "grid-row-end", "-webkit-grid-row-end", "grid-row-end", |
|
294 | 295 | "-ms-grid-row-span", "grid-row-start", "-webkit-grid-row-start", |
|
295 | 296 | "grid-row-start", "-ms-grid-rows", "grid-template", "-webkit-grid-template", |
|
296 | 297 | "grid-template", "grid-template-areas", "-webkit-grid-template-areas", |
|
297 | 298 | "grid-template-areas", "grid-template-columns", |
|
298 | 299 | "-webkit-grid-template-columns", "grid-template-columns", "grid-template-rows", |
|
299 | 300 | "-webkit-grid-template-rows", "grid-template-rows", "-ms-high-contrast-adjust", |
|
300 | 301 | "-webkit-highlight", "-webkit-hyphenate-character", |
|
301 | 302 | "-webkit-hyphenate-character", "-webkit-hyphenate-limit-after", |
|
302 | 303 | "-webkit-hyphenate-limit-before", "-ms-hyphenate-limit-chars", |
|
303 | 304 | "-webkit-hyphenate-limit-lines", "-ms-hyphenate-limit-lines", |
|
304 | 305 | "-ms-hyphenate-limit-zone", "-webkit-hyphens", "-moz-hyphens", "-ms-hyphens", |
|
305 | 306 | "-moz-image-region", "-ms-ime-align", "-webkit-initial-letter", |
|
306 | 307 | "-ms-interpolation-mode", "justify-self", "-webkit-justify-self", |
|
307 | 308 | "-webkit-line-align", "-webkit-line-box-contain", "-webkit-line-box-contain", |
|
308 | 309 | "-webkit-line-break", "-webkit-line-break", "line-break", "-webkit-line-clamp", |
|
309 | 310 | "-webkit-line-clamp", "-webkit-line-grid", "-webkit-line-snap", |
|
310 | 311 | "-webkit-locale", "-webkit-locale", "-webkit-logical-height", |
|
311 | 312 | "-webkit-logical-height", "-webkit-logical-width", "-webkit-logical-width", |
|
312 | 313 | "-webkit-margin-after", "-webkit-margin-after", |
|
313 | 314 | "-webkit-margin-after-collapse", "-webkit-margin-after-collapse", |
|
314 | 315 | "-webkit-margin-before", "-webkit-margin-before", |
|
315 | 316 | "-webkit-margin-before-collapse", "-webkit-margin-before-collapse", |
|
316 | 317 | "-webkit-margin-bottom-collapse", "-webkit-margin-bottom-collapse", |
|
317 | 318 | "-webkit-margin-collapse", "-webkit-margin-collapse", "-webkit-margin-end", |
|
318 | 319 | "-webkit-margin-end", "-moz-margin-end", "-webkit-margin-start", |
|
319 | 320 | "-webkit-margin-start", "-moz-margin-start", "-webkit-margin-top-collapse", |
|
320 | 321 | "-webkit-margin-top-collapse", "-webkit-marquee", "-webkit-marquee-direction", |
|
321 | 322 | "-webkit-marquee-increment", "-webkit-marquee-repetition", |
|
322 | 323 | "-webkit-marquee-speed", "-webkit-marquee-style", "mask", "-webkit-mask", |
|
323 | 324 | "mask", "-webkit-mask-box-image", "-webkit-mask-box-image", |
|
324 | 325 | "-webkit-mask-box-image-outset", "-webkit-mask-box-image-outset", |
|
325 | 326 | "-webkit-mask-box-image-repeat", "-webkit-mask-box-image-repeat", |
|
326 | 327 | "-webkit-mask-box-image-slice", "-webkit-mask-box-image-slice", |
|
327 | 328 | "-webkit-mask-box-image-source", "-webkit-mask-box-image-source", |
|
328 | 329 | "-webkit-mask-box-image-width", "-webkit-mask-box-image-width", |
|
329 | 330 | "-webkit-mask-clip", "-webkit-mask-clip", "-webkit-mask-composite", |
|
330 | 331 | "-webkit-mask-composite", "-webkit-mask-image", "-webkit-mask-image", |
|
331 | 332 | "-webkit-mask-origin", "-webkit-mask-origin", "-webkit-mask-position", |
|
332 | 333 | "-webkit-mask-position", "-webkit-mask-position-x", "-webkit-mask-position-x", |
|
333 | 334 | "-webkit-mask-position-y", "-webkit-mask-position-y", "-webkit-mask-repeat", |
|
334 | 335 | "-webkit-mask-repeat", "-webkit-mask-repeat-x", "-webkit-mask-repeat-x", |
|
335 | 336 | "-webkit-mask-repeat-y", "-webkit-mask-repeat-y", "-webkit-mask-size", |
|
336 | 337 | "-webkit-mask-size", "mask-source-type", "-webkit-mask-source-type", |
|
337 | 338 | "-moz-math-display", "-moz-math-variant", "-webkit-max-logical-height", |
|
338 | 339 | "-webkit-max-logical-height", "-webkit-max-logical-width", |
|
339 | 340 | "-webkit-max-logical-width", "-webkit-min-logical-height", |
|
340 | 341 | "-webkit-min-logical-height", "-webkit-min-logical-width", |
|
341 | 342 | "-webkit-min-logical-width", "-webkit-nbsp-mode", "-moz-orient", |
|
342 | 343 | "-moz-osx-font-smoothing", "-moz-outline-radius", |
|
343 | 344 | "-moz-outline-radius-bottomleft", "-moz-outline-radius-bottomright", |
|
344 | 345 | "-moz-outline-radius-topleft", "-moz-outline-radius-topright", |
|
345 | 346 | "-webkit-overflow-scrolling", "-ms-overflow-style", "-webkit-padding-after", |
|
346 | 347 | "-webkit-padding-after", "-webkit-padding-before", "-webkit-padding-before", |
|
347 | 348 | "-webkit-padding-end", "-webkit-padding-end", "-moz-padding-end", |
|
348 | 349 | "-webkit-padding-start", "-webkit-padding-start", "-moz-padding-start", |
|
349 | 350 | "perspective", "-webkit-perspective", "perspective", "perspective", |
|
350 | 351 | "perspective-origin", "-webkit-perspective-origin", "perspective-origin", |
|
351 | 352 | "perspective-origin", "-webkit-perspective-origin-x", |
|
352 | 353 | "-webkit-perspective-origin-x", "perspective-origin-x", |
|
353 | 354 | "-webkit-perspective-origin-y", "-webkit-perspective-origin-y", |
|
354 | 355 | "perspective-origin-y", "-webkit-print-color-adjust", |
|
355 | 356 | "-webkit-print-color-adjust", "-webkit-region-break-after", |
|
356 | 357 | "-webkit-region-break-before", "-webkit-region-break-inside", |
|
357 | 358 | "-webkit-region-fragment", "-webkit-rtl-ordering", "-webkit-rtl-ordering", |
|
358 | 359 | "-webkit-ruby-position", "-webkit-ruby-position", "ruby-position", |
|
359 | 360 | "-moz-script-level", "-moz-script-min-size", "-moz-script-size-multiplier", |
|
360 | 361 | "-ms-scroll-chaining", "-ms-scroll-limit", "-ms-scroll-limit-x-max", |
|
361 | 362 | "-ms-scroll-limit-x-min", "-ms-scroll-limit-y-max", "-ms-scroll-limit-y-min", |
|
362 | 363 | "-ms-scroll-rails", "-webkit-scroll-snap-coordinate", |
|
363 | 364 | "-webkit-scroll-snap-destination", "-webkit-scroll-snap-points-x", |
|
364 | 365 | "-ms-scroll-snap-points-x", "-webkit-scroll-snap-points-y", |
|
365 | 366 | "-ms-scroll-snap-points-y", "-webkit-scroll-snap-type", "-ms-scroll-snap-type", |
|
366 | 367 | "-ms-scroll-snap-x", "-ms-scroll-snap-y", "-ms-scroll-translation", |
|
367 | 368 | "-ms-scrollbar-3dlight-color", "shape-image-threshold", |
|
368 | 369 | "-webkit-shape-image-threshold", "shape-margin", "-webkit-shape-margin", |
|
369 | 370 | "shape-outside", "-webkit-shape-outside", "-moz-stack-sizing", "tab-size", |
|
370 | 371 | "tab-size", "-moz-tab-size", "-webkit-tap-highlight-color", |
|
371 | 372 | "-webkit-tap-highlight-color", "text-align-last", "-webkit-text-align-last", |
|
372 | 373 | "-moz-text-align-last", "text-align-last", "-webkit-text-combine", |
|
373 | 374 | "-webkit-text-combine", "-ms-text-combine-horizontal", "text-decoration-color", |
|
374 | 375 | "-webkit-text-decoration-color", "text-decoration-color", |
|
375 | 376 | "text-decoration-color", "text-decoration-line", |
|
376 | 377 | "-webkit-text-decoration-line", "text-decoration-line", |
|
377 | 378 | "-webkit-text-decoration-skip", "text-decoration-style", |
|
378 | 379 | "-webkit-text-decoration-style", "text-decoration-style", |
|
379 | 380 | "-webkit-text-decorations-in-effect", "-webkit-text-decorations-in-effect", |
|
380 | 381 | "-webkit-text-emphasis", "text-emphasis", "-webkit-text-emphasis-color", |
|
381 | 382 | "text-emphasis-color", "-webkit-text-emphasis-position", |
|
382 | 383 | "text-emphasis-position", "-webkit-text-emphasis-style", "text-emphasis-style", |
|
383 | 384 | "-webkit-text-fill-color", "-webkit-text-fill-color", "text-justify", |
|
384 | 385 | "-webkit-text-justify", "text-justify", "-webkit-text-orientation", |
|
385 | 386 | "-webkit-text-orientation", "text-orientation", "-webkit-text-security", |
|
386 | 387 | "-webkit-text-security", "-webkit-text-size-adjust", "-moz-text-size-adjust", |
|
387 | 388 | "-ms-text-size-adjust", "-webkit-text-stroke", "-webkit-text-stroke", |
|
388 | 389 | "-webkit-text-stroke-color", "-webkit-text-stroke-color", |
|
389 | 390 | "-webkit-text-stroke-width", "-webkit-text-stroke-width", |
|
390 | 391 | "text-underline-position", "-webkit-text-underline-position", |
|
391 | 392 | "text-underline-position", "-webkit-touch-callout", "-ms-touch-select", |
|
392 | 393 | "transform", "-webkit-transform", "transform", "transform", "transform-origin", |
|
393 | 394 | "-webkit-transform-origin", "transform-origin", "transform-origin", |
|
394 | 395 | "-webkit-transform-origin-x", "-webkit-transform-origin-x", |
|
395 | 396 | "transform-origin-x", "-webkit-transform-origin-y", |
|
396 | 397 | "-webkit-transform-origin-y", "transform-origin-y", |
|
397 | 398 | "-webkit-transform-origin-z", "-webkit-transform-origin-z", |
|
398 | 399 | "transform-origin-z", "transform-style", "-webkit-transform-style", |
|
399 | 400 | "transform-style", "transform-style", "-webkit-user-drag", "-webkit-user-drag", |
|
400 | 401 | "-moz-user-focus", "-moz-user-input", "-webkit-user-modify", |
|
401 | 402 | "-webkit-user-modify", "-moz-user-modify", "-webkit-user-select", |
|
402 | 403 | "-webkit-user-select", "-moz-user-select", "-ms-user-select", |
|
403 | 404 | "-moz-window-dragging", "-moz-window-shadow", "-ms-wrap-flow", |
|
404 | 405 | "-ms-wrap-margin", "-ms-wrap-through", "writing-mode", "-webkit-writing-mode", |
|
405 | 406 | "writing-mode", "writing-mode", |
|
406 | 407 | ] |
|
407 | 408 | |
|
408 | 409 | all_styles = standard_styles + all_prefixed_styles No newline at end of file |
@@ -1,547 +1,537 b'' | |||
|
1 | 1 | |
|
2 | 2 | |
|
3 | 3 | # Copyright (C) 2011-2023 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 | """ |
|
23 | 23 | Renderer for markup languages with ability to parse using rst or markdown |
|
24 | 24 | """ |
|
25 | 25 | |
|
26 | 26 | import re |
|
27 | 27 | import os |
|
28 | 28 | import lxml |
|
29 | 29 | import logging |
|
30 | 30 | import urllib.parse |
|
31 | import bleach | |
|
32 | 31 | import pycmarkgfm |
|
33 | 32 | |
|
34 | 33 | from mako.lookup import TemplateLookup |
|
35 | 34 | from mako.template import Template as MakoTemplate |
|
36 | 35 | |
|
37 | 36 | from docutils.core import publish_parts |
|
38 | 37 | from docutils.parsers.rst import directives |
|
39 | 38 | from docutils import writers |
|
40 | 39 | from docutils.writers import html4css1 |
|
41 | 40 | import markdown |
|
42 | 41 | |
|
43 |
from rhodecode.lib.utils2 import safe_str, |
|
|
42 | from rhodecode.lib.utils2 import safe_str, MENTIONS_REGEX | |
|
44 | 43 | |
|
45 | 44 | log = logging.getLogger(__name__) |
|
46 | 45 | |
|
47 | 46 | # default renderer used to generate automated comments |
|
48 | 47 | DEFAULT_COMMENTS_RENDERER = 'rst' |
|
49 | 48 | |
|
50 | 49 | try: |
|
51 | 50 | from lxml.html import fromstring |
|
52 | 51 | from lxml.html import tostring |
|
53 | 52 | except ImportError: |
|
54 | 53 | log.exception('Failed to import lxml') |
|
55 | 54 | fromstring = None |
|
56 | 55 | tostring = None |
|
57 | 56 | |
|
58 | 57 | |
|
59 | 58 | class CustomHTMLTranslator(writers.html4css1.HTMLTranslator): |
|
60 | 59 | """ |
|
61 | 60 | Custom HTML Translator used for sandboxing potential |
|
62 | 61 | JS injections in ref links |
|
63 | 62 | """ |
|
64 | 63 | def visit_literal_block(self, node): |
|
65 | 64 | self.body.append(self.starttag(node, 'pre', CLASS='codehilite literal-block')) |
|
66 | 65 | |
|
67 | 66 | def visit_reference(self, node): |
|
68 | 67 | if 'refuri' in node.attributes: |
|
69 | 68 | refuri = node['refuri'] |
|
70 | 69 | if ':' in refuri: |
|
71 | 70 | prefix, link = refuri.lstrip().split(':', 1) |
|
72 | 71 | prefix = prefix or '' |
|
73 | 72 | |
|
74 | 73 | if prefix.lower() == 'javascript': |
|
75 | 74 | # we don't allow javascript type of refs... |
|
76 | 75 | node['refuri'] = 'javascript:alert("SandBoxedJavascript")' |
|
77 | 76 | |
|
78 | 77 | # old style class requires this... |
|
79 | 78 | return html4css1.HTMLTranslator.visit_reference(self, node) |
|
80 | 79 | |
|
81 | 80 | |
|
82 | 81 | class RhodeCodeWriter(writers.html4css1.Writer): |
|
83 | 82 | def __init__(self): |
|
84 | 83 | super(RhodeCodeWriter, self).__init__() |
|
85 | 84 | self.translator_class = CustomHTMLTranslator |
|
86 | 85 | |
|
87 | 86 | |
|
88 | 87 | def relative_links(html_source, server_paths): |
|
89 | 88 | if not html_source: |
|
90 | 89 | return html_source |
|
91 | 90 | |
|
92 | 91 | if not fromstring and tostring: |
|
93 | 92 | return html_source |
|
94 | 93 | |
|
95 | 94 | try: |
|
96 | 95 | doc = lxml.html.fromstring(html_source) |
|
97 | 96 | except Exception: |
|
98 | 97 | return html_source |
|
99 | 98 | |
|
100 | 99 | for el in doc.cssselect('img, video'): |
|
101 | 100 | src = el.attrib.get('src') |
|
102 | 101 | if src: |
|
103 | 102 | el.attrib['src'] = relative_path(src, server_paths['raw']) |
|
104 | 103 | |
|
105 | 104 | for el in doc.cssselect('a:not(.gfm)'): |
|
106 | 105 | src = el.attrib.get('href') |
|
107 | 106 | if src: |
|
108 | 107 | raw_mode = el.attrib['href'].endswith('?raw=1') |
|
109 | 108 | if raw_mode: |
|
110 | 109 | el.attrib['href'] = relative_path(src, server_paths['raw']) |
|
111 | 110 | else: |
|
112 | 111 | el.attrib['href'] = relative_path(src, server_paths['standard']) |
|
113 | 112 | |
|
114 | 113 | return lxml.html.tostring(doc, encoding='unicode') |
|
115 | 114 | |
|
116 | 115 | |
|
117 | 116 | def relative_path(path, request_path, is_repo_file=None): |
|
118 | 117 | """ |
|
119 | 118 | relative link support, path is a rel path, and request_path is current |
|
120 | 119 | server path (not absolute) |
|
121 | 120 | |
|
122 | 121 | e.g. |
|
123 | 122 | |
|
124 | 123 | path = '../logo.png' |
|
125 | 124 | request_path= '/repo/files/path/file.md' |
|
126 | 125 | produces: '/repo/files/logo.png' |
|
127 | 126 | """ |
|
128 | 127 | # TODO(marcink): unicode/str support ? |
|
129 | 128 | # maybe=> safe_str(urllib.quote(safe_str(final_path), '/:')) |
|
130 | 129 | |
|
131 | 130 | def dummy_check(p): |
|
132 | 131 | return True # assume default is a valid file path |
|
133 | 132 | |
|
134 | 133 | is_repo_file = is_repo_file or dummy_check |
|
135 | 134 | if not path: |
|
136 | 135 | return request_path |
|
137 | 136 | |
|
138 | 137 | path = safe_str(path) |
|
139 | 138 | request_path = safe_str(request_path) |
|
140 | 139 | |
|
141 | 140 | if path.startswith(('data:', 'javascript:', '#', ':')): |
|
142 | 141 | # skip data, anchor, invalid links |
|
143 | 142 | return path |
|
144 | 143 | |
|
145 | 144 | is_absolute = bool(urllib.parse.urlparse(path).netloc) |
|
146 | 145 | if is_absolute: |
|
147 | 146 | return path |
|
148 | 147 | |
|
149 | 148 | if not request_path: |
|
150 | 149 | return path |
|
151 | 150 | |
|
152 | 151 | if path.startswith('/'): |
|
153 | 152 | path = path[1:] |
|
154 | 153 | |
|
155 | 154 | if path.startswith('./'): |
|
156 | 155 | path = path[2:] |
|
157 | 156 | |
|
158 | 157 | parts = request_path.split('/') |
|
159 | 158 | # compute how deep we need to traverse the request_path |
|
160 | 159 | depth = 0 |
|
161 | 160 | |
|
162 | 161 | if is_repo_file(request_path): |
|
163 | 162 | # if request path is a VALID file, we use a relative path with |
|
164 | 163 | # one level up |
|
165 | 164 | depth += 1 |
|
166 | 165 | |
|
167 | 166 | while path.startswith('../'): |
|
168 | 167 | depth += 1 |
|
169 | 168 | path = path[3:] |
|
170 | 169 | |
|
171 | 170 | if depth > 0: |
|
172 | 171 | parts = parts[:-depth] |
|
173 | 172 | |
|
174 | 173 | parts.append(path) |
|
175 | 174 | final_path = '/'.join(parts).lstrip('/') |
|
176 | 175 | |
|
177 | 176 | return '/' + final_path |
|
178 | 177 | |
|
179 | 178 | |
|
180 | 179 | _cached_markdown_renderer = None |
|
181 | 180 | |
|
182 | 181 | |
|
183 | 182 | def get_markdown_renderer(extensions, output_format): |
|
184 | 183 | global _cached_markdown_renderer |
|
185 | 184 | |
|
186 | 185 | if _cached_markdown_renderer is None: |
|
187 | 186 | _cached_markdown_renderer = markdown.Markdown( |
|
188 | 187 | extensions=extensions + ['legacy_attrs'], |
|
189 | 188 | output_format=output_format) |
|
190 | 189 | return _cached_markdown_renderer |
|
191 | 190 | |
|
192 | 191 | |
|
193 | 192 | def get_markdown_renderer_flavored(extensions, output_format): |
|
194 | 193 | """ |
|
195 | 194 | Dummy wrapper to mimic markdown API and render github HTML rendered |
|
196 | 195 | |
|
197 | 196 | """ |
|
198 | 197 | md = get_markdown_renderer(extensions, output_format) |
|
199 | 198 | |
|
200 | 199 | class GFM(object): |
|
201 | 200 | def convert(self, source): |
|
202 | 201 | with pycmarkgfm.parse_gfm(source) as document: |
|
203 | 202 | parsed_md = document.to_commonmark() |
|
204 | 203 | return md.convert(parsed_md) |
|
205 | 204 | |
|
206 | 205 | return GFM() |
|
207 | 206 | |
|
208 | 207 | |
|
209 | 208 | class MarkupRenderer(object): |
|
210 | 209 | RESTRUCTUREDTEXT_DISALLOWED_DIRECTIVES = ['include', 'meta', 'raw'] |
|
211 | 210 | |
|
212 | 211 | MARKDOWN_PAT = re.compile(r'\.(md|mkdn?|mdown|markdown)$', re.IGNORECASE) |
|
213 | 212 | RST_PAT = re.compile(r'\.re?st$', re.IGNORECASE) |
|
214 | 213 | JUPYTER_PAT = re.compile(r'\.(ipynb)$', re.IGNORECASE) |
|
215 | 214 | PLAIN_PAT = re.compile(r'^readme$', re.IGNORECASE) |
|
216 | 215 | |
|
217 | 216 | URL_PAT = re.compile(r'(http[s]?://(?:[a-zA-Z]|[0-9]|[$-_@.&+]' |
|
218 | 217 | r'|[!*\(\),]|(?:%[0-9a-fA-F][0-9a-fA-F]))+)') |
|
219 | 218 | |
|
220 | 219 | MENTION_PAT = re.compile(MENTIONS_REGEX) |
|
221 | 220 | |
|
222 | 221 | extensions = ['markdown.extensions.codehilite', 'markdown.extensions.extra', |
|
223 | 222 | 'markdown.extensions.def_list', 'markdown.extensions.sane_lists'] |
|
224 | 223 | |
|
225 | 224 | output_format = 'html4' |
|
226 | 225 | |
|
227 | 226 | # extension together with weights. Lower is first means we control how |
|
228 | 227 | # extensions are attached to readme names with those. |
|
229 | 228 | PLAIN_EXTS = [ |
|
230 | 229 | # prefer no extension |
|
231 | 230 | ('', 0), # special case that renders READMES names without extension |
|
232 | 231 | ('.text', 2), ('.TEXT', 2), |
|
233 | 232 | ('.txt', 3), ('.TXT', 3) |
|
234 | 233 | ] |
|
235 | 234 | |
|
236 | 235 | RST_EXTS = [ |
|
237 | 236 | ('.rst', 1), ('.rest', 1), |
|
238 | 237 | ('.RST', 2), ('.REST', 2) |
|
239 | 238 | ] |
|
240 | 239 | |
|
241 | 240 | MARKDOWN_EXTS = [ |
|
242 | 241 | ('.md', 1), ('.MD', 1), |
|
243 | 242 | ('.mkdn', 2), ('.MKDN', 2), |
|
244 | 243 | ('.mdown', 3), ('.MDOWN', 3), |
|
245 | 244 | ('.markdown', 4), ('.MARKDOWN', 4) |
|
246 | 245 | ] |
|
247 | 246 | |
|
248 | 247 | def _detect_renderer(self, source, filename=None): |
|
249 | 248 | """ |
|
250 | 249 | runs detection of what renderer should be used for generating html |
|
251 | 250 | from a markup language |
|
252 | 251 | |
|
253 | 252 | filename can be also explicitly a renderer name |
|
254 | 253 | |
|
255 | 254 | :param source: |
|
256 | 255 | :param filename: |
|
257 | 256 | """ |
|
258 | 257 | |
|
259 | 258 | if MarkupRenderer.MARKDOWN_PAT.findall(filename): |
|
260 | 259 | detected_renderer = 'markdown' |
|
261 | 260 | elif MarkupRenderer.RST_PAT.findall(filename): |
|
262 | 261 | detected_renderer = 'rst' |
|
263 | 262 | elif MarkupRenderer.JUPYTER_PAT.findall(filename): |
|
264 | 263 | detected_renderer = 'jupyter' |
|
265 | 264 | elif MarkupRenderer.PLAIN_PAT.findall(filename): |
|
266 | 265 | detected_renderer = 'plain' |
|
267 | 266 | else: |
|
268 | 267 | detected_renderer = 'plain' |
|
269 | 268 | |
|
270 | 269 | return getattr(MarkupRenderer, detected_renderer) |
|
271 | 270 | |
|
272 | 271 | @classmethod |
|
273 | 272 | def sanitize_html(cls, text): |
|
274 | # TODO: replace this with https://nh3.readthedocs.io/en/latest | |
|
275 | # bleach is abandoned and deprecated :/ | |
|
276 | ||
|
277 | from .bleach_whitelist import markdown_attrs, markdown_tags | |
|
278 | allowed_tags = markdown_tags | |
|
279 | allowed_attrs = markdown_attrs | |
|
280 | ||
|
281 | try: | |
|
282 | return bleach.clean(text, tags=allowed_tags, attributes=allowed_attrs) | |
|
283 | except Exception: | |
|
284 | return 'TEXT CANNOT BE PARSED USING SANITIZE' | |
|
273 | from .html_filters import sanitize_html | |
|
274 | return sanitize_html(text, markdown=True) | |
|
285 | 275 | |
|
286 | 276 | @classmethod |
|
287 | 277 | def renderer_from_filename(cls, filename, exclude): |
|
288 | 278 | """ |
|
289 | 279 | Detect renderer markdown/rst from filename and optionally use exclude |
|
290 | 280 | list to remove some options. This is mostly used in helpers. |
|
291 | 281 | Returns None when no renderer can be detected. |
|
292 | 282 | """ |
|
293 | 283 | def _filter(elements): |
|
294 | 284 | if isinstance(exclude, (list, tuple)): |
|
295 | 285 | return [x for x in elements if x not in exclude] |
|
296 | 286 | return elements |
|
297 | 287 | |
|
298 | 288 | if filename.endswith( |
|
299 | 289 | tuple(_filter([x[0] for x in cls.MARKDOWN_EXTS if x[0]]))): |
|
300 | 290 | return 'markdown' |
|
301 | 291 | if filename.endswith(tuple(_filter([x[0] for x in cls.RST_EXTS if x[0]]))): |
|
302 | 292 | return 'rst' |
|
303 | 293 | |
|
304 | 294 | return None |
|
305 | 295 | |
|
306 | 296 | def render(self, source, filename=None): |
|
307 | 297 | """ |
|
308 | 298 | Renders a given filename using detected renderer |
|
309 | 299 | it detects renderers based on file extension or mimetype. |
|
310 | 300 | At last it will just do a simple html replacing new lines with <br/> |
|
311 | 301 | """ |
|
312 | 302 | |
|
313 | 303 | renderer = self._detect_renderer(source, filename) |
|
314 | 304 | readme_data = renderer(source) |
|
315 | 305 | return readme_data |
|
316 | 306 | |
|
317 | 307 | @classmethod |
|
318 | 308 | def urlify_text(cls, text): |
|
319 | 309 | def url_func(match_obj): |
|
320 | 310 | url_full = match_obj.groups()[0] |
|
321 | 311 | return f'<a href="{url_full}">{url_full}</a>' |
|
322 | 312 | |
|
323 | 313 | return cls.URL_PAT.sub(url_func, text) |
|
324 | 314 | |
|
325 | 315 | @classmethod |
|
326 | 316 | def convert_mentions(cls, text, mode): |
|
327 | 317 | mention_pat = cls.MENTION_PAT |
|
328 | 318 | |
|
329 | 319 | def wrapp(match_obj): |
|
330 | 320 | uname = match_obj.groups()[0] |
|
331 | 321 | hovercard_url = "pyroutes.url('hovercard_username', {'username': '%s'});" % uname |
|
332 | 322 | |
|
333 | 323 | if mode == 'markdown': |
|
334 | 324 | tmpl = '<strong class="tooltip-hovercard" data-hovercard-alt="{uname}" data-hovercard-url="{hovercard_url}">@{uname}</strong>' |
|
335 | 325 | elif mode == 'rst': |
|
336 | 326 | tmpl = ' **@{uname}** ' |
|
337 | 327 | else: |
|
338 | 328 | raise ValueError('mode must be rst or markdown') |
|
339 | 329 | |
|
340 | 330 | return tmpl.format(**{'uname': uname, |
|
341 | 331 | 'hovercard_url': hovercard_url}) |
|
342 | 332 | |
|
343 | 333 | return mention_pat.sub(wrapp, text).strip() |
|
344 | 334 | |
|
345 | 335 | @classmethod |
|
346 | 336 | def plain(cls, source, universal_newline=True, leading_newline=True): |
|
347 | 337 | source = safe_str(source) |
|
348 | 338 | if universal_newline: |
|
349 | 339 | newline = '\n' |
|
350 | 340 | source = newline.join(source.splitlines()) |
|
351 | 341 | |
|
352 | 342 | rendered_source = cls.urlify_text(source) |
|
353 | 343 | source = '' |
|
354 | 344 | if leading_newline: |
|
355 | 345 | source += '<br />' |
|
356 | 346 | source += rendered_source.replace("\n", '<br />') |
|
357 | 347 | |
|
358 | 348 | rendered = cls.sanitize_html(source) |
|
359 | 349 | return rendered |
|
360 | 350 | |
|
361 | 351 | @classmethod |
|
362 | 352 | def markdown(cls, source, safe=True, flavored=True, mentions=False, |
|
363 | 353 | clean_html=True): |
|
364 | 354 | """ |
|
365 | 355 | returns markdown rendered code cleaned by the bleach library |
|
366 | 356 | """ |
|
367 | 357 | |
|
368 | 358 | if flavored: |
|
369 | 359 | markdown_renderer = get_markdown_renderer_flavored( |
|
370 | 360 | cls.extensions, cls.output_format) |
|
371 | 361 | else: |
|
372 | 362 | markdown_renderer = get_markdown_renderer( |
|
373 | 363 | cls.extensions, cls.output_format) |
|
374 | 364 | |
|
375 | 365 | if mentions: |
|
376 | 366 | mention_hl = cls.convert_mentions(source, mode='markdown') |
|
377 | 367 | # we extracted mentions render with this using Mentions false |
|
378 | 368 | return cls.markdown(mention_hl, safe=safe, flavored=flavored, |
|
379 | 369 | mentions=False) |
|
380 | 370 | |
|
381 | 371 | try: |
|
382 | 372 | rendered = markdown_renderer.convert(source) |
|
383 | 373 | |
|
384 | 374 | except Exception: |
|
385 | 375 | log.exception('Error when rendering Markdown') |
|
386 | 376 | if safe: |
|
387 | 377 | log.debug('Fallback to render in plain mode') |
|
388 | 378 | rendered = cls.plain(source) |
|
389 | 379 | else: |
|
390 | 380 | raise |
|
391 | 381 | |
|
392 | 382 | if clean_html: |
|
393 | 383 | rendered = cls.sanitize_html(rendered) |
|
394 | 384 | return rendered |
|
395 | 385 | |
|
396 | 386 | @classmethod |
|
397 | 387 | def rst(cls, source, safe=True, mentions=False, clean_html=False): |
|
398 | 388 | |
|
399 | 389 | if mentions: |
|
400 | 390 | mention_hl = cls.convert_mentions(source, mode='rst') |
|
401 | 391 | # we extracted mentions render with this using Mentions false |
|
402 | 392 | return cls.rst(mention_hl, safe=safe, mentions=False) |
|
403 | 393 | |
|
404 | 394 | source = safe_str(source) |
|
405 | 395 | try: |
|
406 | 396 | docutils_settings = dict( |
|
407 | 397 | [(alias, None) for alias in |
|
408 | 398 | cls.RESTRUCTUREDTEXT_DISALLOWED_DIRECTIVES]) |
|
409 | 399 | |
|
410 | 400 | docutils_settings.update({ |
|
411 | 401 | 'input_encoding': 'unicode', |
|
412 | 402 | 'report_level': 4, |
|
413 | 403 | 'syntax_highlight': 'short', |
|
414 | 404 | }) |
|
415 | 405 | |
|
416 | 406 | for k, v in list(docutils_settings.items()): |
|
417 | 407 | directives.register_directive(k, v) |
|
418 | 408 | |
|
419 | 409 | parts = publish_parts(source=source, |
|
420 | 410 | writer=RhodeCodeWriter(), |
|
421 | 411 | settings_overrides=docutils_settings) |
|
422 | 412 | rendered = parts["fragment"] |
|
423 | 413 | if clean_html: |
|
424 | 414 | rendered = cls.sanitize_html(rendered) |
|
425 | 415 | return parts['html_title'] + rendered |
|
426 | 416 | except Exception: |
|
427 | 417 | log.exception('Error when rendering RST') |
|
428 | 418 | if safe: |
|
429 | 419 | log.debug('Fallback to render in plain mode') |
|
430 | 420 | return cls.plain(source) |
|
431 | 421 | else: |
|
432 | 422 | raise |
|
433 | 423 | |
|
434 | 424 | @classmethod |
|
435 | 425 | def jupyter(cls, source, safe=True): |
|
436 | 426 | from rhodecode.lib import helpers |
|
437 | 427 | |
|
438 | 428 | from traitlets.config import Config |
|
439 | 429 | import nbformat |
|
440 | 430 | from nbconvert import HTMLExporter |
|
441 | 431 | from nbconvert.preprocessors import Preprocessor |
|
442 | 432 | |
|
443 | 433 | class CustomHTMLExporter(HTMLExporter): |
|
444 | 434 | def _template_file_default(self): |
|
445 | 435 | return 'basic' |
|
446 | 436 | |
|
447 | 437 | class Sandbox(Preprocessor): |
|
448 | 438 | |
|
449 | 439 | def preprocess(self, nb, resources): |
|
450 | 440 | sandbox_text = 'SandBoxed(IPython.core.display.Javascript object)' |
|
451 | 441 | for cell in nb['cells']: |
|
452 | 442 | if not safe: |
|
453 | 443 | continue |
|
454 | 444 | |
|
455 | 445 | if 'outputs' in cell: |
|
456 | 446 | for cell_output in cell['outputs']: |
|
457 | 447 | if 'data' in cell_output: |
|
458 | 448 | if 'application/javascript' in cell_output['data']: |
|
459 | 449 | cell_output['data']['text/plain'] = sandbox_text |
|
460 | 450 | cell_output['data'].pop('application/javascript', None) |
|
461 | 451 | |
|
462 | 452 | if 'source' in cell and cell['cell_type'] == 'markdown': |
|
463 | 453 | # sanitize similar like in markdown |
|
464 | 454 | cell['source'] = cls.sanitize_html(cell['source']) |
|
465 | 455 | |
|
466 | 456 | return nb, resources |
|
467 | 457 | |
|
468 | 458 | def _sanitize_resources(input_resources): |
|
469 | 459 | """ |
|
470 | 460 | Skip/sanitize some of the CSS generated and included in jupyter |
|
471 | 461 | so it doesn't messes up UI so much |
|
472 | 462 | """ |
|
473 | 463 | |
|
474 | 464 | # TODO(marcink): probably we should replace this with whole custom |
|
475 | 465 | # CSS set that doesn't screw up, but jupyter generated html has some |
|
476 | 466 | # special markers, so it requires Custom HTML exporter template with |
|
477 | 467 | # _default_template_path_default, to achieve that |
|
478 | 468 | |
|
479 | 469 | # strip the reset CSS |
|
480 | 470 | input_resources[0] = input_resources[0][input_resources[0].find('/*! Source'):] |
|
481 | 471 | return input_resources |
|
482 | 472 | |
|
483 | 473 | def as_html(notebook): |
|
484 | 474 | conf = Config() |
|
485 | 475 | conf.CustomHTMLExporter.preprocessors = [Sandbox] |
|
486 | 476 | html_exporter = CustomHTMLExporter(config=conf) |
|
487 | 477 | |
|
488 | 478 | (body, resources) = html_exporter.from_notebook_node(notebook) |
|
489 | 479 | header = '<!-- ## IPYTHON NOTEBOOK RENDERING ## -->' |
|
490 | 480 | js = MakoTemplate(r''' |
|
491 | 481 | <!-- MathJax configuration --> |
|
492 | 482 | <script type="text/x-mathjax-config"> |
|
493 | 483 | MathJax.Hub.Config({ |
|
494 | 484 | jax: ["input/TeX","output/HTML-CSS", "output/PreviewHTML"], |
|
495 | 485 | extensions: ["tex2jax.js","MathMenu.js","MathZoom.js", "fast-preview.js", "AssistiveMML.js", "[Contrib]/a11y/accessibility-menu.js"], |
|
496 | 486 | TeX: { |
|
497 | 487 | extensions: ["AMSmath.js","AMSsymbols.js","noErrors.js","noUndefined.js"] |
|
498 | 488 | }, |
|
499 | 489 | tex2jax: { |
|
500 | 490 | inlineMath: [ ['$','$'], ["\\(","\\)"] ], |
|
501 | 491 | displayMath: [ ['$$','$$'], ["\\[","\\]"] ], |
|
502 | 492 | processEscapes: true, |
|
503 | 493 | processEnvironments: true |
|
504 | 494 | }, |
|
505 | 495 | // Center justify equations in code and markdown cells. Elsewhere |
|
506 | 496 | // we use CSS to left justify single line equations in code cells. |
|
507 | 497 | displayAlign: 'center', |
|
508 | 498 | "HTML-CSS": { |
|
509 | 499 | styles: {'.MathJax_Display': {"margin": 0}}, |
|
510 | 500 | linebreaks: { automatic: true }, |
|
511 | 501 | availableFonts: ["STIX", "TeX"] |
|
512 | 502 | }, |
|
513 | 503 | showMathMenu: false |
|
514 | 504 | }); |
|
515 | 505 | </script> |
|
516 | 506 | <!-- End of MathJax configuration --> |
|
517 | 507 | <script src="${h.asset('js/src/math_jax/MathJax.js')}"></script> |
|
518 | 508 | ''').render(h=helpers) |
|
519 | 509 | |
|
520 | 510 | css = MakoTemplate(r''' |
|
521 | 511 | <link rel="stylesheet" type="text/css" href="${h.asset('css/style-ipython.css', ver=ver)}" media="screen"/> |
|
522 | 512 | ''').render(h=helpers, ver='ver1') |
|
523 | 513 | |
|
524 | 514 | body = '\n'.join([header, css, js, body]) |
|
525 | 515 | return body, resources |
|
526 | 516 | |
|
527 | 517 | notebook = nbformat.reads(source, as_version=4) |
|
528 | 518 | (body, resources) = as_html(notebook) |
|
529 | 519 | return body |
|
530 | 520 | |
|
531 | 521 | |
|
532 | 522 | class RstTemplateRenderer(object): |
|
533 | 523 | |
|
534 | 524 | def __init__(self): |
|
535 | 525 | base = os.path.abspath(os.path.dirname(os.path.dirname(__file__))) |
|
536 | 526 | rst_template_dirs = [os.path.join(base, 'templates', 'rst_templates')] |
|
537 | 527 | self.template_store = TemplateLookup( |
|
538 | 528 | directories=rst_template_dirs, |
|
539 | 529 | input_encoding='utf-8', |
|
540 | 530 | imports=['from rhodecode.lib import helpers as h']) |
|
541 | 531 | |
|
542 | 532 | def _get_template(self, templatename): |
|
543 | 533 | return self.template_store.get_template(templatename) |
|
544 | 534 | |
|
545 | 535 | def render(self, template_name, **kwargs): |
|
546 | 536 | template = self._get_template(template_name) |
|
547 | 537 | return template.render(**kwargs) |
@@ -1,923 +1,923 b'' | |||
|
1 | 1 | # Copyright (C) 2010-2023 RhodeCode GmbH |
|
2 | 2 | # |
|
3 | 3 | # This program is free software: you can redistribute it and/or modify |
|
4 | 4 | # it under the terms of the GNU Affero General Public License, version 3 |
|
5 | 5 | # (only), as published by the Free Software Foundation. |
|
6 | 6 | # |
|
7 | 7 | # This program is distributed in the hope that it will be useful, |
|
8 | 8 | # but WITHOUT ANY WARRANTY; without even the implied warranty of |
|
9 | 9 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|
10 | 10 | # GNU General Public License for more details. |
|
11 | 11 | # |
|
12 | 12 | # You should have received a copy of the GNU Affero General Public License |
|
13 | 13 | # along with this program. If not, see <http://www.gnu.org/licenses/>. |
|
14 | 14 | # |
|
15 | 15 | # This program is dual-licensed. If you wish to learn more about the |
|
16 | 16 | # RhodeCode Enterprise Edition, including its added features, Support services, |
|
17 | 17 | # and proprietary license terms, please see https://rhodecode.com/licenses/ |
|
18 | 18 | |
|
19 | 19 | import os |
|
20 | 20 | import re |
|
21 | 21 | import logging |
|
22 | 22 | import time |
|
23 | 23 | import functools |
|
24 | import bleach | |
|
25 | 24 | from collections import namedtuple |
|
26 | 25 | |
|
27 | 26 | from pyramid.threadlocal import get_current_request |
|
28 | 27 | |
|
29 | 28 | from rhodecode.lib import rc_cache |
|
30 | 29 | from rhodecode.lib.hash_utils import sha1_safe |
|
30 | from rhodecode.lib.html_filters import sanitize_html | |
|
31 | 31 | from rhodecode.lib.utils2 import ( |
|
32 | 32 | Optional, AttributeDict, safe_str, remove_prefix, str2bool) |
|
33 | 33 | from rhodecode.lib.vcs.backends import base |
|
34 | 34 | from rhodecode.lib.statsd_client import StatsdClient |
|
35 | 35 | from rhodecode.model import BaseModel |
|
36 | 36 | from rhodecode.model.db import ( |
|
37 | 37 | RepoRhodeCodeUi, RepoRhodeCodeSetting, RhodeCodeUi, RhodeCodeSetting) |
|
38 | 38 | from rhodecode.model.meta import Session |
|
39 | 39 | |
|
40 | 40 | |
|
41 | 41 | log = logging.getLogger(__name__) |
|
42 | 42 | |
|
43 | 43 | |
|
44 | 44 | UiSetting = namedtuple( |
|
45 | 45 | 'UiSetting', ['section', 'key', 'value', 'active']) |
|
46 | 46 | |
|
47 | 47 | SOCIAL_PLUGINS_LIST = ['github', 'bitbucket', 'twitter', 'google'] |
|
48 | 48 | |
|
49 | 49 | |
|
50 | 50 | class SettingNotFound(Exception): |
|
51 | 51 | def __init__(self, setting_id): |
|
52 | 52 | msg = f'Setting `{setting_id}` is not found' |
|
53 | 53 | super().__init__(msg) |
|
54 | 54 | |
|
55 | 55 | |
|
56 | 56 | class SettingsModel(BaseModel): |
|
57 | 57 | BUILTIN_HOOKS = ( |
|
58 | 58 | RhodeCodeUi.HOOK_REPO_SIZE, RhodeCodeUi.HOOK_PUSH, |
|
59 | 59 | RhodeCodeUi.HOOK_PRE_PUSH, RhodeCodeUi.HOOK_PRETX_PUSH, |
|
60 | 60 | RhodeCodeUi.HOOK_PULL, RhodeCodeUi.HOOK_PRE_PULL, |
|
61 | 61 | RhodeCodeUi.HOOK_PUSH_KEY,) |
|
62 | 62 | HOOKS_SECTION = 'hooks' |
|
63 | 63 | |
|
64 | 64 | def __init__(self, sa=None, repo=None): |
|
65 | 65 | self.repo = repo |
|
66 | 66 | self.UiDbModel = RepoRhodeCodeUi if repo else RhodeCodeUi |
|
67 | 67 | self.SettingsDbModel = ( |
|
68 | 68 | RepoRhodeCodeSetting if repo else RhodeCodeSetting) |
|
69 | 69 | super().__init__(sa) |
|
70 | 70 | |
|
71 | 71 | def get_ui_by_key(self, key): |
|
72 | 72 | q = self.UiDbModel.query() |
|
73 | 73 | q = q.filter(self.UiDbModel.ui_key == key) |
|
74 | 74 | q = self._filter_by_repo(RepoRhodeCodeUi, q) |
|
75 | 75 | return q.scalar() |
|
76 | 76 | |
|
77 | 77 | def get_ui_by_section(self, section): |
|
78 | 78 | q = self.UiDbModel.query() |
|
79 | 79 | q = q.filter(self.UiDbModel.ui_section == section) |
|
80 | 80 | q = self._filter_by_repo(RepoRhodeCodeUi, q) |
|
81 | 81 | return q.all() |
|
82 | 82 | |
|
83 | 83 | def get_ui_by_section_and_key(self, section, key): |
|
84 | 84 | q = self.UiDbModel.query() |
|
85 | 85 | q = q.filter(self.UiDbModel.ui_section == section) |
|
86 | 86 | q = q.filter(self.UiDbModel.ui_key == key) |
|
87 | 87 | q = self._filter_by_repo(RepoRhodeCodeUi, q) |
|
88 | 88 | return q.scalar() |
|
89 | 89 | |
|
90 | 90 | def get_ui(self, section=None, key=None): |
|
91 | 91 | q = self.UiDbModel.query() |
|
92 | 92 | q = self._filter_by_repo(RepoRhodeCodeUi, q) |
|
93 | 93 | |
|
94 | 94 | if section: |
|
95 | 95 | q = q.filter(self.UiDbModel.ui_section == section) |
|
96 | 96 | if key: |
|
97 | 97 | q = q.filter(self.UiDbModel.ui_key == key) |
|
98 | 98 | |
|
99 | 99 | # TODO: mikhail: add caching |
|
100 | 100 | result = [ |
|
101 | 101 | UiSetting( |
|
102 | 102 | section=safe_str(r.ui_section), key=safe_str(r.ui_key), |
|
103 | 103 | value=safe_str(r.ui_value), active=r.ui_active |
|
104 | 104 | ) |
|
105 | 105 | for r in q.all() |
|
106 | 106 | ] |
|
107 | 107 | return result |
|
108 | 108 | |
|
109 | 109 | def get_builtin_hooks(self): |
|
110 | 110 | q = self.UiDbModel.query() |
|
111 | 111 | q = q.filter(self.UiDbModel.ui_key.in_(self.BUILTIN_HOOKS)) |
|
112 | 112 | return self._get_hooks(q) |
|
113 | 113 | |
|
114 | 114 | def get_custom_hooks(self): |
|
115 | 115 | q = self.UiDbModel.query() |
|
116 | 116 | q = q.filter(~self.UiDbModel.ui_key.in_(self.BUILTIN_HOOKS)) |
|
117 | 117 | return self._get_hooks(q) |
|
118 | 118 | |
|
119 | 119 | def create_ui_section_value(self, section, val, key=None, active=True): |
|
120 | 120 | new_ui = self.UiDbModel() |
|
121 | 121 | new_ui.ui_section = section |
|
122 | 122 | new_ui.ui_value = val |
|
123 | 123 | new_ui.ui_active = active |
|
124 | 124 | |
|
125 | 125 | repository_id = '' |
|
126 | 126 | if self.repo: |
|
127 | 127 | repo = self._get_repo(self.repo) |
|
128 | 128 | repository_id = repo.repo_id |
|
129 | 129 | new_ui.repository_id = repository_id |
|
130 | 130 | |
|
131 | 131 | if not key: |
|
132 | 132 | # keys are unique so they need appended info |
|
133 | 133 | if self.repo: |
|
134 | 134 | key = sha1_safe(f'{section}{val}{repository_id}') |
|
135 | 135 | else: |
|
136 | 136 | key = sha1_safe(f'{section}{val}') |
|
137 | 137 | |
|
138 | 138 | new_ui.ui_key = key |
|
139 | 139 | |
|
140 | 140 | Session().add(new_ui) |
|
141 | 141 | return new_ui |
|
142 | 142 | |
|
143 | 143 | def create_or_update_hook(self, key, value): |
|
144 | 144 | ui = ( |
|
145 | 145 | self.get_ui_by_section_and_key(self.HOOKS_SECTION, key) or |
|
146 | 146 | self.UiDbModel()) |
|
147 | 147 | ui.ui_section = self.HOOKS_SECTION |
|
148 | 148 | ui.ui_active = True |
|
149 | 149 | ui.ui_key = key |
|
150 | 150 | ui.ui_value = value |
|
151 | 151 | |
|
152 | 152 | if self.repo: |
|
153 | 153 | repo = self._get_repo(self.repo) |
|
154 | 154 | repository_id = repo.repo_id |
|
155 | 155 | ui.repository_id = repository_id |
|
156 | 156 | |
|
157 | 157 | Session().add(ui) |
|
158 | 158 | return ui |
|
159 | 159 | |
|
160 | 160 | def delete_ui(self, id_): |
|
161 | 161 | ui = self.UiDbModel.get(id_) |
|
162 | 162 | if not ui: |
|
163 | 163 | raise SettingNotFound(id_) |
|
164 | 164 | Session().delete(ui) |
|
165 | 165 | |
|
166 | 166 | def get_setting_by_name(self, name): |
|
167 | 167 | q = self._get_settings_query() |
|
168 | 168 | q = q.filter(self.SettingsDbModel.app_settings_name == name) |
|
169 | 169 | return q.scalar() |
|
170 | 170 | |
|
171 | 171 | def create_or_update_setting( |
|
172 | 172 | self, name, val=Optional(''), type_=Optional('unicode')): |
|
173 | 173 | """ |
|
174 | 174 | Creates or updates RhodeCode setting. If updates is triggered it will |
|
175 | 175 | only update parameters that are explicitly set Optional instance will |
|
176 | 176 | be skipped |
|
177 | 177 | |
|
178 | 178 | :param name: |
|
179 | 179 | :param val: |
|
180 | 180 | :param type_: |
|
181 | 181 | :return: |
|
182 | 182 | """ |
|
183 | 183 | |
|
184 | 184 | res = self.get_setting_by_name(name) |
|
185 | 185 | repo = self._get_repo(self.repo) if self.repo else None |
|
186 | 186 | |
|
187 | 187 | if not res: |
|
188 | 188 | val = Optional.extract(val) |
|
189 | 189 | type_ = Optional.extract(type_) |
|
190 | 190 | |
|
191 | 191 | args = ( |
|
192 | 192 | (repo.repo_id, name, val, type_) |
|
193 | 193 | if repo else (name, val, type_)) |
|
194 | 194 | res = self.SettingsDbModel(*args) |
|
195 | 195 | |
|
196 | 196 | else: |
|
197 | 197 | if self.repo: |
|
198 | 198 | res.repository_id = repo.repo_id |
|
199 | 199 | |
|
200 | 200 | res.app_settings_name = name |
|
201 | 201 | if not isinstance(type_, Optional): |
|
202 | 202 | # update if set |
|
203 | 203 | res.app_settings_type = type_ |
|
204 | 204 | if not isinstance(val, Optional): |
|
205 | 205 | # update if set |
|
206 | 206 | res.app_settings_value = val |
|
207 | 207 | |
|
208 | 208 | Session().add(res) |
|
209 | 209 | return res |
|
210 | 210 | |
|
211 | 211 | def get_cache_region(self): |
|
212 | 212 | repo = self._get_repo(self.repo) if self.repo else None |
|
213 | 213 | cache_key = f"repo.{repo.repo_id}" if repo else "repo.ALL" |
|
214 | 214 | cache_namespace_uid = f'cache_settings.{cache_key}' |
|
215 | 215 | region = rc_cache.get_or_create_region('cache_general', cache_namespace_uid) |
|
216 | 216 | return region, cache_namespace_uid |
|
217 | 217 | |
|
218 | 218 | def invalidate_settings_cache(self, hard=False): |
|
219 | 219 | region, namespace_key = self.get_cache_region() |
|
220 | 220 | log.debug('Invalidation cache [%s] region %s for cache_key: %s', |
|
221 | 221 | 'invalidate_settings_cache', region, namespace_key) |
|
222 | 222 | |
|
223 | 223 | # we use hard cleanup if invalidation is sent |
|
224 | 224 | rc_cache.clear_cache_namespace(region, namespace_key, method=rc_cache.CLEAR_DELETE) |
|
225 | 225 | |
|
226 | 226 | def get_cache_call_method(self, cache=True): |
|
227 | 227 | region, cache_key = self.get_cache_region() |
|
228 | 228 | |
|
229 | 229 | @region.conditional_cache_on_arguments(condition=cache) |
|
230 | 230 | def _get_all_settings(name, key): |
|
231 | 231 | q = self._get_settings_query() |
|
232 | 232 | if not q: |
|
233 | 233 | raise Exception('Could not get application settings !') |
|
234 | 234 | |
|
235 | 235 | settings = { |
|
236 | 236 | f'rhodecode_{res.app_settings_name}': res.app_settings_value |
|
237 | 237 | for res in q |
|
238 | 238 | } |
|
239 | 239 | return settings |
|
240 | 240 | return _get_all_settings |
|
241 | 241 | |
|
242 | 242 | def get_all_settings(self, cache=False, from_request=True): |
|
243 | 243 | # defines if we use GLOBAL, or PER_REPO |
|
244 | 244 | repo = self._get_repo(self.repo) if self.repo else None |
|
245 | 245 | |
|
246 | 246 | # initially try the requests context, this is the fastest |
|
247 | 247 | # we only fetch global config, NOT for repo-specific |
|
248 | 248 | if from_request and not repo: |
|
249 | 249 | request = get_current_request() |
|
250 | 250 | |
|
251 | 251 | if request and hasattr(request, 'call_context') and hasattr(request.call_context, 'rc_config'): |
|
252 | 252 | rc_config = request.call_context.rc_config |
|
253 | 253 | if rc_config: |
|
254 | 254 | return rc_config |
|
255 | 255 | |
|
256 | 256 | _region, cache_key = self.get_cache_region() |
|
257 | 257 | _get_all_settings = self.get_cache_call_method(cache=cache) |
|
258 | 258 | |
|
259 | 259 | start = time.time() |
|
260 | 260 | result = _get_all_settings('rhodecode_settings', cache_key) |
|
261 | 261 | compute_time = time.time() - start |
|
262 | 262 | log.debug('cached method:%s took %.4fs', _get_all_settings.__name__, compute_time) |
|
263 | 263 | |
|
264 | 264 | statsd = StatsdClient.statsd |
|
265 | 265 | if statsd: |
|
266 | 266 | elapsed_time_ms = round(1000.0 * compute_time) # use ms only |
|
267 | 267 | statsd.timing("rhodecode_settings_timing.histogram", elapsed_time_ms, |
|
268 | 268 | use_decimals=False) |
|
269 | 269 | |
|
270 | 270 | log.debug('Fetching app settings for key: %s took: %.4fs: cache: %s', cache_key, compute_time, cache) |
|
271 | 271 | |
|
272 | 272 | return result |
|
273 | 273 | |
|
274 | 274 | def get_auth_settings(self): |
|
275 | 275 | q = self._get_settings_query() |
|
276 | 276 | q = q.filter( |
|
277 | 277 | self.SettingsDbModel.app_settings_name.startswith('auth_')) |
|
278 | 278 | rows = q.all() |
|
279 | 279 | auth_settings = { |
|
280 | 280 | row.app_settings_name: row.app_settings_value for row in rows} |
|
281 | 281 | return auth_settings |
|
282 | 282 | |
|
283 | 283 | def get_auth_plugins(self): |
|
284 | 284 | auth_plugins = self.get_setting_by_name("auth_plugins") |
|
285 | 285 | return auth_plugins.app_settings_value |
|
286 | 286 | |
|
287 | 287 | def get_default_repo_settings(self, strip_prefix=False): |
|
288 | 288 | q = self._get_settings_query() |
|
289 | 289 | q = q.filter( |
|
290 | 290 | self.SettingsDbModel.app_settings_name.startswith('default_')) |
|
291 | 291 | rows = q.all() |
|
292 | 292 | |
|
293 | 293 | result = {} |
|
294 | 294 | for row in rows: |
|
295 | 295 | key = row.app_settings_name |
|
296 | 296 | if strip_prefix: |
|
297 | 297 | key = remove_prefix(key, prefix='default_') |
|
298 | 298 | result.update({key: row.app_settings_value}) |
|
299 | 299 | return result |
|
300 | 300 | |
|
301 | 301 | def get_repo(self): |
|
302 | 302 | repo = self._get_repo(self.repo) |
|
303 | 303 | if not repo: |
|
304 | 304 | raise Exception( |
|
305 | 305 | 'Repository `{}` cannot be found inside the database'.format( |
|
306 | 306 | self.repo)) |
|
307 | 307 | return repo |
|
308 | 308 | |
|
309 | 309 | def _filter_by_repo(self, model, query): |
|
310 | 310 | if self.repo: |
|
311 | 311 | repo = self.get_repo() |
|
312 | 312 | query = query.filter(model.repository_id == repo.repo_id) |
|
313 | 313 | return query |
|
314 | 314 | |
|
315 | 315 | def _get_hooks(self, query): |
|
316 | 316 | query = query.filter(self.UiDbModel.ui_section == self.HOOKS_SECTION) |
|
317 | 317 | query = self._filter_by_repo(RepoRhodeCodeUi, query) |
|
318 | 318 | return query.all() |
|
319 | 319 | |
|
320 | 320 | def _get_settings_query(self): |
|
321 | 321 | q = self.SettingsDbModel.query() |
|
322 | 322 | return self._filter_by_repo(RepoRhodeCodeSetting, q) |
|
323 | 323 | |
|
324 | 324 | def list_enabled_social_plugins(self, settings): |
|
325 | 325 | enabled = [] |
|
326 | 326 | for plug in SOCIAL_PLUGINS_LIST: |
|
327 | 327 | if str2bool(settings.get(f'rhodecode_auth_{plug}_enabled')): |
|
328 | 328 | enabled.append(plug) |
|
329 | 329 | return enabled |
|
330 | 330 | |
|
331 | 331 | |
|
332 | 332 | def assert_repo_settings(func): |
|
333 | 333 | @functools.wraps(func) |
|
334 | 334 | def _wrapper(self, *args, **kwargs): |
|
335 | 335 | if not self.repo_settings: |
|
336 | 336 | raise Exception('Repository is not specified') |
|
337 | 337 | return func(self, *args, **kwargs) |
|
338 | 338 | return _wrapper |
|
339 | 339 | |
|
340 | 340 | |
|
341 | 341 | class IssueTrackerSettingsModel(object): |
|
342 | 342 | INHERIT_SETTINGS = 'inherit_issue_tracker_settings' |
|
343 | 343 | SETTINGS_PREFIX = 'issuetracker_' |
|
344 | 344 | |
|
345 | 345 | def __init__(self, sa=None, repo=None): |
|
346 | 346 | self.global_settings = SettingsModel(sa=sa) |
|
347 | 347 | self.repo_settings = SettingsModel(sa=sa, repo=repo) if repo else None |
|
348 | 348 | |
|
349 | 349 | @property |
|
350 | 350 | def inherit_global_settings(self): |
|
351 | 351 | if not self.repo_settings: |
|
352 | 352 | return True |
|
353 | 353 | setting = self.repo_settings.get_setting_by_name(self.INHERIT_SETTINGS) |
|
354 | 354 | return setting.app_settings_value if setting else True |
|
355 | 355 | |
|
356 | 356 | @inherit_global_settings.setter |
|
357 | 357 | def inherit_global_settings(self, value): |
|
358 | 358 | if self.repo_settings: |
|
359 | 359 | settings = self.repo_settings.create_or_update_setting( |
|
360 | 360 | self.INHERIT_SETTINGS, value, type_='bool') |
|
361 | 361 | Session().add(settings) |
|
362 | 362 | |
|
363 | 363 | def _get_keyname(self, key, uid, prefix=''): |
|
364 | 364 | return '{}{}{}_{}'.format( |
|
365 | 365 | prefix, self.SETTINGS_PREFIX, key, uid) |
|
366 | 366 | |
|
367 | 367 | def _make_dict_for_settings(self, qs): |
|
368 | 368 | prefix_match = self._get_keyname('pat', '', 'rhodecode_') |
|
369 | 369 | |
|
370 | 370 | issuetracker_entries = {} |
|
371 | 371 | # create keys |
|
372 | 372 | for k, v in qs.items(): |
|
373 | 373 | if k.startswith(prefix_match): |
|
374 | 374 | uid = k[len(prefix_match):] |
|
375 | 375 | issuetracker_entries[uid] = None |
|
376 | 376 | |
|
377 | 377 | def url_cleaner(input_str): |
|
378 | 378 | input_str = input_str.replace('"', '').replace("'", '') |
|
379 |
input_str = |
|
|
379 | input_str = sanitize_html(input_str, strip=True) | |
|
380 | 380 | return input_str |
|
381 | 381 | |
|
382 | 382 | # populate |
|
383 | 383 | for uid in issuetracker_entries: |
|
384 | 384 | url_data = qs.get(self._get_keyname('url', uid, 'rhodecode_')) |
|
385 | 385 | |
|
386 | 386 | pat = qs.get(self._get_keyname('pat', uid, 'rhodecode_')) |
|
387 | 387 | try: |
|
388 | 388 | pat_compiled = re.compile(r'%s' % pat) |
|
389 | 389 | except re.error: |
|
390 | 390 | pat_compiled = None |
|
391 | 391 | |
|
392 | 392 | issuetracker_entries[uid] = AttributeDict({ |
|
393 | 393 | 'pat': pat, |
|
394 | 394 | 'pat_compiled': pat_compiled, |
|
395 | 395 | 'url': url_cleaner( |
|
396 | 396 | qs.get(self._get_keyname('url', uid, 'rhodecode_')) or ''), |
|
397 |
'pref': |
|
|
397 | 'pref': sanitize_html( | |
|
398 | 398 | qs.get(self._get_keyname('pref', uid, 'rhodecode_')) or ''), |
|
399 | 399 | 'desc': qs.get( |
|
400 | 400 | self._get_keyname('desc', uid, 'rhodecode_')), |
|
401 | 401 | }) |
|
402 | 402 | |
|
403 | 403 | return issuetracker_entries |
|
404 | 404 | |
|
405 | 405 | def get_global_settings(self, cache=False): |
|
406 | 406 | """ |
|
407 | 407 | Returns list of global issue tracker settings |
|
408 | 408 | """ |
|
409 | 409 | defaults = self.global_settings.get_all_settings(cache=cache) |
|
410 | 410 | settings = self._make_dict_for_settings(defaults) |
|
411 | 411 | return settings |
|
412 | 412 | |
|
413 | 413 | def get_repo_settings(self, cache=False): |
|
414 | 414 | """ |
|
415 | 415 | Returns list of issue tracker settings per repository |
|
416 | 416 | """ |
|
417 | 417 | if not self.repo_settings: |
|
418 | 418 | raise Exception('Repository is not specified') |
|
419 | 419 | all_settings = self.repo_settings.get_all_settings(cache=cache) |
|
420 | 420 | settings = self._make_dict_for_settings(all_settings) |
|
421 | 421 | return settings |
|
422 | 422 | |
|
423 | 423 | def get_settings(self, cache=False): |
|
424 | 424 | if self.inherit_global_settings: |
|
425 | 425 | return self.get_global_settings(cache=cache) |
|
426 | 426 | else: |
|
427 | 427 | return self.get_repo_settings(cache=cache) |
|
428 | 428 | |
|
429 | 429 | def delete_entries(self, uid): |
|
430 | 430 | if self.repo_settings: |
|
431 | 431 | all_patterns = self.get_repo_settings() |
|
432 | 432 | settings_model = self.repo_settings |
|
433 | 433 | else: |
|
434 | 434 | all_patterns = self.get_global_settings() |
|
435 | 435 | settings_model = self.global_settings |
|
436 | 436 | entries = all_patterns.get(uid, []) |
|
437 | 437 | |
|
438 | 438 | for del_key in entries: |
|
439 | 439 | setting_name = self._get_keyname(del_key, uid) |
|
440 | 440 | entry = settings_model.get_setting_by_name(setting_name) |
|
441 | 441 | if entry: |
|
442 | 442 | Session().delete(entry) |
|
443 | 443 | |
|
444 | 444 | Session().commit() |
|
445 | 445 | |
|
446 | 446 | def create_or_update_setting( |
|
447 | 447 | self, name, val=Optional(''), type_=Optional('unicode')): |
|
448 | 448 | if self.repo_settings: |
|
449 | 449 | setting = self.repo_settings.create_or_update_setting( |
|
450 | 450 | name, val, type_) |
|
451 | 451 | else: |
|
452 | 452 | setting = self.global_settings.create_or_update_setting( |
|
453 | 453 | name, val, type_) |
|
454 | 454 | return setting |
|
455 | 455 | |
|
456 | 456 | |
|
457 | 457 | class VcsSettingsModel(object): |
|
458 | 458 | |
|
459 | 459 | INHERIT_SETTINGS = 'inherit_vcs_settings' |
|
460 | 460 | GENERAL_SETTINGS = ( |
|
461 | 461 | 'use_outdated_comments', |
|
462 | 462 | 'pr_merge_enabled', |
|
463 | 463 | 'hg_use_rebase_for_merging', |
|
464 | 464 | 'hg_close_branch_before_merging', |
|
465 | 465 | 'git_use_rebase_for_merging', |
|
466 | 466 | 'git_close_branch_before_merging', |
|
467 | 467 | 'diff_cache', |
|
468 | 468 | ) |
|
469 | 469 | |
|
470 | 470 | HOOKS_SETTINGS = ( |
|
471 | 471 | ('hooks', 'changegroup.repo_size'), |
|
472 | 472 | ('hooks', 'changegroup.push_logger'), |
|
473 | 473 | ('hooks', 'outgoing.pull_logger'), |
|
474 | 474 | ) |
|
475 | 475 | HG_SETTINGS = ( |
|
476 | 476 | ('extensions', 'largefiles'), |
|
477 | 477 | ('phases', 'publish'), |
|
478 | 478 | ('extensions', 'evolve'), |
|
479 | 479 | ('extensions', 'topic'), |
|
480 | 480 | ('experimental', 'evolution'), |
|
481 | 481 | ('experimental', 'evolution.exchange'), |
|
482 | 482 | ) |
|
483 | 483 | GIT_SETTINGS = ( |
|
484 | 484 | ('vcs_git_lfs', 'enabled'), |
|
485 | 485 | ) |
|
486 | 486 | GLOBAL_HG_SETTINGS = ( |
|
487 | 487 | ('extensions', 'largefiles'), |
|
488 | 488 | ('largefiles', 'usercache'), |
|
489 | 489 | ('phases', 'publish'), |
|
490 | 490 | ('extensions', 'hgsubversion'), |
|
491 | 491 | ('extensions', 'evolve'), |
|
492 | 492 | ('extensions', 'topic'), |
|
493 | 493 | ('experimental', 'evolution'), |
|
494 | 494 | ('experimental', 'evolution.exchange'), |
|
495 | 495 | ) |
|
496 | 496 | |
|
497 | 497 | GLOBAL_GIT_SETTINGS = ( |
|
498 | 498 | ('vcs_git_lfs', 'enabled'), |
|
499 | 499 | ('vcs_git_lfs', 'store_location') |
|
500 | 500 | ) |
|
501 | 501 | |
|
502 | 502 | GLOBAL_SVN_SETTINGS = ( |
|
503 | 503 | ('vcs_svn_proxy', 'http_requests_enabled'), |
|
504 | 504 | ('vcs_svn_proxy', 'http_server_url') |
|
505 | 505 | ) |
|
506 | 506 | |
|
507 | 507 | SVN_BRANCH_SECTION = 'vcs_svn_branch' |
|
508 | 508 | SVN_TAG_SECTION = 'vcs_svn_tag' |
|
509 | 509 | SSL_SETTING = ('web', 'push_ssl') |
|
510 | 510 | PATH_SETTING = ('paths', '/') |
|
511 | 511 | |
|
512 | 512 | def __init__(self, sa=None, repo=None): |
|
513 | 513 | self.global_settings = SettingsModel(sa=sa) |
|
514 | 514 | self.repo_settings = SettingsModel(sa=sa, repo=repo) if repo else None |
|
515 | 515 | self._ui_settings = ( |
|
516 | 516 | self.HG_SETTINGS + self.GIT_SETTINGS + self.HOOKS_SETTINGS) |
|
517 | 517 | self._svn_sections = (self.SVN_BRANCH_SECTION, self.SVN_TAG_SECTION) |
|
518 | 518 | |
|
519 | 519 | @property |
|
520 | 520 | @assert_repo_settings |
|
521 | 521 | def inherit_global_settings(self): |
|
522 | 522 | setting = self.repo_settings.get_setting_by_name(self.INHERIT_SETTINGS) |
|
523 | 523 | return setting.app_settings_value if setting else True |
|
524 | 524 | |
|
525 | 525 | @inherit_global_settings.setter |
|
526 | 526 | @assert_repo_settings |
|
527 | 527 | def inherit_global_settings(self, value): |
|
528 | 528 | self.repo_settings.create_or_update_setting( |
|
529 | 529 | self.INHERIT_SETTINGS, value, type_='bool') |
|
530 | 530 | |
|
531 | 531 | def get_global_svn_branch_patterns(self): |
|
532 | 532 | return self.global_settings.get_ui_by_section(self.SVN_BRANCH_SECTION) |
|
533 | 533 | |
|
534 | 534 | @assert_repo_settings |
|
535 | 535 | def get_repo_svn_branch_patterns(self): |
|
536 | 536 | return self.repo_settings.get_ui_by_section(self.SVN_BRANCH_SECTION) |
|
537 | 537 | |
|
538 | 538 | def get_global_svn_tag_patterns(self): |
|
539 | 539 | return self.global_settings.get_ui_by_section(self.SVN_TAG_SECTION) |
|
540 | 540 | |
|
541 | 541 | @assert_repo_settings |
|
542 | 542 | def get_repo_svn_tag_patterns(self): |
|
543 | 543 | return self.repo_settings.get_ui_by_section(self.SVN_TAG_SECTION) |
|
544 | 544 | |
|
545 | 545 | def get_global_settings(self): |
|
546 | 546 | return self._collect_all_settings(global_=True) |
|
547 | 547 | |
|
548 | 548 | @assert_repo_settings |
|
549 | 549 | def get_repo_settings(self): |
|
550 | 550 | return self._collect_all_settings(global_=False) |
|
551 | 551 | |
|
552 | 552 | @assert_repo_settings |
|
553 | 553 | def get_repo_settings_inherited(self): |
|
554 | 554 | global_settings = self.get_global_settings() |
|
555 | 555 | global_settings.update(self.get_repo_settings()) |
|
556 | 556 | return global_settings |
|
557 | 557 | |
|
558 | 558 | @assert_repo_settings |
|
559 | 559 | def create_or_update_repo_settings( |
|
560 | 560 | self, data, inherit_global_settings=False): |
|
561 | 561 | from rhodecode.model.scm import ScmModel |
|
562 | 562 | |
|
563 | 563 | self.inherit_global_settings = inherit_global_settings |
|
564 | 564 | |
|
565 | 565 | repo = self.repo_settings.get_repo() |
|
566 | 566 | if not inherit_global_settings: |
|
567 | 567 | if repo.repo_type == 'svn': |
|
568 | 568 | self.create_repo_svn_settings(data) |
|
569 | 569 | else: |
|
570 | 570 | self.create_or_update_repo_hook_settings(data) |
|
571 | 571 | self.create_or_update_repo_pr_settings(data) |
|
572 | 572 | |
|
573 | 573 | if repo.repo_type == 'hg': |
|
574 | 574 | self.create_or_update_repo_hg_settings(data) |
|
575 | 575 | |
|
576 | 576 | if repo.repo_type == 'git': |
|
577 | 577 | self.create_or_update_repo_git_settings(data) |
|
578 | 578 | |
|
579 | 579 | ScmModel().mark_for_invalidation(repo.repo_name, delete=True) |
|
580 | 580 | |
|
581 | 581 | @assert_repo_settings |
|
582 | 582 | def create_or_update_repo_hook_settings(self, data): |
|
583 | 583 | for section, key in self.HOOKS_SETTINGS: |
|
584 | 584 | data_key = self._get_form_ui_key(section, key) |
|
585 | 585 | if data_key not in data: |
|
586 | 586 | raise ValueError( |
|
587 | 587 | f'The given data does not contain {data_key} key') |
|
588 | 588 | |
|
589 | 589 | active = data.get(data_key) |
|
590 | 590 | repo_setting = self.repo_settings.get_ui_by_section_and_key( |
|
591 | 591 | section, key) |
|
592 | 592 | if not repo_setting: |
|
593 | 593 | global_setting = self.global_settings.\ |
|
594 | 594 | get_ui_by_section_and_key(section, key) |
|
595 | 595 | self.repo_settings.create_ui_section_value( |
|
596 | 596 | section, global_setting.ui_value, key=key, active=active) |
|
597 | 597 | else: |
|
598 | 598 | repo_setting.ui_active = active |
|
599 | 599 | Session().add(repo_setting) |
|
600 | 600 | |
|
601 | 601 | def update_global_hook_settings(self, data): |
|
602 | 602 | for section, key in self.HOOKS_SETTINGS: |
|
603 | 603 | data_key = self._get_form_ui_key(section, key) |
|
604 | 604 | if data_key not in data: |
|
605 | 605 | raise ValueError( |
|
606 | 606 | f'The given data does not contain {data_key} key') |
|
607 | 607 | active = data.get(data_key) |
|
608 | 608 | repo_setting = self.global_settings.get_ui_by_section_and_key( |
|
609 | 609 | section, key) |
|
610 | 610 | repo_setting.ui_active = active |
|
611 | 611 | Session().add(repo_setting) |
|
612 | 612 | |
|
613 | 613 | @assert_repo_settings |
|
614 | 614 | def create_or_update_repo_pr_settings(self, data): |
|
615 | 615 | return self._create_or_update_general_settings( |
|
616 | 616 | self.repo_settings, data) |
|
617 | 617 | |
|
618 | 618 | def create_or_update_global_pr_settings(self, data): |
|
619 | 619 | return self._create_or_update_general_settings( |
|
620 | 620 | self.global_settings, data) |
|
621 | 621 | |
|
622 | 622 | @assert_repo_settings |
|
623 | 623 | def create_repo_svn_settings(self, data): |
|
624 | 624 | return self._create_svn_settings(self.repo_settings, data) |
|
625 | 625 | |
|
626 | 626 | def _set_evolution(self, settings, is_enabled): |
|
627 | 627 | if is_enabled: |
|
628 | 628 | # if evolve is active set evolution=all |
|
629 | 629 | |
|
630 | 630 | self._create_or_update_ui( |
|
631 | 631 | settings, *('experimental', 'evolution'), value='all', |
|
632 | 632 | active=True) |
|
633 | 633 | self._create_or_update_ui( |
|
634 | 634 | settings, *('experimental', 'evolution.exchange'), value='yes', |
|
635 | 635 | active=True) |
|
636 | 636 | # if evolve is active set topics server support |
|
637 | 637 | self._create_or_update_ui( |
|
638 | 638 | settings, *('extensions', 'topic'), value='', |
|
639 | 639 | active=True) |
|
640 | 640 | |
|
641 | 641 | else: |
|
642 | 642 | self._create_or_update_ui( |
|
643 | 643 | settings, *('experimental', 'evolution'), value='', |
|
644 | 644 | active=False) |
|
645 | 645 | self._create_or_update_ui( |
|
646 | 646 | settings, *('experimental', 'evolution.exchange'), value='no', |
|
647 | 647 | active=False) |
|
648 | 648 | self._create_or_update_ui( |
|
649 | 649 | settings, *('extensions', 'topic'), value='', |
|
650 | 650 | active=False) |
|
651 | 651 | |
|
652 | 652 | @assert_repo_settings |
|
653 | 653 | def create_or_update_repo_hg_settings(self, data): |
|
654 | 654 | largefiles, phases, evolve = \ |
|
655 | 655 | self.HG_SETTINGS[:3] |
|
656 | 656 | largefiles_key, phases_key, evolve_key = \ |
|
657 | 657 | self._get_settings_keys(self.HG_SETTINGS[:3], data) |
|
658 | 658 | |
|
659 | 659 | self._create_or_update_ui( |
|
660 | 660 | self.repo_settings, *largefiles, value='', |
|
661 | 661 | active=data[largefiles_key]) |
|
662 | 662 | self._create_or_update_ui( |
|
663 | 663 | self.repo_settings, *evolve, value='', |
|
664 | 664 | active=data[evolve_key]) |
|
665 | 665 | self._set_evolution(self.repo_settings, is_enabled=data[evolve_key]) |
|
666 | 666 | |
|
667 | 667 | self._create_or_update_ui( |
|
668 | 668 | self.repo_settings, *phases, value=safe_str(data[phases_key])) |
|
669 | 669 | |
|
670 | 670 | def create_or_update_global_hg_settings(self, data): |
|
671 | 671 | largefiles, largefiles_store, phases, hgsubversion, evolve \ |
|
672 | 672 | = self.GLOBAL_HG_SETTINGS[:5] |
|
673 | 673 | largefiles_key, largefiles_store_key, phases_key, subversion_key, evolve_key \ |
|
674 | 674 | = self._get_settings_keys(self.GLOBAL_HG_SETTINGS[:5], data) |
|
675 | 675 | |
|
676 | 676 | self._create_or_update_ui( |
|
677 | 677 | self.global_settings, *largefiles, value='', |
|
678 | 678 | active=data[largefiles_key]) |
|
679 | 679 | self._create_or_update_ui( |
|
680 | 680 | self.global_settings, *largefiles_store, value=data[largefiles_store_key]) |
|
681 | 681 | self._create_or_update_ui( |
|
682 | 682 | self.global_settings, *phases, value=safe_str(data[phases_key])) |
|
683 | 683 | self._create_or_update_ui( |
|
684 | 684 | self.global_settings, *hgsubversion, active=data[subversion_key]) |
|
685 | 685 | self._create_or_update_ui( |
|
686 | 686 | self.global_settings, *evolve, value='', |
|
687 | 687 | active=data[evolve_key]) |
|
688 | 688 | self._set_evolution(self.global_settings, is_enabled=data[evolve_key]) |
|
689 | 689 | |
|
690 | 690 | def create_or_update_repo_git_settings(self, data): |
|
691 | 691 | # NOTE(marcink): # comma makes unpack work properly |
|
692 | 692 | lfs_enabled, \ |
|
693 | 693 | = self.GIT_SETTINGS |
|
694 | 694 | |
|
695 | 695 | lfs_enabled_key, \ |
|
696 | 696 | = self._get_settings_keys(self.GIT_SETTINGS, data) |
|
697 | 697 | |
|
698 | 698 | self._create_or_update_ui( |
|
699 | 699 | self.repo_settings, *lfs_enabled, value=data[lfs_enabled_key], |
|
700 | 700 | active=data[lfs_enabled_key]) |
|
701 | 701 | |
|
702 | 702 | def create_or_update_global_git_settings(self, data): |
|
703 | 703 | lfs_enabled, lfs_store_location \ |
|
704 | 704 | = self.GLOBAL_GIT_SETTINGS |
|
705 | 705 | lfs_enabled_key, lfs_store_location_key \ |
|
706 | 706 | = self._get_settings_keys(self.GLOBAL_GIT_SETTINGS, data) |
|
707 | 707 | |
|
708 | 708 | self._create_or_update_ui( |
|
709 | 709 | self.global_settings, *lfs_enabled, value=data[lfs_enabled_key], |
|
710 | 710 | active=data[lfs_enabled_key]) |
|
711 | 711 | self._create_or_update_ui( |
|
712 | 712 | self.global_settings, *lfs_store_location, |
|
713 | 713 | value=data[lfs_store_location_key]) |
|
714 | 714 | |
|
715 | 715 | def create_or_update_global_svn_settings(self, data): |
|
716 | 716 | # branch/tags patterns |
|
717 | 717 | self._create_svn_settings(self.global_settings, data) |
|
718 | 718 | |
|
719 | 719 | http_requests_enabled, http_server_url = self.GLOBAL_SVN_SETTINGS |
|
720 | 720 | http_requests_enabled_key, http_server_url_key = self._get_settings_keys( |
|
721 | 721 | self.GLOBAL_SVN_SETTINGS, data) |
|
722 | 722 | |
|
723 | 723 | self._create_or_update_ui( |
|
724 | 724 | self.global_settings, *http_requests_enabled, |
|
725 | 725 | value=safe_str(data[http_requests_enabled_key])) |
|
726 | 726 | self._create_or_update_ui( |
|
727 | 727 | self.global_settings, *http_server_url, |
|
728 | 728 | value=data[http_server_url_key]) |
|
729 | 729 | |
|
730 | 730 | def update_global_ssl_setting(self, value): |
|
731 | 731 | self._create_or_update_ui( |
|
732 | 732 | self.global_settings, *self.SSL_SETTING, value=value) |
|
733 | 733 | |
|
734 | 734 | def update_global_path_setting(self, value): |
|
735 | 735 | self._create_or_update_ui( |
|
736 | 736 | self.global_settings, *self.PATH_SETTING, value=value) |
|
737 | 737 | |
|
738 | 738 | @assert_repo_settings |
|
739 | 739 | def delete_repo_svn_pattern(self, id_): |
|
740 | 740 | ui = self.repo_settings.UiDbModel.get(id_) |
|
741 | 741 | if ui and ui.repository.repo_name == self.repo_settings.repo: |
|
742 | 742 | # only delete if it's the same repo as initialized settings |
|
743 | 743 | self.repo_settings.delete_ui(id_) |
|
744 | 744 | else: |
|
745 | 745 | # raise error as if we wouldn't find this option |
|
746 | 746 | self.repo_settings.delete_ui(-1) |
|
747 | 747 | |
|
748 | 748 | def delete_global_svn_pattern(self, id_): |
|
749 | 749 | self.global_settings.delete_ui(id_) |
|
750 | 750 | |
|
751 | 751 | @assert_repo_settings |
|
752 | 752 | def get_repo_ui_settings(self, section=None, key=None): |
|
753 | 753 | global_uis = self.global_settings.get_ui(section, key) |
|
754 | 754 | repo_uis = self.repo_settings.get_ui(section, key) |
|
755 | 755 | |
|
756 | 756 | filtered_repo_uis = self._filter_ui_settings(repo_uis) |
|
757 | 757 | filtered_repo_uis_keys = [ |
|
758 | 758 | (s.section, s.key) for s in filtered_repo_uis] |
|
759 | 759 | |
|
760 | 760 | def _is_global_ui_filtered(ui): |
|
761 | 761 | return ( |
|
762 | 762 | (ui.section, ui.key) in filtered_repo_uis_keys |
|
763 | 763 | or ui.section in self._svn_sections) |
|
764 | 764 | |
|
765 | 765 | filtered_global_uis = [ |
|
766 | 766 | ui for ui in global_uis if not _is_global_ui_filtered(ui)] |
|
767 | 767 | |
|
768 | 768 | return filtered_global_uis + filtered_repo_uis |
|
769 | 769 | |
|
770 | 770 | def get_global_ui_settings(self, section=None, key=None): |
|
771 | 771 | return self.global_settings.get_ui(section, key) |
|
772 | 772 | |
|
773 | 773 | def get_ui_settings_as_config_obj(self, section=None, key=None): |
|
774 | 774 | config = base.Config() |
|
775 | 775 | |
|
776 | 776 | ui_settings = self.get_ui_settings(section=section, key=key) |
|
777 | 777 | |
|
778 | 778 | for entry in ui_settings: |
|
779 | 779 | config.set(entry.section, entry.key, entry.value) |
|
780 | 780 | |
|
781 | 781 | return config |
|
782 | 782 | |
|
783 | 783 | def get_ui_settings(self, section=None, key=None): |
|
784 | 784 | if not self.repo_settings or self.inherit_global_settings: |
|
785 | 785 | return self.get_global_ui_settings(section, key) |
|
786 | 786 | else: |
|
787 | 787 | return self.get_repo_ui_settings(section, key) |
|
788 | 788 | |
|
789 | 789 | def get_svn_patterns(self, section=None): |
|
790 | 790 | if not self.repo_settings: |
|
791 | 791 | return self.get_global_ui_settings(section) |
|
792 | 792 | else: |
|
793 | 793 | return self.get_repo_ui_settings(section) |
|
794 | 794 | |
|
795 | 795 | @assert_repo_settings |
|
796 | 796 | def get_repo_general_settings(self): |
|
797 | 797 | global_settings = self.global_settings.get_all_settings() |
|
798 | 798 | repo_settings = self.repo_settings.get_all_settings() |
|
799 | 799 | filtered_repo_settings = self._filter_general_settings(repo_settings) |
|
800 | 800 | global_settings.update(filtered_repo_settings) |
|
801 | 801 | return global_settings |
|
802 | 802 | |
|
803 | 803 | def get_global_general_settings(self): |
|
804 | 804 | return self.global_settings.get_all_settings() |
|
805 | 805 | |
|
806 | 806 | def get_general_settings(self): |
|
807 | 807 | if not self.repo_settings or self.inherit_global_settings: |
|
808 | 808 | return self.get_global_general_settings() |
|
809 | 809 | else: |
|
810 | 810 | return self.get_repo_general_settings() |
|
811 | 811 | |
|
812 | 812 | def get_repos_location(self): |
|
813 | 813 | return self.global_settings.get_ui_by_key('/').ui_value |
|
814 | 814 | |
|
815 | 815 | def _filter_ui_settings(self, settings): |
|
816 | 816 | filtered_settings = [ |
|
817 | 817 | s for s in settings if self._should_keep_setting(s)] |
|
818 | 818 | return filtered_settings |
|
819 | 819 | |
|
820 | 820 | def _should_keep_setting(self, setting): |
|
821 | 821 | keep = ( |
|
822 | 822 | (setting.section, setting.key) in self._ui_settings or |
|
823 | 823 | setting.section in self._svn_sections) |
|
824 | 824 | return keep |
|
825 | 825 | |
|
826 | 826 | def _filter_general_settings(self, settings): |
|
827 | 827 | keys = [f'rhodecode_{key}' for key in self.GENERAL_SETTINGS] |
|
828 | 828 | return { |
|
829 | 829 | k: settings[k] |
|
830 | 830 | for k in settings if k in keys} |
|
831 | 831 | |
|
832 | 832 | def _collect_all_settings(self, global_=False): |
|
833 | 833 | settings = self.global_settings if global_ else self.repo_settings |
|
834 | 834 | result = {} |
|
835 | 835 | |
|
836 | 836 | for section, key in self._ui_settings: |
|
837 | 837 | ui = settings.get_ui_by_section_and_key(section, key) |
|
838 | 838 | result_key = self._get_form_ui_key(section, key) |
|
839 | 839 | |
|
840 | 840 | if ui: |
|
841 | 841 | if section in ('hooks', 'extensions'): |
|
842 | 842 | result[result_key] = ui.ui_active |
|
843 | 843 | elif result_key in ['vcs_git_lfs_enabled']: |
|
844 | 844 | result[result_key] = ui.ui_active |
|
845 | 845 | else: |
|
846 | 846 | result[result_key] = ui.ui_value |
|
847 | 847 | |
|
848 | 848 | for name in self.GENERAL_SETTINGS: |
|
849 | 849 | setting = settings.get_setting_by_name(name) |
|
850 | 850 | if setting: |
|
851 | 851 | result_key = f'rhodecode_{name}' |
|
852 | 852 | result[result_key] = setting.app_settings_value |
|
853 | 853 | |
|
854 | 854 | return result |
|
855 | 855 | |
|
856 | 856 | def _get_form_ui_key(self, section, key): |
|
857 | 857 | return '{section}_{key}'.format( |
|
858 | 858 | section=section, key=key.replace('.', '_')) |
|
859 | 859 | |
|
860 | 860 | def _create_or_update_ui( |
|
861 | 861 | self, settings, section, key, value=None, active=None): |
|
862 | 862 | ui = settings.get_ui_by_section_and_key(section, key) |
|
863 | 863 | if not ui: |
|
864 | 864 | active = True if active is None else active |
|
865 | 865 | settings.create_ui_section_value( |
|
866 | 866 | section, value, key=key, active=active) |
|
867 | 867 | else: |
|
868 | 868 | if active is not None: |
|
869 | 869 | ui.ui_active = active |
|
870 | 870 | if value is not None: |
|
871 | 871 | ui.ui_value = value |
|
872 | 872 | Session().add(ui) |
|
873 | 873 | |
|
874 | 874 | def _create_svn_settings(self, settings, data): |
|
875 | 875 | svn_settings = { |
|
876 | 876 | 'new_svn_branch': self.SVN_BRANCH_SECTION, |
|
877 | 877 | 'new_svn_tag': self.SVN_TAG_SECTION |
|
878 | 878 | } |
|
879 | 879 | for key in svn_settings: |
|
880 | 880 | if data.get(key): |
|
881 | 881 | settings.create_ui_section_value(svn_settings[key], data[key]) |
|
882 | 882 | |
|
883 | 883 | def _create_or_update_general_settings(self, settings, data): |
|
884 | 884 | for name in self.GENERAL_SETTINGS: |
|
885 | 885 | data_key = f'rhodecode_{name}' |
|
886 | 886 | if data_key not in data: |
|
887 | 887 | raise ValueError( |
|
888 | 888 | f'The given data does not contain {data_key} key') |
|
889 | 889 | setting = settings.create_or_update_setting( |
|
890 | 890 | name, data[data_key], 'bool') |
|
891 | 891 | Session().add(setting) |
|
892 | 892 | |
|
893 | 893 | def _get_settings_keys(self, settings, data): |
|
894 | 894 | data_keys = [self._get_form_ui_key(*s) for s in settings] |
|
895 | 895 | for data_key in data_keys: |
|
896 | 896 | if data_key not in data: |
|
897 | 897 | raise ValueError( |
|
898 | 898 | f'The given data does not contain {data_key} key') |
|
899 | 899 | return data_keys |
|
900 | 900 | |
|
901 | 901 | def create_largeobjects_dirs_if_needed(self, repo_store_path): |
|
902 | 902 | """ |
|
903 | 903 | This is subscribed to the `pyramid.events.ApplicationCreated` event. It |
|
904 | 904 | does a repository scan if enabled in the settings. |
|
905 | 905 | """ |
|
906 | 906 | |
|
907 | 907 | from rhodecode.lib.vcs.backends.hg import largefiles_store |
|
908 | 908 | from rhodecode.lib.vcs.backends.git import lfs_store |
|
909 | 909 | |
|
910 | 910 | paths = [ |
|
911 | 911 | largefiles_store(repo_store_path), |
|
912 | 912 | lfs_store(repo_store_path)] |
|
913 | 913 | |
|
914 | 914 | for path in paths: |
|
915 | 915 | if os.path.isdir(path): |
|
916 | 916 | continue |
|
917 | 917 | if os.path.isfile(path): |
|
918 | 918 | continue |
|
919 | 919 | # not a file nor dir, we try to create it |
|
920 | 920 | try: |
|
921 | 921 | os.makedirs(path) |
|
922 | 922 | except Exception: |
|
923 | 923 | log.warning('Failed to create largefiles dir:%s', path) |
General Comments 0
You need to be logged in to leave comments.
Login now