← Back to branch summary

~loggerhead-team/loggerhead/trunk-rich

« back to all changes in this revision

Viewing changes to loggerhead/apps/filesystem.py

  • Committer: Martin Pool
  • Date: 2009-03-10 01:01:04 UTC
  • mto: This revision was merged to the branch mainline in revision 298.
  • Revision ID: mbp@sourcefrog.net-20090310010104-o75ncguznrridwaz
optparse may have already parsed port as an int

Show diffs side-by-side

added added

removed removed

Lines of Context:
loggerhead/apps/filesystem.py
1
 
# Copyright (C) 2008, 2009 Canonical Ltd.
2
 
#
3
 
# This program is free software; you can redistribute it and/or modify
4
 
# it under the terms of the GNU General Public License as published by
5
 
# the Free Software Foundation; either version 2 of the License, or
6
 
# (at your option) any later version.
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 General Public License
14
 
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
 
#
17
 
"""Serve branches at urls that mimic a transport's file system layout."""
18
 
 
19
 
import threading
20
 
 
21
 
from bzrlib import branch, errors, lru_cache, urlutils
22
 
from bzrlib.config import LocationConfig
23
 
from bzrlib.transport import get_transport
24
 
from bzrlib.transport.http import wsgi
 
1
"""Serve branches at urls that mimic the file system layout."""
 
2
 
 
3
import os
 
4
import tempfile
 
5
 
 
6
from bzrlib import branch, errors, lru_cache
25
7
 
26
8
from paste.request import path_info_pop
27
9
from paste import httpexceptions
28
 
from paste import urlparser
29
10
 
30
11
from loggerhead.apps.branch import BranchWSGIApp
31
12
from loggerhead.apps import favicon_app, static_app
32
13
from loggerhead.controllers.directory_ui import DirectoryUI
33
14
 
34
 
_bools = {
35
 
    'yes': True, 'no': False,
36
 
    'on': True, 'off': False,
37
 
    '1': True, '0': False,
38
 
    'true': True, 'false': False,
39
 
    }
40
 
 
41
 
class BranchesFromTransportServer(object):
42
 
 
43
 
    def __init__(self, transport, root, name=None):
44
 
        self.transport = transport
 
15
sql_dir = tempfile.mkdtemp(prefix='loggerhead-cache-')
 
16
 
 
17
 
 
18
class BranchesFromFileSystemServer(object):
 
19
 
 
20
    def __init__(self, path, root, name=None):
 
21
        self.path = path
45
22
        self.root = root
46
23
        self.name = name
47
 
        self._config = root._config
48
24
 
49
25
    def app_for_branch(self, branch):
50
26
        if not self.name:
51
 
            name = branch._get_nick(local=True)
 
27
            name = branch.get_config().get_nickname()
52
28
            is_root = True
53
29
        else:
54
30
            name = self.name
55
31
            is_root = False
56
32
        branch_app = BranchWSGIApp(
57
 
            branch,
58
 
            name,
59
 
            {'cachepath': self._config.SQL_DIR},
60
 
            self.root.graph_cache,
61
 
            is_root=is_root,
62
 
            use_cdn=self._config.get_option('use_cdn'),
63
 
            )
 
33
            branch, name, {'cachepath': sql_dir}, self.root.graph_cache,
 
34
            is_root=is_root)
64
35
        return branch_app.app
65
36
 
66
37
    def app_for_non_branch(self, environ):
73
44
                name = self.name
74
45
            else:
75
46
                name = '/'
76
 
            return DirectoryUI(
77
 
                environ['loggerhead.static.url'], self.transport, name)
 
47
            return DirectoryUI(environ['loggerhead.static.url'],
 
48
                               self.path,
 
49
                               name)
78
50
        else:
79
 
            new_transport = self.transport.clone(segment)
 
51
            new_path = os.path.join(self.path, segment)
80
52
            if self.name:
81
 
                new_name = urlutils.join(self.name, segment)
 
53
                new_name = os.path.join(self.name, segment)
82
54
            else:
83
55
                new_name = '/' + segment
84
 
            return BranchesFromTransportServer(new_transport, self.root, new_name)
85
 
 
86
 
    def app_for_bazaar_data(self, relpath):
87
 
        if relpath == '/.bzr/smart':
88
 
            wsgi_app = wsgi.SmartWSGIApp(self.transport)
89
 
            return wsgi.RelpathSetter(wsgi_app, '', 'PATH_INFO')
90
 
        else:
91
 
            # TODO: Use something here that uses the transport API
92
 
            # rather than relying on the local filesystem API.
93
 
            base = self.transport.base
94
 
            readonly_prefix = 'readonly+'
95
 
            if base.startswith(readonly_prefix):
96
 
                base = base[len(readonly_prefix):]
97
 
            try:
98
 
                path = urlutils.local_path_from_url(base)
99
 
            except errors.InvalidURL:
100
 
                raise httpexceptions.HTTPNotFound()
101
 
            else:
102
 
                return urlparser.make_static(None, path)
103
 
 
104
 
    def check_serveable(self, config):
105
 
        value = config.get_user_option('http_serve')
106
 
        if value is None:
107
 
            return
108
 
        elif not _bools.get(value.lower(), True):
 
56
            return BranchesFromFileSystemServer(new_path, self.root, new_name)
 
57
 
 
58
    def __call__(self, environ, start_response):
 
59
        if not os.path.isdir(self.path):
109
60
            raise httpexceptions.HTTPNotFound()
110
 
 
111
 
    def __call__(self, environ, start_response):
112
 
        path = environ['PATH_INFO']
113
61
        try:
114
 
            b = branch.Branch.open_from_transport(self.transport)
 
62
            b = branch.Branch.open(self.path)
115
63
        except errors.NotBranchError:
116
 
            if path.startswith('/.bzr'):
117
 
                self.check_serveable(LocationConfig(self.transport.base))
118
 
                return self.app_for_bazaar_data(path)(environ, start_response)
119
 
            if not self.transport.listable() or not self.transport.has('.'):
120
 
                raise httpexceptions.HTTPNotFound()
121
64
            return self.app_for_non_branch(environ)(environ, start_response)
122
65
        else:
123
 
            self.check_serveable(b.get_config())
124
 
            if path.startswith('/.bzr'):
125
 
                return self.app_for_bazaar_data(path)(environ, start_response)
126
 
            else:
127
 
                return self.app_for_branch(b)(environ, start_response)
128
 
 
129
 
 
130
 
_transport_store = threading.local()
131
 
 
132
 
def get_transport_for_thread(base):
133
 
    """ """
134
 
    thread_transports = getattr(_transport_store, 'transports', None)
135
 
    if thread_transports is None:
136
 
        thread_transports = _transport_store.transports = {}
137
 
    if base in thread_transports:
138
 
        return thread_transports[base]
139
 
    transport = get_transport(base)
140
 
    return transport
141
 
 
142
 
 
143
 
class BranchesFromTransportRoot(object):
144
 
 
145
 
    def __init__(self, base, config):
146
 
        self.graph_cache = lru_cache.LRUCache(10)
147
 
        self.base = base
148
 
        self._config = config
 
66
            return self.app_for_branch(b)(environ, start_response)
 
67
 
 
68
 
 
69
class BranchesFromFileSystemRoot(object):
 
70
 
 
71
    def __init__(self, folder):
 
72
        self.graph_cache = lru_cache.LRUCache()
 
73
        self.folder = folder
149
74
 
150
75
    def __call__(self, environ, start_response):
151
76
        environ['loggerhead.static.url'] = environ['SCRIPT_NAME']
156
81
        elif environ['PATH_INFO'] == '/favicon.ico':
157
82
            return favicon_app(environ, start_response)
158
83
        else:
159
 
            transport = get_transport_for_thread(self.base)
160
 
            return BranchesFromTransportServer(
161
 
                transport, self)(environ, start_response)
162
 
 
163
 
 
164
 
class UserBranchesFromTransportRoot(object):
165
 
 
166
 
    def __init__(self, base, config):
167
 
        self.graph_cache = lru_cache.LRUCache(10)
168
 
        self.base = base
169
 
        self._config = config
170
 
        self.trunk_dir = config.get_option('trunk_dir')
 
84
            return BranchesFromFileSystemServer(
 
85
                self.folder, self)(environ, start_response)
 
86
 
 
87
 
 
88
class UserBranchesFromFileSystemRoot(object):
 
89
 
 
90
    def __init__(self, folder, trunk_dir):
 
91
        self.graph_cache = lru_cache.LRUCache()
 
92
        self.folder = folder
 
93
        self.trunk_dir = trunk_dir
171
94
 
172
95
    def __call__(self, environ, start_response):
173
96
        environ['loggerhead.static.url'] = environ['SCRIPT_NAME']
174
 
        path_info = environ['PATH_INFO']
 
97
        path_info= environ['PATH_INFO']
175
98
        if path_info.startswith('/static/'):
176
99
            segment = path_info_pop(environ)
177
100
            assert segment == 'static'
179
102
        elif path_info == '/favicon.ico':
180
103
            return favicon_app(environ, start_response)
181
104
        else:
182
 
            transport = get_transport_for_thread(self.base)
183
105
            # segments starting with ~ are user branches
184
106
            if path_info.startswith('/~'):
185
107
                segment = path_info_pop(environ)
186
 
                return BranchesFromTransportServer(
187
 
                    transport.clone(segment[1:]), self, segment)(
188
 
                    environ, start_response)
 
108
                new_path = os.path.join(self.folder, segment[1:])
 
109
                return BranchesFromFileSystemServer(
 
110
                    new_path, self, segment)(environ, start_response)
189
111
            else:
190
 
                return BranchesFromTransportServer(
191
 
                    transport.clone(self.trunk_dir), self)(
192
 
                    environ, start_response)
 
112
                new_path = os.path.join(self.folder, self.trunk_dir)
 
113
                return BranchesFromFileSystemServer(
 
114
                    new_path, self)(environ, start_response)