# if this association to user is not valid, we don't want to show

            # this message

            if unotification:

                    unotification.mark_as_read()

                    Session().commit()

                c.notification = no

            .filter(RepoGroup.group_parent_id == c.group.group_id).all()

        c.groups = self.scm_model.get_repos_groups(groups)

            c.repos_list = self.scm_model.get_repos(all_repos=gr_filter)

        ## lightweight version of dashboard

        else:

        try:

            dbrepo = RepoModel().get_by_repo_name(repo_name)

                return _('downloads disabled')

            if c.rhodecode_repo.alias == 'hg':

        c.groups = self.scm_model.get_repos_groups()

        c.group = None

            c.repos_list = self.scm_model.get_repos()

        ## lightweight version of dashboard

        else:

                Session().commit()

                # If they want to be remembered, update the cookie

                    _year = (datetime.datetime.now() +

                             datetime.timedelta(seconds=60 * 60 * 24 * 365))

                    session._set_cookie_expires(_year)

        if not is_user_loaded:

            # if we cannot authenticate user try anonymous

                user_model.fill_data(self, user_id=self.anonymous_user.user_id)

                # then we set this user is logged in

                self.is_authenticated = True

            ret = func(*fargs, **fkwargs)

            return ret

        finally:

                meta.Session.remove()

    return decorator(__wrapper, func)

        self.init_db()

        global ask_ok

            ask_ok = lambda *args, **kwargs: True

            ask_ok = lambda *args, **kwargs: False

    def init_db(self):

        if retries == 0:

            sys.exit('max retries reached')

            retries -= 1

            return self.config_prompt(test_repo_path, retries)

        sorter = lambda info: {'A': 0, 'M': 1, 'D': 2}.get(info['operation'])

            return diff_container(sorted(_files, key=sorter))

        # highlight inline changes

        kw.update(ex)

        callback(**kw)

        Repository.lock(Repository.get_by_repo_name(ex.repository), user.user_id)

        #msg = 'Made lock on repo `%s`' % repository

        #sys.stdout.write(msg)

        kw.update(ex)

        callback(**kw)

        Repository.unlock(Repository.get_by_repo_name(ex.repository))

        msg = 'Released lock on repo `%s`\n' % ex.repository

        sys.stdout.write(msg)

            return HTTPInternalServerError()(environ, start_response)

        # quick check if that dir exists...

            return HTTPNotFound()(environ, start_response)

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

            anonymous_perm = self._check_permission(action, anonymous_user,

                                                    repo_name, ip_addr)

                    log.debug('Not enough credentials to access this '

                              'repository as anonymous user')

                    log.debug('Anonymous access is disabled, running '

                              'authentication')

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

                #check permissions for this repository

                perm = self._check_permission(action, user, repo_name, ip_addr)

                    return HTTPForbidden()(environ, start_response)

        # extras are injected into UI object and later available

            return HTTPInternalServerError()(environ, start_response)

        # quick check if that dir exists...

            return HTTPNotFound()(environ, start_response)

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

            anonymous_perm = self._check_permission(action, anonymous_user,

                                                    repo_name, ip_addr)

                    log.debug('Not enough credentials to access this '

                              'repository as anonymous user')

                    log.debug('Anonymous access is disabled, running '

                              'authentication')

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

                #check permissions for this repository

                perm = self._check_permission(action, user, repo_name, ip_addr)

                    return HTTPForbidden()(environ, start_response)

        # extras are injected into mercurial UI object and later available

    try:

        return value.encode("ascii")

    except UnicodeEncodeError:

            # this could have an email address, make sure we don't screw it up

            name, address = parseaddr(value)

            return '"%s" <%s>' % (

        cache_key = cls._get_cache_key(key)

        inv = cls._get_or_create_inv_obj(cache_key, repo_name)

            return inv

    @classmethod

            body=body, recipients=recipients_objs, type_=type_

        )

            return notif

        #don't send email to person who created this comment

                               .all():

                    #don't reset PRIVATE repositories

                        r2p.permission = _def

                        self.sa.add(r2p)

            new_user.username = username

            new_user.admin = admin

            # set password only if creating an user or password is changed

                new_user.password = get_crypt_password(password)

                new_user.api_key = generate_api_key(username)

            new_user.email = email

            assigned_groups = UserGroupRepoToPerm.query()\

                .filter(UserGroupRepoToPerm.users_group == users_group).all()

                raise UserGroupsAssignedException('RepoGroup assigned to %s' %

                                                   assigned_groups)

            if not authenticate(username, password):

                user = User.get_by_username(username)

                    log.warning('user %s is disabled' % username)

                    msg = M(self, 'disabled_account', state)

                    raise formencode.Invalid(msg, value, state,

                        error_dict=dict(repo_type=msg)

                    )

                ## check if we can write to root location !

                    msg = M(self, 'permission_denied_root', state)

                    raise formencode.Invalid(msg, value, state,

                        error_dict=dict(repo_type=msg)

                #we can create in root, we're fine no validations required

                return

            val = HasReposGroupPermissionAny('group.admin')

            forbidden = not val(gr_name, 'can create group validator')

            if forbidden_in_root or forbidden:

              ${h.link_to(_('show as raw'),h.url('files_raw_home',repo_name=c.repo_name,revision=c.file_changeset.raw_id,f_path=c.f_path),class_="ui-btn")}

              ${h.link_to(_('download as raw'),h.url('files_rawfile_home',repo_name=c.repo_name,revision=c.file_changeset.raw_id,f_path=c.f_path),class_="ui-btn")}

              % if h.HasRepoPermissionAny('repository.write','repository.admin')(c.repo_name):

                ${h.link_to(_('edit on branch:%s') % c.changeset.branch,h.url('files_edit_home',repo_name=c.repo_name,revision=c.changeset.branch,f_path=c.f_path),class_="ui-btn")}

               %else:

                ${h.link_to(_('edit on branch:?'), '#', class_="ui-btn disabled tooltip", title=_('Editing files allowed only when on branch head revision'))}

            </div>

             <%cnt=0%>

             <%namespace name="dt" file="/data_table/_dt_elements.html"/>

              ## old full detailed version

            <div id='repos_list_wrap' class="yui-skin-sam">

            <table id="repos_list">

            % endif

        </div>

    </div>

    <script>

      YUD.get('repo_count').innerHTML = ${cnt+1 if cnt else 0};

              <div class="input ${summary(c.show_stats)}">

                %if len(c.rhodecode_repo.revisions) == 0:

                  ${_('There are no downloads yet')}

                  ${_('Downloads are disabled for this repository')}

                    %if h.HasPermissionAll('hg.admin')('enable downloads on from summary'):

                        ${h.link_to(_('enable'),h.url('edit_repo',repo_name=c.repo_name),class_="ui-btn")}

    else:

        stdout, stderr = Command(cwd).execute(backend, method, clone_url, dest)

        print stdout,'sdasdsadsa'

            if backend == 'hg':

                assert """adding file changes""" in stdout, 'no messages about cloning'

                assert """abort""" not in stderr , 'got error from clone'