Compare commits
1 commit
master
...
show-logo-
Author | SHA1 | Date | |
---|---|---|---|
|
cb2c9df23b |
64 changed files with 589 additions and 1328 deletions
|
@ -1,10 +0,0 @@
|
|||
# Ignore everything
|
||||
*
|
||||
|
||||
# Include source, config and scripts
|
||||
!app
|
||||
!etc
|
||||
!*.md
|
||||
!*.sh
|
||||
!*.txt
|
||||
!LICENSE
|
|
@ -5,8 +5,6 @@
|
|||
# run arbitrary code.
|
||||
extension-pkg-whitelist=
|
||||
|
||||
fail-under=9.58
|
||||
|
||||
# Add files or directories to the blacklist. They should be base names, not
|
||||
# paths.
|
||||
ignore=CVS
|
||||
|
@ -30,7 +28,7 @@ limit-inference-results=100
|
|||
|
||||
# List of plugins (as comma separated values of python modules names) to load,
|
||||
# usually to register additional checkers.
|
||||
load-plugins=pylint_flask_sqlalchemy,pylint_flask
|
||||
load-plugins=
|
||||
|
||||
# Pickle collected data for later comparisons.
|
||||
persistent=yes
|
||||
|
@ -62,7 +60,7 @@ confidence=
|
|||
# --enable=similarities". If you want to run only the classes checker, but have
|
||||
# no Warning level messages displayed, use "--disable=all --enable=classes
|
||||
# --disable=W".
|
||||
disable=E0401,E0611,C0103,W0511,W0611,C0415
|
||||
disable=E0401,E0611,C0103,W0511,W0611
|
||||
|
||||
# Enable the message, report, category or checker with the given id(s). You can
|
||||
# either give multiple identifier separated by comma (,) or put this option
|
||||
|
|
|
@ -1 +1 @@
|
|||
3.9.2
|
||||
3.5.3
|
|
@ -1 +0,0 @@
|
|||
python 3.9.2
|
26
Dockerfile
26
Dockerfile
|
@ -1,26 +0,0 @@
|
|||
# syntax=docker/dockerfile:1
|
||||
FROM python:3.9.2-slim AS development
|
||||
|
||||
WORKDIR /src
|
||||
|
||||
RUN pip install pymysql
|
||||
|
||||
ADD https://git.zeus.gent/haldis/menus/-/archive/master/menus-master.tar /tmp
|
||||
RUN mkdir menus && \
|
||||
tar --directory=menus --extract --strip-components=1 --file=/tmp/menus-master.tar
|
||||
|
||||
COPY requirements.txt .
|
||||
RUN pip install -r requirements.txt
|
||||
|
||||
COPY . .
|
||||
|
||||
WORKDIR /src/app
|
||||
CMD python app.py db upgrade && \
|
||||
python app.py runserver -h 0.0.0.0 -p 8000
|
||||
|
||||
FROM development AS production
|
||||
|
||||
RUN pip install waitress
|
||||
|
||||
CMD python app.py db upgrade && \
|
||||
python waitress_wsgi.py
|
|
@ -14,7 +14,6 @@ Be lazier today!
|
|||
## Local setup
|
||||
|
||||
There is a special script to get started with the project. Just run it in the root of the project.
|
||||
Note: this script might require you to install a certain python version, you can do this using your favorite tool e.g. [pyenv](https://github.com/pyenv/pyenv#simple-python-version-management-pyenv)
|
||||
|
||||
./first-setup.sh
|
||||
|
||||
|
@ -26,7 +25,7 @@ Afterwards upgrade the database to the latest version using
|
|||
cd app
|
||||
python3 app.py db upgrade
|
||||
|
||||
You can now still seed the database by running, note that you might want to put your name in the `HALDIS_ADMINS` in `app/config.py`
|
||||
You can now still seed the database by running
|
||||
|
||||
./populate-db.sh
|
||||
|
||||
|
|
|
@ -1,14 +0,0 @@
|
|||
"""Script for adding users as admin to Haldis."""
|
||||
from models import User
|
||||
|
||||
from app import db
|
||||
from models import User
|
||||
from config import Configuration
|
||||
|
||||
|
||||
def add() -> None:
|
||||
"""Add users as admin."""
|
||||
for username in Configuration.HALDIS_ADMINS:
|
||||
user = User()
|
||||
user.configure(username, True, 0, associations=["zeus"])
|
||||
db.session.add(user)
|
39
app/admin.py
39
app/admin.py
|
@ -1,22 +1,19 @@
|
|||
"Module for everything related to Admin users"
|
||||
import flask_login as login
|
||||
from flask import Flask
|
||||
from flask_admin import Admin
|
||||
from flask_admin.contrib.sqla import ModelView
|
||||
from flask_sqlalchemy import SQLAlchemy
|
||||
|
||||
from models import Order, OrderItem, OrderItemChoice, User
|
||||
|
||||
|
||||
class ModelBaseView(ModelView):
|
||||
"Class for the base view of the model"
|
||||
# pylint: disable=too-few-public-methods, no-self-use
|
||||
def is_accessible(self) -> bool:
|
||||
"Function to check if the logged in user is an admin"
|
||||
return login.current_user.is_admin()
|
||||
|
||||
|
||||
class UserAdminModel(ModelBaseView):
|
||||
"Class for the model of a UserAdmin"
|
||||
# pylint: disable=too-few-public-methods
|
||||
column_searchable_list = ("username",)
|
||||
column_editable_list = ("username",)
|
||||
|
@ -25,45 +22,27 @@ class UserAdminModel(ModelBaseView):
|
|||
|
||||
|
||||
class OrderAdminModel(ModelBaseView):
|
||||
"Class for the model of a OrderAdmin"
|
||||
# pylint: disable=too-few-public-methods
|
||||
column_default_sort = ("starttime", True)
|
||||
column_list = ["starttime", "stoptime", "location_name", "location_id", "courier", "association"]
|
||||
column_list = ["starttime", "stoptime", "location_name", "location_id", "courier"]
|
||||
column_labels = {
|
||||
"starttime": "Start Time",
|
||||
"stoptime": "Closing Time",
|
||||
"location_id": "HLDS Location ID",
|
||||
"association": "Association",
|
||||
}
|
||||
"starttime": "Start Time", "stoptime": "Closing Time",
|
||||
"location_id": "HLDS Location ID"}
|
||||
form_excluded_columns = ["items", "courier_id"]
|
||||
can_delete = False
|
||||
|
||||
|
||||
class OrderItemAdminModel(ModelBaseView):
|
||||
"Class for the model of a OrderItemAdmin"
|
||||
# pylint: disable=too-few-public-methods
|
||||
column_default_sort = ("order_id", True)
|
||||
column_list = [
|
||||
"order_id",
|
||||
"slug",
|
||||
"order.location_name",
|
||||
"user_name",
|
||||
"user",
|
||||
"dish_name",
|
||||
"dish_id",
|
||||
"comment",
|
||||
"price",
|
||||
"paid",
|
||||
"hlds_data_version",
|
||||
"order_id", "order.location_name", "user_name", "user", "dish_name", "dish_id", "comment", "price", "paid",
|
||||
"hlds_data_version"
|
||||
]
|
||||
column_labels = {
|
||||
"order_id": "Order",
|
||||
"order.location_name": "Order's Location",
|
||||
"user_name": "Anon. User",
|
||||
"user_id": "Registered User",
|
||||
"hlds_data_version": "HLDS Data Version",
|
||||
"dish_id": "HLDS Dish ID",
|
||||
}
|
||||
"order_id": "Order", "order.location_name": "Order's Location",
|
||||
"user_name": "Anon. User", "user_id": "Registered User",
|
||||
"hlds_data_version": "HLDS Data Version", "dish_id": "HLDS Dish ID"}
|
||||
|
||||
|
||||
def init_admin(app: Flask, database: SQLAlchemy) -> None:
|
||||
|
|
83
app/app.py
83
app/app.py
|
@ -1,35 +1,29 @@
|
|||
#!/usr/bin/env python3
|
||||
|
||||
"""Main Haldis script"""
|
||||
|
||||
"Main Haldis script"
|
||||
import logging
|
||||
import sentry_sdk
|
||||
from logging.handlers import TimedRotatingFileHandler
|
||||
import typing
|
||||
from datetime import datetime
|
||||
from logging.handlers import TimedRotatingFileHandler
|
||||
|
||||
from admin import init_admin
|
||||
from config import Configuration
|
||||
from flask import Flask, render_template, Response
|
||||
from flask import Flask, render_template
|
||||
from flask_bootstrap import Bootstrap, StaticCDN
|
||||
from flask_debugtoolbar import DebugToolbarExtension
|
||||
from flask_login import LoginManager
|
||||
from flask_migrate import Migrate, MigrateCommand
|
||||
from flask_oauthlib.client import OAuth, OAuthException
|
||||
from flask_script import Manager, Server
|
||||
from markupsafe import Markup
|
||||
|
||||
from admin import init_admin
|
||||
from auth.login import init_login
|
||||
from auth.zeus import init_oauth
|
||||
from config import Configuration
|
||||
from login import init_login
|
||||
from models import db
|
||||
from models.anonymous_user import AnonymouseUser
|
||||
from sentry_sdk.integrations.flask import FlaskIntegration
|
||||
from utils import euro_string, price_range_string, ignore_none
|
||||
from utils import euro_string, price_range_string
|
||||
from zeus import init_oauth
|
||||
|
||||
|
||||
def register_plugins(app: Flask) -> Manager:
|
||||
"""Register the plugins to the app"""
|
||||
# pylint: disable=W0612
|
||||
if not app.debug:
|
||||
timedFileHandler = TimedRotatingFileHandler(
|
||||
|
@ -74,8 +68,7 @@ def register_plugins(app: Flask) -> Manager:
|
|||
|
||||
# Make cookies more secure
|
||||
app.config.update(
|
||||
SESSION_COOKIE_HTTPONLY=True,
|
||||
SESSION_COOKIE_SAMESITE="Lax",
|
||||
SESSION_COOKIE_HTTPONLY=True, SESSION_COOKIE_SAMESITE="Lax",
|
||||
)
|
||||
|
||||
if not app.debug:
|
||||
|
@ -85,8 +78,7 @@ def register_plugins(app: Flask) -> Manager:
|
|||
|
||||
|
||||
def add_handlers(app: Flask) -> None:
|
||||
"""Add handlers for 4xx error codes"""
|
||||
|
||||
"Add handlers for 4xx error codes"
|
||||
# pylint: disable=W0612,W0613
|
||||
@app.errorhandler(404)
|
||||
def handle404(e) -> typing.Tuple[str, int]:
|
||||
|
@ -98,34 +90,29 @@ def add_handlers(app: Flask) -> None:
|
|||
|
||||
|
||||
def add_routes(application: Flask) -> None:
|
||||
"""Add all routes to Haldis"""
|
||||
"Add all routes to Haldis"
|
||||
# import views # TODO convert to blueprint
|
||||
# import views.stats # TODO convert to blueprint
|
||||
|
||||
from auth.login import auth_bp
|
||||
from auth.microsoft import auth_microsoft_bp
|
||||
from auth.zeus import auth_zeus_bp
|
||||
from views.debug import debug_bp
|
||||
from views.general import general_bp
|
||||
from views.order import order_bp
|
||||
from views.general import general_bp
|
||||
from views.stats import stats_blueprint
|
||||
from views.debug import debug_bp
|
||||
from login import auth_bp
|
||||
from zeus import oauth_bp
|
||||
|
||||
application.register_blueprint(general_bp, url_prefix="/")
|
||||
application.register_blueprint(order_bp, url_prefix="/order")
|
||||
application.register_blueprint(stats_blueprint, url_prefix="/stats")
|
||||
application.register_blueprint(auth_bp, url_prefix="/")
|
||||
if Configuration.ENABLE_MICROSOFT_AUTH:
|
||||
application.register_blueprint(auth_microsoft_bp,
|
||||
url_prefix="/users/auth/microsoft_graph_auth") # "/auth/microsoft")
|
||||
application.register_blueprint(auth_zeus_bp, url_prefix="/auth/zeus")
|
||||
application.register_blueprint(oauth_bp, url_prefix="/")
|
||||
|
||||
if application.debug:
|
||||
application.register_blueprint(debug_bp, url_prefix="/debug")
|
||||
|
||||
|
||||
def add_template_filters(app: Flask) -> None:
|
||||
"""Add functions which can be used in the templates"""
|
||||
|
||||
"Add functions which can be used in the templates"
|
||||
# pylint: disable=W0612
|
||||
@app.template_filter("countdown")
|
||||
def countdown(
|
||||
|
@ -160,41 +147,19 @@ def add_template_filters(app: Flask) -> None:
|
|||
app.template_filter("price_range")(price_range_string)
|
||||
app.template_filter("any")(any)
|
||||
app.template_filter("all")(all)
|
||||
app.template_filter("ignore_none")(ignore_none)
|
||||
|
||||
|
||||
def create_app():
|
||||
"""Initializer for the Flask app object"""
|
||||
app = Flask(__name__)
|
||||
app = Flask(__name__)
|
||||
|
||||
@app.route('/robots.txt')
|
||||
def noindex():
|
||||
r = Response(response="User-Agent: *\nDisallow: /\n", status=200, mimetype="text/plain")
|
||||
r.headers["Content-Type"] = "text/plain; charset=utf-8"
|
||||
return r
|
||||
|
||||
# Load the config file
|
||||
app.config.from_object("config.Configuration")
|
||||
# Load the config file
|
||||
app.config.from_object("config.Configuration")
|
||||
|
||||
app_manager = register_plugins(app)
|
||||
add_handlers(app)
|
||||
add_routes(app)
|
||||
add_template_filters(app)
|
||||
|
||||
@app.context_processor
|
||||
def inject_config():
|
||||
return dict(configuration=Configuration)
|
||||
|
||||
return app, app_manager
|
||||
app_manager = register_plugins(app)
|
||||
add_handlers(app)
|
||||
add_routes(app)
|
||||
add_template_filters(app)
|
||||
|
||||
|
||||
# For usage when you directly call the script with python
|
||||
if __name__ == "__main__":
|
||||
if Configuration.SENTRY_DSN:
|
||||
sentry_sdk.init(
|
||||
dsn=Configuration.SENTRY_DSN,
|
||||
integrations=[FlaskIntegration()]
|
||||
)
|
||||
|
||||
app, app_mgr = create_app()
|
||||
app_mgr.run()
|
||||
app_manager.run()
|
||||
|
|
|
@ -1,77 +0,0 @@
|
|||
import typing
|
||||
|
||||
from flask import Blueprint, url_for, request, redirect, flash, Response
|
||||
from flask_login import login_user
|
||||
from microsoftgraph.client import Client
|
||||
|
||||
from config import Configuration
|
||||
from models import User, db
|
||||
|
||||
auth_microsoft_bp = Blueprint("auth_microsoft_bp", __name__)
|
||||
|
||||
client = Client(Configuration.MICROSOFT_AUTH_ID,
|
||||
Configuration.MICROSOFT_AUTH_SECRET,
|
||||
account_type="ugentbe.onmicrosoft.com")
|
||||
|
||||
|
||||
def microsoft_login():
|
||||
"""Log in using Microsoft"""
|
||||
scope = ["openid", "profile", "User.Read", "User.Read.All"]
|
||||
url = client.authorization_url(url_for("auth_microsoft_bp.authorized", _external=True), scope, state=None)
|
||||
return redirect(url)
|
||||
|
||||
|
||||
@auth_microsoft_bp.route("/login")
|
||||
def login():
|
||||
"""Function to handle a user trying to log in"""
|
||||
return microsoft_login()
|
||||
|
||||
|
||||
@auth_microsoft_bp.route("callback") # "/authorized")
|
||||
def authorized() -> typing.Any:
|
||||
# type is 'typing.Union[str, Response]', but this errors due to
|
||||
# https://github.com/python/mypy/issues/7187
|
||||
"""Check authorized status"""
|
||||
|
||||
oauth_code = request.args['code']
|
||||
|
||||
resp = client.exchange_code(url_for("auth_microsoft_bp.authorized", _external=True), oauth_code)
|
||||
client.set_token(resp.data)
|
||||
|
||||
resp = client.users.get_me()
|
||||
microsoft_uuid = resp.data['id']
|
||||
username = resp.data['userPrincipalName']
|
||||
|
||||
# Fail if fields are not populated
|
||||
if not microsoft_uuid or not username:
|
||||
flash("You're not allowed to enter, please contact a system administrator")
|
||||
return redirect(url_for("general_bp.home"))
|
||||
|
||||
# Find existing user by Microsoft UUID (userPrincipalName can change)
|
||||
user = User.query.filter_by(microsoft_uuid=microsoft_uuid).first()
|
||||
if user:
|
||||
return login_and_redirect_user(user)
|
||||
|
||||
# Find existing user by username (pre-existing account)
|
||||
user = User.query.filter_by(username=username).first()
|
||||
if user:
|
||||
return login_and_redirect_user(user)
|
||||
|
||||
# No user found, create a new one
|
||||
user = create_user(username, microsoft_uuid=microsoft_uuid)
|
||||
return login_and_redirect_user(user)
|
||||
|
||||
|
||||
def login_and_redirect_user(user) -> Response:
|
||||
"""Log in the user and then redirect them"""
|
||||
login_user(user)
|
||||
return redirect(url_for("general_bp.home"))
|
||||
|
||||
|
||||
def create_user(username, *, microsoft_uuid) -> User:
|
||||
"""Create a temporary user if it is needed"""
|
||||
user = User()
|
||||
user.configure(username, False, 1, microsoft_uuid=microsoft_uuid)
|
||||
db.session.add(user)
|
||||
db.session.commit()
|
||||
return user
|
|
@ -1,26 +1,15 @@
|
|||
"""An example for a Haldis config"""
|
||||
# import os
|
||||
"An example for a Haldis config"
|
||||
# config
|
||||
|
||||
|
||||
class Configuration:
|
||||
"Haldis configuration object"
|
||||
# pylint: disable=too-few-public-methods
|
||||
SQLALCHEMY_DATABASE_URI = "sqlite:///haldis.db"
|
||||
# MARIADB_HOST = os.environ.get("MARIADB_HOST")
|
||||
# MARIADB_DB = os.environ.get("MARIADB_DATABASE")
|
||||
# MARIADB_USER = os.environ.get("MARIADB_USER")
|
||||
# MARIADB_PASS = os.environ.get("MARIADB_PASSWORD")
|
||||
# SQLALCHEMY_DATABASE_URI = f"mysql+pymysql://{MARIADB_USER}:{MARIADB_PASS}@{MARIADB_HOST}/{MARIADB_DB}"
|
||||
SQLALCHEMY_TRACK_MODIFICATIONS = False
|
||||
DEBUG = True
|
||||
HALDIS_ADMINS = []
|
||||
SECRET_KEY = "<change>"
|
||||
SLACK_WEBHOOK = None
|
||||
LOGFILE = "haldis.log"
|
||||
SENTRY_DSN = None
|
||||
ZEUS_KEY = "tomtest"
|
||||
ZEUS_SECRET = "blargh"
|
||||
|
||||
ENABLE_MICROSOFT_AUTH = False
|
||||
MICROSOFT_AUTH_ID = ""
|
||||
MICROSOFT_AUTH_SECRET = ""
|
||||
|
|
24
app/database/add_admins.py
Normal file
24
app/database/add_admins.py
Normal file
|
@ -0,0 +1,24 @@
|
|||
"Script for adding users as admin to Haldis."
|
||||
from app import db
|
||||
from models import User
|
||||
|
||||
|
||||
def add() -> None:
|
||||
"Add users as admin."
|
||||
feli = User()
|
||||
feli.configure("feliciaan", True, 0)
|
||||
db.session.add(feli)
|
||||
|
||||
destro = User()
|
||||
destro.configure("destro", True, 0)
|
||||
db.session.add(destro)
|
||||
|
||||
iepoev = User()
|
||||
iepoev.configure("iepoev", True, 1)
|
||||
db.session.add(iepoev)
|
||||
|
||||
flynn = User()
|
||||
flynn.configure("flynn", True, 0)
|
||||
db.session.add(flynn)
|
||||
|
||||
# To future developers, add yourself here
|
|
@ -1,10 +1,6 @@
|
|||
"""Script for interaction and changes to the database"""
|
||||
|
||||
"Script for interaction and changes to the database"
|
||||
import add_admins
|
||||
|
||||
from app import create_app, db
|
||||
|
||||
app, app_manager = create_app()
|
||||
from app import db, app_manager
|
||||
|
||||
entry_sets = {
|
||||
"admins": add_admins.add,
|
||||
|
@ -15,13 +11,13 @@ no = ["no", "n"]
|
|||
|
||||
|
||||
def commit() -> None:
|
||||
"""Commit all the things to the database"""
|
||||
"Commit all the things to the database"
|
||||
db.session.commit()
|
||||
print("Committing successful")
|
||||
|
||||
|
||||
def check_if_overwrite() -> bool:
|
||||
"""Check if the user wants to overwrite the previous database"""
|
||||
"Check if the user wants to overwrite the previous database"
|
||||
answer = input("Do you want to overwrite the previous database? (y/N) ")
|
||||
return answer.lower() in yes
|
||||
|
||||
|
@ -29,12 +25,12 @@ def check_if_overwrite() -> bool:
|
|||
def add_all() -> None:
|
||||
"Add all possible entries in the entry_sets to the database"
|
||||
for entry_set, function in entry_sets.items():
|
||||
print(f"Adding {entry_set}.")
|
||||
print("Adding {}.".format(entry_set))
|
||||
function()
|
||||
|
||||
|
||||
def recreate_from_scratch() -> None:
|
||||
"""Recreate a completely new database"""
|
||||
"Recreate a completely new database"
|
||||
print("Resetting the database!")
|
||||
db.drop_all()
|
||||
db.create_all()
|
||||
|
@ -42,19 +38,19 @@ def recreate_from_scratch() -> None:
|
|||
|
||||
|
||||
def add_to_current() -> None:
|
||||
"""Add things to the current database"""
|
||||
available = list(entry_sets)
|
||||
"Add things to the current database"
|
||||
available = [entry_set for entry_set in entry_sets]
|
||||
|
||||
def add_numbers() -> str:
|
||||
return " ".join(
|
||||
[f"{loc}({i}), " for i, loc in enumerate(available)]
|
||||
["{}({}), ".format(loc, i) for i, loc in enumerate(available)]
|
||||
).rstrip(", ")
|
||||
|
||||
while input("Do you still want to add something? (Y/n) ").lower() not in no:
|
||||
print(
|
||||
"What do you want to add? (Use numbers, or A for all, or C for cancel) "
|
||||
)
|
||||
answer = input(f"Available: {add_numbers()} : ")
|
||||
answer = input("Available: {} : ".format(add_numbers()))
|
||||
if answer.lower() == "a":
|
||||
add_all()
|
||||
available = []
|
||||
|
@ -62,7 +58,7 @@ def add_to_current() -> None:
|
|||
pass
|
||||
elif answer.isnumeric() and answer in [str(x) for x in range(len(available))]:
|
||||
answer_index = int(answer)
|
||||
print(f"Adding {available[answer_index]}.")
|
||||
print("Adding {}.".format(available[answer_index]))
|
||||
entry_sets[str(available[answer_index])]()
|
||||
del available[answer_index]
|
||||
else:
|
||||
|
@ -72,7 +68,7 @@ def add_to_current() -> None:
|
|||
|
||||
@app_manager.command
|
||||
def setup_database(): # type: None
|
||||
"""Start the database interaction script"""
|
||||
"Start the database interaction script"
|
||||
print("Database modification script!")
|
||||
print("=============================\n\n")
|
||||
if (not db.engine.table_names()) or check_if_overwrite():
|
|
@ -9,7 +9,6 @@ user
|
|||
|
||||
order
|
||||
id
|
||||
slug secret used in URL
|
||||
courier_id
|
||||
location_id HLDS identifier
|
||||
location_name this allows historical orders to keep the same location name
|
||||
|
|
|
@ -1,31 +1,23 @@
|
|||
"Module used for everything related to the fat versions of models"
|
||||
import typing
|
||||
|
||||
from hlds.definitions import location_definitions
|
||||
from hlds.models import Dish, Location
|
||||
from models import Order, OrderItem, User
|
||||
from sqlalchemy.sql import desc, func
|
||||
|
||||
from hlds.definitions import location_definitions
|
||||
from hlds.models import Location, Dish
|
||||
from models import Order, OrderItem, User
|
||||
|
||||
|
||||
class FatModel:
|
||||
"General class for the fat version of models"
|
||||
|
||||
@classmethod
|
||||
def all(cls):
|
||||
"Function to query all"
|
||||
# pylint: disable=E1101
|
||||
return cls.query.all()
|
||||
|
||||
@classmethod
|
||||
def amount(cls):
|
||||
"Function to query the amount"
|
||||
# pylint: disable=E1101
|
||||
return cls.query.count()
|
||||
|
||||
|
||||
class FatLocation(Location, FatModel):
|
||||
"Fat version of the Location model"
|
||||
|
||||
@classmethod
|
||||
def all(cls):
|
||||
return location_definitions
|
||||
|
@ -36,7 +28,6 @@ class FatLocation(Location, FatModel):
|
|||
|
||||
|
||||
class FatOrder(Order, FatModel):
|
||||
"Fat version of the Order model"
|
||||
|
||||
# It's hard to add the unique user constraint,
|
||||
# as DISTINCT seems to apply after a GROUP BY and aggregate
|
||||
|
@ -44,15 +35,16 @@ class FatOrder(Order, FatModel):
|
|||
# even if they get reduced by the disctinct afterwards.
|
||||
@classmethod
|
||||
def items_per_order(cls):
|
||||
"Function to get the total of all items per order"
|
||||
return (Order.query.join(OrderItem).group_by(Order.id).with_entities(
|
||||
Order.id,
|
||||
func.count(OrderItem.user_id).label("total")))
|
||||
return (
|
||||
Order.query.join(OrderItem)
|
||||
.group_by(Order.id)
|
||||
.with_entities(Order.id, func.count(OrderItem.user_id).label("total"))
|
||||
)
|
||||
|
||||
|
||||
class FatUser(User, FatModel):
|
||||
"Fat version of the User model"
|
||||
pass
|
||||
|
||||
|
||||
class FatOrderItem(OrderItem, FatModel):
|
||||
"Fat version of the OrderItem model"
|
||||
pass
|
||||
|
|
37
app/forms.py
37
app/forms.py
|
@ -1,16 +1,25 @@
|
|||
"Script for everything form related in Haldis"
|
||||
from datetime import datetime, timedelta
|
||||
|
||||
from typing import Optional
|
||||
|
||||
from flask import request, session
|
||||
from flask import session, request
|
||||
from flask_login import current_user
|
||||
from flask_wtf import FlaskForm as Form
|
||||
from hlds.definitions import location_definitions
|
||||
from hlds.models import Choice, Dish, Location
|
||||
from models import User
|
||||
from wtforms import (
|
||||
DateTimeField,
|
||||
SelectField,
|
||||
SelectMultipleField,
|
||||
StringField,
|
||||
SubmitField,
|
||||
FieldList,
|
||||
validators,
|
||||
)
|
||||
|
||||
from utils import euro_string, price_range_string
|
||||
from wtforms import (DateTimeField, FieldList, SelectField,
|
||||
SelectMultipleField, StringField, SubmitField, validators)
|
||||
from hlds.definitions import location_definitions
|
||||
from hlds.models import Location, Dish, Choice
|
||||
from models import User
|
||||
|
||||
|
||||
class OrderForm(Form):
|
||||
|
@ -20,21 +29,20 @@ class OrderForm(Form):
|
|||
location_id = SelectField(
|
||||
"Location", coerce=str, validators=[validators.required()]
|
||||
)
|
||||
organizing_id = SelectField(
|
||||
"Organizing", coerce=str, validators=[validators.required()]
|
||||
)
|
||||
starttime = DateTimeField(
|
||||
"Starttime", default=datetime.now, format="%d-%m-%Y %H:%M"
|
||||
)
|
||||
stoptime = DateTimeField("Stoptime", format="%d-%m-%Y %H:%M")
|
||||
association = SelectField("Association", coerce=str, validators=[validators.required()])
|
||||
submit_button = SubmitField("Submit")
|
||||
|
||||
def populate(self) -> None:
|
||||
"Fill in the options for courier for an Order"
|
||||
if current_user.is_admin():
|
||||
self.courier_id.choices = [
|
||||
(0, None),
|
||||
(current_user.id, current_user.username),
|
||||
] + [
|
||||
(u.id, u.username) for u in User.query.order_by("username") if u.id != current_user.id
|
||||
self.courier_id.choices = [(0, None)] + [
|
||||
(u.id, u.username) for u in User.query.order_by("username")
|
||||
]
|
||||
else:
|
||||
self.courier_id.choices = [
|
||||
|
@ -42,7 +50,7 @@ class OrderForm(Form):
|
|||
(current_user.id, current_user.username),
|
||||
]
|
||||
self.location_id.choices = [(l.id, l.name) for l in location_definitions]
|
||||
self.association.choices = current_user.association_list()
|
||||
self.organizing_id.choices = [("zeus", "Zeus WPI")]
|
||||
if self.stoptime.data is None:
|
||||
self.stoptime.data = datetime.now() + timedelta(hours=1)
|
||||
|
||||
|
@ -55,7 +63,6 @@ class OrderItemForm(Form):
|
|||
submit_button = SubmitField("Submit")
|
||||
|
||||
def populate(self, location: Location) -> None:
|
||||
"Populate the order item form"
|
||||
self.dish_id.choices = [(dish.id, dish.name) for dish in location.dishes]
|
||||
if not self.is_submitted() and self.comment.data is None:
|
||||
self.comment.data = request.args.get("comment")
|
||||
|
@ -82,7 +89,7 @@ class AnonOrderItemForm(OrderItemForm):
|
|||
self.user_name.data = session.get("anon_name", None)
|
||||
|
||||
def validate(self) -> bool:
|
||||
"""Check if the provided anon_name is not already taken"""
|
||||
"Check if the provided anon_name is not already taken"
|
||||
rv = OrderForm.validate(self)
|
||||
if not rv:
|
||||
return False
|
||||
|
|
|
@ -6,4 +6,4 @@ These are not imported in this module's init, to avoid opening the definition fi
|
|||
parser on them when testing other code in this module, or when testing the parser on other files.
|
||||
"""
|
||||
|
||||
from .models import Choice, Location, Option
|
||||
from .models import Location, Choice, Option
|
||||
|
|
|
@ -1,24 +1,21 @@
|
|||
# Import this class to load the standard HLDS definitions
|
||||
import subprocess
|
||||
from pathlib import Path
|
||||
from typing import List
|
||||
|
||||
from .models import Location
|
||||
from os import path
|
||||
from typing import List
|
||||
import subprocess
|
||||
from .parser import parse_all_directory
|
||||
from .models import Location
|
||||
|
||||
|
||||
__all__ = ["location_definitions", "location_definition_version"]
|
||||
|
||||
# pylint: disable=invalid-name
|
||||
|
||||
# TODO Use proper way to get resources, see https://stackoverflow.com/a/10935674
|
||||
ROOT_DIR = Path(__file__).parent.parent.parent
|
||||
DATA_DIR = ROOT_DIR / "menus"
|
||||
DATA_DIR = path.join(path.dirname(__file__), "..", "..", "menus")
|
||||
|
||||
location_definitions: List[Location] = parse_all_directory(str(DATA_DIR))
|
||||
location_definitions: List[Location] = parse_all_directory(DATA_DIR)
|
||||
location_definitions.sort(key=lambda l: l.name)
|
||||
|
||||
try:
|
||||
proc = subprocess.run(["git", "rev-parse", "HEAD"], stdout=subprocess.PIPE, cwd=str(ROOT_DIR), check=True)
|
||||
location_definition_version = proc.stdout.decode().strip()
|
||||
except FileNotFoundError:
|
||||
location_definition_version = ""
|
||||
proc = subprocess.run(["git", "rev-parse", "HEAD"], stdout=subprocess.PIPE, check=True)
|
||||
location_definition_version = proc.stdout.decode().strip()
|
||||
|
|
|
@ -29,9 +29,9 @@ location = >location_header items:{ block } ;
|
|||
|
||||
|
||||
attributes =
|
||||
name:/[^\n#]*?(?= +-- | | €| *\n| *#)/
|
||||
name:/[^\n#]*?(?= +-- | | *\n| *#)/
|
||||
[ s '--' ~ s description:/[^\n#]*?(?= | *\n| *#)/ ]
|
||||
[ / +/ ~
|
||||
[ / {2,}/ ~
|
||||
[ {[ s ] ('{' tags+:identifier '}')} / +|$/ ]
|
||||
[ price:price ]
|
||||
]
|
||||
|
|
|
@ -1,28 +1,26 @@
|
|||
#!/usr/bin/env python3
|
||||
# pylint: disable=too-few-public-methods
|
||||
|
||||
from typing import Any, Iterable, List, Mapping, Optional, Tuple
|
||||
|
||||
from typing import Iterable, List, Tuple, Mapping, Any, Optional
|
||||
from utils import euro_string, first
|
||||
|
||||
|
||||
def _format_tags(tags: Iterable[str]) -> str:
|
||||
# pylint: disable=consider-using-f-string
|
||||
return " :: {}".format(" ".join(["{" + tag + "}"
|
||||
for tag in tags])) if tags else ""
|
||||
return " :: {}".format(" ".join(["{" + tag + "}" for tag in tags])) \
|
||||
if tags \
|
||||
else ""
|
||||
|
||||
|
||||
def _format_price(price: int) -> str:
|
||||
return f" {euro_string(price)}" if price else ""
|
||||
return " {}".format(euro_string(price)) if price else ""
|
||||
|
||||
|
||||
def _format_type_and_choice(type_and_choice):
|
||||
type_, choice = type_and_choice
|
||||
return f"{type_} {choice}"
|
||||
return "{} {}".format(type_, choice)
|
||||
|
||||
|
||||
class Option:
|
||||
|
||||
def __init__(self, id_, *, name, description, price, tags):
|
||||
self.id: str = id_
|
||||
self.name: str = name
|
||||
|
@ -31,17 +29,15 @@ class Option:
|
|||
self.tags: List[str] = tags
|
||||
|
||||
def __str__(self):
|
||||
# pylint: disable=consider-using-f-string
|
||||
return "{0.id}: {0.name}{1}{2}{3}".format(
|
||||
self,
|
||||
f" -- {self.description}" if self.description else "",
|
||||
" -- {}".format(self.description) if self.description else "",
|
||||
_format_tags(self.tags),
|
||||
_format_price(self.price),
|
||||
)
|
||||
|
||||
|
||||
class Choice:
|
||||
|
||||
def __init__(self, id_, *, name, description, options):
|
||||
self.id: str = id_
|
||||
self.name: str = name
|
||||
|
@ -52,7 +48,7 @@ class Choice:
|
|||
def __str__(self):
|
||||
return "{0.id}: {0.name}{1}\n\t\t{2}".format(
|
||||
self,
|
||||
f" -- {self.description}" if self.description else "",
|
||||
" -- {}".format(self.description) if self.description else "",
|
||||
"\n\t\t".join(map(str, self.options)),
|
||||
)
|
||||
|
||||
|
@ -61,7 +57,6 @@ class Choice:
|
|||
|
||||
|
||||
class Dish:
|
||||
|
||||
def __init__(self, id_, *, name, description, price, tags, choices):
|
||||
self.id: str = id_
|
||||
self.name: str = name
|
||||
|
@ -75,7 +70,7 @@ class Dish:
|
|||
def __str__(self):
|
||||
return "dish {0.id}: {0.name}{1}{2}{3}\n\t{4}".format(
|
||||
self,
|
||||
f" -- {self.description}" if self.description else "",
|
||||
" -- {}".format(self.description) if self.description else "",
|
||||
_format_tags(self.tags),
|
||||
_format_price(self.price),
|
||||
"\n\t".join(map(_format_type_and_choice, self.choices)),
|
||||
|
@ -91,20 +86,14 @@ class Dish:
|
|||
return sum(
|
||||
f(option.price for option in choice.options)
|
||||
for (choice_type, choice) in self.choices
|
||||
if choice_type == "single_choice")
|
||||
if choice_type == "single_choice"
|
||||
)
|
||||
|
||||
|
||||
class Location:
|
||||
|
||||
def __init__(self,
|
||||
id_,
|
||||
*,
|
||||
name,
|
||||
dishes,
|
||||
osm=None,
|
||||
address=None,
|
||||
telephone=None,
|
||||
website=None):
|
||||
def __init__(
|
||||
self, id_, *, name, dishes, osm=None, address=None, telephone=None, website=None
|
||||
):
|
||||
self.id: str = id_
|
||||
self.name: str = name
|
||||
self.osm: Optional[str] = osm
|
||||
|
@ -118,18 +107,24 @@ class Location:
|
|||
return first(filter(lambda d: d.id == dish_id, self.dishes))
|
||||
|
||||
def __str__(self):
|
||||
return ("============================\n"
|
||||
"{0.id}: {0.name}"
|
||||
"{1}\n"
|
||||
"============================\n"
|
||||
"\n"
|
||||
"{2}").format(
|
||||
self,
|
||||
"".join(f"\n\t{k} {v}" for k, v in (
|
||||
("osm", self.osm),
|
||||
("address", self.address),
|
||||
("telephone", self.telephone),
|
||||
("website", self.website),
|
||||
) if v is not None),
|
||||
"\n".join(map(str, self.dishes)),
|
||||
return (
|
||||
"============================\n"
|
||||
"{0.id}: {0.name}"
|
||||
"{1}\n"
|
||||
"============================\n"
|
||||
"\n"
|
||||
"{2}"
|
||||
).format(
|
||||
self,
|
||||
"".join(
|
||||
"\n\t{} {}".format(k, v)
|
||||
for k, v in (
|
||||
("osm", self.osm),
|
||||
("address", self.address),
|
||||
("telephone", self.telephone),
|
||||
("website", self.website),
|
||||
)
|
||||
if v is not None
|
||||
),
|
||||
"\n".join(map(str, self.dishes)),
|
||||
)
|
||||
|
|
|
@ -1,17 +1,16 @@
|
|||
#!/usr/bin/env python3
|
||||
|
||||
import itertools
|
||||
from copy import deepcopy
|
||||
from glob import glob
|
||||
from os import path
|
||||
from typing import Iterable, List, Tuple, Union
|
||||
|
||||
import itertools
|
||||
from copy import deepcopy
|
||||
from typing import Iterable, List, Union, Tuple
|
||||
from tatsu import parse as tatsu_parse
|
||||
from tatsu.ast import AST
|
||||
from tatsu.exceptions import SemanticError
|
||||
from .models import Location, Choice, Option, Dish
|
||||
from utils import first
|
||||
|
||||
from .models import Choice, Dish, Location, Option
|
||||
|
||||
# TODO Use proper way to get resources, see https://stackoverflow.com/a/10935674
|
||||
with open(path.join(path.dirname(__file__), "hlds.tatsu")) as fh:
|
||||
|
@ -59,16 +58,14 @@ class HldsSemanticActions:
|
|||
option.price += dish.price
|
||||
dish.price = 0
|
||||
dishes = list(dishes)
|
||||
dishes.append(
|
||||
Dish(
|
||||
"custom",
|
||||
name="Vrije keuze",
|
||||
description="Zet wat je wil in comment",
|
||||
price=0,
|
||||
tags=[],
|
||||
choices=[],
|
||||
)
|
||||
)
|
||||
dishes.append(Dish(
|
||||
"custom",
|
||||
name="Vrije keuze",
|
||||
description="Zet wat je wil in comment",
|
||||
price=0,
|
||||
tags=[],
|
||||
choices=[],
|
||||
))
|
||||
|
||||
attributes = {att["key"]: att["value"] for att in ast["attributes"]}
|
||||
|
||||
|
@ -148,7 +145,7 @@ def parse(menu: str) -> List[Location]:
|
|||
|
||||
|
||||
def parse_file(filename: str) -> List[Location]:
|
||||
with open(filename) as file_handle:
|
||||
with open(filename, "r") as file_handle:
|
||||
return parse(file_handle.read())
|
||||
|
||||
|
||||
|
|
|
@ -1,25 +1,32 @@
|
|||
"""Script for everything related to logging in and out"""
|
||||
"Script for everything related to logging in and out"
|
||||
from flask import Blueprint, abort, redirect, session, url_for
|
||||
from flask_login import current_user, logout_user
|
||||
from models import User
|
||||
from werkzeug.wrappers import Response
|
||||
|
||||
from models import User
|
||||
from zeus import zeus_login
|
||||
|
||||
auth_bp = Blueprint("auth_bp", __name__)
|
||||
|
||||
|
||||
def init_login(app) -> None:
|
||||
"""Initialize the login"""
|
||||
|
||||
"Initialize the login"
|
||||
# pylint: disable=W0612
|
||||
@app.login_manager.user_loader
|
||||
def load_user(userid) -> User:
|
||||
"""Load the user"""
|
||||
"Load the user"
|
||||
return User.query.filter_by(id=userid).first()
|
||||
|
||||
|
||||
@auth_bp.route("/login")
|
||||
def login():
|
||||
"Function to handle a user trying to log in"
|
||||
return zeus_login()
|
||||
|
||||
|
||||
@auth_bp.route("/logout")
|
||||
def logout() -> Response:
|
||||
"""Function to handle a user trying to log out"""
|
||||
"Function to handle a user trying to log out"
|
||||
if "zeus_token" in session:
|
||||
session.pop("zeus_token", None)
|
||||
logout_user()
|
||||
|
@ -27,6 +34,6 @@ def logout() -> Response:
|
|||
|
||||
|
||||
def before_request() -> None:
|
||||
"""Function for what has to be done before a request"""
|
||||
"Function for what has to be done before a request"
|
||||
if current_user.is_anonymous() or not current_user.is_allowed():
|
||||
abort(401)
|
|
@ -1,8 +1,10 @@
|
|||
"Script that runs migrations online or offline"
|
||||
from __future__ import with_statement
|
||||
|
||||
from logging.config import fileConfig
|
||||
|
||||
from alembic import context
|
||||
|
||||
# add your model's MetaData object here
|
||||
# for 'autogenerate' support
|
||||
# from myapp import mymodel
|
||||
|
|
|
@ -43,7 +43,7 @@ def upgrade():
|
|||
sa.Column("starttime", sa.DateTime(), nullable=True),
|
||||
sa.Column("stoptime", sa.DateTime(), nullable=True),
|
||||
sa.Column("public", sa.Boolean(), nullable=True),
|
||||
sa.ForeignKeyConstraint(["location_id"], ["location.id"], name="order_ibfk_1"),
|
||||
sa.ForeignKeyConstraint(["location_id"], ["location.id"]),
|
||||
sa.PrimaryKeyConstraint("id"),
|
||||
)
|
||||
op.create_table(
|
||||
|
@ -65,7 +65,7 @@ def upgrade():
|
|||
sa.Column("extra", sa.String(length=254), nullable=True),
|
||||
sa.Column("name", sa.String(length=120), nullable=True),
|
||||
sa.ForeignKeyConstraint(["order_id"], ["order.id"]),
|
||||
sa.ForeignKeyConstraint(["product_id"], ["product.id"], name="order_item_ibfk_3"),
|
||||
sa.ForeignKeyConstraint(["product_id"], ["product.id"]),
|
||||
sa.ForeignKeyConstraint(["user_id"], ["user.id"]),
|
||||
sa.PrimaryKeyConstraint("id"),
|
||||
)
|
||||
|
|
|
@ -1,30 +0,0 @@
|
|||
"""add slug
|
||||
|
||||
Revision ID: 29ccbe077c57
|
||||
Revises: 55013fe95bea
|
||||
Create Date: 2022-05-20 19:46:11.924218
|
||||
|
||||
"""
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision = '29ccbe077c57'
|
||||
down_revision = '55013fe95bea'
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
from sqlalchemy.sql import text
|
||||
|
||||
def upgrade():
|
||||
op.add_column('order', sa.Column(
|
||||
'slug',
|
||||
sa.String(length=8),
|
||||
nullable=False,
|
||||
# Default: random alphanumerical string
|
||||
server_default=text('SUBSTRING(MD5(RAND()) FROM 1 FOR 7)')
|
||||
))
|
||||
op.create_unique_constraint('order_slug_unique', 'order', ['slug'])
|
||||
|
||||
|
||||
def downgrade():
|
||||
op.drop_constraint('order_slug_unique', 'order', type_='unique')
|
||||
op.drop_column('order', 'slug')
|
|
@ -1,21 +0,0 @@
|
|||
"""Create price_modified column
|
||||
|
||||
Revision ID: 55013fe95bea
|
||||
Revises: 9159a6fed021
|
||||
Create Date: 2022-04-22 01:00:03.729596
|
||||
|
||||
"""
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision = '55013fe95bea'
|
||||
down_revision = '9159a6fed021'
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
def upgrade():
|
||||
op.add_column('order_item', sa.Column('price_modified', sa.DateTime(), nullable=True))
|
||||
|
||||
|
||||
def downgrade():
|
||||
op.drop_column('order_item', 'price_modified')
|
|
@ -1,26 +0,0 @@
|
|||
"""empty message
|
||||
|
||||
Revision ID: 89b2c980b663
|
||||
Revises: 9eac0f3d7b1e
|
||||
Create Date: 2023-04-20 02:01:54.558602
|
||||
|
||||
"""
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision = '89b2c980b663'
|
||||
down_revision = '9eac0f3d7b1e'
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
def upgrade():
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('user', sa.Column('microsoft_uuid', sa.VARCHAR(length=120), nullable=True))
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade():
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user', 'microsoft_uuid')
|
||||
# ### end Alembic commands ###
|
|
@ -12,11 +12,11 @@ revision = "9159a6fed021"
|
|||
down_revision = "150252c1cdb1"
|
||||
|
||||
from itertools import chain
|
||||
|
||||
import sqlalchemy as sa
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
from sqlalchemy.sql import table, column, text
|
||||
|
||||
from hlds.definitions import location_definitions
|
||||
from sqlalchemy.sql import column, table, text
|
||||
|
||||
LOCATION_LEGACY_TO_HLDS = {
|
||||
2: "blauw_kotje",
|
||||
|
@ -50,104 +50,71 @@ LOCATION_LEGACY_TO_HLDS = {
|
|||
|
||||
def upgrade():
|
||||
# First the simple actions
|
||||
op.create_table(
|
||||
"order_item_choice",
|
||||
op.create_table("order_item_choice",
|
||||
sa.Column("id", sa.Integer, nullable=False),
|
||||
sa.Column("choice_id", sa.String(length=64), nullable=True),
|
||||
sa.Column("order_item_id", sa.Integer, nullable=False),
|
||||
sa.Column("kind", sa.String(length=1), nullable=False),
|
||||
sa.Column("name", sa.String(length=120), nullable=True),
|
||||
sa.Column("value", sa.String(length=120), nullable=True),
|
||||
sa.ForeignKeyConstraint(
|
||||
["order_item_id"],
|
||||
["order_item.id"],
|
||||
),
|
||||
sa.PrimaryKeyConstraint("id"),
|
||||
)
|
||||
op.add_column(
|
||||
"order_item",
|
||||
sa.Column("hlds_data_version", sa.String(length=40), nullable=True),
|
||||
)
|
||||
op.alter_column(
|
||||
"order", "courrier_id", new_column_name="courier_id", type_=sa.Integer
|
||||
)
|
||||
op.alter_column(
|
||||
"order_item",
|
||||
"extra",
|
||||
new_column_name="comment",
|
||||
existing_type=sa.String(254),
|
||||
type_=sa.Text,
|
||||
)
|
||||
op.alter_column(
|
||||
"order_item", "name", new_column_name="user_name", type_=sa.String(120)
|
||||
sa.ForeignKeyConstraint(["order_item_id"], ["order_item.id"], ),
|
||||
sa.PrimaryKeyConstraint("id")
|
||||
)
|
||||
op.add_column("order_item", sa.Column("hlds_data_version", sa.String(length=40), nullable=True))
|
||||
op.alter_column("order", "courrier_id", new_column_name="courier_id", type_=sa.Integer)
|
||||
op.alter_column("order_item", "extra", new_column_name="comment",
|
||||
existing_type=sa.String(254), type_=sa.Text)
|
||||
op.alter_column("order_item", "name", new_column_name="user_name", type_=sa.String(120))
|
||||
|
||||
# ----------------------------------------------------------------------------------------------
|
||||
#----------------------------------------------------------------------------------------------
|
||||
# Migrate historical product data to order items
|
||||
|
||||
# First create the new columns we will populate
|
||||
op.add_column(
|
||||
"order_item", sa.Column("dish_id", sa.String(length=64), nullable=True)
|
||||
)
|
||||
op.add_column(
|
||||
"order_item", sa.Column("dish_name", sa.String(length=120), nullable=True)
|
||||
)
|
||||
op.add_column("order_item", sa.Column("dish_id", sa.String(length=64), nullable=True))
|
||||
op.add_column("order_item", sa.Column("dish_name", sa.String(length=120), nullable=True))
|
||||
op.add_column("order_item", sa.Column("price", sa.Integer(), nullable=True))
|
||||
# Brief, ad-hoc table constructs just for our UPDATE statement, see
|
||||
# https://alembic.sqlalchemy.org/en/latest/ops.html#alembic.operations.Operations.execute
|
||||
order_item = table(
|
||||
"order_item",
|
||||
order_item = table("order_item",
|
||||
column("product_id", sa.Integer),
|
||||
column("dish_id", sa.String),
|
||||
column("dish_name", sa.String),
|
||||
column("price", sa.Integer),
|
||||
column("price", sa.Integer)
|
||||
)
|
||||
# Construct and execute queries
|
||||
op.execute(
|
||||
text(
|
||||
"""
|
||||
op.execute(text("""
|
||||
UPDATE order_item
|
||||
SET dish_name = (SELECT product.name FROM product WHERE product.id = order_item.product_id),
|
||||
price = (SELECT product.price FROM product WHERE product.id = order_item.product_id)"""
|
||||
)
|
||||
)
|
||||
))
|
||||
# Historical product data migrated, drop obsolete column and table
|
||||
op.drop_constraint("order_item_ibfk_3", "order_item", type_="foreignkey")
|
||||
op.execute(text("ALTER TABLE order_item DROP FOREIGN KEY order_item_ibfk_3"))
|
||||
op.drop_column("order_item", "product_id")
|
||||
op.drop_table("product")
|
||||
|
||||
# ----------------------------------------------------------------------------------------------
|
||||
#----------------------------------------------------------------------------------------------
|
||||
# Migrate historical location data to orders
|
||||
op.alter_column(
|
||||
"order",
|
||||
"location_id",
|
||||
new_column_name="legacy_location_id",
|
||||
type_=sa.Integer,
|
||||
nullable=True,
|
||||
)
|
||||
op.add_column(
|
||||
"order", sa.Column("location_id", sa.String(length=64), nullable=True)
|
||||
)
|
||||
op.add_column(
|
||||
"order", sa.Column("location_name", sa.String(length=128), nullable=True)
|
||||
)
|
||||
|
||||
op.execute(text("ALTER TABLE `order` DROP FOREIGN KEY order_ibfk_2"))
|
||||
op.alter_column("order", "location_id", new_column_name="legacy_location_id",
|
||||
type_=sa.Integer, nullable=True)
|
||||
op.add_column("order", sa.Column("location_id", sa.String(length=64), nullable=True))
|
||||
op.add_column("order", sa.Column("location_name", sa.String(length=128), nullable=True))
|
||||
# Brief, ad-hoc table constructs just for our UPDATE statement, see
|
||||
# https://alembic.sqlalchemy.org/en/latest/ops.html#alembic.operations.Operations.execute
|
||||
order = table(
|
||||
"order",
|
||||
order = table("order",
|
||||
column("legacy_location_id", sa.Integer),
|
||||
column("location_id", sa.String),
|
||||
column("location_name", sa.String),
|
||||
column("location_name", sa.String)
|
||||
)
|
||||
# Construct and execute queries
|
||||
new_location_id = [
|
||||
order.update()
|
||||
.where(order.c.legacy_location_id == old_id)
|
||||
.values(location_id=new_id)
|
||||
.where(order.c.legacy_location_id == old_id)
|
||||
.values(location_id=new_id)
|
||||
for old_id, new_id in LOCATION_LEGACY_TO_HLDS.items()
|
||||
]
|
||||
location_name_from_location = text(
|
||||
"""
|
||||
location_name_from_location = text("""
|
||||
UPDATE `order`
|
||||
SET location_name = (SELECT location.name FROM location
|
||||
WHERE location.id = `order`.legacy_location_id)"""
|
||||
|
@ -155,7 +122,6 @@ def upgrade():
|
|||
for query in chain(new_location_id, [location_name_from_location]):
|
||||
op.execute(query)
|
||||
# Historical location data migrated, drop obsolete column and table
|
||||
op.drop_constraint("order_ibfk_1", "order", type_="foreignkey")
|
||||
op.drop_column("order", "legacy_location_id")
|
||||
op.drop_table("location")
|
||||
|
||||
|
|
|
@ -1,22 +0,0 @@
|
|||
"""empty message
|
||||
|
||||
Revision ID: 9eac0f3d7b1e
|
||||
Revises: ('f6a6004bf4b9', '29ccbe077c57')
|
||||
Create Date: 2022-05-30 18:35:43.918797
|
||||
|
||||
"""
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision = '9eac0f3d7b1e'
|
||||
down_revision = ('f6a6004bf4b9', '29ccbe077c57')
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
def upgrade():
|
||||
pass
|
||||
|
||||
|
||||
def downgrade():
|
||||
pass
|
|
@ -1,28 +0,0 @@
|
|||
"""Add user associations
|
||||
|
||||
Revision ID: f6a6004bf4b9
|
||||
Revises: 55013fe95bea
|
||||
Create Date: 2022-05-24 21:23:27.770365
|
||||
|
||||
"""
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision = 'f6a6004bf4b9'
|
||||
down_revision = '55013fe95bea'
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
def upgrade():
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.add_column('order', sa.Column('association', sa.String(length=120), server_default='', nullable=False))
|
||||
op.add_column('user', sa.Column('associations', sa.String(length=255), server_default='', nullable=False))
|
||||
# ### end Alembic commands ###
|
||||
|
||||
|
||||
def downgrade():
|
||||
# ### commands auto generated by Alembic - please adjust! ###
|
||||
op.drop_column('user', 'associations')
|
||||
op.drop_column('order', 'association')
|
||||
# ### end Alembic commands ###
|
|
@ -1,14 +1,10 @@
|
|||
"AnonymouseUser for people who are not logged in the normal way"
|
||||
from typing import List
|
||||
# pylint: disable=R0201,C0111
|
||||
|
||||
|
||||
class AnonymouseUser:
|
||||
id = None
|
||||
|
||||
def association_list(self) -> List[str]:
|
||||
return []
|
||||
|
||||
def is_active(self) -> bool:
|
||||
return False
|
||||
|
||||
|
|
|
@ -1,26 +1,16 @@
|
|||
"""Script for everything Order related in the database"""
|
||||
"Script for everything Order related in the database"
|
||||
import typing
|
||||
from collections import defaultdict
|
||||
from datetime import datetime
|
||||
import secrets
|
||||
import string
|
||||
from collections import defaultdict
|
||||
|
||||
from hlds.definitions import location_definitions
|
||||
from utils import first
|
||||
|
||||
from hlds.definitions import location_definitions
|
||||
from .database import db
|
||||
from .user import User
|
||||
|
||||
BASE31_ALPHABET = '23456789abcdefghjkmnpqrstuvwxyz'
|
||||
|
||||
def generate_slug():
|
||||
secret = ''.join(secrets.choice(BASE31_ALPHABET) for i in range(8))
|
||||
while Order.query.filter(Order.slug == secret).first() is not None:
|
||||
secret = ''.join(secrets.choice(BASE31_ALPHABET) for i in range(8))
|
||||
return secret
|
||||
|
||||
class Order(db.Model):
|
||||
"""Class used for configuring the Order model in the database"""
|
||||
"Class used for configuring the Order model in the database"
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
courier_id = db.Column(db.Integer, nullable=True)
|
||||
location_id = db.Column(db.String(64))
|
||||
|
@ -28,8 +18,7 @@ class Order(db.Model):
|
|||
starttime = db.Column(db.DateTime)
|
||||
stoptime = db.Column(db.DateTime)
|
||||
public = db.Column(db.Boolean, default=True)
|
||||
slug = db.Column(db.String(8), default=generate_slug, unique=True)
|
||||
association = db.Column(db.String(120), nullable=False, server_default="")
|
||||
organizing_id = db.Column(db.String(64), default="")
|
||||
|
||||
items = db.relationship("OrderItem", backref="order", lazy="dynamic")
|
||||
|
||||
|
@ -43,9 +32,9 @@ class Order(db.Model):
|
|||
def __repr__(self) -> str:
|
||||
# pylint: disable=R1705
|
||||
if self.location:
|
||||
return f"Order {self.id} @ {self.location.name or 'None'}"
|
||||
return "Order %d @ %s for %s" % (self.id, self.location.name or "None", self.organizing_id or "None")
|
||||
else:
|
||||
return f"Order {self.id}"
|
||||
return "Order %d for %s" % (self.id, self.organizing_id or "None")
|
||||
|
||||
def update_from_hlds(self) -> None:
|
||||
"""
|
||||
|
@ -58,21 +47,19 @@ class Order(db.Model):
|
|||
self.location_name = self.location.name
|
||||
|
||||
def for_user(self, anon=None, user=None) -> typing.List:
|
||||
"""Get the items for a certain user"""
|
||||
return list(
|
||||
filter(
|
||||
(lambda i: i.user == user)
|
||||
if user is not None
|
||||
else (lambda i: i.user_name == anon),
|
||||
self.items,
|
||||
self.items
|
||||
)
|
||||
)
|
||||
|
||||
def group_by_user(self) -> typing.List[typing.Tuple[str, typing.List]]:
|
||||
"""Group items of an Order by user"""
|
||||
group: typing.Dict[str, typing.List] = {}
|
||||
"Group items of an Order by user"
|
||||
group: typing.Dict[str, typing.List] = dict()
|
||||
|
||||
# pylint: disable=E1133
|
||||
for item in self.items:
|
||||
if item.for_name not in group:
|
||||
group[item.for_name] = []
|
||||
|
@ -84,17 +71,12 @@ class Order(db.Model):
|
|||
|
||||
return list(sorted(group.items(), key=lambda t: (t[0] or "", t[1] or "")))
|
||||
|
||||
def group_by_dish(
|
||||
self,
|
||||
) -> typing.List[
|
||||
typing.Tuple[str, int, typing.List[typing.Tuple[str, typing.List]]]
|
||||
]:
|
||||
"""Group items of an Order by dish"""
|
||||
group: typing.Dict[str, typing.Dict[str, typing.List]] = defaultdict(
|
||||
lambda: defaultdict(list)
|
||||
)
|
||||
def group_by_dish(self) \
|
||||
-> typing.List[typing.Tuple[str, int, typing.List[typing.Tuple[str, typing.List]]]]:
|
||||
"Group items of an Order by dish"
|
||||
group: typing.Dict[str, typing.Dict[str, typing.List]] = \
|
||||
defaultdict(lambda: defaultdict(list))
|
||||
|
||||
# pylint: disable=E1133
|
||||
for item in self.items:
|
||||
group[item.dish_name][item.comment].append(item)
|
||||
|
||||
|
@ -106,17 +88,16 @@ class Order(db.Model):
|
|||
sorted(
|
||||
(comment, sorted(items, key=lambda x: (x.for_name or "")))
|
||||
for comment, items in comment_group.items()
|
||||
),
|
||||
)
|
||||
)
|
||||
for dish_name, comment_group in group.items()
|
||||
)
|
||||
|
||||
def is_closed(self) -> bool:
|
||||
"""Return whether the order is closed"""
|
||||
return self.stoptime and datetime.now() > self.stoptime
|
||||
|
||||
def can_close(self, user_id: int) -> bool:
|
||||
"""Check if a user can close the Order"""
|
||||
"Check if a user can close the Order"
|
||||
if self.stoptime and self.stoptime < datetime.now():
|
||||
return False
|
||||
user = None
|
||||
|
@ -125,13 +106,3 @@ class Order(db.Model):
|
|||
if self.courier_id == user_id or (user and user.is_admin()):
|
||||
return True
|
||||
return False
|
||||
|
||||
def can_modify_prices(self, user_id: int) -> bool:
|
||||
if not self.is_closed():
|
||||
return False
|
||||
user = User.query.filter_by(id=user_id).first()
|
||||
return user and (user.is_admin() or user == self.courier)
|
||||
|
||||
def can_modify_payment(self, user_id: int) -> bool:
|
||||
user = User.query.filter_by(id=user_id).first()
|
||||
return user and (user.is_admin() or user == self.courier)
|
||||
|
|
|
@ -1,16 +1,15 @@
|
|||
"Script for everything OrderItem related in the database"
|
||||
from datetime import datetime
|
||||
|
||||
from hlds.definitions import location_definitions
|
||||
from utils import first
|
||||
|
||||
from hlds.definitions import location_definitions
|
||||
from .database import db
|
||||
from .order import Order
|
||||
from .user import User
|
||||
|
||||
|
||||
class OrderItem(db.Model):
|
||||
"""Class used for configuring the OrderItem model in the database"""
|
||||
"Class used for configuring the OrderItem model in the database"
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
order_id = db.Column(db.Integer, db.ForeignKey("order.id"), nullable=False)
|
||||
user_id = db.Column(db.Integer, db.ForeignKey("user.id"))
|
||||
|
@ -18,25 +17,24 @@ class OrderItem(db.Model):
|
|||
dish_id = db.Column(db.String(64), nullable=True)
|
||||
dish_name = db.Column(db.String(120), nullable=True)
|
||||
price = db.Column(db.Integer, nullable=True)
|
||||
price_modified = db.Column(db.DateTime, nullable=True)
|
||||
paid = db.Column(db.Boolean, default=False, nullable=True)
|
||||
comment = db.Column(db.Text(), nullable=True)
|
||||
hlds_data_version = db.Column(db.String(40), nullable=True)
|
||||
|
||||
choices = db.relationship("OrderItemChoice",
|
||||
backref="order_item",
|
||||
lazy="dynamic")
|
||||
choices = db.relationship("OrderItemChoice", backref="order_item", lazy="dynamic")
|
||||
|
||||
def __getattr__(self, name):
|
||||
if name == "dish":
|
||||
location_id = (Order.query.filter(
|
||||
Order.id == self.order_id).first().location_id)
|
||||
location_id = (
|
||||
Order.query.filter(Order.id == self.order_id).first().location_id
|
||||
)
|
||||
location = first(
|
||||
filter(lambda l: l.id == location_id, location_definitions))
|
||||
filter(lambda l: l.id == location_id, location_definitions)
|
||||
)
|
||||
if location:
|
||||
return first(
|
||||
filter(lambda d: d.id == self.dish_id, location.dishes))
|
||||
raise ValueError(f"No Location found with id: {location_id}")
|
||||
return first(filter(lambda d: d.id == self.dish_id, location.dishes))
|
||||
else:
|
||||
raise ValueError("No Location found with id: " + location_id)
|
||||
raise AttributeError()
|
||||
|
||||
@property
|
||||
|
@ -47,7 +45,11 @@ class OrderItem(db.Model):
|
|||
return self.user_name
|
||||
|
||||
def __repr__(self) -> str:
|
||||
return "Order {self.order_id or 0}: {self.for_name} wants {self.dish_name or 'None'}"
|
||||
return "Order %d: %s wants %s" % (
|
||||
self.order_id or 0,
|
||||
self.for_name,
|
||||
self.dish_name or "None",
|
||||
)
|
||||
|
||||
def update_from_hlds(self) -> None:
|
||||
"""
|
||||
|
@ -61,7 +63,7 @@ class OrderItem(db.Model):
|
|||
|
||||
# pylint: disable=W0613
|
||||
def can_delete(self, order_id: int, user_id: int, name: str) -> bool:
|
||||
"""Check if a user can delete an item"""
|
||||
"Check if a user can delete an item"
|
||||
if int(self.order_id) != int(order_id):
|
||||
return False
|
||||
if self.order.is_closed():
|
||||
|
@ -74,12 +76,3 @@ class OrderItem(db.Model):
|
|||
if user and (user.is_admin() or user == self.order.courier):
|
||||
return True
|
||||
return False
|
||||
|
||||
# pylint: disable=W0613
|
||||
def can_modify_payment(self, order_id: int, user_id: int) -> bool:
|
||||
if int(self.order_id) != int(order_id):
|
||||
return False
|
||||
user = User.query.filter(User.id == user_id).first()
|
||||
if user and (user.is_admin() or user == self.order.courier):
|
||||
return True
|
||||
return False
|
||||
|
|
|
@ -1,4 +1,3 @@
|
|||
"Script for everything OrderItemChoice related in the database"
|
||||
from datetime import datetime
|
||||
|
||||
from .database import db
|
||||
|
@ -6,7 +5,6 @@ from .orderitem import OrderItem
|
|||
|
||||
|
||||
class OrderItemChoice(db.Model):
|
||||
"Class used for configuring the OrderItemChoice model in the database"
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
choice_id = db.Column(db.String(64), nullable=True)
|
||||
order_item_id = db.Column(
|
||||
|
@ -18,8 +16,7 @@ class OrderItemChoice(db.Model):
|
|||
|
||||
# pylint: disable=attribute-defined-outside-init
|
||||
def configure(self, order: OrderItem) -> None:
|
||||
"Set the orderitem"
|
||||
self.order = order
|
||||
|
||||
def __repr__(self) -> str:
|
||||
return f"{self.name}: {self.value}"
|
||||
return "{}: {}".format(self.name, self.value)
|
||||
|
|
|
@ -1,21 +1,13 @@
|
|||
"Script for everything User related in the database"
|
||||
from typing import List, Optional
|
||||
|
||||
from models import db
|
||||
|
||||
|
||||
class User(db.Model):
|
||||
"""Class used for configuring the User model in the database"""
|
||||
"Class used for configuring the User model in the database"
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
username = db.Column(db.String(80), unique=True, nullable=False)
|
||||
admin = db.Column(db.Boolean)
|
||||
bias = db.Column(db.Integer)
|
||||
# Microsoft OAUTH info
|
||||
microsoft_uuid = db.Column(db.String(120), unique=True)
|
||||
# Association logic
|
||||
associations = db.Column(db.String(255), nullable=False, server_default="")
|
||||
|
||||
# Relations
|
||||
runs = db.relation(
|
||||
"Order",
|
||||
backref="courier",
|
||||
|
@ -24,18 +16,11 @@ class User(db.Model):
|
|||
)
|
||||
orderItems = db.relationship("OrderItem", backref="user", lazy="dynamic")
|
||||
|
||||
def association_list(self) -> List[str]:
|
||||
return self.associations.split(",")
|
||||
|
||||
def configure(self, username: str, admin: bool, bias: int, *, microsoft_uuid: str = None, associations: Optional[List[str]] = None) -> None:
|
||||
"""Configure the User"""
|
||||
if associations is None:
|
||||
associations = []
|
||||
def configure(self, username: str, admin: bool, bias: int) -> None:
|
||||
"Configure the User"
|
||||
self.username = username
|
||||
self.admin = admin
|
||||
self.bias = bias
|
||||
self.microsoft_uuid = microsoft_uuid
|
||||
self.associations = ",".join(associations)
|
||||
|
||||
# pylint: disable=C0111, R0201
|
||||
def is_authenticated(self) -> bool:
|
||||
|
@ -54,4 +39,4 @@ class User(db.Model):
|
|||
return str(self.id)
|
||||
|
||||
def __repr__(self) -> str:
|
||||
return f"{self.username}"
|
||||
return "%s" % self.username
|
||||
|
|
|
@ -11,29 +11,28 @@ from models.order import Order
|
|||
|
||||
|
||||
def webhook_text(order: Order) -> typing.Optional[str]:
|
||||
"""Function that makes the text for the notification"""
|
||||
"Function that makes the text for the notification"
|
||||
if order.location_id == "test":
|
||||
return None
|
||||
|
||||
if order.courier is not None:
|
||||
# pylint: disable=C0301, C0209
|
||||
# pylint: disable=C0301
|
||||
return "<!channel|@channel> {3} is going to {1}, order <{0}|here>! Deadline in {2} minutes!".format(
|
||||
url_for("order_bp.order_from_slug", order_slug=order.slug, _external=True),
|
||||
url_for("order_bp.order_from_id", order_id=order.id, _external=True),
|
||||
order.location_name,
|
||||
remaining_minutes(order.stoptime),
|
||||
order.courier.username,
|
||||
order.courier.username.title(),
|
||||
)
|
||||
|
||||
# pylint: disable=C0209
|
||||
return "<!channel|@channel> New order for {}. Deadline in {} minutes. <{}|Open here.>".format(
|
||||
order.location_name,
|
||||
remaining_minutes(order.stoptime),
|
||||
url_for("order_bp.order_from_slug", order_slug=order.slug, _external=True),
|
||||
url_for("order_bp.order_from_id", order_id=order.id, _external=True),
|
||||
)
|
||||
|
||||
|
||||
def post_order_to_webhook(order: Order) -> None:
|
||||
"""Function that sends the notification for the order"""
|
||||
"Function that sends the notification for the order"
|
||||
message = webhook_text(order)
|
||||
if message:
|
||||
webhookthread = WebhookSenderThread(message, app.config["SLACK_WEBHOOK"])
|
||||
|
@ -41,10 +40,10 @@ def post_order_to_webhook(order: Order) -> None:
|
|||
|
||||
|
||||
class WebhookSenderThread(Thread):
|
||||
"""Extension of the Thread class, which sends a webhook for the notification"""
|
||||
"Extension of the Thread class, which sends a webhook for the notification"
|
||||
|
||||
def __init__(self, message: str, url: str) -> None:
|
||||
super().__init__()
|
||||
super(WebhookSenderThread, self).__init__()
|
||||
self.message = message
|
||||
self.url = url
|
||||
|
||||
|
@ -52,7 +51,7 @@ class WebhookSenderThread(Thread):
|
|||
self.slack_webhook()
|
||||
|
||||
def slack_webhook(self) -> None:
|
||||
"""The webhook for the specified chat platform"""
|
||||
"The webhook for the specified chat platform"
|
||||
if self.url:
|
||||
requests.post(self.url, json={"text": self.message})
|
||||
else:
|
||||
|
@ -60,9 +59,9 @@ class WebhookSenderThread(Thread):
|
|||
|
||||
|
||||
def remaining_minutes(value) -> str:
|
||||
"""Return the remaining minutes until the deadline of and order"""
|
||||
"Return the remaining minutes until the deadline of and order"
|
||||
delta = value - datetime.now()
|
||||
if delta.total_seconds() < 0:
|
||||
return "0"
|
||||
minutes = int(delta.total_seconds() // 60)
|
||||
return f"{minutes:02}"
|
||||
minutes = delta.total_seconds() // 60
|
||||
return "%02d" % minutes
|
||||
|
|
|
@ -1,8 +1,9 @@
|
|||
#!/usr/bin/env python3
|
||||
"Module used for parsing the HLDS files"
|
||||
|
||||
from tatsu.util import asjson
|
||||
from hlds.parser import parse_files
|
||||
|
||||
|
||||
USAGE = """{0} [filename]...
|
||||
Parse HLDS files, print as JSON
|
||||
|
||||
|
|
|
@ -18,9 +18,7 @@ sys.path.append(os.getcwd())
|
|||
|
||||
# Phusion Passenger expects this file to be called `passenger_wsgi.py`
|
||||
# and the WSGI object to be called `application`
|
||||
from app import create_app
|
||||
|
||||
application, appmgr = create_app()
|
||||
from app import app as application
|
||||
|
||||
# For running on the server with passenger etc
|
||||
if __name__ == "__main__":
|
||||
|
|
|
@ -243,9 +243,9 @@ details summary {
|
|||
}
|
||||
details summary:before {
|
||||
font-style: normal;
|
||||
content: "▸";
|
||||
content: "⯈";
|
||||
padding-right: 0.4em;
|
||||
}
|
||||
details[open] summary:before {
|
||||
content: "▾";
|
||||
content: "⯆";
|
||||
}
|
||||
|
|
2
app/static/js/jquery.min.js
vendored
2
app/static/js/jquery.min.js
vendored
File diff suppressed because one or more lines are too long
1
app/static/js/qrcode.min.js
vendored
1
app/static/js/qrcode.min.js
vendored
File diff suppressed because one or more lines are too long
|
@ -63,8 +63,7 @@
|
|||
<nav class="navbar navbar-default navbar-fixed-top">
|
||||
<div class="container">
|
||||
<div class="navbar-header">
|
||||
<button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#navbar"
|
||||
aria-expanded="false" aria-controls="navbar">
|
||||
<button type="button" class="navbar-toggle collapsed" data-toggle="collapse" data-target="#navbar" aria-expanded="false" aria-controls="navbar">
|
||||
<span class="sr-only">Toggle navigation</span>
|
||||
<span class="icon-bar"></span>
|
||||
<span class="icon-bar"></span>
|
||||
|
@ -82,10 +81,7 @@
|
|||
</ul>
|
||||
<ul class="nav navbar-nav navbar-right">
|
||||
{% if current_user.is_anonymous() %}
|
||||
{% if configuration.ENABLE_MICROSOFT_AUTH %}
|
||||
<li><a href="{{ url_for('auth_microsoft_bp.login') }}">Login with Microsoft</a></li>
|
||||
{% endif %}
|
||||
<li><a href="{{ url_for('auth_zeus_bp.login') }}">Login with Zeus</a></li>
|
||||
<li><a href="{{ url_for('auth_bp.login') }}">Login</a></li>
|
||||
{% else %}
|
||||
<li><a href="{{ url_for('general_bp.profile') }}">{{ current_user.username }}</a></li>
|
||||
<li><a href="{{ url_for('auth_bp.logout') }}">Logout</a></li>
|
||||
|
@ -100,8 +96,8 @@
|
|||
{{ utils.flashed_messages(container=True) }}
|
||||
|
||||
<div class="container main">
|
||||
{% block container -%}
|
||||
{%- endblock %}
|
||||
{% block container -%}
|
||||
{%- endblock %}
|
||||
</div>
|
||||
|
||||
<footer>
|
||||
|
|
|
@ -12,39 +12,18 @@
|
|||
{% block metas %}
|
||||
{{ super() }}
|
||||
<meta name="robots" content="noindex, nofollow">
|
||||
|
||||
<script type="text/javascript" src="{{ url_for('static', filename='js/jquery.min.js') }}"></script>
|
||||
<script type="text/javascript" src="{{ url_for('static', filename='js/qrcode.min.js') }}"></script>
|
||||
{% endblock %}
|
||||
|
||||
{% block container %}
|
||||
<header class="row">
|
||||
<div class="col-md-2" style="padding-top: 2em">
|
||||
<div id="qrcode"></div>
|
||||
<script type="text/javascript">
|
||||
var qrcode = new QRCode(document.getElementById("qrcode"), {
|
||||
text: "{{ url_for("order_bp.order_from_slug", order_slug=order.slug, _external=True) }}",
|
||||
width: 128,
|
||||
height: 128,
|
||||
colorDark : "#000000",
|
||||
colorLight : "#ffffff",
|
||||
correctLevel : QRCode.CorrectLevel.H
|
||||
});
|
||||
</script>
|
||||
</div>
|
||||
<div class="col-md-10">
|
||||
<h2 id="order-title">Order {{ order.id }}</h2>
|
||||
<header>
|
||||
<h2 id="order-title">Order {{ order.id }}</h2>
|
||||
|
||||
<div class="location">
|
||||
{% if order.location %}
|
||||
<a href="{{ url_for('general_bp.location', location_id=order.location_id) }}">{{ order.location_name }}</a>
|
||||
{% else %}
|
||||
{{ order.location_name }}
|
||||
{% endif %}
|
||||
</div>
|
||||
<div>
|
||||
Unique order link: <code>{{ url_for("order_bp.order_from_slug", order_slug=order.slug, _external=True) }}</code>
|
||||
</div>
|
||||
<div class="location">
|
||||
{% if order.location %}
|
||||
<a href="{{ url_for('general_bp.location', location_id=order.location_id) }}">{{ order.location_name }}</a>
|
||||
{% else %}
|
||||
{{ order.location_name }}
|
||||
{% endif %}
|
||||
</div>
|
||||
</header>
|
||||
|
||||
|
@ -57,7 +36,7 @@
|
|||
{% for item in my_items %}
|
||||
<li class="spacecake">
|
||||
{% if item.can_delete(order.id, current_user.id, session.get('anon_name', '')) -%}
|
||||
<form action="{{ url_for('order_bp.delete_item', order_slug=order.slug, item_id=item.id) }}" method="post" style="display:inline">
|
||||
<form action="{{ url_for('order_bp.delete_item', order_id=order.id, item_id=item.id) }}" method="post" style="display:inline">
|
||||
<button class="btn btn-link btn-sm" type="submit" style="padding: 0 0.5em;"><span class="glyphicon glyphicon-remove"></span></button>
|
||||
</form>
|
||||
{%- endif %}
|
||||
|
@ -86,7 +65,7 @@
|
|||
<h3>Add item to order</h3>
|
||||
|
||||
{% for dish in order.location.dishes %}
|
||||
<form method="post" action="{{ url_for('order_bp.order_item_create', order_slug=order.slug) }}" id="dish_{{ dish.id }}">
|
||||
<form method="post" action="{{ url_for('order_bp.order_item_create', order_id=order.id) }}" id="dish_{{ dish.id }}">
|
||||
{{ form.csrf_token }}
|
||||
<input type="hidden" name="dish_id" value="{{ dish.id }}" />
|
||||
|
||||
|
@ -155,66 +134,60 @@
|
|||
|
||||
<div class="box" id="order_info">
|
||||
<h3>Order information</h3>
|
||||
<div class="row">
|
||||
<dl class="col-md-10 col-lg-8">
|
||||
<div>
|
||||
<dt>Order opens</dt>
|
||||
<dd>{{ order.starttime.strftime("%Y-%m-%d, %H:%M") }}</dd>
|
||||
<dl>
|
||||
<div>
|
||||
<dt>Order opens</dt>
|
||||
<dd>{{ order.starttime.strftime("%Y-%m-%d, %H:%M") }}</dd>
|
||||
|
||||
<dt>Order closes</dt>
|
||||
<dd>
|
||||
{% if order.stoptime %}
|
||||
{% set stoptimefmt = (
|
||||
"%H:%M" if order.stoptime.date() == order.starttime.date()
|
||||
else "%Y-%m-%d, %H:%M"
|
||||
) %}
|
||||
{{ order.stoptime.strftime(stoptimefmt) }} ({{ order.stoptime|countdown }})
|
||||
{% else %}
|
||||
Never
|
||||
{% endif %}
|
||||
</dd>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<dt>Location</dt>
|
||||
<dd>
|
||||
{% if order.location %}
|
||||
<a href="{{ url_for('general_bp.location', location_id=order.location_id) }}">{{ order.location_name }}</a>
|
||||
{% else %}
|
||||
{{ order.location_name }}
|
||||
{% endif %}
|
||||
</dd>
|
||||
|
||||
<dt>Courier</dt>
|
||||
<dd>
|
||||
{% if order.courier == None %}
|
||||
{% if not current_user.is_anonymous() %}
|
||||
<form action="{{ url_for('order_bp.volunteer', order_slug=order.slug) }}" method="post" style="display:inline">
|
||||
<input type="submit" class="btn btn-primary btn-sm" value="Volunteer"></input>
|
||||
</form>
|
||||
{% else %}No-one yet{% endif %}
|
||||
{% else %}
|
||||
{{ order.courier.username }}
|
||||
{% endif %}
|
||||
</dd>
|
||||
</div>
|
||||
|
||||
</dl>
|
||||
|
||||
<div class="col-md-2 col-lg-4">
|
||||
<img src="https://dsa.ugent.be/api/verenigingen/{{ order.association }}/logo" class="img-responsive align-top" style="max-width:200px;width:100%">
|
||||
<dt>Order closes</dt>
|
||||
<dd>
|
||||
{% if order.stoptime %}
|
||||
{% set stoptimefmt = (
|
||||
"%H:%M" if order.stoptime.date() == order.starttime.date()
|
||||
else "%Y-%m-%d, %H:%M"
|
||||
) %}
|
||||
{{ order.stoptime.strftime(stoptimefmt) }} ({{ order.stoptime|countdown }})
|
||||
{% else %}
|
||||
Never
|
||||
{% endif %}
|
||||
</dd>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<dt>Location</dt>
|
||||
<dd>
|
||||
{% if order.location %}
|
||||
<a href="{{ url_for('general_bp.location', location_id=order.location_id) }}">{{ order.location_name }}</a>
|
||||
{% else %}
|
||||
{{ order.location_name }}
|
||||
{% endif %}
|
||||
</dd>
|
||||
|
||||
<dt>Courier</dt>
|
||||
<dd>
|
||||
{% if order.courier == None %}
|
||||
{% if not current_user.is_anonymous() %}
|
||||
<form action="{{ url_for('order_bp.volunteer', order_id=order.id) }}" method="post" style="display:inline">
|
||||
<input type="submit" class="btn btn-primary btn-sm" value="Volunteer"></input>
|
||||
</form>
|
||||
{% else %}No-one yet{% endif %}
|
||||
{% else %}
|
||||
{{ order.courier.username }}
|
||||
{% endif %}
|
||||
</dd>
|
||||
</div>
|
||||
</dl>
|
||||
|
||||
<div>
|
||||
{% if order.can_close(current_user.id) -%}
|
||||
<form action="{{ url_for('order_bp.close_order', order_id=order.id) }}" method="post" style="display:inline">
|
||||
<input type="submit" class="btn btn-danger" value="Close"></input>
|
||||
</form>
|
||||
{% endif %}
|
||||
{% if courier_or_admin %}
|
||||
<a class="btn" href="{{ url_for('order_bp.order_edit', order_id=order.id) }}">Edit</a>
|
||||
{%- endif %}
|
||||
</div>
|
||||
|
||||
{% if order.can_close(current_user.id) -%}
|
||||
<form action="{{ url_for('order_bp.close_order', order_slug=order.slug) }}" method="post" style="display:inline">
|
||||
<input type="submit" class="btn btn-danger" value="Close"></input>
|
||||
</form>
|
||||
{% endif %}
|
||||
{% if courier_or_admin %}
|
||||
<a class="btn" href="{{ url_for('order_bp.order_edit', order_slug=order.slug) }}">Edit</a>
|
||||
{%- endif %}
|
||||
|
||||
</div>
|
||||
|
||||
<div class="box" id="how_to_order">
|
||||
|
@ -285,7 +258,7 @@
|
|||
<div class="footer">
|
||||
Total {{ order.items.count() }} items — {{ total_price|euro }}
|
||||
|
||||
<a class="btn btn-sm" href="{{ url_for('order_bp.items_shop_view', order_slug=order.slug) }}">Shop view</a>
|
||||
<a class="btn btn-sm" href="{{ url_for('order_bp.items_shop_view', order_id=order.id) }}">Shop view</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
@ -294,7 +267,6 @@
|
|||
<section class="single_column">
|
||||
<div class="box" id="per_person">
|
||||
<h3>Items per person</h3>
|
||||
<form action="{{ url_for('order_bp.modify_items', order_slug=order.slug) }}" method="post">
|
||||
<table class="table table-condensed">
|
||||
<thead>
|
||||
<tr><th>Total</th><th>Name</th><th>Items</th></tr>
|
||||
|
@ -304,37 +276,35 @@
|
|||
<tr>
|
||||
<td>
|
||||
{% set paid = order_items | map(attribute="paid") | all %}
|
||||
<input type="checkbox" name="user_names" value="{{ user_name }}"
|
||||
{{ "disabled" if not order.can_modify_payment(current_user.id) }}>
|
||||
<input type="checkbox" name="{{ user_name }}"
|
||||
{{ "disabled" if paid }} style="{{ 'opacity: 0.5' if paid }}">
|
||||
|
||||
<span class="price" style="{{ 'opacity: 0.5' if paid }}">
|
||||
{{ order_items | map(attribute="price") | ignore_none | sum | euro }}
|
||||
</span>
|
||||
<span class="price">{{ order_items | map(attribute="price") | sum | euro }}</span>
|
||||
|
||||
{% if paid %}<span class="glyphicon glyphicon-ok" style="opacity: 0.5"></span>{% endif %}
|
||||
{% if paid %}paid{% endif %}
|
||||
</td>
|
||||
<td style="{{ 'opacity: 0.5' if paid }}">{{ user_name }}</td>
|
||||
<td>{{ user_name }}</td>
|
||||
<td class="items">
|
||||
<ul>
|
||||
{% for item in order_items %}
|
||||
<li class="{{ 'paid' if item.paid }}">
|
||||
<div class="actions">
|
||||
{% if item.can_delete(order.id, current_user.id, session.get('anon_name', '')) -%}
|
||||
<button class="btn btn-link btn-sm" type="submit" name="delete_item" value="{{ item.id }}" style="padding: 0 0.5em;"><span class="glyphicon glyphicon-remove"></span></button>
|
||||
<form action="{{ url_for('order_bp.delete_item', order_id=order.id, item_id=item.id) }}" method="post" style="display:inline">
|
||||
<button class="btn btn-link btn-sm" type="submit" style="padding: 0 0.5em;"><span class="glyphicon glyphicon-remove"></span></button>
|
||||
</form>
|
||||
{% else %}
|
||||
<span class="glyphicon glyphicon-remove" style="color: var(--gray3); padding: 0 0.5em; cursor: not-allowed"></span>
|
||||
<span class="glyphicon glyphicon-remove" style="color: var(--gray3); padding: 0 0.5em"></span>
|
||||
{%- endif %}
|
||||
</div>
|
||||
|
||||
<div class="price_aligned">
|
||||
{{ item.price|euro }}
|
||||
{% if item.price_modified %}
|
||||
<span class="glyphicon glyphicon-pencil" style="opacity: 0.5" title="Edited"></span>
|
||||
{% endif %}
|
||||
</div>
|
||||
<div class="price_aligned">{{ item.price|euro }}</div>
|
||||
<div class="item_description">{{ item.dish_name }}{{ "; " + item.comment if item.comment }}</div>
|
||||
</li>
|
||||
{% endfor %}
|
||||
<li>
|
||||
<button class="btn btn-link btn-sm" onclick="alert('TODO')" style="color: green; padding: 0 0.5em;"><span class="glyphicon glyphicon-plus"></span></button>
|
||||
</li>
|
||||
</ul>
|
||||
</td>
|
||||
|
||||
|
@ -344,21 +314,11 @@
|
|||
</table>
|
||||
|
||||
<div class="footer">
|
||||
{% if order.can_modify_payment(current_user.id) %}
|
||||
On selected:
|
||||
<button name="action" value="mark_paid" class="btn btn-sm"><span class="glyphicon glyphicon-ok"></span> Mark paid</button>
|
||||
<button name="action" value="mark_unpaid" class="btn btn-sm">Mark unpaid</button>
|
||||
{% endif %}
|
||||
|
||||
{% if order.can_modify_prices(current_user.id) %}
|
||||
<span style="border-left: 1px solid var(--gray0); display: inline-block;"> </span>
|
||||
<a href="{{ url_for('order_bp.prices', order_slug=order.slug) }}" class="btn btn-sm">
|
||||
<span class="glyphicon glyphicon-pencil"></span> Edit prices
|
||||
</a>
|
||||
{% endif %}
|
||||
|
||||
<button class="btn btn-sm"><span class="glyphicon glyphicon-ok"></span> Mark paid (TODO)</button>
|
||||
<button class="btn btn-sm"><span class="glyphicon glyphicon-piggy-bank"></span> Tab (TODO)</button>
|
||||
<button class="btn btn-sm"><span class="glyphicon glyphicon-qrcode"></span> QR code (TODO)</button>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
</section>
|
||||
{% endblock %}
|
||||
|
|
|
@ -11,7 +11,7 @@
|
|||
<h3>Edit order</h3>
|
||||
<div class="row darker">
|
||||
<div class="col-sm-12">
|
||||
<form method="post" action="{{ url_for('.order_edit', order_slug=order_slug) }}">
|
||||
<form method="post" action="{{ url_for('.order_edit', order_id=order_id) }}">
|
||||
{{ form.csrf_token }}
|
||||
<div class="form-group select2 {{ 'has-errors' if form.courier_id.errors else ''}}">
|
||||
{{ form.courier_id.label(class='control-label') }}<br>
|
||||
|
|
|
@ -1,132 +0,0 @@
|
|||
{% extends "layout.html" %}
|
||||
{% set active_page = "orders" -%}
|
||||
|
||||
{% import "utils.html" as util %}
|
||||
|
||||
{% block metas %}
|
||||
{{ super() }}
|
||||
<meta name="robots" content="noindex, nofollow">
|
||||
{% endblock %}
|
||||
|
||||
{% block container %}
|
||||
<header>
|
||||
<h2 id="order-title">Edit prices</h2>
|
||||
<div>Only applied to <a href="{{ url_for('order_bp.order_from_slug', order_slug=order.slug) }}">order {{ order.id }}</a>. To permanently change prices for {{ order.location_name }}, edit the <a href="https://git.zeus.gent/haldis/menus/-/blob/master/{{order.location_id}}.hlds">HLDS location definition</a>.</div>
|
||||
</header>
|
||||
|
||||
<form action="{{ url_for('order_bp.prices', order_slug=order.slug) }}" method="post">
|
||||
<div class="col-md-6" id="per_dish">
|
||||
<h3>Per dish</h3>
|
||||
<div class="noscript">This functionality requires JavaScript.</div>
|
||||
<div class="script">
|
||||
|
||||
<table class="table table-condensed">
|
||||
<thead>
|
||||
<tr><th colspan="2">Dish</th><th>Price</th></tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for dish_name, dish_quantity, dish_comment_groups in order.group_by_dish() -%}
|
||||
{% set has_comments = dish_comment_groups | length > 1 or (dish_comment_groups | map("first") | any) -%}
|
||||
{% for comment, items in dish_comment_groups -%}
|
||||
|
||||
<tr>
|
||||
{% if loop.first %}
|
||||
<td rowspan="{{dish_comment_groups | length }}">
|
||||
<span class="quantity">{{ dish_quantity }}</span> ×
|
||||
{{ dish_name }}
|
||||
</td>
|
||||
{% endif %}
|
||||
|
||||
<td>
|
||||
<span class="quantity">{{ items | length }}</span> ×
|
||||
{% if comment %}{{ comment }}
|
||||
{% else %}<i>No comment</i>
|
||||
{% endif %}
|
||||
</td>
|
||||
|
||||
<td>
|
||||
{% set price = items[0].price | euro("") %}
|
||||
{% set item_ids = items | map(attribute="id") %}
|
||||
€ <input type="text" data-for-items="{{ item_ids | join(",") }}" value="{{ price }}">
|
||||
</td>
|
||||
</tr>
|
||||
|
||||
{% endfor %}
|
||||
{%- endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="col-md-6" id="per_person">
|
||||
<h3>Per person</h3>
|
||||
<table class="table table-condensed">
|
||||
<thead>
|
||||
<tr><th>Name</th><th>Items</th></tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for user_name, order_items in order.group_by_user() -%}
|
||||
<tr>
|
||||
<td>{{ user_name }}</td>
|
||||
<td class="items">
|
||||
<ul>
|
||||
{% for item in order_items %}
|
||||
<li class="{{ 'paid' if item.paid }}">
|
||||
€ <input type="text" value="{{ item.price|euro("") }}" name="item_{{ item.id }}" id="item_{{ item.id }}">
|
||||
<span class="item_description">{{ item.dish_name }}{{ "; " + item.comment if item.comment }}</span>
|
||||
</li>
|
||||
{% endfor %}
|
||||
</ul>
|
||||
</td>
|
||||
|
||||
</tr>
|
||||
{%- endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
|
||||
<div>
|
||||
<a href="{{ url_for('order_bp.order_from_slug', order_slug=order.slug) }}" class="btn btn-sm">Cancel</a>
|
||||
<button class="btn btn-sm btn-primary">Apply</button>
|
||||
</div>
|
||||
</form>
|
||||
|
||||
{% endblock %}
|
||||
|
||||
{% block styles %}
|
||||
{{ super() }}
|
||||
<style>
|
||||
.script {
|
||||
display: none;
|
||||
}
|
||||
|
||||
#per_dish ul, #per_person ul {
|
||||
list-style-type: none;
|
||||
padding: 0;
|
||||
}
|
||||
|
||||
#per_dish input, #per_person input {
|
||||
width: 3em;
|
||||
}
|
||||
</style>
|
||||
{% endblock %}
|
||||
|
||||
{% block scripts %}
|
||||
{{ super() }}
|
||||
<script type="text/javascript">
|
||||
"use strict";
|
||||
$(window).on("load", () => {
|
||||
$(".noscript").css("display", "none");
|
||||
$(".script").css("display", "unset");
|
||||
|
||||
function updatePerPersonPrices(e) {
|
||||
console.log(e.target);
|
||||
for (let item_id of e.target.dataset.forItems.split(",")) {
|
||||
$("#item_" + item_id).val(e.target.value);
|
||||
}
|
||||
};
|
||||
$("#per_dish input").on("change", updatePerPersonPrices);
|
||||
$("#per_dish input").on("keyup", updatePerPersonPrices);
|
||||
});
|
||||
</script>
|
||||
{% endblock %}
|
|
@ -38,10 +38,10 @@
|
|||
{{ form.location_id(class='form-control select') }}
|
||||
{{ util.render_form_field_errors(form.location_id) }}
|
||||
</div>
|
||||
<div class="form-group select2 {{ 'has-errors' if form.association.errors else ''}}{{ ' required' if form.association.flags.required }}">
|
||||
{{ form.association.label(class='control-label') }}
|
||||
{{ form.association(class='form-control select') }}
|
||||
{{ util.render_form_field_errors(form.association) }}
|
||||
<div class="form-group select2 {{ 'has-errors' if form.courier_id.errors else ''}}">
|
||||
{{ form.organizing_id.label(class='control-label') }}<br>
|
||||
{{ form.organizing_id(class='form-control select') }}
|
||||
{{ util.render_form_field_errors(form.courier_id) }}
|
||||
</div>
|
||||
{% if current_user.is_admin() %}
|
||||
<div class="form-group{{ ' has-error' if form.starttime.errors }}{{ ' required' if form.starttime.flags.required }}{{ ' hidden' if not current_user.is_admin() }}">
|
||||
|
|
|
@ -1,28 +1,34 @@
|
|||
{% macro render_order(order) -%}
|
||||
<div class="row order_row">
|
||||
<div class="col-md-6 order_data">
|
||||
<div class="col-md-2 col-lg-3">
|
||||
{% if order.organizing_id %}
|
||||
<img class="my_image" src="https://dsa.ugent.be/api/verenigingen/{{order.organizing_id}}/logo?size=large">
|
||||
{% endif %}<br />
|
||||
</div>
|
||||
<div class="col-md-5 col-lg-6 order_data">
|
||||
<h5>{{ order.location_name }}</h5>
|
||||
<b class="amount_of_orders">{{ order.items.count() }} items ordered for {{ order.association }}</b></p>
|
||||
<b class="amount_of_orders">{{ order.items.count() }} orders</b></p>
|
||||
<p class="time_data">
|
||||
{% if order.organizing_name %}
|
||||
<p>{{order.organizing_name}}</p>
|
||||
{% endif %}
|
||||
{% if order.stoptime %}
|
||||
<span><b>Closes </b>{{ order.stoptime.strftime("%H:%M") }}</span>{{ order.stoptime|countdown }}
|
||||
{% else %}open{% endif %}<br/>
|
||||
<span><b>Closes </b>{{ order.stoptime.strftime("%H:%M") }}</span>{{ order.stoptime|countdown }}
|
||||
{% else %}open{% endif %}<br />
|
||||
</div>
|
||||
<div class="col-md-3">
|
||||
<img src="https://dsa.ugent.be/api/verenigingen/{{ order.association }}/logo" class="img-responsive align-bottom" style="max-width:200px;width:100%">
|
||||
</div>
|
||||
<div class="col-md-3 expand_button_wrapper">
|
||||
<a class="btn btn-primary btn-block align-bottom expand_button" href="{{ url_for('order_bp.order_from_slug', order_slug=order.slug) }}">Expand</a>
|
||||
<div class="col-md-4 col-lg-3 expand_button_wrapper">
|
||||
<a class="btn btn-primary btn-block align-bottom expand_button"
|
||||
href="{{ url_for('order_bp.order_from_id', order_id=order.id) }}">Expand</a>
|
||||
</div>
|
||||
</div>
|
||||
{%- endmacro %}
|
||||
|
||||
{% macro render_form_field_errors(field) %}
|
||||
{%- if field.errors %}
|
||||
{%- for error in field.errors %}
|
||||
<p class="help-block">{{error}}</p>
|
||||
{%- endfor %}
|
||||
{%- for error in field.errors %}
|
||||
<p class="help-block">{{error}}</p>
|
||||
{%- endfor %}
|
||||
{%- elif field.description -%}
|
||||
<p class="help-block">{{field.description|safe}}</p>
|
||||
<p class="help-block">{{field.description|safe}}</p>
|
||||
{%- endif %}
|
||||
{% endmacro %}
|
||||
{% endmacro %}
|
22
app/utils.py
22
app/utils.py
|
@ -1,31 +1,20 @@
|
|||
"Script which contains several utils for Haldis"
|
||||
|
||||
import re
|
||||
from typing import Iterable, Optional
|
||||
from typing import Iterable
|
||||
|
||||
|
||||
def euro_string(value: Optional[int], unit="€ ") -> str:
|
||||
def euro_string(value: int) -> str:
|
||||
"""
|
||||
Convert cents to string formatted euro
|
||||
"""
|
||||
if value is None:
|
||||
return "✗"
|
||||
euro, cents = divmod(value, 100)
|
||||
if cents:
|
||||
return f"{unit}{euro}.{cents:02}"
|
||||
return f"{unit}{euro}"
|
||||
|
||||
|
||||
def parse_euro_string(value: str) -> Optional[int]:
|
||||
m = re.fullmatch("(?:€ ?)?([0-9]+)(?:[.,]([0-9]+))?", value)
|
||||
if not m:
|
||||
return None
|
||||
cents_02 = "{:0<2.2}".format(m.group(2)) if m.group(2) else "00"
|
||||
return int(m.group(1)) * 100 + int(cents_02)
|
||||
return "€ {}.{:02}".format(euro, cents)
|
||||
else:
|
||||
return "€ {}".format(euro)
|
||||
|
||||
|
||||
def price_range_string(price_range, include_upper=False):
|
||||
"Convert a price range to a string formatted euro"
|
||||
if price_range[0] == price_range[1]:
|
||||
return euro_string(price_range[0])
|
||||
return ("{}—{}" if include_upper else "from {}").format(
|
||||
|
@ -44,5 +33,4 @@ def first(iterable: Iterable, default=None):
|
|||
|
||||
|
||||
def ignore_none(iterable: Iterable):
|
||||
"Filter to ignore None objects"
|
||||
return filter(lambda x: x is not None, iterable)
|
||||
|
|
|
@ -17,12 +17,12 @@ def list_routes() -> str:
|
|||
for rule in app.url_map.iter_rules():
|
||||
options = {}
|
||||
for arg in rule.arguments:
|
||||
options[arg] = f"[{arg}]"
|
||||
options[arg] = "[{0}]".format(arg)
|
||||
print(rule.endpoint)
|
||||
methods = ",".join(rule.methods)
|
||||
url = url_for(rule.endpoint, **options)
|
||||
line = urllib.parse.unquote(
|
||||
f"{rule.endpoint:50s} {methods:20s} {url}"
|
||||
"{:50s} {:20s} {}".format(rule.endpoint, methods, url)
|
||||
)
|
||||
output.append(line)
|
||||
|
||||
|
|
|
@ -1,26 +1,32 @@
|
|||
"Script to generate the general views of Haldis"
|
||||
import json
|
||||
import os
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Optional
|
||||
|
||||
import yaml
|
||||
from flask import Blueprint, Flask, abort
|
||||
from typing import Optional
|
||||
|
||||
from flask import Flask, render_template, make_response
|
||||
from flask import request, jsonify
|
||||
from flask import Blueprint, abort
|
||||
from flask import current_app as app
|
||||
from flask import (jsonify, make_response, render_template, request,
|
||||
send_from_directory, url_for)
|
||||
from flask_login import current_user, login_required
|
||||
from flask import send_from_directory, url_for
|
||||
from flask_login import login_required
|
||||
|
||||
from utils import first
|
||||
from hlds.definitions import location_definitions
|
||||
from hlds.models import Location
|
||||
from models import Order
|
||||
from utils import first
|
||||
|
||||
# import views
|
||||
from views.order import get_orders
|
||||
|
||||
import json
|
||||
from flask import jsonify
|
||||
|
||||
general_bp = Blueprint("general_bp", __name__)
|
||||
|
||||
|
||||
with open(os.path.join(os.path.dirname(__file__), "themes.yml")) as _stream:
|
||||
with open(os.path.join(os.path.dirname(__file__), "themes.yml"), "r") as _stream:
|
||||
_theme_data = yaml.safe_load(_stream)
|
||||
THEME_OPTIONS = _theme_data["options"]
|
||||
THEMES = _theme_data["themes"]
|
||||
|
@ -31,12 +37,10 @@ def home() -> str:
|
|||
"Generate the home view"
|
||||
prev_day = datetime.now() - timedelta(days=1)
|
||||
recently_closed = get_orders(
|
||||
(Order.stoptime > prev_day) & (Order.stoptime < datetime.now())
|
||||
((Order.stoptime > prev_day) & (Order.stoptime < datetime.now()))
|
||||
)
|
||||
return render_template(
|
||||
"home.html", orders=get_orders(
|
||||
((datetime.now() > Order.starttime) & (Order.stoptime > datetime.now()) | (Order.stoptime == None))
|
||||
), recently_closed=recently_closed
|
||||
"home.html", orders=get_orders(), recently_closed=recently_closed
|
||||
)
|
||||
|
||||
|
||||
|
@ -56,7 +60,7 @@ def is_theme_active(theme, now):
|
|||
|
||||
return start_datetime <= now <= end_datetime
|
||||
|
||||
raise Exception(f"Unknown theme type {theme_type}")
|
||||
raise Exception("Unknown theme type {}".format(theme_type))
|
||||
|
||||
|
||||
def get_theme_css(theme, options):
|
||||
|
@ -67,18 +71,13 @@ def get_theme_css(theme, options):
|
|||
|
||||
for option in theme.get("options", []):
|
||||
theme_name = theme["name"]
|
||||
assert (
|
||||
option in THEME_OPTIONS
|
||||
), f"Theme `{theme_name}` uses undefined option `{option}`"
|
||||
assert option in THEME_OPTIONS, f"Theme `{theme_name}` uses undefined option `{option}`"
|
||||
|
||||
chosen_value = options[option]
|
||||
possible_values = list(THEME_OPTIONS[option].keys())
|
||||
|
||||
value = (
|
||||
chosen_value
|
||||
if chosen_value in possible_values
|
||||
value = chosen_value if chosen_value in possible_values \
|
||||
else THEME_OPTIONS[option]["_default"]
|
||||
)
|
||||
|
||||
filename += "_" + value
|
||||
|
||||
|
@ -120,15 +119,13 @@ def current_theme_js():
|
|||
themes = get_active_themes()
|
||||
|
||||
selected_theme_name = request.cookies.get("theme", None)
|
||||
matching_theme = first(t for t in themes if t["file"] == selected_theme_name)
|
||||
matching_theme = first((t for t in themes if t["file"] == selected_theme_name))
|
||||
cur_theme = matching_theme or themes[-1]
|
||||
|
||||
response = make_response(
|
||||
rf"""
|
||||
response = make_response(rf'''
|
||||
var currentTheme = {json.dumps(cur_theme['file'])};
|
||||
var currentThemeOptions = {json.dumps(cur_theme.get('options', []))};
|
||||
"""
|
||||
)
|
||||
''')
|
||||
response.headers["Content-Type"] = "text/javascript"
|
||||
|
||||
# Theme name that is not valid at this moment: delete cookie
|
||||
|
@ -169,27 +166,25 @@ def location_dish(location_id, dish_id) -> str:
|
|||
dish = loc.dish_by_id(dish_id)
|
||||
if dish is None:
|
||||
abort(404)
|
||||
return jsonify(
|
||||
[
|
||||
{
|
||||
"type": c[0],
|
||||
"id": c[1].id,
|
||||
"name": c[1].name,
|
||||
"description": c[1].description,
|
||||
"options": [
|
||||
{
|
||||
"id": o.id,
|
||||
"name": o.name,
|
||||
"description": o.description,
|
||||
"price": o.price,
|
||||
"tags": o.tags,
|
||||
}
|
||||
for o in c[1].options
|
||||
],
|
||||
}
|
||||
for c in dish.choices
|
||||
]
|
||||
)
|
||||
return jsonify([
|
||||
{
|
||||
"type": c[0],
|
||||
"id": c[1].id,
|
||||
"name": c[1].name,
|
||||
"description": c[1].description,
|
||||
"options": [
|
||||
{
|
||||
"id": o.id,
|
||||
"name": o.name,
|
||||
"description": o.description,
|
||||
"price": o.price,
|
||||
"tags": o.tags,
|
||||
}
|
||||
for o in c[1].options
|
||||
],
|
||||
}
|
||||
for c in dish.choices
|
||||
])
|
||||
|
||||
|
||||
@general_bp.route("/about/")
|
||||
|
@ -209,7 +204,7 @@ def profile() -> str:
|
|||
def favicon() -> str:
|
||||
"Generate the favicon"
|
||||
# pylint: disable=R1705
|
||||
if not get_orders(Order.stoptime > datetime.now()):
|
||||
if not get_orders((Order.stoptime > datetime.now())):
|
||||
return send_from_directory(
|
||||
os.path.join(app.root_path, "static"),
|
||||
"favicon.ico",
|
||||
|
|
|
@ -1,27 +1,37 @@
|
|||
"""Script to generate the order related views of Haldis"""
|
||||
"Script to generate the order related views of Haldis"
|
||||
import random
|
||||
import re
|
||||
import typing
|
||||
from datetime import datetime
|
||||
|
||||
# from flask import current_app as app
|
||||
from flask import (Blueprint, abort, flash, redirect, render_template, request,
|
||||
session, url_for, wrappers)
|
||||
from flask_login import current_user, login_required
|
||||
from forms import AnonOrderItemForm, OrderForm, OrderItemForm
|
||||
from hlds.definitions import location_definition_version, location_definitions
|
||||
from models import Order, OrderItem, User, db
|
||||
from notification import post_order_to_webhook
|
||||
from utils import ignore_none, parse_euro_string
|
||||
from werkzeug.wrappers import Response
|
||||
|
||||
# from flask import current_app as app
|
||||
from flask import (
|
||||
Blueprint,
|
||||
abort,
|
||||
flash,
|
||||
redirect,
|
||||
render_template,
|
||||
request,
|
||||
session,
|
||||
url_for,
|
||||
wrappers,
|
||||
)
|
||||
from flask_login import current_user, login_required
|
||||
|
||||
from forms import AnonOrderItemForm, OrderForm, OrderItemForm
|
||||
from models import Order, OrderItem, User, db
|
||||
from hlds.definitions import location_definitions, location_definition_version
|
||||
from notification import post_order_to_webhook
|
||||
from utils import ignore_none
|
||||
|
||||
order_bp = Blueprint("order_bp", "order")
|
||||
|
||||
|
||||
@order_bp.route("/")
|
||||
def orders(form: OrderForm = None) -> str:
|
||||
"""Generate general order view"""
|
||||
if form is None and current_user.association_list():
|
||||
"Generate general order view"
|
||||
if form is None and not current_user.is_anonymous():
|
||||
form = OrderForm()
|
||||
location_id = request.args.get("location_id")
|
||||
form.location_id.default = location_id
|
||||
|
@ -33,10 +43,7 @@ def orders(form: OrderForm = None) -> str:
|
|||
@order_bp.route("/create", methods=["POST"])
|
||||
@login_required
|
||||
def order_create() -> typing.Union[str, Response]:
|
||||
"""Generate order create view"""
|
||||
if not current_user.association_list():
|
||||
flash("Not allowed to create an order.", "info")
|
||||
abort(401)
|
||||
"Generate order create view"
|
||||
orderForm = OrderForm()
|
||||
orderForm.populate()
|
||||
if orderForm.validate_on_submit():
|
||||
|
@ -46,14 +53,14 @@ def order_create() -> typing.Union[str, Response]:
|
|||
db.session.add(order)
|
||||
db.session.commit()
|
||||
post_order_to_webhook(order)
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order.slug))
|
||||
return redirect(url_for("order_bp.order_from_id", order_id=order.id))
|
||||
return orders(form=orderForm)
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>")
|
||||
def order_from_slug(order_slug: str, form: OrderForm = None, dish_id=None) -> str:
|
||||
"""Generate order view from id"""
|
||||
order = Order.query.filter(Order.slug == order_slug).first()
|
||||
@order_bp.route("/<order_id>")
|
||||
def order_from_id(order_id: int, form: OrderForm = None, dish_id=None) -> str:
|
||||
"Generate order view from id"
|
||||
order = Order.query.filter(Order.id == order_id).first()
|
||||
if order is None:
|
||||
abort(404)
|
||||
if current_user.is_anonymous() and not order.public:
|
||||
|
@ -65,8 +72,8 @@ def order_from_slug(order_slug: str, form: OrderForm = None, dish_id=None) -> st
|
|||
form.populate(order.location)
|
||||
if order.is_closed():
|
||||
form = None
|
||||
total_price = sum(o.price or 0 for o in order.items)
|
||||
debts = sum(o.price or 0 for o in order.items if not o.paid)
|
||||
total_price = sum([o.price for o in order.items])
|
||||
debts = sum([o.price for o in order.items if not o.paid])
|
||||
|
||||
dish = order.location.dish_by_id(dish_id) if order.location else None
|
||||
|
||||
|
@ -80,44 +87,44 @@ def order_from_slug(order_slug: str, form: OrderForm = None, dish_id=None) -> st
|
|||
)
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/items")
|
||||
def items_shop_view(order_slug: int) -> str:
|
||||
"""Generate order items view from id"""
|
||||
order = Order.query.filter(Order.slug == order_slug).first()
|
||||
@order_bp.route("/<order_id>/items")
|
||||
def items_shop_view(order_id: int) -> str:
|
||||
"Generate order items view from id"
|
||||
order = Order.query.filter(Order.id == order_id).first()
|
||||
if order is None:
|
||||
abort(404)
|
||||
if current_user.is_anonymous() and not order.public:
|
||||
flash("Please login to see this order.", "info")
|
||||
abort(401)
|
||||
total_price = sum(o.price or 0 for o in order.items)
|
||||
total_price = sum([o.price for o in order.items])
|
||||
return render_template("order_items.html", order=order, total_price=total_price)
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/edit", methods=["GET", "POST"])
|
||||
@order_bp.route("/<order_id>/edit", methods=["GET", "POST"])
|
||||
@login_required
|
||||
def order_edit(order_slug: str) -> typing.Union[str, Response]:
|
||||
"""Generate order edit view from id"""
|
||||
order = Order.query.filter(Order.slug == order_slug).first()
|
||||
def order_edit(order_id: int) -> typing.Union[str, Response]:
|
||||
"Generate order edit view from id"
|
||||
order = Order.query.filter(Order.id == order_id).first()
|
||||
if current_user.id is not order.courier_id and not current_user.is_admin():
|
||||
abort(401)
|
||||
if order is None:
|
||||
abort(404)
|
||||
order_form = OrderForm(obj=order)
|
||||
order_form.populate()
|
||||
if order_form.validate_on_submit():
|
||||
order_form.populate_obj(order)
|
||||
orderForm = OrderForm(obj=order)
|
||||
orderForm.populate()
|
||||
if orderForm.validate_on_submit():
|
||||
orderForm.populate_obj(order)
|
||||
order.update_from_hlds()
|
||||
db.session.commit()
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order.slug))
|
||||
return render_template("order_edit.html", form=order_form, order_slug=order.slug)
|
||||
return redirect(url_for("order_bp.order_from_id", order_id=order.id))
|
||||
return render_template("order_edit.html", form=orderForm, order_id=order_id)
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/create", methods=["GET", "POST"])
|
||||
def order_item_create(order_slug: str) -> typing.Any:
|
||||
@order_bp.route("/<order_id>/create", methods=["GET", "POST"])
|
||||
def order_item_create(order_id: int) -> typing.Any:
|
||||
# type is 'typing.Union[str, Response]', but this errors due to
|
||||
# https://github.com/python/mypy/issues/7187
|
||||
"""Add item to order from slug"""
|
||||
current_order = Order.query.filter(Order.slug == order_slug).first()
|
||||
"Add item to order from id"
|
||||
current_order = Order.query.filter(Order.id == order_id).first()
|
||||
if current_order is None:
|
||||
abort(404)
|
||||
if current_order.is_closed():
|
||||
|
@ -126,14 +133,12 @@ def order_item_create(order_slug: str) -> typing.Any:
|
|||
flash("Please login to see this order.", "info")
|
||||
abort(401)
|
||||
location = current_order.location
|
||||
# If location doesn't exist anymore, adding items is nonsensical
|
||||
# If location doesn't exist any more, adding items is nonsensical
|
||||
if not location:
|
||||
abort(404)
|
||||
form = AnonOrderItemForm() if current_user.is_anonymous() else OrderItemForm()
|
||||
|
||||
dish_id = (
|
||||
request.form["dish_id"] if form.is_submitted() else request.args.get("dish")
|
||||
)
|
||||
dish_id = request.form["dish_id"] if form.is_submitted() else request.args.get("dish")
|
||||
if dish_id and not location.dish_by_id(dish_id):
|
||||
abort(404)
|
||||
if not form.is_submitted():
|
||||
|
@ -174,7 +179,7 @@ def order_item_create(order_slug: str) -> typing.Any:
|
|||
return redirect(
|
||||
url_for(
|
||||
"order_bp.order_item_create",
|
||||
order_slug=current_order.slug,
|
||||
order_id=order_id,
|
||||
dish=form.dish_id.data,
|
||||
user_name=user_name,
|
||||
comment=comment,
|
||||
|
@ -183,13 +188,14 @@ def order_item_create(order_slug: str) -> typing.Any:
|
|||
|
||||
# If the form was not submitted (GET request) or the form had errors: show form again
|
||||
if not form.validate_on_submit():
|
||||
return order_from_slug(current_order.slug, form=form, dish_id=dish_id)
|
||||
return order_from_id(order_id, form=form, dish_id=dish_id)
|
||||
|
||||
# Form was submitted and is valid
|
||||
|
||||
item = OrderItem()
|
||||
form.populate_obj(item)
|
||||
item.hlds_data_version = location_definition_version
|
||||
item.order_id = current_order.id
|
||||
item.order_id = order_id
|
||||
if not current_user.is_anonymous():
|
||||
item.user_id = current_user.id
|
||||
else:
|
||||
|
@ -224,82 +230,59 @@ def order_item_create(order_slug: str) -> typing.Any:
|
|||
|
||||
db.session.add(item)
|
||||
db.session.commit()
|
||||
flash("Ordered %s" % item.dish_name, "success")
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order_slug))
|
||||
flash("Ordered %s" % (item.dish_name), "success")
|
||||
return redirect(url_for("order_bp.order_from_id", order_id=order_id))
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/modify_items", methods=["POST"])
|
||||
@order_bp.route("/<order_id>/<user_name>/user_paid", methods=["POST"])
|
||||
@login_required
|
||||
# pylint: disable=R1710
|
||||
def modify_items(order_slug: str) -> typing.Optional[Response]:
|
||||
if "delete_item" in request.form:
|
||||
return delete_item(order_slug, int(request.form["delete_item"]))
|
||||
user_names = request.form.getlist("user_names")
|
||||
if request.form.get("action") == "mark_paid":
|
||||
return set_items_paid(order_slug, user_names, True)
|
||||
elif request.form.get("action") == "mark_unpaid":
|
||||
return set_items_paid(order_slug, user_names, False)
|
||||
def items_user_paid(order_id: int, user_name: str) -> typing.Optional[Response]:
|
||||
"Indicate payment status for a user in an order"
|
||||
user = User.query.filter(User.username == user_name).first()
|
||||
items: typing.List[OrderItem] = []
|
||||
if user:
|
||||
items = OrderItem.query.filter(
|
||||
(OrderItem.user_id == user.id) & (OrderItem.order_id == order_id)
|
||||
).all()
|
||||
else:
|
||||
abort(404)
|
||||
return None
|
||||
|
||||
def set_items_paid(order_slug: str, user_names: typing.Iterable[str], paid: bool):
|
||||
order = Order.query.filter(Order.slug == order_slug).first()
|
||||
total_paid_items = 0
|
||||
total_failed_items = 0
|
||||
for user_name in user_names:
|
||||
user = User.query.filter(User.username == user_name).first()
|
||||
items: typing.List[OrderItem] = []
|
||||
if user:
|
||||
items = OrderItem.query.filter(
|
||||
(OrderItem.user_id == user.id) & (OrderItem.order_id == order.id)
|
||||
).all()
|
||||
else:
|
||||
items = OrderItem.query.filter(
|
||||
(OrderItem.user_name == user_name) & (OrderItem.order_id == order.id)
|
||||
).all()
|
||||
|
||||
items = OrderItem.query.filter(
|
||||
(OrderItem.user_name == user_name) & (OrderItem.order_id == order_id)
|
||||
).all()
|
||||
current_order = Order.query.filter(Order.id == order_id).first()
|
||||
if current_order.courier_id == current_user.id or current_user.admin:
|
||||
for item in items:
|
||||
if item.can_modify_payment(order.id, current_user.id):
|
||||
if item.paid != paid:
|
||||
item.paid = paid
|
||||
total_paid_items += 1
|
||||
else:
|
||||
total_failed_items += 1
|
||||
|
||||
db.session.commit()
|
||||
if total_failed_items == 0:
|
||||
flash("Marked %d items as paid" % (total_paid_items,), "success")
|
||||
else:
|
||||
flash("Failed to mark %d items as paid (succeeded in marking %d items as paid)" % (total_failed_items, total_paid_items), "error")
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order_slug))
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/<item_id>/delete", methods=["POST"])
|
||||
# pylint: disable=R1710
|
||||
def delete_item(order_slug: str, item_id: int) -> typing.Any:
|
||||
# type is 'typing.Optional[Response]', but this errors due to
|
||||
# https://github.com/python/mypy/issues/7187
|
||||
"""Delete an item from an order"""
|
||||
item: OrderItem = OrderItem.query.filter(OrderItem.id == item_id).first()
|
||||
order: Order = Order.query.filter(Order.slug == order_slug).first()
|
||||
user_id = None
|
||||
if not current_user.is_anonymous():
|
||||
user_id = current_user.id
|
||||
if item.can_delete(order.id, user_id, session.get("anon_name", "")):
|
||||
dish_name = item.dish_name
|
||||
db.session.delete(item)
|
||||
item.paid = True
|
||||
db.session.commit()
|
||||
flash("Deleted %s" % dish_name, "success")
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order_slug))
|
||||
flash("Paid %d items for %s" % (len(items), item.for_name), "success")
|
||||
return redirect(url_for("order_bp.order_from_id", order_id=order_id))
|
||||
abort(404)
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/volunteer", methods=["POST"])
|
||||
@order_bp.route("/<order_id>/<item_id>/delete", methods=["POST"])
|
||||
# pylint: disable=R1710
|
||||
def delete_item(order_id: int, item_id: int) -> typing.Any:
|
||||
# type is 'typing.Optional[Response]', but this errors due to
|
||||
# https://github.com/python/mypy/issues/7187
|
||||
"Delete an item from an order"
|
||||
item = OrderItem.query.filter(OrderItem.id == item_id).first()
|
||||
user_id = None
|
||||
if not current_user.is_anonymous():
|
||||
user_id = current_user.id
|
||||
if item.can_delete(order_id, user_id, session.get("anon_name", "")):
|
||||
dish_name = item.dish_name
|
||||
db.session.delete(item)
|
||||
db.session.commit()
|
||||
flash("Deleted %s" % (dish_name), "success")
|
||||
return redirect(url_for("order_bp.order_from_id", order_id=order_id))
|
||||
abort(404)
|
||||
|
||||
|
||||
@order_bp.route("/<order_id>/volunteer", methods=["POST"])
|
||||
@login_required
|
||||
def volunteer(order_slug: str) -> Response:
|
||||
"""Add a volunteer to an order"""
|
||||
order = Order.query.filter(Order.slug == order_slug).first()
|
||||
def volunteer(order_id: int) -> Response:
|
||||
"Add a volunteer to an order"
|
||||
order = Order.query.filter(Order.id == order_id).first()
|
||||
if order is None:
|
||||
abort(404)
|
||||
if order.courier_id is None or order.courier_id == 0:
|
||||
|
@ -308,14 +291,14 @@ def volunteer(order_slug: str) -> Response:
|
|||
flash("Thank you for volunteering!")
|
||||
else:
|
||||
flash("Volunteering not possible!")
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order.slug))
|
||||
return redirect(url_for("order_bp.order_from_id", order_id=order_id))
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/close", methods=["POST"])
|
||||
@order_bp.route("/<order_id>/close", methods=["POST"])
|
||||
@login_required
|
||||
def close_order(order_slug: str) -> typing.Optional[Response]:
|
||||
"""Close an order"""
|
||||
order = Order.query.filter(Order.slug == order_slug).first()
|
||||
def close_order(order_id: int) -> typing.Optional[Response]:
|
||||
"Close an order"
|
||||
order = Order.query.filter(Order.id == order_id).first()
|
||||
if order is None:
|
||||
abort(404)
|
||||
if (
|
||||
|
@ -327,54 +310,12 @@ def close_order(order_slug: str) -> typing.Optional[Response]:
|
|||
if courier is not None:
|
||||
order.courier_id = courier.id
|
||||
db.session.commit()
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order_slug))
|
||||
return redirect(url_for("order_bp.order_from_id", order_id=order_id))
|
||||
return None
|
||||
|
||||
|
||||
@order_bp.route("/<order_slug>/prices", methods=["GET", "POST"])
|
||||
@login_required
|
||||
def prices(order_slug: str) -> typing.Optional[Response]:
|
||||
order = Order.query.filter(Order.slug == order_slug).first()
|
||||
if order is None:
|
||||
abort(404)
|
||||
if not order.can_modify_prices(current_user.id):
|
||||
flash("You cannot modify the prices at this time.", "error")
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order.slug))
|
||||
|
||||
if request.method == "GET":
|
||||
return render_template(
|
||||
"order_prices.html",
|
||||
order=order,
|
||||
)
|
||||
else:
|
||||
new_prices = {}
|
||||
|
||||
for key, value in request.form.items():
|
||||
m = re.fullmatch("item_([0-9]+)", key)
|
||||
if not m:
|
||||
continue
|
||||
item_id = int(m.group(1))
|
||||
|
||||
price = parse_euro_string(value)
|
||||
if not price:
|
||||
flash(f"Could not recognize '{value}' as a price")
|
||||
continue
|
||||
|
||||
new_prices[item_id] = price
|
||||
|
||||
for item in order.items:
|
||||
new_price = new_prices.get(item.id)
|
||||
if new_price is not None and new_price != item.price:
|
||||
item.price = new_price
|
||||
item.price_modified = datetime.now()
|
||||
db.session.commit()
|
||||
|
||||
return redirect(url_for("order_bp.order_from_slug", order_slug=order.slug))
|
||||
|
||||
|
||||
|
||||
def select_user(items) -> typing.Optional[User]:
|
||||
"""Select a random user from those who are signed up for the order"""
|
||||
"Select a random user from those who are signed up for the order"
|
||||
user = None
|
||||
# remove non users
|
||||
items = [i for i in items if i.user_id]
|
||||
|
@ -393,20 +334,19 @@ def select_user(items) -> typing.Optional[User]:
|
|||
|
||||
|
||||
def get_orders(expression=None) -> typing.List[Order]:
|
||||
"""Give the list of all currently open and public Orders"""
|
||||
"Give the list of all currently open and public Orders"
|
||||
order_list: typing.List[OrderForm] = []
|
||||
if expression is None:
|
||||
expression = ((datetime.now() > Order.starttime) & (
|
||||
Order.stoptime
|
||||
> datetime.now()
|
||||
# pylint: disable=C0121
|
||||
) | (Order.stoptime == None)
|
||||
) & (Order.association.in_(current_user.association_list()))
|
||||
expression = (datetime.now() > Order.starttime) & (
|
||||
Order.stoptime
|
||||
> datetime.now()
|
||||
# pylint: disable=C0121
|
||||
) | (Order.stoptime == None)
|
||||
if not current_user.is_anonymous():
|
||||
order_list = Order.query.filter(expression).all()
|
||||
else:
|
||||
order_list = Order.query.filter(
|
||||
# pylint: disable=C0121
|
||||
expression & (Order.public == True) & (Order.association.in_(current_user.association_list()))
|
||||
(expression & (Order.public == True))
|
||||
).all()
|
||||
return order_list
|
||||
|
|
|
@ -1,9 +1,10 @@
|
|||
"Script to generate the stats related views of Haldis"
|
||||
from fatmodels import FatLocation, FatOrder, FatOrderItem, FatUser
|
||||
from flask import Blueprint
|
||||
from flask import current_app as app
|
||||
from flask import render_template
|
||||
|
||||
from fatmodels import FatLocation, FatOrder, FatOrderItem, FatUser
|
||||
|
||||
stats_blueprint = Blueprint("stats_blueprint", __name__)
|
||||
|
||||
|
||||
|
|
|
@ -1,16 +0,0 @@
|
|||
import sentry_sdk
|
||||
from sentry_sdk.integrations.flask import FlaskIntegration
|
||||
from waitress import serve
|
||||
|
||||
from app import create_app
|
||||
from config import Configuration
|
||||
|
||||
if __name__ == "__main__":
|
||||
if Configuration.SENTRY_DSN:
|
||||
sentry_sdk.init(
|
||||
dsn=Configuration.SENTRY_DSN,
|
||||
integrations=[FlaskIntegration()]
|
||||
)
|
||||
|
||||
app, app_mgr = create_app()
|
||||
serve(app, host="0.0.0.0", port=8000)
|
|
@ -1,37 +1,34 @@
|
|||
"Script containing everything specific to ZeusWPI"
|
||||
import typing
|
||||
|
||||
from flask import (Blueprint, current_app, flash, redirect, request, session,
|
||||
url_for)
|
||||
from flask import Blueprint, current_app, flash, redirect, request, session, url_for
|
||||
from flask_login import login_user
|
||||
from flask_oauthlib.client import OAuth, OAuthException, OAuthRemoteApp
|
||||
from models import User, db
|
||||
from flask_oauthlib.client import OAuth, OAuthException
|
||||
from werkzeug.wrappers import Response
|
||||
|
||||
auth_zeus_bp = Blueprint("auth_zeus_bp", __name__)
|
||||
from models import User, db
|
||||
|
||||
oauth_bp = Blueprint("oauth_bp", __name__)
|
||||
|
||||
|
||||
def zeus_login():
|
||||
"""Log in using ZeusWPI"""
|
||||
"Log in using ZeusWPI"
|
||||
return current_app.zeus.authorize(
|
||||
callback=url_for("auth_zeus_bp.authorized", _external=True))
|
||||
callback=url_for("oauth_bp.authorized", _external=True)
|
||||
)
|
||||
|
||||
|
||||
@auth_zeus_bp.route("/login")
|
||||
def login():
|
||||
"""Function to handle a user trying to log in"""
|
||||
return zeus_login()
|
||||
|
||||
|
||||
@auth_zeus_bp.route("/authorized")
|
||||
@oauth_bp.route("/login/zeus/authorized")
|
||||
def authorized() -> typing.Any:
|
||||
# type is 'typing.Union[str, Response]', but this errors due to
|
||||
# https://github.com/python/mypy/issues/7187
|
||||
"""Check authorized status"""
|
||||
"Check authorized status"
|
||||
resp = current_app.zeus.authorized_response()
|
||||
if resp is None:
|
||||
# pylint: disable=C0301
|
||||
return f"Access denied: reason={request.args['error']} error={request.args['error_description']}"
|
||||
return "Access denied: reason=%s error=%s" % (
|
||||
request.args["error"],
|
||||
request.args["error_description"],
|
||||
)
|
||||
if isinstance(resp, OAuthException):
|
||||
return f"Access denied: {resp.message}<br>{resp.data}"
|
||||
|
||||
|
@ -51,8 +48,8 @@ def authorized() -> typing.Any:
|
|||
return redirect(url_for("general_bp.home"))
|
||||
|
||||
|
||||
def init_oauth(app) -> OAuthRemoteApp:
|
||||
"""Initialize the OAuth for ZeusWPI"""
|
||||
def init_oauth(app):
|
||||
"Initialize the OAuth for ZeusWPI"
|
||||
oauth = OAuth(app)
|
||||
|
||||
zeus = oauth.remote_app(
|
||||
|
@ -75,15 +72,15 @@ def init_oauth(app) -> OAuthRemoteApp:
|
|||
|
||||
|
||||
def login_and_redirect_user(user) -> Response:
|
||||
"""Log in the user and then redirect them"""
|
||||
"Log in the user and then redirect them"
|
||||
login_user(user)
|
||||
return redirect(url_for("general_bp.home"))
|
||||
|
||||
|
||||
def create_user(username) -> User:
|
||||
"""Create a temporary user if it is needed"""
|
||||
"Create a temporary user if it is needed"
|
||||
user = User()
|
||||
user.configure(username, False, 1, associations=["zeus"])
|
||||
user.configure(username, False, 1)
|
||||
db.session.add(user)
|
||||
db.session.commit()
|
||||
return user
|
|
@ -1,17 +0,0 @@
|
|||
version: "3.4"
|
||||
|
||||
services:
|
||||
app:
|
||||
build:
|
||||
target: "development"
|
||||
environment:
|
||||
- MARIADB_DATABASE=haldis
|
||||
- MARIADB_USER=haldis
|
||||
- MARIADB_PASSWORD=haldis
|
||||
volumes: ["$PWD:/src"]
|
||||
database:
|
||||
environment:
|
||||
- MARIADB_DATABASE=haldis
|
||||
- MARIADB_ROOT_PASSWORD=mariadb
|
||||
- MARIADB_USER=haldis
|
||||
- MARIADB_PASSWORD=haldis
|
|
@ -1,31 +0,0 @@
|
|||
version: "3.4"
|
||||
|
||||
services:
|
||||
app:
|
||||
build:
|
||||
context: .
|
||||
target: production
|
||||
restart: on-failure
|
||||
depends_on: [database]
|
||||
ports: ["8000:8000"]
|
||||
environment:
|
||||
- MARIADB_HOST=database
|
||||
- MARIADB_DATABASE
|
||||
- MARIADB_USER
|
||||
- MARIADB_PASSWORD
|
||||
networks: [haldis]
|
||||
database:
|
||||
image: mariadb:10.8
|
||||
hostname: database
|
||||
restart: on-failure
|
||||
environment:
|
||||
- MARIADB_DATABASE
|
||||
- MARIADB_ROOT_PASSWORD
|
||||
- MARIADB_USER
|
||||
- MARIADB_PASSWORD
|
||||
networks: [haldis]
|
||||
volumes: [haldis_data:/var/lib/mysql]
|
||||
networks:
|
||||
haldis:
|
||||
volumes:
|
||||
haldis_data:
|
|
@ -25,7 +25,7 @@ syn keyword hldsChoiceType single_choice multi_choice nextgroup=hldsBlockIdAf
|
|||
syn match hldsBlockId "^[a-z0-9_-]\+: "
|
||||
syn match hldsBlockIdAftrKywrd "[a-z0-9_-]\+: " contained
|
||||
|
||||
syn match _space " \+" nextgroup=hldsTag,hldsPrice
|
||||
syn match _doubleSpace " \+" nextgroup=hldsTag,hldsPrice
|
||||
syn match hldsTag "{[a-z0-9_-]\+}\( \|$\)" contained nextgroup=hldsTag,hldsPrice
|
||||
syn match hldsPrice "€ *[0-9]\+\(\.[0-9]\+\|\)\( \|$\)" contained
|
||||
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
#!/usr/bin/env bash
|
||||
#!/bin/bash
|
||||
set -euo pipefail
|
||||
# A simple file to run all instructions from the README
|
||||
## this should be run in the root of the repository
|
||||
|
@ -10,9 +10,8 @@ B="\n${bold}"
|
|||
E="${normal}"
|
||||
|
||||
if [ ! -d "venv" ]; then
|
||||
PYTHON_VERSION=$(cat .python-version)
|
||||
echo -e "${B} No venv found, creating a new one with version ${PYTHON_VERSION} ${E}"
|
||||
python3 -m virtualenv -p "$PYTHON_VERSION" venv
|
||||
echo -e "${B} No venv found, creating a new one ${E}"
|
||||
python3 -m venv venv
|
||||
fi
|
||||
source venv/bin/activate
|
||||
|
||||
|
|
|
@ -1,4 +1,4 @@
|
|||
#!/usr/bin/env bash
|
||||
#!/bin/bash
|
||||
set -euo pipefail
|
||||
|
||||
# args = map(lambda arg: arg if x[0] in "/-" else pwd+arg, sys.argv[1:])
|
||||
|
|
|
@ -1,9 +1,7 @@
|
|||
#!/usr/bin/env bash
|
||||
#!/bin/bash
|
||||
set -euo pipefail
|
||||
|
||||
cd "$(dirname "$0")/app"
|
||||
|
||||
env python create_database.py setup_database
|
||||
latest_revision=$(env python app.py db heads | sed "s/ (head)$//")
|
||||
echo Stamping db at $latest_revision
|
||||
env python app.py db stamp $latest_revision
|
||||
cp database/* .
|
||||
../venv/bin/python create_database.py setup_database
|
||||
rm -f add_* create_database.py muhscheme.txt
|
||||
|
|
|
@ -1,2 +0,0 @@
|
|||
pylint-flask
|
||||
pylint-flask-sqlalchemy
|
|
@ -12,5 +12,3 @@ black
|
|||
pymysql
|
||||
pyyaml
|
||||
tatsu<5.6 # >=5.6 needs Python >=3.8
|
||||
microsoftgraph-python
|
||||
sentry-sdk[flask]
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
#
|
||||
# This file is autogenerated by pip-compile with python 3.9
|
||||
# This file is autogenerated by pip-compile
|
||||
# To update, run:
|
||||
#
|
||||
# pip-compile
|
||||
|
@ -11,15 +11,11 @@ appdirs==1.4.4
|
|||
black==21.6b0
|
||||
# via -r requirements.in
|
||||
blinker==1.4
|
||||
# via
|
||||
# flask-debugtoolbar
|
||||
# sentry-sdk
|
||||
# via flask-debugtoolbar
|
||||
cachelib==0.1.1
|
||||
# via flask-oauthlib
|
||||
certifi==2021.5.30
|
||||
# via
|
||||
# requests
|
||||
# sentry-sdk
|
||||
# via requests
|
||||
chardet==4.0.0
|
||||
# via requests
|
||||
click==7.1.2
|
||||
|
@ -28,19 +24,6 @@ click==7.1.2
|
|||
# flask
|
||||
dominate==2.6.0
|
||||
# via flask-bootstrap
|
||||
flask==1.1.4
|
||||
# via
|
||||
# -r requirements.in
|
||||
# flask-admin
|
||||
# flask-bootstrap
|
||||
# flask-debugtoolbar
|
||||
# flask-login
|
||||
# flask-migrate
|
||||
# flask-oauthlib
|
||||
# flask-script
|
||||
# flask-sqlalchemy
|
||||
# flask-wtf
|
||||
# sentry-sdk
|
||||
flask-admin==1.5.8
|
||||
# via -r requirements.in
|
||||
flask-bootstrap==3.3.7.1
|
||||
|
@ -61,6 +44,18 @@ flask-sqlalchemy==2.5.1
|
|||
# flask-migrate
|
||||
flask-wtf==0.15.1
|
||||
# via -r requirements.in
|
||||
flask==1.1.4
|
||||
# via
|
||||
# -r requirements.in
|
||||
# flask-admin
|
||||
# flask-bootstrap
|
||||
# flask-debugtoolbar
|
||||
# flask-login
|
||||
# flask-migrate
|
||||
# flask-oauthlib
|
||||
# flask-script
|
||||
# flask-sqlalchemy
|
||||
# flask-wtf
|
||||
greenlet==1.1.0
|
||||
# via sqlalchemy
|
||||
idna==2.10
|
||||
|
@ -79,8 +74,6 @@ markupsafe==2.0.1
|
|||
# jinja2
|
||||
# mako
|
||||
# wtforms
|
||||
microsoftgraph-python==1.1.3
|
||||
# via -r requirements.in
|
||||
mypy-extensions==0.4.3
|
||||
# via black
|
||||
oauthlib==2.1.0
|
||||
|
@ -99,14 +92,10 @@ pyyaml==5.4.1
|
|||
# via -r requirements.in
|
||||
regex==2021.4.4
|
||||
# via black
|
||||
requests==2.25.1
|
||||
# via
|
||||
# microsoftgraph-python
|
||||
# requests-oauthlib
|
||||
requests-oauthlib==1.1.0
|
||||
# via flask-oauthlib
|
||||
sentry-sdk[flask]==1.10.1
|
||||
# via -r requirements.in
|
||||
requests==2.25.1
|
||||
# via requests-oauthlib
|
||||
six==1.16.0
|
||||
# via python-dateutil
|
||||
sqlalchemy==1.4.18
|
||||
|
@ -117,10 +106,8 @@ tatsu==4.4.0
|
|||
# via -r requirements.in
|
||||
toml==0.10.2
|
||||
# via black
|
||||
urllib3==1.26.12
|
||||
# via
|
||||
# requests
|
||||
# sentry-sdk
|
||||
urllib3==1.26.5
|
||||
# via requests
|
||||
visitor==0.1.3
|
||||
# via flask-bootstrap
|
||||
werkzeug==1.0.1
|
||||
|
|
Loading…
Reference in a new issue