From 826d67400c317836cd9dd02bb03b39a390e4514b Mon Sep 17 00:00:00 2001 From: =?utf8?q?=C5=81ukasz=20Rekucki?= Date: Tue, 29 Sep 2009 16:11:07 +0200 Subject: [PATCH] Added "merge_url" to document meta-data. Gallery API (no view yet). --- lib/wlrepo/backend_mercurial.py | 565 -------------------------------- 1 file changed, 565 deletions(-) delete mode 100644 lib/wlrepo/backend_mercurial.py diff --git a/lib/wlrepo/backend_mercurial.py b/lib/wlrepo/backend_mercurial.py deleted file mode 100644 index 35e4442e..00000000 --- a/lib/wlrepo/backend_mercurial.py +++ /dev/null @@ -1,565 +0,0 @@ -## -*- encoding: utf-8 -*- -# -#__author__ = "Łukasz Rekucki" -#__date__ = "$2009-09-18 10:49:24$" -# -#__doc__ = """RAL implementation over Mercurial""" -# -#import mercurial -#from mercurial import localrepo as hglrepo -#from mercurial import ui as hgui -#from mercurial.node import nullid -#import re -#import wlrepo -# -#FILTER = re.compile(r"^pub_(.+)\.xml$", re.UNICODE) -# -#def default_filter(name): -# m = FILTER.match(name) -# if m is not None: -# return name, m.group(1) -# return None -# -#class MercurialLibrary(wlrepo.Library): -# -# def __init__(self, path, maincabinet="default", ** kwargs): -# super(wlrepo.Library, self).__init__( ** kwargs) -# -# self._hgui = hgui.ui() -# self._hgui.config('ui', 'quiet', 'true') -# self._hgui.config('ui', 'interactive', 'false') -# -# import os.path -# self._ospath = self._sanitize_string(os.path.realpath(path)) -# -# maincabinet = self._sanitize_string(maincabinet) -# -# if os.path.isdir(path): -# try: -# self._hgrepo = hglrepo.localrepository(self._hgui, path) -# except mercurial.error.RepoError: -# raise wlrepo.LibraryException("[HGLibrary] Not a valid repository at path '%s'." % path) -# elif kwargs.get('create', False): -# os.makedirs(path) -# try: -# self._hgrepo = hglrepo.localrepository(self._hgui, path, create=1) -# except mercurial.error.RepoError: -# raise wlrepo.LibraryException("[HGLibrary] Can't create a repository on path '%s'." % path) -# else: -# raise wlrepo.LibraryException("[HGLibrary] Can't open a library on path '%s'." % path) -# -# # fetch the main cabinet -# lock = self._hgrepo.lock() -# try: -# btags = self._hgrepo.branchtags() -# -# if not self._has_branch(maincabinet): -# raise wlrepo.LibraryException("[HGLibrary] No branch named '%s' to init main cabinet" % maincabinet) -# -# self._maincab = MercurialCabinet(self, maincabinet) -# finally: -# lock.release() -# -# @property -# def ospath(self): -# return self._ospath -# -# @property -# def main_cabinet(self): -# return self._maincab -# -# def document(self, docid, user, part=None, shelve=None): -# return self.cabinet(docid, user, create=False).retrieve(part=part, shelve=shelve) -# -# def cabinet(self, docid, user, create=False): -# docid = self._sanitize_string(docid) -# user = self._sanitize_string(user) -# -# bname = self._bname(user, docid) -# -# lock = self._lock(True) -# try: -# if self._has_branch(bname): -# return MercurialCabinet(self, doc=docid, user=user) -# -# if not create: -# raise wlrepo.CabinetNotFound(bname) -# -# # check if the docid exists in the main cabinet -# needs_touch = not self._maincab.exists(docid) -# cab = MercurialCabinet(self, doc=docid, user=user) -# -# name, fileid = cab._filename(None) -# -# def cleanup_action(l): -# if needs_touch: -# l._fileopener()(fileid, "w").write('') -# l._fileadd(fileid) -# -# garbage = [fid for (fid, did) in l._filelist() if not did.startswith(docid)] -# l._filesrm(garbage) -# print "removed: ", garbage -# -# # create the branch -# self._create_branch(bname, before_commit=cleanup_action) -# return MercurialCabinet(self, doc=docid, user=user) -# finally: -# lock.release() -# -# # -# # Private methods -# # -# -# # -# # Locking -# # -# -# def _lock(self, write_mode=False): -# return self._hgrepo.wlock() # no support for read/write mode yet -# -# def _transaction(self, write_mode, action): -# lock = self._lock(write_mode) -# try: -# return action(self) -# finally: -# lock.release() -# -# # -# # Basic repo manipulation -# # -# -# def _checkout(self, rev, force=True): -# return MergeStatus(mercurial.merge.update(self._hgrepo, rev, False, force, None)) -# -# def _merge(self, rev): -# """ Merge the revision into current working directory """ -# return MergeStatus(mercurial.merge.update(self._hgrepo, rev, True, False, None)) -# -# def _common_ancestor(self, revA, revB): -# return self._hgrepo[revA].ancestor(self.repo[revB]) -# -# def _commit(self, message, user=u"library"): -# return self._hgrepo.commit(text=message, user=user) -# -# -# def _fileexists(self, fileid): -# return (fileid in self._hgrepo[None]) -# -# def _fileadd(self, fileid): -# return self._hgrepo.add([fileid]) -# -# def _filesadd(self, fileid_list): -# return self._hgrepo.add(fileid_list) -# -# def _filerm(self, fileid): -# return self._hgrepo.remove([fileid]) -# -# def _filesrm(self, fileid_list): -# return self._hgrepo.remove(fileid_list) -# -# def _filelist(self, filter=default_filter): -# for name in self._hgrepo[None]: -# result = filter(name) -# if result is None: continue -# -# yield result -# -# def _fileopener(self): -# return self._hgrepo.wopener -# -# def _filectx(self, fileid, branchid): -# return self._hgrepo.filectx(fileid, changeid=branchid) -# -# def _changectx(self, nodeid): -# return self._hgrepo.changectx(nodeid) -# -# # -# # BASIC BRANCH routines -# # -# -# def _bname(self, user, docid): -# """Returns a branch name for a given document and user.""" -# docid = self._sanitize_string(docid) -# uname = self._sanitize_string(user) -# return "personal_" + uname + "_file_" + docid; -# -# def _has_branch(self, name): -# return self._hgrepo.branchmap().has_key(self._sanitize_string(name)) -# -# def _branch_tip(self, name): -# name = self._sanitize_string(name) -# return self._hgrepo.branchtags()[name] -# -# def _create_branch(self, name, parent=None, before_commit=None): -# name = self._sanitize_string(name) -# -# if self._has_branch(name): return # just exit -# -# if parent is None: -# parent = self._maincab -# -# parentrev = parent._hgtip() -# -# self._checkout(parentrev) -# self._hgrepo.dirstate.setbranch(name) -# -# if before_commit: before_commit(self) -# -# self._commit("[AUTO] Initial commit for branch '%s'." % name, user='library') -# -# # revert back to main -# self._checkout(self._maincab._hgtip()) -# return self._branch_tip(name) -# -# def _switch_to_branch(self, branchname): -# current = self._hgrepo[None].branch() -# -# if current == branchname: -# return current # quick exit -# -# self._checkout(self._branch_tip(branchname)) -# return branchname -# -# def shelf(self, nodeid=None): -# if nodeid is None: -# nodeid = self._maincab._name -# return MercurialShelf(self, self._changectx(nodeid)) -# -# -# # -# # Utils -# # -# -# @staticmethod -# def _sanitize_string(s): -# if isinstance(s, unicode): -# s = s.encode('utf-8') -# return s -# -#class MercurialCabinet(wlrepo.Cabinet): -# -# def __init__(self, library, branchname=None, doc=None, user=None): -# if doc and user: -# super(MercurialCabinet, self).__init__(library, doc=doc, user=user) -# self._branchname = library._bname(user=user, docid=doc) -# elif branchname: -# super(MercurialCabinet, self).__init__(library, name=branchname) -# self._branchname = branchname -# else: -# raise ValueError("Provide either doc/user or branchname") -# -# def shelf(self): -# return self._library.shelf(self._branchname) -# -# def parts(self): -# return self._execute_in_branch(action=lambda l, c: (e[1] for e in l._filelist())) -# -# def retrieve(self, part=None, shelf=None): -# name, fileid = self._filename(part) -# -# print "Retrieving document %s from cab %s" % (name, self._name) -# -# if fileid is None: -# raise wlrepo.LibraryException("Can't retrieve main document from main cabinet.") -# -# def retrieve_action(l,c): -# if l._fileexists(fileid): -# return MercurialDocument(c, name=name, fileid=fileid) -# print "File %s not found " % fileid -# return None -# -# return self._execute_in_branch(retrieve_action) -# -# def create(self, name, initial_data): -# name, fileid = self._filename(name) -# -# if name is None: -# raise ValueError("Can't create main doc for maincabinet.") -# -# def create_action(l, c): -# if l._fileexists(fileid): -# raise wlrepo.LibraryException("Can't create document '%s' in cabinet '%s' - it already exists" % (fileid, c.name)) -# -# fd = l._fileopener()(fileid, "w") -# fd.write(initial_data) -# fd.close() -# l._fileadd(fileid) -# l._commit("File '%s' created." % fileid) -# return MercurialDocument(c, fileid=fileid, name=name) -# -# return self._execute_in_branch(create_action) -# -# def exists(self, part=None, shelf=None): -# name, filepath = self._filename(part) -# -# if filepath is None: return False -# return self._execute_in_branch(lambda l, c: l._fileexists(filepath)) -# -# def _execute_in_branch(self, action, write=False): -# def switch_action(library): -# old = library._switch_to_branch(self._branchname) -# try: -# return action(library, self) -# finally: -# library._switch_to_branch(old) -# -# return self._library._transaction(write_mode=write, action=switch_action) -# -# -# def _filename(self, docid): -# return self._partname(docid, 'xml') -# -# def _partname(self, docid, part): -# docid = self._library._sanitize_string(part) -# part = self._library._sanitize_string(part) -# -# if part is None: -# part = 'xml' -# -# if self._maindoc == '' and docid is None: -# return None -# -# return 'pub_' + docid + '.' + part -# -# def _fileopener(self): -# return self._library._fileopener() -# -# def _hgtip(self): -# return self._library._branch_tip(self._branchname) -# -# def _filectx(self, fileid): -# return self._library._filectx(fileid, self._branchname) -# -# def ismain(self): -# return (self._library.main_cabinet == self) -# -#class MercurialDocument(wlrepo.Document): -# -# def __init__(self, cabinet, docid): -# super(MercurialDocument, self).__init__(cabinet, name=docid) -# self._opener = self._cabinet._fileopener() -# self._docid = docid -# self._ctxs = {} -# -# def _ctx(self, part): -# if not self._ctxs.has_key(part): -# self._ctxs[part] = self._cabinet._filectx(self._fileid()) -# return self._ctxs[part] -# -# def _fileid(self, part='xml'): -# return self._cabinet._partname(self._docid, part) -# -# def read(self, part='xml'): -# return self._opener(self._ctx(part).path(), "r").read() -# -# def write(self, data, part='xml'): -# return self._opener(self._ctx(part).path(), "w").write(data) -# -# def commit(self, message, user): -# """Commit all parts of the document.""" -# self.library._fileadd(self._fileid) -# self.library._commit(self._fileid, message, user) -# -# def update(self): -# """Update parts of the document.""" -# lock = self.library._lock() -# try: -# if self._cabinet.ismain(): -# return True # always up-to-date -# -# user = self._cabinet.username or 'library' -# mdoc = self.library.document(self._fileid) -# -# mshelf = mdoc.shelf() -# shelf = self.shelf() -# -# if not mshelf.ancestorof(shelf) and not shelf.parentof(mshelf): -# shelf.merge_with(mshelf, user=user) -# -# return True -# finally: -# lock.release() -# -# def share(self, message): -# lock = self.library._lock() -# try: -# print "sharing from", self._cabinet, self._cabinet.username -# -# if self._cabinet.ismain(): -# return True # always shared -# -# if self._cabinet.username is None: -# raise ValueError("Can only share documents from personal cabinets.") -# -# user = self._cabinet.username -# -# main = self.library.shelf() -# local = self.shelf() -# -# no_changes = True -# -# # Case 1: -# # * local -# # | -# # * <- can also be here! -# # /| -# # / | -# # main * * -# # | | -# # The local branch has been recently updated, -# # so we don't need to update yet again, but we need to -# # merge down to default branch, even if there was -# # no commit's since last update -# -# if main.ancestorof(local): -# print "case 1" -# main.merge_with(local, user=user, message=message) -# no_changes = False -# # Case 2: -# # -# # main * * local -# # |\ | -# # | \| -# # | * -# # | | -# # -# # Default has no changes, to update from this branch -# # since the last merge of local to default. -# elif local.has_common_ancestor(main): -# print "case 2" -# if not local.parentof(main): -# main.merge_with(local, user=user, message=message) -# no_changes = False -# -# # Case 3: -# # main * -# # | -# # * <- this case overlaps with previos one -# # |\ -# # | \ -# # | * local -# # | | -# # -# # There was a recent merge to the defaul branch and -# # no changes to local branch recently. -# # -# # Use the fact, that user is prepared to see changes, to -# # update his branch if there are any -# elif local.ancestorof(main): -# print "case 3" -# if not local.parentof(main): -# local.merge_with(main, user=user, message='Local branch update.') -# no_changes = False -# else: -# print "case 4" -# local.merge_with(main, user=user, message='Local branch update.') -# local = self.shelf() -# main.merge_with(local, user=user, message=message) -# -# print "no_changes: ", no_changes -# return no_changes -# finally: -# lock.release() -# -# def shared(self): -# return self.library.main_cabinet.retrieve(self._name) -# -# def exists(self, part='xml'): -# return self._cabinet.exists(self._fileid(part)) -# -# @property -# def size(self): -# return self._filectx.size() -# -# def shelf(self): -# return self._cabinet.shelf() -# -# @property -# def last_modified(self): -# return self._filectx.date() -# -# def __str__(self): -# return u"Document(%s->%s)" % (self._cabinet.name, self._name) -# -# def __eq__(self, other): -# return self._filectx == other._filectx -# -# -# -#class MercurialShelf(wlrepo.Shelf): -# -# def __init__(self, lib, changectx): -# super(MercurialShelf, self).__init__(lib) -# -# if isinstance(changectx, str): -# self._changectx = lib._changectx(changectx) -# else: -# self._changectx = changectx -# -# @property -# def _rev(self): -# return self._changectx.node() -# -# def __str__(self): -# return self._changectx.hex() -# -# def __repr__(self): -# return "MercurialShelf(%s)" % self._changectx.hex() -# -# def ancestorof(self, other): -# nodes = list(other._changectx._parents) -# while nodes[0].node() != nullid: -# v = nodes.pop(0) -# if v == self._changectx: -# return True -# nodes.extend( v._parents ) -# return False -# -# def parentof(self, other): -# return self._changectx in other._changectx._parents -# -# def has_common_ancestor(self, other): -# a = self._changectx.ancestor(other._changectx) -# # print a, self._changectx.branch(), a.branch() -# -# return (a.branch() == self._changectx.branch()) -# -# def merge_with(self, other, user, message): -# lock = self._library._lock(True) -# try: -# self._library._checkout(self._changectx.node()) -# self._library._merge(other._changectx.node()) -# self._library._commit(user=user, message=message) -# finally: -# lock.release() -# -# def __eq__(self, other): -# return self._changectx.node() == other._changectx.node() -# -# -#class MergeStatus(object): -# def __init__(self, mstatus): -# self.updated = mstatus[0] -# self.merged = mstatus[1] -# self.removed = mstatus[2] -# self.unresolved = mstatus[3] -# -# def isclean(self): -# return self.unresolved == 0 -# -#class UpdateStatus(object): -# -# def __init__(self, mstatus): -# self.modified = mstatus[0] -# self.added = mstatus[1] -# self.removed = mstatus[2] -# self.deleted = mstatus[3] -# self.untracked = mstatus[4] -# self.ignored = mstatus[5] -# self.clean = mstatus[6] -# -# def has_changes(self): -# return bool(len(self.modified) + len(self.added) + \ -# len(self.removed) + len(self.deleted)) -# -#__all__ = ["MercurialLibrary"] \ No newline at end of file -- 2.20.1