James Rhodes <jrhodes@redpointsoftware.com.au>

    Dominik Ruf <dominikruf@gmail.com>

    xpol <xpolife@gmail.com>

    Vincent Caron <vcaron@bearstech.com>

    Zachary Auclair <zach101@gmail.com>

    Stefan Engel <mail@engel-stefan.de>

    id : <id_given_in_input>

    result : [

               {

               "users_group_id" : "<id>",

               "group_name" :     "<groupname>",

               "active":          "<bool>",

               },

               …

              ]

    error : null

    result: {

              "msg": "created new users group `<groupname>`",

              "users_group": {

                     "users_group_id" : "<id>",

                     "group_name" :     "<groupname>",

                     "active":          "<bool>",

               },

            }

    error:  null

add_user_to_users_group

++++

- obfuscate db password in logs for engine connection string

- #574 Show pull request status also in shortlog (if any)

- remember selected tab in my account page

- Bumped mercurial version to 2.3.2

fixes

+++++

- Add git version detection to warn users that Git used in system is to

  old. Ref #588 - also show git version in system details in settings page

  comparison including the incoming changesets

- Fixed #585, checks for status of revision where to strict, and made

  opening pull request with those revision impossible due to previously set

  status. Checks now are made also for the repository.

- fixes #591 git backend was causing encoding errors when handling binary

  files - added a test case for VCS lib tests

1.4.3 (**2012-09-28**)

----------------------

news

++++

functionality. To do this simply execute::

    paster make-rcext production.ini

This will create `rcextensions` package in the same place that your `ini` file

lives. With `rcextensions` it's possible to add additional mapping for whoosh, 

Please see the `__init__.py` file inside `rcextensions` package 

for more details.

Using RhodeCode with SSH

------------------------

     :param enable_statistics:

     :param clone_uri:

     :param fork_id:

     :param group_id:

     :param created_by:

    """

    return 0

CREATE_REPO_HOOK = _crhook

#==============================================================================

# POST PUSH HOOK

#==============================================================================

# this function will be executed after each push it's runned after the build-in

# hook that rhodecode uses for logging pushes

def _pushhook(*args, **kwargs):

                        category='success')

        except Exception, e:

            log.error(traceback.format_exc())

            h.flash(_('An error occurred during unlocking'),

                    category='error')

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

        """

        Function executed at the end of setup

        """

        if not __py_version__ >= (2, 6):

            notify('Python2.5 detected, please switch '

                   'egg:waitress#main -> egg:Paste#http '

# 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, see <http://www.gnu.org/licenses/>.

import os

import sys

import binascii

from inspect import isfunction

from mercurial.scmutil import revrange

from mercurial.node import nullrev

from rhodecode.lib.vcs.backends.base import EmptyChangeset

from rhodecode.lib.compat import json

from rhodecode.lib.exceptions import HTTPLockedRC

from rhodecode.lib.utils2 import safe_str

from rhodecode.model.db import Repository, User

def _get_scm_size(alias, root_path):

    if not alias.startswith('.'):

        alias += '.'

    size_scm, size_root = 0, 0

    Post create repository Hook. This is a dummy function for admins to re-use

    if needed. It's taken from rhodecode-extensions module and executed

    if present

    :param repository: dict dump of repository object

    :param created_by: username who created repository

    available keys of repository_dict:

     'repo_type',

     'description',

     'private',

        kw.update({'created_by': created_by})

        kw.update(kwargs)

        return callback(**kw)

    return 0

handle_git_pre_receive = (lambda repo_path, revs, env:

    handle_git_receive(repo_path, revs, env, hook_type='pre'))

handle_git_post_receive = (lambda repo_path, revs, env:

    handle_git_receive(repo_path, revs, env, hook_type='post'))

    try:

        if hasattr(user, 'user_id'):

            user_obj = user

        elif isinstance(user, basestring):

            user_obj = User.get_by_username(user)

        else:

        if hasattr(repo, 'repo_id'):

            repo_obj = Repository.get(repo.repo_id)

            repo_name = repo_obj.repo_name

        elif  isinstance(repo, basestring):

            repo_name = repo.lstrip('/')

    if os.path.isdir(full_path):

        return True

    return False

    while True:

        ok = raw_input(prompt)

        if ok in ('y', 'ye', 'yes'):

            return True

        if ok in ('n', 'no', 'nop', 'nope'):

            return False

    baseui._ocfg = config.config()

    baseui._ucfg = config.config()

    baseui._tcfg = config.config()

    if read_from == 'file':

        if not os.path.isfile(path):

            return False

        log.debug('reading hgrc from %s' % path)

        cfg = config.config()

        cfg.read(path)

        for section in ui_sections:

            for k, v in cfg.items(section):

    from rhodecode.model.repo import RepoModel

    from rhodecode.model.scm import ScmModel

    sa = meta.Session()

    rm = RepoModel()

    user = sa.query(User).filter(User.admin == True).first()

    if user is None:

    added = []

#    # clear cache keys

#    log.debug("Clearing cache keys now...")

#    CacheInvalidation.clear_cache()

#    sa.commit()

    for name, repo in initial_repo_list.items():

        group = map_groups(name)

        db_repo = rm.get_by_repo_name(name)

        # found repo that is on filesystem not in RhodeCode database

        if not db_repo:

            added.append(name)

            desc = (repo.description

                    if repo.description != 'unknown'

                    else '%s repository' % name)

            new_repo = rm.create_repo(

                repo_name=name,

        elif install_git_hook:

            if db_repo.repo_type == 'git':

                ScmModel().install_git_hook(db_repo.scm_instance)

        # during starting install all cache keys for all repositories in the

        # system, this will register all repos and multiple instances

        key, _prefix, _org_key = CacheInvalidation._get_key(name)

        CacheInvalidation._get_or_create_key(key, _prefix, _org_key, commit=False)

    sa.commit()

    removed = []

    if remove_obsolete:

        # remove from database those repositories that are not in the filesystem

        for repo in sa.query(Repository).all():

            if repo.repo_name not in initial_repo_list.keys():

                          repo.repo_name)

                try:

                    sa.delete(repo)

                    sa.commit()

                    removed.append(repo.repo_name)

                except:

        pylonsconfig.init_app(conf.global_conf, conf.local_conf)

def check_git_version():

    """

    Checks what version of git is installed in system, and issues a warning

    """

    import subprocess

    from distutils.version import StrictVersion

    from rhodecode import BACKENDS

    p = subprocess.Popen('git --version', shell=True,

    if 'git' in BACKENDS:

        log.debug('GIT version detected: %s' % stdout)

        if stderr:

            log.warning('Unable to detect git version org error was:%r' % stderr)

        elif to_old_git:

    :rtype: unicode

    :returns: unicode words describing age

    """

    order = ['year', 'month', 'day', 'hour', 'minute', 'second']

    deltas = {}

    # Get date parts deltas

    now = datetime.datetime.now()

    for part in order:

        deltas[part] = getattr(now, part) - getattr(prevdate, part)

    # Fix negative offsets (there is 1 second between 10:59:59 and 11:00:00,

    # not 1 hour, -59 minutes and -59 seconds)

            sub_part = order[i + 1]

            sub_value = deltas[sub_part]

        else:

            sub_value = 0

        if sub_value == 0:

    return _(u'just now')

def uri_filter(uri):

    """

def obfuscate_url_pw(engine):

    from sqlalchemy.engine import url

    url = url.make_url(engine)

    if url.password:

        url.password = 'XXXXX'

from datetime import datetime

from rhodecode.lib.vcs.backends import get_backend

from rhodecode.lib.compat import json

from rhodecode.lib.utils2 import LazyProperty, safe_str, safe_unicode

from rhodecode.lib.caching_query import FromCache

from rhodecode.model import BaseModel

from rhodecode.model.db import Repository, UserRepoToPerm, User, Permission, \

    Statistics, UsersGroup, UsersGroupRepoToPerm, RhodeCodeUi, RepoGroup

from rhodecode.lib import helpers as h

        from rhodecode.lib.celerylib import tasks, run_task

        run_task(tasks.create_repo_fork, form_data, cur_user)

    def delete(self, repo):

        repo = self._get_repo(repo)

        if repo:

            try:

                self.sa.delete(repo)

                self.__delete_repo(repo)

            except:

                log.error(traceback.format_exc())

                raise

    def grant_user_permission(self, repo, user, perm):

        """

    YUD.removeClass('show_my','current');

    YUD.removeClass('show_pullrequests','current');

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

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

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

}

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

    show_perms();

})

var show_my = function(e){

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

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

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

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

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

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

        table_sort();

        filter_activate();

}

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

	show_my(e);

})

var show_pullrequests = function(e){

    YUD.removeClass('show_perms','current');

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

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

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

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

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

}

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

	show_pullrequests(e)

})

var tabs = {

    'perms': show_perms,

    'my': show_my,

    'pullrequests': show_pullrequests

}

    var tabHash = url[1];

    console.log(tabs, tabHash)

}

// main table sorting

var myColumnDefs = [

    {key:"menu",label:"",sortable:false,className:"quick_repo_menu hidden"},

    {key:"name",label:"${_('Name')}",sortable:true,

<script type="text/javascript">

  var _USERS_AC_DATA = ${c.users_array|n};

  var _GROUPS_AC_DATA = ${c.users_groups_array|n};

  PullRequestAutoComplete('user', 'reviewers_container', _USERS_AC_DATA, _GROUPS_AC_DATA);

  var other_repos_info = ${c.other_repos_info|n};

  var loadPreview = function(){

	  YUD.setStyle(YUD.get('pull_request_overview_url').parentElement,'display','none');

      var url = "${h.url('compare_url',

    	                 repo_name='org_repo',

    	                 org_ref_type='org_ref_type', org_ref='org_ref',

                         other_ref_type='other_ref_type', other_ref='other_ref',

      var rev_data = {}; // gather the org/other ref and repo here

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

        var select_ref = select_refs[i];

        var select_ref_data = select_ref.value.split(':');

        var key = null;

        var val = null;

        if(select_ref_data.length>1){

          key = select_ref.name+"_type";

          val = select_ref_data[0];

          url = url.replace(key,val);

          rev_data[key] = val;

          key = select_ref.name;

          val = select_ref_data[1];

          url = url.replace(key,val);

          rev_data[key] = val;

        }else{

          key = select_ref.name;

          val = select_ref.value;

          url = url.replace(key,val);

          rev_data[key] = val;

        }

      YUE.on('other_repo', 'change', function(e){

    	  var repo_name = e.currentTarget.value;

    	  // replace the <select> of changed repo

    	  YUD.get('other_ref').innerHTML = other_repos_info[repo_name]['revs'];

      });

      ypjax(url,'pull_request_overview', function(data){

    	  var sel_box = YUQ('#pull_request_form #other_repo')[0];

    	  var repo_name = sel_box.options[sel_box.selectedIndex].value;

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

    	  YUD.setStyle(YUD.get('pull_request_overview_url').parentElement,'display','');

    	  YUD.get('other_repo_gravatar').src = other_repos_info[repo_name]['gravatar'];

              <label>${_('Still not reviewed by')}:</label>

          </div>

          <div class="input">

            % if len(c.pull_request_pending_reviewers) > 0:

                <div class="tooltip" title="${h.tooltip(','.join([x.username for x in c.pull_request_pending_reviewers]))}">${ungettext('%d reviewer', '%d reviewers',len(c.pull_request_pending_reviewers)) % len(c.pull_request_pending_reviewers)}</div>

            %else:

            %endif

          </div>

         </div>

      </div>

    </div>

    <div style="white-space:pre-wrap;padding:3px 3px 5px 20px">${h.literal(c.pull_request.description)}</div>

                  </a>

                %else:

                  <img src="${h.url('/images/icons/flag_status_%s.png' % c.statuses.get(cs.raw_id)[0])}" />

                %endif

                </div>

              %endif

            <pre><a href="${h.url('files_home',repo_name=c.repo_name,revision=cs.raw_id)}">r${cs.revision}:${h.short_id(cs.raw_id)}</a></pre>

         </div>

        </td>

        <td>

            ${h.link_to(h.truncate(cs.message,50) or _('No commit message'),

            h.url('changeset_home',repo_name=c.repo_name,revision=cs.raw_id),

            response.mustcontain("""file2-line1-from-fork""")

            response.mustcontain("""file3-line1-from-fork""")

            self.assertFalse("""<a href="#">file2</a>""" in response.body)  # new commit from parent

            self.assertFalse("""line1-from-new-parent"""  in response.body)

        finally:

            RepoModel().delete(r2_id)

        self.assertEqual(age(n), u'just now')

        self.assertEqual(age(n - delt(seconds=1)), u'1 second ago')

        self.assertEqual(age(n - delt(seconds=60 * 2)), u'2 minutes ago')

        self.assertEqual(age(n - delt(hours=1)), u'1 hour ago')

        self.assertEqual(age(n - delt(hours=24)), u'1 day ago')

        self.assertEqual(age(n - delt(hours=24 * 5)), u'5 days ago')

                         u'1 month and 2 days ago')

        self.assertEqual(age(n - delt(hours=24 * 400)), u'1 year and 1 month ago')

    def test_tag_exctrator(self):

        sample = (

            "hello pta[tag] gog [[]] [[] sda ero[or]d [me =>>< sa]"

            "[requires] [stale] [see<>=>] [see => http://url.com]"

            "[requires => url] [lang => python] [just a tag]"

            "[,d] [ => ULR ] [obsolete] [desc]]"

            fake = fake_conf(alternative_gravatar_url='{scheme}://{netloc}/{md5email}/{size}')

            with mock.patch('pylons.config', fake):

                em = 'test@foo.com'

                grav = gravatar_url(email_address=em, size=24)

                assert grav == 'https://server.com/%s/%s' % (_md5(em), 24)

from rhodecode.model import validators as v

from rhodecode.model.users_group import UsersGroupModel

from rhodecode.model.meta import Session

from rhodecode.model.repos_group import ReposGroupModel

from rhodecode.config.routing import ADMIN_PREFIX

from rhodecode.model.changeset_status import ChangesetStatusModel

from rhodecode.model.comment import ChangesetCommentsModel

class TestReposGroups(unittest.TestCase):

    def test_AttrLoginValidator(self):

        validator = v.AttrLoginValidator()

        self.assertRaises(formencode.Invalid, validator.to_python, 123)

    def test_NotReviewedRevisions(self):

        rev = '0' * 40

        # add status for a rev, that should throw an error because it is already

        # reviewed

        new_status = ChangesetStatus()

        new_status.author = ChangesetStatusModel()._get_user(TEST_USER_ADMIN_LOGIN)

        new_status.repo = ChangesetStatusModel()._get_repo(HG_REPO)