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

"""

    package.rhodecode.controllers.summary

    ~~~~~~~~~~~~~~

    Summary controller for Rhodecode

    :created_on: Apr 18, 2010

    :author: marcink

    :copyright: (C) 2009-2010 Marcin Kuzminski <marcin@python-works.com>    

    :license: GPLv3, see COPYING for more details.

"""

# This program is free software; you can redistribute it and/or

# modify it under the terms of the GNU General Public License

# as published by the Free Software Foundation; version 2

# of the License or (at your opinion) any later version of the license.

# 

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU General Public License for more details.

# 

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

# MA  02110-1301, USA.

import calendar

import logging

from time import mktime

from datetime import datetime, timedelta

from vcs.exceptions import ChangesetError

from pylons import tmpl_context as c, request, url

from pylons.i18n.translation import _

from rhodecode.model.scm import ScmModel

from rhodecode.model.db import Statistics

from rhodecode.lib.auth import LoginRequired, HasRepoPermissionAnyDecorator

from rhodecode.lib.base import BaseController, render

from rhodecode.lib.utils import OrderedDict, EmptyChangeset

from rhodecode.lib.celerylib import run_task

from rhodecode.lib.celerylib.tasks import get_commits_stats

from webhelpers.paginate import Page

try:

    import json

except ImportError:

    #python 2.5 compatibility

    import simplejson as json

log = logging.getLogger(__name__)

class SummaryController(BaseController):

    @LoginRequired()

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

                                   'repository.admin')

    def __before__(self):

        super(SummaryController, self).__before__()

    def index(self):

        scm_model = ScmModel()

        c.repo_info = scm_model.get_repo(c.repo_name)

        c.following = scm_model.is_following_repo(c.repo_name,

                                             c.rhodecode_user.user_id)

        def url_generator(**kw):

            return url('shortlog_home', repo_name=c.repo_name, **kw)

        c.repo_changesets = Page(c.repo_info, page=1, items_per_page=10,

                                 url=url_generator)

        e = request.environ

        if self.rhodecode_user.username == 'default':

            password = ':default'

        else:

            password = ''

        uri = u'%(protocol)s://%(user)s%(password)s@%(host)s%(prefix)s/%(repo_name)s' % {

                                        'protocol': e.get('wsgi.url_scheme'),

                                        'user':str(c.rhodecode_user.username),

                                        'password':password,

                                        'host':e.get('HTTP_HOST'),

                                        'prefix':e.get('SCRIPT_NAME'),

                                        'repo_name':c.repo_name, }

        c.clone_repo_url = uri

        c.repo_tags = OrderedDict()

        for name, hash in c.repo_info.tags.items()[:10]:

            try:

                c.repo_tags[name] = c.repo_info.get_changeset(hash)

            except ChangesetError:

                c.repo_tags[name] = EmptyChangeset(hash)

        c.repo_branches = OrderedDict()

        for name, hash in c.repo_info.branches.items()[:10]:

            try:

                c.repo_branches[name] = c.repo_info.get_changeset(hash)

            except ChangesetError:

                c.repo_branches[name] = EmptyChangeset(hash)

        td = datetime.today() + timedelta(days=1)

        y, m, d = td.year, td.month, td.day

        ts_min_y = mktime((y - 1, (td - timedelta(days=calendar.mdays[m])).month,

                            d, 0, 0, 0, 0, 0, 0,))

        ts_min_m = mktime((y, (td - timedelta(days=calendar.mdays[m])).month,

                            d, 0, 0, 0, 0, 0, 0,))

        ts_max_y = mktime((y, m, d, 0, 0, 0, 0, 0, 0,))

        if c.repo_info.dbrepo.enable_statistics:

            c.no_data_msg = _('No data loaded yet')

            run_task(get_commits_stats, c.repo_info.name, ts_min_y, ts_max_y)

        else:

        c.ts_min = ts_min_m

        c.ts_max = ts_max_y

        stats = self.sa.query(Statistics)\

            .filter(Statistics.repository == c.repo_info.dbrepo)\

            .scalar()

        if stats and stats.languages:

            lang_stats = json.loads(stats.languages)

            c.commit_data = stats.commit_activity

            c.overview_data = stats.commit_activity_combined

            c.trending_languages = json.dumps(OrderedDict(

                                       sorted(lang_stats.items(), reverse=True,

                                            key=lambda k: k[1])[:10]

                                        )

                                    )

        else:

            c.commit_data = json.dumps({})

            c.overview_data = json.dumps([[ts_min_y, 0], [ts_max_y, 10] ])

            c.trending_languages = json.dumps({})

            c.no_data = True

        return render('summary/summary.html')

			    var cur_data = args[0];

			    var cur_ranges = args[1];

				var new_data = [];

		    	var inputs = choiceContainer.getElementsByTagName("input");

		    	//show only checked labels

		        for(var i=0; i<inputs.length; i++) {

		            var checkbox_key = inputs[i].name;

	                if(inputs[i].checked){

						for(var d in cur_data){

							if(cur_data[d].label == checkbox_key){

								new_data.push(cur_data[d]);

							}

						}			                

	    	        }

	                else{

		                //push dummy data to not hide the label

						new_data.push(getDummyData(checkbox_key));

			        }

		        }

		    	var new_options = YAHOO.lang.merge(plot_options, {

		            xaxis: { 

		  	      		min: cur_ranges.xaxis.from, 

		  	      		max: cur_ranges.xaxis.to,

		  	      		mode:"time",

		  	      		timeformat: "%d/%m",

		        	},

		    	});

		    	if (!new_data){

					new_data = [[0,1]];

				}

		    	// do the zooming

		       plot = YAHOO.widget.Flot(plotContainer, new_data, new_options);

		       plot.subscribe("plotselected", plotselected);

		       //resubscribe plothover

		       plot.subscribe("plothover", plothover);

		       // don't fire event on the overview to prevent eternal loop

		       overview.setSelection(cur_ranges, true);

		    }

			/**

		     * plot only selected items from overview

		     * @param ranges

		     * @returns

		     */

		    function plotselected(ranges,cur_data) {

			    //updates the data for new plot

	    		data = getDataAccordingToRanges(ranges);

	    		generateCheckboxes(data);

		    	var new_options = YAHOO.lang.merge(plot_options, {

		            xaxis: { 

		  	      		min: ranges.xaxis.from, 

		  	      		max: ranges.xaxis.to,

		  	      		mode:"time",

		  	      		timeformat: "%d/%m",

		        	},

		        	yaxis: { 

                        min: ranges.yaxis.from, 

                        max: ranges.yaxis.to,

                    },

		    	});

		    	// do the zooming

		        plot = YAHOO.widget.Flot(plotContainer, data, new_options);

		        plot.subscribe("plotselected", plotselected);

		        //resubscribe plothover

		        plot.subscribe("plothover", plothover);

		        // don't fire event on the overview to prevent eternal loop

		        overview.setSelection(ranges, true);

		        //resubscribe choiced

		        YUE.on(choiceContainer.getElementsByTagName("input"), "click", plotchoiced, [data, ranges]);

		    }

		    var previousPoint = null;

			function plothover(o) {

		        var pos = o.pos;

		        var item = o.item;

		        //YUD.get("x").innerHTML = pos.x.toFixed(2);

		        //YUD.get("y").innerHTML = pos.y.toFixed(2);

		        if (item) {

		            if (previousPoint != item.datapoint) {

		                previousPoint = item.datapoint;

		                var tooltip = YUD.get("tooltip");

		                if(tooltip) {

		                	  tooltip.parentNode.removeChild(tooltip);

		                }

		                var x = item.datapoint.x.toFixed(2);

		                var y = item.datapoint.y.toFixed(2);

		                if (!item.series.label){

		                    item.series.label = 'commits';

		                }

		                var d = new Date(x*1000);

		                var fd = d.toDateString()

		                var nr_commits = parseInt(y);

		                var cur_data = dataset[item.series.label].data[item.dataIndex];

		                var added = cur_data.added;

		                var changed = cur_data.changed;

		                var removed = cur_data.removed;

		                var nr_commits_suffix = " ${_('commits')} ";

		                var added_suffix = " ${_('files added')} ";

		                var changed_suffix = " ${_('files changed')} ";

		                var removed_suffix = " ${_('files removed')} ";

		                if(nr_commits == 1){nr_commits_suffix = " ${_('commit')} ";}

						if(added==1){added_suffix=" ${_('file added')} ";}

						if(changed==1){changed_suffix=" ${_('file changed')} ";}

						if(removed==1){removed_suffix=" ${_('file removed')} ";}

		                showTooltip(item.pageX, item.pageY, item.series.label + " on " + fd

								 +'<br/>'+

		                         nr_commits + nr_commits_suffix+'<br/>'+

		                         added + added_suffix +'<br/>'+

		                         changed + changed_suffix + '<br/>'+

		                         removed + removed_suffix + '<br/>');

		            }

		        }

		        else {

		        	  var tooltip = YUD.get("tooltip");

			          if(tooltip) {

			                tooltip.parentNode.removeChild(tooltip);

			          }

		            previousPoint = null;

		        }

		    }

		    /**

		     * MAIN EXECUTION

		     */

			var data = getDataAccordingToRanges(initial_ranges);

			generateCheckboxes(data);

		    //main plot

		    var plot = YAHOO.widget.Flot(plotContainer,data,plot_options);

			//overview

			var overview = YAHOO.widget.Flot(overviewContainer, overview_dataset, overview_options);

			//show initial selection on overview

			overview.setSelection(initial_ranges);    

		    plot.subscribe("plotselected", plotselected);

		    overview.subscribe("plotselected", function (ranges) {

		        plot.setSelection(ranges);

		    });		

		    plot.subscribe("plothover", plothover);

		    YUE.on(choiceContainer.getElementsByTagName("input"), "click", plotchoiced, [data, initial_ranges]);

		}

			SummaryPlot(${c.ts_min},${c.ts_max},${c.commit_data|n},${c.overview_data|n});		

		</script>

    </div>

</div>    

<div class="box">    

    <div class="title">

        <div class="breadcrumbs">${h.link_to(_('Shortlog'),h.url('shortlog_home',repo_name=c.repo_name))}</div>

    </div>    

    <div class="table">

        <div id="shortlog_data">

            <%include file='../shortlog/shortlog_data.html'/>

        </div>

        ##%if c.repo_changesets:

        ##	${h.link_to(_('show more'),h.url('changelog_home',repo_name=c.repo_name))}

        ##%endif

    </div>

</div>

<div class="box">    

    <div class="title">

    </div>    

    <div class="table">

        <%include file='../tags/tags_data.html'/>

        %if c.repo_changesets:

        	${h.link_to(_('show more'),h.url('tags_home',repo_name=c.repo_name))}

        %endif

    </div>

</div>

<div class="box">

    <div class="title">

    </div>    

    <div class="table">

        <%include file='../branches/branches_data.html'/>

        %if c.repo_changesets:

        	${h.link_to(_('show more'),h.url('branches_home',repo_name=c.repo_name))}

        %endif

    </div>      

</div> 

</%def>