log.error('compare of two different kind of remote repos not available')

            raise HTTPNotFound

        partial = request.environ.get('HTTP_X_PARTIAL_XHR')

        self.__get_cs_or_redirect(rev=org_ref, repo=org_repo, partial=partial)

        self.__get_cs_or_redirect(rev=other_ref, repo=other_repo, partial=partial)

        if rev_start and rev_end:

            #replace our org_ref with given CS

            org_ref = ('rev', rev_start)

            other_ref = ('rev', rev_end)

                                    org_repo, org_ref, other_repo, other_ref,

                                    )

        c.statuses = c.rhodecode_db_repo.statuses([x.raw_id for x in

                                                   c.cs_ranges])

        c.target_repo = c.repo_name

        # defines that we need hidden inputs with changesets

        c.as_form = request.GET.get('as_form', False)

        if partial:

            return render('compare/compare_cs.html')

        c.org_ref = org_ref[1]

            # for review purposes. Make the diff on the forked repo, with

            # revision that is common ancestor

            _org_ref = org_ref

            org_ref = ('rev', getattr(c.cs_ranges[0].parents[0]

                                      if c.cs_ranges[0].parents

                                      else EmptyChangeset(), 'raw_id'))

            log.debug('Changed org_ref from %s to %s' % (_org_ref, org_ref))

            other_repo = org_repo

        diff_limit = self.cut_off_limit if not fulldiff else None

        _diff = diffs.differ(org_repo, org_ref, other_repo, other_ref,

                             remote_compare=incoming_changesets)

        diff_processor = diffs.DiffProcessor(_diff or '', format='gitdiff',

                                             diff_limit=diff_limit)

        _parsed = diff_processor.prepare()

        c.limited_diff = False

        if isinstance(_parsed, LimitedDiffContainer):

            c.limited_diff = True

        c.files = []

        c.changes = {}

class InMemoryBundleRepo(bundlerepository):

    def __init__(self, ui, path, bundlestream):

        self._tempparent = None

        localrepo.localrepository.__init__(self, ui, path)

        self.ui.setconfig('phases', 'publish', False)

        self.bundle = bundlestream

        # dict with the mapping 'filename' -> position in the bundle

        self.bundlefilespos = {}

           remote_compare=False, context=3, ignore_whitespace=False):

    """

    General differ between branches, bookmarks, revisions of two remote or

    local but related repositories

    :param org_repo:

    :param org_ref:

    :param other_repo:

    :type other_repo:

    :type other_ref:

    """

    org_ref = org_ref[1]

    other_ref = other_ref[1]

    if org_repo_scm == other_repo_scm:

        log.debug('running diff between %s@%s and %s@%s'

                  % (org_repo.path, org_ref, other_repo.path, other_ref))

        _diff = org_repo_scm.get_diff(rev1=org_ref, rev2=other_ref,

            ignore_whitespace=ignore_whitespace, context=context)

        return _diff

    elif remote_compare:

        opts = diffopts(git=True, ignorews=ignore_whitespace, context=context)

        org_repo_peer = localrepo.locallegacypeer(org_repo.local())

        # create a bundle (uncompressed if other repo is not local)

        if org_repo_peer.capable('getbundle'):

            # disable repo hooks here since it's just bundle !

            # patch and reset hooks section of UI config to not run any

            # hooks on fetching archives with subrepos

            for k, _ in org_repo.ui.configitems('hooks'):

                org_repo.ui.setconfig('hooks', k, None)

            unbundle = org_repo.getbundle('incoming', common=None,

                                          heads=None)

            buf = BytesIO()

                self.sa.delete(reviewer)

    def delete(self, pull_request):

        pull_request = self.__get_pull_request(pull_request)

        Session().delete(pull_request)

    def close_pull_request(self, pull_request):

        pull_request = self.__get_pull_request(pull_request)

        pull_request.status = PullRequest.STATUS_CLOSED

        pull_request.updated_on = datetime.datetime.now()

        self.sa.add(pull_request)

        """

        Returns a list of changesets that are incoming from org_repo@org_ref

        to other_repo@other_ref

        :param org_repo:

        :param org_ref:

        :param other_repo:

        :param other_ref:

        :param tmp:

        """

        changesets = []

        #case two independent repos

        if org_repo != other_repo:

            revs = [

                org_repo._repo.lookup(org_ref[1]),

                org_repo._repo.lookup(other_ref[1]),

            ]

            obj = findcommonoutgoing(org_repo._repo,

                        localrepo.locallegacypeer(other_repo._repo.local()),

                        revs,

                        force=True)

            revs = obj.missing

                    changesets.append(org_repo.get_changeset(cs))

            elif alias == 'git':

                so, se = org_repo.run_git_command(

                    'log --reverse --pretty="format: %%H" -s -p %s..%s' % (org_ref[1],

                                                                     other_ref[1])

                )

                ids = re.findall(r'[0-9a-fA-F]{40}', so)

                for cs in (ids):

                    changesets.append(org_repo.get_changeset(cs))

        return changesets

    def get_compare_data(self, org_repo, org_ref, other_repo, other_ref):

        """

        :param org_repo:

        :type org_repo:

        :param org_ref:

        :type org_ref:

        :param other_repo:

        :type other_repo:

        :param other_ref:

        :type other_ref:

        """

        if len(org_ref) != 2 or not isinstance(org_ref, (list, tuple)):

            raise Exception('org_ref must be a two element list/tuple')

        if len(other_ref) != 2 or not isinstance(org_ref, (list, tuple)):

            raise Exception('other_ref must be a two element list/tuple')

        org_repo_scm = org_repo.scm_instance

        other_repo_scm = other_repo.scm_instance

        alias = org_repo.scm_instance.alias

        cs_ranges = self._get_changesets(alias,

                                         org_repo_scm, org_ref,