# 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 logging

from sqlalchemy import or_

from pylons import request, response, session, tmpl_context as c, url

from webhelpers.paginate import Page

from rhodecode.lib.auth import LoginRequired, NotAnonymous

from rhodecode.lib.base import BaseController, render

from rhodecode.lib.helpers import get_token

from rhodecode.model.db import UserLog, UserFollowing

from rhodecode.model.scm import ScmModel

from paste.httpexceptions import HTTPInternalServerError

log = logging.getLogger(__name__)

class JournalController(BaseController):

    @LoginRequired()

    @NotAnonymous()

    def __before__(self):

        super(JournalController, self).__before__()

    def index(self):

        # Return a rendered template

        c.following = self.sa.query(UserFollowing)\

        repo_ids = [x.follows_repository.repo_id for x in c.following

                    if x.follows_repository is not None]

        user_ids = [x.follows_user.user_id for x in c.following

                    if x.follows_user is not None]

        journal = self.sa.query(UserLog)\

            .filter(or_(

                        UserLog.repository_id.in_(repo_ids),

                        UserLog.user_id.in_(user_ids),

                        ))\

            .order_by(UserLog.action_date.desc())

        p = int(request.params.get('page', 1))

        c.journal_pager = Page(journal, page=p, items_per_page=10)

        c.journal_day_aggreagate = self._get_daily_aggregate(c.journal_pager)

        c.journal_data = render('journal/journal_data.html')

        if request.params.get('partial'):

            return c.journal_data

        return render('journal/journal.html')

    __table_args__ = (UniqueConstraint('repository_id'), {'useexisting':True})

    stat_id = Column("stat_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

    repository_id = Column("repository_id", Integer(), ForeignKey('repositories.repo_id'), nullable=False, unique=True, default=None)

    stat_on_revision = Column("stat_on_revision", Integer(), nullable=False)

    commit_activity = Column("commit_activity", LargeBinary(), nullable=False)#JSON data

    commit_activity_combined = Column("commit_activity_combined", LargeBinary(), nullable=False)#JSON data

    languages = Column("languages", LargeBinary(), nullable=False)#JSON data

    repository = relationship('Repository', single_parent=True)

class UserFollowing(Base, BaseModel):

    __tablename__ = 'user_followings'

    __table_args__ = (UniqueConstraint('user_id', 'follows_repository_id'),

                      UniqueConstraint('user_id', 'follows_user_id')

                      , {'useexisting':True})

    user_following_id = Column("user_following_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

    user_id = Column("user_id", Integer(), ForeignKey('users.user_id'), nullable=False, unique=None, default=None)

    follows_repo_id = Column("follows_repository_id", Integer(), ForeignKey('repositories.repo_id'), nullable=True, unique=None, default=None)

    follows_user_id = Column("follows_user_id", Integer(), ForeignKey('users.user_id'), nullable=True, unique=None, default=None)

    user = relationship('User', primaryjoin='User.user_id==UserFollowing.user_id')

    follows_user = relationship('User', primaryjoin='User.user_id==UserFollowing.follows_user_id')

class CacheInvalidation(Base, BaseModel):

    __tablename__ = 'cache_invalidation'

    __table_args__ = (UniqueConstraint('cache_key'), {'useexisting':True})

    cache_id = Column("cache_id", Integer(), nullable=False, unique=True, default=None, primary_key=True)

    cache_key = Column("cache_key", String(length=None, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

    cache_args = Column("cache_args", String(length=None, convert_unicode=False, assert_unicode=None), nullable=True, unique=None, default=None)

    cache_active = Column("cache_active", Boolean(), nullable=True, unique=None, default=False)

    def __init__(self, cache_key, cache_args=''):

        self.cache_key = cache_key

        self.cache_args = cache_args

        self.cache_active = False

    def __repr__(self):

        return "<%s('%s:%s')>" % (self.__class__.__name__,

                                  self.cache_id, self.cache_key)

class DbMigrateVersion(Base, BaseModel):

    __tablename__ = 'db_migrate_version'

    __table_args__ = {'useexisting':True}

    repository_id = Column('repository_id', String(250), primary_key=True)

    repository_path = Column('repository_path', Text)

		    YUD.setStyle(YUD.get(el.id.substring(1)),'display','');

		    YUD.setStyle(el.parentNode,'display','none');

		});

		}

		</script> 	    

	    <div id="journal">${c.journal_data}</div>

    </div>

    <div class="box box-right">

        <!-- box / title -->

        <div class="title">

            <h5>${_('Following')}</h5>

        </div>

        <div>

		%if c.following:

		    %for entry in c.following:

		        <div class="currently_following">

		            %if entry.follows_user_id:

		              <img title="${_('following user')}" alt="${_('user')}" src="/images/icons/user.png"/>

		              ${entry.follows_user.full_contact}

		            %endif

		            %if entry.follows_repo_id:

		              %if entry.follows_repository.private:

		                <img class="icon" title="${_('private repository')}" alt="${_('private repository')}" src="/images/icons/lock.png"/>

		              %else:

		                <img class="icon" title="${_('public repository')}" alt="${_('public repository')}" src="/images/icons/lock_open.png"/>

		              %endif

		              ${h.link_to(entry.follows_repository.repo_name,h.url('summary_home',

		                repo_name=entry.follows_repository.repo_name))}

		            %endif

		        </div>

		    %endfor

		%else:

		    ${_('You are not following any users or repositories')}

		%endif

        </div>

    </div>    

</%def>