statichttprepo.py
79 lines
| 2.5 KiB
| text/x-python
|
PythonLexer
/ mercurial / statichttprepo.py
|
r1101 | # statichttprepo.py - simple http repository class for mercurial | ||
# | ||||
# This provides read-only repo access to repositories exported via static http | ||||
# | ||||
|
r2859 | # Copyright 2005, 2006 Matt Mackall <mpm@selenic.com> | ||
|
r1101 | # | ||
# This software may be used and distributed according to the terms | ||||
# of the GNU General Public License, incorporated herein by reference. | ||||
|
r2740 | from demandload import * | ||
from i18n import gettext as _ | ||||
|
r1325 | demandload(globals(), "changelog filelog httprangereader") | ||
|
r2740 | demandload(globals(), "localrepo manifest os urllib urllib2 util") | ||
|
r1325 | |||
class rangereader(httprangereader.httprangereader): | ||||
def read(self, size=None): | ||||
try: | ||||
return httprangereader.httprangereader.read(self, size) | ||||
|
r1821 | except urllib2.HTTPError, inst: | ||
raise IOError(None, inst) | ||||
|
r1325 | except urllib2.URLError, inst: | ||
|
r1821 | raise IOError(None, inst.reason[1]) | ||
|
r1101 | |||
def opener(base): | ||||
"""return a function that opens files over http""" | ||||
p = base | ||||
def o(path, mode="r"): | ||||
|
r3794 | f = "/".join((p, urllib.quote(path))) | ||
|
r1325 | return rangereader(f) | ||
|
r1101 | return o | ||
class statichttprepository(localrepo.localrepository): | ||||
def __init__(self, ui, path): | ||||
|
r2673 | self._url = path | ||
|
r1101 | self.path = (path + "/.hg") | ||
|
r3791 | self.spath = self.path | ||
|
r1101 | self.ui = ui | ||
|
r2072 | self.revlogversion = 0 | ||
|
r1101 | self.opener = opener(self.path) | ||
|
r3851 | # find requirements | ||
try: | ||||
requirements = self.opener("requires").read().splitlines() | ||||
except IOError: | ||||
requirements = [] | ||||
# check them | ||||
for r in requirements: | ||||
if r not in self.supported: | ||||
raise repo.RepoError(_("requirement '%s' not supported") % r) | ||||
# setup store | ||||
self.spath = self.path | ||||
|
r3791 | self.sopener = opener(self.spath) | ||
|
r3851 | |||
|
r3791 | self.manifest = manifest.manifest(self.sopener) | ||
self.changelog = changelog.changelog(self.sopener) | ||||
|
r1101 | self.tagscache = None | ||
self.nodetagscache = None | ||||
|
r1598 | self.encodepats = None | ||
self.decodepats = None | ||||
|
r1101 | |||
|
r2673 | def url(self): | ||
return 'static-' + self._url | ||||
|
r1101 | def dev(self): | ||
return -1 | ||||
def local(self): | ||||
return False | ||||
|
r2740 | |||
def instance(ui, path, create): | ||||
if create: | ||||
raise util.Abort(_('cannot create new static-http repository')) | ||||
if path.startswith('old-http:'): | ||||
ui.warn(_("old-http:// syntax is deprecated, " | ||||
"please use static-http:// instead\n")) | ||||
path = path[4:] | ||||
else: | ||||
path = path[7:] | ||||
return statichttprepository(ui, path) | ||||