Changeset - 5b3568c99cc3
Parent rev.
Child rev.
[Not reviewed]
default
0 6 0
domruf - 9 years ago 2017-05-09 17:49:31
dominikruf@gmail.com
sqlalchemy: remove echo setting from .ini files and create_engine

Instead of 'echo' the normal logging configration should be used.

Follow the advice from
https://docs.sqlalchemy.org/en/rel_1_1/core/engines.html#configuring-logging
which says "when using Python logging, ensure all echo flags are set to False
at all times".
6 files changed with 4 insertions and 8 deletions:
development.ini
1
kallithea/lib/db_manage.py
2
3
kallithea/lib/paster_commands/setup_db.py
1
1
kallithea/lib/paster_commands/template.ini.mako
1
kallithea/tests/fixture.py
1
1
kallithea/tests/test.ini
1
0 comments (0 inline, 0 general)
development.ini
➞
Show inline comments
 
@@ -314,309 +314,308 @@ allow_custom_hooks_settings = True
 
####################################
 
###        CELERY CONFIG        ####
 
####################################
 

			




	
	
	
		
 
use_celery = false

			




	
	
	
		
 

			




	
	
	
		
 
## Example: connect to the virtual host 'rabbitmqhost' on localhost as rabbitmq:

			




	
	
	
		
 
broker.url = amqp://rabbitmq:qewqew@localhost:5672/rabbitmqhost

			




	
	
	
		
 

			




	
	
	
		
 
celery.imports = kallithea.lib.celerylib.tasks

			




	
	
	
		
 
celery.accept.content = pickle

			




	
	
	
		
 
celery.result.backend = amqp

			




	
	
	
		
 
celery.result.dburi = amqp://

			




	
	
	
		
 
celery.result.serialier = json

			




	
	
	
		
 

			




	
	
	
		
 
#celery.send.task.error.emails = true

			




	
	
	
		
 
#celery.amqp.task.result.expires = 18000

			




	
	
	
		
 

			




	
	
	
		
 
celeryd.concurrency = 2

			




	
	
	
		
 
celeryd.max.tasks.per.child = 1

			




	
	
	
		
 

			




	
	
	
		
 
## If true, tasks will never be sent to the queue, but executed locally instead.

			




	
	
	
		
 
celery.always.eager = false

			




	
	
	
		
 

			




	
	
	
		
 
####################################

			




	
	
	
		
 
###         BEAKER CACHE        ####

			




	
	
	
		
 
####################################

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.data_dir = %(here)s/data/cache/data

			




	
	
	
		
 
beaker.cache.lock_dir = %(here)s/data/cache/lock

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.regions = short_term,long_term,sql_cache_short

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.short_term.type = memory

			




	
	
	
		
 
beaker.cache.short_term.expire = 60

			




	
	
	
		
 
beaker.cache.short_term.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.long_term.type = memory

			




	
	
	
		
 
beaker.cache.long_term.expire = 36000

			




	
	
	
		
 
beaker.cache.long_term.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.sql_cache_short.type = memory

			




	
	
	
		
 
beaker.cache.sql_cache_short.expire = 10

			




	
	
	
		
 
beaker.cache.sql_cache_short.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
####################################

			




	
	
	
		
 
###       BEAKER SESSION        ####

			




	
	
	
		
 
####################################

			




	
	
	
		
 

			




	
	
	
		
 
## Name of session cookie. Should be unique for a given host and path, even when running

			




	
	
	
		
 
## on different ports. Otherwise, cookie sessions will be shared and messed up.

			




	
	
	
		
 
beaker.session.key = kallithea

			




	
	
	
		
 
## Sessions should always only be accessible by the browser, not directly by JavaScript.

			




	
	
	
		
 
beaker.session.httponly = true

			




	
	
	
		
 
## Session lifetime. 2592000 seconds is 30 days.

			




	
	
	
		
 
beaker.session.timeout = 2592000

			




	
	
	
		
 

			




	
	
	
		
 
## Server secret used with HMAC to ensure integrity of cookies.

			




	
	
	
		
 
beaker.session.secret = development-not-secret

			




	
	
	
		
 
## Further, encrypt the data with AES.

			




	
	
	
		
 
#beaker.session.encrypt_key = <key_for_encryption>

			




	
	
	
		
 
#beaker.session.validate_key = <validation_key>

			




	
	
	
		
 

			




	
	
	
		
 
## Type of storage used for the session, current types are

			




	
	
	
		
 
## dbm, file, memcached, database, and memory.

			




	
	
	
		
 

			




	
	
	
		
 
## File system storage of session data. (default)

			




	
	
	
		
 
#beaker.session.type = file

			




	
	
	
		
 

			




	
	
	
		
 
## Cookie only, store all session data inside the cookie. Requires secure secrets.

			




	
	
	
		
 
#beaker.session.type = cookie

			




	
	
	
		
 

			




	
	
	
		
 
## Database storage of session data.

			




	
	
	
		
 
#beaker.session.type = ext:database

			




	
	
	
		
 
#beaker.session.sa.url = postgresql://postgres:qwe@localhost/kallithea

			




	
	
	
		
 
#beaker.session.table_name = db_session

			




	
	
	
		
 

			




	
	
	
		
 
############################

			




	
	
	
		
 
## ERROR HANDLING SYSTEMS ##

			




	
	
	
		
 
############################

			




	
	
	
		
 

			




	
	
	
		
 
# Propagate email settings to ErrorReporter of TurboGears2

			




	
	
	
		
 
# You do not normally need to change these lines

			




	
	
	
		
 
get trace_errors.error_email = email_to

			




	
	
	
		
 
get trace_errors.smtp_server = smtp_server

			




	
	
	
		
 
get trace_errors.smtp_port = smtp_port

			




	
	
	
		
 
get trace_errors.from_address = error_email_from

			




	
	
	
		
 

			




	
	
	
		
 
####################

			




	
	
	
		
 
### [appenlight] ###

			




	
	
	
		
 
####################

			




	
	
	
		
 

			




	
	
	
		
 
## AppEnlight is tailored to work with Kallithea, see

			




	
	
	
		
 
## http://appenlight.com for details how to obtain an account

			




	
	
	
		
 
## you must install python package `appenlight_client` to make it work

			




	
	
	
		
 

			




	
	
	
		
 
## appenlight enabled

			




	
	
	
		
 
appenlight = false

			




	
	
	
		
 

			




	
	
	
		
 
appenlight.server_url = https://api.appenlight.com

			




	
	
	
		
 
appenlight.api_key = YOUR_API_KEY

			




	
	
	
		
 

			




	
	
	
		
 
## TWEAK AMOUNT OF INFO SENT HERE

			




	
	
	
		
 

			




	
	
	
		
 
## enables 404 error logging (default False)

			




	
	
	
		
 
appenlight.report_404 = false

			




	
	
	
		
 

			




	
	
	
		
 
## time in seconds after request is considered being slow (default 1)

			




	
	
	
		
 
appenlight.slow_request_time = 1

			




	
	
	
		
 

			




	
	
	
		
 
## record slow requests in application

			




	
	
	
		
 
## (needs to be enabled for slow datastore recording and time tracking)

			




	
	
	
		
 
appenlight.slow_requests = true

			




	
	
	
		
 

			




	
	
	
		
 
## enable hooking to application loggers

			




	
	
	
		
 
#appenlight.logging = true

			




	
	
	
		
 

			




	
	
	
		
 
## minimum log level for log capture

			




	
	
	
		
 
#appenlight.logging.level = WARNING

			




	
	
	
		
 

			




	
	
	
		
 
## send logs only from erroneous/slow requests

			




	
	
	
		
 
## (saves API quota for intensive logging)

			




	
	
	
		
 
appenlight.logging_on_error = false

			




	
	
	
		
 

			




	
	
	
		
 
## list of additional keywords that should be grabbed from environ object

			




	
	
	
		
 
## can be string with comma separated list of words in lowercase

			




	
	
	
		
 
## (by default client will always send following info:

			




	
	
	
		
 
## 'REMOTE_USER', 'REMOTE_ADDR', 'SERVER_NAME', 'CONTENT_TYPE' + all keys that

			




	
	
	
		
 
## start with HTTP* this list be extended with additional keywords here

			




	
	
	
		
 
appenlight.environ_keys_whitelist =

			




	
	
	
		
 

			




	
	
	
		
 
## list of keywords that should be blanked from request object

			




	
	
	
		
 
## can be string with comma separated list of words in lowercase

			




	
	
	
		
 
## (by default client will always blank keys that contain following words

			




	
	
	
		
 
## 'password', 'passwd', 'pwd', 'auth_tkt', 'secret', 'csrf'

			




	
	
	
		
 
## this list be extended with additional keywords set here

			




	
	
	
		
 
appenlight.request_keys_blacklist =

			




	
	
	
		
 

			




	
	
	
		
 
## list of namespaces that should be ignores when gathering log entries

			




	
	
	
		
 
## can be string with comma separated list of namespaces

			




	
	
	
		
 
## (by default the client ignores own entries: appenlight_client.client)

			




	
	
	
		
 
appenlight.log_namespace_blacklist =

			




	
	
	
		
 

			




	
	
	
		
 
################

			




	
	
	
		
 
### [sentry] ###

			




	
	
	
		
 
################

			




	
	
	
		
 

			




	
	
	
		
 
## sentry is a alternative open source error aggregator

			




	
	
	
		
 
## you must install python packages `sentry` and `raven` to enable

			




	
	
	
		
 

			




	
	
	
		
 
sentry.dsn = YOUR_DNS

			




	
	
	
		
 
sentry.servers =

			




	
	
	
		
 
sentry.name =

			




	
	
	
		
 
sentry.key =

			




	
	
	
		
 
sentry.public_key =

			




	
	
	
		
 
sentry.secret_key =

			




	
	
	
		
 
sentry.project =

			




	
	
	
		
 
sentry.site =

			




	
	
	
		
 
sentry.include_paths =

			




	
	
	
		
 
sentry.exclude_paths =

			




	
	
	
		
 

			




	
	
	
		
 
################################################################################

			




	
	
	
		
 
## WARNING: *DEBUG MODE MUST BE OFF IN A PRODUCTION ENVIRONMENT*              ##

			




	
	
	
		
 
## Debug mode will enable the interactive debugging tool, allowing ANYONE to  ##

			




	
	
	
		
 
## execute malicious code after an exception is raised.                       ##

			




	
	
	
		
 
################################################################################

			




	
	
	
		
 
#debug = false

			




	
	
	
		
 
debug = true

			




	
	
	
		
 

			




	
	
	
		
 
##################################

			




	
	
	
		
 
###       LOGVIEW CONFIG       ###

			




	
	
	
		
 
##################################

			




	
	
	
		
 

			




	
	
	
		
 
logview.sqlalchemy = #faa

			




	
	
	
		
 
logview.pylons.templating = #bfb

			




	
	
	
		
 
logview.pylons.util = #eee

			




	
	
	
		
 

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
### DB CONFIGS - EACH DB WILL HAVE IT'S OWN CONFIG    ###

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 

			




	
	
	
		
 
# SQLITE [default]

			




	
	
	
		
 
sqlalchemy.url = sqlite:///%(here)s/kallithea.db?timeout=60

			




	
	
	
		
 

			




	
	
	
		
 
# POSTGRESQL

			




	
	
	
		
 
#sqlalchemy.url = postgresql://user:pass@localhost/kallithea

			




	
	
	
		
 

			




	
	
	
		
 
# MySQL

			




	
	
	
		
 
#sqlalchemy.url = mysql://user:pass@localhost/kallithea?charset=utf8

			




	
	
	
		
 

			




	
	
	
		
 
# see sqlalchemy docs for others

			




	
	
	
		
 

			




	
	
	
		
 
sqlalchemy.echo = false

			




	
	
	
		
 
sqlalchemy.pool_recycle = 3600

			




	
	
	
		
 

			




	
	
	
		
 
################################

			




	
	
	
		
 
### ALEMBIC CONFIGURATION   ####

			




	
	
	
		
 
################################

			




	
	
	
		
 

			




	
	
	
		
 
[alembic]

			




	
	
	
		
 
script_location = kallithea:alembic

			




	
	
	
		
 

			




	
	
	
		
 
################################

			




	
	
	
		
 
### LOGGING CONFIGURATION   ####

			




	
	
	
		
 
################################

			




	
	
	
		
 

			




	
	
	
		
 
[loggers]

			




	
	
	
		
 
keys = root, routes, kallithea, sqlalchemy, tg, gearbox, beaker, templates, whoosh_indexer

			




	
	
	
		
 

			




	
	
	
		
 
[handlers]

			




	
	
	
		
 
keys = console, console_sql

			




	
	
	
		
 

			




	
	
	
		
 
[formatters]

			




	
	
	
		
 
keys = generic, color_formatter, color_formatter_sql

			




	
	
	
		
 

			




	
	
	
		
 
#############

			




	
	
	
		
 
## LOGGERS ##

			




	
	
	
		
 
#############

			




	
	
	
		
 

			




	
	
	
		
 
[logger_root]

			




	
	
	
		
 
level = NOTSET

			




	
	
	
		
 
handlers = console

			




	
	
	
		
 

			




	
	
	
		
 
[logger_routes]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = routes.middleware

			




	
	
	
		
 
## "level = DEBUG" logs the route matched and routing variables.

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_beaker]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = beaker.container

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_templates]

			




	
	
	
		
 
level = INFO

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = pylons.templating

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_kallithea]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = kallithea

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_tg]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = tg

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_gearbox]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = gearbox

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_sqlalchemy]

			




	
	
	
		
 
level = INFO

			




	
	
	
		
 
handlers = console_sql

			




	
	
	
		
 
qualname = sqlalchemy.engine

			




	
	
	
		
 
propagate = 0

			




	
	
	
		
 

			




	
	
	
		
 
[logger_whoosh_indexer]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = whoosh_indexer

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
##############

			




	
	
	
		
 
## HANDLERS ##

			




	
	
	
		
 
##############

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
#level = INFO

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
#formatter = generic

			




	
	
	
		
 
formatter = color_formatter

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console_sql]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
#level = WARN

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
#formatter = generic

			




	
	
	
		
 
formatter = color_formatter_sql

			




	
	
	
		
 

			




	
	
	
		
 
################

			




	
	
	
		
 
## FORMATTERS ##

			




	
	
	
		
 
################

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_generic]

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_color_formatter]

			




	
	
	
		
 
class = kallithea.lib.colored_formatter.ColorFormatter

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_color_formatter_sql]

			




	
	
	
		
 
class = kallithea.lib.colored_formatter.ColorFormatterSql

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




        

    


    
    

    

        

                

                    kallithea/lib/db_manage.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



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

			




	
	
	
		
 
# This program is free software: you can redistribute it and/or modify

			




	
	
	
		
 
# it under the terms of the GNU General Public License as published by

			




	
	
	
		
 
# the Free Software Foundation, either version 3 of the License, or

			




	
	
	
		
 
# (at your option) any later version.

			




	
	
	
		
 
#

			




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

			




	
	
	
		
 
"""

			




	
	
	
		
 
kallithea.lib.db_manage

			




	
	
	
		
 
~~~~~~~~~~~~~~~~~~~~~~~

			




	
	
	
		
 

			




	
	
	
		
 
Database creation, and setup module for Kallithea. Used for creation

			




	
	
	
		
 
of database as well as for migration operations

			




	
	
	
		
 

			




	
	
	
		
 
This file was forked by the Kallithea project in July 2014.

			




	
	
	
		
 
Original author and date, and relevant copyright and licensing information is below:

			




	
	
	
		
 
:created_on: Apr 10, 2010

			




	
	
	
		
 
:author: marcink

			




	
	
	
		
 
:copyright: (c) 2013 RhodeCode GmbH, and others.

			




	
	
	
		
 
:license: GPLv3, see LICENSE.md for more details.

			




	
	
	
		
 
"""

			




	
	
	
		
 

			




	
	
	
		
 
import os

			




	
	
	
		
 
import sys

			




	
	
	
		
 
import time

			




	
	
	
		
 
import uuid

			




	
	
	
		
 
import logging

			




	
	
	
		
 
import sqlalchemy

			




	
	
	
		
 
from os.path import dirname

			




	
	
	
		
 

			




	
	
	
		
 
import alembic.config

			




	
	
	
		
 
import alembic.command

			




	
	
	
		
 

			




	
	
	
		
 
from kallithea.model.user import UserModel

			




	
	
	
		
 
from kallithea.model.base import init_model

			




	
	
	
		
 
from kallithea.model.db import User, Permission, Ui, \

			




	
	
	
		
 
    Setting, UserToPerm, RepoGroup, \

			




	
	
	
		
 
    UserRepoGroupToPerm, CacheInvalidation, Repository

			




	
	
	
		
 

			




	
	
	
		
 
from sqlalchemy.engine import create_engine

			




	
	
	
		
 
from kallithea.model.repo_group import RepoGroupModel

			




	
	
	
		
 
#from kallithea.model import meta

			




	
	
	
		
 
from kallithea.model.meta import Session, Base

			




	
	
	
		
 
from kallithea.model.repo import RepoModel

			




	
	
	
		
 
from kallithea.model.permission import PermissionModel

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
log = logging.getLogger(__name__)

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
def notify(msg):

			




	
	
	
		
 
    """

			




	
	
	
		
 
    Notification for migrations messages

			




	
	
	
		
 
    """

			




	
	
	
		
 
    ml = len(msg) + (4 * 2)

			




	
	
	
		
 
    print('\n%s\n*** %s ***\n%s' % ('*' * ml, msg, '*' * ml)).upper()

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
class DbManage(object):

			




	
	
	
		
 
    def __init__(self, log_sql, dbconf, root, tests=False, SESSION=None, cli_args=None):

			




	
	
	
		
 
    def __init__(self, dbconf, root, tests=False, SESSION=None, cli_args=None):

			




	
	
	
		
 
        self.dbname = dbconf.split('/')[-1]

			




	
	
	
		
 
        self.tests = tests

			




	
	
	
		
 
        self.root = root

			




	
	
	
		
 
        self.dburi = dbconf

			




	
	
	
		
 
        self.log_sql = log_sql

			




	
	
	
		
 
        self.db_exists = False

			




	
	
	
		
 
        self.cli_args = cli_args or {}

			




	
	
	
		
 
        self.init_db(SESSION=SESSION)

			




	
	
	
		
 

			




	
	
	
		
 
    def _ask_ok(self, msg):

			




	
	
	
		
 
        """Invoke ask_ok unless the force_ask option provides the answer"""

			




	
	
	
		
 
        force_ask = self.cli_args.get('force_ask')

			




	
	
	
		
 
        if force_ask is not None:

			




	
	
	
		
 
            return force_ask

			




	
	
	
		
 
        from kallithea.lib.paster_commands.common import ask_ok

			




	
	
	
		
 
        return ask_ok(msg)

			




	
	
	
		
 

			




	
	
	
		
 
    def init_db(self, SESSION=None):

			




	
	
	
		
 
        if SESSION:

			




	
	
	
		
 
            self.sa = SESSION

			




	
	
	
		
 
        else:

			




	
	
	
		
 
            #init new sessions

			




	
	
	
		
 
            engine = create_engine(self.dburi, echo=self.log_sql)

			




	
	
	
		
 
            engine = create_engine(self.dburi)

			




	
	
	
		
 
            init_model(engine)

			




	
	
	
		
 
            self.sa = Session()

			




	
	
	
		
 

			




	
	
	
		
 
    def create_tables(self, override=False):

			




	
	
	
		
 
        """

			




	
	
	
		
 
        Create a auth database

			




	
	
	
		
 
        """

			




	
	
	
		
 

			




	
	
	
		
 
        log.info("Any existing database is going to be destroyed")

			




	
	
	
		
 
        if self.tests:

			




	
	
	
		
 
            destroy = True

			




	
	
	
		
 
        else:

			




	
	
	
		
 
            destroy = self._ask_ok('Are you sure to destroy old database ? [y/n]')

			




	
	
	
		
 
        if not destroy:

			




	
	
	
		
 
            print 'Nothing done.'

			




	
	
	
		
 
            sys.exit(0)

			




	
	
	
		
 
        if destroy:

			




	
	
	
		
 
            # drop and re-create old schemas

			




	
	
	
		
 

			




	
	
	
		
 
            url = sqlalchemy.engine.url.make_url(self.dburi)

			




	
	
	
		
 
            database = url.database

			




	
	
	
		
 

			




	
	
	
		
 
            # Some databases enforce foreign key constraints and Base.metadata.drop_all() doesn't work

			




	
	
	
		
 
            if url.drivername == 'mysql':

			




	
	
	
		
 
                url.database = None  # don't connect to the database (it might not exist)

			




	
	
	
		
 
                engine = sqlalchemy.create_engine(url)

			




	
	
	
		
 
                with engine.connect() as conn:

			




	
	
	
		
 
                    conn.execute('DROP DATABASE IF EXISTS ' + database)

			




	
	
	
		
 
                    conn.execute('CREATE DATABASE ' + database)

			




	
	
	
		
 
            elif url.drivername == 'postgresql':

			




	
	
	
		
 
                from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT

			




	
	
	
		
 
                url.database = 'postgres'  # connect to the system database (as the real one might not exist)

			




	
	
	
		
 
                engine = sqlalchemy.create_engine(url)

			




	
	
	
		
 
                with engine.connect() as conn:

			




	
	
	
		
 
                    conn.connection.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT)

			




	
	
	
		
 
                    conn.execute('DROP DATABASE IF EXISTS ' + database)

			




	
	
	
		
 
                    conn.execute('CREATE DATABASE ' + database)

			




	
	
	
		
 
            else:

			




	
	
	
		
 
                # known to work on SQLite - possibly not on other databases with strong referential integrity

			




	
	
	
		
 
                Base.metadata.drop_all()

			




	
	
	
		
 

			




	
	
	
		
 
        checkfirst = not override

			




	
	
	
		
 
        Base.metadata.create_all(checkfirst=checkfirst)

			




	
	
	
		
 

			




	
	
	
		
 
        # Create an Alembic configuration and generate the version table,

			




	
	
	
		
 
        # "stamping" it with the most recent Alembic migration revision, to

			




	
	
	
		
 
        # tell Alembic that all the schema upgrades are already in effect.

			




	
	
	
		
 
        alembic_cfg = alembic.config.Config()

			




	
	
	
		
 
        alembic_cfg.set_main_option('script_location', 'kallithea:alembic')

			




	
	
	
		
 
        alembic_cfg.set_main_option('sqlalchemy.url', self.dburi)

			




	
	
	
		
 
        # This command will give an error in an Alembic multi-head scenario,

			




	
	
	
		
 
        # but in practice, such a scenario should not come up during database

			




	
	
	
		
 
        # creation, even during development.

			




	
	
	
		
 
        alembic.command.stamp(alembic_cfg, 'head')

			




	
	
	
		
 

			




	
	
	
		
 
        log.info('Created tables for %s', self.dbname)

			




	
	
	
		
 

			




	
	
	
		
 
    def fix_repo_paths(self):

			




	
	
	
		
 
        """

			




	
	
	
		
 
        Fixes a old kallithea version path into new one without a '*'

			




	
	
	
		
 
        """

			




	
	
	
		
 

			




	
	
	
		
 
        paths = Ui.query() \

			




	
	
	
		
 
                .filter(Ui.ui_key == '/') \

			




	
	
	
		
 
                .scalar()

			




	
	
	
		
 

			




	
	
	
		
 
        paths.ui_value = paths.ui_value.replace('*', '')

			




	
	
	
		
 

			




	
	
	
		
 
        self.sa.commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def fix_default_user(self):

			




	
	
	
		
 
        """

			




	
	
	
		
 
        Fixes a old default user with some 'nicer' default values,

			




	
	
	
		
 
        used mostly for anonymous access

			




	
	
	
		
 
        """

			




	
	
	
		
 
        def_user = User.query().filter_by(is_default_user=True).one()

			




	
	
	
		
 

			




	
	
	
		
 
        def_user.name = 'Anonymous'

			




	
	
	
		
 
        def_user.lastname = 'User'

			




	
	
	
		
 
        def_user.email = 'anonymous@kallithea-scm.org'

			




	
	
	
		
 

			




	
	
	
		
 
        self.sa.commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def fix_settings(self):

			




	
	
	
		
 
        """

			




	
	
	
		
 
        Fixes kallithea settings adds ga_code key for google analytics

			




	
	
	
		
 
        """

			




	
	
	
		
 

			




	
	
	
		
 
        hgsettings3 = Setting('ga_code', '')

			




	
	
	
		
 

			




	
	
	
		
 
        self.sa.add(hgsettings3)

			




	
	
	
		
 
        self.sa.commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def admin_prompt(self, second=False):

			




	
	
	
		
 
        if not self.tests:

			




	
	
	
		
 
            import getpass

			




	
	
	
		
 

			




	
	
	
		
 
            username = self.cli_args.get('username')

			




	
	
	
		
 
            password = self.cli_args.get('password')

			




	
	
	
		
 
            email = self.cli_args.get('email')

			




	
	
	
		
 

			




	
	
	
		
 
            def get_password():

			




	
	
	
		
 
                password = getpass.getpass('Specify admin password '

			




	
	
	
		
 
                                           '(min 6 chars):')

			




	
	
	
		
 
                confirm = getpass.getpass('Confirm password:')

			




	
	
	
		
 

			




	
	
	
		
 
                if password != confirm:

			




	
	
	
		
 
                    log.error('passwords mismatch')

			




	
	
	
		
 
                    return False

			




	
	
	
		
 
                if len(password) < 6:

			




	
	
	
		
 
                    log.error('password is to short use at least 6 characters')

			




	
	
	
		
 
                    return False

			




	
	
	
		
 

			




	
	
	
		
 
                return password

			




	
	
	
		
 
            if username is None:

			




	
	
	
		
 
                username = raw_input('Specify admin username:')

			




	
	
	
		
 
            if password is None:

			




	
	
	
		
 
                password = get_password()

			




	
	
	
		
 
                if not password:

			




	
	
	
		
 
                    #second try

			




	
	
	
		
 
                    password = get_password()

			




	
	
	
		
 
                    if not password:

			




	
	
	
		
 
                        sys.exit()

			




	
	
	
		
 
            if email is None:

			




	
	
	
		
 
                email = raw_input('Specify admin email:')

			




	
	
	
		
 
            self.create_user(username, password, email, True)

			




	
	
	
		
 
        else:

			




	
	
	
		
 
            log.info('creating admin and regular test users')

			




	
	
	
		
 
            from kallithea.tests.base import TEST_USER_ADMIN_LOGIN, \

			




	
	
	
		
 
            TEST_USER_ADMIN_PASS, TEST_USER_ADMIN_EMAIL, \

			




	
	
	
		
 
            TEST_USER_REGULAR_LOGIN, TEST_USER_REGULAR_PASS, \

			




	
	
	
		
 
            TEST_USER_REGULAR_EMAIL, TEST_USER_REGULAR2_LOGIN, \

			




	
	
	
		
 
            TEST_USER_REGULAR2_PASS, TEST_USER_REGULAR2_EMAIL

			




	
	
	
		
 

			




	
	
	
		
 
            self.create_user(TEST_USER_ADMIN_LOGIN, TEST_USER_ADMIN_PASS,

			




	
	
	
		
 
                             TEST_USER_ADMIN_EMAIL, True)

			




	
	
	
		
 

			




	
	
	
		
 
            self.create_user(TEST_USER_REGULAR_LOGIN, TEST_USER_REGULAR_PASS,

			




	
	
	
		
 
                             TEST_USER_REGULAR_EMAIL, False)

			




	
	
	
		
 

			




	
	
	
		
 
            self.create_user(TEST_USER_REGULAR2_LOGIN, TEST_USER_REGULAR2_PASS,

			




	
	
	
		
 
                             TEST_USER_REGULAR2_EMAIL, False)

			




	
	
	
		
 

			




	
	
	
		
 
    def create_ui_settings(self, repo_store_path):

			




	
	
	
		
 
        """

			




	
	
	
		
 
        Creates ui settings, fills out hooks

			




	
	
	
		
 
        """

			




	
	
	
		
 

			




	
	
	
		
 
        #HOOKS

			




	
	
	
		
 
        hooks1_key = Ui.HOOK_UPDATE

			




	
	
	
		
 
        hooks1_ = Ui.query() \

			




	
	
	
		
 
            .filter(Ui.ui_key == hooks1_key).scalar()

			




	
	
	
		
 

			




	
	
	
		
 
        hooks1 = Ui() if hooks1_ is None else hooks1_

			




	
	
	
		
 
        hooks1.ui_section = 'hooks'

			




	
	
	
		
 
        hooks1.ui_key = hooks1_key

			




	
	
	
		
 
        hooks1.ui_value = 'hg update >&2'

			




	
	
	
		
 
        hooks1.ui_active = False

			




	
	
	
		
 
        self.sa.add(hooks1)

			




	
	
	
		
 

			




	
	
	
		
 
        hooks2_key = Ui.HOOK_REPO_SIZE

			




	
	
	
		
 
        hooks2_ = Ui.query() \

			




	
	
	
		
 
            .filter(Ui.ui_key == hooks2_key).scalar()

			




	
	
	
		
 
        hooks2 = Ui() if hooks2_ is None else hooks2_

			




	
	
	
		
 
        hooks2.ui_section = 'hooks'

			




	
	
	
		
 
        hooks2.ui_key = hooks2_key

			




	
	
	
		
 
        hooks2.ui_value = 'python:kallithea.lib.hooks.repo_size'

			




	
	
	
		
 
        self.sa.add(hooks2)

			




	
	
	
		
 

			




	
	
	
		
 
        hooks3 = Ui()

			




	
	
	
		
 
        hooks3.ui_section = 'hooks'

			




	
	
	
		
 
        hooks3.ui_key = Ui.HOOK_PUSH

			




	
	
	
		
 
        hooks3.ui_value = 'python:kallithea.lib.hooks.log_push_action'

			




	
	
	
		
 
        self.sa.add(hooks3)

			




	
	
	
		
 

			




	
	
	
		
 
        hooks4 = Ui()

			




	
	
	
		
 
        hooks4.ui_section = 'hooks'

			




	
	
	
		
 
        hooks4.ui_key = Ui.HOOK_PRE_PUSH

			




	
	
	
		
 
        hooks4.ui_value = 'python:kallithea.lib.hooks.pre_push'

			




	
	
	
		
 
        self.sa.add(hooks4)

			




	
	
	
		
 

			




	
	
	
		
 
        hooks5 = Ui()

			




	
	
	
		
 
        hooks5.ui_section = 'hooks'

			




	
	
	
		
 
        hooks5.ui_key = Ui.HOOK_PULL

			




	
	
	
		
 
        hooks5.ui_value = 'python:kallithea.lib.hooks.log_pull_action'

			




	
	
	
		
 
        self.sa.add(hooks5)

			




	
	
	
		
 

			




	
	
	
		
 
        hooks6 = Ui()

			




	
	
	
		
 
        hooks6.ui_section = 'hooks'

			




	
	
	
		
 
        hooks6.ui_key = Ui.HOOK_PRE_PULL

			




	
	
	
		
 
        hooks6.ui_value = 'python:kallithea.lib.hooks.pre_pull'

			




	
	
	
		
 
        self.sa.add(hooks6)

			




        

    


    
    

    

        

                

                    kallithea/lib/paster_commands/setup_db.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



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

			




	
	
	
		
 
# This program is free software: you can redistribute it and/or modify

			




	
	
	
		
 
# it under the terms of the GNU General Public License as published by

			




	
	
	
		
 
# the Free Software Foundation, either version 3 of the License, or

			




	
	
	
		
 
# (at your option) any later version.

			




	
	
	
		
 
#

			




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

			




	
	
	
		
 
"""

			




	
	
	
		
 
kallithea.lib.paster_commands.setup_db

			




	
	
	
		
 
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

			




	
	
	
		
 

			




	
	
	
		
 
Databaset setup gearbox command for Kallithea

			




	
	
	
		
 
"""

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
import os

			




	
	
	
		
 
import sys

			




	
	
	
		
 
import paste.deploy

			




	
	
	
		
 

			




	
	
	
		
 
from kallithea.lib.db_manage import DbManage

			




	
	
	
		
 
from kallithea.lib.paster_commands.common import BasePasterCommand

			




	
	
	
		
 
from kallithea.model.meta import Session

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
# This is almost like SetupAppCommand ... but we have to pass options and it is

			




	
	
	
		
 
# thus simpler to drop websetup and reimplement everything

			




	
	
	
		
 
class Command(BasePasterCommand):

			




	
	
	
		
 
    """Kallithea: Configure the database specified in the .ini file

			




	
	
	
		
 

			




	
	
	
		
 
    Setup Kallithea according to its configuration file.  This is

			




	
	
	
		
 
    the second part of a two-phase web application installation

			




	
	
	
		
 
    process (the first phase is prepare-app). The setup process

			




	
	
	
		
 
    consist of things like setting up databases and creating the admin user

			




	
	
	
		
 
    """

			




	
	
	
		
 

			




	
	
	
		
 
    def get_description(self):

			




	
	
	
		
 
        return self.__doc__.splitlines()[0]

			




	
	
	
		
 

			




	
	
	
		
 
    requires_db_session = False # only available after this command has been run

			




	
	
	
		
 

			




	
	
	
		
 
    def get_parser(self, prog_name):

			




	
	
	
		
 
        parser = super(Command, self).get_parser(prog_name)

			




	
	
	
		
 

			




	
	
	
		
 
        parser.add_argument('--user',

			




	
	
	
		
 
                          action='store',

			




	
	
	
		
 
                          dest='username',

			




	
	
	
		
 
                          default=None,

			




	
	
	
		
 
                          help='Admin Username')

			




	
	
	
		
 
        parser.add_argument('--email',

			




	
	
	
		
 
                          action='store',

			




	
	
	
		
 
                          dest='email',

			




	
	
	
		
 
                          default=None,

			




	
	
	
		
 
                          help='Admin Email')

			




	
	
	
		
 
        parser.add_argument('--password',

			




	
	
	
		
 
                          action='store',

			




	
	
	
		
 
                          dest='password',

			




	
	
	
		
 
                          default=None,

			




	
	
	
		
 
                          help='Admin password min 6 chars')

			




	
	
	
		
 
        parser.add_argument('--repos',

			




	
	
	
		
 
                          action='store',

			




	
	
	
		
 
                          dest='repos_location',

			




	
	
	
		
 
                          default=None,

			




	
	
	
		
 
                          help='Absolute path to repositories location')

			




	
	
	
		
 
        parser.add_argument('--force-yes',

			




	
	
	
		
 
                           action='store_true',

			




	
	
	
		
 
                           dest='force_ask',

			




	
	
	
		
 
                           default=None,

			




	
	
	
		
 
                           help='Force yes to every question')

			




	
	
	
		
 
        parser.add_argument('--force-no',

			




	
	
	
		
 
                           action='store_false',

			




	
	
	
		
 
                           dest='force_ask',

			




	
	
	
		
 
                           default=None,

			




	
	
	
		
 
                           help='Force no to every question')

			




	
	
	
		
 
        parser.add_argument('--public-access',

			




	
	
	
		
 
                           action='store_true',

			




	
	
	
		
 
                           dest='public_access',

			




	
	
	
		
 
                           default=None,

			




	
	
	
		
 
                           help='Enable public access on this installation (default)')

			




	
	
	
		
 
        parser.add_argument('--no-public-access',

			




	
	
	
		
 
                           action='store_false',

			




	
	
	
		
 
                           dest='public_access',

			




	
	
	
		
 
                           default=None,

			




	
	
	
		
 
                           help='Disable public access on this installation ')

			




	
	
	
		
 

			




	
	
	
		
 
        return parser

			




	
	
	
		
 

			




	
	
	
		
 
    def take_action(self, opts):

			




	
	
	
		
 
        path_to_ini_file = os.path.realpath(opts.config_file)

			




	
	
	
		
 
        conf = paste.deploy.appconfig('config:' + path_to_ini_file)

			




	
	
	
		
 

			




	
	
	
		
 
        dbconf = conf['sqlalchemy.url']

			




	
	
	
		
 
        dbmanage = DbManage(log_sql=True, dbconf=dbconf, root=conf['here'],

			




	
	
	
		
 
        dbmanage = DbManage(dbconf=dbconf, root=conf['here'],

			




	
	
	
		
 
                            tests=False, cli_args=vars(opts))

			




	
	
	
		
 
        dbmanage.create_tables(override=True)

			




	
	
	
		
 
        opts = dbmanage.config_prompt(None)

			




	
	
	
		
 
        dbmanage.create_settings(opts)

			




	
	
	
		
 
        dbmanage.create_default_user()

			




	
	
	
		
 
        dbmanage.admin_prompt()

			




	
	
	
		
 
        dbmanage.create_permissions()

			




	
	
	
		
 
        dbmanage.populate_default_permissions()

			




	
	
	
		
 
        Session().commit()

			




        

    


    
    

    

        

                

                    kallithea/lib/paster_commands/template.ini.mako
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -318,305 +318,304 @@ use_celery = false

			




	
	
	
		
 
<%text>## Example: connect to the virtual host 'rabbitmqhost' on localhost as rabbitmq:</%text>

			




	
	
	
		
 
broker.url = amqp://rabbitmq:qewqew@localhost:5672/rabbitmqhost

			




	
	
	
		
 

			




	
	
	
		
 
celery.imports = kallithea.lib.celerylib.tasks

			




	
	
	
		
 
celery.accept.content = pickle

			




	
	
	
		
 
celery.result.backend = amqp

			




	
	
	
		
 
celery.result.dburi = amqp://

			




	
	
	
		
 
celery.result.serialier = json

			




	
	
	
		
 

			




	
	
	
		
 
#celery.send.task.error.emails = true

			




	
	
	
		
 
#celery.amqp.task.result.expires = 18000

			




	
	
	
		
 

			




	
	
	
		
 
celeryd.concurrency = 2

			




	
	
	
		
 
celeryd.max.tasks.per.child = 1

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## If true, tasks will never be sent to the queue, but executed locally instead.</%text>

			




	
	
	
		
 
celery.always.eager = false

			




	
	
	
		
 

			




	
	
	
		
 
<%text>####################################</%text>

			




	
	
	
		
 
<%text>###         BEAKER CACHE        ####</%text>

			




	
	
	
		
 
<%text>####################################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.data_dir = ${here}/data/cache/data

			




	
	
	
		
 
beaker.cache.lock_dir = ${here}/data/cache/lock

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.regions = short_term,long_term,sql_cache_short

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.short_term.type = memory

			




	
	
	
		
 
beaker.cache.short_term.expire = 60

			




	
	
	
		
 
beaker.cache.short_term.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.long_term.type = memory

			




	
	
	
		
 
beaker.cache.long_term.expire = 36000

			




	
	
	
		
 
beaker.cache.long_term.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.sql_cache_short.type = memory

			




	
	
	
		
 
beaker.cache.sql_cache_short.expire = 10

			




	
	
	
		
 
beaker.cache.sql_cache_short.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
<%text>####################################</%text>

			




	
	
	
		
 
<%text>###       BEAKER SESSION        ####</%text>

			




	
	
	
		
 
<%text>####################################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## Name of session cookie. Should be unique for a given host and path, even when running</%text>

			




	
	
	
		
 
<%text>## on different ports. Otherwise, cookie sessions will be shared and messed up.</%text>

			




	
	
	
		
 
beaker.session.key = kallithea

			




	
	
	
		
 
<%text>## Sessions should always only be accessible by the browser, not directly by JavaScript.</%text>

			




	
	
	
		
 
beaker.session.httponly = true

			




	
	
	
		
 
<%text>## Session lifetime. 2592000 seconds is 30 days.</%text>

			




	
	
	
		
 
beaker.session.timeout = 2592000

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## Server secret used with HMAC to ensure integrity of cookies.</%text>

			




	
	
	
		
 
beaker.session.secret = ${uuid()}

			




	
	
	
		
 
<%text>## Further, encrypt the data with AES.</%text>

			




	
	
	
		
 
#beaker.session.encrypt_key = <key_for_encryption>

			




	
	
	
		
 
#beaker.session.validate_key = <validation_key>

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## Type of storage used for the session, current types are</%text>

			




	
	
	
		
 
<%text>## dbm, file, memcached, database, and memory.</%text>

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## File system storage of session data. (default)</%text>

			




	
	
	
		
 
#beaker.session.type = file

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## Cookie only, store all session data inside the cookie. Requires secure secrets.</%text>

			




	
	
	
		
 
#beaker.session.type = cookie

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## Database storage of session data.</%text>

			




	
	
	
		
 
#beaker.session.type = ext:database

			




	
	
	
		
 
#beaker.session.sa.url = postgresql://postgres:qwe@localhost/kallithea

			




	
	
	
		
 
#beaker.session.table_name = db_session

			




	
	
	
		
 

			




	
	
	
		
 
%if error_aggregation_service == 'appenlight':

			




	
	
	
		
 
<%text>############################</%text>

			




	
	
	
		
 
<%text>## ERROR HANDLING SYSTEMS ##</%text>

			




	
	
	
		
 
<%text>############################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
# Propagate email settings to ErrorReporter of TurboGears2

			




	
	
	
		
 
# You do not normally need to change these lines

			




	
	
	
		
 
get trace_errors.error_email = email_to

			




	
	
	
		
 
get trace_errors.smtp_server = smtp_server

			




	
	
	
		
 
get trace_errors.smtp_port = smtp_port

			




	
	
	
		
 
get trace_errors.from_address = error_email_from

			




	
	
	
		
 

			




	
	
	
		
 
<%text>####################</%text>

			




	
	
	
		
 
<%text>### [appenlight] ###</%text>

			




	
	
	
		
 
<%text>####################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## AppEnlight is tailored to work with Kallithea, see</%text>

			




	
	
	
		
 
<%text>## http://appenlight.com for details how to obtain an account</%text>

			




	
	
	
		
 
<%text>## you must install python package `appenlight_client` to make it work</%text>

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## appenlight enabled</%text>

			




	
	
	
		
 
appenlight = false

			




	
	
	
		
 

			




	
	
	
		
 
appenlight.server_url = https://api.appenlight.com

			




	
	
	
		
 
appenlight.api_key = YOUR_API_KEY

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## TWEAK AMOUNT OF INFO SENT HERE</%text>

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## enables 404 error logging (default False)</%text>

			




	
	
	
		
 
appenlight.report_404 = false

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## time in seconds after request is considered being slow (default 1)</%text>

			




	
	
	
		
 
appenlight.slow_request_time = 1

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## record slow requests in application</%text>

			




	
	
	
		
 
<%text>## (needs to be enabled for slow datastore recording and time tracking)</%text>

			




	
	
	
		
 
appenlight.slow_requests = true

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## enable hooking to application loggers</%text>

			




	
	
	
		
 
#appenlight.logging = true

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## minimum log level for log capture</%text>

			




	
	
	
		
 
#appenlight.logging.level = WARNING

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## send logs only from erroneous/slow requests</%text>

			




	
	
	
		
 
<%text>## (saves API quota for intensive logging)</%text>

			




	
	
	
		
 
appenlight.logging_on_error = false

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## list of additional keywords that should be grabbed from environ object</%text>

			




	
	
	
		
 
<%text>## can be string with comma separated list of words in lowercase</%text>

			




	
	
	
		
 
<%text>## (by default client will always send following info:</%text>

			




	
	
	
		
 
<%text>## 'REMOTE_USER', 'REMOTE_ADDR', 'SERVER_NAME', 'CONTENT_TYPE' + all keys that</%text>

			




	
	
	
		
 
<%text>## start with HTTP* this list be extended with additional keywords here</%text>

			




	
	
	
		
 
appenlight.environ_keys_whitelist =

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## list of keywords that should be blanked from request object</%text>

			




	
	
	
		
 
<%text>## can be string with comma separated list of words in lowercase</%text>

			




	
	
	
		
 
<%text>## (by default client will always blank keys that contain following words</%text>

			




	
	
	
		
 
<%text>## 'password', 'passwd', 'pwd', 'auth_tkt', 'secret', 'csrf'</%text>

			




	
	
	
		
 
<%text>## this list be extended with additional keywords set here</%text>

			




	
	
	
		
 
appenlight.request_keys_blacklist =

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## list of namespaces that should be ignores when gathering log entries</%text>

			




	
	
	
		
 
<%text>## can be string with comma separated list of namespaces</%text>

			




	
	
	
		
 
<%text>## (by default the client ignores own entries: appenlight_client.client)</%text>

			




	
	
	
		
 
appenlight.log_namespace_blacklist =

			




	
	
	
		
 

			




	
	
	
		
 
%elif error_aggregation_service == 'sentry':

			




	
	
	
		
 
<%text>################</%text>

			




	
	
	
		
 
<%text>### [sentry] ###</%text>

			




	
	
	
		
 
<%text>################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
<%text>## sentry is a alternative open source error aggregator</%text>

			




	
	
	
		
 
<%text>## you must install python packages `sentry` and `raven` to enable</%text>

			




	
	
	
		
 

			




	
	
	
		
 
sentry.dsn = YOUR_DNS

			




	
	
	
		
 
sentry.servers =

			




	
	
	
		
 
sentry.name =

			




	
	
	
		
 
sentry.key =

			




	
	
	
		
 
sentry.public_key =

			




	
	
	
		
 
sentry.secret_key =

			




	
	
	
		
 
sentry.project =

			




	
	
	
		
 
sentry.site =

			




	
	
	
		
 
sentry.include_paths =

			




	
	
	
		
 
sentry.exclude_paths =

			




	
	
	
		
 

			




	
	
	
		
 
%endif

			




	
	
	
		
 
<%text>################################################################################</%text>

			




	
	
	
		
 
<%text>## WARNING: *DEBUG MODE MUST BE OFF IN A PRODUCTION ENVIRONMENT*              ##</%text>

			




	
	
	
		
 
<%text>## Debug mode will enable the interactive debugging tool, allowing ANYONE to  ##</%text>

			




	
	
	
		
 
<%text>## execute malicious code after an exception is raised.                       ##</%text>

			




	
	
	
		
 
<%text>################################################################################</%text>

			




	
	
	
		
 
debug = false

			




	
	
	
		
 

			




	
	
	
		
 
<%text>##################################</%text>

			




	
	
	
		
 
<%text>###       LOGVIEW CONFIG       ###</%text>

			




	
	
	
		
 
<%text>##################################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
logview.sqlalchemy = #faa

			




	
	
	
		
 
logview.pylons.templating = #bfb

			




	
	
	
		
 
logview.pylons.util = #eee

			




	
	
	
		
 

			




	
	
	
		
 
<%text>#########################################################</%text>

			




	
	
	
		
 
<%text>### DB CONFIGS - EACH DB WILL HAVE IT'S OWN CONFIG    ###</%text>

			




	
	
	
		
 
<%text>#########################################################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
%if database_engine == 'sqlite':

			




	
	
	
		
 
# SQLITE [default]

			




	
	
	
		
 
sqlalchemy.url = sqlite:///${here}/kallithea.db?timeout=60

			




	
	
	
		
 

			




	
	
	
		
 
%elif database_engine == 'postgres':

			




	
	
	
		
 
# POSTGRESQL

			




	
	
	
		
 
sqlalchemy.url = postgresql://user:pass@localhost/kallithea

			




	
	
	
		
 

			




	
	
	
		
 
%elif database_engine == 'mysql':

			




	
	
	
		
 
# MySQL

			




	
	
	
		
 
sqlalchemy.url = mysql://user:pass@localhost/kallithea?charset=utf8

			




	
	
	
		
 

			




	
	
	
		
 
%endif

			




	
	
	
		
 
# see sqlalchemy docs for others

			




	
	
	
		
 

			




	
	
	
		
 
sqlalchemy.echo = false

			




	
	
	
		
 
sqlalchemy.pool_recycle = 3600

			




	
	
	
		
 

			




	
	
	
		
 
<%text>################################</%text>

			




	
	
	
		
 
<%text>### ALEMBIC CONFIGURATION   ####</%text>

			




	
	
	
		
 
<%text>################################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
[alembic]

			




	
	
	
		
 
script_location = kallithea:alembic

			




	
	
	
		
 

			




	
	
	
		
 
<%text>################################</%text>

			




	
	
	
		
 
<%text>### LOGGING CONFIGURATION   ####</%text>

			




	
	
	
		
 
<%text>################################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
[loggers]

			




	
	
	
		
 
keys = root, routes, kallithea, sqlalchemy, tg, gearbox, beaker, templates, whoosh_indexer

			




	
	
	
		
 

			




	
	
	
		
 
[handlers]

			




	
	
	
		
 
keys = console, console_sql

			




	
	
	
		
 

			




	
	
	
		
 
[formatters]

			




	
	
	
		
 
keys = generic, color_formatter, color_formatter_sql

			




	
	
	
		
 

			




	
	
	
		
 
<%text>#############</%text>

			




	
	
	
		
 
<%text>## LOGGERS ##</%text>

			




	
	
	
		
 
<%text>#############</%text>

			




	
	
	
		
 

			




	
	
	
		
 
[logger_root]

			




	
	
	
		
 
level = NOTSET

			




	
	
	
		
 
handlers = console

			




	
	
	
		
 

			




	
	
	
		
 
[logger_routes]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = routes.middleware

			




	
	
	
		
 
<%text>## "level = DEBUG" logs the route matched and routing variables.</%text>

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_beaker]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = beaker.container

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_templates]

			




	
	
	
		
 
level = INFO

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = pylons.templating

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_kallithea]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = kallithea

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_tg]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = tg

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_gearbox]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = gearbox

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_sqlalchemy]

			




	
	
	
		
 
level = INFO

			




	
	
	
		
 
handlers = console_sql

			




	
	
	
		
 
qualname = sqlalchemy.engine

			




	
	
	
		
 
propagate = 0

			




	
	
	
		
 

			




	
	
	
		
 
[logger_whoosh_indexer]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = whoosh_indexer

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
<%text>##############</%text>

			




	
	
	
		
 
<%text>## HANDLERS ##</%text>

			




	
	
	
		
 
<%text>##############</%text>

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
level = INFO

			




	
	
	
		
 
formatter = generic

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console_sql]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
level = WARN

			




	
	
	
		
 
formatter = generic

			




	
	
	
		
 

			




	
	
	
		
 
<%text>################</%text>

			




	
	
	
		
 
<%text>## FORMATTERS ##</%text>

			




	
	
	
		
 
<%text>################</%text>

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_generic]

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_color_formatter]

			




	
	
	
		
 
class = kallithea.lib.colored_formatter.ColorFormatter

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_color_formatter_sql]

			




	
	
	
		
 
class = kallithea.lib.colored_formatter.ColorFormatterSql

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




        

    


    
    

    

        

                

                    kallithea/tests/fixture.py
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -140,251 +140,251 @@ class Fixture(object):

			




	
	
	
		
 
        defs.update(custom)

			




	
	
	
		
 

			




	
	
	
		
 
        return defs

			




	
	
	
		
 

			




	
	
	
		
 
    def create_repo(self, name, repo_group=None, **kwargs):

			




	
	
	
		
 
        if 'skip_if_exists' in kwargs:

			




	
	
	
		
 
            del kwargs['skip_if_exists']

			




	
	
	
		
 
            r = Repository.get_by_repo_name(name)

			




	
	
	
		
 
            if r:

			




	
	
	
		
 
                return r

			




	
	
	
		
 

			




	
	
	
		
 
        if isinstance(repo_group, RepoGroup):

			




	
	
	
		
 
            repo_group = repo_group.group_id

			




	
	
	
		
 

			




	
	
	
		
 
        form_data = self._get_repo_create_params(repo_name=name, **kwargs)

			




	
	
	
		
 
        form_data['repo_group'] = repo_group # patch form dict so it can be used directly by model

			




	
	
	
		
 
        cur_user = kwargs.get('cur_user', TEST_USER_ADMIN_LOGIN)

			




	
	
	
		
 
        RepoModel().create(form_data, cur_user)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 
        ScmModel().mark_for_invalidation(name)

			




	
	
	
		
 
        return Repository.get_by_repo_name(name)

			




	
	
	
		
 

			




	
	
	
		
 
    def create_fork(self, repo_to_fork, fork_name, **kwargs):

			




	
	
	
		
 
        repo_to_fork = Repository.get_by_repo_name(repo_to_fork)

			




	
	
	
		
 

			




	
	
	
		
 
        form_data = self._get_repo_create_params(repo_name=fork_name,

			




	
	
	
		
 
                                            fork_parent_id=repo_to_fork,

			




	
	
	
		
 
                                            repo_type=repo_to_fork.repo_type,

			




	
	
	
		
 
                                            **kwargs)

			




	
	
	
		
 
        # patch form dict so it can be used directly by model

			




	
	
	
		
 
        form_data['description'] = form_data['repo_description']

			




	
	
	
		
 
        form_data['private'] = form_data['repo_private']

			




	
	
	
		
 
        form_data['landing_rev'] = form_data['repo_landing_rev']

			




	
	
	
		
 

			




	
	
	
		
 
        owner = kwargs.get('cur_user', TEST_USER_ADMIN_LOGIN)

			




	
	
	
		
 
        RepoModel().create_fork(form_data, cur_user=owner)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 
        ScmModel().mark_for_invalidation(fork_name)

			




	
	
	
		
 
        r = Repository.get_by_repo_name(fork_name)

			




	
	
	
		
 
        assert r

			




	
	
	
		
 
        return r

			




	
	
	
		
 

			




	
	
	
		
 
    def destroy_repo(self, repo_name, **kwargs):

			




	
	
	
		
 
        RepoModel().delete(repo_name, **kwargs)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def create_repo_group(self, name, parent_group_id=None, **kwargs):

			




	
	
	
		
 
        if 'skip_if_exists' in kwargs:

			




	
	
	
		
 
            del kwargs['skip_if_exists']

			




	
	
	
		
 
            gr = RepoGroup.get_by_group_name(group_name=name)

			




	
	
	
		
 
            if gr:

			




	
	
	
		
 
                return gr

			




	
	
	
		
 
        form_data = self._get_repo_group_create_params(group_name=name, **kwargs)

			




	
	
	
		
 
        gr = RepoGroupModel().create(

			




	
	
	
		
 
            group_name=form_data['group_name'],

			




	
	
	
		
 
            group_description=form_data['group_name'],

			




	
	
	
		
 
            parent=parent_group_id,

			




	
	
	
		
 
            owner=kwargs.get('cur_user', TEST_USER_ADMIN_LOGIN),

			




	
	
	
		
 
            )

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 
        gr = RepoGroup.get_by_group_name(gr.group_name)

			




	
	
	
		
 
        return gr

			




	
	
	
		
 

			




	
	
	
		
 
    def destroy_repo_group(self, repogroupid):

			




	
	
	
		
 
        RepoGroupModel().delete(repogroupid)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def create_user(self, name, **kwargs):

			




	
	
	
		
 
        if 'skip_if_exists' in kwargs:

			




	
	
	
		
 
            del kwargs['skip_if_exists']

			




	
	
	
		
 
            user = User.get_by_username(name)

			




	
	
	
		
 
            if user:

			




	
	
	
		
 
                return user

			




	
	
	
		
 
        form_data = self._get_user_create_params(name, **kwargs)

			




	
	
	
		
 
        user = UserModel().create(form_data)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 
        user = User.get_by_username(user.username)

			




	
	
	
		
 
        return user

			




	
	
	
		
 

			




	
	
	
		
 
    def destroy_user(self, userid):

			




	
	
	
		
 
        UserModel().delete(userid)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def create_user_group(self, name, **kwargs):

			




	
	
	
		
 
        if 'skip_if_exists' in kwargs:

			




	
	
	
		
 
            del kwargs['skip_if_exists']

			




	
	
	
		
 
            gr = UserGroup.get_by_group_name(group_name=name)

			




	
	
	
		
 
            if gr:

			




	
	
	
		
 
                return gr

			




	
	
	
		
 
        form_data = self._get_user_group_create_params(name, **kwargs)

			




	
	
	
		
 
        owner = kwargs.get('cur_user', TEST_USER_ADMIN_LOGIN)

			




	
	
	
		
 
        user_group = UserGroupModel().create(

			




	
	
	
		
 
            name=form_data['users_group_name'],

			




	
	
	
		
 
            description=form_data['user_group_description'],

			




	
	
	
		
 
            owner=owner, active=form_data['users_group_active'],

			




	
	
	
		
 
            group_data=form_data['user_group_data'])

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 
        user_group = UserGroup.get_by_group_name(user_group.users_group_name)

			




	
	
	
		
 
        return user_group

			




	
	
	
		
 

			




	
	
	
		
 
    def destroy_user_group(self, usergroupid):

			




	
	
	
		
 
        UserGroupModel().delete(user_group=usergroupid, force=True)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def create_gist(self, **kwargs):

			




	
	
	
		
 
        form_data = {

			




	
	
	
		
 
            'description': u'new-gist',

			




	
	
	
		
 
            'owner': TEST_USER_ADMIN_LOGIN,

			




	
	
	
		
 
            'gist_type': Gist.GIST_PUBLIC,

			




	
	
	
		
 
            'lifetime': -1,

			




	
	
	
		
 
            'gist_mapping': {'filename1.txt':{'content':'hello world'},}

			




	
	
	
		
 
        }

			




	
	
	
		
 
        form_data.update(kwargs)

			




	
	
	
		
 
        gist = GistModel().create(

			




	
	
	
		
 
            description=form_data['description'],owner=form_data['owner'],

			




	
	
	
		
 
            gist_mapping=form_data['gist_mapping'], gist_type=form_data['gist_type'],

			




	
	
	
		
 
            lifetime=form_data['lifetime']

			




	
	
	
		
 
        )

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 

			




	
	
	
		
 
        return gist

			




	
	
	
		
 

			




	
	
	
		
 
    def destroy_gists(self, gistid=None):

			




	
	
	
		
 
        for g in Gist.query():

			




	
	
	
		
 
            if gistid:

			




	
	
	
		
 
                if gistid == g.gist_access_id:

			




	
	
	
		
 
                    GistModel().delete(g)

			




	
	
	
		
 
            else:

			




	
	
	
		
 
                GistModel().delete(g)

			




	
	
	
		
 
        Session().commit()

			




	
	
	
		
 

			




	
	
	
		
 
    def load_resource(self, resource_name, strip=True):

			




	
	
	
		
 
        with open(os.path.join(FIXTURES, resource_name), 'rb') as f:

			




	
	
	
		
 
            source = f.read()

			




	
	
	
		
 
            if strip:

			




	
	
	
		
 
                source = source.strip()

			




	
	
	
		
 

			




	
	
	
		
 
        return source

			




	
	
	
		
 

			




	
	
	
		
 
    def commit_change(self, repo, filename, content, message, vcs_type,

			




	
	
	
		
 
                      parent=None, newfile=False, author=None):

			




	
	
	
		
 
        repo = Repository.get_by_repo_name(repo)

			




	
	
	
		
 
        _cs = parent

			




	
	
	
		
 
        if parent is None:

			




	
	
	
		
 
            _cs = EmptyChangeset(alias=vcs_type)

			




	
	
	
		
 
        if author is None:

			




	
	
	
		
 
            author = TEST_USER_ADMIN_LOGIN

			




	
	
	
		
 

			




	
	
	
		
 
        if newfile:

			




	
	
	
		
 
            nodes = {

			




	
	
	
		
 
                filename: {

			




	
	
	
		
 
                    'content': content

			




	
	
	
		
 
                }

			




	
	
	
		
 
            }

			




	
	
	
		
 
            cs = ScmModel().create_nodes(

			




	
	
	
		
 
                user=TEST_USER_ADMIN_LOGIN, repo=repo,

			




	
	
	
		
 
                message=message,

			




	
	
	
		
 
                nodes=nodes,

			




	
	
	
		
 
                parent_cs=_cs,

			




	
	
	
		
 
                author=author,

			




	
	
	
		
 
            )

			




	
	
	
		
 
        else:

			




	
	
	
		
 
            cs = ScmModel().commit_change(

			




	
	
	
		
 
                repo=repo.scm_instance, repo_name=repo.repo_name,

			




	
	
	
		
 
                cs=parent, user=TEST_USER_ADMIN_LOGIN,

			




	
	
	
		
 
                author=author,

			




	
	
	
		
 
                message=message,

			




	
	
	
		
 
                content=content,

			




	
	
	
		
 
                f_path=filename

			




	
	
	
		
 
            )

			




	
	
	
		
 
        return cs

			




	
	
	
		
 

			




	
	
	
		
 

			




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

			




	
	
	
		
 
# Global test environment setup

			




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

			




	
	
	
		
 

			




	
	
	
		
 
def create_test_env(repos_test_path, config):

			




	
	
	
		
 
    """

			




	
	
	
		
 
    Makes a fresh database and

			




	
	
	
		
 
    install test repository into tmp dir

			




	
	
	
		
 
    """

			




	
	
	
		
 

			




	
	
	
		
 
    # PART ONE create db

			




	
	
	
		
 
    dbconf = config['sqlalchemy.url']

			




	
	
	
		
 
    log.debug('making test db %s', dbconf)

			




	
	
	
		
 

			




	
	
	
		
 
    # create test dir if it doesn't exist

			




	
	
	
		
 
    if not os.path.isdir(repos_test_path):

			




	
	
	
		
 
        log.debug('Creating testdir %s', repos_test_path)

			




	
	
	
		
 
        os.makedirs(repos_test_path)

			




	
	
	
		
 

			




	
	
	
		
 
    dbmanage = DbManage(log_sql=True, dbconf=dbconf, root=config['here'],

			




	
	
	
		
 
    dbmanage = DbManage(dbconf=dbconf, root=config['here'],

			




	
	
	
		
 
                        tests=True)

			




	
	
	
		
 
    dbmanage.create_tables(override=True)

			




	
	
	
		
 
    # for tests dynamically set new root paths based on generated content

			




	
	
	
		
 
    dbmanage.create_settings(dbmanage.config_prompt(repos_test_path))

			




	
	
	
		
 
    dbmanage.create_default_user()

			




	
	
	
		
 
    dbmanage.admin_prompt()

			




	
	
	
		
 
    dbmanage.create_permissions()

			




	
	
	
		
 
    dbmanage.populate_default_permissions()

			




	
	
	
		
 
    Session().commit()

			




	
	
	
		
 
    # PART TWO make test repo

			




	
	
	
		
 
    log.debug('making test vcs repositories')

			




	
	
	
		
 

			




	
	
	
		
 
    idx_path = config['index_dir']

			




	
	
	
		
 
    data_path = config['cache_dir']

			




	
	
	
		
 

			




	
	
	
		
 
    #clean index and data

			




	
	
	
		
 
    if idx_path and os.path.exists(idx_path):

			




	
	
	
		
 
        log.debug('remove %s', idx_path)

			




	
	
	
		
 
        shutil.rmtree(idx_path)

			




	
	
	
		
 

			




	
	
	
		
 
    if data_path and os.path.exists(data_path):

			




	
	
	
		
 
        log.debug('remove %s', data_path)

			




	
	
	
		
 
        shutil.rmtree(data_path)

			




	
	
	
		
 

			




	
	
	
		
 
    #CREATE DEFAULT TEST REPOS

			




	
	
	
		
 
    tar = tarfile.open(os.path.join(FIXTURES, 'vcs_test_hg.tar.gz'))

			




	
	
	
		
 
    tar.extractall(os.path.join(TESTS_TMP_PATH, HG_REPO))

			




	
	
	
		
 
    tar.close()

			




	
	
	
		
 

			




	
	
	
		
 
    tar = tarfile.open(os.path.join(FIXTURES, 'vcs_test_git.tar.gz'))

			




	
	
	
		
 
    tar.extractall(os.path.join(TESTS_TMP_PATH, GIT_REPO))

			




	
	
	
		
 
    tar.close()

			




	
	
	
		
 

			




	
	
	
		
 
    #LOAD VCS test stuff

			




	
	
	
		
 
    from kallithea.tests.vcs import setup_package

			




	
	
	
		
 
    setup_package()

			




	
	
	
		
 

			




	
	
	
		
 

			




	
	
	
		
 
def create_test_index(repo_location, config, full_index):

			




	
	
	
		
 
    """

			




	
	
	
		
 
    Makes default test index

			




	
	
	
		
 
    """

			




	
	
	
		
 

			




	
	
	
		
 
    from kallithea.lib.indexers.daemon import WhooshIndexingDaemon

			




	
	
	
		
 
    from kallithea.lib.pidlock import DaemonLock, LockHeld

			




	
	
	
		
 

			




	
	
	
		
 
    index_location = os.path.join(config['index_dir'])

			




	
	
	
		
 
    if not os.path.exists(index_location):

			




	
	
	
		
 
        os.makedirs(index_location)

			




	
	
	
		
 

			




	
	
	
		
 
    try:

			




	
	
	
		
 
        l = DaemonLock(file_=os.path.join(dirname(index_location), 'make_index.lock'))

			




	
	
	
		
 
        WhooshIndexingDaemon(index_location=index_location,

			




	
	
	
		
 
                             repo_location=repo_location) \

			




	
	
	
		
 
            .run(full_index=full_index)

			




	
	
	
		
 
        l.release()

			




	
	
	
		
 
    except LockHeld:

			




	
	
	
		
 
        pass

			




        

    


    
    

    

        

                

                    kallithea/tests/test.ini
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -317,308 +317,307 @@ allow_custom_hooks_settings = True

			




	
	
	
		
 

			




	
	
	
		
 
use_celery = false

			




	
	
	
		
 

			




	
	
	
		
 
## Example: connect to the virtual host 'rabbitmqhost' on localhost as rabbitmq:

			




	
	
	
		
 
broker.url = amqp://rabbitmq:qewqew@localhost:5672/rabbitmqhost

			




	
	
	
		
 

			




	
	
	
		
 
celery.imports = kallithea.lib.celerylib.tasks

			




	
	
	
		
 
celery.accept.content = pickle

			




	
	
	
		
 
celery.result.backend = amqp

			




	
	
	
		
 
celery.result.dburi = amqp://

			




	
	
	
		
 
celery.result.serialier = json

			




	
	
	
		
 

			




	
	
	
		
 
#celery.send.task.error.emails = true

			




	
	
	
		
 
#celery.amqp.task.result.expires = 18000

			




	
	
	
		
 

			




	
	
	
		
 
celeryd.concurrency = 2

			




	
	
	
		
 
celeryd.max.tasks.per.child = 1

			




	
	
	
		
 

			




	
	
	
		
 
## If true, tasks will never be sent to the queue, but executed locally instead.

			




	
	
	
		
 
celery.always.eager = false

			




	
	
	
		
 

			




	
	
	
		
 
####################################

			




	
	
	
		
 
###         BEAKER CACHE        ####

			




	
	
	
		
 
####################################

			




	
	
	
		
 

			




	
	
	
		
 
#beaker.cache.data_dir = %(here)s/data/cache/data

			




	
	
	
		
 
beaker.cache.data_dir = %(here)s/../../data/test/cache/data

			




	
	
	
		
 
#beaker.cache.lock_dir = %(here)s/data/cache/lock

			




	
	
	
		
 
beaker.cache.lock_dir = %(here)s/../../data/test/cache/lock

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.regions = short_term,long_term,sql_cache_short

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.short_term.type = memory

			




	
	
	
		
 
beaker.cache.short_term.expire = 60

			




	
	
	
		
 
beaker.cache.short_term.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.long_term.type = memory

			




	
	
	
		
 
beaker.cache.long_term.expire = 36000

			




	
	
	
		
 
beaker.cache.long_term.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
beaker.cache.sql_cache_short.type = memory

			




	
	
	
		
 
#beaker.cache.sql_cache_short.expire = 10

			




	
	
	
		
 
beaker.cache.sql_cache_short.expire = 1

			




	
	
	
		
 
beaker.cache.sql_cache_short.key_length = 256

			




	
	
	
		
 

			




	
	
	
		
 
####################################

			




	
	
	
		
 
###       BEAKER SESSION        ####

			




	
	
	
		
 
####################################

			




	
	
	
		
 

			




	
	
	
		
 
## Name of session cookie. Should be unique for a given host and path, even when running

			




	
	
	
		
 
## on different ports. Otherwise, cookie sessions will be shared and messed up.

			




	
	
	
		
 
beaker.session.key = kallithea

			




	
	
	
		
 
## Sessions should always only be accessible by the browser, not directly by JavaScript.

			




	
	
	
		
 
beaker.session.httponly = true

			




	
	
	
		
 
## Session lifetime. 2592000 seconds is 30 days.

			




	
	
	
		
 
beaker.session.timeout = 2592000

			




	
	
	
		
 

			




	
	
	
		
 
## Server secret used with HMAC to ensure integrity of cookies.

			




	
	
	
		
 
beaker.session.secret = {74e0cd75-b339-478b-b129-07dd221def1f}

			




	
	
	
		
 
## Further, encrypt the data with AES.

			




	
	
	
		
 
#beaker.session.encrypt_key = <key_for_encryption>

			




	
	
	
		
 
#beaker.session.validate_key = <validation_key>

			




	
	
	
		
 

			




	
	
	
		
 
## Type of storage used for the session, current types are

			




	
	
	
		
 
## dbm, file, memcached, database, and memory.

			




	
	
	
		
 

			




	
	
	
		
 
## File system storage of session data. (default)

			




	
	
	
		
 
#beaker.session.type = file

			




	
	
	
		
 

			




	
	
	
		
 
## Cookie only, store all session data inside the cookie. Requires secure secrets.

			




	
	
	
		
 
#beaker.session.type = cookie

			




	
	
	
		
 

			




	
	
	
		
 
## Database storage of session data.

			




	
	
	
		
 
#beaker.session.type = ext:database

			




	
	
	
		
 
#beaker.session.sa.url = postgresql://postgres:qwe@localhost/kallithea

			




	
	
	
		
 
#beaker.session.table_name = db_session

			




	
	
	
		
 

			




	
	
	
		
 
############################

			




	
	
	
		
 
## ERROR HANDLING SYSTEMS ##

			




	
	
	
		
 
############################

			




	
	
	
		
 

			




	
	
	
		
 
# Propagate email settings to ErrorReporter of TurboGears2

			




	
	
	
		
 
# You do not normally need to change these lines

			




	
	
	
		
 
get trace_errors.error_email = email_to

			




	
	
	
		
 
get trace_errors.smtp_server = smtp_server

			




	
	
	
		
 
get trace_errors.smtp_port = smtp_port

			




	
	
	
		
 
get trace_errors.from_address = error_email_from

			




	
	
	
		
 

			




	
	
	
		
 
####################

			




	
	
	
		
 
### [appenlight] ###

			




	
	
	
		
 
####################

			




	
	
	
		
 

			




	
	
	
		
 
## AppEnlight is tailored to work with Kallithea, see

			




	
	
	
		
 
## http://appenlight.com for details how to obtain an account

			




	
	
	
		
 
## you must install python package `appenlight_client` to make it work

			




	
	
	
		
 

			




	
	
	
		
 
## appenlight enabled

			




	
	
	
		
 
appenlight = false

			




	
	
	
		
 

			




	
	
	
		
 
appenlight.server_url = https://api.appenlight.com

			




	
	
	
		
 
appenlight.api_key = YOUR_API_KEY

			




	
	
	
		
 

			




	
	
	
		
 
## TWEAK AMOUNT OF INFO SENT HERE

			




	
	
	
		
 

			




	
	
	
		
 
## enables 404 error logging (default False)

			




	
	
	
		
 
appenlight.report_404 = false

			




	
	
	
		
 

			




	
	
	
		
 
## time in seconds after request is considered being slow (default 1)

			




	
	
	
		
 
appenlight.slow_request_time = 1

			




	
	
	
		
 

			




	
	
	
		
 
## record slow requests in application

			




	
	
	
		
 
## (needs to be enabled for slow datastore recording and time tracking)

			




	
	
	
		
 
appenlight.slow_requests = true

			




	
	
	
		
 

			




	
	
	
		
 
## enable hooking to application loggers

			




	
	
	
		
 
#appenlight.logging = true

			




	
	
	
		
 

			




	
	
	
		
 
## minimum log level for log capture

			




	
	
	
		
 
#appenlight.logging.level = WARNING

			




	
	
	
		
 

			




	
	
	
		
 
## send logs only from erroneous/slow requests

			




	
	
	
		
 
## (saves API quota for intensive logging)

			




	
	
	
		
 
appenlight.logging_on_error = false

			




	
	
	
		
 

			




	
	
	
		
 
## list of additional keywords that should be grabbed from environ object

			




	
	
	
		
 
## can be string with comma separated list of words in lowercase

			




	
	
	
		
 
## (by default client will always send following info:

			




	
	
	
		
 
## 'REMOTE_USER', 'REMOTE_ADDR', 'SERVER_NAME', 'CONTENT_TYPE' + all keys that

			




	
	
	
		
 
## start with HTTP* this list be extended with additional keywords here

			




	
	
	
		
 
appenlight.environ_keys_whitelist =

			




	
	
	
		
 

			




	
	
	
		
 
## list of keywords that should be blanked from request object

			




	
	
	
		
 
## can be string with comma separated list of words in lowercase

			




	
	
	
		
 
## (by default client will always blank keys that contain following words

			




	
	
	
		
 
## 'password', 'passwd', 'pwd', 'auth_tkt', 'secret', 'csrf'

			




	
	
	
		
 
## this list be extended with additional keywords set here

			




	
	
	
		
 
appenlight.request_keys_blacklist =

			




	
	
	
		
 

			




	
	
	
		
 
## list of namespaces that should be ignores when gathering log entries

			




	
	
	
		
 
## can be string with comma separated list of namespaces

			




	
	
	
		
 
## (by default the client ignores own entries: appenlight_client.client)

			




	
	
	
		
 
appenlight.log_namespace_blacklist =

			




	
	
	
		
 

			




	
	
	
		
 
################

			




	
	
	
		
 
### [sentry] ###

			




	
	
	
		
 
################

			




	
	
	
		
 

			




	
	
	
		
 
## sentry is a alternative open source error aggregator

			




	
	
	
		
 
## you must install python packages `sentry` and `raven` to enable

			




	
	
	
		
 

			




	
	
	
		
 
sentry.dsn = YOUR_DNS

			




	
	
	
		
 
sentry.servers =

			




	
	
	
		
 
sentry.name =

			




	
	
	
		
 
sentry.key =

			




	
	
	
		
 
sentry.public_key =

			




	
	
	
		
 
sentry.secret_key =

			




	
	
	
		
 
sentry.project =

			




	
	
	
		
 
sentry.site =

			




	
	
	
		
 
sentry.include_paths =

			




	
	
	
		
 
sentry.exclude_paths =

			




	
	
	
		
 

			




	
	
	
		
 
################################################################################

			




	
	
	
		
 
## WARNING: *DEBUG MODE MUST BE OFF IN A PRODUCTION ENVIRONMENT*              ##

			




	
	
	
		
 
## Debug mode will enable the interactive debugging tool, allowing ANYONE to  ##

			




	
	
	
		
 
## execute malicious code after an exception is raised.                       ##

			




	
	
	
		
 
################################################################################

			




	
	
	
		
 
debug = false

			




	
	
	
		
 

			




	
	
	
		
 
##################################

			




	
	
	
		
 
###       LOGVIEW CONFIG       ###

			




	
	
	
		
 
##################################

			




	
	
	
		
 

			




	
	
	
		
 
logview.sqlalchemy = #faa

			




	
	
	
		
 
logview.pylons.templating = #bfb

			




	
	
	
		
 
logview.pylons.util = #eee

			




	
	
	
		
 

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 
### DB CONFIGS - EACH DB WILL HAVE IT'S OWN CONFIG    ###

			




	
	
	
		
 
#########################################################

			




	
	
	
		
 

			




	
	
	
		
 
# SQLITE [default]

			




	
	
	
		
 
#sqlalchemy.url = sqlite:///%(here)s/kallithea.db?timeout=60

			




	
	
	
		
 
sqlalchemy.url = sqlite:///%(here)s/kallithea_test.sqlite

			




	
	
	
		
 

			




	
	
	
		
 
# POSTGRESQL

			




	
	
	
		
 
#sqlalchemy.url = postgresql://user:pass@localhost/kallithea

			




	
	
	
		
 

			




	
	
	
		
 
# MySQL

			




	
	
	
		
 
#sqlalchemy.url = mysql://user:pass@localhost/kallithea?charset=utf8

			




	
	
	
		
 

			




	
	
	
		
 
# see sqlalchemy docs for others

			




	
	
	
		
 

			




	
	
	
		
 
sqlalchemy.echo = false

			




	
	
	
		
 
sqlalchemy.pool_recycle = 3600

			




	
	
	
		
 

			




	
	
	
		
 
################################

			




	
	
	
		
 
### ALEMBIC CONFIGURATION   ####

			




	
	
	
		
 
################################

			




	
	
	
		
 

			




	
	
	
		
 
[alembic]

			




	
	
	
		
 
script_location = kallithea:alembic

			




	
	
	
		
 

			




	
	
	
		
 
################################

			




	
	
	
		
 
### LOGGING CONFIGURATION   ####

			




	
	
	
		
 
################################

			




	
	
	
		
 

			




	
	
	
		
 
[loggers]

			




	
	
	
		
 
keys = root, routes, kallithea, sqlalchemy, tg, gearbox, beaker, templates, whoosh_indexer

			




	
	
	
		
 

			




	
	
	
		
 
[handlers]

			




	
	
	
		
 
keys = console, console_sql

			




	
	
	
		
 

			




	
	
	
		
 
[formatters]

			




	
	
	
		
 
keys = generic, color_formatter, color_formatter_sql

			




	
	
	
		
 

			




	
	
	
		
 
#############

			




	
	
	
		
 
## LOGGERS ##

			




	
	
	
		
 
#############

			




	
	
	
		
 

			




	
	
	
		
 
[logger_root]

			




	
	
	
		
 
level = NOTSET

			




	
	
	
		
 
handlers = console

			




	
	
	
		
 

			




	
	
	
		
 
[logger_routes]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = routes.middleware

			




	
	
	
		
 
## "level = DEBUG" logs the route matched and routing variables.

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_beaker]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = beaker.container

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_templates]

			




	
	
	
		
 
level = INFO

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = pylons.templating

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_kallithea]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = kallithea

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_tg]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = tg

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_gearbox]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = gearbox

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
[logger_sqlalchemy]

			




	
	
	
		
 
level = INFO

			




	
	
	
		
 
handlers = console_sql

			




	
	
	
		
 
qualname = sqlalchemy.engine

			




	
	
	
		
 
propagate = 0

			




	
	
	
		
 

			




	
	
	
		
 
[logger_whoosh_indexer]

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
handlers =

			




	
	
	
		
 
qualname = whoosh_indexer

			




	
	
	
		
 
propagate = 1

			




	
	
	
		
 

			




	
	
	
		
 
##############

			




	
	
	
		
 
## HANDLERS ##

			




	
	
	
		
 
##############

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
#level = INFO

			




	
	
	
		
 
level = DEBUG

			




	
	
	
		
 
#formatter = generic

			




	
	
	
		
 
formatter = color_formatter

			




	
	
	
		
 

			




	
	
	
		
 
[handler_console_sql]

			




	
	
	
		
 
class = StreamHandler

			




	
	
	
		
 
args = (sys.stderr,)

			




	
	
	
		
 
level = WARN

			




	
	
	
		
 
#formatter = generic

			




	
	
	
		
 
formatter = color_formatter_sql

			




	
	
	
		
 

			




	
	
	
		
 
################

			




	
	
	
		
 
## FORMATTERS ##

			




	
	
	
		
 
################

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_generic]

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_color_formatter]

			




	
	
	
		
 
class = kallithea.lib.colored_formatter.ColorFormatter

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




	
	
	
		
 

			




	
	
	
		
 
[formatter_color_formatter_sql]

			




	
	
	
		
 
class = kallithea.lib.colored_formatter.ColorFormatterSql

			




	
	
	
		
 
format = %(asctime)s.%(msecs)03d %(levelname)-5.5s [%(name)s] %(message)s

			




	
	
	
		
 
datefmt = %Y-%m-%d %H:%M:%S

			




        

    



    


    



    



      

      





    
    0 comments (0 inline, 0 general)
    





    


  

  







  


    




    








    
        
    
    
        This site is powered by
            Kallithea 0.7.0,
        which is
        © 2010–2025 by various authors & licensed under GPLv3.