Compare commits
	
		
			8 Commits
		
	
	
		
			aeb4c39a12
			...
			44a7abab82
		
	
	| Author | SHA1 | Date | 
|---|---|---|
| 
							
							
								
								 | 
						44a7abab82 | |
| 
							
							
								
								 | 
						c161541b46 | |
| 
							
							
								
								 | 
						b03fe136be | |
| 
							
							
								
								 | 
						5c1fc19ca8 | |
| 
							
							
								
								 | 
						216b88c529 | |
| 
							
							
								
								 | 
						cfb4776a3c | |
| 
							
							
								
								 | 
						f1df5076ed | |
| 
							
							
								
								 | 
						35a2f25e71 | 
| 
						 | 
				
			
			@ -4,13 +4,14 @@ from flask import Flask
 | 
			
		|||
from flask_cors import CORS
 | 
			
		||||
from datetime import datetime, date
 | 
			
		||||
from flask.json import JSONEncoder, jsonify
 | 
			
		||||
from importlib_metadata import entry_points
 | 
			
		||||
from sqlalchemy.exc import OperationalError
 | 
			
		||||
from werkzeug.exceptions import HTTPException
 | 
			
		||||
 | 
			
		||||
from flaschengeist import logger
 | 
			
		||||
from flaschengeist.utils.hook import Hook
 | 
			
		||||
from flaschengeist.plugins import AuthPlugin
 | 
			
		||||
from flaschengeist.plugins import AuthPlugin, Plugin
 | 
			
		||||
from flaschengeist.utils.plugin import get_plugins
 | 
			
		||||
from flaschengeist.controller import roleController
 | 
			
		||||
from flaschengeist.config import config, configure_app
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -37,38 +38,29 @@ class CustomJSONEncoder(JSONEncoder):
 | 
			
		|||
 | 
			
		||||
@Hook("plugins.loaded")
 | 
			
		||||
def load_plugins(app: Flask):
 | 
			
		||||
    app.config["FG_PLUGINS"] = {}
 | 
			
		||||
 | 
			
		||||
    for entry_point in entry_points(group="flaschengeist.plugins"):
 | 
			
		||||
        logger.debug(f"Found plugin: {entry_point.name} ({entry_point.dist.version})")
 | 
			
		||||
 | 
			
		||||
        if entry_point.name == config["FLASCHENGEIST"]["auth"] or (
 | 
			
		||||
            entry_point.name in config and config[entry_point.name].get("enabled", False)
 | 
			
		||||
        ):
 | 
			
		||||
            logger.debug(f"Load plugin {entry_point.name}")
 | 
			
		||||
            try:
 | 
			
		||||
                plugin = entry_point.load()(entry_point, config=config.get(entry_point.name, {}))
 | 
			
		||||
                if hasattr(plugin, "blueprint") and plugin.blueprint is not None:
 | 
			
		||||
    def load_plugin(cls: type[Plugin]):
 | 
			
		||||
        logger.debug(f"Load plugin {cls.id}")
 | 
			
		||||
        # Initialize plugin with config section
 | 
			
		||||
        plugin = cls(config.get(plugin_class.id, config.get(plugin_class.id.split(".")[-1], {})))
 | 
			
		||||
        # Register blueprint if provided
 | 
			
		||||
        if plugin.blueprint is not None:
 | 
			
		||||
            app.register_blueprint(plugin.blueprint)
 | 
			
		||||
            except:
 | 
			
		||||
                logger.error(
 | 
			
		||||
                    f"Plugin {entry_point.name} was enabled, but could not be loaded due to an error.",
 | 
			
		||||
                    exc_info=True,
 | 
			
		||||
                )
 | 
			
		||||
                continue
 | 
			
		||||
            if isinstance(plugin, AuthPlugin):
 | 
			
		||||
                if entry_point.name != config["FLASCHENGEIST"]["auth"]:
 | 
			
		||||
                    logger.debug(f"Unload not configured AuthPlugin {entry_point.name}")
 | 
			
		||||
                    del plugin
 | 
			
		||||
                    continue
 | 
			
		||||
        # Save plugin application context
 | 
			
		||||
        app.config.setdefault("FG_PLUGINS", {})[plugin.id] = plugin
 | 
			
		||||
        return plugin
 | 
			
		||||
 | 
			
		||||
    for plugin_class in get_plugins():
 | 
			
		||||
        names = [plugin_class.id, plugin_class.id.split(".")[-1]]
 | 
			
		||||
        if config["FLASCHENGEIST"]["auth"] in names:
 | 
			
		||||
            # Load authentification plugin
 | 
			
		||||
            app.config["FG_AUTH_BACKEND"] = load_plugin(plugin_class)
 | 
			
		||||
            logger.info(f"Using authentication plugin: {plugin_class.id}")
 | 
			
		||||
        elif any([i in config and config[i].get("enabled", False) for i in names]):
 | 
			
		||||
            # Load all other enabled plugins
 | 
			
		||||
            load_plugin(plugin_class)
 | 
			
		||||
            logger.info(f"Using plugin: {plugin_class.id}")
 | 
			
		||||
        else:
 | 
			
		||||
                    logger.info(f"Using authentication plugin: {entry_point.name}")
 | 
			
		||||
                    app.config["FG_AUTH_BACKEND"] = plugin
 | 
			
		||||
            else:
 | 
			
		||||
                logger.info(f"Using plugin: {entry_point.name}")
 | 
			
		||||
            app.config["FG_PLUGINS"][entry_point.name] = plugin
 | 
			
		||||
        else:
 | 
			
		||||
            logger.debug(f"Skip disabled plugin {entry_point.name}")
 | 
			
		||||
            logger.debug(f"Skip disabled plugin {plugin_class.id}")
 | 
			
		||||
    if "FG_AUTH_BACKEND" not in app.config:
 | 
			
		||||
        logger.fatal("No authentication plugin configured or authentication plugin not found")
 | 
			
		||||
        raise RuntimeError("No authentication plugin configured or authentication plugin not found")
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -24,11 +24,7 @@ For more information, please refer to
 | 
			
		|||
- `flaschengeist.utils.hook.HookAfter`
 | 
			
		||||
"""
 | 
			
		||||
 | 
			
		||||
from importlib_metadata import Distribution, EntryPoint
 | 
			
		||||
from werkzeug.exceptions import MethodNotAllowed, NotFound
 | 
			
		||||
from werkzeug.datastructures import FileStorage
 | 
			
		||||
 | 
			
		||||
from flaschengeist.models.user import _Avatar, User
 | 
			
		||||
from flaschengeist.utils.hook import HookBefore, HookAfter
 | 
			
		||||
 | 
			
		||||
__all__ = [
 | 
			
		||||
| 
						 | 
				
			
			@ -92,47 +88,54 @@ Passed args:
 | 
			
		|||
class Plugin:
 | 
			
		||||
    """Base class for all Plugins
 | 
			
		||||
 | 
			
		||||
    All plugins must derived from this class.
 | 
			
		||||
    All plugins must be derived from this class.
 | 
			
		||||
    There are some static properties a plugin must provide,
 | 
			
		||||
    and some properties a plugin can provide if you might want
 | 
			
		||||
    to use more functionality.
 | 
			
		||||
 | 
			
		||||
    Required:
 | 
			
		||||
        - *id*: Unique identifier of your plugin
 | 
			
		||||
 | 
			
		||||
    Optional:
 | 
			
		||||
        - *blueprint*: `flask.Blueprint` providing your routes
 | 
			
		||||
        - *permissions*: List of your custom permissions
 | 
			
		||||
        - *models*: Your models, used for API export
 | 
			
		||||
        - *version*: Version of your plugin, can also be guessed by Flaschengeist
 | 
			
		||||
    """
 | 
			
		||||
 | 
			
		||||
    name: str
 | 
			
		||||
    """Name of the plugin, loaded from EntryPoint"""
 | 
			
		||||
    id: str = None
 | 
			
		||||
    """Override with the unique ID of the plugin
 | 
			
		||||
    
 | 
			
		||||
    version: str
 | 
			
		||||
    """Version of the plugin, loaded from Distribution"""
 | 
			
		||||
 | 
			
		||||
    dist: Distribution
 | 
			
		||||
    """Distribution of this plugin"""
 | 
			
		||||
    Hint: Use a fully qualified name like "dev.flaschengeist.plugin"
 | 
			
		||||
    """
 | 
			
		||||
 | 
			
		||||
    blueprint = None
 | 
			
		||||
    """Optional `flask.blueprint` if the plugin uses custom routes"""
 | 
			
		||||
    """Override with a `flask.blueprint` if the plugin uses custom routes"""
 | 
			
		||||
 | 
			
		||||
    permissions: list[str] = []
 | 
			
		||||
    """Optional list of custom permissions used by the plugin
 | 
			
		||||
    permissions: list[str] = []  # You have to override
 | 
			
		||||
    """Override to add custom permissions used by the plugin
 | 
			
		||||
    
 | 
			
		||||
    A good style is to name the permissions with a prefix related to the plugin name,
 | 
			
		||||
    to prevent clashes with other plugins. E. g. instead of *delete* use *plugin_delete*.
 | 
			
		||||
    """
 | 
			
		||||
 | 
			
		||||
    models = None
 | 
			
		||||
    """Optional module containing the SQLAlchemy models used by the plugin"""
 | 
			
		||||
    """Override with models module
 | 
			
		||||
    
 | 
			
		||||
    migrations_path = None
 | 
			
		||||
    """Optional location of the path to migration files, required if custome db tables are used"""
 | 
			
		||||
    Used for API export, has to be a static property
 | 
			
		||||
    """
 | 
			
		||||
 | 
			
		||||
    def __init__(self, entry_point: EntryPoint, config=None):
 | 
			
		||||
    version = None
 | 
			
		||||
    """Override with a custom version, optional
 | 
			
		||||
    
 | 
			
		||||
    If not set, the version is guessed from the package / distribution
 | 
			
		||||
    """
 | 
			
		||||
 | 
			
		||||
    def __init__(self, config=None):
 | 
			
		||||
        """Constructor called by create_app
 | 
			
		||||
        Args:
 | 
			
		||||
            config: Dict configuration containing the plugin section
 | 
			
		||||
        """
 | 
			
		||||
        self.version = entry_point.dist.version
 | 
			
		||||
        self.name = entry_point.name
 | 
			
		||||
        self.dist = entry_point.dist
 | 
			
		||||
 | 
			
		||||
    def install(self):
 | 
			
		||||
        """Installation routine
 | 
			
		||||
| 
						 | 
				
			
			@ -165,7 +168,7 @@ class Plugin:
 | 
			
		|||
        """
 | 
			
		||||
        from ..controller import pluginController
 | 
			
		||||
 | 
			
		||||
        return pluginController.get_setting(self.id, name, **kwargs)
 | 
			
		||||
        return pluginController.get_setting(self.id)
 | 
			
		||||
 | 
			
		||||
    def set_setting(self, name: str, value):
 | 
			
		||||
        """Save setting in database
 | 
			
		||||
| 
						 | 
				
			
			@ -287,7 +290,7 @@ class AuthPlugin(Plugin):
 | 
			
		|||
        """
 | 
			
		||||
        raise NotFound
 | 
			
		||||
 | 
			
		||||
    def set_avatar(self, user, file: FileStorage):
 | 
			
		||||
    def set_avatar(self, user, file):
 | 
			
		||||
        """Set the avatar for given user (if supported by auth backend)
 | 
			
		||||
 | 
			
		||||
        Default behavior is to use native Image objects stored on the Flaschengeist server
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -17,8 +17,10 @@ from flaschengeist.plugins import AuthPlugin, before_role_updated
 | 
			
		|||
 | 
			
		||||
 | 
			
		||||
class AuthLDAP(AuthPlugin):
 | 
			
		||||
    def __init__(self, entry_point, config):
 | 
			
		||||
        super().__init__(entry_point, config)
 | 
			
		||||
    id = "auth_ldap"
 | 
			
		||||
 | 
			
		||||
    def __init__(self, config):
 | 
			
		||||
        super().__init__()
 | 
			
		||||
        app.config.update(
 | 
			
		||||
            LDAP_SERVER=config.get("host", "localhost"),
 | 
			
		||||
            LDAP_PORT=config.get("port", 389),
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -57,15 +57,17 @@ def service_debit():
 | 
			
		|||
 | 
			
		||||
 | 
			
		||||
class BalancePlugin(Plugin):
 | 
			
		||||
    """Balance Plugin"""
 | 
			
		||||
 | 
			
		||||
    id = "dev.flaschengeist.balance"
 | 
			
		||||
    blueprint = Blueprint("balance", __name__)
 | 
			
		||||
    permissions = permissions.permissions
 | 
			
		||||
    plugin: "BalancePlugin" = LocalProxy(lambda: current_app.config["FG_PLUGINS"][BalancePlugin.name])
 | 
			
		||||
    models = models
 | 
			
		||||
 | 
			
		||||
    def __init__(self, entry_point, config):
 | 
			
		||||
        super(BalancePlugin, self).__init__(entry_point, config)
 | 
			
		||||
        from .routes import blueprint
 | 
			
		||||
 | 
			
		||||
        self.blueprint = blueprint
 | 
			
		||||
    def __init__(self, config):
 | 
			
		||||
        super(BalancePlugin, self).__init__(config)
 | 
			
		||||
        from . import routes
 | 
			
		||||
 | 
			
		||||
        self.migrations_path = (pathlib.Path(__file__).parent / "migrations").resolve()
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,6 +1,6 @@
 | 
			
		|||
from datetime import datetime, timezone
 | 
			
		||||
from werkzeug.exceptions import Forbidden, BadRequest
 | 
			
		||||
from flask import Blueprint, request, jsonify
 | 
			
		||||
from flask import request, jsonify
 | 
			
		||||
 | 
			
		||||
from flaschengeist.utils import HTTP
 | 
			
		||||
from flaschengeist.models.session import Session
 | 
			
		||||
| 
						 | 
				
			
			@ -18,10 +18,7 @@ def str2bool(string: str):
 | 
			
		|||
    raise ValueError
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
blueprint = Blueprint("balance", __package__)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/balance/shortcuts", methods=["GET", "PUT"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/users/<userid>/balance/shortcuts", methods=["GET", "PUT"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def get_shortcuts(userid, current_session: Session):
 | 
			
		||||
    """Get balance shortcuts of an user
 | 
			
		||||
| 
						 | 
				
			
			@ -53,7 +50,7 @@ def get_shortcuts(userid, current_session: Session):
 | 
			
		|||
        return HTTP.no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/balance/limit", methods=["GET"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/users/<userid>/balance/limit", methods=["GET"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def get_limit(userid, current_session: Session):
 | 
			
		||||
    """Get limit of an user
 | 
			
		||||
| 
						 | 
				
			
			@ -76,7 +73,7 @@ def get_limit(userid, current_session: Session):
 | 
			
		|||
    return {"limit": balance_controller.get_limit(user)}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/balance/limit", methods=["PUT"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/users/<userid>/balance/limit", methods=["PUT"])
 | 
			
		||||
@login_required(permissions.SET_LIMIT)
 | 
			
		||||
def set_limit(userid, current_session: Session):
 | 
			
		||||
    """Set the limit of an user
 | 
			
		||||
| 
						 | 
				
			
			@ -102,7 +99,7 @@ def set_limit(userid, current_session: Session):
 | 
			
		|||
    return HTTP.no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/balance/limit", methods=["GET", "PUT"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/users/balance/limit", methods=["GET", "PUT"])
 | 
			
		||||
@login_required(permission=permissions.SET_LIMIT)
 | 
			
		||||
def limits(current_session: Session):
 | 
			
		||||
    """Get, Modify limit of all users
 | 
			
		||||
| 
						 | 
				
			
			@ -127,7 +124,7 @@ def limits(current_session: Session):
 | 
			
		|||
    return HTTP.no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/balance", methods=["GET"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/users/<userid>/balance", methods=["GET"])
 | 
			
		||||
@login_required(permission=permissions.SHOW)
 | 
			
		||||
def get_balance(userid, current_session: Session):
 | 
			
		||||
    """Get balance of user, optionally filtered
 | 
			
		||||
| 
						 | 
				
			
			@ -165,7 +162,7 @@ def get_balance(userid, current_session: Session):
 | 
			
		|||
    return {"credit": balance[0], "debit": balance[1], "balance": balance[2]}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/balance/transactions", methods=["GET"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/users/<userid>/balance/transactions", methods=["GET"])
 | 
			
		||||
@login_required(permission=permissions.SHOW)
 | 
			
		||||
def get_transactions(userid, current_session: Session):
 | 
			
		||||
    """Get transactions of user, optionally filtered
 | 
			
		||||
| 
						 | 
				
			
			@ -226,7 +223,7 @@ def get_transactions(userid, current_session: Session):
 | 
			
		|||
    return {"transactions": transactions, "count": count}
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/balance", methods=["PUT"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/users/<userid>/balance", methods=["PUT"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def change_balance(userid, current_session: Session):
 | 
			
		||||
    """Change balance of an user
 | 
			
		||||
| 
						 | 
				
			
			@ -275,7 +272,7 @@ def change_balance(userid, current_session: Session):
 | 
			
		|||
    raise Forbidden
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/balance/<int:transaction_id>", methods=["DELETE"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/balance/<int:transaction_id>", methods=["DELETE"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def reverse_transaction(transaction_id, current_session: Session):
 | 
			
		||||
    """Reverse a transaction
 | 
			
		||||
| 
						 | 
				
			
			@ -300,7 +297,7 @@ def reverse_transaction(transaction_id, current_session: Session):
 | 
			
		|||
    raise Forbidden
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/balance", methods=["GET"])
 | 
			
		||||
@BalancePlugin.blueprint.route("/balance", methods=["GET"])
 | 
			
		||||
@login_required(permission=permissions.SHOW_OTHER)
 | 
			
		||||
def get_balances(current_session: Session):
 | 
			
		||||
    """Get all balances
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -12,8 +12,10 @@ from . import Plugin
 | 
			
		|||
 | 
			
		||||
 | 
			
		||||
class MailMessagePlugin(Plugin):
 | 
			
		||||
    def __init__(self, entry_point, config):
 | 
			
		||||
        super().__init__(entry_point, config)
 | 
			
		||||
    id = "dev.flaschengeist.mail_plugin"
 | 
			
		||||
 | 
			
		||||
    def __init__(self, config):
 | 
			
		||||
        super().__init__()
 | 
			
		||||
        self.server = config["SERVER"]
 | 
			
		||||
        self.port = config["PORT"]
 | 
			
		||||
        self.user = config["USER"]
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -16,24 +16,22 @@ from . import models
 | 
			
		|||
from . import pricelist_controller, permissions
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
blueprint = Blueprint("pricelist", __name__, url_prefix="/pricelist")
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
class PriceListPlugin(Plugin):
 | 
			
		||||
    id = "dev.flaschengeist.pricelist"
 | 
			
		||||
    permissions = permissions.permissions
 | 
			
		||||
    blueprint = Blueprint("pricelist", __name__, url_prefix="/pricelist")
 | 
			
		||||
    plugin = LocalProxy(lambda: current_app.config["FG_PLUGINS"][PriceListPlugin.name])
 | 
			
		||||
    models = models
 | 
			
		||||
 | 
			
		||||
    def __init__(self, entry_point, config=None):
 | 
			
		||||
        super().__init__(entry_point, config)
 | 
			
		||||
        self.blueprint = blueprint
 | 
			
		||||
    def __init__(self, cfg):
 | 
			
		||||
        super().__init__(cfg)
 | 
			
		||||
        self.migrations_path = (pathlib.Path(__file__).parent / "migrations").resolve()
 | 
			
		||||
        config = {"discount": 0}
 | 
			
		||||
        config.update(config)
 | 
			
		||||
        config.update(cfg)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drink-types", methods=["GET"])
 | 
			
		||||
@blueprint.route("/drink-types/<int:identifier>", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drink-types", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drink-types/<int:identifier>", methods=["GET"])
 | 
			
		||||
def get_drink_types(identifier=None):
 | 
			
		||||
    """Get DrinkType(s)
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -53,7 +51,7 @@ def get_drink_types(identifier=None):
 | 
			
		|||
    return jsonify(result)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drink-types", methods=["POST"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drink-types", methods=["POST"])
 | 
			
		||||
@login_required(permission=permissions.CREATE_TYPE)
 | 
			
		||||
def new_drink_type(current_session):
 | 
			
		||||
    """Create new DrinkType
 | 
			
		||||
| 
						 | 
				
			
			@ -75,7 +73,7 @@ def new_drink_type(current_session):
 | 
			
		|||
    return jsonify(drink_type)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drink-types/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drink-types/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@login_required(permission=permissions.EDIT_TYPE)
 | 
			
		||||
def update_drink_type(identifier, current_session):
 | 
			
		||||
    """Modify DrinkType
 | 
			
		||||
| 
						 | 
				
			
			@ -98,7 +96,7 @@ def update_drink_type(identifier, current_session):
 | 
			
		|||
    return jsonify(drink_type)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drink-types/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drink-types/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@login_required(permission=permissions.DELETE_TYPE)
 | 
			
		||||
def delete_drink_type(identifier, current_session):
 | 
			
		||||
    """Delete DrinkType
 | 
			
		||||
| 
						 | 
				
			
			@ -116,8 +114,8 @@ def delete_drink_type(identifier, current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/tags", methods=["GET"])
 | 
			
		||||
@blueprint.route("/tags/<int:identifier>", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/tags", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/tags/<int:identifier>", methods=["GET"])
 | 
			
		||||
def get_tags(identifier=None):
 | 
			
		||||
    """Get Tag(s)
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -137,7 +135,7 @@ def get_tags(identifier=None):
 | 
			
		|||
    return jsonify(result)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/tags", methods=["POST"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/tags", methods=["POST"])
 | 
			
		||||
@login_required(permission=permissions.CREATE_TAG)
 | 
			
		||||
def new_tag(current_session):
 | 
			
		||||
    """Create Tag
 | 
			
		||||
| 
						 | 
				
			
			@ -157,7 +155,7 @@ def new_tag(current_session):
 | 
			
		|||
    return jsonify(drink_type)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/tags/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/tags/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@login_required(permission=permissions.EDIT_TAG)
 | 
			
		||||
def update_tag(identifier, current_session):
 | 
			
		||||
    """Modify Tag
 | 
			
		||||
| 
						 | 
				
			
			@ -178,7 +176,7 @@ def update_tag(identifier, current_session):
 | 
			
		|||
    return jsonify(tag)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/tags/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/tags/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@login_required(permission=permissions.DELETE_TAG)
 | 
			
		||||
def delete_tag(identifier, current_session):
 | 
			
		||||
    """Delete Tag
 | 
			
		||||
| 
						 | 
				
			
			@ -196,8 +194,8 @@ def delete_tag(identifier, current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drinks", methods=["GET"])
 | 
			
		||||
@blueprint.route("/drinks/<int:identifier>", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks/<int:identifier>", methods=["GET"])
 | 
			
		||||
def get_drinks(identifier=None):
 | 
			
		||||
    """Get Drink(s)
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -253,7 +251,7 @@ def get_drinks(identifier=None):
 | 
			
		|||
    return jsonify({"drinks": drinks, "count": count})
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/list", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/list", methods=["GET"])
 | 
			
		||||
def get_pricelist():
 | 
			
		||||
    """Get Priclist
 | 
			
		||||
    Route: ``/pricelist/list`` | Method: ``GET``
 | 
			
		||||
| 
						 | 
				
			
			@ -302,7 +300,7 @@ def get_pricelist():
 | 
			
		|||
    return jsonify({"pricelist": pricelist, "count": count})
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drinks/search/<string:name>", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks/search/<string:name>", methods=["GET"])
 | 
			
		||||
def search_drinks(name):
 | 
			
		||||
    """Search Drink
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			@ -323,7 +321,7 @@ def search_drinks(name):
 | 
			
		|||
    return jsonify(pricelist_controller.get_drinks(name, public=public))
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drinks", methods=["POST"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks", methods=["POST"])
 | 
			
		||||
@login_required(permission=permissions.CREATE)
 | 
			
		||||
def create_drink(current_session):
 | 
			
		||||
    """Create Drink
 | 
			
		||||
| 
						 | 
				
			
			@ -375,7 +373,7 @@ def create_drink(current_session):
 | 
			
		|||
    return jsonify(pricelist_controller.set_drink(data))
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drinks/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@login_required(permission=permissions.EDIT)
 | 
			
		||||
def update_drink(identifier, current_session):
 | 
			
		||||
    """Modify Drink
 | 
			
		||||
| 
						 | 
				
			
			@ -429,7 +427,7 @@ def update_drink(identifier, current_session):
 | 
			
		|||
    return jsonify(pricelist_controller.update_drink(identifier, data))
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drinks/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@login_required(permission=permissions.DELETE)
 | 
			
		||||
def delete_drink(identifier, current_session):
 | 
			
		||||
    """Delete Drink
 | 
			
		||||
| 
						 | 
				
			
			@ -447,7 +445,7 @@ def delete_drink(identifier, current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/prices/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/prices/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@login_required(permission=permissions.DELETE_PRICE)
 | 
			
		||||
def delete_price(identifier, current_session):
 | 
			
		||||
    """Delete Price
 | 
			
		||||
| 
						 | 
				
			
			@ -465,7 +463,7 @@ def delete_price(identifier, current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/volumes/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/volumes/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@login_required(permission=permissions.DELETE_VOLUME)
 | 
			
		||||
def delete_volume(identifier, current_session):
 | 
			
		||||
    """Delete DrinkPriceVolume
 | 
			
		||||
| 
						 | 
				
			
			@ -483,7 +481,7 @@ def delete_volume(identifier, current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/ingredients/extraIngredients", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/ingredients/extraIngredients", methods=["GET"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def get_extra_ingredients(current_session):
 | 
			
		||||
    """Get ExtraIngredients
 | 
			
		||||
| 
						 | 
				
			
			@ -499,7 +497,7 @@ def get_extra_ingredients(current_session):
 | 
			
		|||
    return jsonify(pricelist_controller.get_extra_ingredients())
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/ingredients/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/ingredients/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@login_required(permission=permissions.DELETE_INGREDIENTS_DRINK)
 | 
			
		||||
def delete_ingredient(identifier, current_session):
 | 
			
		||||
    """Delete Ingredient
 | 
			
		||||
| 
						 | 
				
			
			@ -517,7 +515,7 @@ def delete_ingredient(identifier, current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/ingredients/extraIngredients", methods=["POST"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/ingredients/extraIngredients", methods=["POST"])
 | 
			
		||||
@login_required(permission=permissions.EDIT_INGREDIENTS)
 | 
			
		||||
def set_extra_ingredient(current_session):
 | 
			
		||||
    """Create ExtraIngredient
 | 
			
		||||
| 
						 | 
				
			
			@ -536,7 +534,7 @@ def set_extra_ingredient(current_session):
 | 
			
		|||
    return jsonify(pricelist_controller.set_extra_ingredient(data))
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/ingredients/extraIngredients/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/ingredients/extraIngredients/<int:identifier>", methods=["PUT"])
 | 
			
		||||
@login_required(permission=permissions.EDIT_INGREDIENTS)
 | 
			
		||||
def update_extra_ingredient(identifier, current_session):
 | 
			
		||||
    """Modify ExtraIngredient
 | 
			
		||||
| 
						 | 
				
			
			@ -556,7 +554,7 @@ def update_extra_ingredient(identifier, current_session):
 | 
			
		|||
    return jsonify(pricelist_controller.update_extra_ingredient(identifier, data))
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/ingredients/extraIngredients/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/ingredients/extraIngredients/<int:identifier>", methods=["DELETE"])
 | 
			
		||||
@login_required(permission=permissions.DELETE_INGREDIENTS)
 | 
			
		||||
def delete_extra_ingredient(identifier, current_session):
 | 
			
		||||
    """Delete ExtraIngredient
 | 
			
		||||
| 
						 | 
				
			
			@ -574,7 +572,7 @@ def delete_extra_ingredient(identifier, current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/settings/min_prices", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/settings/min_prices", methods=["GET"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def get_pricelist_settings_min_prices(current_session):
 | 
			
		||||
    """Get MinPrices
 | 
			
		||||
| 
						 | 
				
			
			@ -595,7 +593,7 @@ def get_pricelist_settings_min_prices(current_session):
 | 
			
		|||
    return jsonify(min_prices)
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/settings/min_prices", methods=["POST"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/settings/min_prices", methods=["POST"])
 | 
			
		||||
@login_required(permission=permissions.EDIT_MIN_PRICES)
 | 
			
		||||
def post_pricelist_settings_min_prices(current_session):
 | 
			
		||||
    """Create MinPrices
 | 
			
		||||
| 
						 | 
				
			
			@ -618,7 +616,7 @@ def post_pricelist_settings_min_prices(current_session):
 | 
			
		|||
    return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/pricecalc_columns", methods=["GET", "PUT"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/users/<userid>/pricecalc_columns", methods=["GET", "PUT"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def get_columns(userid, current_session):
 | 
			
		||||
    """Get pricecalc_columns of an user
 | 
			
		||||
| 
						 | 
				
			
			@ -650,7 +648,7 @@ def get_columns(userid, current_session):
 | 
			
		|||
        return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/pricecalc_columns_order", methods=["GET", "PUT"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/users/<userid>/pricecalc_columns_order", methods=["GET", "PUT"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def get_columns_order(userid, current_session):
 | 
			
		||||
    """Get pricecalc_columns_order of an user
 | 
			
		||||
| 
						 | 
				
			
			@ -681,7 +679,7 @@ def get_columns_order(userid, current_session):
 | 
			
		|||
        return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/users/<userid>/pricelist", methods=["GET", "PUT"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/users/<userid>/pricelist", methods=["GET", "PUT"])
 | 
			
		||||
@login_required()
 | 
			
		||||
def get_priclist_setting(userid, current_session):
 | 
			
		||||
    """Get pricelistsetting of an user
 | 
			
		||||
| 
						 | 
				
			
			@ -714,7 +712,7 @@ def get_priclist_setting(userid, current_session):
 | 
			
		|||
        return no_content()
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drinks/<int:identifier>/picture", methods=["POST", "DELETE"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks/<int:identifier>/picture", methods=["POST", "DELETE"])
 | 
			
		||||
@login_required(permission=permissions.EDIT)
 | 
			
		||||
def set_picture(identifier, current_session):
 | 
			
		||||
    """Get, Create, Delete Drink Picture
 | 
			
		||||
| 
						 | 
				
			
			@ -741,7 +739,7 @@ def set_picture(identifier, current_session):
 | 
			
		|||
        raise BadRequest
 | 
			
		||||
 | 
			
		||||
 | 
			
		||||
@blueprint.route("/drinks/<int:identifier>/picture", methods=["GET"])
 | 
			
		||||
@PriceListPlugin.blueprint.route("/drinks/<int:identifier>/picture", methods=["GET"])
 | 
			
		||||
# @headers({"Cache-Control": "private, must-revalidate"})
 | 
			
		||||
def _get_picture(identifier):
 | 
			
		||||
    """Get Picture
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -16,6 +16,7 @@ from . import permissions
 | 
			
		|||
 | 
			
		||||
 | 
			
		||||
class RolesPlugin(Plugin):
 | 
			
		||||
    id = "dev.flaschengeist.roles"
 | 
			
		||||
    blueprint = Blueprint("roles", __name__)
 | 
			
		||||
    permissions = permissions.permissions
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -1,5 +1,6 @@
 | 
			
		|||
from flask import Blueprint
 | 
			
		||||
import pkg_resources
 | 
			
		||||
from datetime import datetime, timedelta
 | 
			
		||||
from flask import Blueprint
 | 
			
		||||
 | 
			
		||||
from flaschengeist import logger
 | 
			
		||||
from flaschengeist.utils.HTTP import no_content
 | 
			
		||||
| 
						 | 
				
			
			@ -39,9 +40,15 @@ def scheduled(id: str, replace=False, **kwargs):
 | 
			
		|||
 | 
			
		||||
 | 
			
		||||
class SchedulerPlugin(Plugin):
 | 
			
		||||
    def __init__(self, entry_point, config=None):
 | 
			
		||||
        super().__init__(entry_point, config)
 | 
			
		||||
        self.blueprint = Blueprint(self.name, __name__)
 | 
			
		||||
    id = "dev.flaschengeist.scheduler"
 | 
			
		||||
    name = "scheduler"
 | 
			
		||||
    blueprint = Blueprint(name, __name__)
 | 
			
		||||
 | 
			
		||||
    def __init__(self, config=None):
 | 
			
		||||
        """Constructor called by create_app
 | 
			
		||||
        Args:
 | 
			
		||||
            config: Dict configuration containing the plugin section
 | 
			
		||||
        """
 | 
			
		||||
 | 
			
		||||
        def __view_func():
 | 
			
		||||
            self.run_tasks()
 | 
			
		||||
| 
						 | 
				
			
			@ -53,6 +60,7 @@ class SchedulerPlugin(Plugin):
 | 
			
		|||
            except:
 | 
			
		||||
                logger.error("Error while executing scheduled tasks!", exc_info=True)
 | 
			
		||||
 | 
			
		||||
        self.version = pkg_resources.get_distribution(self.__module__.split(".")[0]).version
 | 
			
		||||
        cron = None if config is None else config.get("cron", "passive_web").lower()
 | 
			
		||||
 | 
			
		||||
        if cron is None or cron == "passive_web":
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -18,6 +18,7 @@ from flaschengeist.utils.datetime import from_iso_format
 | 
			
		|||
 | 
			
		||||
 | 
			
		||||
class UsersPlugin(Plugin):
 | 
			
		||||
    id = "dev.flaschengeist.users"
 | 
			
		||||
    blueprint = Blueprint("users", __name__)
 | 
			
		||||
    permissions = permissions.permissions
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
							
								
								
									
										14
									
								
								setup.cfg
								
								
								
								
							
							
						
						
									
										14
									
								
								setup.cfg
								
								
								
								
							| 
						 | 
				
			
			@ -22,14 +22,12 @@ include_package_data = True
 | 
			
		|||
python_requires = >=3.9
 | 
			
		||||
packages = find:
 | 
			
		||||
install_requires =
 | 
			
		||||
    Flask>=2.0
 | 
			
		||||
    Pillow>=8.4.0
 | 
			
		||||
    flask_cors
 | 
			
		||||
    flask_migrate>=3.1.0
 | 
			
		||||
    flask_sqlalchemy>=2.5
 | 
			
		||||
    # Importlib requirement can be dropped when python requirement is >= 3.10
 | 
			
		||||
    importlib_metadata>=4.3
 | 
			
		||||
    sqlalchemy>=1.4.26
 | 
			
		||||
    Flask >= 2.0
 | 
			
		||||
    Flask-Cors >= 3.0
 | 
			
		||||
    Flask-Migrate >= 3.1.0 
 | 
			
		||||
    Flask-SQLAlchemy >= 2.5
 | 
			
		||||
    Pillow >= 8.4.0
 | 
			
		||||
    SQLAlchemy >= 1.4.28
 | 
			
		||||
    toml
 | 
			
		||||
    werkzeug >= 2.0
 | 
			
		||||
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
		Reference in New Issue