55
59
# displaydate and approximatedate return an elementtree <span> Element
56
60
# with the full date in a tooltip.
58
63
def date_day(value):
59
64
return value.strftime('%Y-%m-%d')
62
67
def date_time(value):
63
return value.strftime('%Y-%m-%d %T')
69
return value.strftime('%Y-%m-%d %T')
66
74
def _displaydate(date):
126
134
Convert a dict into an object with attributes.
128
137
def __init__(self, _dict=None, **kw):
129
138
if _dict is not None:
130
139
for key, value in _dict.iteritems():
135
144
def __repr__(self):
137
146
for key, value in self.__dict__.iteritems():
138
if key.startswith('_') or (getattr(self.__dict__[key], '__call__', None) is not None):
147
if key.startswith('_') or (getattr(self.__dict__[key],
148
'__call__', None) is not None):
140
150
out += '%r => %r, ' % (key, value)
145
def clean_revid(revid):
146
if revid == 'missing':
148
return sha.new(revid).hexdigest()
152
return ''.join([ '&#%d;' % ord(c) for c in text ])
155
155
def trunc(text, limit=10):
156
156
if len(text) <= limit:
158
158
return text[:limit] + '...'
162
if isinstance(s, unicode):
163
return s.encode('utf-8')
167
161
STANDARD_PATTERN = re.compile(r'^(.*?)\s*<(.*?)>\s*$')
168
162
EMAIL_PATTERN = re.compile(r'[-\w\d\+_!%\.]+@[-\w\d\+_!%\.]+')
170
165
def hide_email(email):
172
167
try to obsure any email address in a bazaar committer's name.
186
181
return '%s at %s' % (username, domains[-2])
187
182
return '%s at %s' % (username, domains[0])
190
def triple_factors(min_value=1):
196
yield n * factors[index]
198
if index >= len(factors):
203
def scan_range(pos, max, pagesize=1):
205
given a position in a maximum range, return a list of negative and positive
206
jump factors for an hgweb-style triple-factor geometric scan.
208
for example, with pos=20 and max=500, the range would be:
209
[ -10, -3, -1, 1, 3, 10, 30, 100, 300 ]
211
i admit this is a very strange way of jumping through revisions. i didn't
215
for n in triple_factors(pagesize + 1):
184
def hide_emails(emails):
186
try to obscure any email address in a list of bazaar committers' names.
190
result.append(hide_email(email))
224
193
# only do this if unicode turns out to be a problem
225
194
#_BADCHARS_RE = re.compile(ur'[\u007f-\uffff]')
227
196
# FIXME: get rid of this method; use fixed_width() and avoid XML().
228
199
def html_clean(s):
230
201
clean up a string for html display. expand any tabs, encode any html
240
210
NONBREAKING_SPACE = u'\N{NO-BREAK SPACE}'
215
CSS is stupid. In some cases we need to replace an empty value with
216
a non breaking space ( ). There has to be a better way of doing this.
218
return: the same value recieved if not empty, and a ' ' if it is.
224
elif isinstance(s, int):
230
s = s.decode('utf-8')
231
except UnicodeDecodeError:
232
s = s.decode('iso-8859-15')
235
HSC = HTMLStructureCleaner()
242
237
def fixed_width(s):
244
239
expand tabs and turn spaces into "non-breaking spaces", so browsers won't
254
249
s = s.decode('utf-8')
255
250
except UnicodeDecodeError:
256
251
s = s.decode('iso-8859-15')
257
return s.expandtabs().replace(' ', NONBREAKING_SPACE)
253
s = s.expandtabs().replace(' ', NONBREAKING_SPACE)
255
return HSC.clean(s).replace('\n', '<br/>')
260
258
def fake_permissions(kind, executable):
266
264
return '-rw-r--r--'
269
def if_present(format, value):
271
format a value using a format string, if the value exists and is not None.
275
return format % value
279
268
s = base64.encodestring(s).replace('\n', '')
280
269
while (len(s) > 0) and (s[-1] == '='):
347
337
navigation.position = 0
348
338
navigation.count = len(navigation.revid_list)
349
339
navigation.page_position = navigation.position // navigation.pagesize + 1
350
navigation.page_count = (len(navigation.revid_list) + (navigation.pagesize - 1)) // navigation.pagesize
340
navigation.page_count = (len(navigation.revid_list) + (navigation.pagesize\
341
- 1)) // navigation.pagesize
352
343
def get_offset(offset):
353
if (navigation.position + offset < 0) or (navigation.position + offset > navigation.count - 1):
344
if (navigation.position + offset < 0) or (
345
navigation.position + offset > navigation.count - 1):
355
347
return navigation.revid_list[navigation.position + offset]
349
navigation.last_in_page_revid = get_offset(navigation.pagesize - 1)
357
350
navigation.prev_page_revid = get_offset(-1 * navigation.pagesize)
358
351
navigation.next_page_revid = get_offset(1 * navigation.pagesize)
359
prev_page_revno = navigation.branch.history.get_revno(
352
prev_page_revno = navigation.history.get_revno(
360
353
navigation.prev_page_revid)
361
next_page_revno = navigation.branch.history.get_revno(
354
next_page_revno = navigation.history.get_revno(
362
355
navigation.next_page_revid)
363
start_revno = navigation.branch._history.get_revno(navigation.start_revid)
356
start_revno = navigation.history.get_revno(navigation.start_revid)
365
params = { 'filter_file_id': navigation.filter_file_id }
358
params = {'filter_file_id': navigation.filter_file_id}
366
359
if getattr(navigation, 'query', None) is not None:
367
360
params['q'] = navigation.query
377
370
[navigation.scan_url, next_page_revno], **params)
380
def log_exception(log):
381
for line in ''.join(traceback.format_exception(*sys.exc_info())).split('\n'):
373
def directory_breadcrumbs(path, is_root, view):
375
Generate breadcrumb information from the directory path given
377
The path given should be a path up to any branch that is currently being
381
path -- The path to convert into breadcrumbs
382
is_root -- Whether or not loggerhead is serving a branch at its root
383
view -- The type of view we are showing (files, changes etc)
385
# Is our root directory itself a branch?
387
if view == 'directory':
395
# Create breadcrumb trail for the path leading up to the branch
397
'dir_name': "(root)",
402
dir_parts = path.strip('/').split('/')
403
for index, dir_name in enumerate(dir_parts):
405
'dir_name': dir_name,
406
'path': '/'.join(dir_parts[:index + 1]),
409
# If we are not in the directory view, the last crumb is a branch,
410
# so we need to specify a view
411
if view != 'directory':
412
breadcrumbs[-1]['suffix'] = '/' + view
416
def branch_breadcrumbs(path, inv, view):
418
Generate breadcrumb information from the branch path given
420
The path given should be a path that exists within a branch
423
path -- The path to convert into breadcrumbs
424
inv -- Inventory to get file information from
425
view -- The type of view we are showing (files, changes etc)
427
dir_parts = path.strip('/').split('/')
428
inner_breadcrumbs = []
429
for index, dir_name in enumerate(dir_parts):
430
inner_breadcrumbs.append({
431
'dir_name': dir_name,
432
'file_id': inv.path2id('/'.join(dir_parts[:index + 1])),
433
'suffix': '/' + view,
435
return inner_breadcrumbs
385
438
def decorator(unbound):
386
440
def new_decorator(f):
388
442
g.__name__ = f.__name__
395
449
return new_decorator
398
# common threading-lock decorator
399
def with_lock(lockname, debug_name=None):
400
if debug_name is None:
401
debug_name = lockname
403
def _decorator(unbound):
404
def locked(self, *args, **kw):
405
getattr(self, lockname).acquire()
407
return unbound(self, *args, **kw)
409
getattr(self, lockname).release()
415
def strip_whitespace(f):
419
out = re.sub(r'\n\s+', '\n', out)
420
out = re.sub(r'[ \t]+', ' ', out)
421
out = re.sub(r'\s+\n', '\n', out)
423
log.debug('Saved %sB (%d%%) by stripping whitespace.',
424
human_size(orig_len - new_len),
425
round(100.0 - float(new_len) * 100.0 / float(orig_len)))
432
456
def _f(*a, **kw):
433
457
from loggerhead.lsprof import profile
436
460
ret, stats = profile(f, *a, **kw)
437
log.debug('Finished profiled %s in %d msec.' % (f.__name__, int((time.time() - z) * 1000)))
461
log.debug('Finished profiled %s in %d msec.' % (f.__name__,
462
int((time.time() - z) * 1000)))
440
465
now = time.time()
441
466
msec = int(now * 1000) % 1000
442
timestr = time.strftime('%Y%m%d%H%M%S', time.localtime(now)) + ('%03d' % msec)
467
timestr = time.strftime('%Y%m%d%H%M%S',
468
time.localtime(now)) + ('%03d' % msec)
443
469
filename = f.__name__ + '-' + timestr + '.lsprof'
444
470
cPickle.dump(stats, open(filename, 'w'), 2)
501
527
overrides = dict((k, v) for (k, v) in overrides.iteritems() if k in _valid)
502
528
map.update(overrides)
532
class Reloader(object):
534
This class wraps all paste.reloader logic. All methods are @classmethod.
537
_reloader_environ_key = 'PYTHON_RELOADER_SHOULD_RUN'
540
def _turn_sigterm_into_systemexit(self):
542
Attempts to turn a SIGTERM exception into a SystemExit exception.
549
def handle_term(signo, frame):
551
signal.signal(signal.SIGTERM, handle_term)
554
def is_installed(self):
555
return os.environ.get(self._reloader_environ_key)
559
from paste import reloader
560
reloader.install(int(1))
563
def restart_with_reloader(self):
564
"""Based on restart_with_monitor from paste.script.serve."""
565
print 'Starting subprocess with file monitor'
567
args = [sys.executable] + sys.argv
568
new_environ = os.environ.copy()
569
new_environ[self._reloader_environ_key] = 'true'
573
self._turn_sigterm_into_systemexit()
574
proc = subprocess.Popen(args, env=new_environ)
575
exit_code = proc.wait()
577
except KeyboardInterrupt:
578
print '^C caught in monitor process'
582
and hasattr(os, 'kill')):
585
os.kill(proc.pid, signal.SIGTERM)
586
except (OSError, IOError):
589
# Reloader always exits with code 3; but if we are
590
# a monitor, any exit code will restart
593
print '-'*20, 'Restarting', '-'*20
added
removed
loggerhead/util.py
