59
55
# displaydate and approximatedate return an elementtree <span> Element
60
56
# with the full date in a tooltip.
63
58
def date_day(value):
64
59
return value.strftime('%Y-%m-%d')
67
62
def date_time(value):
69
return value.strftime('%Y-%m-%d %T')
63
return value.strftime('%Y-%m-%d %T')
74
66
def _displaydate(date):
134
126
Convert a dict into an object with attributes.
137
128
def __init__(self, _dict=None, **kw):
138
129
if _dict is not None:
139
130
for key, value in _dict.iteritems():
144
135
def __repr__(self):
146
137
for key, value in self.__dict__.iteritems():
147
if key.startswith('_') or (getattr(self.__dict__[key],
148
'__call__', None) is not None):
138
if key.startswith('_') or (getattr(self.__dict__[key], '__call__', None) is not None):
150
140
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')
161
167
STANDARD_PATTERN = re.compile(r'^(.*?)\s*<(.*?)>\s*$')
162
168
EMAIL_PATTERN = re.compile(r'[-\w\d\+_!%\.]+@[-\w\d\+_!%\.]+')
165
170
def hide_email(email):
167
172
try to obsure any email address in a bazaar committer's name.
181
186
return '%s at %s' % (username, domains[-2])
182
187
return '%s at %s' % (username, domains[0])
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))
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):
193
224
# only do this if unicode turns out to be a problem
194
225
#_BADCHARS_RE = re.compile(ur'[\u007f-\uffff]')
196
227
# FIXME: get rid of this method; use fixed_width() and avoid XML().
199
228
def html_clean(s):
201
230
clean up a string for html display. expand any tabs, encode any html
210
240
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()
237
242
def fixed_width(s):
239
244
expand tabs and turn spaces into "non-breaking spaces", so browsers won't
249
254
s = s.decode('utf-8')
250
255
except UnicodeDecodeError:
251
256
s = s.decode('iso-8859-15')
253
s = cgi.escape(s).expandtabs().replace(' ', NONBREAKING_SPACE)
255
return HSC.clean(s).replace('\n', '<br/>')
257
return s.expandtabs().replace(' ', NONBREAKING_SPACE)
258
260
def fake_permissions(kind, executable):
264
266
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
268
279
s = base64.encodestring(s).replace('\n', '')
269
280
while (len(s) > 0) and (s[-1] == '='):
337
347
navigation.position = 0
338
348
navigation.count = len(navigation.revid_list)
339
349
navigation.page_position = navigation.position // navigation.pagesize + 1
340
navigation.page_count = (len(navigation.revid_list) + (navigation.pagesize\
341
- 1)) // navigation.pagesize
350
navigation.page_count = (len(navigation.revid_list) + (navigation.pagesize - 1)) // navigation.pagesize
343
352
def get_offset(offset):
344
if (navigation.position + offset < 0) or (
345
navigation.position + offset > navigation.count - 1):
353
if (navigation.position + offset < 0) or (navigation.position + offset > navigation.count - 1):
347
355
return navigation.revid_list[navigation.position + offset]
349
navigation.last_in_page_revid = get_offset(navigation.pagesize - 1)
350
357
navigation.prev_page_revid = get_offset(-1 * navigation.pagesize)
351
358
navigation.next_page_revid = get_offset(1 * navigation.pagesize)
352
359
prev_page_revno = navigation.history.get_revno(
355
362
navigation.next_page_revid)
356
363
start_revno = navigation.history.get_revno(navigation.start_revid)
358
params = {'filter_file_id': navigation.filter_file_id}
365
params = { 'filter_file_id': navigation.filter_file_id }
359
366
if getattr(navigation, 'query', None) is not None:
360
367
params['q'] = navigation.query
370
377
[navigation.scan_url, next_page_revno], **params)
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
380
def log_exception(log):
381
for line in ''.join(traceback.format_exception(*sys.exc_info())).split('\n'):
438
385
def decorator(unbound):
440
386
def new_decorator(f):
442
388
g.__name__ = f.__name__
449
395
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()
456
417
def _f(*a, **kw):
457
418
from loggerhead.lsprof import profile
460
421
ret, stats = profile(f, *a, **kw)
461
log.debug('Finished profiled %s in %d msec.' % (f.__name__,
462
int((time.time() - z) * 1000)))
422
log.debug('Finished profiled %s in %d msec.' % (f.__name__, int((time.time() - z) * 1000)))
465
425
now = time.time()
466
426
msec = int(now * 1000) % 1000
467
timestr = time.strftime('%Y%m%d%H%M%S',
468
time.localtime(now)) + ('%03d' % msec)
427
timestr = time.strftime('%Y%m%d%H%M%S', time.localtime(now)) + ('%03d' % msec)
469
428
filename = f.__name__ + '-' + timestr + '.lsprof'
470
429
cPickle.dump(stats, open(filename, 'w'), 2)
527
486
overrides = dict((k, v) for (k, v) in overrides.iteritems() if k in _valid)
528
487
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
