h.flash(msg, 'error')

            return redirect(url('pullrequest_home', repo_name=repo_name)) ## would rather just go back to form ...

        org_repo = _form['org_repo']

        org_ref = _form['org_ref'] # will end with merge_rev but have symbolic name

        other_repo = _form['other_repo']

        other_ref = 'rev:ancestor:%s' % _form['ancestor_rev'] # could be calculated from other_ref ...

        revisions = [x for x in reversed(_form['revisions'])]

        reviewers = _form['review_members']

        title = _form['pullrequest_title']

        if not title:

            title = '%s#%s to %s' % (org_repo, org_ref.split(':', 2)[1], other_repo)

        description = _form['pullrequest_desc']

        try:

            pull_request = PullRequestModel().create(

                self.authuser.user_id, org_repo, org_ref, other_repo,

                other_ref, revisions, reviewers, title, description

            )

            Session().commit()

            h.flash(_('Successfully opened new pull request'),

                    category='success')

        except Exception:

                    category='error')

            log.error(traceback.format_exc())

            return redirect(url('pullrequest_home', repo_name=repo_name))

        return redirect(url('pullrequest_show', repo_name=other_repo,

                            pull_request_id=pull_request.pull_request_id))

    @LoginRequired()

    @NotAnonymous()

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

                                   'repository.admin')

    @jsonify

    def update(self, repo_name, pull_request_id):

        pull_request = PullRequest.get_or_404(pull_request_id)

        if pull_request.is_closed():

            raise HTTPForbidden()

        #only owner or admin can update it

        owner = pull_request.author.user_id == c.authuser.user_id

        repo_admin = h.HasRepoPermissionAny('repository.admin')(c.repo_name)

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

            reviewers_ids = map(int, filter(lambda v: v not in [None, ''],

                request.POST.get('reviewers_ids', '').split(',')))

            PullRequestModel().update_reviewers(pull_request_id, reviewers_ids)

        CacheInvalidation.set_invalidate(self.repo_name)

    def scm_instance_no_cache(self):

        return self.__get_instance()

    @property

    def scm_instance(self):

        import kallithea

        full_cache = str2bool(kallithea.CONFIG.get('vcs_full_cache'))

        if full_cache:

            return self.scm_instance_cached()

        return self.__get_instance()

    def scm_instance_cached(self, valid_cache_keys=None):

        @cache_region('long_term')

        def _c(repo_name):

            return self.__get_instance()

        rn = self.repo_name

        valid = CacheInvalidation.test_and_set_valid(rn, None, valid_cache_keys=valid_cache_keys)

        if not valid:

            log.debug('Cache for %s invalidated, getting new object' % (rn))

            region_invalidate(_c, None, rn)

        else:

        return _c(rn)

    def __get_instance(self):

        repo_full_path = self.repo_full_path

        try:

            alias = get_scm(repo_full_path)[0]

            log.debug('Creating instance of %s repository from %s'

                      % (alias, repo_full_path))

            backend = get_backend(alias)

        except VCSError:

            log.error(traceback.format_exc())

            log.error('Perhaps this repository is in db and not in '

                      'filesystem run rescan repositories with '

                      '"destroy old data " option from admin panel')

            return

        if alias == 'hg':

            repo = backend(safe_str(repo_full_path), create=False,

                           baseui=self._ui)

            # skip hidden web repository

            if repo._get_hidden():

                return

        else:

    def __unicode__(self):

        return u"<%s('%s:%s')>" % (

            self.__class__.__name__,

            self.status, self.author

        )

    @classmethod

    def get_status_lbl(cls, value):

        return dict(cls.STATUSES).get(value)

    @property

    def status_lbl(self):

        return ChangesetStatus.get_status_lbl(self.status)

class PullRequest(Base, BaseModel):

    __tablename__ = 'pull_requests'

    __table_args__ = (

        {'extend_existing': True, 'mysql_engine': 'InnoDB',

         'mysql_charset': 'utf8', 'sqlite_autoincrement': True},

    )

    # values for .status

    STATUS_NEW = u'new'

    STATUS_CLOSED = u'closed'

    pull_request_id = Column('pull_request_id', Integer(), nullable=False, primary_key=True)

    title = Column('title', Unicode(256), nullable=True)

    description = Column('description', UnicodeText(10240), nullable=True)

    status = Column('status', Unicode(256), nullable=False, default=STATUS_NEW) # only for closedness, not approve/reject/etc

    created_on = Column('created_on', DateTime(timezone=False), nullable=False, default=datetime.datetime.now)

    updated_on = Column('updated_on', DateTime(timezone=False), nullable=False, default=datetime.datetime.now)

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

    _revisions = Column('revisions', UnicodeText(20500))  # 500 revisions max

    org_repo_id = Column('org_repo_id', Integer(), ForeignKey('repositories.repo_id'), nullable=False)

    org_ref = Column('org_ref', Unicode(256), nullable=False)

    other_repo_id = Column('other_repo_id', Integer(), ForeignKey('repositories.repo_id'), nullable=False)

    other_ref = Column('other_ref', Unicode(256), nullable=False)

    @hybrid_property

    def revisions(self):

        return self._revisions.split(':')

    @revisions.setter

    def revisions(self, val):

        self._revisions = ':'.join(val)

    @property

            run_task(tasks.send_email, rec.email, email_subject, email_body,

                     email_body_html)

        return notif

    def delete(self, user, notification):

        # we don't want to remove actual notification just the assignment

        try:

            notification = self.__get_notification(notification)

            user = self._get_user(user)

            if notification and user:

                obj = UserNotification.query()\

                        .filter(UserNotification.user == user)\

                        .filter(UserNotification.notification

                                == notification)\

                        .one()

                Session().delete(obj)

                return True

        except Exception:

            log.error(traceback.format_exc())

            raise

    def get_for_user(self, user, filter_=None):

        """

        :param user:

        :param filter:

        """

        user = self._get_user(user)

        q = UserNotification.query()\

            .filter(UserNotification.user == user)\

            .join((Notification, UserNotification.notification_id ==

                                 Notification.notification_id))

        if filter_:

            q = q.filter(Notification.type_.in_(filter_))

        return q.all()

    def mark_read(self, user, notification):

        try:

            notification = self.__get_notification(notification)

            user = self._get_user(user)

            if notification and user:

                obj = UserNotification.query()\

                        .filter(UserNotification.user == user)\

                        .filter(UserNotification.notification

    return YAHOO.util.Sort.compare(a_, b_, desc);

};

var dateSort = function(a, b, desc, field) {

    var a_ = parseFloat(a.getData('raw_date') || 0);

    var b_ = parseFloat(b.getData('raw_date') || 0);

    return YAHOO.util.Sort.compare(a_, b_, desc);

};

var addPermAction = function(_html, users_list, groups_list){

    var $last_node = $('.last_new_member').last(); // empty tr between last and add

    var next_id = $('.new_members').length;

    $last_node.before($('<tr class="new_members">').append(_html.format(next_id)));

    _MembersAutoComplete("perm_new_member_name_"+next_id,

            "perm_container_"+next_id, users_list, groups_list);

}

function ajaxActionRevokePermission(url, obj_id, obj_type, field_id, extra_data) {

    var callback = {

        success: function (o) {

            $('#' + field_id).remove();

        },

        failure: function (o) {

        },

    };

    query_params = {

        '_method': 'delete'

    }

    // put extra data into POST

    if (extra_data !== undefined && (typeof extra_data === 'object')){

        for(k in extra_data){

            query_params[k] = extra_data[k];

        }

    }

    if (obj_type=='user'){

        query_params['user_id'] = obj_id;

        query_params['obj_type'] = 'user';

    }

    else if (obj_type=='user_group'){

        query_params['user_group_id'] = obj_id;

        query_params['obj_type'] = 'user_group';

    }

    var request = YAHOO.util.Connect.asyncRequest('POST', url, callback,

            _toQueryString(query_params));

};

            (function() {

                var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true;

                ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js';

                var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s);

                })();

        </script>

        %endif

        ## JAVASCRIPT ##

        <%def name="js()">

            <script type="text/javascript">

            //JS translations map

            var TRANSLATION_MAP = {

                'Add another comment':'${_("Add another comment")}',

                'Stop following this repository':"${_('Stop following this repository')}",

                'Start following this repository':"${_('Start following this repository')}",

                'Group':"${_('Group')}",

                'members':"${_('members')}",

                'Loading ...':"${_('Loading ...')}",

                'loading ...':"${_('loading ...')}",

                'Search truncated': "${_('Search truncated')}",

                'No matching files': "${_('No matching files')}",

                'Open new pull request': "${_('Open new pull request')}",

                'Open new pull request for selected changesets':  "${_('Open new pull request for selected changesets')}",

                'Show selected changeset __S': "${_('Show selected changeset __S')}",

                'Selection link': "${_('Selection link')}",

                'Collapse diff': "${_('Collapse diff')}",

                'Expand diff': "${_('Expand diff')}",

                'Failed to revoke permission': "${_('Failed to revoke permission')}",

                'Confirm to revoke permission for {0}: {1} ?': "${_('confirm to revoke permission for {0}: {1} ?')}",

                'enabled': "${_('enabled')}",

                'disabled': "${_('disabled')}",

                'Select changeset': "${_('Select changeset')}",

                'MSG_SORTASC': "${_('Click to sort ascending')}",

                'MSG_SORTDESC': "${_('Click to sort descending')}",

                'MSG_EMPTY': "${_('No records found.')}",

                'MSG_ERROR': "${_('Data error.')}",

                'MSG_LOADING': "${_('Loading...')}",

            };

            var _TM = TRANSLATION_MAP;

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

            var REPO_NAME = "";

            %if hasattr(c, 'repo_name'):

                var REPO_NAME = "${c.repo_name}";

            %endif

            </script>

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

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

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

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

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

            <!--[if lt IE 9]>

               <script language="javascript" type="text/javascript" src="${h.url('/js/excanvas.min.js')}"></script>

    ${self.menu('repositories')}

</%def>

<%def name="main()">

${self.repo_context_bar('changelog')}

<div class="box">

    <!-- box / title -->

    <div class="title">

        ${self.breadcrumbs()}

    </div>

    <div class="table">

        % if c.pagination:

            <div id="graph">

                <div style="overflow:auto; display:${'none' if c.changelog_for_path else ''}">

                    <div class="container_header">

                       <div style="float:right; margin: 0px 0px 0px 4px">${h.select('branch_filter',c.branch_name,c.branch_filters)}</div>

                       <div class="info_box" style="text-align: right; float: right">

                            <a href="#" class="btn btn-mini" id="rev_range_container" style="display:none"></a>

                            <a href="#" class="btn btn-mini" id="rev_range_clear" style="display:none">${_('Clear selection')}</a>

                            %if c.db_repo.fork:

                                <a id="compare_fork"

                                   title="${_('Compare fork with %s' % c.db_repo.fork.repo_name)}"

                                   href="${h.url('compare_url',repo_name=c.db_repo.fork.repo_name,org_ref_type=c.db_repo.landing_rev[0],org_ref=c.db_repo.landing_rev[1],other_repo=c.repo_name,other_ref_type='branch' if request.GET.get('branch') else c.db_repo.landing_rev[0],other_ref=request.GET.get('branch') or c.db_repo.landing_rev[1], merge=1)}"

                            %endif

                            <a id="open_new_pr" href="${h.url('pullrequest_home',repo_name=c.repo_name)}" class="btn btn-mini">${_('Open new pull request')}</a>

                       </div>

                       ${h.form(h.url.current(),method='get')}

                       <div style="float:left">

                           ${h.submit('set',_('Show'),class_="btn btn-mini")}

                           ${h.text('size',size=1,value=c.size)}

                           ${_('revisions')}

                       </div>

                       ${h.end_form()}

                    </div>

                </div>

                <div id="graph_nodes">

                    <canvas id="graph_canvas"></canvas>

                </div>

                <div id="graph_content" style="${'margin: 0px' if c.changelog_for_path else ''}">

                <table id="changesets">

                <tbody>

                %for cnt,cs in enumerate(c.pagination):

                    <tr id="chg_${cnt+1}" class="container ${'tablerow%s' % (cnt%2)}">

                        <td class="checkbox">

                            %if c.changelog_for_path:

                            checked_checkboxes.push(checkboxes[pos]);

                        }

                    }

                    if(YUD.get('open_new_pr')){

                        if(checked_checkboxes.length>1){

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

                        } else {

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

                            if(checked_checkboxes.length>0){

                                YUD.get('open_new_pr').innerHTML = _TM['Open new pull request for selected changesets'];

                            }else{

                                YUD.get('open_new_pr').innerHTML = _TM['Open new pull request'];

                            }

                        }

                    }

                    if(checked_checkboxes.length>0){

                        var rev_end = checked_checkboxes[0].name;

                        var rev_start = checked_checkboxes[checked_checkboxes.length-1].name;

                        var url = pyroutes.url('changeset_home', {'repo_name': '${c.repo_name}',

                                                                  'revision': rev_start+'...'+rev_end});

                        var link = (rev_start == rev_end)

                            ? _TM['Show selected changeset __S']

                        link = link.replace('__S',rev_start.substr(0,6));

                        link = link.replace('__E',rev_end.substr(0,6));

                        YUD.get('rev_range_container').href = url;

                        YUD.get('rev_range_container').innerHTML = link;

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

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

                        YUD.get('open_new_pr').href = pyroutes.url('pullrequest_home',

                                                                   {'repo_name': '${c.repo_name}',

                                                                    'rev_start': rev_start,

                                                                    'rev_end': rev_end})

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

                    }else{

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

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

                        %if c.branch_name:

                            YUD.get('open_new_pr').href = pyroutes.url('pullrequest_home',

                                                                       {'repo_name': '${c.repo_name}',

                                                                        'branch':'${c.branch_name}'});

                        %else:

                            YUD.get('open_new_pr').href = pyroutes.url('pullrequest_home',

                                                                       {'repo_name': '${c.repo_name}'});

        %endif

      <a class="permalink" href="#comment-${co.comment_id}">&para;</a>

      %if h.HasPermissionAny('hg.admin')() or h.HasRepoPermissionAny('repository.admin')(c.repo_name) or co.author.user_id == c.authuser.user_id:

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

      %endif

      </div>

      <div class="text">

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

      </div>

    </div>

  </div>

</%def>

<%def name="comment_inline_form()">

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

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

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

      ${h.form('#', class_='inline-form')}

      <div id="edit-container_{1}" class="clearfix">

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

          ${(_('Comments parsed using %s syntax with %s support.') % (

                 ('<a href="%s">RST</a>' % h.url('rst_help')),

               )

            )|n

           }

          <div id="preview-btn_{1}" class="preview-btn btn btn-mini">${_('Preview')}</div>

          </div>

            <div class="mentions-container" id="mentions_container_{1}"></div>

            <textarea id="text_{1}" name="text" class="comment-block-ta yui-ac-input"></textarea>

      </div>

      <div id="preview-container_{1}" class="clearfix" style="display:none">

         <div class="comment-help">

              ${_('Comment preview')}

            <div id="edit-btn_{1}" class="edit-btn btn btn-mini">${_('Edit')}</div>

          </div>

          <div id="preview-box_{1}" class="preview-box"></div>

      </div>

      <div class="comment-button">

      <div class="submitting-overlay">${_('Submitting ...')}</div>

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

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

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

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

      </div>

      ${h.end_form()}

  %else:

    var cache = {}

    $("#compare_org").select2({

        placeholder: "${'%s@%s' % (c.org_repo.repo_name, c.org_ref)}",

        formatSelection: function(obj){

            return '{0}@{1}'.format("${c.org_repo.repo_name}", obj.text)

        },

        dropdownAutoWidth: true,

        query: function(query){

          var key = 'cache';

          var cached = cache[key] ;

          if(cached) {

            var data = {results: []};

            //filter results

            $.each(cached.results, function(){

                var section = this.text;

                var children = [];

                $.each(this.children, function(){

                    if(query.term.length == 0 || this.text.toUpperCase().indexOf(query.term.toUpperCase()) >= 0 ){

                        children.push({'id': this.id, 'text': this.text})

                    }

                })

                data.results.push({'text': section, 'children': children})

            });

            //push the typed in changeset

                               'children': [{'id': query.term, 'text': query.term, 'type': 'rev'}]})

            query.callback(data);

          }else{

              $.ajax({

                url: pyroutes.url('repo_refs_data', {'repo_name': '${c.org_repo.repo_name}'}),

                data: {},

                dataType: 'json',

                type: 'GET',

                success: function(data) {

                  cache[key] = data;

                }

              })

          }

        },

    });

    $("#compare_other").select2({

        placeholder: "${'%s@%s' % (c.other_repo.repo_name, c.other_ref)}",

        dropdownAutoWidth: true,

        formatSelection: function(obj){

            return '{0}@{1}'.format("${c.other_repo.repo_name}", obj.text)

        },

        query: function(query){

          var key = 'cache2';

          var cached = cache[key] ;

          if(cached) {

            var data = {results: []};

            //filter results

            $.each(cached.results, function(){

                var section = this.text;

                var children = [];

                $.each(this.children, function(){

                    if(query.term.length == 0 || this.text.toUpperCase().indexOf(query.term.toUpperCase()) >= 0 ){

                        children.push({'id': this.id, 'text': this.text})

                    }

                })

                data.results.push({'text': section, 'children': children})

            });

            //push the typed in changeset

                               'children': [{'id': query.term, 'text': query.term, 'type': 'rev'}]})

            query.callback(data);

          }else{

              $.ajax({

                url: pyroutes.url('repo_refs_data', {'repo_name': '${c.other_repo.repo_name}'}),

                data: {},

                dataType: 'json',

                type: 'GET',

                success: function(data) {

                  cache[key] = data;

                  query.callback({results: data.results});

                }

              })

          }

        },

    });

    $('#compare_revs').on('click', function(e){

        var org = $('#compare_org').select2('data');

        var other = $('#compare_other').select2('data');

        var compare_url = "${h.url('compare_url',repo_name=c.repo_name,org_ref_type='__other_ref_type__',org_ref='__org__',other_ref_type='__org_ref_type__',other_ref='__other__', other_repo=c.other_repo.repo_name)}";

        var u = compare_url.replace('__other_ref_type__',org.type)

                           .replace('__org__',org.text)

        var filterTimeout = null;

        updateFilter = function () {

            // Reset timeout

            filterTimeout = null;

            // Reset sort

            var state = myDataTable.getState();

            state.sortedBy = {key:'name', dir:YAHOO.widget.DataTable.CLASS_ASC};

            // Get filtered data

            myDataSource.sendRequest(YUD.get('q_filter').value,{

                success : myDataTable.onDataReturnInitializeTable,

                failure : myDataTable.onDataReturnInitializeTable,

                scope   : myDataTable,

                argument: state

            });

        };

        YUE.on('q_filter','click',function(){

            if(!YUD.hasClass('q_filter', 'loaded')){

                //TODO: load here full list later to do search within groups

                YUD.addClass('q_filter', 'loaded');

            }

        YUE.on('q_filter','keyup',function (e) {

            clearTimeout(filterTimeout);

            filterTimeout = setTimeout(updateFilter,600);

        });

        if(YUD.get('q_filter').value) {

            updateFilter();

        }

      </script>

                            </div>

                            <span style="font-size: 20px">

                            ${h.select('org_repo','',c.org_repos,class_='refs')}:${h.select('org_ref',c.default_org_ref,c.org_refs,class_='refs')}

                            </span>

                        </div>

                    </div>

                    ##OTHER, most Probably the PARENT OF THIS FORK

                    <div style="border-top: 1px solid #EEE; margin: 5px 0px 0px 0px">

                        <div>

                            ## filled with JS

                            <div id="other_repo_desc" style="padding:5px 3px 3px 3px;">

                            </div>

                            <span style="font-size: 20px">

                            ${h.select('other_repo',c.default_other_repo,c.other_repos,class_='refs')}:${c.default_other_repo_info['revs']}

                            </span>

                        </div>

                    </div>

                    <div style="clear:both"></div>

                </div>

            </div>

            <div class="field">

                <div class="buttons">

                    ${h.reset('reset',_('Reset'),class_="btn")}

               </div>

            </div>

        </div>

        ## Reviewers

        <div style="float:left; border-left:1px dashed #eee">

            <div class="pr-details-title">${_('Pull request reviewers')}</div>

            <div id="reviewers" style="padding:0px 0px 0px 15px">

              ## members goes here !

              <div>

                <ul id="review_members" class="group_members">

                %for member in [c.default_other_repo_info['user']]:

                  <li id="reviewer_${member['user_id']}">

                    <div class="reviewers_member">

                      <div class="gravatar"><img alt="gravatar" src="${member['gravatar_link']}"/> </div>

                      <div style="float:left">${member['firstname']} ${member['lastname']} (${_('owner')})</div>

                      <input type="hidden" value="${member['user_id']}" name="review_members" />

                      <span class="action_button" style="padding: 3px" onclick="removeReviewMember(${member['user_id']})">

                          <i class="icon-remove-sign"  style="color: #FF4444;"></i>

                      </span>

                    </div>

                  </li>

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

import os

import sys

import platform

if sys.version_info < (2, 5):

    raise Exception('Kallithea requires python 2.5 or later')

here = os.path.abspath(os.path.dirname(__file__))

def _get_meta_var(name, data, callback_handler=None):

    import re

    matches = re.compile(r'(?:%s)\s*=\s*(.*)' % name).search(data)

    if matches:

        if not callable(callback_handler):

            callback_handler = lambda v: v

        return callback_handler(eval(matches.groups()[0]))

_meta = open(os.path.join(here, 'kallithea', '__init__.py'), 'rb')

_metadata = _meta.read()

_meta.close()