7.78.0 — MCP : périmètre du propriétaire du jeton

list_workspaces/get_workspace filtrés par user_workspace_ids ;
collections filtrées par workspace effectif ; hors périmètre =
introuvable, lectures et écritures. Test deux comptes.

CHANGELOG.md

@@ -1,5 +1,77 @@
 # Changelog - FlowDeck
 
+## v7.78.0 (2026-10-22) — MCP : périmètre du jeton (enfin)
+
+### Corrigé
+
+- **`list_workspaces` rendait les 52 workspaces de la base** — tous
+  les comptes et les résidus de tests : le MCP vérifiait le jeton
+  (qui tu es) mais n'appliquait aucun périmètre (ce que ce compte a
+  le droit de voir). Cas réel de Bruno, quelques heures après la
+  7.77.0. Désormais : workspaces du propriétaire du jeton
+  (propriétaire ou membre, via `user_workspace_ids`), collections
+  filtrées par leur workspace effectif (direct ou via la page hôte ;
+  les collections sans rattachement restent visibles, comme dans
+  l'API publique historique), et tout objet hors périmètre répond
+  « introuvable » — lectures **et** écritures. Test de régression
+  à deux comptes.
+
+## v7.77.0 (2026-10-22) — Corbeille réparée + MCP : les workspaces
+
+### Corrigé
+
+- **La suppression définitive depuis la corbeille échouait (500)**
+  pour toute page réelle : `favorites.page_id` et `recents.page_id`
+  référencent `pages(id)` sans CASCADE, avec les clés étrangères
+  actives — un `IntegrityError` dès que la page avait été ouverte
+  ou mise en favori. La purge automatique des 30 jours mourait sur
+  la même erreur, en silence. Nouveau nettoyage partagé
+  `detach_page_references`, appliqué aux trois chemins (suppression
+  unitaire, Empty Trash, purge planifiée). Cas réel de Bruno :
+  4 pages impossibles à supprimer. Test de régression ajouté.
+
+### Ajouté
+
+- **MCP : `list_workspaces` et `get_workspace`** — les workspaces
+  (conteneurs de pages : Techno, Famille Charest…) sont enfin
+  exposés au service d'agents, et les descriptions des outils
+  collections disent désormais clairement qu'une collection est une
+  base de données, pas un workspace (la réponse « 17 collections
+  (espaces de travail) » du panneau a induit Bruno en erreur).
+
+## v7.76.1 (2026-10-22) — Correctif : le MCP était bloqué par le CSRF
+
+### Corrigé
+
+- **Tout client MCP réel recevait 403 sur `initialize`** : le
+  middleware CSRF exigeait un jeton de session pour tout POST hors
+  préfixes exemptés, et `/mcp` n'y était pas — alors que c'est du
+  machine-à-machine authentifié par jeton d'API (Bearer), comme
+  `/scim/v2`. Les tests ne voyaient rien : leur client porte une
+  session et un CSRF. `/mcp` rejoint les préfixes exemptés du CSRF
+  (son authentification propre est inchangée : sans jeton valide,
+  toujours 401). Test de régression ajouté : client Bearer anonyme,
+  sans session ni CSRF.
+
+## v7.76.0 (2026-10-21) — Fusion : serveur MCP en écriture
+
+### Ajouté
+
+- **Serveur MCP en écriture** (`POST /mcp`) : en plus des lectures
+  existantes, trois nouveaux outils — `create_page`
+  (`collection_id`, `title`, `icon` optionnel, `properties` optionnel
+  → `property_values_json`), `update_page` (`id`, `title` optionnel,
+  `properties` optionnel qui remplace `property_values_json`) et
+  `create_collection` (`name`, `description` optionnel, `icon`
+  optionnel, avec vue par défaut comme l'API collections native).
+  Aucune suppression. Les erreurs métier (collection/page
+  introuvable, titre vide) reviennent en `{"erreur": "..."}` dans le
+  contenu texte, comme les lectures. `GET /mcp` reflète les nouveaux
+  outils (`read_only: false`). Authentification inchangée : jetons
+  d'API personnels existants.
+- **Redéploiement Docker à la charge de Bruno** pour mettre cette
+  version en production.
+
 ## v7.75.0 (2026-10-21) — Fusion : serveur MCP + panneau Spark
 
 ### Ajouté

VERSION

@@ -1 +1 @@
-7.75.0
+7.78.0

app/middleware/csrf.py

@@ -20,6 +20,11 @@ class CSRFMiddleware(BaseHTTPMiddleware):
     SAFE_METHODS = {"GET", "HEAD", "OPTIONS"}
     # NOTE: ``/scim/v2`` is Bearer-token only (no cookie auth), so CSRF does not
     # apply — IdP SCIM clients (Okta, Entra) cannot send an X-CSRF-Token.
+    # Même logique pour ``/mcp`` (Fusion, 7.76.1) : le serveur MCP est
+    # machine-à-machine, authentifié par les jetons d'API personnels
+    # (Bearer) — le service d'agents ne peut pas envoyer de X-CSRF-Token.
+    # Sans cette exemption, tout POST /mcp mourait en 403 avant la route
+    # (les tests passaient : leur client porte session + CSRF).
     # A19 — LISTE FINALE : plus aucun préfixe cookie-auth n'est exempté.
     # Tous les appels non-GET du front envoient désormais `X-CSRF-Token`
     # (46 sites équipés en v7.3.6 : agent_panel, settings, local_workspace,
@@ -30,7 +35,7 @@ class CSRFMiddleware(BaseHTTPMiddleware):
     #   - publics      : /s/ (sites), /f/ (forms)
     #   - infra/diag   : /api/csrf-token (le jeton lui-même), /api/frontend-error
     EXCLUDED_PATHS = {
-        "/api/webhook", "/api/v1", "/api/v2", "/scim/v2",
+        "/api/webhook", "/api/v1", "/api/v2", "/scim/v2", "/mcp",
         "/auth/callback", "/auth/register", "/auth/local-login", "/auth/local-verify",
         "/auth/2fa", "/auth/saml", "/auth/oidc", "/auth/webauthn",
         "/s/", "/f/", "/api/csrf-token", "/api/frontend-error",

app/routers/board/sharing.py

@@ -16,6 +16,7 @@ from app.services.collection_lifecycle import (
     collections_hosted_by_page,
     collections_hosted_by_pages,
     delete_collections,
+    detach_page_references,
 )
 from app.services.publish import fire_published, fire_unpublished, publish, unpublish
 
@@ -199,6 +200,7 @@ def permanent_delete(request: Request, page_id: int):
         # tâches sans document.
         collections = collections_hosted_by_page(conn, page_id)
         conn.execute("UPDATE pages SET parent_id=NULL WHERE parent_id=?", (page_id,))
+        detach_page_references(conn, [page_id])
         conn.execute("DELETE FROM pages WHERE id=? AND deleted_at IS NOT NULL", (page_id,))
         delete_collections(conn, collections)
         conn.commit()
@@ -229,6 +231,7 @@ def empty_trash(request: Request):
             "UPDATE pages SET parent_id=NULL WHERE parent_id IN "
             "(SELECT id FROM pages WHERE deleted_at IS NOT NULL)"
         )
+        detach_page_references(conn, trashed)
         conn.execute("DELETE FROM pages WHERE deleted_at IS NOT NULL")
         delete_collections(conn, collections)
         conn.commit()

app/routers/mcp_server.py

@@ -1,20 +1,23 @@
 """FlowDeck — serveur MCP (Fusion, branchement du service d'agents).
 
-Lecture seule, même dialecte JSON-RPC que les autres apps du
-programme (TikTak, Kanbante) : POST /mcp, initialize → tools/list →
-tools/call, réponses en contenu texte JSON.
+Même dialecte JSON-RPC que les autres apps du programme (TikTak,
+Kanbante) : POST /mcp, initialize → tools/list → tools/call,
+réponses en contenu texte JSON.
 
 Authentification : les jetons d'API personnels existants
 (Settings → API tokens, table ``api_tokens``, vérifiés par
 ``public_api._token_owner``) — aucune nouvelle machinerie de clés.
 Le service d'agents reçoit un jeton dédié créé par l'utilisateur ;
-il lit en son nom.
+il lit et écrit en son nom.
 
-Objet exposé : les **collections** (les projets/espaces de travail
-de Flowdeck) et leurs pages, la recherche par titre, et le registre
-des dépôts (table ``projects``). Doctrine du programme : Flowdeck
+Objets exposés : les **workspaces** (conteneurs de pages) et leurs
+pages, les **collections** (bases de données type Notion — ne pas
+confondre : une collection vit dans un workspace ou une page), la
+recherche par titre, et le registre des dépôts (table ``projects``).
+Doctrine du programme : Flowdeck
 référence les tâches, il ne les copie pas — aucune tâche TikTak ne
-transite par ici, et ce serveur n'écrit rien.
+transite par ici. Écritures limitées à la création/mise à jour de
+pages et à la création de collections ; aucune suppression.
 """
 from __future__ import annotations
 
@@ -25,13 +28,33 @@ from fastapi.responses import JSONResponse, Response
 
 from app.db import get_conn
 from app.routers.public_api import _token_owner
+from app.services.collection_lifecycle import (
+    effective_workspace_sql,
+    user_workspace_ids,
+)
 
 router = APIRouter(tags=["mcp"])
 
 OUTILS = [
+    {"name": "list_workspaces",
+     "description": "Liste les WORKSPACES Flowdeck du propriétaire du jeton "
+                    "(propriétaire ou membre) — ses conteneurs de pages "
+                    "(ex. Techno, Famille Charest), avec leur nombre de pages "
+                    "actives. À ne pas confondre avec les collections "
+                    "(bases de données).",
+     "inputSchema": {"type": "object", "properties": {}}},
+    {"name": "get_workspace",
+     "description": "Lit un workspace et l'arborescence de ses pages "
+                    "(titres, parent, section) — pages classiques, pas les "
+                    "lignes des collections.",
+     "inputSchema": {"type": "object",
+                     "properties": {"id": {"type": "integer"}},
+                     "required": ["id"]}},
     {"name": "list_collections",
-     "description": "Liste les collections Flowdeck (projets / espaces de travail) "
-                    "avec leur nombre de pages.",
+     "description": "Liste les COLLECTIONS Flowdeck — les bases de données "
+                    "de type Notion (tables, CRM, calendriers, formulaires), "
+                    "avec leur nombre de lignes. Ce ne sont PAS les workspaces : "
+                    "une collection vit dans un workspace ou dans une page.",
      "inputSchema": {"type": "object", "properties": {}}},
     {"name": "get_collection",
      "description": "Lit une collection et ses pages (titres et propriétés).",
@@ -51,6 +74,29 @@ OUTILS = [
     {"name": "list_repos",
      "description": "Liste le registre des dépôts suivis par Flowdeck (builtin, Gitea, GitHub).",
      "inputSchema": {"type": "object", "properties": {}}},
+    {"name": "create_page",
+     "description": "Crée une page dans une collection Flowdeck.",
+     "inputSchema": {"type": "object",
+                     "properties": {"collection_id": {"type": "integer"},
+                                    "title": {"type": "string"},
+                                    "icon": {"type": "string"},
+                                    "properties": {"type": "object"}},
+                     "required": ["collection_id", "title"]}},
+    {"name": "update_page",
+     "description": "Met à jour une page Flowdeck (titre et/ou propriétés ; "
+                    "les propriétés fournies remplacent property_values_json).",
+     "inputSchema": {"type": "object",
+                     "properties": {"id": {"type": "integer"},
+                                    "title": {"type": "string"},
+                                    "properties": {"type": "object"}},
+                     "required": ["id"]}},
+    {"name": "create_collection",
+     "description": "Crée une collection Flowdeck (projet / espace de travail).",
+     "inputSchema": {"type": "object",
+                     "properties": {"name": {"type": "string"},
+                                    "description": {"type": "string"},
+                                    "icon": {"type": "string"}},
+                     "required": ["name"]}},
 ]
 
 
@@ -71,21 +117,65 @@ def _page_resume(row) -> dict:
             "updated_at": row["updated_at"]}
 
 
-def _appel_outil(nom: str, args: dict):
+def _appel_outil(nom: str, args: dict, user_id: int):
+    """Exécute un outil DANS LE PÉRIMÈTRE du propriétaire du jeton.
+
+    Correctif 7.78.0 (cas réel de Bruno) : la première version listait
+    les 52 workspaces de la base — tous les comptes, résidus de tests
+    compris. Règle : workspaces dont l'utilisateur est propriétaire
+    ou membre ; collections rattachées (directement ou via leur page
+    hôte) à l'un de ces workspaces, plus les collections sans aucun
+    rattachement (héritage global, comme l'API publique historique).
+    Un objet hors périmètre répond « introuvable », sans fuiter son
+    existence.
+    """
     with get_conn() as conn:
+        accessible = set(user_workspace_ids(conn, user_id))
+        eff_sql = effective_workspace_sql("c")
+
+        def collection_visible(coll_id: int) -> bool:
+            row = conn.execute(
+                f"SELECT {eff_sql} AS eff FROM collections c WHERE c.id = ?",
+                (coll_id,)).fetchone()
+            if row is None:
+                return False
+            return row["eff"] is None or row["eff"] in accessible
+
+        if nom == "list_workspaces":
+            rows = conn.execute(
+                "SELECT w.id, w.name, w.owner_id, "
+                "(SELECT COUNT(*) FROM pages p WHERE p.workspace_id = w.id "
+                " AND p.deleted_at IS NULL) AS page_count "
+                "FROM workspaces w ORDER BY w.name").fetchall()
+            return [dict(r) for r in rows if r["id"] in accessible]
+        if nom == "get_workspace":
+            ws = conn.execute("SELECT * FROM workspaces WHERE id = ?",
+                              (int(args.get("id", 0)),)).fetchone()
+            if ws is None or ws["id"] not in accessible:
+                return {"erreur": "workspace introuvable"}
+            pages = conn.execute(
+                "SELECT id, title, parent_id, parent_section, updated_at "
+                "FROM pages WHERE workspace_id = ? AND deleted_at IS NULL "
+                "ORDER BY parent_id, title LIMIT 300", (ws["id"],)).fetchall()
+            return {"workspace": {"id": ws["id"], "name": ws["name"],
+                                  "owner_id": ws["owner_id"]},
+                    "pages": [dict(p) for p in pages]}
         if nom == "list_collections":
             rows = conn.execute(
-                "SELECT c.*, (SELECT COUNT(*) FROM collection_pages p "
-                "WHERE p.collection_id = c.id) AS page_count "
+                f"SELECT c.*, (SELECT COUNT(*) FROM collection_pages p "
+                f"WHERE p.collection_id = c.id) AS page_count, "
+                f"{eff_sql} AS eff_ws "
                 "FROM collections c ORDER BY c.name").fetchall()
             return [{"id": r["id"], "name": r["name"],
                      "description": r["description"], "icon": r["icon"],
                      "is_task": bool(r["is_task"]) if "is_task" in r.keys() else False,
-                     "page_count": r["page_count"]} for r in rows]
+                     "page_count": r["page_count"]}
+                    for r in rows
+                    if r["eff_ws"] is None or r["eff_ws"] in accessible]
         if nom == "get_collection":
             coll = conn.execute("SELECT * FROM collections WHERE id = ?",
                                 (int(args.get("id", 0)),)).fetchone()
-            if coll is None:
+            if coll is None or not collection_visible(coll["id"]):
                 return {"erreur": "collection introuvable"}
             pages = conn.execute(
                 "SELECT * FROM collection_pages WHERE collection_id = ? "
@@ -97,7 +187,7 @@ def _appel_outil(nom: str, args: dict):
         if nom == "get_page":
             p = conn.execute("SELECT * FROM collection_pages WHERE id = ?",
                              (int(args.get("id", 0)),)).fetchone()
-            if p is None:
+            if p is None or not collection_visible(p["collection_id"]):
                 return {"erreur": "page introuvable"}
             res = _page_resume(p)
             for cle in ("content", "blocks", "blocks_json"):
@@ -111,12 +201,94 @@ def _appel_outil(nom: str, args: dict):
             rows = conn.execute(
                 "SELECT * FROM collection_pages WHERE title LIKE ? "
                 "ORDER BY updated_at DESC LIMIT 25", (q,)).fetchall()
-            return [_page_resume(p) for p in rows]
+            return [_page_resume(p) for p in rows
+                    if collection_visible(p["collection_id"])]
         if nom == "list_repos":
             rows = conn.execute(
                 "SELECT id, name, proj_type, owner, language, description "
                 "FROM projects ORDER BY proj_type, name").fetchall()
             return [dict(r) for r in rows]
+        if nom == "create_page":
+            try:
+                collection_id = int(args.get("collection_id"))
+            except (TypeError, ValueError):
+                return {"erreur": "collection_id requis (entier)"}
+            title = str(args.get("title") or "").strip()
+            if not title:
+                return {"erreur": "titre vide"}
+            coll = conn.execute("SELECT * FROM collections WHERE id = ?",
+                                (collection_id,)).fetchone()
+            if coll is None or not collection_visible(collection_id):
+                return {"erreur": "collection introuvable"}
+            props = args.get("properties")
+            if props is None:
+                props = {}
+            if not isinstance(props, dict):
+                return {"erreur": "properties doit être un objet"}
+            icon = str(args.get("icon") or "file")
+            max_pos = conn.execute(
+                "SELECT COALESCE(MAX(position), -1) + 1 FROM collection_pages "
+                "WHERE collection_id = ?", (collection_id,)).fetchone()[0]
+            cur = conn.execute(
+                "INSERT INTO collection_pages "
+                "(collection_id, title, icon, position, property_values_json) "
+                "VALUES (?, ?, ?, ?, ?)",
+                (collection_id, title, icon, max_pos, json.dumps(props, ensure_ascii=False)))
+            conn.commit()
+            page = conn.execute("SELECT * FROM collection_pages WHERE id = ?",
+                                (cur.lastrowid,)).fetchone()
+            return _page_resume(page)
+        if nom == "update_page":
+            try:
+                page_id = int(args.get("id"))
+            except (TypeError, ValueError):
+                return {"erreur": "id requis (entier)"}
+            page = conn.execute("SELECT * FROM collection_pages WHERE id = ?",
+                                (page_id,)).fetchone()
+            if page is None or not collection_visible(page["collection_id"]):
+                return {"erreur": "page introuvable"}
+            title = page["title"]
+            if "title" in args and args.get("title") is not None:
+                title = str(args.get("title") or "").strip()
+                if not title:
+                    return {"erreur": "titre vide"}
+            props_json = page["property_values_json"]
+            if "properties" in args and args.get("properties") is not None:
+                props = args.get("properties")
+                if not isinstance(props, dict):
+                    return {"erreur": "properties doit être un objet"}
+                props_json = json.dumps(props, ensure_ascii=False)
+            conn.execute(
+                "UPDATE collection_pages SET title = ?, property_values_json = ?, "
+                "updated_at = CURRENT_TIMESTAMP WHERE id = ?",
+                (title, props_json, page_id))
+            conn.commit()
+            updated = conn.execute("SELECT * FROM collection_pages WHERE id = ?",
+                                   (page_id,)).fetchone()
+            return _page_resume(updated)
+        if nom == "create_collection":
+            name = str(args.get("name") or "").strip()
+            if not name:
+                return {"erreur": "nom vide"}
+            description = str(args.get("description") or "")
+            icon = str(args.get("icon") or "📋")
+            cur = conn.execute(
+                "INSERT INTO collections (name, description, icon, schema_json) "
+                "VALUES (?, ?, ?, '[]')",
+                (name, description, icon))
+            new_id = cur.lastrowid
+            # Vue par défaut, comme la création via l'API collections
+            # (app/routers/collections/crud.py).
+            conn.execute(
+                "INSERT INTO collection_views "
+                "(collection_id, name, view_type, config_json) VALUES (?, ?, ?, ?)",
+                (new_id, "Default View", "table", json.dumps({
+                    "visible_properties": ["Title"], "sorts": [], "filters": []})))
+            conn.commit()
+            coll = conn.execute("SELECT * FROM collections WHERE id = ?",
+                                (new_id,)).fetchone()
+            return {"id": coll["id"], "name": coll["name"],
+                    "description": coll["description"], "icon": coll["icon"]}
     return {"erreur": f"outil inconnu : {nom}"}
 
 
@@ -133,14 +305,15 @@ def _version() -> str:
 def mcp_info():
     return {"name": "flowdeck", "version": _version(),
             "transport": "streamable-http (JSON-RPC 2.0 over POST)",
-            "read_only": True, "tools": [t["name"] for t in OUTILS]}
+            "read_only": False, "tools": [t["name"] for t in OUTILS]}
 
 
 @router.post("/mcp")
 async def mcp(request: Request):
     auth = request.headers.get("authorization", "")
     token = auth[7:].strip() if auth.lower().startswith("bearer ") else ""
-    if not token or _token_owner(token) is None:
+    proprietaire = _token_owner(token) if token else None
+    if proprietaire is None:
         return JSONResponse(
             {"jsonrpc": "2.0", "id": None,
              "error": {"code": -32001, "message": "Authentification requise (jeton d'API Flowdeck)"}},
@@ -167,7 +340,8 @@ async def mcp(request: Request):
         return {"jsonrpc": "2.0", "id": rid, "result": {"tools": OUTILS}}
     if methode == "tools/call":
         params = data.get("params") or {}
-        res = _appel_outil(params.get("name", ""), params.get("arguments") or {})
+        res = _appel_outil(params.get("name", ""), params.get("arguments") or {},
+                           proprietaire["user_id"])
         return {"jsonrpc": "2.0", "id": rid,
                 "result": {"content": [{"type": "text",
                                         "text": json.dumps(res, ensure_ascii=False)}]}}

app/services/collection_lifecycle.py

@@ -51,6 +51,26 @@ EFFECTIVE_WORKSPACE_SQL = (
 )
 
 
+def detach_page_references(conn, page_ids) -> None:
+    """Supprime les lignes qui référencent des pages en ``NO ACTION``.
+
+    ``favorites.page_id`` et ``recents.page_id`` référencent
+    ``pages(id)`` sans CASCADE et la connexion applique
+    ``PRAGMA foreign_keys=ON`` : supprimer définitivement une page
+    réelle — ouverte un jour (recents) ou mise en favori — levait un
+    ``IntegrityError`` (500 côté API, échec silencieux de la purge
+    automatique des 30 jours). À appeler avant tout
+    ``DELETE FROM pages`` définitif. (Régression du 2026-10-22 :
+    les pages synthétiques des tests n'avaient ni favori ni récent.)
+    """
+    ids = [int(i) for i in page_ids]
+    if not ids:
+        return
+    ph = ",".join("?" * len(ids))
+    conn.execute(f"DELETE FROM favorites WHERE page_id IN ({ph})", ids)
+    conn.execute(f"DELETE FROM recents WHERE page_id IN ({ph})", ids)
+
+
 def effective_workspace_sql(alias: str = "c") -> str:
     """Workspace effectif d'une collection (colonne ou ``NULL`` si orpheline)."""
     return EFFECTIVE_WORKSPACE_SQL.format(a=alias)

app/services/trash.py

@@ -16,6 +16,7 @@ from app.db import get_conn
 from app.services.collection_lifecycle import (
     collections_hosted_by_page,
     delete_collections,
+    detach_page_references,
 )
 
 logger = logging.getLogger(__name__)
@@ -71,6 +72,7 @@ def purge_expired(days: int = 30) -> dict:
                 "WHERE parent_id=?",
                 (page_id, page_id),
             )
+            detach_page_references(conn, [page_id])
             conn.execute("DELETE FROM pages WHERE id=?", (page_id,))
             delete_collections(conn, collections)
             purged.append(page_id)

static/css/draco-panneau.css

@@ -60,3 +60,24 @@
 }
 .draco-panneau-form button:disabled { opacity: .5; cursor: default; }
 .draco-panneau-note { font-size: 11.5px; color: #8a8f84; margin-top: 8px; text-align: center; }
+.draco-missions { align-self: stretch; background: #fff; border: 1px solid #e4e5e0; border-radius: 12px; padding: 10px 12px; }
+.draco-missions h5 { font-size: 12px; text-transform: uppercase; letter-spacing: .4px; color: #6c7268; margin: 0 0 6px; }
+.draco-missions label { display: block; font-size: 12px; font-weight: 600; color: #6c7268; margin: 8px 0 3px; }
+.draco-missions select, .draco-missions input, .draco-missions textarea {
+  width: 100%; box-sizing: border-box; border: 1px solid #d6d8d1; border-radius: 8px;
+  padding: 7px 9px; font: inherit; font-size: 13px; background: #fff;
+}
+.draco-missions .btns { display: flex; gap: 7px; margin-top: 10px; }
+.draco-missions .btns button { border: 0; border-radius: 8px; padding: 6px 11px; font: 600 12.5px system-ui; cursor: pointer; background: #eef0ea; }
+.draco-missions .btns button.go { background: #7c5cd6; color: #fff; }
+.draco-missions .m-liste { margin-top: 12px; display: flex; flex-direction: column; gap: 8px; }
+.draco-missions .etat-source { color: #6c7268; font-size: 12.5px; }
+.draco-missions .m-item { border: 1px solid #e4e5e0; border-radius: 10px; padding: 8px 10px; }
+.draco-missions .m-entete { display: flex; justify-content: space-between; gap: 8px; align-items: baseline; }
+.draco-missions .m-statut { font-size: 11.5px; font-weight: 700; color: #6c7268; white-space: nowrap; }
+.draco-missions .m-statut.st-succeeded { color: #2ea36b; }
+.draco-missions .m-statut.st-failed { color: #cf4b32; }
+.draco-missions .m-statut.st-running, .draco-missions .m-statut.st-paused_question { color: #9a6a1c; }
+.draco-missions .m-meta { font-size: 12px; color: #6c7268; }
+.draco-missions .m-rapport { font-size: 12.5px; margin-top: 5px; white-space: pre-wrap; word-wrap: break-word; }
+.draco-missions .m-annuler { margin-top: 6px; border: 0; border-radius: 7px; padding: 4px 9px; font: 600 12px system-ui; cursor: pointer; background: #f6e3de; color: #a03a28; }

static/js/draco-panneau.js

@@ -1,12 +1,16 @@
-/* Panneau Spark — branchement au service d'agents (Fusion, jalons J1-J2).
+/* Panneau Spark — branchement au service d'agents (Fusion, J1 → J5).
  *
  * Parle à l'API du service d'agents (contrat de dracodev-commons) :
  *   GET  /api/v1/me               — identité (cookie draco_session)
  *   POST /api/v1/chat             — conversation réelle du noyau (J2) :
  *                                   LLM DeepSeek + outils MCP des apps
  *   GET  /api/v1/conversations/…  — historique de la conversation
+ *   GET  /api/v1/executors       — registre (noyau, sous-agents J3,
+ *                                   externes J4 : état de configuration)
+ *   POST /api/v1/missions         — missions longues (J5) : lancement,
+ *                                   suivi, rapport, annulation
  * États honnêtes : service injoignable / session non reconnue / LLM non
- * configuré sont affichés tels quels, jamais masqués. */
+ * configuré / exécuteur non configuré sont affichés tels quels. */
 (function () {
   "use strict";
   var API = "https://agent.dracodev.net";
@@ -37,12 +41,13 @@
       '<div class="draco-panneau-outils">' +
       '  <button type="button" data-outil="aujourdhui">☀ Aujourd\'hui</button>' +
       '  <button type="button" data-outil="approbations">Approbations</button>' +
+      '  <button type="button" data-outil="missions">🚀 Missions</button>' +
       '</div>' +
       '<div class="draco-panneau-msgs"></div>' +
       '<div class="draco-panneau-ft"><form class="draco-panneau-form">' +
       '  <input type="text" placeholder="Écrire à Spark…" autocomplete="off" aria-label="Message à Spark">' +
       '  <button type="submit">Envoyer</button></form>' +
-      '  <div class="draco-panneau-note">Jalon J2 : conversation réelle — Spark peut lire tes tâches et tes cartes via les outils des apps ; toute écriture passe par une approbation.</div>' +
+      '  <div class="draco-panneau-note">Conversation réelle, sous-agents (J3) et missions longues (J5) vers les exécuteurs configurés ; toute écriture dans les apps passe par une approbation.</div>' +
       '</div>';
     document.body.appendChild(root);
     msgsEl = root.querySelector(".draco-panneau-msgs");
@@ -52,6 +57,7 @@
     root.querySelector(".fermer").addEventListener("click", fermer);
     root.querySelector('[data-outil="aujourdhui"]').addEventListener("click", chargerAujourdhui);
     root.querySelector('[data-outil="approbations"]').addEventListener("click", chargerApprobations);
+    root.querySelector('[data-outil="missions"]').addEventListener("click", ouvrirMissions);
     root.querySelector("form").addEventListener("submit", envoyer);
     document.addEventListener("keydown", function (ev) {
       if (ev.key === "Escape" && root.classList.contains("open")) fermer();
@@ -177,6 +183,113 @@
       .catch(function () { ajouterMsg("sys", "La décision n'a pas pu être envoyée (service injoignable ?)."); });
   }
 
+  /* ── Missions longues (J5) ───────────────────────────────────
+   * Sélecteur d'exécuteur alimenté par le registre du service :
+   * les externes non configurés sont montrés mais désactivés —
+   * jamais un lancement qui simule. La liste se rafraîchit à
+   * l'ouverture et après chaque lancement/annulation. */
+  var STATUTS_MISSION = {
+    queued: "En file", running: "En cours…", paused_question: "Question en attente",
+    succeeded: "Terminée", failed: "Échouée", cancelled: "Annulée"
+  };
+
+  function ouvrirMissions() {
+    var bloc = document.createElement("div");
+    bloc.className = "draco-missions";
+    bloc.innerHTML =
+      "<h5>Missions longues</h5>" +
+      "<label>Exécuteur</label><select class='m-exec'><option>Chargement…</option></select>" +
+      "<label>Titre</label><input type='text' class='m-titre' placeholder='Ex. Veille des projets du matin'>" +
+      "<label>Consigne</label><textarea class='m-prompt' rows='3' placeholder='Ce que l\u2019exécuteur doit faire…'></textarea>" +
+      "<label>Carte Kanbante liée (n°, optionnel)</label><input type='number' class='m-carte' min='1' placeholder='—'>" +
+      "<div class='btns'><button type='button' class='go'>Lancer la mission</button>" +
+      "<button type='button' class='rafraichir'>Rafraîchir la liste</button></div>" +
+      "<div class='m-liste'><div class='etat-source'>Chargement des missions…</div></div>";
+    msgsEl.appendChild(bloc);
+    msgsEl.scrollTop = msgsEl.scrollHeight;
+    fetch(API + "/api/v1/executors", { credentials: "include" })
+      .then(function (r) { if (!r.ok) throw new Error("HTTP " + r.status); return r.json(); })
+      .then(function (d) {
+        var sel = bloc.querySelector(".m-exec");
+        sel.innerHTML = "";
+        d.executors.forEach(function (e) {
+          if (e.family !== "sous-agent" && e.family !== "externe") return;
+          var opt = document.createElement("option");
+          opt.value = e.id;
+          opt.textContent = e.name + (e.family === "sous-agent" ? " (sous-agent)" : "") +
+            (e.status === "non_configure" ? " — non configuré" : "");
+          if (e.status === "non_configure") opt.disabled = true;
+          sel.appendChild(opt);
+        });
+        if (!sel.options.length) sel.innerHTML = "<option value=''>Aucun exécuteur lançable</option>";
+      })
+      .catch(function () { bloc.querySelector(".m-exec").innerHTML = "<option value=''>Registre injoignable</option>"; });
+    bloc.querySelector(".go").addEventListener("click", function () { lancerMission(bloc); });
+    bloc.querySelector(".rafraichir").addEventListener("click", function () { chargerMissions(bloc); });
+    chargerMissions(bloc);
+  }
+
+  function chargerMissions(bloc) {
+    var zone = bloc.querySelector(".m-liste");
+    fetch(API + "/api/v1/missions", { credentials: "include" })
+      .then(function (r) { if (!r.ok) throw new Error("HTTP " + r.status); return r.json(); })
+      .then(function (d) {
+        if (!d.missions.length) { zone.innerHTML = "<div class='etat-source'>Aucune mission pour le moment.</div>"; return; }
+        zone.innerHTML = "";
+        d.missions.slice(0, 10).forEach(function (m) {
+          var ligne = document.createElement("div");
+          ligne.className = "m-item";
+          var rapport = m.result ? "<div class='m-rapport'>" + esc(String(m.result).slice(0, 700)) + "</div>" : "";
+          ligne.innerHTML = "<div class='m-entete'><b>" + esc(m.title) + "</b>" +
+            "<span class='m-statut st-" + esc(m.status) + "'>" + esc(STATUTS_MISSION[m.status] || m.status) + "</span></div>" +
+            "<div class='m-meta'>" + esc(m.executor) +
+            (m.meta && m.meta.duree_s ? " · " + esc(m.meta.duree_s) + " s" : "") +
+            (m.meta && m.meta.cout ? " · coût : " + esc(m.meta.cout) : "") + "</div>" + rapport;
+          if (m.status === "queued" || m.status === "running" || m.status === "paused_question") {
+            var btn = document.createElement("button");
+            btn.type = "button"; btn.className = "m-annuler"; btn.textContent = "Annuler";
+            btn.addEventListener("click", function () {
+              fetch(API + "/api/v1/missions/" + m.id + "/cancel", {
+                method: "POST", credentials: "include",
+                headers: { "Content-Type": "application/json" }, body: "{}"
+              }).then(function () { chargerMissions(bloc); })
+                .catch(function () { ajouterMsg("sys", "Annulation non envoyée (service injoignable ?)."); });
+            });
+            ligne.appendChild(btn);
+          }
+          zone.appendChild(ligne);
+        });
+      })
+      .catch(function () { zone.innerHTML = "<div class='etat-source'>Missions : service injoignable.</div>"; });
+  }
+
+  function lancerMission(bloc) {
+    var executor = bloc.querySelector(".m-exec").value;
+    var titre = bloc.querySelector(".m-titre").value.trim();
+    var prompt = bloc.querySelector(".m-prompt").value.trim();
+    var carte = bloc.querySelector(".m-carte").value;
+    if (!executor) { ajouterMsg("sys", "Choisis un exécuteur configuré pour lancer une mission."); return; }
+    if (!titre || !prompt) { ajouterMsg("sys", "Mission : il faut un titre et une consigne."); return; }
+    var corps = { executor: executor, title: titre, prompt: prompt, domain: domaine() };
+    if (carte) corps.kanbante_number = parseInt(carte, 10);
+    fetch(API + "/api/v1/missions", {
+      method: "POST", credentials: "include",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify(corps)
+    })
+      .then(function (r) {
+        if (!r.ok) return r.json().catch(function () { return null; }).then(function (e) {
+          throw new Error(e && e.detail ? e.detail : "HTTP " + r.status);
+        });
+        return r.json();
+      })
+      .then(function () {
+        ajouterMsg("sys", "Mission « " + titre + " » lancée — suis-la dans la liste des missions.");
+        chargerMissions(bloc);
+      })
+      .catch(function (e) { ajouterMsg("sys", "Lancement refusé : " + e.message); });
+  }
+
   function chargerHistorique() {
     if (historiqueCharge || !convId) return;
     historiqueCharge = true;

tests/test_fusion_mcp_server.py

@@ -1,8 +1,9 @@
 """Fusion — serveur MCP Flowdeck (branchement du service d'agents).
 
-POST /mcp en lecture seule, authentifié par les jetons d'API
-personnels existants (api_tokens). Le service d'agents lit les
-collections et leurs pages au nom du propriétaire du jeton.
+POST /mcp, authentifié par les jetons d'API personnels existants
+(api_tokens). Le service d'agents lit et écrit (création/mise à
+jour de pages, création de collections — aucune suppression) au
+nom du propriétaire du jeton.
 """
 import hashlib
 import json
@@ -67,8 +68,33 @@ def test_mcp_handshake_et_outils(client, jeton):
     assert r.json()["result"]["serverInfo"]["name"] == "flowdeck"
     r = _rpc(client, jeton, 2, "tools/list")
     noms = [t["name"] for t in r.json()["result"]["tools"]]
-    assert noms == ["list_collections", "get_collection", "get_page",
-                    "search_pages", "list_repos"]
+    assert noms == ["list_workspaces", "get_workspace",
+                    "list_collections", "get_collection", "get_page",
+                    "search_pages", "list_repos", "create_page",
+                    "update_page", "create_collection"]
+
+
+def test_mcp_workspaces(client, jeton):
+    with get_conn() as conn:
+        conn.execute("INSERT OR IGNORE INTO users (id, login) VALUES (1, 'tester')")
+        cur = conn.execute(
+            "INSERT INTO workspaces (name, owner_id) VALUES ('Techno', 1)")
+        wid = cur.lastrowid
+        conn.execute(
+            "INSERT INTO pages (workspace, workspace_id, title, parent_section) "
+            "VALUES ('Techno', ?, 'Page racine', 'Private')", (wid,))
+        conn.execute(
+            "INSERT INTO pages (workspace, workspace_id, title, parent_section, deleted_at) "
+            "VALUES ('Techno', ?, 'Page corbeille', 'Private', '2026-10-11 10:00:00')", (wid,))
+        conn.commit()
+    ws = _appel(client, jeton, 70, "list_workspaces")
+    techno = [w for w in ws if w["name"] == "Techno"]
+    assert techno and techno[0]["page_count"] == 1  # la corbeille ne compte pas
+    detail = _appel(client, jeton, 71, "get_workspace", {"id": wid})
+    assert detail["workspace"]["name"] == "Techno"
+    assert [p["title"] for p in detail["pages"]] == ["Page racine"]
+    res = _appel(client, jeton, 72, "get_workspace", {"id": 99999})
+    assert "introuvable" in res["erreur"]
 
 
 def test_mcp_collections_et_pages(client, jeton, donnees):
@@ -84,3 +110,130 @@ def test_mcp_collections_et_pages(client, jeton, donnees):
     assert [p["title"] for p in res] == ["Page de cadrage"]
     res = _appel(client, jeton, 4, "get_collection", {"id": 99999})
     assert "introuvable" in res["erreur"]
+
+
+def test_mcp_create_page_puis_relecture(client, jeton, donnees):
+    creee = _appel(client, jeton, 10, "create_page", {
+        "collection_id": donnees, "title": "Page créée via MCP",
+        "icon": "file", "properties": {"statut": "à faire", "priorite": "haute"}})
+    assert creee["title"] == "Page créée via MCP"
+    assert creee["collection_id"] == donnees
+    assert creee["properties"] == {"statut": "à faire", "priorite": "haute"}
+    detail = _appel(client, jeton, 11, "get_collection", {"id": donnees})
+    titres = [p["title"] for p in detail["pages"]]
+    assert "Page créée via MCP" in titres
+    relue = [p for p in detail["pages"] if p["id"] == creee["id"]][0]
+    assert relue["properties"] == {"statut": "à faire", "priorite": "haute"}
+
+
+def test_mcp_update_page_titre_et_proprietes(client, jeton, donnees):
+    creee = _appel(client, jeton, 20, "create_page", {
+        "collection_id": donnees, "title": "Titre initial",
+        "properties": {"statut": "brouillon"}})
+    maj = _appel(client, jeton, 21, "update_page", {
+        "id": creee["id"], "title": "Titre mis à jour",
+        "properties": {"statut": "publié"}})
+    assert maj["title"] == "Titre mis à jour"
+    # properties remplace property_values_json (pas de fusion)
+    assert maj["properties"] == {"statut": "publié"}
+    relue = _appel(client, jeton, 22, "get_page", {"id": creee["id"]})
+    assert relue["title"] == "Titre mis à jour"
+    assert relue["properties"] == {"statut": "publié"}
+
+
+def test_mcp_create_collection(client, jeton):
+    creee = _appel(client, jeton, 30, "create_collection", {
+        "name": "Projet Bêta", "description": "Créée via MCP", "icon": "🧪"})
+    assert creee["name"] == "Projet Bêta"
+    assert creee["description"] == "Créée via MCP"
+    assert creee["icon"] == "🧪"
+    cols = _appel(client, jeton, 31, "list_collections")
+    beta = [c for c in cols if c["name"] == "Projet Bêta"]
+    assert beta and beta[0]["id"] == creee["id"]
+    assert beta[0]["page_count"] == 0
+    detail = _appel(client, jeton, 32, "get_collection", {"id": creee["id"]})
+    assert detail["collection"]["name"] == "Projet Bêta"
+    assert detail["pages"] == []
+
+
+def test_mcp_erreurs_ecritures(client, jeton, donnees):
+    res = _appel(client, jeton, 40, "create_page", {
+        "collection_id": 99999, "title": "Orpheline"})
+    assert "introuvable" in res["erreur"]
+    res = _appel(client, jeton, 41, "create_page", {
+        "collection_id": donnees, "title": "   "})
+    assert "erreur" in res
+    res = _appel(client, jeton, 42, "update_page", {
+        "id": 99999, "title": "Fantôme"})
+    assert "introuvable" in res["erreur"]
+    res = _appel(client, jeton, 43, "create_collection", {"name": "  "})
+    assert "erreur" in res
+
+
+def test_mcp_ecriture_sans_jeton_401(client, donnees):
+    r = _rpc(client, None, 50, "tools/call",
+             {"name": "create_page",
+              "arguments": {"collection_id": donnees, "title": "Refusée"}})
+    assert r.status_code == 401
+    r = _rpc(client, "mauvais-jeton", 51, "tools/call",
+             {"name": "create_collection", "arguments": {"name": "Refusée"}})
+    assert r.status_code == 401
+
+
+def test_mcp_client_bearer_sans_session_ni_csrf(client, jeton, donnees):
+    """Régression 7.76.1 : un vrai client MCP est machine-à-machine
+    (Bearer seul, ni session ni jeton CSRF) — exactement le service
+    d'agents. Le client de test habituel porte une session + un CSRF,
+    ce qui masquait le 403 du middleware en production."""
+    from tests.conftest import anon
+    anon(client)
+    r = _rpc(client, jeton, 60, "initialize", {})
+    assert r.status_code == 200, r.text
+    cols = _appel(client, jeton, 61, "list_collections")
+    assert any(c["name"] == "Projet Alpha" for c in cols)
+    r = _rpc(client, None, 62, "tools/list")
+    assert r.status_code == 401, r.text
+
+
+def test_mcp_perimetre_du_jeton(client, jeton, donnees):
+    """Régression 7.78.0 (cas réel de Bruno) : list_workspaces rendait
+    les 52 workspaces de la base, tous comptes confondus. Chaque jeton
+    ne voit que les workspaces de son propriétaire (ou ceux dont il
+    est membre) et les collections rattachées à ce périmètre."""
+    autre = "fd_token_autre_compte"
+    with get_conn() as conn:
+        conn.execute("INSERT OR IGNORE INTO users (id, login) VALUES (2, 'autre')")
+        conn.execute(
+            "INSERT INTO api_tokens (user_id, name, token_hash, token_prefix, revoked) "
+            "VALUES (2, 'autre', ?, ?, 0)",
+            (hashlib.sha256(autre.encode()).hexdigest(), autre[:12]))
+        cur = conn.execute(
+            "INSERT INTO workspaces (name, owner_id) VALUES ('Espace de lautre', 2)")
+        wid_autre = cur.lastrowid
+        cur = conn.execute(
+            "INSERT INTO collections (name, description, icon, workspace_id) "
+            "VALUES ('Base de lautre', '', '📋', ?)", (wid_autre,))
+        base_autre = cur.lastrowid
+        conn.commit()
+    # Bruno (jeton principal) ne voit ni le workspace ni la base de l'autre.
+    noms = [w["name"] for w in _appel(client, jeton, 80, "list_workspaces")]
+    assert "Espace de lautre" not in noms
+    res = _appel(client, jeton, 81, "get_workspace", {"id": wid_autre})
+    assert "introuvable" in res["erreur"]
+    cols = [c["name"] for c in _appel(client, jeton, 82, "list_collections")]
+    assert "Base de lautre" not in cols and "Projet Alpha" in cols
+    res = _appel(client, jeton, 83, "get_collection", {"id": base_autre})
+    assert "introuvable" in res["erreur"]
+    # Et l'autre ne voit pas le workspace de Bruno, mais voit le sien.
+    noms2 = [w["name"] for w in _appel(client, autre, 84, "list_workspaces")]
+    assert noms2 == ["Espace de lautre"]
+
+
+def test_mcp_info_get(client, jeton):
+    r = client.get("/mcp")
+    assert r.status_code == 200
+    infos = r.json()
+    assert infos["read_only"] is False
+    assert "create_page" in infos["tools"]
+    assert "update_page" in infos["tools"]
+    assert "create_collection" in infos["tools"]

tests/test_trash_api.py

@@ -32,6 +32,32 @@ def _row(page_id):
         ).fetchone()
 
 
+def test_permanent_delete_page_referenced_by_favorites_and_recents(client):
+    """Régression 7.77.0 (cas réel de Bruno, 2026-10-22) : une page
+    réelle — ouverte (recents) et/ou favorite — ne pouvait plus être
+    supprimée définitivement : favorites.page_id et recents.page_id
+    référencent pages(id) sans CASCADE, PRAGMA foreign_keys=ON →
+    IntegrityError → 500 « Delete failed », et Empty Trash (une seule
+    transaction) échouait en bloc. Les pages synthétiques des anciens
+    tests n'avaient ni favori ni récent : elles passaient."""
+    from app.db import get_conn
+
+    login_test_client(client)
+    pid = _mk_page(title="Page réelle de Bruno")
+    with get_conn() as conn:
+        conn.execute("INSERT INTO favorites (user_id, page_id, position) VALUES (1, ?, 0)", (pid,))
+        conn.execute("INSERT INTO recents (user_id, page_id, workspace) VALUES (1, ?, 'x')", (pid,))
+        conn.commit()
+    r = client.post(f"/api/pages/{pid}/trash")
+    assert r.status_code == 200
+    r = client.delete(f"/board/api/trash/{pid}")
+    assert r.status_code == 200, r.text
+    assert _row(pid) is None
+    with get_conn() as conn:
+        assert conn.execute("SELECT COUNT(*) FROM favorites WHERE page_id=?", (pid,)).fetchone()[0] == 0
+        assert conn.execute("SELECT COUNT(*) FROM recents WHERE page_id=?", (pid,)).fetchone()[0] == 0
+
+
 def test_trash_requires_session(client):
     pid = _mk_page()
     anon_csrf(client)  # anonyme mais CSRF valide → on veut le 401, pas le 403