~malept/loggerhead/standalone-auth

« back to all changes in this revision

Viewing changes to loggerhead/apps/config.py

  • Committer: Martin Albisetti
  • Date: 2008-07-22 00:40:03 UTC
  • mfrom: (182 loggerhead.search_integration)
  • mto: This revision was merged to the branch mainline in revision 187.
  • Revision ID: argentina@gmail.com-20080722004003-lx1fp0tthpp6kl92
Merged from trunk, resolved billions of conflicts

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# A server that recreates (modulo cherrypy bugs :) the url parsing
2
 
# from the old, loggerhead.conf approach.
 
1
"""A server that uses a loggerhead.conf file.
3
2
 
4
 
# It's all a bit horrible really.
 
3
We recreate the branch discovery and url scheme of the old branchview
 
4
code.  It's all a bit horrible really.
 
5
"""
5
6
 
6
7
import logging
7
8
import os
8
9
import posixpath
9
10
 
 
11
import bzrlib.lru_cache
 
12
 
10
13
from configobj import ConfigObj
11
14
 
12
15
from paste.request import path_info_pop
24
27
from loggerhead.history import is_branch
25
28
 
26
29
class Project(object):
27
 
    def __init__(self, name, config, root_config):
 
30
    """A project contains the branches.
 
31
 
 
32
    There is some complication because we don't want to hold on to the
 
33
    branches when they are not being browsed."""
 
34
 
 
35
    def __init__(self, name, config, root_config, graph_cache):
28
36
        self.name = name
29
37
        self.friendly_name = config.get('name', name)
30
38
        self.description = config.get('description', '')
31
39
        self.long_description = config.get('long_description', '')
32
40
        self._config = config
33
41
        self._root_config = root_config
 
42
        self.graph_cache = graph_cache
34
43
 
35
 
        self.views = []
36
 
        self.views_by_name = {}
 
44
        self.view_names = []
 
45
        self.view_data_by_name = {}
37
46
        for view_name in config.sections:
38
47
            log.debug('Configuring (project %s) branch %s...', name, view_name)
39
48
            self._add_view(
60
69
            return
61
70
 
62
71
        # rebuild views:
 
72
        self.view_names = []
63
73
        log.debug('Rescanning auto-folder for project %s ...', self.name)
64
 
        self._views = []
65
74
        for folder in auto_list:
66
75
            view_name = os.path.basename(folder)
67
76
            log.debug('Auto-configuring (project %s) branch %s...', self.name, view_name)
77
86
            return posixpath.join(url, folder) + '/'
78
87
        return None
79
88
 
80
 
    def _get_description(self, view, view_config):
 
89
    def _get_description(self, view, view_config, history):
81
90
        description = view_config.get('description', None)
82
91
        if description is not None:
83
92
            return description
84
 
        description = view.history._branch.get_config().get_user_option('description')
 
93
        description = history._branch.get_config().get_user_option('description')
85
94
        return description
86
95
 
87
96
    def _add_view(self, view_name, view_config, folder):
88
 
        view = BranchWSGIApp(folder, view_name, view_config)
89
 
        friendly_name = view_config.get('branch_name', None)
90
 
        if friendly_name is None:
91
 
            friendly_name = view.history.get_config().get_nickname()
 
97
        b = bzrlib.branch.Branch.open(folder)
 
98
        view = BranchWSGIApp(b, view_name, view_config, self.graph_cache)
 
99
        b.lock_read()
 
100
        try:
 
101
            history = view.get_history()
 
102
            friendly_name = view_config.get('branch_name', None)
92
103
            if friendly_name is None:
93
 
                friendly_name = view_name
94
 
        view.friendly_name = friendly_name
95
 
        view.name = view_name
96
 
        branch_url = self._get_branch_url(view, view_config, view_name)
97
 
        if branch_url is not None:
98
 
            view.branch_url = branch_url
99
 
        view.description = self._get_description(view, view_config)
100
 
        view._src_folder = folder
101
 
        view._view_config = view_config
102
 
        self.views.append(view)
103
 
        self.views_by_name[view_name] = view
 
104
                friendly_name = history.get_config().get_nickname()
 
105
                if friendly_name is None:
 
106
                    friendly_name = view_name
 
107
            self.view_data_by_name[view_name] = {
 
108
                'branch_path': folder,
 
109
                'args': (view_name, view_config, self.graph_cache),
 
110
                'description': self._get_description(view, view_config, history),
 
111
                '_src_folder': folder,
 
112
                '_view_config': view_config,
 
113
                'friendly_name': friendly_name,
 
114
                'name': view_name,
 
115
                }
 
116
            branch_url = self._get_branch_url(view, view_config, view_name)
 
117
            if branch_url is not None:
 
118
                self.view_data_by_name[view_name]['branch_url'] = branch_url
 
119
            self.view_names.append(view_name)
 
120
        finally:
 
121
            b.unlock()
 
122
 
 
123
    def view_named(self, name):
 
124
        view_data = self.view_data_by_name.get(name)
 
125
        if view_data is None:
 
126
            return None
 
127
        view_data = view_data.copy()
 
128
        branch_path = view_data.pop('branch_path')
 
129
        args = view_data.pop('args')
 
130
        b = bzrlib.branch.Branch.open(branch_path)
 
131
        b.lock_read()
 
132
        view = BranchWSGIApp(b, *args)
 
133
        for k in view_data:
 
134
            setattr(view, k, view_data[k])
 
135
        return view
104
136
 
105
137
    def call(self, environ, start_response):
106
138
        segment = path_info_pop(environ)
107
139
        if not segment:
108
140
            raise httpexceptions.HTTPNotFound()
109
141
        else:
110
 
            view = self.views_by_name.get(segment)
 
142
            view = self.view_named(segment)
111
143
            if view is None:
112
144
                raise httpexceptions.HTTPNotFound()
113
 
            return view.app(environ, start_response)
 
145
            try:
 
146
                return view.app(environ, start_response)
 
147
            finally:
 
148
                view.branch.unlock()
114
149
 
115
150
 
116
151
class Root(object):
 
152
    """The root of the server -- renders as the browse view,
 
153
    dispatches to Project above for each 'project'."""
117
154
 
118
155
    def __init__(self, config):
119
156
        self.projects = []
120
157
        self.config = config
121
158
        self.projects_by_name = {}
 
159
        graph_cache = bzrlib.lru_cache.LRUCache()
122
160
        for project_name in self.config.sections:
123
161
            project = Project(
124
 
                project_name, self.config[project_name], self.config)
 
162
                project_name, self.config[project_name], self.config, graph_cache)
125
163
            self.projects.append(project)
126
164
            self.projects_by_name[project_name] = project
127
165
 
128
166
    def browse(self, response):
 
167
        # This is insanely complicated because we want to open and
 
168
        # lock all the branches, render the view and then unlock the
 
169
        # branches again.
129
170
        for p in self.projects:
130
171
            p._recheck_auto_folders()
131
172
        class branch(object):
132
173
            @staticmethod
133
174
            def static_url(path):
134
175
                return self._static_url_base + path
135
 
        vals = {
136
 
            'projects': self.projects,
137
 
            'util': util,
138
 
            'title': self.config.get('title', None),
139
 
            'branch': branch,
140
 
        }
141
 
        vals.update(templatefunctions)
142
 
        response.headers['Content-Type'] = 'text/html'
143
 
        template = load_template('loggerhead.templates.browse')
144
 
        template.expand_into(response, **vals)
 
176
        views_by_project = {}
 
177
        all_views = []
 
178
        try:
 
179
            for p in self.projects:
 
180
                views_by_project[p] = []
 
181
                for vn in p.view_names:
 
182
                    v = p.view_named(vn)
 
183
                    all_views.append(v)
 
184
                    views_by_project[p].append(v)
 
185
            vals = {
 
186
                'projects': self.projects,
 
187
                'util': util,
 
188
                'title': self.config.get('title', None),
 
189
                'branch': branch,
 
190
                'views_by_project': views_by_project,
 
191
            }
 
192
            vals.update(templatefunctions)
 
193
            response.headers['Content-Type'] = 'text/html'
 
194
            template = load_template('loggerhead.templates.browse')
 
195
            template.expand_into(response, **vals)
 
196
        finally:
 
197
            for v in all_views:
 
198
                v.branch.unlock()
145
199
 
146
200
    def __call__(self, environ, start_response):
147
 
        self._static_url_base = environ['loggerhead.static.url'] = environ['SCRIPT_NAME']
 
201
        self._static_url_base = environ['loggerhead.static.url'] = \
 
202
                                environ['SCRIPT_NAME']
148
203
        segment = path_info_pop(environ)
149
204
        if segment is None:
150
205
            raise httpexceptions.HTTPMovedPermanently(