2274139388

Build Type

push

github

Committed by Lukas Holecek

Commit Message

Add stomp consumers

Run Details

548 of 666 branches covered (82.28%)

Branch coverage included in aggregate %.

256 of 262 new or added lines in 5 files covered. (97.71%)

4 existing lines in 2 files now uncovered.

1720 of 1990 relevant lines covered (86.43%)

0.86 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

89.8

/greenwave/app_factory.py

# SPDX-License-Identifier: GPL-2.0+

import logging
import logging.config

from flask import Flask
from greenwave.api_v1 import api
from greenwave.monitor import monitor_api
from greenwave.utils import json_error, load_config, sha1_mangle_key
from greenwave.policies import load_policies
from greenwave.subjects.subject_type import load_subject_types

from dogpile.cache import make_region
import requests
from werkzeug.exceptions import default_exceptions

log = logging.getLogger(__name__)


# applicaiton factory http://flask.pocoo.org/docs/0.12/patterns/appfactories/
def create_app(config_obj=None):
    app = Flask(__name__)

    app.config.update(load_config(config_obj))
    if app.config['PRODUCTION'] and app.secret_key == 'replace-me-with-something-random':  # nosec
        raise Warning("You need to change the app.secret_key value for production")

    logging_config = app.config.get('LOGGING')
    if logging_config:
        logging.config.dictConfig(logging_config)

    policies_dir = app.config['POLICIES_DIR']
    log.debug("config: Loading policies from %r", policies_dir)
    app.config['policies'] = load_policies(policies_dir)

    subject_types_dir = app.config['SUBJECT_TYPES_DIR']
    log.debug("config: Loading subject types from %r", subject_types_dir)
    app.config['subject_types'] = load_subject_types(subject_types_dir)

    if app.config.get('DIST_GIT_URL_TEMPLATE') and app.config.get('DIST_GIT_BASE_URL'):
        app.config['DIST_GIT_URL_TEMPLATE'] = app.config['DIST_GIT_URL_TEMPLATE'].replace(
            '{DIST_GIT_BASE_URL}', app.config['DIST_GIT_BASE_URL']
        )

    # register error handlers
    for code in default_exceptions.keys():
        app.register_error_handler(code, json_error)
    app.register_error_handler(ConnectionError, json_error)
    app.register_error_handler(requests.ConnectionError, json_error)
    app.register_error_handler(requests.Timeout, json_error)

    # register blueprints
    app.register_blueprint(api, url_prefix="/api/v1.0")
    app.register_blueprint(monitor_api, url_prefix="/api/v1.0")
    app.add_url_rule('/healthcheck', view_func=healthcheck)

    # Initialize the cache.
    app.cache = make_region(key_mangler=sha1_mangle_key)
    app.cache.configure(**app.config['CACHE'])

    return app


def healthcheck():
    """
    Request handler for performing an application-level health check. This is
    not part of the published API, it is intended for use by OpenShift or other
    monitoring tools.

    Returns a 200 response if the application is alive and able to serve requests.
    """
    return 'Health check OK', 200, [('Content-Type', 'text/plain')]

1	# SPDX-License-Identifier: GPL-2.0+
2
3	import logging	1✔
4	import logging.config	1✔
5
6	from flask import Flask	1✔
7	from greenwave.api_v1 import api	1✔
8	from greenwave.monitor import monitor_api	1✔
9	from greenwave.utils import json_error, load_config, sha1_mangle_key	1✔
10	from greenwave.policies import load_policies	1✔
11	from greenwave.subjects.subject_type import load_subject_types	1✔
12
13	from dogpile.cache import make_region	1✔
14	import requests	1✔
15	from werkzeug.exceptions import default_exceptions	1✔
16
17	log = logging.getLogger(__name__)	1✔
18
19
20	# applicaiton factory http://flask.pocoo.org/docs/0.12/patterns/appfactories/
21	def create_app(config_obj=None):	1✔
22	app = Flask(__name__)	1✔
23
24	app.config.update(load_config(config_obj))	1✔
25	if app.config['PRODUCTION'] and app.secret_key == 'replace-me-with-something-random': # nosec	1!
UNCOV 26	raise Warning("You need to change the app.secret_key value for production")	×
27
28	logging_config = app.config.get('LOGGING')	1✔
29	if logging_config:	1!
UNCOV 30	logging.config.dictConfig(logging_config)	×
31
32	policies_dir = app.config['POLICIES_DIR']	1✔
33	log.debug("config: Loading policies from %r", policies_dir)	1✔
34	app.config['policies'] = load_policies(policies_dir)	1✔
35
36	subject_types_dir = app.config['SUBJECT_TYPES_DIR']	1✔
37	log.debug("config: Loading subject types from %r", subject_types_dir)	1✔
38	app.config['subject_types'] = load_subject_types(subject_types_dir)	1✔
39
40	if app.config.get('DIST_GIT_URL_TEMPLATE') and app.config.get('DIST_GIT_BASE_URL'):	1✔
41	app.config['DIST_GIT_URL_TEMPLATE'] = app.config['DIST_GIT_URL_TEMPLATE'].replace(	1✔
42	'{DIST_GIT_BASE_URL}', app.config['DIST_GIT_BASE_URL']
43	)
44
45	# register error handlers
46	for code in default_exceptions.keys():	1✔
47	app.register_error_handler(code, json_error)	1✔
48	app.register_error_handler(ConnectionError, json_error)	1✔
49	app.register_error_handler(requests.ConnectionError, json_error)	1✔
50	app.register_error_handler(requests.Timeout, json_error)	1✔
51
52	# register blueprints
53	app.register_blueprint(api, url_prefix="/api/v1.0")	1✔
54	app.register_blueprint(monitor_api, url_prefix="/api/v1.0")	1✔
55	app.add_url_rule('/healthcheck', view_func=healthcheck)	1✔
56
57	# Initialize the cache.
58	app.cache = make_region(key_mangler=sha1_mangle_key)	1✔
59	app.cache.configure(**app.config['CACHE'])	1✔
60
61	return app	1✔
62
63
64	def healthcheck():	1✔
65	"""
66	Request handler for performing an application-level health check. This is
67	not part of the published API, it is intended for use by OpenShift or other
68	monitoring tools.
69
70	Returns a 200 response if the application is alive and able to serve requests.
71	"""
UNCOV 72	return 'Health check OK', 200, [('Content-Type', 'text/plain')]	×

release-engineering / greenwave / 2274139388

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous