15
15
# You should have received a copy of the GNU General Public License
16
16
# along with this program; if not, write to the Free Software
17
17
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
25
from configobj import ConfigObj
28
from turbogears import controllers
29
from cherrypy import HTTPRedirect, NotFound
31
my_config = ConfigObj('loggerhead.conf', encoding='utf-8')
32
extra_path = my_config.get('bzrpath', None)
34
sys.path.insert(0, extra_path)
22
from paste.request import path_info_pop, parse_querystring
36
24
from loggerhead import util
37
from loggerhead.branchview import BranchView
38
from loggerhead.history import History
40
log = logging.getLogger("loggerhead.controllers")
43
def cherrypy_friendly(s):
45
convert a config section name into a name that pleases cherrypy.
47
return re.sub(r'[^\w\d_]', '_', s)
51
def __init__(self, name, config):
53
self.friendly_name = config.get('name', name)
54
self.description = config.get('description', '')
57
for view_name in config.sections:
58
log.debug('Configuring (group %r) branch %r...', name, view_name)
59
c_view_name = cherrypy_friendly(view_name)
60
view = BranchView(name, c_view_name, config[view_name])
61
self._views.append(view)
62
setattr(self, c_view_name, view)
64
views = property(lambda self: self._views)
67
class Root (controllers.RootController):
71
for group_name in my_config.sections:
72
# FIXME: clean out any non-python chars
73
c_group_name = cherrypy_friendly(group_name)
74
group = Group(c_group_name, my_config[group_name])
75
self._groups.append(group)
76
setattr(self, c_group_name, group)
78
@turbogears.expose(template='loggerhead.templates.browse')
81
'groups': self._groups,
25
from loggerhead.templatefunctions import templatefunctions
26
from loggerhead.zptsupport import load_template
28
class BufferingWriter(object):
30
def __init__(self, writefunc, buf_limit):
34
self.writefunc = writefunc
36
self.buf_limit = buf_limit
39
chunk = ''.join(self.buf)
40
chunk = re.sub(r'\s*\n\s*', '\n', chunk)
41
chunk = re.sub(r'[ \t]+', ' ', chunk)
42
self.bytes_saved += self.buflen - len(chunk)
47
def write(self, data):
49
self.buflen += len(data)
50
self.bytes += len(data)
51
if self.buflen > self.buf_limit:
54
class TemplatedBranchView(object):
58
def __init__(self, branch, history):
60
self._history = history
63
def __call__(self, environ, start_response):
66
kw = dict(parse_querystring(environ))
70
arg = path_info_pop(environ)
76
'branch': self._branch,
83
'title': my_config.get('title', ''),
79
'url': self._branch.context_url,
86
def _check_rebuild(self):
87
for g in self._groups:
95
# re-index every 6 hours
98
turbogears.scheduler.add_interval_task(initialdelay=1, interval=index_freq, action=Root._check_rebuild)
100
# for use in profiling the very-slow get_change() method:
101
#h = util.get_history()
102
#w = list(h.get_revision_history())
103
#h._get_changes_profiled(w[:100])
81
vals.update(templatefunctions)
83
vals.update(self.get_values(h, args, kw, headers))
85
self.log.info('Getting information for %s: %r secs' % (
86
self.__class__.__name__, time.time() - z,))
87
if 'Content-Type' not in headers:
88
headers['Content-Type'] = 'text/html'
89
writer = start_response("200 OK", headers.items())
90
template = load_template(self.template_path)
92
w = BufferingWriter(writer, 8192)
93
template.expand_into(w, **vals)
95
self.log.info('Rendering %s: %r secs, %s bytes, %s (%2.1f%%) bytes saved' % (
96
self.__class__.__name__, time.time() - z, w.bytes, w.bytes_saved, 100.0*w.bytes_saved/w.bytes))