1
# Copyright (C) 2008, 2009 Canonical Ltd.
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.
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.
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
17
"""Serve branches at urls that mimic a transport's file system layout."""
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
import cgi, os, tempfile
2
from bzrlib import branch, errors
3
from loggerhead.history import History
4
from loggerhead.wsgiapp import BranchWSGIApp, static_app
26
5
from paste.request import path_info_pop
6
from paste.wsgiwrappers import WSGIRequest, WSGIResponse
27
7
from paste import httpexceptions
28
from paste import urlparser
30
from loggerhead.apps.branch import BranchWSGIApp
31
from loggerhead.apps import favicon_app, static_app
32
from loggerhead.controllers.directory_ui import DirectoryUI
35
'yes': True, 'no': False,
36
'on': True, 'off': False,
37
'1': True, '0': False,
38
'true': True, 'false': False,
41
class BranchesFromTransportServer(object):
43
def __init__(self, transport, root, name=None):
44
self.transport = transport
8
from paste import httpserver
9
from paste.httpexceptions import make_middleware
10
from paste.translogger import make_filter
11
from loggerhead.changecache import FileChangeCache
14
sql_dir = tempfile.mkdtemp()
16
class BranchesFromFileSystemServer(object):
17
def __init__(self, folder, root):
47
self._config = root._config
49
def app_for_branch(self, branch):
51
name = branch._get_nick(local=True)
56
branch_app = BranchWSGIApp(
58
{'cachepath': self._config.SQL_DIR},
59
self.root.graph_cache, is_root=is_root,
60
use_cdn=self._config.get_option('use_cdn'))
63
def app_for_non_branch(self, environ):
21
def __call__(self, environ, start_response):
64
22
segment = path_info_pop(environ)
65
23
if segment is None:
66
raise httpexceptions.HTTPMovedPermanently(
67
environ['SCRIPT_NAME'] + '/')
74
environ['loggerhead.static.url'], self.transport, name)
76
new_transport = self.transport.clone(segment)
78
new_name = urlutils.join(self.name, segment)
80
new_name = '/' + segment
81
return BranchesFromTransportServer(new_transport, self.root, new_name)
83
def app_for_bazaar_data(self, relpath):
84
if relpath == '/.bzr/smart':
85
wsgi_app = wsgi.SmartWSGIApp(self.transport)
86
return wsgi.RelpathSetter(wsgi_app, '', 'PATH_INFO')
88
# TODO: Use something here that uses the transport API
89
# rather than relying on the local filesystem API.
90
base = self.transport.base
91
readonly_prefix = 'readonly+'
92
if base.startswith(readonly_prefix):
93
base = base[len(readonly_prefix):]
95
path = urlutils.local_path_from_url(base)
96
except errors.InvalidURL:
97
raise httpexceptions.HTTPNotFound()
99
return urlparser.make_static(None, path)
101
def check_serveable(self, config):
102
value = config.get_user_option('http_serve')
105
elif not _bools.get(value.lower(), True):
24
f = os.path.join(self.root.folder, self.folder)
25
request = WSGIRequest(environ)
26
response = WSGIResponse()
27
listing = [d for d in os.listdir(f) if not d.startswith('.')]
28
response.headers['Content-Type'] = 'text/html'
29
print >> response, '<html><body>'
30
for d in sorted(listing):
32
print >> response, '<li><a href="%s/">%s</a></li>' % (d, d)
33
print >> response, '</body></html>'
34
return response(environ, start_response)
35
relpath = os.path.join(self.folder, segment)
36
f = os.path.join(self.root.folder, relpath)
37
if not os.path.isdir(f):
106
38
raise httpexceptions.HTTPNotFound()
108
def __call__(self, environ, start_response):
109
path = environ['PATH_INFO']
39
if f in self.root.cache:
40
return self.root.cache[f](environ, start_response)
111
b = branch.Branch.open_from_transport(self.transport)
42
b = branch.Branch.open(f)
112
43
except errors.NotBranchError:
113
if path.startswith('/.bzr'):
114
self.check_serveable(LocationConfig(self.transport.base))
115
return self.app_for_bazaar_data(path)(environ, start_response)
116
if not self.transport.listable() or not self.transport.has('.'):
117
raise httpexceptions.HTTPNotFound()
118
return self.app_for_non_branch(environ)(environ, start_response)
120
self.check_serveable(b.get_config())
121
if path.startswith('/.bzr'):
122
return self.app_for_bazaar_data(path)(environ, start_response)
124
return self.app_for_branch(b)(environ, start_response)
127
_transport_store = threading.local()
129
def get_transport_for_thread(base):
131
thread_transports = getattr(_transport_store, 'transports', None)
132
if thread_transports is None:
133
thread_transports = _transport_store.transports = {}
134
if base in thread_transports:
135
return thread_transports[base]
136
transport = get_transport(base)
140
class BranchesFromTransportRoot(object):
142
def __init__(self, base, config):
143
self.graph_cache = lru_cache.LRUCache(10)
145
self._config = config
147
def __call__(self, environ, start_response):
148
environ['loggerhead.static.url'] = environ['SCRIPT_NAME']
149
if environ['PATH_INFO'].startswith('/static/'):
150
segment = path_info_pop(environ)
151
assert segment == 'static'
152
return static_app(environ, start_response)
153
elif environ['PATH_INFO'] == '/favicon.ico':
154
return favicon_app(environ, start_response)
156
transport = get_transport_for_thread(self.base)
157
return BranchesFromTransportServer(
158
transport, self)(environ, start_response)
161
class UserBranchesFromTransportRoot(object):
163
def __init__(self, base, config):
164
self.graph_cache = lru_cache.LRUCache(10)
166
self._config = config
167
self.trunk_dir = config.get_option('trunk_dir')
169
def __call__(self, environ, start_response):
170
environ['loggerhead.static.url'] = environ['SCRIPT_NAME']
171
path_info = environ['PATH_INFO']
172
if path_info.startswith('/static/'):
173
segment = path_info_pop(environ)
174
assert segment == 'static'
175
return static_app(environ, start_response)
176
elif path_info == '/favicon.ico':
177
return favicon_app(environ, start_response)
179
transport = get_transport_for_thread(self.base)
180
# segments starting with ~ are user branches
181
if path_info.startswith('/~'):
182
segment = path_info_pop(environ)
183
return BranchesFromTransportServer(
184
transport.clone(segment[1:]), self, segment)(
185
environ, start_response)
187
return BranchesFromTransportServer(
188
transport.clone(self.trunk_dir), self)(
189
environ, start_response)
44
return BranchesFromFileSystemServer(relpath, self.root)(environ, start_response)
48
_history = History.from_branch(b)
49
_history.use_file_cache(FileChangeCache(_history, sql_dir))
50
h = BranchWSGIApp(_history, relpath).app
51
self.root.cache[f] = h
52
return h(environ, start_response)
56
class BranchesFromFileSystemRoot(object):
57
def __init__(self, folder):
60
def __call__(self, environ, start_response):
61
environ['loggerhead.static.url'] = environ['SCRIPT_NAME']
62
segment = path_info_pop(environ)
63
if segment == 'static':
64
return static_app(environ, start_response)
66
return BranchesFromFileSystemServer(
67
segment, self)(environ, start_response)
69
app = BranchesFromFileSystemRoot('.')
72
app = make_middleware(app)
73
app = make_filter(app, None)
76
httpserver.serve(app, host='127.0.0.1', port='9876')
added
removed
wsgitest.py
