Colin Maudry
307 lines
8.7 KiB
Python
307 lines
8.7 KiB
Python
# ruff: noqa: E402 -- sys.path manipulation must precede third-party imports
|
||
import os
|
||
import sys
|
||
from pathlib import Path
|
||
from shutil import rmtree
|
||
|
||
# Sur les serveurs où le package est installé en mode éditable, pip peut ajouter
|
||
# src/ à sys.path via un fichier .pth. Combiné à la racine du projet (déjà dans
|
||
# sys.path via gunicorn), Dash's use_pages enregistre alors chaque page deux fois :
|
||
# une fois comme pages.X et une fois comme src.pages.X → erreur "duplicate paths".
|
||
_src_dir = str(Path(__file__).parent.resolve())
|
||
while _src_dir in sys.path:
|
||
sys.path.remove(_src_dir)
|
||
|
||
import dash_bootstrap_components as dbc
|
||
import pandas # noqa: F401 # eager import: avoid plotly's lazy-import race across Dash callback threads
|
||
import tomllib
|
||
from dash import (
|
||
ALL,
|
||
Dash,
|
||
Input,
|
||
Output,
|
||
State,
|
||
callback,
|
||
ctx,
|
||
dcc,
|
||
html,
|
||
page_container,
|
||
page_registry,
|
||
)
|
||
from dotenv import load_dotenv
|
||
from flask import Flask, Response
|
||
from flask_login import current_user
|
||
|
||
from src.auth.setup import init_auth
|
||
from src.utils import DEVELOPMENT
|
||
from src.utils.cache import cache
|
||
|
||
load_dotenv()
|
||
|
||
# if os.getenv("PYTEST_CURRENT_TEST"):
|
||
# os.environ["DATA_FILE_PARQUET_PATH"]
|
||
|
||
META_TAGS = [
|
||
{"name": "viewport", "content": "width=device-width, initial-scale=1"},
|
||
{
|
||
"name": "keywords",
|
||
"content": "commande publique, decp, marchés publics, données essentielles",
|
||
},
|
||
]
|
||
|
||
if DEVELOPMENT:
|
||
META_TAGS.append({"name": "robots", "content": "noindex"})
|
||
|
||
# Le cache doit être initialisé AVANT la construction de Dash : `use_pages=True`
|
||
# importe les modules de pages pendant l'instanciation, et certains appellent des
|
||
# fonctions memoizées (@cache.memoize) dès l'import (ex. tableau.py).
|
||
server = Flask(__name__)
|
||
|
||
cache_dir = os.getenv("CACHE_DIR", "/tmp/decp-cache")
|
||
|
||
if os.path.exists(cache_dir):
|
||
rmtree(cache_dir)
|
||
|
||
cache.init_app(
|
||
server,
|
||
config={
|
||
"CACHE_TYPE": "FileSystemCache",
|
||
"CACHE_DIR": cache_dir,
|
||
"CACHE_DEFAULT_TIMEOUT": int(
|
||
os.getenv("CACHE_DEFAULT_TIMEOUT", 3600 * 24)
|
||
), # 24h par défaut
|
||
"CACHE_THRESHOLD": 300,
|
||
},
|
||
)
|
||
|
||
app: Dash = Dash(
|
||
server=server,
|
||
title="decp.info",
|
||
use_pages=True,
|
||
suppress_callback_exceptions=True,
|
||
compress=True,
|
||
meta_tags=META_TAGS,
|
||
)
|
||
|
||
init_auth(app.server)
|
||
|
||
# Exempter les routes internes de Dash de la protection CSRF.
|
||
# Dash enregistre ses routes directement sur le serveur Flask (pas via blueprint),
|
||
# donc on itère la url_map après init_auth pour cibler les bons endpoints.
|
||
from src.auth.setup import _csrf as _auth_csrf # noqa: E402
|
||
|
||
if _auth_csrf is not None:
|
||
for _rule in app.server.url_map.iter_rules():
|
||
if _rule.rule.startswith("/_dash") or _rule.rule.startswith("/_reload"):
|
||
_vf = app.server.view_functions.get(_rule.endpoint)
|
||
if _vf is not None:
|
||
_auth_csrf.exempt(_vf)
|
||
|
||
from src.api import init_api # noqa: E402 # inline: src.db.conn must be ready first
|
||
|
||
init_api(app.server)
|
||
|
||
from src.subscriptions.setup import init_subscriptions # noqa: E402
|
||
|
||
init_subscriptions(app.server)
|
||
|
||
from src.saved_views import db as saved_views_db # noqa: E402
|
||
|
||
saved_views_db.init_schema()
|
||
|
||
|
||
# robots.txt
|
||
@app.server.route("/robots.txt")
|
||
def robots():
|
||
text = """User-agent: *
|
||
Allow: /
|
||
"""
|
||
return Response(text, mimetype="text/plain")
|
||
|
||
|
||
@app.server.route("/sitemap.xml")
|
||
def sitemap():
|
||
base_url = "https://decp.info"
|
||
pages = [
|
||
"/",
|
||
"/observatoire",
|
||
"/tableau",
|
||
"/a-propos",
|
||
"/etapes",
|
||
]
|
||
xml = '<?xml version="1.0" encoding="UTF-8"?>\n'
|
||
xml += '<urlset xmlns="http://www.sitemaps.org/schemas/sitemap/0.9">\n'
|
||
for page in pages:
|
||
xml += " <url>\n"
|
||
xml += f" <loc>{base_url}{page}</loc>\n"
|
||
xml += " </url>\n"
|
||
xml += "</urlset>"
|
||
return Response(xml, mimetype="text/xml")
|
||
|
||
|
||
with open("./pyproject.toml", "rb") as f:
|
||
pyproject = tomllib.load(f)
|
||
version = "v" + pyproject["project"]["version"]
|
||
|
||
|
||
app.index_string = """
|
||
<!DOCTYPE html>
|
||
<html lang="fr">
|
||
<head>
|
||
{%metas%}
|
||
<title>{%title%}</title>
|
||
{%favicon%}
|
||
{%css%}
|
||
<!-- canonical link -->
|
||
</head>
|
||
<body>
|
||
{%app_entry%}
|
||
<footer>
|
||
{%config%}
|
||
{%scripts%}
|
||
{%renderer%}
|
||
</footer>
|
||
<script type="application/javascript">
|
||
console.log("Matomo");
|
||
var _paq = window._paq = window._paq || [];
|
||
/* tracker methods like "setCustomDimension" should be called before "trackPageView" */
|
||
_paq.push(['trackPageView']);
|
||
_paq.push(['enableLinkTracking']);
|
||
(function() {
|
||
var u="//analytics.maudry.com/";
|
||
_paq.push(['setTrackerUrl', u+'matomo.php']);
|
||
_paq.push(['setSiteId', '14']);
|
||
var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0];
|
||
g.async=true; g.src=u+'matomo.js'; s.parentNode.insertBefore(g,s);
|
||
})();
|
||
</script>
|
||
</body>
|
||
</html>
|
||
"""
|
||
|
||
navbar = dbc.Navbar(
|
||
dbc.Container(
|
||
fluid=True,
|
||
children=[
|
||
dbc.NavItem(
|
||
children=[
|
||
html.Div(
|
||
[
|
||
dcc.Link(html.H1("decp.info"), href="/", className="logo"),
|
||
html.P(
|
||
[
|
||
html.A(
|
||
version,
|
||
href="https://github.com/ColinMaudry/decp.info/blob/main/CHANGELOG.md",
|
||
)
|
||
],
|
||
className="version",
|
||
),
|
||
],
|
||
className="logo-wrapper",
|
||
)
|
||
],
|
||
style={"minWidth": "230px"},
|
||
),
|
||
dbc.Nav(
|
||
children=[
|
||
dcc.Markdown(
|
||
os.getenv("ANNOUNCEMENTS"),
|
||
id="announcements",
|
||
dangerously_allow_html=True,
|
||
),
|
||
],
|
||
style={
|
||
"maxWidth": "1200px",
|
||
"display": "inline-block",
|
||
},
|
||
navbar=True,
|
||
id="announcements-nav",
|
||
),
|
||
dbc.NavbarToggler(id="navbar-toggler"),
|
||
dbc.Collapse(
|
||
dbc.Nav(
|
||
[
|
||
dbc.NavItem(
|
||
dbc.NavLink(
|
||
page["name"].replace(" ", " "),
|
||
href=page["relative_path"] + "/presentation"
|
||
if page["name"] == "À propos"
|
||
else page["relative_path"],
|
||
active="exact",
|
||
)
|
||
)
|
||
for page in page_registry.values()
|
||
if page["name"]
|
||
in ["Recherche", "À propos", "Tableau", "Observatoire"]
|
||
]
|
||
+ [html.Div(id="auth-nav-slot")],
|
||
className="ms-auto",
|
||
navbar=True,
|
||
),
|
||
id="navbar-collapse",
|
||
navbar=True,
|
||
),
|
||
],
|
||
),
|
||
color="light",
|
||
dark=False,
|
||
className="mb-4",
|
||
expand="lg",
|
||
)
|
||
|
||
app.layout = html.Div(
|
||
[
|
||
dcc.Store(id="csrf-token"),
|
||
navbar,
|
||
dbc.Container(
|
||
page_container,
|
||
fluid=True,
|
||
id="page-content-container",
|
||
className="mb-4",
|
||
),
|
||
]
|
||
)
|
||
|
||
|
||
@app.callback(
|
||
Output("navbar-collapse", "is_open"),
|
||
[Input("navbar-toggler", "n_clicks")],
|
||
[State("navbar-collapse", "is_open")],
|
||
)
|
||
def toggle_navbar_collapse(n, is_open):
|
||
if n:
|
||
return not is_open
|
||
return is_open
|
||
|
||
|
||
@callback(
|
||
Output("auth-nav-slot", "children"),
|
||
Input("auth-nav-slot", "id"),
|
||
)
|
||
def _auth_nav(_):
|
||
if current_user.is_authenticated:
|
||
email = current_user.email
|
||
display = email if len(email) <= 30 else email[:27] + "..."
|
||
return dbc.NavItem(dbc.NavLink(display, href="/compte/admin"))
|
||
return dbc.NavItem(dbc.NavLink("Connexion", href="/connexion"))
|
||
|
||
|
||
@callback(
|
||
Output("csrf-token", "data"),
|
||
Input("_pages_location", "pathname"),
|
||
Input("auth-nav-slot", "children"),
|
||
)
|
||
def _generate_csrf_token(*_):
|
||
from flask_wtf.csrf import generate_csrf
|
||
|
||
return generate_csrf()
|
||
|
||
|
||
@callback(
|
||
Output({"type": "csrf-input", "index": ALL}, "value"),
|
||
Input("csrf-token", "data"),
|
||
)
|
||
def _fill_csrf_inputs(token):
|
||
return [token] * len(ctx.outputs_list)
|