from rhodecode.lib.auth import LoginRequired, HasRepoPermissionAnyDecorator

from rhodecode.lib.base import BaseRepoController, render

from rhodecode.lib.utils import EmptyChangeset

from rhodecode.lib.compat import OrderedDict

from rhodecode.lib import diffs

from rhodecode.model.db import ChangesetComment

from rhodecode.model.comment import ChangesetCommentsModel

from rhodecode.model.meta import Session

log = logging.getLogger(__name__)

    fid = h.FID(revision, path)

def get_ignore_ws(fid, GET):

    ig_ws_global = request.GET.get('ignorews')

    if ig_ws:

        try:

            return int(ig_ws[0].split(':')[-1])

        except:

            pass

    return ig_ws_global

def _ignorews_url(fileid=None):

    params = defaultdict(list)

    lbl = _('show white space')

    ig_ws = get_ignore_ws(fileid, request.GET)

    ln_ctx = get_line_ctx(fileid, request.GET)

    # global option

    if fileid is None:

        if ig_ws is None:

            params['ignorews'] += [1]

            lbl = _('ignore white space')

        ctx_key = 'context'

        ctx_val = ln_ctx

    # per file options

    else:

        if ig_ws is None:

            params[fileid] += ['WS:1']

            lbl = _('ignore white space')

        ctx_key = fileid

        ctx_val = 'C:%s' % ln_ctx

    # if we have passed in ln_ctx pass it along to our params

    if ln_ctx:

        params[ctx_key] += [ctx_val]

    params['anchor'] = fileid

    return h.link_to(lbl, h.url.current(**params))

def get_line_ctx(fid, GET):

    ln_ctx_global = request.GET.get('context')

    if ln_ctx:

        retval = ln_ctx[0].split(':')[-1]

    else:

        retval = ln_ctx_global

    try:

        return int(retval)

    except:

        return

def _context_url(fileid=None):

    """

    Generates url for context lines

    :param fileid:

    """

    ig_ws = get_ignore_ws(fileid, request.GET)

    ln_ctx = (get_line_ctx(fileid, request.GET) or 3) * 2

    params = defaultdict(list)

    # global option

    if fileid is None:

        if ln_ctx > 0:

            params['context'] += [ln_ctx]

        if ig_ws:

            ig_ws_key = 'ignorews'

            ig_ws_val = 1

    # per file option

    else:

        params[fileid] += ['C:%s' % ln_ctx]

        ig_ws_key = fileid

        ig_ws_val = 'WS:%s' % 1

    if ig_ws:

        params[ig_ws_key] += [ig_ws_val]

    lbl = _('%s line context') % ln_ctx

    params['anchor'] = fileid

    return h.link_to(lbl, h.url.current(**params))

def wrap_to_table(str_):

    return '''<table class="code-difftable">

                <td class="lineno new"></td>

                </tr>

              </table>''' % str_

class ChangesetController(BaseRepoController):

    @LoginRequired()

    @HasRepoPermissionAnyDecorator('repository.read', 'repository.write',

                                   'repository.admin')

    def __before__(self):

        super(ChangesetController, self).__before__()

        c.affected_files_cut_off = 60

    def index(self, revision):

        c.anchor_url = anchor_url

        c.ignorews_url = _ignorews_url

        c.context_url = _context_url

        #get ranges of revisions if preset

        rev_range = revision.split('...')[:2]

        try:

            if len(rev_range) == 2:

                rev_start = rev_range[0]

                rev_end = rev_range[1]

                rev_ranges = c.rhodecode_repo.get_changesets(start=rev_start,

                                                            end=rev_end)

            else:

                rev_ranges = [c.rhodecode_repo.get_changeset(revision)]

            c.cs_ranges = list(rev_ranges)

            if not c.cs_ranges:

                raise RepositoryError('Changeset range returned empty result')

        except (RepositoryError, ChangesetDoesNotExistError, Exception), e:

                    # made

                    c.sum_added += node.size

                    fid = h.FID(revision, node.path)

                    line_context_lcl = get_line_ctx(fid, request.GET)

                    ignore_whitespace_lcl = get_ignore_ws(fid, request.GET)

                    if c.sum_added < self.cut_off_limit:

                        f_gitdiff = diffs.get_gitdiff(filenode_old, node,

                                        ignore_whitespace=ignore_whitespace_lcl,

                                        context=line_context_lcl)

                        d = diffs.DiffProcessor(f_gitdiff, format='gitdiff')

                        st = d.stat()

                    else:

                        diff = wrap_to_table(_('Changeset is to big and '

                                               'was cut off, see raw '

                                               'changeset instead'))

                        c.cut_off = True

                        break

                cs1 = None

                cs2 = node.last_changeset.raw_id

                c.lines_added += st[0]

                c.lines_deleted += st[1]

                            ignore_whitespace_lcl = get_ignore_ws(fid, request.GET,)

                            f_gitdiff = diffs.get_gitdiff(filenode_old, node,

                                    ignore_whitespace=ignore_whitespace_lcl,

                                    context=line_context_lcl)

                            d = diffs.DiffProcessor(f_gitdiff,

                                                     format='gitdiff')

                            st = d.stat()

                            if (st[0] + st[1]) * 256 > self.cut_off_limit:

                                diff = wrap_to_table(_('Diff is to big '

                                                       'and was cut off, see '

                                                       'raw diff instead'))

                            else:

                            if diff:

                                c.sum_removed += len(diff)

                        else:

                            diff = wrap_to_table(_('Changeset is to big and '

                                                   'was cut off, see raw '

                                                   'changeset instead'))

                            c.cut_off = True

                            break

                    cs1 = filenode_old.last_changeset.raw_id

                    cs2 = node.last_changeset.raw_id

                                        repo_id=c.rhodecode_db_repo.repo_id,

                                        user_id=c.rhodecode_user.user_id,

                                        revision=revision,

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

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

        Session.commit()

        return redirect(h.url('changeset_home', repo_name=repo_name,

                              revision=revision))

    @jsonify

    def delete_comment(self, repo_name, comment_id):

        co = ChangesetComment.get(comment_id)

        if h.HasPermissionAny('hg.admin', 'repository.admin')() or owner:

            ChangesetCommentsModel().delete(comment=co)

            Session.commit()

            return True

        else:

            raise HTTPForbidden()

        """

        self.__udiff, iterator_copy = tee(self.__udiff)

        return iterator_copy

    def _extract_rev(self, line1, line2):

        """

        Extract the filename and revision hint from a line.

        """

        try:

            if line1.startswith('--- ') and line2.startswith('+++ '):

                l1 = line1[4:].split(None, 1)

                old_rev = l1[1] if len(l1) == 2 else 'old'

                l2 = line2[4:].split(None, 1)

                new_rev = l2[1] if len(l2) == 2 else 'new'

                return filename, new_rev, old_rev

        except (ValueError, IndexError):

            pass

        return None, None, None

    def _parse_gitdiff(self, diffiterator):

        def line_decoder(l):

            if l.startswith('+') and not l.startswith('+++'):

                self.adds += 1

            elif l.startswith('-') and not l.startswith('---'):

    def raw_diff(self):

        """

        Returns raw string as udiff

        """

        udiff_copy = self.copy_iterator()

        if self.__format == 'gitdiff':

            udiff_copy = self._parse_gitdiff(udiff_copy)

        return u''.join(udiff_copy)

    def as_html(self, table_class='code-difftable', line_class='line',

                new_lineno_class='lineno old', old_lineno_class='lineno new',

        """

        Return udiff as html table with customized css classes

        """

        def _link_to_if(condition, label, url):

            """

            Generates a link if condition is meet or just the label if not.

            """

            if condition:

                return '''<a href="%(url)s">%(label)s</a>''' % {'url': url,

                                                                'label': label}

            else:

                    _html.append('''\t<td %(a_id)s class="%(new_lineno_cls)s">''' \

                                    % {'a_id': anchor_new_id,

                                       'new_lineno_cls': new_lineno_class})

                    _html.append('''%(link)s''' \

                        % {'link':

                        _link_to_if(cond_new, change['new_lineno'], '#%s' \

                                                                % anchor_new)})

                    _html.append('''</td>\n''')

                    ###########################################################

                    # CODE

                    ###########################################################

                    _html.append('''\n\t\t<pre>%(code)s</pre>\n''' \

                                                % {'code': change['line']})

                    _html.append('''\t</td>''')

                    _html.append('''\n</tr>\n''')

        _html.append('''</table>''')

        if _html_empty:

            return None

        return ''.join(_html)

    def stat(self):

        """

        Returns tuple of added, and removed lines for this instance

    margin: 0px -10px 0px 5px;

    background-color: #DEDEDE;

}

.notifications a{

	color:#888 !important;

	display: block;

	font-size: 10px

}

.notifications a:hover{

	text-decoration: none !important;

}

.notification-header{

}

.notification-header .desc{

	font-size: 16px;

    height: 24px;

    float: left

}

.notification-list .container.unread{

}

.notification-header .desc.unread{

    font-weight: bold;

    font-size: 17px;

}

.notification-header .delete-notifications{

    float: right;

    padding-top: 8px;

    cursor: pointer;

}

.notification-subject{

    clear:both;

    height: 17px;

    line-height: 17px;

}

.diffblock.margined.comm .line .code:hover{

    background-color:#FFFFCC !important;

    cursor: pointer !important;

    background-image:url("../images/icons/comment_add.png") !important;

    background-repeat:no-repeat !important;

    background-position: right !important;

    background-position: 0% 50% !important;

}

	// create event for hide button

	form = new YAHOO.util.Element(form);

	var form_hide_button = new YAHOO.util.Element(form.getElementsByClassName('hide-inline-form')[0]);

	form_hide_button.on('click', function(e) {

		var newtr = e.currentTarget.parentNode.parentNode.parentNode.parentNode.parentNode;

		removeInlineForm(newtr);

		YUD.removeClass(parent_tr, 'form-open');

	});

	return form

};

var injectInlineForm = function(tr){

		  return

	  }	

	  YUD.addClass(tr,'form-open');

	  var node = tr.parentNode.parentNode.parentNode.getElementsByClassName('full_f_path')[0];

	  var f_path = YUD.getAttribute(node,'path');

	  var lineno = getLineNo(tr);

	  var form = createInlineForm(tr, f_path, lineno);

	  var target_tr = tr;

	  if(YUD.hasClass(YUD.getNextSibling(tr),'inline-comments')){

		  target_tr = YUD.getNextSibling(tr);

	  }

	  YUD.insertAfter(form,target_tr);

                            %endif

                            </div>

		                    <div class="changes">${h.fancy_file_stats(stat)}</div>

	                    </div>

	                %endfor

	                % if c.cut_off:

	                  ${_('Changeset was too big and was cut off...')}

	                % endif

	        </div>         

	    </div>

    </div>

    <%namespace name="comment" file="/changeset/changeset_file_comment.html"/>

    <script type="text/javascript">

      var deleteComment = function(comment_id){

          var url = "${url('changeset_comment_delete',repo_name=c.repo_name,comment_id='__COMMENT_ID__')}".replace('__COMMENT_ID__',comment_id);

          var postData = '_method=delete';

          var success = function(o){

              var n = YUD.get('comment-'+comment_id);

              n.parentNode.removeChild(n);

          }

          ajaxPOST(url,postData,success);

      }

      YUE.onDOMReady(function(){

              var act = e.currentTarget.nextElementSibling;

              if(YUD.hasClass(act,'active')){

              }else{

              }

          });

              for(c in btns){ 

                  YUD.setStyle(btns[c],'display',show);

          YUE.on(YUQ('.line'),'click',function(e){

          });

          // inject comments into they proper positions

          var file_comments = YUQ('.inline-comment-placeholder');

          for (f in file_comments){

                    var target_line = YUD.get(lineid);

                    var add = createInlineAddButton(target_line.parentNode,'${_("add another comment")}');

                    YUD.insertAfter(add,target_line.parentNode);

                    var comment = new YAHOO.util.Element(tableTr('inline-comments',inline.innerHTML))

                    YUD.insertAfter(comment,target_line.parentNode);

          }

      })

</%def>

## <%namespace name="comment" file="/changeset/changeset_file_comment.html"/>

## ${comment.comment_block(co)}

##

<%def name="comment_block(co)">

  <div class="comment" id="comment-${co.comment_id}">

    <div class="comment-wrapp">

  	<div class="meta">

  		<span class="user">

  			<img src="${h.gravatar_url(co.author.email, 20)}" />

  			${co.author.username}

  		</span>

  		<a href="${h.url.current(anchor='comment-%s' % co.comment_id)}"> ${_('commented on')} </a>

  		%if h.HasPermissionAny('hg.admin', 'repository.admin')() or co.author.user_id == c.rhodecode_user.user_id:

  			<div class="buttons">

  				<span onClick="deleteComment(${co.comment_id})" class="delete-comment ui-btn">${_('Delete')}</span>

  			</div>

  		%endif

  		${h.rst_w_mentions(co.text)|n}

  	</div>

    </div>

  </div>

</%def>

<div id='comment-inline-form-template' style="display:none">

  <div class="comment-inline-form">

  %if c.rhodecode_user.username != 'default':

      <div class="clearfix">

          <div class="comment-help">${_('Commenting on line')} {1}. ${_('Comments parsed using')} 

          <a href="${h.url('rst_help')}">RST</a> ${_('syntax')} ${_('with')} 

          <span style="color:#003367" class="tooltip" title="${_('Use @username inside this text to send notification to this RhodeCode user')}">@mention</span> ${_('support')}

          </div>

          <textarea id="text_{1}" name="text"></textarea>

      </div>

      <div class="comment-button">

      <input type="hidden" name="f_path" value="{0}">

      <input type="hidden" name="line" value="{1}">            

      ${h.submit('save', _('Comment'), class_='ui-btn')}

      ${h.reset('hide-inline-form', _('Hide'), class_='ui-btn hide-inline-form')}

      <div class="clearfix">

          <div class="comment-help">

            ${'You need to be logged in to comment.'} <a href="${h.url('login_home',came_from=h.url.current())}">${_('Login now')}</a>

          </div>

      </div>

      <div class="comment-button">

      ${h.reset('hide-inline-form', _('Hide'), class_='ui-btn hide-inline-form')}

      </div>

      ${h.end_form()}  

  %endif      

  </div>

</div>  

<%inherit file="/base/base.html"/>

<%def name="title()">

    ${c.repo_name} ${_('Changesets')} - r${c.cs_ranges[0].revision}:${h.short_id(c.cs_ranges[0].raw_id)} -> r${c.cs_ranges[-1].revision}:${h.short_id(c.cs_ranges[-1].raw_id)} - ${c.rhodecode_name}

</%def>

<%def name="breadcrumbs_links()">

    ${h.link_to(u'Home',h.url('/'))}

    »

    ${h.link_to(c.repo_name,h.url('summary_home',repo_name=c.repo_name))}

    »

    ${_('Changesets')} - r${c.cs_ranges[0].revision}:${h.short_id(c.cs_ranges[0].raw_id)} -> r${c.cs_ranges[-1].revision}:${h.short_id(c.cs_ranges[-1].raw_id)}

<%def name="page_nav()">

    ${self.menu('changelog')}     

</%def>

<%def name="main()">

<div class="box">

    <!-- box / title -->

    <div class="title">

        ${self.breadcrumbs()}

    </div>

    <div class="table">

		<div id="body" class="diffblock">

                <div>

				${_('Changesets')} - r${c.cs_ranges[0].revision}:${h.short_id(c.cs_ranges[0].raw_id)} -> r${c.cs_ranges[-1].revision}:${h.short_id(c.cs_ranges[-1].raw_id)}

				</div>

			</div>

		</div>

	    <div id="changeset_compare_view_content">

			<div class="container">

			<table class="compare_view_commits noborder">

            %for cs in c.cs_ranges:

                <tr>

                <td><div class="gravatar"><img alt="gravatar" src="${h.gravatar_url(h.email(cs.author),14)}"/></div></td>

                <td>${h.link_to('r%s:%s' % (cs.revision,h.short_id(cs.raw_id)),h.url('changeset_home',repo_name=c.repo_name,revision=cs.raw_id))}</td>

	        <div style="font-size:1.1em;font-weight: bold;clear:both;padding-top:10px">${_('Files affected')}</div>

	        <div class="cs_files">

	               %for cs in c.cs_ranges:

	                   <div class="cur_cs">r${cs}</div>

	                %for change,filenode,diff,cs1,cs2,st in c.changes[cs.raw_id]:

	                    <div class="cs_${change}">${h.link_to(h.safe_unicode(filenode.path),h.url.current(anchor=h.FID(cs.raw_id,filenode.path)))}</div>

	                %endfor

	               %endfor 

	        </div>         

	    </div>

    </div>