from kallithea.lib.diffs import DiffProcessor, LimitedDiffContainer

from kallithea.model.db import CacheInvalidation

from kallithea.lib.utils2 import safe_int, str2bool, safe_unicode

log = logging.getLogger(__name__)

language = 'en-us'

ttl = "5"

class FeedController(BaseRepoController):

    @LoginRequired(api_access=True)

    @HasRepoPermissionLevelDecorator('read')

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

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

    def _get_title(self, cs):

        return h.shorter(cs.message, 160)

    def __changes(self, cs):

        changes = []

        rss_cut_off_limit = safe_int(CONFIG.get('rss_cut_off_limit', 32 * 1024))

        diff_processor = DiffProcessor(cs.diff(),

                                       diff_limit=rss_cut_off_limit)

        _parsed = diff_processor.prepare(inline_diff=False)

        limited_diff = False

        if isinstance(_parsed, LimitedDiffContainer):

            limited_diff = True

        for st in _parsed:

            st.update({'added': st['stats']['added'],

                       'removed': st['stats']['deleted']})

            changes.append('\n %(operation)s %(filename)s '

                           '(%(added)s lines added, %(removed)s lines removed)'

                            % st)

        if limited_diff:

            changes = changes + ['\n ' +

                                 _('Changeset was too big and was cut off...')]

        return diff_processor, changes

    def __get_desc(self, cs):

        desc_msg = [(_('%s committed on %s')

                     % (h.person(cs.author), h.fmt_date(cs.date))) + '<br/>']

        #branches, tags, bookmarks

        if cs.branch:

            desc_msg.append('branch: %s<br/>' % cs.branch)

        for tag in cs.tags:

            desc_msg.append('tag: %s<br/>' % tag)

        diff_processor, changes = self.__changes(cs)

        # rev link

        _url = h.canonical_url('changeset_home', repo_name=c.db_repo.repo_name,

                   revision=cs.raw_id)

        desc_msg.append('changeset: <a href="%s">%s</a>' % (_url, cs.raw_id[:8]))

        desc_msg.append('<pre>')

        desc_msg.append(h.urlify_text(cs.message))

        desc_msg.append('\n')

        desc_msg.extend(changes)

        if str2bool(CONFIG.get('rss_include_diff', False)):

            desc_msg.append('\n\n')

            desc_msg.append(diff_processor.as_raw())

        desc_msg.append('</pre>')

        return map(safe_unicode, desc_msg)

    def atom(self, repo_name):

        """Produce an atom-1.0 feed via feedgenerator module"""

        @cache_region('long_term', '_get_feed_from_cache')

        def _get_feed_from_cache(key, kind):

            feed = Atom1Feed(

                title=_('%s %s feed') % (c.site_name, repo_name),

                link=h.canonical_url('summary_home', repo_name=repo_name),

                description=_('Changes on %s repository') % repo_name,

                language=language,

                ttl=ttl

            )

            rss_items_per_page = safe_int(CONFIG.get('rss_items_per_page', 20))

            for cs in reversed(list(c.db_repo_scm_instance[-rss_items_per_page:])):

                feed.add_item(title=self._get_title(cs),

                              link=h.canonical_url('changeset_home', repo_name=repo_name,

                                       revision=cs.raw_id),

                              author_name=cs.author,

                              description=''.join(self.__get_desc(cs)),

                              pubdate=cs.date,

                              )

            response.content_type = feed.mime_type

            return feed.writeString('utf-8')

        kind = 'ATOM'

        valid = CacheInvalidation.test_and_set_valid(repo_name, kind)

        if not valid:

            region_invalidate(_get_feed_from_cache, None, '_get_feed_from_cache', repo_name, kind)

from kallithea.lib.vcs.conf import settings

from kallithea.lib.vcs.backends.base import BaseChangeset, EmptyChangeset

from kallithea.lib.vcs.exceptions import (

    RepositoryError, ChangesetError, NodeDoesNotExistError, VCSError,

    ChangesetDoesNotExistError, ImproperArchiveTypeError

)

from kallithea.lib.vcs.nodes import (

    FileNode, DirNode, NodeKind, RootNode, SubModuleNode,

    ChangedFileNodesGenerator, AddedFileNodesGenerator, RemovedFileNodesGenerator

)

from kallithea.lib.vcs.utils import (

    safe_unicode, safe_str, safe_int, date_fromtimestamp

)

from kallithea.lib.vcs.utils.lazy import LazyProperty

class GitChangeset(BaseChangeset):

    """

    Represents state of the repository at single revision.

    """

    def __init__(self, repository, revision):

        self._stat_modes = {}

        self.repository = repository

        revision = safe_str(revision)

        try:

            commit = self.repository._repo[revision]

            if isinstance(commit, objects.Tag):

                revision = safe_str(commit.object[1])

                commit = self.repository._repo.get_object(commit.object[1])

        except KeyError:

            raise RepositoryError("Cannot get object with id %s" % revision)

        self.raw_id = revision

        self.id = self.raw_id

        self.short_id = self.raw_id[:12]

        self._commit = commit

        self._tree_id = commit.tree

        self._committer_property = 'committer'

        self._author_property = 'author'

        self._date_property = 'commit_time'

        self._date_tz_property = 'commit_timezone'

        self.revision = repository.revisions.index(revision)

        self.nodes = {}

        self._paths = {}

    @LazyProperty

    def message(self):

        return safe_unicode(self._commit.message)

    @LazyProperty

    def committer(self):

        return safe_unicode(getattr(self._commit, self._committer_property))

    @LazyProperty

    def author(self):

        return safe_unicode(getattr(self._commit, self._author_property))

    @LazyProperty

    def date(self):

        return date_fromtimestamp(getattr(self._commit, self._date_property),

                                  getattr(self._commit, self._date_tz_property))

    @LazyProperty

    def _timestamp(self):

        return getattr(self._commit, self._date_property)

    @LazyProperty

    def status(self):

        """

        Returns modified, added, removed, deleted files for current changeset

        """

        return self.changed, self.added, self.removed

    @LazyProperty

    def tags(self):

        _tags = []

        for tname, tsha in self.repository.tags.iteritems():

            if tsha == self.raw_id:

                _tags.append(tname)

        return _tags

    @LazyProperty

    def branch(self):

        heads = self.repository._heads(reverse=False)

        ref = heads.get(self.raw_id)

        if ref:

            return safe_unicode(ref)

    def _fix_path(self, path):

        """

        Paths are stored without trailing slash so we need to get rid off it if

        needed.

                        <% 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">

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

                                        <a class="comments-container comments-cnt" href="${c.cs_comments[cs.raw_id][0].url()}" data-toggle="tooltip" title="${_('%s comments') % len(c.cs_comments[cs.raw_id])}">

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

                                            <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:

                                        <span class="phasetag" title="Phase">

                                            ${cs.phase}

                                        </span>

                                    %endif

                                    %for tag in cs.tags:

                                        <span class="tagtag" title="${_('Tag %s') % tag}">

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

                                        </span>

                                    %endfor

                                    %if (not c.branch_name) and cs.branch:

                                        <span class="branchtag" title="${_('Branch %s' % cs.branch)}">

                                            ${h.link_to(cs.branch,h.url('changelog_home',repo_name=c.repo_name,branch=cs.branch))}

                                        </span>

                                    %endif

                                </div>

                            </div>

                        </td>

                    </tr>

                %endfor

                </tbody>

                </table>

                <input type="checkbox" id="singlerange" style="display:none"/>

                </div>

                ${c.cs_pagination.pager()}

        <script type="text/javascript" src="${h.url('/js/graph.js', ver=c.kallithea_version)}"></script>

        <script type="text/javascript">

            var jsdata = ${h.js(c.jsdata)};

            var graph = new BranchRenderer('graph_canvas', 'graph_content', 'chg_');

            $(document).ready(function(){

                var $checkboxes = $('.changeset_range');

                pyroutes.register('changeset_home', ${h.js(h.url('changeset_home', repo_name='%(repo_name)s', revision='%(revision)s'))}, ['repo_name', 'revision']);

                var checkbox_checker = function(e) {

                    var $checked_checkboxes = $checkboxes.filter(':checked');

                    var $singlerange = $('#singlerange');

                    $('#rev_range_container').hide();

                    $checkboxes.show();

                    $singlerange.show();

                    if ($checked_checkboxes.length > 0) {

                        $checked_checkboxes.first().parent('td').append($singlerange);

                        var singlerange = $singlerange.prop('checked');

                        var rev_end = $checked_checkboxes.first().prop('name');

                        if ($checked_checkboxes.length > 1 || singlerange) {

                            var rev_start = $checked_checkboxes.last().prop('name');

<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.cs_pagination):

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

        <td class="compact">

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

                %if c.cs_statuses.get(cs.raw_id)[2]:

                  <a data-toggle="tooltip" title="${_('Changeset status: %s by %s\nClick to open associated pull request %s') % (c.cs_statuses.get(cs.raw_id)[1], c.cs_statuses.get(cs.raw_id)[5].username, c.cs_statuses.get(cs.raw_id)[4])}" href="${h.url('pullrequest_show',repo_name=c.cs_statuses.get(cs.raw_id)[3],pull_request_id=c.cs_statuses.get(cs.raw_id)[2])}">

                    <i class="icon-circle changeset-status-${c.cs_statuses.get(cs.raw_id)[0]}"></i>

                  </a>

                %else:

                  <a data-toggle="tooltip" title="${_('Changeset status: %s by %s') % (c.cs_statuses.get(cs.raw_id)[1], c.cs_statuses.get(cs.raw_id)[5].username)}"

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

                    <i class="icon-circle changeset-status-${c.cs_statuses.get(cs.raw_id)[0]}"></i>

                  </a>

                %endif

              %endif

        </td>

        <td class="compact">

              %if c.cs_comments.get(cs.raw_id,[]):

               <div class="comments-container">

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

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

                          <i class="icon-comment"></i>${len(c.cs_comments[cs.raw_id])}

                       </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>

            %for tag in cs.tags:

             <span class="tagtag" title="${_('Tag %s') % tag}">

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

             </span>

            %endfor

            %if cs.branch:

             <span class="branchtag" title="${_('Branch %s' % cs.branch)}">

                 ${h.link_to(cs.branch,h.url('changelog_home',repo_name=c.repo_name,branch=cs.branch))}

             </span>

            %endif

        </td>

    </tr>

%endfor

</table>

${c.cs_pagination.pager()}

%else:

%if h.HasRepoPermissionLevel('write')(c.repo_name):

<h4>${_('Add or upload files directly via Kallithea')}</h4>

<div>

  <div id="add_node_id" class="add_node">

      <a class="btn btn-default btn-xs" href="${h.url('files_add_home',repo_name=c.repo_name,revision=0,f_path='', anchor='edit')}">${_('Add New File')}</a>

  </div>

</div>

%endif

<h4>${_('Push new repository')}</h4>

<pre>

    ${c.db_repo_scm_instance.alias} clone ${c.clone_repo_url}

    ${c.db_repo_scm_instance.alias} add README # add first file

    ${c.db_repo_scm_instance.alias} commit -m "Initial" # commit with message

    ${c.db_repo_scm_instance.alias} push ${'origin master' if h.is_git(c.db_repo_scm_instance) else ''} # push changes back

</pre>

<h4>${_('Existing repository?')}</h4>

<pre>

%if h.is_git(c.db_repo_scm_instance):

    git remote add origin ${c.clone_repo_url}

    git push -u origin master

%else:

    hg push ${c.clone_repo_url}

%endif

</pre>

%endif

    AJAX_COMMENT_URL = ${h.js(url('changeset_comment',repo_name=c.repo_name,revision=c.changeset.raw_id))};

    AJAX_COMMENT_DELETE_URL = ${h.js(url('changeset_comment_delete',repo_name=c.repo_name,comment_id='__COMMENT_ID__'))};

  </script>

  <div class="panel-body">

    <div class="panel panel-default">

        <div class="panel-heading clearfix">

            <div class="parents pull-left">

                <div id="parent_link">

                    <i class="icon-left-open"></i> <a href="#">${_('Parent rev.')}</a>

                </div>

            </div>

            <div class="pull-right children">

                <div id="child_link">

                    <a href="#">${_('Child rev.')}</a> <i class="icon-right-open"></i>

                </div>

            </div>

            <div class="pull-left">

                <div class="pull-left" title="${_('Changeset status')}">

                    %if c.statuses:

                        <i class="icon-circle changeset-status-${c.statuses[0]}"></i>

                        [${h.changeset_status_lbl(c.statuses[0])}]

                    %endif

                </div>

                <div class="diff-actions pull-left">

                  <a href="${h.url('changeset_raw_home',repo_name=c.repo_name,revision=c.changeset.raw_id)}" data-toggle="tooltip" title="${_('Raw diff')}">

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

                  </a>

                  <a href="${h.url('changeset_patch_home',repo_name=c.repo_name,revision=c.changeset.raw_id)}" data-toggle="tooltip" title="${_('Patch diff')}">

                      <i class="icon-file-powerpoint"></i>

                  </a>

                  <a href="${h.url('changeset_download_home',repo_name=c.repo_name,revision=c.changeset.raw_id,diff='download')}" data-toggle="tooltip" title="${_('Download diff')}">

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

                  </a>

                  ${c.ignorews_url(request.GET)}

                  ${c.context_url(request.GET)}

                </div>

            </div>

        </div>

        <div class="panel-body">

            <div class="form-group changeset_content_header clearfix">

                <div class="pull-right">

                    <span class="logtags">

                        %if len(c.changeset.parents)>1:

                        <span class="mergetag">${_('Merge')}</span>

                        %endif

                        %for tag in c.changeset.tags:

                         <span class="tagtag"  title="${_('Tag %s') % tag}">

                         ${h.link_to(tag,h.url('changeset_home',repo_name=c.repo_name,revision=c.changeset.raw_id))}</span>

                        %endfor

                        %if c.changeset.branch:

                         <span class="branchtag" title="${_('Branch %s') % c.changeset.branch}">

                         ${h.link_to(c.changeset.branch,h.url('changelog_home',repo_name=c.repo_name,branch=c.changeset.branch))}

                         </span>

                        %endif

                    </span>

                    <div class="changes">

                        % if (len(c.changeset.affected_files) <= c.affected_files_cut_off) or c.fulldiff:

                         <span class="label deleted" title="${_('Removed')}">${len(c.changeset.removed)}</span>

                         <span class="label changed" title="${_('Changed')}">${len(c.changeset.changed)}</span>

                         <span class="label added" title="${_('Added')}">${len(c.changeset.added)}</span>

                        % else:

                         <span class="label deleted" title="${_('Affected %s files') % len(c.changeset.affected_files)}">!</span>

                         <span class="label changed" title="${_('Affected %s files') % len(c.changeset.affected_files)}">!</span>

                         <span class="label added"   title="${_('Affected %s files') % len(c.changeset.affected_files)}">!</span>

                        % endif

                    </div>

                </div>

                <div class="pull-left">

                     <div class="author">

                         ${h.gravatar_div(h.email_or_none(c.changeset.author), size=20)}

                         <span><b>${h.person(c.changeset.author,'full_name_and_username')}</b> - ${h.age(c.changeset.date,True)} ${h.fmt_date(c.changeset.date)}</span><br/>

                         <span>${h.email_or_none(c.changeset.author)}</span><br/>

                     </div>

                     <% rev = c.changeset.extra.get('source') %>

                     %if rev:

                     <div>

                       ${_('Grafted from:')} ${h.link_to(h.short_id(rev),h.url('changeset_home',repo_name=c.repo_name,revision=rev), class_="changeset_hash")}

                     </div>

                     %endif

                     <% rev = c.changeset.extra.get('transplant_source', '').encode('hex') %>

                     %if rev:

                     <div>

                       ${_('Transplanted from:')} ${h.link_to(h.short_id(rev),h.url('changeset_home',repo_name=c.repo_name,revision=rev), class_="changeset_hash")}

                     </div>

                     %endif

                     % if hasattr(c.changeset, 'successors') and c.changeset.successors:

                     <div class='successors'>

                       <span class='successors_header'>${_('Replaced by:')} </span>

                       % for i, s in enumerate(c.changeset.successors):