from kallithea.lib.page import RepoPage

from kallithea.lib.vcs.exceptions import RepositoryError, ChangesetDoesNotExistError, \

    ChangesetError, NodeDoesNotExistError, EmptyRepositoryError

from kallithea.lib.utils2 import safe_int, safe_str

log = logging.getLogger(__name__)

def _load_changelog_summary():

    # also used from summary ...

    p = safe_int(request.GET.get('page'), 1)

    size = safe_int(request.GET.get('size'), 10)

    def url_generator(**kw):

        return url('changelog_summary_home',

                   repo_name=c.db_repo.repo_name, size=size, **kw)

    collection = c.db_repo_scm_instance

    c.repo_changesets = RepoPage(collection, page=p,

                                 items_per_page=size,

                                 url=url_generator)

    page_revisions = [x.raw_id for x in list(c.repo_changesets)]

class ChangelogController(BaseRepoController):

    def _before(self, *args, **kwargs):

        super(ChangelogController, self)._before(*args, **kwargs)

        c.affected_files_cut_off = 60

    @staticmethod

    def __get_cs(rev, repo):

        """

        Safe way to get changeset. If error occur fail with error message.

        :param rev: revision to fetch

        :param repo: repo instance

        """

        try:

            return c.db_repo_scm_instance.get_changeset(rev)

        except EmptyRepositoryError as e:

            h.flash(h.literal(_('There are no changesets yet')),

                    category='error')

        except RepositoryError as e:

            log.error(traceback.format_exc())

            if f_path:

                log.debug('generating changelog for path %s', f_path)

                # get the history for the file !

                tip_cs = c.db_repo_scm_instance.get_changeset()

                try:

                    collection = tip_cs.get_file_history(f_path)

                except (NodeDoesNotExistError, ChangesetError):

                    #this node is not present at tip !

                    try:

                        cs = self.__get_cs(revision, repo_name)

                        collection = cs.get_file_history(f_path)

                    except RepositoryError as e:

                        h.flash(safe_str(e), category='warning')

                        raise HTTPFound(location=h.url('changelog_home', repo_name=repo_name))

                collection = list(reversed(collection))

            else:

                collection = c.db_repo_scm_instance.get_changesets(start=0, end=revision,

                                                        branch_name=branch_name)

            c.total_cs = len(collection)

            c.pagination = RepoPage(collection, page=p, item_count=c.total_cs,

                                    items_per_page=c.size, branch=branch_name,)

            page_revisions = [x.raw_id for x in c.pagination]

        except EmptyRepositoryError as e:

            h.flash(safe_str(e), category='warning')

            raise HTTPFound(location=url('summary_home', repo_name=c.repo_name))

        except (RepositoryError, ChangesetDoesNotExistError, Exception) as e:

            log.error(traceback.format_exc())

            h.flash(safe_str(e), category='error')

            raise HTTPFound(location=url('changelog_home', repo_name=c.repo_name))

        c.branch_name = branch_name

        c.branch_filters = [('', _('None'))] + \

            [(k, k) for k in c.db_repo_scm_instance.branches.keys()]

        if c.db_repo_scm_instance.closed_branches:

            prefix = _('(closed)') + ' '

            c.branch_filters += [('-', '-')] + \

                [(k, prefix + k) for k in c.db_repo_scm_instance.closed_branches.keys()]

        revs = []

        if not f_path:

            revs = [x.revision for x in c.pagination]

        c.jsdata = graph_data(c.db_repo_scm_instance, revs)

        c.revision = revision # requested revision ref

        c.first_revision = c.pagination[0] # pagination is never empty here!

        return render('changelog/changelog.html')

            other_ref_type=org_ref_type, other_ref_name=org_ref_name,

            merge=merge or '')

        # set callbacks for generating markup for icons

        c.ignorews_url = _ignorews_url

        c.context_url = _context_url

        ignore_whitespace = request.GET.get('ignorews') == '1'

        line_context = safe_int(request.GET.get('context'), 3)

        c.a_rev = self._get_ref_rev(c.a_repo, org_ref_type, org_ref_name,

            returnempty=True)

        c.cs_rev = self._get_ref_rev(c.cs_repo, other_ref_type, other_ref_name)

        c.compare_home = False

        c.a_ref_name = org_ref_name

        c.a_ref_type = org_ref_type

        c.cs_ref_name = other_ref_name

        c.cs_ref_type = other_ref_type

        c.cs_ranges, c.cs_ranges_org, c.ancestors = self._get_changesets(

            c.a_repo.scm_instance.alias, c.a_repo.scm_instance, c.a_rev,

            c.cs_repo.scm_instance, c.cs_rev)

        raw_ids = [x.raw_id for x in c.cs_ranges]

        c.cs_comments = c.cs_repo.get_comments(raw_ids)

        revs = [ctx.revision for ctx in reversed(c.cs_ranges)]

        c.jsdata = graph_data(c.cs_repo.scm_instance, revs)

        if partial:

            return render('compare/compare_cs.html')

        org_repo = c.a_repo

        other_repo = c.cs_repo

        if merge:

            rev1 = msg = None

            if not c.cs_ranges:

                msg = _('Cannot show empty diff')

            elif not c.ancestors:

                msg = _('No ancestor found for merge diff')

            elif len(c.ancestors) == 1:

                rev1 = c.ancestors[0]

            else:

                msg = _('Multiple merge ancestors found for merge compare')

            if rev1 is None:

                h.flash(msg, category='error')

                log.error(msg)

                raise HTTPNotFound

                    # TODO: handle branch heads that not are tip-most

                    brevs = org_scm_instance._repo.revs('%s - %ld - %s', c.cs_branch_name, avail_revs, revs[0])

                    if brevs:

                        # also show changesets that are on branch but neither ancestors nor descendants

                        show.update(org_scm_instance._repo.revs('::%ld - ::%ld - ::%s', brevs, avail_revs, c.a_branch_name))

                        show.add(revs[0]) # make sure graph shows this so we can see how they relate

                        c.update_msg_other = _('Note: Branch %s has another head: %s.') % (c.cs_branch_name,

                            h.short_id(org_scm_instance.get_changeset((max(brevs))).raw_id))

                    avail_show = sorted(show, reverse=True)

            elif org_scm_instance.alias == 'git':

                c.cs_repo.scm_instance.get_changeset(c.cs_rev) # check it exists - raise ChangesetDoesNotExistError if not

                c.update_msg = _("Git pull requests don't support iterating yet.")

        except ChangesetDoesNotExistError:

            c.update_msg = _('Error: some changesets not found when displaying pull request from %s.') % c.cs_rev

        c.avail_revs = avail_revs

        c.avail_cs = [org_scm_instance.get_changeset(r) for r in avail_show]

        c.avail_jsdata = graph_data(org_scm_instance, avail_show)

        raw_ids = [x.raw_id for x in c.cs_ranges]

        c.cs_comments = c.cs_repo.get_comments(raw_ids)

        ignore_whitespace = request.GET.get('ignorews') == '1'

        line_context = safe_int(request.GET.get('context'), 3)

        c.ignorews_url = _ignorews_url

        c.context_url = _context_url

        c.fulldiff = request.GET.get('fulldiff')

        diff_limit = self.cut_off_limit if not c.fulldiff else None

        # we swap org/other ref since we run a simple diff on one repo

        log.debug('running diff between %s and %s in %s',

                  c.a_rev, c.cs_rev, org_scm_instance.path)

        try:

            txtdiff = org_scm_instance.get_diff(rev1=safe_str(c.a_rev), rev2=safe_str(c.cs_rev),

                                                ignore_whitespace=ignore_whitespace,

                                                context=line_context)

        except ChangesetDoesNotExistError:

            txtdiff =  _("The diff can't be shown - the PR revisions could not be found.")

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

                                             diff_limit=diff_limit)

        _parsed = diff_processor.prepare()

        c.limited_diff = False

        if isinstance(_parsed, LimitedDiffContainer):

            c.limited_diff = True

        c.file_diff_data = []

        c.lines_added = 0

        c.lines_deleted = 0

        for f in _parsed:

            st = f['stats']

            c.lines_added += st['added']

            c.lines_deleted += st['deleted']

            filename = f['filename']

            fid = h.FID('', filename)

            diff = diff_processor.as_html(enable_comments=True,

                                          parsed_lines=[f])

            c.file_diff_data.append((fid, None, f['operation'], f['old_filename'], filename, diff, st))

        # inline comments

        c.inline_cnt = 0

        c.inline_comments = cc_model.get_inline_comments(

                                c.db_repo.repo_id,

                                pull_request=pull_request_id)

        # count inline comments

        for __, lines in c.inline_comments:

            for comments in lines.values():

                c.inline_cnt += len(comments)

        # comments

        # (badly named) pull-request status calculation based on reviewer votes

        (c.pull_request_reviewers,

         c.pull_request_pending_reviewers,

         c.current_voting_result,

         ) = cs_model.calculate_pull_request_result(c.pull_request)

        c.changeset_statuses = ChangesetStatus.STATUSES

        c.is_ajax_preview = False

        c.ancestors = None # [c.a_rev] ... but that is shown in an other way

        return render('/pullrequests/pullrequest_show.html')

    @LoginRequired()

    @NotAnonymous()

    @HasRepoPermissionLevelDecorator('read')

    @jsonify

    def comment(self, repo_name, pull_request_id):

        pull_request = PullRequest.get_or_404(pull_request_id)

        status = request.POST.get('changeset_status')

        close_pr = request.POST.get('save_close')

        delete = request.POST.get('save_delete')

        f_path = request.POST.get('f_path')

        line_no = request.POST.get('line')

                        %endif

                        ## text and href of open_new_pr is controlled from javascript

                        <a id="open_new_pr" class="btn btn-default btn-sm"></a>

                        ${_("Branch filter:")} ${h.select('branch_filter',c.branch_name,c.branch_filters)}

                    </div>

                </div>

                <div id="graph_nodes">

                    <canvas id="graph_canvas" style="width:0"></canvas>

                </div>

                <div id="graph_content" style="${'margin: 0px' if c.changelog_for_path else ''}">

                <table class="table" id="changesets">

                <tbody>

                %for cnt,cs in enumerate(c.pagination):

                    <tr id="chg_${cnt+1}" class="${'mergerow' if len(cs.parents) > 1 else ''}">

                        <td class="checkbox-column">

                            %if c.changelog_for_path:

                                ${h.checkbox(cs.raw_id,class_="changeset_range", disabled="disabled")}

                            %else:

                                ${h.checkbox(cs.raw_id,class_="changeset_range")}

                            %endif

                        </td>

                        <td class="status">

                              </a>

                            %else:

                              </a>

                            %endif

                          %endif

                        </td>

                        <td class="author" data-toggle="tooltip" title="${cs.author}">

                            ${h.gravatar(h.email_or_none(cs.author), size=16)}

                            <span class="user">${h.person(cs.author)}</span>

                        </td>

                        <td class="hash">

                            ${h.link_to(h.show_id(cs),h.url('changeset_home',repo_name=c.repo_name,revision=cs.raw_id), class_='changeset_hash')}

                        </td>

                        <td class="date">

                            <div class="date" data-toggle="tooltip" title="${h.fmt_date(cs.date)}">${h.age(cs.date,True)}</div>

                        </td>

                        <% message_lines = cs.message.splitlines() %>

                        %if len(message_lines) > 1:

                        <td class="expand_commit" title="${_('Expand commit message')}">

                            <i class="icon-align-left"></i>

                        </td>

                        %else:

                        <td></td>

                        %endif

                        <td class="mid">

                            <div class="log-container">

                                <div class="message">

                                    <div class="message-firstline">${h.urlify_text(message_lines[0], c.repo_name,h.url('changeset_home',repo_name=c.repo_name,revision=cs.raw_id))}</div>

                                    %if len(message_lines) > 1:

                                    <div class="message-full hidden">${h.urlify_text(cs.message, c.repo_name)}</div>

                                    %endif

                                </div>

                                <div class="extra-container">

                                            <i class="icon-comment-discussion"></i>

                                        </a>

                                    %endif

                                    %if cs.bumped:

                                        <span class="bumpedtag" title="Bumped">

                                            Bumped

                                        </span>

                                    %endif

                                    %if cs.divergent:

                                        <span class="divergenttag" title="Divergent">

                                            Divergent

                                        </span>

                                    %endif

                                    %if cs.extinct:

                                        <span class="extincttag" title="Extinct">

                                            Extinct

                                        </span>

                                    %endif

                                    %if cs.unstable:

                                        <span class="unstabletag" title="Unstable">

                                            Unstable

                                        </span>

                                    %endif

                                    %if cs.phase:

## -*- coding: utf-8 -*-

%if c.repo_changesets:

<table class="table">

    <tr>

        <th class="left"></th>

        <th class="left"></th>

        <th class="left">${_('Revision')}</th>

        <th class="left">${_('Commit Message')}</th>

        <th class="left">${_('Age')}</th>

        <th class="left">${_('Author')}</th>

        <th class="left">${_('Refs')}</th>

    </tr>

%for cnt,cs in enumerate(c.repo_changesets):

    <tr class="parity${cnt%2} ${'mergerow' if len(cs.parents) > 1 else ''}">

        <td class="compact">

                  </a>

                %else:

                  </a>

                %endif

              %endif

        </td>

        <td class="compact">

               <div class="comments-container">

                   <div title="${('comments')}">

                       </a>

                   </div>

               </div>

              %endif

        </td>

        <td>

            <a href="${h.url('changeset_home',repo_name=c.repo_name,revision=cs.raw_id)}" class="revision-link">${h.show_id(cs)}</a>

        </td>

        <td>

            ${h.urlify_text(h.chop_at(cs.message,'\n'),c.repo_name, h.url('changeset_home',repo_name=c.repo_name,revision=cs.raw_id))}

        </td>

        <td><span data-toggle="tooltip" title="${h.fmt_date(cs.date)}">

                      ${h.age(cs.date)}</span>

        </td>

        <td title="${cs.author}">${h.person(cs.author)}</td>

        <td>

            %if h.is_hg(c.db_repo_scm_instance):

                %for book in cs.bookmarks:

                    <span class="booktag" title="${_('Bookmark %s') % book}">

                        ${h.link_to(book,h.url('changeset_home',repo_name=c.repo_name,revision=cs.raw_id))}

                    </span>

                %endfor

            %endif

            %for tag in cs.tags:

        </div>

        <div>

          ${_('Please merge the target branch to your branch before creating a pull request.')}

        </div>

        %endif

        <div>

          ${_('Merge Ancestor')}:

          %for ancestor in c.ancestors:

            ${h.link_to(h.short_id(ancestor),h.url('changeset_home',repo_name=c.repo_name,revision=ancestor), class_="changeset_hash")}

          %endfor

        </div>

      </div>

    %endif

    <div id="graph_nodes">

        <canvas id="graph_canvas"></canvas>

    </div>

    <div id="graph_content_pr">

    <table class="table compare_view_commits">

    %for cnt, cs in enumerate(reversed(c.cs_ranges)):

      <tr id="chg_${cnt+1}" class="${'mergerow' if len(cs.parents) > 1 else ''}">

        <td>

          %endif

          %if c.cs_comments.get(cs.raw_id):

              <div class="comments-container">

                  <div class="comments-cnt" title="${_('Changeset has comments')}">

                      <a href="${c.cs_comments[cs.raw_id][0].url()}">

                          ${len(c.cs_comments[cs.raw_id])}

                          <i class="icon-comment"></i>

                      </a>

                  </div>

              </div>

          %endif

        </td>

        <td class="changeset-logical-index">

          <%

              num_cs = len(c.cs_ranges)

              index = num_cs - cnt

              if index == 1:

                  title = _('First (oldest) changeset in this list')

              elif index == num_cs:

                  title = _('Last (most recent) changeset in this list')

              else:

                  title = _('Position in this list of changesets')

          %>

          <span data-toggle="tooltip" title="${title}">