from pylons import request, tmpl_context as c, url

from sqlalchemy.orm import joinedload

from webhelpers.paginate import Page

from whoosh.qparser.default import QueryParser

from whoosh import query

from rhodecode.lib.auth import LoginRequired, HasPermissionAllDecorator

from rhodecode.lib.base import BaseController, render

from rhodecode.model.db import UserLog, User

from rhodecode.lib.utils2 import safe_int, remove_prefix, remove_suffix

from rhodecode.lib.indexers import JOURNAL_SCHEMA

log = logging.getLogger(__name__)

    """

    Filters sqlalchemy user_log based on search_term with whoosh Query language

    http://packages.python.org/Whoosh/querylang.html

    :param user_log:

    :param search_term:

    """

    log.debug('Initial search term: %r' % search_term)

    qry = None

    if search_term:

        qp = QueryParser('repository', schema=JOURNAL_SCHEMA)

        qry = qp.parse(unicode(search_term))

        log.debug('Filtering using parsed query %r' % qry)

    def wildcard_handler(col, wc_term):

        if wc_term.startswith('*') and not wc_term.endswith('*'):

            #postfix == endswith

        #sql filtering

        if isinstance(term, query.Wildcard):

            return wildcard_handler(field, val)

        elif isinstance(term, query.Prefix):

            return field.startswith(val)

        return field == val

        if not isinstance(qry, query.And):

            qry = [qry]

        for term in qry:

            field = term.fieldname

            user_log = user_log.filter(get_filterion(field, val, term))

    elif isinstance(qry, query.Or):

        filters = []

        for term in qry:

            field = term.fieldname

            filters.append(get_filterion(field, val, term))

        user_log = user_log.filter(or_(*filters))

    return user_log

                .options(joinedload(UserLog.user))\

                .options(joinedload(UserLog.repository))

        #FILTERING

        c.search_term = request.GET.get('filter')

        try:

        except:

            # we want this to crash for now

            raise

        users_log = users_log.order_by(UserLog.action_date.desc())

from rhodecode.lib.base import BaseController, render

from rhodecode.model.db import UserLog, UserFollowing, Repository, User

from rhodecode.model.meta import Session

from sqlalchemy.sql.expression import func

from rhodecode.model.scm import ScmModel

from rhodecode.lib.utils2 import safe_int

log = logging.getLogger(__name__)

class JournalController(BaseController):

        c.user = User.get(self.rhodecode_user.user_id)

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

            .filter(UserFollowing.user_id == self.rhodecode_user.user_id)\

            .options(joinedload(UserFollowing.follows_repository))\

            .all()

        journal = self._get_journal_data(c.following)

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

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

        if request.environ.get('HTTP_X_PARTIAL_XHR'):

            return c.journal_data

        return render('journal/journal.html')

            filtering_criterion = UserLog.repository_id.in_(repo_ids)

        if not repo_ids and user_ids:

            filtering_criterion = UserLog.user_id.in_(user_ids)

        if filtering_criterion is not None:

            journal = self.sa.query(UserLog)\

                .options(joinedload(UserLog.user))\

        else:

            journal = []

        return journal

    @LoginRequired()

import StringIO

import urllib

import math

import logging

import re

import urlparse

from datetime import datetime

from pygments.formatters.html import HtmlFormatter

from pygments import highlight as code_highlight

from pylons import url, request, config

from pylons.i18n.translation import _, ungettext

def changeset_status_lbl(changeset_status):

    return dict(ChangesetStatus.STATUSES).get(changeset_status)

def get_permission_name(key):

    return dict(Permission.PERMS).get(key)

<%def name="title()">

    ${_('Admin journal')} - ${c.rhodecode_name}

</%def>

<%def name="breadcrumbs_links()">

    <form id="filter_form">

    <input type='submit' value="${_('filter')}" class="ui-btn" style="padding:0px 2px 0px 2px;margin:0px"/>

    ${_('Admin journal')} - ${ungettext('%s entry', '%s entries', c.users_log.item_count) % (c.users_log.item_count)}

    </form>

    ${h.end_form()}

</%def>

	        ${c.log_data}

	    </div>

	</div>

</div>

<script>

	}

});

}

});

YUE.on('filter_form','submit',function(e){

	YUE.preventDefault(e)

	window.location = "${url.current(filter='__FILTER__')}".replace('__FILTER__',val);

});

</script>

</%def>

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

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

<%def name="title()">

    ${_('Journal')} - ${c.rhodecode_name}

</%def>

<%def name="breadcrumbs()">

</%def>

<%def name="page_nav()">

	${self.menu('home')}

</%def>

<%def name="head_extra()">

<link href="${h.url('journal_atom', api_key=c.rhodecode_user.api_key)}" rel="alternate" title="${_('ATOM journal feed')}" type="application/atom+xml" />

</%def>

<%def name="main()">

    <div class="box box-left">

	    <!-- box / title -->

	    <div class="title">

	    </div>

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

    </div>

    <div class="box box-right">

        <!-- box / title -->

        <div class="title">

              </div>

          %endif

        </div>

    </div>

    <script type="text/javascript">

    var show_my = function(e){

        YUD.setStyle('watched','display','none');

        YUD.setStyle('my','display','');

        var url = "${h.url('admin_settings_my_repos')}";

        ypjax(url, 'my', function(){

        //We have a hash

        var tabHash = url[1];

        tabs[tabHash]();

    }

    YUE.on('refresh','click',function(e){

        	show_more_event();

        	tooltip_activate();

        	show_changeset_tooltip();

        	});

        YUE.preventDefault(e);

    });

        response.mustcontain('1095 entries')  # 1087 + 8

    def test_filter_journal_filter_wildcard_on_action(self):

        self.log_user()

        response = self.app.get(url(controller='admin/admin', action='index',

                                    filter='action:*pull_request*'))