comparison hgext/evolve.py @ 1202:4099b087f672 stable

evolve: handle invalid obsmarkers in the `debugobsconvert`

User can now recover from such situation, The error message is also changed to
point the `debugobsconvert` commands.

1201:ee9c10728b68

    for chg, obs in _obsrelsethashtree(repo):
        ui.status('%s %s\n' % (node.hex(chg), node.hex(obs)))

_bestformat = max(obsolete.formats.keys())

@command(
    'debugobsconvert',
    [('', 'new-format', _bestformat, _('Destination format for markers.'))],
    '')
def debugobsconvert(ui, repo, new_format):

    f = repo.sopener('obsstore', 'wb', atomictemp=True)
    origmarkers = repo.obsstore._all
    known = set()
    markers = []
    for m in origmarkers:
        if m in known:
            continue
        known.add(m)
        markers.append(m)
    ui.write(_('Old store is version %d, will rewrite in version %d\n') % (

1202:4099b087f672

    for chg, obs in _obsrelsethashtree(repo):
        ui.status('%s %s\n' % (node.hex(chg), node.hex(obs)))

_bestformat = max(obsolete.formats.keys())


if getattr(obsolete, '_checkinvalidmarkers', None) is not None:
    @eh.wrapfunction(obsolete, '_checkinvalidmarkers')
    def _checkinvalidmarkers(orig, markers):
        """search for marker with invalid data and raise error if needed

        Exist as a separated function to allow the evolve extension for a more
        subtle handling.
        """
        if 'debugobsconvert' in sys.argv:
            return
        for mark in markers:
            if node.nullid in mark[1]:
                raise util.Abort(_('bad obsolescence marker detected: '
                                   'invalid successors nullid'),
                                 hint=_('You should run `hg debugobsconvert`'))

@command(
    'debugobsconvert',
    [('', 'new-format', _bestformat, _('Destination format for markers.'))],
    '')
def debugobsconvert(ui, repo, new_format):

    f = repo.sopener('obsstore', 'wb', atomictemp=True)
    origmarkers = repo.obsstore._all
    known = set()
    markers = []
    for m in origmarkers:
        # filter out invalid markers
        if nullid in m[1]:
            m = list(m)
            m[1] = tuple(s for s in m[1] if s != nullid)
            m = tuple(m)
        if m in known:
            continue
        known.add(m)
        markers.append(m)
    ui.write(_('Old store is version %d, will rewrite in version %d\n') % (