1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
import cgi, os, tempfile
from bzrlib import branch, errors
from loggerhead.history import History
from loggerhead.wsgiapp import BranchWSGIApp, static_app
from paste.request import path_info_pop
from paste.wsgiwrappers import WSGIRequest, WSGIResponse
from paste import httpexceptions
from paste import httpserver
from paste.httpexceptions import make_middleware
from paste.translogger import make_filter
from loggerhead.changecache import FileChangeCache
sql_dir = tempfile.mkdtemp()
class BranchesFromFileSystemServer(object):
def __init__(self, folder, root):
self.folder = folder
self.root = root
def directory_listing(self, path, environ, start_response):
request = WSGIRequest(environ)
response = WSGIResponse()
listing = [d for d in os.listdir(path) if not d.startswith('.')]
response.headers['Content-Type'] = 'text/html'
print >> response, '<html><body>'
for d in sorted(listing):
if os.path.isdir(os.path.join(path, d)):
d = cgi.escape(d)
print >> response, '<li><a href="%s/">%s</a></li>' % (d, d)
print >> response, '</body></html>'
return response(environ, start_response)
def app_for_branch(self, b, path):
b.lock_read()
try:
_history = History.from_branch(b)
_history.use_file_cache(FileChangeCache(_history, sql_dir))
if not self.folder:
name = os.path.basename(os.path.abspath(path))
else:
name = self.folder
h = BranchWSGIApp(_history, name).app
self.root.cache[path] = h
return h
finally:
b.unlock()
def __call__(self, environ, start_response):
path = os.path.join(self.root.folder, self.folder)
if not os.path.isdir(path):
raise httpexceptions.HTTPNotFound()
if path in self.root.cache:
return self.root.cache[path](environ, start_response)
try:
b = branch.Branch.open(path)
except errors.NotBranchError:
segment = path_info_pop(environ)
if segment is None:
raise httpexceptions.HTTPMovedPermanently(environ['SCRIPT_NAME'] + '/')
elif segment == '':
return self.directory_listing(path, environ, start_response)
else:
relpath = os.path.join(self.folder, segment)
return BranchesFromFileSystemServer(relpath, self.root)(
environ, start_response)
else:
return self.app_for_branch(b, path)(environ, start_response)
class BranchesFromFileSystemRoot(object):
def __init__(self, folder):
self.cache = {}
self.folder = folder
def __call__(self, environ, start_response):
environ['loggerhead.static.url'] = environ['SCRIPT_NAME']
if environ['PATH_INFO'].startswith('/static/'):
segment = path_info_pop(environ)
assert segment == 'static'
return static_app(environ, start_response)
else:
return BranchesFromFileSystemServer(
'', self)(environ, start_response)
app = BranchesFromFileSystemRoot('.')
app = app
app = make_middleware(app)
app = make_filter(app, None)
httpserver.serve(app, host='127.0.0.1', port='9876')
|