comparison mercurial/bundle2.py @ 20947:c33d7bf53812

bundle2: feed a unbundle20 to the `processbundle` function

The unbundle can comes from multiple sources. (on disk file, peer, etc) and
(ultimately) of multiple type (bundle10, bundle20). The `processbundle` is no
longer in charge of creating the bundle.

20946:e910336539f7

        assert lparttype not in parthandlermapping
        parthandlermapping[lparttype] = func
        return func
    return _decorator

def processbundle(repo, stream):
    """This function process a bundle, apply effect to/from a repo

    Currently it:
    - parse a stream into an unbundle20 object
    - iterate over each parts then search and use the proper handling code to
      process the part.

    Parts are processes in order.

    This is very early version of this function that will be strongly reworked
    before final usage.

    Unknown Mandatory part will abort the process.
    """
    ui = repo.ui
    # Extraction of the unbundler object will most likely change. It may be
    # done outside of this function, the unbundler would be passed as argument.
    # in all case the unbundler will eventually be created by a
    # `changegroup.readbundle` style function.
    unbundler = unbundle20(ui, stream)
    # todo:
    # - replace this is a init function soon.
    # - exception catching
    unbundler.params
    iterparts = iter(unbundler)

20947:c33d7bf53812

        assert lparttype not in parthandlermapping
        parthandlermapping[lparttype] = func
        return func
    return _decorator

def processbundle(repo, unbundler):
    """This function process a bundle, apply effect to/from a repo

    It iterates over each part then searches for and uses the proper handling
    code to process the part. Parts are processed in order.

    This is very early version of this function that will be strongly reworked
    before final usage.

    Unknown Mandatory part will abort the process.
    """
    ui = repo.ui
    # todo:
    # - replace this is a init function soon.
    # - exception catching
    unbundler.params
    iterparts = iter(unbundler)