comparison hgext/convert/subversion.py @ 4772:69548a9d9796

convert: fetch svn changes on demand (in batches)

4771:e2292928cbe6

except ImportError:
    pass

class CompatibilityException(Exception): pass

nbRevisionsPerFetch = 50

class svn_entry(object):
    """Emulate a Subversion path change."""
    __slots__ = ['path', 'copyfrom_path', 'copyfrom_rev', 'action']
    def __init__(self, entry):

            latest = svn.ra.get_latest_revnum(self.ra)
        dirent = svn.ra.stat(self.ra, self.module, latest)
        self.last_changed = dirent.created_rev

        self.head = self.rev(self.last_changed)

        # Should lazily fetch revisions in batches of, say, 1,000...:
        self._fetch_revisions(from_revnum=self.last_changed, to_revnum=0)

    def rev(self, revnum):
        return (u"svn:%s%s@%s" % (self.uuid, self.module, revnum)).decode(self.encoding)
            
    def get_blacklist(self):

        svn_url = self.base + module
        self.ui.debug("reparent to %s\n" % svn_url.encode(self.encoding))
        svn.ra.reparent(self.ra, svn_url.encode(self.encoding))

    def _fetch_revisions(self, from_revnum = 0, to_revnum = 347, pb=None):
        self.parent_cset = None
        self.child_cset = None
        
        self.ui.debug('Fetching revisions %d to %d\n' % (from_revnum, to_revnum))

        def get_entry_from_path(path, module=self.module):
            # Given the repository url of this wc, say
            #   "http://server/plone/CMFPlone/branches/Plone-2_0-branch"

                log = message and self.recode(message)
                author = author and self.recode(author) or ''

                cset = commit(author=author,
                        date=util.datestr(date), 
                        desc=log, 
                        parents=[],
                        copies=copies,
                        branch=branch)

                if self.child_cset is not None:
                    self.child_cset.parents = [rev]

                self.child_cset = cset

                self.commits[rev] = cset

        try:
            discover_changed_paths = True
            strict_node_history = False
            svn.ra.get_log(self.ra, [self.module], from_revnum, to_revnum, 

        cl = files
        cl.sort()
        return cl

    def getcommit(self, rev):
        return self.commits[rev]

    def gettags(self):
        return []

4772:69548a9d9796

except ImportError:
    pass

class CompatibilityException(Exception): pass

LOG_BATCH_SIZE = 50

class svn_entry(object):
    """Emulate a Subversion path change."""
    __slots__ = ['path', 'copyfrom_path', 'copyfrom_rev', 'action']
    def __init__(self, entry):

            latest = svn.ra.get_latest_revnum(self.ra)
        dirent = svn.ra.stat(self.ra, self.module, latest)
        self.last_changed = dirent.created_rev

        self.head = self.rev(self.last_changed)

    def rev(self, revnum):
        return (u"svn:%s%s@%s" % (self.uuid, self.module, revnum)).decode(self.encoding)
            
    def get_blacklist(self):

        svn_url = self.base + module
        self.ui.debug("reparent to %s\n" % svn_url.encode(self.encoding))
        svn.ra.reparent(self.ra, svn_url.encode(self.encoding))

    def _fetch_revisions(self, from_revnum = 0, to_revnum = 347, pb=None):
        if not hasattr(self, 'child_rev'):
            self.child_rev = from_revnum
            self.child_cset = self.commits.get(self.child_rev)
        else:
            self.commits[self.child_rev] = self.child_cset

        self.ui.debug('Fetching revisions %d to %d\n' % (from_revnum, to_revnum))

        def get_entry_from_path(path, module=self.module):
            # Given the repository url of this wc, say
            #   "http://server/plone/CMFPlone/branches/Plone-2_0-branch"

                log = message and self.recode(message)
                author = author and self.recode(author) or ''

                cset = commit(author=author,
                              date=util.datestr(date), 
                              desc=log, 
                              parents=[],
                              copies=copies,
                              branch=branch)

                if self.child_cset and self.child_rev != rev:
                    self.child_cset.parents = [rev]
                    self.commits[self.child_rev] = self.child_cset
                self.child_cset = cset
                self.child_rev = rev

        try:
            discover_changed_paths = True
            strict_node_history = False
            svn.ra.get_log(self.ra, [self.module], from_revnum, to_revnum, 

        cl = files
        cl.sort()
        return cl

    def getcommit(self, rev):
        if rev not in self.commits:
            revnum = int(rev.split('@')[-1])
            minrev = revnum - LOG_BATCH_SIZE > 0 and revnum - LOG_BATCH_SIZE or 0
            self._fetch_revisions(from_revnum=revnum, to_revnum=minrev)
        return self.commits[rev]

    def gettags(self):
        return []