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
94
95
96
97
98
99
100
101
|
#!/usr/bin/env python
#
# Copyright (C) 2012 Codethink Limited
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; version 2 of the License.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License along
# with this program; if not, write to the Free Software Foundation, Inc.,
# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
import cliapp
import logging
import os
import urllib
from bottle import Bottle, request, response, run, static_file
from morphcacheserver.repocache import RepoCache
defaults = {
'repo-dir': '/var/cache/morph-cache-server/gits',
'bundle-dir': '/var/cache/morph-cache-server/bundles',
}
class MorphCacheServer(cliapp.Application):
def add_settings(self):
self.settings.string(['repo-dir'],
'path to the repository cache directory',
metavar='PATH',
default=defaults['repo-dir'])
self.settings.string(['bundle-dir'],
'path to the bundle cache directory',
metavar='PATH',
default=defaults['bundle-dir'])
def process_args(self, args):
app = Bottle()
repo_cache = RepoCache(self,
self.settings['repo-dir'],
self.settings['bundle-dir'])
@app.get('/sha1s')
def sha1():
repo = self._unescape_parameter(request.query.repo)
ref = self._unescape_parameter(request.query.ref)
try:
response.set_header('Cache-Control', 'no-cache')
sha1 = repo_cache.resolve_ref(repo, ref)
return {
'repo': '%s' % repo,
'ref': '%s' % ref,
'sha1': '%s' % sha1
}
except Exception, e:
response.status = 404
logging.debug('%s' % e)
@app.get('/files')
def file():
repo = self._unescape_parameter(request.query.repo)
ref = self._unescape_parameter(request.query.ref)
filename = self._unescape_parameter(request.query.filename)
try:
content = repo_cache.cat_file(repo, ref, filename)
response.set_header('Content-Type', 'application/octet-stream')
return content
except Exception, e:
response.status = 404
logging.debug('%s' % e)
@app.get('/bundles')
def bundle():
repo = self._unescape_parameter(request.query.repo)
filename = repo_cache.get_bundle_filename(repo)
dirname = os.path.dirname(filename)
basename = os.path.basename(filename)
return static_file(basename, root=dirname, download=True)
root = Bottle()
root.mount(app, '/1.0')
run(root, host='0.0.0.0', port=8080, reloader=True)
def _unescape_parameter(self, param):
return urllib.unquote(param)
if __name__ == '__main__':
MorphCacheServer().run()
|