Compare commits
10 Commits
fix/m4-str
...
feature/m7
| Author | SHA1 | Date | |
|---|---|---|---|
|
ebbe39f1f0
|
|||
|
958bb3ec5d
|
|||
|
1d26d49e74
|
|||
|
29270427ef
|
|||
|
f9a1a5aa43
|
|||
|
4ec827a945
|
|||
|
7fdca2ca55
|
|||
|
344745d725
|
|||
|
bfae1ca87f
|
|||
|
6d1a7a649f
|
@@ -22,7 +22,10 @@ SYNC_PAST_DAYS=7
|
||||
SYNC_FUTURE_DAYS=30
|
||||
|
||||
# --- Agenda théorique ---
|
||||
THEORETICAL_AGENDA_PATH=./data/theoretical.ics
|
||||
THEORETICAL_AGENDA_PATH=./data/theoretical.json
|
||||
SCHOOL_HOLIDAYS_PATH=./data/school_holidays.json
|
||||
THEORETICAL_WEEK_ANCHOR_DATE=2026-09-01
|
||||
THEORETICAL_WEEK_ANCHOR_TYPE=even
|
||||
|
||||
# --- XMPP ---
|
||||
XMPP_ENABLED=false
|
||||
|
||||
@@ -26,7 +26,7 @@ repos:
|
||||
name: mypy
|
||||
entry: mypy
|
||||
language: python
|
||||
additional_dependencies: ["mypy>=1.10.0", "pydantic>=2.0.0", "pydantic-settings>=2.0.0", "pytest>=8.0.0", "types-requests>=2.31.0", "icalendar>=5.0.0", "pronotepy>=2.15.0", "responses>=0.25.0", "pytest-mock>=3.10.0"]
|
||||
additional_dependencies: ["mypy>=1.10.0", "pydantic>=2.0.0", "pydantic-settings>=2.0.0", "pytest>=8.0.0", "types-requests>=2.31.0", "icalendar>=5.0.0", "pronotepy>=2.15.0", "responses>=0.25.0", "pytest-mock>=3.10.0", "feedparser>=6.0.0", "caldav>=1.3.0"]
|
||||
types: [python]
|
||||
pass_filenames: true
|
||||
|
||||
|
||||
@@ -140,10 +140,10 @@
|
||||
"filename": "GUIDE_DEV_PYTHON.md",
|
||||
"hashed_secret": "90bd1b48e958257948487b90bee080ba5ed00caa",
|
||||
"is_verified": true,
|
||||
"line_number": 4893,
|
||||
"line_number": 5034,
|
||||
"is_secret": false
|
||||
}
|
||||
]
|
||||
},
|
||||
"generated_at": "2026-09-06T14:37:44Z"
|
||||
"generated_at": "2026-09-06T22:00:48Z"
|
||||
}
|
||||
|
||||
1197
GUIDE_DEV_PYTHON.md
1197
GUIDE_DEV_PYTHON.md
File diff suppressed because it is too large
Load Diff
46
TODO.md
46
TODO.md
@@ -97,11 +97,11 @@ Récupérer et normaliser l'agenda, les devoirs et les messages Pronote, avec re
|
||||
|
||||
Récupérer le flux RSS du blog du collège, parser et dédupliquer les articles.
|
||||
|
||||
- [ ] Créer `sources/blog/rss.py` : `BlogRSSClient.fetch_and_parse(known_guids)` avec `feedparser` (§5 bis.7.1).
|
||||
- [ ] Parser les dates (RFC 822 / ISO 8601) et convertir le HTML en texte brut (`BeautifulSoup` + `html.unescape`).
|
||||
- [ ] Créer `sources/blog/state.py` (ou `sync/blog_state.py`) : `BlogRSSState` (JSON : `known_guids`, `etag`, `last_modified`).
|
||||
- [ ] Implémenter la déduplication par GUID et le cache HTTP (`If-Modified-Since` / `etag`).
|
||||
- [ ] Gérer un flux invalide (`bozo`) et les exceptions sans fuite de secret (retour `[]`/warning).
|
||||
- [x] Créer `sources/blog/rss.py` : `BlogRSSClient.fetch_and_parse(known_guids)` avec `feedparser` (§5 bis.7.1).
|
||||
- [x] Parser les dates (RFC 822 / ISO 8601) et convertir le HTML en texte brut (`BeautifulSoup` + `html.unescape`).
|
||||
- [x] Créer `sources/blog/state.py` (ou `sync/blog_state.py`) : `BlogRSSState` (JSON : `known_guids`, `etag`, `last_modified`).
|
||||
- [x] Implémenter la déduplication par GUID et le cache HTTP (`If-Modified-Since` / `etag`).
|
||||
- [x] Gérer un flux invalide (`bozo`) et les exceptions sans fuite de secret (retour `[]`/warning).
|
||||
|
||||
### Critères d'acceptation
|
||||
- `fetch_and_parse` renvoie les nouveaux articles triés par date décroissante, sans doublons.
|
||||
@@ -112,16 +112,23 @@ Récupérer le flux RSS du blog du collège, parser et dédupliquer les articles
|
||||
|
||||
## M6. Source agenda théorique — Priorité : Moyenne
|
||||
|
||||
Lire l'agenda théorique (iCal ou CSV) via une interface de provider extensible.
|
||||
Lire l'agenda théorique (JSON) via une interface de provider extensible, avec gestion de la parité des semaines (paire/impaire) et des vacances scolaires.
|
||||
|
||||
- [ ] Créer `sources/theoretical/provider.py` : protocole `TheoreticalAgendaProvider` (§8.2).
|
||||
- [ ] Créer `sources/theoretical/file.py` : lecture fichier iCal/CSV → liste de `TheoreticalLesson` (§8.3).
|
||||
- [ ] Normaliser les matières et créneaux pour le matching déterministe.
|
||||
- [ ] Supporter les deux formats (iCal et CSV) derrière la même interface.
|
||||
- [x] Créer `sources/theoretical/provider.py` : protocole `TheoreticalAgendaProvider` (§8.2).
|
||||
- [x] Créer `sources/theoretical/file.py` : parser JSON → liste de `TheoreticalLesson` avec filtrage par parité de semaine (paire/impaire/toutes).
|
||||
- [x] Créer `sources/theoretical/parity.py` : service `WeekParityService` déterminant la parité d'une date à partir d'une date de référence configurée.
|
||||
- [x] Créer `sources/theoretical/holidays.py` : service `SchoolHolidayCalendar` lisant un fichier JSON de vacances scolaires (zone A) et exposant `is_holiday(date)`.
|
||||
- [x] Implémenter le provider JSON : filtrage par parité + vacances, génération d'identifiants déterministes incluant le type de semaine.
|
||||
- [x] Ajouter la configuration : `SCHOOL_HOLIDAYS_PATH`, `THEORETICAL_WEEK_ANCHOR_DATE`, `THEORETICAL_WEEK_ANCHOR_TYPE` dans `AppSettings`.
|
||||
- [x] Normaliser les matières et créneaux pour le matching déterministe.
|
||||
- [x] Créer les fixtures : `tests/fixtures/theoretical.json` et `tests/fixtures/school_holidays.json`.
|
||||
|
||||
### Critères d'acceptation
|
||||
- `file.py` lit `tests/fixtures/theoretical.ics` et `theoretical.csv` en `TheoreticalLesson`.
|
||||
- `file.py` lit `tests/fixtures/theoretical.json` en `TheoreticalLesson` avec filtrage par parité.
|
||||
- Le provider renvoie une liste vide pendant les vacances scolaires.
|
||||
- Le provider renvoie une liste stable et déterministe (tri par identifiant).
|
||||
- Les identifiants sont distincts pour des leçons de parité différente sur le même créneau.
|
||||
- Une configuration incomplète (ancre de parité manquante alors que des leçons `even`/`odd` existent) produit une erreur explicite.
|
||||
|
||||
---
|
||||
|
||||
@@ -129,19 +136,20 @@ Lire l'agenda théorique (iCal ou CSV) via une interface de provider extensible.
|
||||
|
||||
Synchroniser différentiellement les événements Pronote vers le calendrier CalDAV, de façon idempotente.
|
||||
|
||||
- [ ] Créer `sync/caldav.py` : `CalDAVClient` (connexion, liste/ajout/MAJ/suppression, marqueur `X-PRONOTE-SYNC-MANAGED: v1`).
|
||||
- [ ] Créer `sync/state.py` : état local de sync (SQLite ou JSON) assurant l'idempotence (UID connus).
|
||||
- [ ] Calculer le `CalDAVSyncPlan` (to_add / to_update / to_remove) par UID stable.
|
||||
- [ ] Avant de figer le plan de sync, vérifier sur fixture anonymisée que le même cours provenant d'iCal et de `pronotepy` possède le même identifiant canonique ; corriger la normalisation à la frontière des sources si nécessaire.
|
||||
- [ ] Créer `sync/caldav.py` : passerelle CalDAV isolant la bibliothèque `caldav>=1.3.0` (connexion via `DAVClient`, résolution du calendrier via `calendar_path`, récupération/ajout/MAJ/suppression des événements, marqueur `X-PRONOTE-SYNC-MANAGED: v1`).
|
||||
- [ ] Calculer le `CalDAVSyncPlan` (to_add / to_update / to_remove) par UID stable, explicitement avant l'exécution de la sync.
|
||||
- [ ] Implémenter l'exécution du plan : ajout, mise à jour (si modifié), suppression (si absent). En mode `dry_run`, loguer le plan sans écrire.
|
||||
- [ ] Vérifier sur fixture anonymisée que le même cours provenant d'iCal et de `pronotepy` possède le même identifiant canonique ; corriger la normalisation des UID dans `sources/pronote/client.py` à la frontière des sources si nécessaire.
|
||||
- [ ] Implémenter la sync différentielle : conserver les cours annulés (`STATUS:CANCELLED`), ne pas supprimer.
|
||||
- [ ] Garantir l'idempotence (2 exécutions identiques → même `CalDAVSyncResult`).
|
||||
- [ ] Réutiliser `BlogRSSState` pour l'état blog si pertinent (sinon `sync/blog_state.py`).
|
||||
- [ ] Garantir l'idempotence (2 exécutions identiques → même `CalDAVSyncResult`), sans état local persistant (scan du calendrier distant).
|
||||
- [ ] Ne jamais modifier ou supprimer les événements non marqués `X-PRONOTE-SYNC-MANAGED`.
|
||||
|
||||
### Critères d'acceptation
|
||||
- Le plan de sync est correctement calculé (PronoteData vs état local).
|
||||
- Le plan de sync est correctement calculé (données Pronote vs événements distants gérés).
|
||||
- Un changement de source iCal ↔ `pronotepy` ne crée ni doublon ni suppression/ajout artificiel pour un cours équivalent.
|
||||
- Un run dry-run n'écrit rien ; deux runs identiques donnent un résultat identique.
|
||||
- Les événements annulés restent (`STATUS:CANCELLED`) et sont marqués `MANAGED`.
|
||||
- Les événements non marqués ne sont jamais modifiés ni supprimés.
|
||||
|
||||
---
|
||||
|
||||
@@ -236,7 +244,7 @@ Exposer le lancement du pipeline via une interface en ligne de commande.
|
||||
|
||||
Couvrir l'ensemble du code par des tests sans réseau, avec fixtures anonymisées, jusqu'à ≥ 90 %.
|
||||
|
||||
- [ ] Créer `tests/fixtures/` : `pronote-4e.ics`, `pronote-6e.ics`, `theoretical.ics`, `theoretical.csv`, `blog_rss.xml` (anonymisés, sans `icalsecurise`).
|
||||
- [ ] Créer `tests/fixtures/` : `pronote-4e.ics`, `pronote-6e.ics`, `theoretical.json`, `school_holidays.json`, `blog_rss.xml` (anonymisés, sans `icalsecurise`).
|
||||
- [ ] Créer `tests/conftest.py` : fixtures partagées (sample_lesson, sample_cancelled_lesson, sample_homework, sample_school_event, sample_message, sample_pronote_data…).
|
||||
- [ ] Écrire `tests/unit/` : `test_models`, `test_parsing` (iCal), `test_uid`, `test_redaction`, `test_diff`, `test_sync`.
|
||||
- [ ] Couvrir les régressions M4 : signature réelle de `ParentClient`, ENT autorisé/inconnu, erreur vs résultat vide, `STATUS:CANCELLED` sans catégorie, plusieurs devoirs à la même date, filtrage `pronotepy` sur la date cible et stabilité d'identité entre sources.
|
||||
|
||||
@@ -8,6 +8,7 @@ depuis les variables d'environnement (préfixées par groupe) et le fichier
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from datetime import date
|
||||
from typing import Literal
|
||||
|
||||
from pydantic import Field, SecretStr, field_serializer
|
||||
@@ -114,7 +115,10 @@ class AppSettings(BaseSettings):
|
||||
"""Paramètres généraux de l'application, sans préfixe d'environnement.
|
||||
|
||||
Contient notamment la fenêtre de synchronisation en jours
|
||||
(``SYNC_PAST_DAYS`` / ``SYNC_FUTURE_DAYS``).
|
||||
(``SYNC_PAST_DAYS`` / ``SYNC_FUTURE_DAYS``) et la configuration de
|
||||
l'agenda théorique (``THEORETICAL_AGENDA_PATH``,
|
||||
``THEORETICAL_WEEK_ANCHOR_DATE``, ``THEORETICAL_WEEK_ANCHOR_TYPE`` ainsi
|
||||
que ``SCHOOL_HOLIDAYS_PATH`` pour les vacances scolaires).
|
||||
"""
|
||||
|
||||
model_config = SettingsConfigDict(env_file=".env", extra="ignore")
|
||||
@@ -122,6 +126,9 @@ class AppSettings(BaseSettings):
|
||||
dry_run: bool = False
|
||||
log_level: str = "INFO"
|
||||
theoretical_agenda_path: str | None = None
|
||||
school_holidays_path: str | None = None
|
||||
theoretical_week_anchor_date: date | None = None
|
||||
theoretical_week_anchor_type: Literal["even", "odd"] | None = None
|
||||
sync_past_days: int = 7
|
||||
sync_future_days: int = 30
|
||||
|
||||
|
||||
@@ -0,0 +1,21 @@
|
||||
"""Source du blog du collège : récupération et suivi du flux RSS.
|
||||
|
||||
Ce package expose l'API publique du connecteur du blog du collège :
|
||||
|
||||
- :class:`BlogRSSClient` (:mod:`pronote_sync.sources.blog.rss`) : télécharge
|
||||
et parse le flux RSS, déduplique les entrées par GUID et renvoie les
|
||||
nouveaux articles dans un :class:`BlogRSSFetchResult`.
|
||||
- :class:`BlogRSSFetchResult` (:mod:`pronote_sync.sources.blog.result`) :
|
||||
type de retour figé d'une récupération : nouveaux articles, en-têtes
|
||||
HTTP de cache (``ETag``/``Last-Modified``) et indicateur ``304 Not
|
||||
Modified``.
|
||||
- :class:`BlogRSSState` (:mod:`pronote_sync.sources.blog.state`) : état
|
||||
local persistant (GUID connus et en-têtes de cache) pour la
|
||||
déduplication et les requêtes conditionnelles.
|
||||
"""
|
||||
|
||||
from pronote_sync.sources.blog.result import BlogRSSFetchResult
|
||||
from pronote_sync.sources.blog.rss import BlogRSSClient
|
||||
from pronote_sync.sources.blog.state import BlogRSSState
|
||||
|
||||
__all__ = ["BlogRSSClient", "BlogRSSFetchResult", "BlogRSSState"]
|
||||
|
||||
54
pronote_sync/sources/blog/result.py
Normal file
54
pronote_sync/sources/blog/result.py
Normal file
@@ -0,0 +1,54 @@
|
||||
"""Résultat de la récupération du flux RSS du blog du collège.
|
||||
|
||||
Ce module définit :class:`BlogRSSFetchResult`, le type de retour figé du
|
||||
client RSS du blog (:mod:`pronote_sync.sources.blog`).
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from pydantic import BaseModel, ConfigDict, Field
|
||||
|
||||
from pronote_sync.models.blog import BlogArticle
|
||||
|
||||
|
||||
class BlogRSSFetchResult(BaseModel):
|
||||
"""Résultat d'une récupération du flux RSS du blog du collège.
|
||||
|
||||
Modèle figé (``frozen``) : les instances sont immuables après création.
|
||||
Il regroupe les nouveaux articles, triés par date de publication
|
||||
décroissante puis par identifiant croissant, ainsi que les en-têtes
|
||||
HTTP utiles aux requêtes conditionnelles (``ETag`` et
|
||||
``Last-Modified``).
|
||||
|
||||
:param articles: Nouveaux articles absents de ``known_guids``, triés
|
||||
par date de publication décroissante puis par identifiant
|
||||
croissant. Vide par défaut.
|
||||
:param etag: Valeur de l'en-tête ``ETag`` de la réponse RSS, si elle
|
||||
est disponible. ``None`` par défaut.
|
||||
:param last_modified: Valeur de l'en-tête ``Last-Modified`` de la
|
||||
réponse RSS, si elle est disponible. ``None`` par défaut.
|
||||
:param not_modified: Vaut ``True`` si le serveur a répondu avec le
|
||||
statut ``304 Not Modified``, ``False`` sinon.
|
||||
"""
|
||||
|
||||
model_config = ConfigDict(frozen=True)
|
||||
|
||||
articles: tuple[BlogArticle, ...] = Field(
|
||||
default=(),
|
||||
description=(
|
||||
"Nouveaux articles absents de known_guids, triés par date de "
|
||||
"publication décroissante puis par identifiant croissant"
|
||||
),
|
||||
)
|
||||
etag: str | None = Field(
|
||||
default=None,
|
||||
description="Valeur de l'en-tête ETag de la réponse RSS, si disponible",
|
||||
)
|
||||
last_modified: str | None = Field(
|
||||
default=None,
|
||||
description="Valeur de l'en-tête Last-Modified de la réponse RSS, si disponible",
|
||||
)
|
||||
not_modified: bool = Field(
|
||||
default=False,
|
||||
description="Vaut True si le serveur a répondu 304 Not Modified",
|
||||
)
|
||||
293
pronote_sync/sources/blog/rss.py
Normal file
293
pronote_sync/sources/blog/rss.py
Normal file
@@ -0,0 +1,293 @@
|
||||
"""Client de récupération et de parsing du flux RSS du blog du collège.
|
||||
|
||||
Ce module définit :class:`BlogRSSClient`, un client sans état qui
|
||||
télécharge le flux RSS du blog via ``requests``, le parse via
|
||||
``feedparser``, déduplique les entrées par GUID et les convertit en
|
||||
:class:`~pronote_sync.models.blog.BlogArticle`.
|
||||
|
||||
Le résultat d'une récupération est un
|
||||
:class:`~pronote_sync.sources.blog.result.BlogRSSFetchResult` : les
|
||||
nouveaux articles (triés par date de publication décroissante, puis par
|
||||
identifiant croissant) accompagnés des en-têtes HTTP ``ETag`` et
|
||||
``Last-Modified`` de la réponse. Toute erreur de récupération ou de
|
||||
parsing est journalisée (URL et exception rédigées) puis dégradée en
|
||||
résultat vide : une liste vide est un succès valide, pas une panne.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import logging
|
||||
import re
|
||||
from datetime import UTC, datetime
|
||||
from html import unescape
|
||||
|
||||
import feedparser # type: ignore[import-untyped]
|
||||
import requests
|
||||
from bs4 import BeautifulSoup
|
||||
|
||||
from pronote_sync.models.blog import BlogArticle
|
||||
from pronote_sync.sources.blog.result import BlogRSSFetchResult
|
||||
from pronote_sync.utils.redaction import redact_exception, redact_url
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class BlogRSSClient:
|
||||
"""Client de récupération et de parsing du flux RSS du blog du collège.
|
||||
|
||||
Client sans état : aucune E/S n'est effectuée à la construction et
|
||||
aucune donnée n'est conservée entre deux appels à
|
||||
:meth:`fetch_and_parse`. Toute erreur de récupération ou de parsing
|
||||
est journalisée puis dégradée en résultat vide.
|
||||
|
||||
:param rss_url: URL du flux RSS du blog du collège.
|
||||
:param timeout: Timeout HTTP en secondes (défaut : 20).
|
||||
"""
|
||||
|
||||
def __init__(self, rss_url: str, timeout: int = 20) -> None:
|
||||
"""Initialise le client RSS du blog.
|
||||
|
||||
Aucune opération d'E/S n'est réalisée ici : le téléchargement et
|
||||
le parsing n'ont lieu qu'à l'appel de :meth:`fetch_and_parse`.
|
||||
|
||||
:param rss_url: URL du flux RSS du blog du collège.
|
||||
:param timeout: Timeout HTTP en secondes (défaut : 20).
|
||||
"""
|
||||
self.rss_url = rss_url
|
||||
self.timeout = timeout
|
||||
|
||||
def fetch_and_parse(
|
||||
self,
|
||||
*,
|
||||
known_guids: frozenset[str] | None = None,
|
||||
etag: str | None = None,
|
||||
last_modified: str | None = None,
|
||||
) -> BlogRSSFetchResult:
|
||||
"""Télécharge et parse le flux RSS du blog en nouveaux articles.
|
||||
|
||||
Le flux est téléchargé par ``requests`` avec les en-têtes de
|
||||
requête conditionnelle fournis (``ETag``/``Last-Modified``), puis
|
||||
parsé par ``feedparser``. Si le serveur répond ``304 Not Modified``,
|
||||
le résultat est vide avec
|
||||
``not_modified=True`` et les en-têtes passés en entrée sont
|
||||
restitués tels quels. Chaque entrée est dédupliquée par GUID,
|
||||
convertie en :class:`~pronote_sync.models.blog.BlogArticle`, puis
|
||||
l'ensemble est trié par date de publication décroissante puis par
|
||||
identifiant croissant. Toute erreur est journalisée (URL et
|
||||
exception rédigées) et dégradée en résultat vide : aucune
|
||||
exception n'est propagée.
|
||||
|
||||
:param known_guids: Ensemble des GUID d'articles déjà traités ; les
|
||||
entrées correspondantes sont ignorées. ``None`` pour tout
|
||||
conserver (défaut).
|
||||
:param etag: Valeur de l'en-tête ``ETag`` mémorisée pour la requête
|
||||
conditionnelle, ou ``None`` (défaut).
|
||||
:param last_modified: Valeur de l'en-tête ``Last-Modified`` mémorisée
|
||||
pour la requête conditionnelle, ou ``None`` (défaut).
|
||||
:return: Résultat de la récupération : nouveaux articles (tuple vide
|
||||
si aucun nouvel article, réponse ``304`` ou erreur), en-têtes de
|
||||
cache de la réponse et indicateur ``not_modified``.
|
||||
:rtype: :class:`~pronote_sync.sources.blog.result.BlogRSSFetchResult`
|
||||
"""
|
||||
try:
|
||||
# Téléchargement HTTP explicite via requests : feedparser 6.x
|
||||
# n'accepte aucun paramètre de transport ; les requêtes
|
||||
# conditionnelles sont gérées avec les en-têtes HTTP standards.
|
||||
headers: dict[str, str] = {"user-agent": "pronote-sync"}
|
||||
if etag is not None:
|
||||
headers["If-None-Match"] = etag
|
||||
if last_modified is not None:
|
||||
headers["If-Modified-Since"] = last_modified
|
||||
response = requests.get(self.rss_url, headers=headers, timeout=self.timeout)
|
||||
|
||||
# Réponse 304 Not Modified : rien n'a changé, on restitue les
|
||||
# en-têtes mémorisés tels quels pour les conserver.
|
||||
if response.status_code == 304:
|
||||
return BlogRSSFetchResult(
|
||||
articles=(),
|
||||
etag=etag,
|
||||
last_modified=last_modified,
|
||||
not_modified=True,
|
||||
)
|
||||
|
||||
# Les statuts 4xx/5xx lèvent une exception HTTP, attrapée par le
|
||||
# gestionnaire général et dégradée en résultat vide.
|
||||
response.raise_for_status()
|
||||
|
||||
response_etag: str | None = response.headers.get("ETag", None)
|
||||
if response_etag is None:
|
||||
response_etag = response.headers.get("etag", None)
|
||||
response_last_modified: str | None = response.headers.get("Last-Modified", None)
|
||||
if response_last_modified is None:
|
||||
response_last_modified = response.headers.get("last-modified", None)
|
||||
|
||||
# feedparser ne reçoit que le contenu brut de la réponse.
|
||||
feed = feedparser.parse(response.content)
|
||||
|
||||
# Flux invalide (XML malformé, etc.) : avertissement puis résultat
|
||||
# vide, sans propager l'exception brute. Les validateurs de cache
|
||||
# d'entrée sont conservés : on ne fait pas confiance aux en-têtes
|
||||
# d'une réponse au contenu invalide.
|
||||
if getattr(feed, "bozo", None):
|
||||
bozo_exception = getattr(feed, "bozo_exception", None)
|
||||
if bozo_exception is not None:
|
||||
logger.warning(
|
||||
"Flux RSS du blog invalide (%s), ignoré : %s",
|
||||
redact_exception(bozo_exception),
|
||||
redact_url(self.rss_url),
|
||||
)
|
||||
else:
|
||||
logger.warning(
|
||||
"Flux RSS du blog invalide, ignoré : %s",
|
||||
redact_url(self.rss_url),
|
||||
)
|
||||
return BlogRSSFetchResult(
|
||||
articles=(),
|
||||
etag=etag,
|
||||
last_modified=last_modified,
|
||||
not_modified=False,
|
||||
)
|
||||
|
||||
articles: list[BlogArticle] = []
|
||||
# Déduplication silencieuse des GUID déjà connus (exécutions
|
||||
# précédentes) et détection des doublons au sein de la réponse.
|
||||
known_set = set(known_guids) if known_guids is not None else None
|
||||
seen_in_feed: set[str] = set()
|
||||
for entry in getattr(feed, "entries", []):
|
||||
guid_source = entry.get("id") or entry.get("link")
|
||||
if not guid_source:
|
||||
logger.warning(
|
||||
"Entrée RSS sans GUID ni lien, ignorée : %s",
|
||||
redact_url(self.rss_url),
|
||||
)
|
||||
continue
|
||||
guid = str(guid_source)
|
||||
|
||||
if known_set is not None and guid in known_set:
|
||||
# Déduplication normale (GUID connu d'une exécution
|
||||
# précédente) : aucun journal n'est nécessaire.
|
||||
continue
|
||||
|
||||
if guid in seen_in_feed:
|
||||
logger.warning(
|
||||
"Entrée RSS en double dans le flux, ignorée : %s",
|
||||
redact_url(self.rss_url),
|
||||
)
|
||||
continue
|
||||
|
||||
seen_in_feed.add(guid)
|
||||
|
||||
published_at = self._parse_date(
|
||||
entry.get("published_parsed") or entry.get("pubdate_parsed")
|
||||
)
|
||||
if published_at is None:
|
||||
logger.warning(
|
||||
"Entrée RSS sans date de publication valide, ignorée : %s",
|
||||
redact_url(self.rss_url),
|
||||
)
|
||||
continue
|
||||
|
||||
updated_at = self._parse_date(entry.get("updated_parsed"))
|
||||
|
||||
raw_content = entry.get("content")
|
||||
if raw_content:
|
||||
content_html = str(raw_content[0].get("value") or "")
|
||||
else:
|
||||
content_html = str(entry.get("description") or "")
|
||||
|
||||
tags = entry.get("tags")
|
||||
category_value = tags[0].get("term") if tags else None
|
||||
if not category_value:
|
||||
category_value = entry.get("category")
|
||||
category = str(category_value) if category_value else None
|
||||
|
||||
author_value = entry.get("author")
|
||||
author = str(author_value) if author_value else None
|
||||
|
||||
title = str(entry.get("title") or guid)
|
||||
url = str(entry.get("link") or guid)
|
||||
|
||||
articles.append(
|
||||
BlogArticle(
|
||||
id=guid,
|
||||
title=title,
|
||||
url=url,
|
||||
published_at=published_at,
|
||||
updated_at=updated_at,
|
||||
category=category,
|
||||
author=author,
|
||||
content_html=content_html,
|
||||
content_text=self._html_to_text(content_html),
|
||||
)
|
||||
)
|
||||
|
||||
# Tri stable : d'abord par identifiant croissant, puis par date de
|
||||
# publication décroissante ; l'ordre par identifiant est conservé
|
||||
# entre articles de même date.
|
||||
articles.sort(key=lambda article: article.id)
|
||||
articles.sort(key=lambda article: article.published_at, reverse=True)
|
||||
|
||||
return BlogRSSFetchResult(
|
||||
articles=tuple(articles),
|
||||
etag=response_etag,
|
||||
last_modified=response_last_modified,
|
||||
not_modified=False,
|
||||
)
|
||||
except Exception as exc:
|
||||
logger.error(
|
||||
"Échec de la récupération du flux RSS du blog %s : %s",
|
||||
redact_url(self.rss_url),
|
||||
redact_exception(exc),
|
||||
)
|
||||
return BlogRSSFetchResult(
|
||||
articles=(),
|
||||
etag=etag,
|
||||
last_modified=last_modified,
|
||||
not_modified=False,
|
||||
)
|
||||
|
||||
@staticmethod
|
||||
def _parse_date(date_tuple: tuple[int, ...] | None) -> datetime | None:
|
||||
"""Convertit un tuple de date ``struct_time`` en :class:`datetime` UTC.
|
||||
|
||||
:param date_tuple: Tuple horodaté au format ``time.struct_time``
|
||||
(indices 0 à 5 : année, mois, jour, heure, minute, seconde), ou
|
||||
``None`` si absent.
|
||||
:return: Date/heure consciente du fuseau UTC, ou ``None`` si le
|
||||
tuple est absent, vide ou invalide.
|
||||
:rtype: datetime | None
|
||||
"""
|
||||
if not date_tuple:
|
||||
return None
|
||||
try:
|
||||
return datetime(
|
||||
date_tuple[0],
|
||||
date_tuple[1],
|
||||
date_tuple[2],
|
||||
date_tuple[3],
|
||||
date_tuple[4],
|
||||
date_tuple[5],
|
||||
tzinfo=UTC,
|
||||
)
|
||||
except (ValueError, IndexError):
|
||||
return None
|
||||
|
||||
@staticmethod
|
||||
def _html_to_text(html: str) -> str:
|
||||
"""Convertit du HTML en texte brut nettoyé.
|
||||
|
||||
Le HTML est parsé avec BeautifulSoup, les balises sont remplacées
|
||||
par des espaces, les entités HTML sont décodées et les suites
|
||||
d'espaces sont unifiées.
|
||||
|
||||
:param html: Contenu HTML à convertir.
|
||||
:return: Texte brut sans balises, entités décodées et espaces
|
||||
unifiés ; chaîne vide si ``html`` est vide.
|
||||
:rtype: str
|
||||
"""
|
||||
if not html:
|
||||
return ""
|
||||
soup = BeautifulSoup(html, "html.parser")
|
||||
text = soup.get_text(separator=" ", strip=True)
|
||||
text = unescape(text)
|
||||
return re.sub(r"\s+", " ", text).strip()
|
||||
174
pronote_sync/sources/blog/state.py
Normal file
174
pronote_sync/sources/blog/state.py
Normal file
@@ -0,0 +1,174 @@
|
||||
"""Gestion de l'état local du flux RSS du blog du collège.
|
||||
|
||||
Ce module définit :class:`BlogRSSState`, un gestionnaire d'état persistant
|
||||
dans un fichier JSON local (``.blog_rss_state.json`` par défaut). Il
|
||||
mémorise les identifiants (GUID) des articles déjà traités — pour la
|
||||
déduplication — ainsi que les en-têtes HTTP ``ETag`` et ``Last-Modified``
|
||||
de la dernière réponse — pour les requêtes conditionnelles.
|
||||
|
||||
La lecture et l'écriture sont tolérantes aux erreurs : un fichier absent,
|
||||
corrompu ou illisible ne fait jamais échouer le pipeline ; l'état vide est
|
||||
alors utilisé. La sortie JSON est déterministe (``known_guids`` triés
|
||||
alphabétiquement, champ ``version`` constant).
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import json
|
||||
import logging
|
||||
from collections.abc import Iterable
|
||||
from pathlib import Path
|
||||
|
||||
from pronote_sync.utils.redaction import redact_exception, redact_secrets
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
_STATE_VERSION = 1
|
||||
|
||||
|
||||
class BlogRSSState:
|
||||
"""Gère l'état local pour la déduplication des articles et le cache HTTP du flux RSS.
|
||||
|
||||
L'état regroupe l'ensemble des GUID d'articles déjà publiés
|
||||
(``known_guids``) et les en-têtes de cache HTTP (``etag``,
|
||||
``last_modified``). Il est chargé depuis le fichier JSON à la
|
||||
construction et sauvegardé à chaque modification. Toute erreur de
|
||||
lecture ou d'écriture est journalisée sans être propagée.
|
||||
|
||||
:param state_file: Chemin du fichier d'état JSON (``str`` ou
|
||||
:class:`~pathlib.Path`). ``".blog_rss_state.json"`` par défaut.
|
||||
"""
|
||||
|
||||
def __init__(self, state_file: Path | str = ".blog_rss_state.json") -> None:
|
||||
"""Initialise le gestionnaire d'état depuis le fichier JSON.
|
||||
|
||||
:param state_file: Chemin du fichier d'état JSON (``str`` ou
|
||||
:class:`~pathlib.Path`). ``".blog_rss_state.json"`` par défaut.
|
||||
"""
|
||||
self._state_file = Path(state_file)
|
||||
self._known_guids: set[str] = set()
|
||||
self._etag: str | None = None
|
||||
self._last_modified: str | None = None
|
||||
self._load()
|
||||
|
||||
def _load(self) -> None:
|
||||
"""Charge l'état depuis le fichier JSON.
|
||||
|
||||
Si le fichier n'existe pas, l'état reste vide. Si le fichier est
|
||||
corrompu, illisible ou que la version est absente ou différente
|
||||
de 1, un avertissement est journalisé et l'état reste vide.
|
||||
Aucune exception n'est propagée.
|
||||
"""
|
||||
if not self._state_file.exists():
|
||||
return
|
||||
try:
|
||||
data = json.loads(self._state_file.read_text(encoding="utf-8"))
|
||||
if not isinstance(data, dict) or data.get("version") != _STATE_VERSION:
|
||||
logger.warning(
|
||||
"Fichier d'état blog RSS %s : version absente ou non supportée, "
|
||||
"démarrage avec un état vide.",
|
||||
redact_secrets(str(self._state_file)),
|
||||
)
|
||||
return
|
||||
guids_data = data.get("known_guids", [])
|
||||
if isinstance(guids_data, list):
|
||||
self._known_guids = {guid for guid in guids_data if isinstance(guid, str)}
|
||||
etag_data = data.get("etag")
|
||||
if isinstance(etag_data, str):
|
||||
self._etag = etag_data
|
||||
last_modified_data = data.get("last_modified")
|
||||
if isinstance(last_modified_data, str):
|
||||
self._last_modified = last_modified_data
|
||||
except Exception as exc:
|
||||
logger.warning(
|
||||
"Impossible de charger le fichier d'état blog RSS %s : %s, "
|
||||
"démarrage avec un état vide.",
|
||||
redact_secrets(str(self._state_file)),
|
||||
redact_exception(exc),
|
||||
)
|
||||
|
||||
def _save(self) -> None:
|
||||
"""Sauvegarde l'état dans le fichier JSON de manière atomique.
|
||||
|
||||
La sortie est déterministe : ``known_guids`` est trié
|
||||
alphabétiquement et le champ ``version`` vaut 1. Le JSON est
|
||||
d'abord écrit dans un fichier temporaire du même répertoire, puis
|
||||
remplacé atomiquement par :meth:`~pathlib.Path.replace` afin de ne
|
||||
jamais laisser un fichier partiel en cas d'interruption. En cas
|
||||
d'erreur d'écriture, une erreur est journalisée sans être
|
||||
propagée et le fichier temporaire est supprimé.
|
||||
"""
|
||||
payload = {
|
||||
"version": _STATE_VERSION,
|
||||
"known_guids": sorted(self._known_guids),
|
||||
"etag": self._etag,
|
||||
"last_modified": self._last_modified,
|
||||
}
|
||||
tmp_file = self._state_file.with_suffix(".tmp")
|
||||
try:
|
||||
with open(tmp_file, "w", encoding="utf-8") as handle:
|
||||
json.dump(payload, handle, indent=2)
|
||||
tmp_file.replace(self._state_file)
|
||||
except Exception as exc:
|
||||
logger.error(
|
||||
"Impossible d'écrire le fichier d'état blog RSS %s : %s.",
|
||||
redact_secrets(str(self._state_file)),
|
||||
redact_exception(exc),
|
||||
)
|
||||
try:
|
||||
tmp_file.unlink(missing_ok=True)
|
||||
except Exception as cleanup_exc:
|
||||
logger.debug(
|
||||
"Nettoyage du fichier temporaire échoué : %s",
|
||||
redact_exception(cleanup_exc),
|
||||
)
|
||||
|
||||
def get_known_guids(self) -> frozenset[str]:
|
||||
"""Renvoie une copie immuable des GUID d'articles déjà connus.
|
||||
|
||||
:return: Copie de type :class:`frozenset` des GUID connus.
|
||||
:rtype: frozenset[str]
|
||||
"""
|
||||
return frozenset(self._known_guids)
|
||||
|
||||
def add_guids(self, guids: Iterable[str]) -> None:
|
||||
"""Ajoute des GUID d'articles à l'état connu et sauvegarde.
|
||||
|
||||
Si l'itérable ne contient aucun GUID, l'état n'est pas modifié et
|
||||
aucune sauvegarde n'est déclenchée.
|
||||
|
||||
:param guids: Itérable des GUID d'articles à enregistrer.
|
||||
"""
|
||||
new_guids = set(guids)
|
||||
if not new_guids:
|
||||
return
|
||||
self._known_guids.update(new_guids)
|
||||
self._save()
|
||||
|
||||
def get_cache_headers(self) -> tuple[str | None, str | None]:
|
||||
"""Renvoie les en-têtes de cache HTTP mémorisés.
|
||||
|
||||
:return: Tuple ``(etag, last_modified)``, chaque valeur pouvant
|
||||
être ``None`` si elle n'a jamais été reçue.
|
||||
:rtype: tuple[str | None, str | None]
|
||||
"""
|
||||
return self._etag, self._last_modified
|
||||
|
||||
def update_cache_headers(self, etag: str | None, last_modified: str | None) -> None:
|
||||
"""Met à jour les en-têtes de cache HTTP et sauvegarde.
|
||||
|
||||
:param etag: Nouvelle valeur de l'en-tête ``ETag``, ou ``None``
|
||||
pour l'effacer.
|
||||
:param last_modified: Nouvelle valeur de l'en-tête
|
||||
``Last-Modified``, ou ``None`` pour l'effacer.
|
||||
"""
|
||||
self._etag = etag
|
||||
self._last_modified = last_modified
|
||||
self._save()
|
||||
|
||||
def clear(self) -> None:
|
||||
"""Réinitialise l'état (GUID et en-têtes de cache) et sauvegarde."""
|
||||
self._known_guids = set()
|
||||
self._etag = None
|
||||
self._last_modified = None
|
||||
self._save()
|
||||
@@ -0,0 +1,75 @@
|
||||
"""Usine de construction du fournisseur d'agenda théorique.
|
||||
|
||||
Ce module expose l'API publique du package ``theoretical`` : les classes
|
||||
:class:`~pronote_sync.sources.theoretical.provider.TheoreticalAgendaProvider`,
|
||||
:class:`~pronote_sync.sources.theoretical.file.JsonTheoreticalAgendaProvider`,
|
||||
:class:`~pronote_sync.sources.theoretical.parity.WeekParityService` et
|
||||
:class:`~pronote_sync.sources.theoretical.holidays.SchoolHolidayCalendar`, ainsi
|
||||
que la fonction :func:`get_theoretical_provider` qui assemble la configuration
|
||||
(chemin du fichier JSON, parité des semaines et vacances scolaires) pour
|
||||
produire un fournisseur d'agenda théorique prêt à l'emploi.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from datetime import date
|
||||
from typing import Literal
|
||||
|
||||
from pronote_sync.errors import PronoteSyncError
|
||||
from pronote_sync.sources.theoretical.file import JsonTheoreticalAgendaProvider
|
||||
from pronote_sync.sources.theoretical.holidays import SchoolHolidayCalendar
|
||||
from pronote_sync.sources.theoretical.parity import WeekParityService
|
||||
from pronote_sync.sources.theoretical.provider import TheoreticalAgendaProvider
|
||||
|
||||
__all__ = [
|
||||
"TheoreticalAgendaProvider",
|
||||
"JsonTheoreticalAgendaProvider",
|
||||
"WeekParityService",
|
||||
"SchoolHolidayCalendar",
|
||||
"get_theoretical_provider",
|
||||
]
|
||||
|
||||
|
||||
def get_theoretical_provider(
|
||||
agenda_path: str | None,
|
||||
holidays_path: str | None,
|
||||
anchor_date: date | None,
|
||||
anchor_type: Literal["even", "odd"] | None,
|
||||
) -> TheoreticalAgendaProvider | None:
|
||||
"""Construit un fournisseur d'agenda théorique depuis la configuration.
|
||||
|
||||
:param agenda_path: Chemin du fichier JSON d'agenda théorique. Si None, retourne None.
|
||||
:param holidays_path: Chemin du fichier JSON de vacances scolaires (optionnel).
|
||||
:param anchor_date: Date de référence pour la parité des semaines.
|
||||
:param anchor_type: Type de la semaine de référence ("even" ou "odd").
|
||||
:return: Le fournisseur configuré, ou None si l'agenda théorique est désactivé.
|
||||
:rtype: TheoreticalAgendaProvider | None
|
||||
:raises PronoteSyncError: Si la configuration de parité est incomplète
|
||||
(date sans type ou inversement) alors que l'agenda nécessite la parité.
|
||||
"""
|
||||
if agenda_path is None:
|
||||
return None
|
||||
|
||||
# Build parity service if both anchor fields are provided
|
||||
parity_service: WeekParityService | None = None
|
||||
if anchor_date is not None and anchor_type is not None:
|
||||
parity_service = WeekParityService(anchor_date, anchor_type)
|
||||
elif anchor_date is not None or anchor_type is not None:
|
||||
# Partial parity config — one field without the other
|
||||
raise PronoteSyncError(
|
||||
"Configuration de parité incomplète : THEORETICAL_WEEK_ANCHOR_DATE et "
|
||||
"THEORETICAL_WEEK_ANCHOR_TYPE doivent être fournis ensemble."
|
||||
)
|
||||
|
||||
# Build holiday calendar if path is provided
|
||||
holiday_calendar: SchoolHolidayCalendar | None = None
|
||||
if holidays_path is not None:
|
||||
holiday_calendar = SchoolHolidayCalendar(holidays_path)
|
||||
|
||||
# Build provider — the provider's __init__ will validate that parity_service
|
||||
# is provided if the JSON contains even/odd lessons
|
||||
return JsonTheoreticalAgendaProvider(
|
||||
file_path=agenda_path,
|
||||
parity_service=parity_service,
|
||||
holiday_calendar=holiday_calendar,
|
||||
)
|
||||
|
||||
204
pronote_sync/sources/theoretical/file.py
Normal file
204
pronote_sync/sources/theoretical/file.py
Normal file
@@ -0,0 +1,204 @@
|
||||
"""Fournisseur d'agenda théorique basé sur un fichier JSON.
|
||||
|
||||
Ce module fournit :class:`JsonTheoreticalAgendaProvider`, une implémentation de
|
||||
:class:`~pronote_sync.sources.theoretical.provider.TheoreticalAgendaProvider` qui charge
|
||||
un fichier JSON d'emploi du temps théorique et expose les cours applicables par date ou
|
||||
plage de dates. Le filtrage tient compte du jour de la semaine, de la parité de semaine
|
||||
(``even``/``odd``) et du calendrier des vacances scolaires.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import logging
|
||||
import re
|
||||
import unicodedata
|
||||
from datetime import date, time, timedelta
|
||||
from pathlib import Path
|
||||
from typing import Literal
|
||||
|
||||
from pronote_sync.errors import PronoteSyncError
|
||||
from pronote_sync.models.agenda import TheoreticalLesson
|
||||
from pronote_sync.sources.theoretical.holidays import SchoolHolidayCalendar
|
||||
from pronote_sync.sources.theoretical.model import TheoreticalAgendaFile, TheoreticalLessonEntry
|
||||
from pronote_sync.sources.theoretical.parity import WeekParityService
|
||||
from pronote_sync.utils.redaction import redact_exception, redact_secrets
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
def normalize_subject(subject: str) -> str:
|
||||
"""Normalise une matière pour le matching déterministe.
|
||||
|
||||
Applique la normalisation Unicode NFKC, unifie les espaces (y compris
|
||||
tabulations et espaces insécables), supprime la ponctuation et met la
|
||||
chaîne en minuscules. Deux représentations visuellement identiques d'une
|
||||
même matière produisent ainsi la même forme normalisée.
|
||||
|
||||
:param subject: La matière brute.
|
||||
:return: La forme normalisée (NFKC, espaces unifiés, sans ponctuation, minuscule).
|
||||
:rtype: str
|
||||
"""
|
||||
normalized = unicodedata.normalize("NFKC", subject)
|
||||
normalized = re.sub(r"\s+", " ", normalized).strip()
|
||||
normalized = re.sub(r"[^\w\s]", "", normalized)
|
||||
normalized = re.sub(r"\s+", " ", normalized).strip()
|
||||
return normalized.lower()
|
||||
|
||||
|
||||
def _generate_id(entry: TheoreticalLessonEntry) -> str:
|
||||
"""Génère un identifiant déterministe pour une entrée de cours.
|
||||
|
||||
L'identifiant intègre le type de semaine (``all``, ``even`` ou ``odd``),
|
||||
le jour de la semaine, le créneau horaire et la matière : deux leçons
|
||||
occupant le même créneau dans des semaines différentes (ou le même
|
||||
créneau un autre jour) obtiennent ainsi des identifiants distincts.
|
||||
|
||||
:param entry: Entrée de cours du fichier JSON.
|
||||
:return: Identifiant déterministe unique.
|
||||
:rtype: str
|
||||
"""
|
||||
subject_slug = normalize_subject(entry.subject).replace(" ", "-")
|
||||
return f"theoretical:{entry.week}:{entry.day_of_week}:{entry.start_time}-{entry.end_time}:{subject_slug}"
|
||||
|
||||
|
||||
class JsonTheoreticalAgendaProvider:
|
||||
"""Fournisseur d'agenda théorique basé sur un fichier JSON.
|
||||
|
||||
Charge un fichier JSON d'emploi du temps théorique au format défini par
|
||||
:class:`~pronote_sync.sources.theoretical.model.TheoreticalAgendaFile` et expose
|
||||
les cours théoriques pour une date ou une plage de dates. Les cours peuvent être
|
||||
restreints à une parité de semaine (paire/impaire) via
|
||||
:class:`~pronote_sync.sources.theoretical.parity.WeekParityService` et exclus
|
||||
pendant les vacances scolaires via
|
||||
:class:`~pronote_sync.sources.theoretical.holidays.SchoolHolidayCalendar`.
|
||||
|
||||
:param file_path: Chemin vers le fichier JSON de l'agenda théorique.
|
||||
:param parity_service: Service optionnel de calcul de la parité de semaine.
|
||||
:param holiday_calendar: Calendrier optionnel des vacances scolaires.
|
||||
:raises PronoteSyncError: Si le fichier ne peut être lu ou analysé, si
|
||||
des leçons à semaine paire/impaire sont présentes sans ancre de parité,
|
||||
ou si plusieurs leçons partagent le même identifiant (explicite ou
|
||||
généré).
|
||||
"""
|
||||
|
||||
def __init__(
|
||||
self,
|
||||
file_path: str,
|
||||
parity_service: WeekParityService | None = None,
|
||||
holiday_calendar: SchoolHolidayCalendar | None = None,
|
||||
) -> None:
|
||||
"""Initialise le fournisseur en chargeant et analysant le fichier JSON.
|
||||
|
||||
Le fichier est lu et analysé immédiatement. Toute erreur de lecture,
|
||||
de décodage JSON ou de validation est journalisée (chemin et exception
|
||||
expurgés) puis remontée sous forme de :class:`PronoteSyncError`. Si des
|
||||
leçons à semaine paire/impaire sont présentes alors qu'aucun service de
|
||||
parité n'est configuré, une :class:`PronoteSyncError` est également levée.
|
||||
|
||||
:param file_path: Chemin vers le fichier JSON de l'agenda théorique.
|
||||
:param parity_service: Service optionnel de calcul de la parité de semaine.
|
||||
:param holiday_calendar: Calendrier optionnel des vacances scolaires.
|
||||
:raises PronoteSyncError: Si le fichier est introuvable, invalide,
|
||||
nécessite une ancre de parité non configurée ou contient plusieurs
|
||||
leçons partageant le même identifiant (explicite ou généré).
|
||||
"""
|
||||
self._file_path: str = file_path
|
||||
self._parity_service: WeekParityService | None = parity_service
|
||||
self._holiday_calendar: SchoolHolidayCalendar | None = holiday_calendar
|
||||
try:
|
||||
content = Path(file_path).read_text(encoding="utf-8")
|
||||
parsed = TheoreticalAgendaFile.model_validate_json(content)
|
||||
except Exception as exc:
|
||||
logger.error(
|
||||
"Fichier d'agenda théorique invalide %s : %s.",
|
||||
redact_secrets(str(file_path)),
|
||||
redact_exception(exc),
|
||||
)
|
||||
raise PronoteSyncError(
|
||||
f"Le fichier d'agenda théorique est invalide : {redact_secrets(str(file_path))}"
|
||||
) from None
|
||||
self._lessons: tuple[TheoreticalLessonEntry, ...] = parsed.lessons
|
||||
if self._parity_service is None and any(
|
||||
entry.week in ("even", "odd") for entry in self._lessons
|
||||
):
|
||||
raise PronoteSyncError(
|
||||
"L'agenda théorique contient des leçons à semaine paire/impaire "
|
||||
"mais aucune ancre de parité n'est configurée "
|
||||
"(THEORETICAL_WEEK_ANCHOR_DATE et THEORETICAL_WEEK_ANCHOR_TYPE)"
|
||||
) from None
|
||||
seen_ids: set[str] = set()
|
||||
for entry in self._lessons:
|
||||
effective_id = entry.id if entry.id is not None else _generate_id(entry)
|
||||
if effective_id in seen_ids:
|
||||
raise PronoteSyncError(
|
||||
f"Conflit d'identifiant dans l'agenda théorique : "
|
||||
f"l'identifiant '{redact_secrets(effective_id)}' est utilisé par plusieurs leçons. "
|
||||
f"Fournissez des identifiants explicites uniques."
|
||||
) from None
|
||||
seen_ids.add(effective_id)
|
||||
|
||||
def get_lessons(self, target_date: date) -> list[TheoreticalLesson]:
|
||||
"""Retourne les cours théoriques applicables à la date donnée.
|
||||
|
||||
Si un calendrier de vacances est configuré et que la date tombe pendant
|
||||
une période de vacances, la liste retournée est vide. La parité de la
|
||||
semaine est déterminée via le service de parité lorsqu'il est configuré ;
|
||||
sinon seuls les cours de type ``all`` sont conservés. Les entrées sont
|
||||
ensuite filtrées par jour de la semaine, converties en
|
||||
:class:`~pronote_sync.models.agenda.TheoreticalLesson` et triées par
|
||||
identifiant.
|
||||
|
||||
:param target_date: Date cible.
|
||||
:return: Liste des cours théoriques triée par identifiant.
|
||||
:rtype: list[TheoreticalLesson]
|
||||
"""
|
||||
if self._holiday_calendar is not None and self._holiday_calendar.is_holiday(target_date):
|
||||
return []
|
||||
|
||||
week_parity: Literal["all", "even", "odd"]
|
||||
if self._parity_service is not None:
|
||||
week_parity = self._parity_service.parity_for(target_date)
|
||||
else:
|
||||
week_parity = "all"
|
||||
|
||||
lessons: list[TheoreticalLesson] = []
|
||||
for entry in self._lessons:
|
||||
if entry.week != "all" and entry.week != week_parity:
|
||||
continue
|
||||
if entry.day_of_week != target_date.weekday():
|
||||
continue
|
||||
lesson_id = entry.id if entry.id is not None else _generate_id(entry)
|
||||
lessons.append(
|
||||
TheoreticalLesson(
|
||||
id=lesson_id,
|
||||
day_of_week=entry.day_of_week,
|
||||
start_time=time.fromisoformat(entry.start_time),
|
||||
end_time=time.fromisoformat(entry.end_time),
|
||||
subject=entry.subject,
|
||||
teachers=entry.teachers,
|
||||
rooms=entry.rooms,
|
||||
)
|
||||
)
|
||||
return sorted(lessons, key=lambda lesson: lesson.id)
|
||||
|
||||
def get_lessons_for_range(self, start_date: date, end_date: date) -> list[TheoreticalLesson]:
|
||||
"""Retourne les cours théoriques pour une plage de dates (inclusives).
|
||||
|
||||
Chaque date de la plage, bornes incluses, est évaluée via
|
||||
:meth:`get_lessons`. Les cours sont dédupliqués par identifiant : pour
|
||||
un identifiant donné, la dernière occurrence (date la plus récente)
|
||||
écrase la précédente. Si ``start_date`` est postérieure à ``end_date``,
|
||||
la liste retournée est vide.
|
||||
|
||||
:param start_date: Date de début (inclusive).
|
||||
:param end_date: Date de fin (inclusive).
|
||||
:return: Liste des cours théoriques triée par identifiant.
|
||||
:rtype: list[TheoreticalLesson]
|
||||
"""
|
||||
seen: dict[str, TheoreticalLesson] = {}
|
||||
current_date = start_date
|
||||
while current_date <= end_date:
|
||||
for lesson in self.get_lessons(current_date):
|
||||
seen[lesson.id] = lesson
|
||||
current_date += timedelta(days=1)
|
||||
return sorted(seen.values(), key=lambda lesson: lesson.id)
|
||||
106
pronote_sync/sources/theoretical/holidays.py
Normal file
106
pronote_sync/sources/theoretical/holidays.py
Normal file
@@ -0,0 +1,106 @@
|
||||
"""Service de calendrier des vacances scolaires.
|
||||
|
||||
Ce module fournit les modèles de données :class:`HolidayPeriod` et
|
||||
:class:`SchoolHolidayFile`, ainsi que le service :class:`SchoolHolidayCalendar`
|
||||
qui charge un fichier JSON de périodes de vacances scolaires et permet de
|
||||
déterminer si une date donnée tombe pendant ces vacances.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import json
|
||||
import logging
|
||||
from datetime import date
|
||||
from pathlib import Path
|
||||
from typing import Any, Self
|
||||
|
||||
from pydantic import BaseModel, ConfigDict, Field, model_validator
|
||||
|
||||
from pronote_sync.errors import PronoteSyncError
|
||||
from pronote_sync.utils.redaction import redact_exception, redact_secrets
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
|
||||
class HolidayPeriod(BaseModel):
|
||||
"""Période de vacances scolaires, bornes incluses.
|
||||
|
||||
:ivar start_date: Date de début de la période (incluse).
|
||||
:ivar end_date: Date de fin de la période (incluse).
|
||||
:ivar label: Nom de la période (ex. « Toussaint »).
|
||||
"""
|
||||
|
||||
model_config = ConfigDict(frozen=True)
|
||||
|
||||
start_date: date
|
||||
end_date: date
|
||||
label: str
|
||||
|
||||
@model_validator(mode="after")
|
||||
def _validate_date_order(self) -> Self:
|
||||
"""Vérifie que la date de fin n'est pas antérieure à la date de début.
|
||||
|
||||
:return: L'instance de période après validation.
|
||||
:rtype: Self
|
||||
:raises ValueError: Si ``end_date`` est strictement antérieure à ``start_date``.
|
||||
"""
|
||||
if self.end_date < self.start_date:
|
||||
raise ValueError("end_date doit être supérieure ou égale à start_date.")
|
||||
return self
|
||||
|
||||
|
||||
class SchoolHolidayFile(BaseModel):
|
||||
"""Modèle de parsing d'un fichier JSON de vacances scolaires.
|
||||
|
||||
:ivar zone: Zone académique (ex. « A »).
|
||||
:ivar school_year: Année scolaire (ex. « 2026-2027 »).
|
||||
:ivar periods: Périodes de vacances scolaires du fichier.
|
||||
"""
|
||||
|
||||
zone: str
|
||||
school_year: str
|
||||
periods: tuple[HolidayPeriod, ...] = Field(default=())
|
||||
|
||||
|
||||
class SchoolHolidayCalendar:
|
||||
"""Calendrier des vacances scolaires chargé depuis un fichier JSON."""
|
||||
|
||||
def __init__(self, file_path: Path | str) -> None:
|
||||
"""Charge les périodes de vacances scolaires depuis un fichier JSON.
|
||||
|
||||
:param file_path: Chemin vers le fichier JSON.
|
||||
:raises PronoteSyncError: Si le fichier ne peut être lu ou analysé.
|
||||
"""
|
||||
path = Path(file_path)
|
||||
self._periods: tuple[HolidayPeriod, ...]
|
||||
if not path.is_file():
|
||||
raise PronoteSyncError(
|
||||
f"Le fichier de vacances scolaires est introuvable : {redact_secrets(str(path))}"
|
||||
) from None
|
||||
try:
|
||||
data: Any = json.loads(path.read_text(encoding="utf-8"))
|
||||
file_model: SchoolHolidayFile = SchoolHolidayFile.model_validate(data)
|
||||
except Exception as exc:
|
||||
logger.error(
|
||||
"Fichier de vacances scolaires invalide %s : %s.",
|
||||
redact_secrets(str(path)),
|
||||
redact_exception(exc),
|
||||
)
|
||||
raise PronoteSyncError(
|
||||
f"Le fichier de vacances scolaires est invalide : {redact_secrets(str(path))}"
|
||||
) from None
|
||||
self._periods = file_model.periods
|
||||
|
||||
def is_holiday(self, target_date: date) -> bool:
|
||||
"""Vérifie si la date donnée tombe pendant une période de vacances.
|
||||
|
||||
La date est considérée comme étant en vacances si elle appartient à
|
||||
l'intervalle d'au moins une période, bornes incluses
|
||||
(``start_date <= target_date <= end_date``).
|
||||
|
||||
:param target_date: Date à vérifier.
|
||||
:return: ``True`` si la date tombe pendant les vacances scolaires,
|
||||
``False`` sinon.
|
||||
:rtype: bool
|
||||
"""
|
||||
return any(period.start_date <= target_date <= period.end_date for period in self._periods)
|
||||
123
pronote_sync/sources/theoretical/model.py
Normal file
123
pronote_sync/sources/theoretical/model.py
Normal file
@@ -0,0 +1,123 @@
|
||||
"""Modèles Pydantic de parsing du fichier JSON de l'agenda théorique.
|
||||
|
||||
Ce module définit les modèles de parsing utilisés pour lire le fichier
|
||||
JSON de l'agenda théorique : :class:`TheoreticalLessonEntry` pour une
|
||||
entrée de cours et :class:`TheoreticalAgendaFile` pour le fichier
|
||||
complet.
|
||||
|
||||
Ces modèles sont distincts du modèle de domaine
|
||||
:class:`~pronote_sync.models.agenda.TheoreticalLesson` : ils restent
|
||||
proches du format JSON brut (heures au format ``HH:MM``) et servent
|
||||
uniquement à la désérialisation, la conversion vers le modèle de domaine
|
||||
étant réalisée ensuite par le fournisseur.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import re
|
||||
from typing import Any, Literal
|
||||
|
||||
from pydantic import BaseModel, ConfigDict, Field, model_validator
|
||||
|
||||
_TIME_PATTERN = re.compile(r"^(?:[01]\d|2[0-3]):[0-5]\d$")
|
||||
|
||||
|
||||
class TheoreticalLessonEntry(BaseModel):
|
||||
"""Représente une entrée de cours dans le fichier JSON de l'agenda théorique.
|
||||
|
||||
Modèle figé (``frozen``) : les instances sont immuables après
|
||||
création. Le format des heures est validé (``HH:MM`` sur 24 heures,
|
||||
avec ``HH`` entre ``00`` et ``23`` et ``MM`` entre ``00`` et ``59``)
|
||||
ainsi que l'ordre des heures (fin postérieure au début).
|
||||
|
||||
:param week: Type de semaine auquel s'applique le cours
|
||||
(``"all"``, ``"even"`` ou ``"odd"``).
|
||||
:param day_of_week: Jour de la semaine (0 = lundi, 6 = dimanche).
|
||||
:param start_time: Heure de début au format ``HH:MM`` sur 24 heures.
|
||||
:param end_time: Heure de fin au format ``HH:MM`` sur 24 heures.
|
||||
:param subject: Nom de la matière.
|
||||
:param teachers: Noms des professeurs. Tuple vide par défaut.
|
||||
:param rooms: Noms des salles. Tuple vide par défaut.
|
||||
:param id: Identifiant explicite optionnel. ``None`` par défaut ; en
|
||||
cas d'absence, le fournisseur en génère un.
|
||||
"""
|
||||
|
||||
model_config = ConfigDict(frozen=True)
|
||||
|
||||
week: Literal["all", "even", "odd"] = Field(
|
||||
..., description="Type de semaine concerné (all, even ou odd)"
|
||||
)
|
||||
day_of_week: int = Field(
|
||||
..., ge=0, le=6, description="Jour de la semaine (0=lundi, 6=dimanche)"
|
||||
)
|
||||
start_time: str = Field(..., description="Heure de début au format HH:MM")
|
||||
end_time: str = Field(..., description="Heure de fin au format HH:MM")
|
||||
subject: str = Field(..., description="Nom de la matière")
|
||||
teachers: tuple[str, ...] = Field(default=(), description="Noms des professeurs")
|
||||
rooms: tuple[str, ...] = Field(default=(), description="Noms des salles")
|
||||
id: str | None = Field(
|
||||
default=None, description="Identifiant explicite optionnel (None si absent)"
|
||||
)
|
||||
|
||||
@model_validator(mode="before")
|
||||
@classmethod
|
||||
def _validate_time_format(cls, data: Any) -> Any:
|
||||
"""Valide le format ``HH:MM`` des heures de début et de fin.
|
||||
|
||||
Les heures doivent être au format ``HH:MM`` sur 24 heures, avec
|
||||
``HH`` entre ``00`` et ``23`` et ``MM`` entre ``00`` et ``59``.
|
||||
Cette validation précède :meth:`_validate_time_order`, dont la
|
||||
comparaison par ordre lexicographique n'est fiable que si le
|
||||
format est garanti.
|
||||
|
||||
:param data: Données brutes transmises au modèle.
|
||||
:return: Les données brutes inchangées.
|
||||
:rtype: Any
|
||||
:raises ValueError: Si ``start_time`` ou ``end_time`` n'est pas
|
||||
au format ``HH:MM``.
|
||||
"""
|
||||
if not isinstance(data, dict):
|
||||
return data
|
||||
for field_name in ("start_time", "end_time"):
|
||||
if field_name not in data:
|
||||
continue
|
||||
value = data[field_name]
|
||||
if not isinstance(value, str) or _TIME_PATTERN.fullmatch(value) is None:
|
||||
raise ValueError(
|
||||
f"{field_name} doit être au format HH:MM (HH entre 00 et 23, MM entre 00 et 59)"
|
||||
)
|
||||
return data
|
||||
|
||||
@model_validator(mode="after")
|
||||
def _validate_time_order(self) -> TheoreticalLessonEntry:
|
||||
"""Valide que l'heure de fin est postérieure à l'heure de début.
|
||||
|
||||
La comparaison est effectuée sur les chaînes ``HH:MM`` de façon
|
||||
lexicographique ; elle n'est fiable que parce que
|
||||
:meth:`_validate_time_format` a déjà garanti le format à deux
|
||||
chiffres.
|
||||
|
||||
:return: L'instance validée.
|
||||
:rtype: TheoreticalLessonEntry
|
||||
:raises ValueError: Si ``end_time`` n'est pas postérieur à
|
||||
``start_time``.
|
||||
"""
|
||||
if self.end_time <= self.start_time:
|
||||
raise ValueError("end_time doit être postérieur à start_time")
|
||||
return self
|
||||
|
||||
|
||||
class TheoreticalAgendaFile(BaseModel):
|
||||
"""Représente le fichier JSON complet de l'agenda théorique.
|
||||
|
||||
Modèle de parsing non figé : il sert uniquement à désérialiser le
|
||||
fichier JSON avant conversion vers les modèles de domaine.
|
||||
|
||||
:param version: Version du schéma du fichier (vaut ``1``).
|
||||
:param lessons: Liste des entrées de cours du fichier.
|
||||
"""
|
||||
|
||||
version: Literal[1] = Field(default=1, description="Version du schéma (1)")
|
||||
lessons: tuple[TheoreticalLessonEntry, ...] = Field(
|
||||
..., description="Liste des entrées de cours"
|
||||
)
|
||||
55
pronote_sync/sources/theoretical/parity.py
Normal file
55
pronote_sync/sources/theoretical/parity.py
Normal file
@@ -0,0 +1,55 @@
|
||||
"""Service déterministe de calcul de la parité des semaines pour l'agenda théorique.
|
||||
|
||||
Ce module fournit :class:`WeekParityService`, un service sans état qui détermine
|
||||
si la semaine contenant une date donnée est paire ou impaire, à partir d'une
|
||||
date d'ancrage dont la parité est connue. L'algorithme repose sur le décalage
|
||||
entre les lundis des deux semaines, et non sur les numéros de semaine ISO.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from datetime import date, timedelta
|
||||
from typing import Literal
|
||||
|
||||
|
||||
class WeekParityService:
|
||||
"""Service déterministe de calcul de la parité des semaines.
|
||||
|
||||
La parité d'une semaine est déduite d'une date d'ancrage fournie à la
|
||||
construction : la semaine contenant cette date a une parité connue
|
||||
(paire ou impaire). Le service est immuable après construction et ne
|
||||
dépend d'aucun état global ni de l'horloge système.
|
||||
"""
|
||||
|
||||
def __init__(self, anchor_date: date, anchor_type: Literal["even", "odd"]) -> None:
|
||||
"""Initialise le service avec la date d'ancrage et sa parité.
|
||||
|
||||
:param anchor_date: Date de référence dont la semaine a une parité connue.
|
||||
:param anchor_type: Parité de la semaine d'ancrage (``"even"`` ou ``"odd"``).
|
||||
"""
|
||||
self._anchor_monday = anchor_date - timedelta(days=anchor_date.weekday())
|
||||
self._anchor_type = anchor_type
|
||||
|
||||
def parity_for(self, target_date: date) -> Literal["even", "odd"]:
|
||||
"""Détermine la parité de la semaine contenant la date cible.
|
||||
|
||||
Algorithme :
|
||||
1. Calculer le lundi de la semaine de la date cible.
|
||||
2. Utiliser le lundi de la semaine de la date d'ancrage (stocké à
|
||||
l'initialisation).
|
||||
3. Calculer le nombre de semaines entre les deux lundis :
|
||||
``(target_monday - anchor_monday).days // 7``.
|
||||
4. Si le décalage de semaines est pair, la cible a la même parité que
|
||||
l'ancrage.
|
||||
5. Si le décalage de semaines est impair, la cible a la parité opposée.
|
||||
|
||||
:param target_date: Date dont il faut déterminer la parité.
|
||||
:return: ``"even"`` ou ``"odd"`` selon la parité de la semaine cible.
|
||||
:rtype: Literal["even", "odd"]
|
||||
"""
|
||||
target_monday = target_date - timedelta(days=target_date.weekday())
|
||||
week_offset = (target_monday - self._anchor_monday).days // 7
|
||||
if week_offset % 2 == 0:
|
||||
return self._anchor_type
|
||||
# Inverse la parité.
|
||||
return "odd" if self._anchor_type == "even" else "even"
|
||||
44
pronote_sync/sources/theoretical/provider.py
Normal file
44
pronote_sync/sources/theoretical/provider.py
Normal file
@@ -0,0 +1,44 @@
|
||||
"""Protocole pour les fournisseurs d'agenda théorique.
|
||||
|
||||
Ce module définit :class:`TheoreticalAgendaProvider`, le contrat que
|
||||
tous les fournisseurs d'agenda théorique doivent respecter pour exposer
|
||||
les cours théoriques (emploi du temps attendu) par date ou plage de
|
||||
dates.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from datetime import date
|
||||
from typing import Protocol, runtime_checkable
|
||||
|
||||
from pronote_sync.models.agenda import TheoreticalLesson
|
||||
|
||||
|
||||
@runtime_checkable
|
||||
class TheoreticalAgendaProvider(Protocol):
|
||||
"""Protocole pour un fournisseur d'agenda théorique.
|
||||
|
||||
Un fournisseur d'agenda théorique expose les cours théoriques
|
||||
(emploi du temps attendu) pour une date ou une plage de dates.
|
||||
L'implémentation encapsule la logique de filtrage par parité de
|
||||
semaine et par vacances scolaires.
|
||||
"""
|
||||
|
||||
def get_lessons(self, target_date: date) -> list[TheoreticalLesson]:
|
||||
"""Retourne les cours théoriques applicables à la date donnée.
|
||||
|
||||
:param target_date: Date cible.
|
||||
:return: Liste des cours théoriques triée par identifiant.
|
||||
:rtype: list[TheoreticalLesson]
|
||||
"""
|
||||
...
|
||||
|
||||
def get_lessons_for_range(self, start_date: date, end_date: date) -> list[TheoreticalLesson]:
|
||||
"""Retourne les cours théoriques pour une plage de dates (inclusives).
|
||||
|
||||
:param start_date: Date de début (inclusive).
|
||||
:param end_date: Date de fin (inclusive).
|
||||
:return: Liste des cours théoriques triée par identifiant.
|
||||
:rtype: list[TheoreticalLesson]
|
||||
"""
|
||||
...
|
||||
47
tests/fixtures/blog_rss.xml
vendored
Normal file
47
tests/fixtures/blog_rss.xml
vendored
Normal file
@@ -0,0 +1,47 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<rss version="2.0" xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/">
|
||||
<channel>
|
||||
<title>Blog du collège Les Mimosas</title>
|
||||
<link>https://example.com/blog/</link>
|
||||
<description>Actualités et informations du collège Les Mimosas</description>
|
||||
<language>fr-FR</language>
|
||||
<item>
|
||||
<title>Information générale</title>
|
||||
<link>https://example.com/blog/?p=1003</link>
|
||||
<guid isPermaLink="false">https://example.com/blog/?p=1003</guid>
|
||||
<pubDate>Wed, 12 Aug 2026 08:00:00 +0000</pubDate>
|
||||
<description>Information générale à destination des familles.</description>
|
||||
<content:encoded><![CDATA[
|
||||
<p>La vie scolaire rappelle aux familles que les billets de cantine sont à commander avant le vendredi soir.</p>
|
||||
<p>Pour toute question, consultez la page <a href="https://example.com/blog/cantine/">cantines et restauration</a> du site.</p>
|
||||
]]></content:encoded>
|
||||
</item>
|
||||
<item>
|
||||
<title>Réunion de rentrée</title>
|
||||
<link>https://example.com/blog/?p=1001</link>
|
||||
<guid isPermaLink="false">https://example.com/blog/?p=1001</guid>
|
||||
<pubDate>Mon, 10 Aug 2026 09:00:11 +0000</pubDate>
|
||||
<category>Administration</category>
|
||||
<dc:creator>M. Dupont</dc:creator>
|
||||
<description>Réunion de rentrée des parents d'élèves.</description>
|
||||
<content:encoded><![CDATA[
|
||||
<p>La réunion de rentrée des parents d'élèves se tiendra le mardi 15 septembre à 18 h 00 dans la salle polyvalente.</p>
|
||||
<p>L'équipe pédagogique y présentera le projet d'établissement et le calendrier des conseils de classe. Un temps d'échange est prévu avec les professeurs principaux.</p>
|
||||
<p>Merci de confirmer votre présence en remplissant le <a href="https://example.com/blog/reunion-rentree-inscription/">formulaire d'inscription</a> avant le 10 septembre.</p>
|
||||
]]></content:encoded>
|
||||
</item>
|
||||
<item>
|
||||
<title>Sortie pédagogique au musée</title>
|
||||
<link>https://example.com/blog/?p=1002</link>
|
||||
<guid isPermaLink="false">https://example.com/blog/?p=1002</guid>
|
||||
<pubDate>Tue, 11 Aug 2026 14:30:00 +0000</pubDate>
|
||||
<category>Pédagogie</category>
|
||||
<description>Sortie pédagogique des élèves de 4e au musée d'art moderne.</description>
|
||||
<content:encoded><![CDATA[
|
||||
<p>Les élèves de 4e se rendront au musée d'art moderne le jeudi 8 octobre dans le cadre du cours d'arts plastiques.</p>
|
||||
<p>La visite guidée portera sur la période impressionniste. Les élèves devront apporter un carnet de croquis et leur pique-nique.</p>
|
||||
<p>Le détail de l'organisation figure dans la <a href="https://example.com/blog/sortie-musee-autorisation/">note d'autorisation</a> à retourner signée avant le 25 septembre.</p>
|
||||
]]></content:encoded>
|
||||
</item>
|
||||
</channel>
|
||||
</rss>
|
||||
26
tests/fixtures/school_holidays.json
vendored
Normal file
26
tests/fixtures/school_holidays.json
vendored
Normal file
@@ -0,0 +1,26 @@
|
||||
{
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [
|
||||
{
|
||||
"start_date": "2026-10-17",
|
||||
"end_date": "2026-11-02",
|
||||
"label": "Toussaint"
|
||||
},
|
||||
{
|
||||
"start_date": "2026-12-19",
|
||||
"end_date": "2027-01-04",
|
||||
"label": "Noël"
|
||||
},
|
||||
{
|
||||
"start_date": "2027-02-06",
|
||||
"end_date": "2027-02-22",
|
||||
"label": "Hiver"
|
||||
},
|
||||
{
|
||||
"start_date": "2027-04-03",
|
||||
"end_date": "2027-04-19",
|
||||
"label": "Printemps"
|
||||
}
|
||||
]
|
||||
}
|
||||
87
tests/fixtures/theoretical.json
vendored
Normal file
87
tests/fixtures/theoretical.json
vendored
Normal file
@@ -0,0 +1,87 @@
|
||||
{
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"id": "theoretical-maths-monday-1",
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Mathématiques",
|
||||
"teachers": ["Mme Martin"],
|
||||
"rooms": ["101"]
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "09:00",
|
||||
"end_time": "10:00",
|
||||
"subject": "Français",
|
||||
"teachers": ["M. Dupont"],
|
||||
"rooms": ["102"]
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "11:00",
|
||||
"end_time": "12:00",
|
||||
"subject": "Histoire-Géographie",
|
||||
"teachers": ["Mme Petit"],
|
||||
"rooms": ["103"]
|
||||
},
|
||||
{
|
||||
"week": "even",
|
||||
"day_of_week": 1,
|
||||
"start_time": "10:00",
|
||||
"end_time": "11:00",
|
||||
"subject": "Anglais",
|
||||
"teachers": ["Mme Bernard"],
|
||||
"rooms": ["201"]
|
||||
},
|
||||
{
|
||||
"week": "even",
|
||||
"day_of_week": 1,
|
||||
"start_time": "10:00",
|
||||
"end_time": "11:00",
|
||||
"subject": "Technologie",
|
||||
"teachers": [],
|
||||
"rooms": []
|
||||
},
|
||||
{
|
||||
"week": "odd",
|
||||
"day_of_week": 1,
|
||||
"start_time": "10:00",
|
||||
"end_time": "11:00",
|
||||
"subject": "Espagnol",
|
||||
"teachers": ["M. Garcia"],
|
||||
"rooms": ["202"]
|
||||
},
|
||||
{
|
||||
"week": "odd",
|
||||
"day_of_week": 1,
|
||||
"start_time": "10:00",
|
||||
"end_time": "11:00",
|
||||
"subject": "Éducation musicale",
|
||||
"teachers": [],
|
||||
"rooms": []
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 2,
|
||||
"start_time": "14:00",
|
||||
"end_time": "15:00",
|
||||
"subject": "Sciences",
|
||||
"teachers": [],
|
||||
"rooms": ["203"]
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 4,
|
||||
"start_time": "09:00",
|
||||
"end_time": "10:00",
|
||||
"subject": "Arts plastiques",
|
||||
"teachers": [],
|
||||
"rooms": []
|
||||
}
|
||||
]
|
||||
}
|
||||
1285
tests/unit/test_blog_client.py
Normal file
1285
tests/unit/test_blog_client.py
Normal file
File diff suppressed because it is too large
Load Diff
350
tests/unit/test_blog_state.py
Normal file
350
tests/unit/test_blog_state.py
Normal file
@@ -0,0 +1,350 @@
|
||||
"""Tests unitaires pour le gestionnaire d'état du flux RSS du blog.
|
||||
|
||||
Ce module valide le comportement de :class:`BlogRSSState` dans
|
||||
:mod:`pronote_sync.sources.blog.state`. Les tests couvrent :
|
||||
|
||||
- La persistance des GUID connus et des en-têtes de cache HTTP,
|
||||
- La tolérance aux erreurs (fichier absent, corrompu, version incompatible),
|
||||
- Le tri alphabétique des GUID lors de la sauvegarde,
|
||||
- La réinitialisation complète de l'état.
|
||||
|
||||
Tous les tests utilisent des fichiers temporaires via la fixture ``tmp_path``.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import json
|
||||
from pathlib import Path
|
||||
from unittest.mock import patch
|
||||
|
||||
import pytest
|
||||
|
||||
from pronote_sync.sources.blog.state import BlogRSSState
|
||||
|
||||
|
||||
def test_state_file_absent_empty_state(tmp_path: Path) -> None:
|
||||
"""Vérifie qu'un fichier d'état absent initialise un état vide.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "nonexistent.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
assert state.get_known_guids() == frozenset()
|
||||
assert state.get_cache_headers() == (None, None)
|
||||
|
||||
|
||||
def test_add_guids_persists(tmp_path: Path) -> None:
|
||||
"""Vérifie que l'ajout de GUID persiste dans le fichier JSON.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
state.add_guids(["guid-2", "guid-1", "guid-3"])
|
||||
|
||||
assert state.get_known_guids() == frozenset({"guid-1", "guid-2", "guid-3"})
|
||||
|
||||
# Vérification du contenu du fichier
|
||||
saved_data = json.loads(state_file.read_text(encoding="utf-8"))
|
||||
assert saved_data["known_guids"] == ["guid-1", "guid-2", "guid-3"]
|
||||
|
||||
|
||||
def test_add_guids_empty_noop(tmp_path: Path) -> None:
|
||||
"""Vérifie que l'ajout d'une liste vide ne modifie pas le fichier.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
# Ajout initial de GUID
|
||||
state.add_guids(["guid-1"])
|
||||
original_content = state_file.read_text(encoding="utf-8")
|
||||
|
||||
# Ajout d'une liste vide
|
||||
state.add_guids([])
|
||||
|
||||
# Vérification que le fichier n'a pas été modifié (comparaison par contenu)
|
||||
assert state_file.read_text(encoding="utf-8") == original_content
|
||||
|
||||
|
||||
def test_state_load_persisted_guids(tmp_path: Path) -> None:
|
||||
"""Vérifie que les GUID persistés sont rechargés dans une nouvelle instance.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
|
||||
# Création et sauvegarde de l'état initial
|
||||
state1 = BlogRSSState(state_file)
|
||||
state1.add_guids(["guid-1", "guid-2"])
|
||||
|
||||
# Création d'une nouvelle instance avec le même fichier
|
||||
state2 = BlogRSSState(state_file)
|
||||
|
||||
assert state2.get_known_guids() == frozenset({"guid-1", "guid-2"})
|
||||
|
||||
|
||||
def test_state_load_cache_headers(tmp_path: Path) -> None:
|
||||
"""Vérifie que les en-têtes de cache persistés sont rechargés.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
|
||||
# Création et sauvegarde des en-têtes de cache
|
||||
state1 = BlogRSSState(state_file)
|
||||
state1.update_cache_headers("etag-123", "Wed, 01 Sep 2026 GMT")
|
||||
|
||||
# Création d'une nouvelle instance avec le même fichier
|
||||
state2 = BlogRSSState(state_file)
|
||||
|
||||
assert state2.get_cache_headers() == ("etag-123", "Wed, 01 Sep 2026 GMT")
|
||||
|
||||
|
||||
def test_corrupt_json_warning(tmp_path: Path, caplog: pytest.LogCaptureFixture) -> None:
|
||||
"""Vérifie qu'un fichier JSON corrompu déclenche un avertissement et initialise un état vide.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:param caplog: Fixture pytest pour capturer les logs.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "corrupt.json"
|
||||
state_file.write_text("not json{", encoding="utf-8")
|
||||
|
||||
with caplog.at_level("WARNING"):
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
assert state.get_known_guids() == frozenset()
|
||||
assert state.get_cache_headers() == (None, None)
|
||||
assert "Impossible de charger le fichier d'état blog RSS" in caplog.text
|
||||
|
||||
|
||||
def test_wrong_version_warning(tmp_path: Path, caplog: pytest.LogCaptureFixture) -> None:
|
||||
"""Vérifie qu'une version incompatible déclenche un avertissement et initialise un état vide.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:param caplog: Fixture pytest pour capturer les logs.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "wrong_version.json"
|
||||
state_file.write_text(
|
||||
json.dumps({"version": 99, "known_guids": ["x"], "etag": None, "last_modified": None}),
|
||||
encoding="utf-8",
|
||||
)
|
||||
|
||||
with caplog.at_level("WARNING"):
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
assert state.get_known_guids() == frozenset()
|
||||
assert state.get_cache_headers() == (None, None)
|
||||
assert "version absente ou non supportée" in caplog.text
|
||||
|
||||
|
||||
def test_missing_version_warning(tmp_path: Path, caplog: pytest.LogCaptureFixture) -> None:
|
||||
"""Vérifie qu'un fichier sans champ version déclenche un avertissement et initialise un état vide.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:param caplog: Fixture pytest pour capturer les logs.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "missing_version.json"
|
||||
state_file.write_text(
|
||||
json.dumps({"known_guids": ["x"], "etag": None, "last_modified": None}),
|
||||
encoding="utf-8",
|
||||
)
|
||||
|
||||
with caplog.at_level("WARNING"):
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
assert state.get_known_guids() == frozenset()
|
||||
assert state.get_cache_headers() == (None, None)
|
||||
assert "version absente ou non supportée" in caplog.text
|
||||
|
||||
|
||||
def test_known_guids_sorted_on_save(tmp_path: Path) -> None:
|
||||
"""Vérifie que les GUID sont triés alphabétiquement lors de la sauvegarde.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
state.add_guids(["c-guid", "a-guid", "b-guid"])
|
||||
|
||||
saved_data = json.loads(state_file.read_text(encoding="utf-8"))
|
||||
assert saved_data["known_guids"] == ["a-guid", "b-guid", "c-guid"]
|
||||
|
||||
|
||||
def test_clear_resets_state(tmp_path: Path) -> None:
|
||||
"""Vérifie que la méthode clear réinitialise complètement l'état.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
# Ajout de GUID et d'en-têtes de cache
|
||||
state.add_guids(["guid-1", "guid-2"])
|
||||
state.update_cache_headers("etag-123", "Wed, 01 Sep 2026 GMT")
|
||||
|
||||
# Réinitialisation
|
||||
state.clear()
|
||||
|
||||
assert state.get_known_guids() == frozenset()
|
||||
assert state.get_cache_headers() == (None, None)
|
||||
|
||||
# Vérification du contenu du fichier
|
||||
saved_data = json.loads(state_file.read_text(encoding="utf-8"))
|
||||
assert saved_data["known_guids"] == []
|
||||
assert saved_data["etag"] is None
|
||||
assert saved_data["last_modified"] is None
|
||||
|
||||
|
||||
def test_clear_persists_to_file(tmp_path: Path) -> None:
|
||||
"""Vérifie que la réinitialisation est persistée dans le fichier.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
|
||||
# Création, ajout de données et réinitialisation
|
||||
state1 = BlogRSSState(state_file)
|
||||
state1.add_guids(["guid-1"])
|
||||
state1.update_cache_headers("etag-123", "Wed, 01 Sep 2026 GMT")
|
||||
state1.clear()
|
||||
|
||||
# Création d'une nouvelle instance avec le même fichier
|
||||
state2 = BlogRSSState(state_file)
|
||||
|
||||
assert state2.get_known_guids() == frozenset()
|
||||
assert state2.get_cache_headers() == (None, None)
|
||||
|
||||
|
||||
def test_str_path_converted_to_path(tmp_path: Path) -> None:
|
||||
"""Vérifie qu'un chemin de type str est converti en Path.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = str(tmp_path / "state.json")
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
state.add_guids(["guid-1"])
|
||||
|
||||
assert Path(state_file).exists()
|
||||
|
||||
|
||||
def test_update_cache_headers_none_values(tmp_path: Path) -> None:
|
||||
"""Vérifie que la mise à jour avec des valeurs None fonctionne correctement.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
state.update_cache_headers(None, None)
|
||||
|
||||
assert state.get_cache_headers() == (None, None)
|
||||
|
||||
# Vérification du contenu du fichier
|
||||
saved_data = json.loads(state_file.read_text(encoding="utf-8"))
|
||||
assert saved_data["etag"] is None
|
||||
assert saved_data["last_modified"] is None
|
||||
|
||||
|
||||
def test_add_guids_multiple_calls(tmp_path: Path) -> None:
|
||||
"""Vérifie que plusieurs appels à add_guids accumulent les GUID.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
state.add_guids(["guid-1"])
|
||||
state.add_guids(["guid-2"])
|
||||
|
||||
assert state.get_known_guids() == frozenset({"guid-1", "guid-2"})
|
||||
|
||||
|
||||
def test_version_in_saved_file(tmp_path: Path) -> None:
|
||||
"""Vérifie que le champ version est présent dans le fichier sauvegardé.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
state.add_guids(["guid-1"])
|
||||
|
||||
saved_data = json.loads(state_file.read_text(encoding="utf-8"))
|
||||
assert saved_data["version"] == 1
|
||||
|
||||
|
||||
def test_get_known_guids_returns_frozenset(tmp_path: Path) -> None:
|
||||
"""Vérifie que get_known_guids retourne un frozenset.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
state = BlogRSSState(state_file)
|
||||
|
||||
state.add_guids(["guid-1", "guid-2"])
|
||||
|
||||
result = state.get_known_guids()
|
||||
assert type(result) is frozenset
|
||||
|
||||
|
||||
def test_atomic_save_preserves_on_error(tmp_path: Path) -> None:
|
||||
"""Vérifie que l'état original est préservé en cas d'erreur lors de la sauvegarde atomique.
|
||||
|
||||
Si une erreur survient pendant le remplacement atomique du fichier,
|
||||
le fichier original doit rester intact et le fichier temporaire doit être nettoyé.
|
||||
|
||||
:param tmp_path: Fixture pytest pour un répertoire temporaire.
|
||||
:return: None
|
||||
"""
|
||||
state_file = tmp_path / "state.json"
|
||||
|
||||
# Créer un état initial avec des GUID
|
||||
state = BlogRSSState(state_file)
|
||||
state.add_guids(["original-guid-1", "original-guid-2"])
|
||||
|
||||
# Lire le contenu original
|
||||
original_content = state_file.read_text(encoding="utf-8")
|
||||
|
||||
# Mock Path.replace pour simuler une erreur pendant le remplacement atomique
|
||||
with patch.object(Path, "replace") as mock_replace:
|
||||
mock_replace.side_effect = OSError("Simulated atomic replace failure")
|
||||
|
||||
# Essayer d'ajouter de nouveaux GUID, ce qui déclenchera _save()
|
||||
state.add_guids(["new-guid"])
|
||||
|
||||
# Vérifier que le fichier original est toujours intact
|
||||
assert state_file.read_text(encoding="utf-8") == original_content
|
||||
|
||||
# Vérifier que le fichier temporaire a été nettoyé
|
||||
tmp_file = state_file.with_suffix(".tmp")
|
||||
assert not tmp_file.exists()
|
||||
|
||||
# Vérifier que l'état en mémoire n'a pas été modifié (car la sauvegarde a échoué)
|
||||
# Note: En réalité, l'état en mémoire est modifié mais pas persistant
|
||||
# C'est le fichier qui doit rester intact
|
||||
assert state.get_known_guids() == frozenset({"original-guid-1", "original-guid-2", "new-guid"})
|
||||
|
||||
|
||||
# Ensure trailing newline
|
||||
146
tests/unit/test_theoretical_factory.py
Normal file
146
tests/unit/test_theoretical_factory.py
Normal file
@@ -0,0 +1,146 @@
|
||||
"""Tests unitaires pour l'usine de construction du fournisseur d'agenda théorique.
|
||||
|
||||
Ce module contient les tests pour la fonction :func:`get_theoretical_provider`
|
||||
du module :mod:`pronote_sync.sources.theoretical`.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import json
|
||||
from datetime import date
|
||||
from pathlib import Path
|
||||
|
||||
import pytest
|
||||
|
||||
from pronote_sync.errors import PronoteSyncError
|
||||
from pronote_sync.sources.theoretical import (
|
||||
TheoreticalAgendaProvider,
|
||||
get_theoretical_provider,
|
||||
)
|
||||
|
||||
|
||||
class TestGetTheoreticalProvider:
|
||||
"""Tests pour la fonction get_theoretical_provider."""
|
||||
|
||||
@pytest.fixture
|
||||
def fixture_path(self) -> Path:
|
||||
"""Retourne le chemin du fichier de fixture theoretical.json."""
|
||||
return Path(__file__).parent.parent / "fixtures" / "theoretical.json"
|
||||
|
||||
@pytest.fixture
|
||||
def holidays_path(self) -> Path:
|
||||
"""Retourne le chemin du fichier de fixture school_holidays.json."""
|
||||
return Path(__file__).parent.parent / "fixtures" / "school_holidays.json"
|
||||
|
||||
@pytest.fixture
|
||||
def all_only_path(self, tmp_path: Path) -> Path:
|
||||
"""Crée un fichier JSON avec uniquement des cours "all"."""
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Test",
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "all_only.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
return file_path
|
||||
|
||||
def test_factory_returns_none_when_path_none(self) -> None:
|
||||
"""Teste que l'usine retourne None quand agenda_path est None.
|
||||
|
||||
:assert: get_theoretical_provider(None, None, None, None) retourne None.
|
||||
"""
|
||||
result = get_theoretical_provider(None, None, None, None)
|
||||
assert result is None
|
||||
|
||||
def test_factory_returns_provider_with_full_config(
|
||||
self, fixture_path: Path, holidays_path: Path
|
||||
) -> None:
|
||||
"""Teste que l'usine retourne un fournisseur avec une configuration complète.
|
||||
|
||||
:assert: Un fournisseur est retourné avec tous les paramètres.
|
||||
"""
|
||||
result = get_theoretical_provider(
|
||||
agenda_path=str(fixture_path),
|
||||
holidays_path=str(holidays_path),
|
||||
anchor_date=date(2026, 9, 1),
|
||||
anchor_type="even",
|
||||
)
|
||||
assert result is not None
|
||||
assert isinstance(result, TheoreticalAgendaProvider)
|
||||
|
||||
def test_factory_partial_parity_config_error(self, fixture_path: Path) -> None:
|
||||
"""Teste qu'une configuration de parité partielle lève une PronoteSyncError.
|
||||
|
||||
:assert: PronoteSyncError est levée quand anchor_date est fourni sans anchor_type.
|
||||
"""
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
get_theoretical_provider(
|
||||
agenda_path=str(fixture_path),
|
||||
holidays_path=None,
|
||||
anchor_date=date(2026, 9, 1),
|
||||
anchor_type=None,
|
||||
)
|
||||
assert "incomplète" in str(exc_info.value)
|
||||
|
||||
def test_factory_partial_parity_config_error_type_only(self, fixture_path: Path) -> None:
|
||||
"""Teste qu'une configuration de parité partielle (type seulement) lève une PronoteSyncError.
|
||||
|
||||
:assert: PronoteSyncError est levée quand anchor_type est fourni sans anchor_date.
|
||||
"""
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
get_theoretical_provider(
|
||||
agenda_path=str(fixture_path),
|
||||
holidays_path=None,
|
||||
anchor_date=None,
|
||||
anchor_type="even",
|
||||
)
|
||||
assert "incomplète" in str(exc_info.value)
|
||||
|
||||
def test_factory_no_holidays(self, fixture_path: Path) -> None:
|
||||
"""Teste que l'usine retourne un fournisseur sans calendrier de vacances.
|
||||
|
||||
:assert: Un fournisseur est retourné sans calendrier de vacances.
|
||||
"""
|
||||
result = get_theoretical_provider(
|
||||
agenda_path=str(fixture_path),
|
||||
holidays_path=None,
|
||||
anchor_date=date(2026, 9, 1),
|
||||
anchor_type="even",
|
||||
)
|
||||
assert result is not None
|
||||
assert isinstance(result, TheoreticalAgendaProvider)
|
||||
|
||||
def test_factory_no_parity(self, all_only_path: Path) -> None:
|
||||
"""Teste que l'usine retourne un fournisseur sans service de parité pour des cours "all".
|
||||
|
||||
:assert: Un fournisseur est retourné sans service de parité.
|
||||
"""
|
||||
result = get_theoretical_provider(
|
||||
agenda_path=str(all_only_path),
|
||||
holidays_path=None,
|
||||
anchor_date=None,
|
||||
anchor_type=None,
|
||||
)
|
||||
assert result is not None
|
||||
assert isinstance(result, TheoreticalAgendaProvider)
|
||||
|
||||
def test_factory_protocol_compliance(self, fixture_path: Path, holidays_path: Path) -> None:
|
||||
"""Teste que le fournisseur retourné respecte le protocole TheoreticalAgendaProvider.
|
||||
|
||||
:assert: Le fournisseur satisfait isinstance(provider, TheoreticalAgendaProvider).
|
||||
"""
|
||||
result = get_theoretical_provider(
|
||||
agenda_path=str(fixture_path),
|
||||
holidays_path=str(holidays_path),
|
||||
anchor_date=date(2026, 9, 1),
|
||||
anchor_type="even",
|
||||
)
|
||||
assert result is not None
|
||||
assert isinstance(result, TheoreticalAgendaProvider)
|
||||
188
tests/unit/test_theoretical_holidays.py
Normal file
188
tests/unit/test_theoretical_holidays.py
Normal file
@@ -0,0 +1,188 @@
|
||||
"""Tests unitaires pour le calendrier des vacances scolaires.
|
||||
|
||||
Ce module contient les tests pour les classes :class:`SchoolHolidayCalendar`,
|
||||
:class:`HolidayPeriod` et :class:`SchoolHolidayFile` du module
|
||||
:mod:`pronote_sync.sources.theoretical.holidays`.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import json
|
||||
from datetime import date
|
||||
from pathlib import Path
|
||||
|
||||
import pytest
|
||||
|
||||
from pronote_sync.errors import PronoteSyncError
|
||||
from pronote_sync.sources.theoretical.holidays import SchoolHolidayCalendar
|
||||
|
||||
|
||||
class TestSchoolHolidayCalendar:
|
||||
"""Tests pour la classe SchoolHolidayCalendar."""
|
||||
|
||||
def test_load_valid_file(self, tmp_path: Path) -> None:
|
||||
"""Teste le chargement d'un fichier JSON valide.
|
||||
|
||||
:assert: is_holiday retourne True pour une date dans une période.
|
||||
"""
|
||||
holiday_data = {
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [
|
||||
{
|
||||
"start_date": "2026-10-17",
|
||||
"end_date": "2026-11-02",
|
||||
"label": "Toussaint",
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "holidays.json"
|
||||
file_path.write_text(json.dumps(holiday_data), encoding="utf-8")
|
||||
|
||||
calendar = SchoolHolidayCalendar(file_path)
|
||||
# Date dans la période de Toussaint
|
||||
assert calendar.is_holiday(date(2026, 10, 20)) is True
|
||||
|
||||
def test_date_outside_periods(self, tmp_path: Path) -> None:
|
||||
"""Teste qu'une date en dehors des périodes retourne False.
|
||||
|
||||
:assert: is_holiday retourne False pour une date hors période.
|
||||
"""
|
||||
holiday_data = {
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [
|
||||
{
|
||||
"start_date": "2026-10-17",
|
||||
"end_date": "2026-11-02",
|
||||
"label": "Toussaint",
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "holidays.json"
|
||||
file_path.write_text(json.dumps(holiday_data), encoding="utf-8")
|
||||
|
||||
calendar = SchoolHolidayCalendar(file_path)
|
||||
# Date en dehors de la période
|
||||
assert calendar.is_holiday(date(2026, 9, 1)) is False
|
||||
|
||||
def test_start_date_inclusive(self, tmp_path: Path) -> None:
|
||||
"""Teste que la date de début est incluse dans la période.
|
||||
|
||||
:assert: is_holiday retourne True pour une date égale à start_date.
|
||||
"""
|
||||
holiday_data = {
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [
|
||||
{
|
||||
"start_date": "2026-10-17",
|
||||
"end_date": "2026-11-02",
|
||||
"label": "Toussaint",
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "holidays.json"
|
||||
file_path.write_text(json.dumps(holiday_data), encoding="utf-8")
|
||||
|
||||
calendar = SchoolHolidayCalendar(file_path)
|
||||
assert calendar.is_holiday(date(2026, 10, 17)) is True
|
||||
|
||||
def test_end_date_inclusive(self, tmp_path: Path) -> None:
|
||||
"""Teste que la date de fin est incluse dans la période.
|
||||
|
||||
:assert: is_holiday retourne True pour une date égale à end_date.
|
||||
"""
|
||||
holiday_data = {
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [
|
||||
{
|
||||
"start_date": "2026-10-17",
|
||||
"end_date": "2026-11-02",
|
||||
"label": "Toussaint",
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "holidays.json"
|
||||
file_path.write_text(json.dumps(holiday_data), encoding="utf-8")
|
||||
|
||||
calendar = SchoolHolidayCalendar(file_path)
|
||||
assert calendar.is_holiday(date(2026, 11, 2)) is True
|
||||
|
||||
def test_file_not_found(self, tmp_path: Path) -> None:
|
||||
"""Teste qu'un fichier introuvable lève une PronoteSyncError.
|
||||
|
||||
:assert: PronoteSyncError est levée pour un fichier introuvable.
|
||||
"""
|
||||
file_path = tmp_path / "nonexistent.json"
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
SchoolHolidayCalendar(file_path)
|
||||
assert "introuvable" in str(exc_info.value)
|
||||
# Vérifier qu'aucun secret n'est fuité dans le message d'erreur
|
||||
assert "nonexistent" not in str(exc_info.value) or "introuvable" in str(exc_info.value)
|
||||
|
||||
def test_invalid_json(self, tmp_path: Path, caplog: pytest.LogCaptureFixture) -> None:
|
||||
"""Teste qu'un fichier JSON invalide lève une PronoteSyncError.
|
||||
|
||||
:assert: PronoteSyncError est levée pour un JSON invalide.
|
||||
"""
|
||||
file_path = tmp_path / "invalid.json"
|
||||
file_path.write_text("{ invalid json }", encoding="utf-8")
|
||||
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
SchoolHolidayCalendar(file_path)
|
||||
assert "invalide" in str(exc_info.value)
|
||||
|
||||
def test_invalid_period_dates(self, tmp_path: Path, caplog: pytest.LogCaptureFixture) -> None:
|
||||
"""Teste qu'une période avec end_date < start_date lève une ValidationError.
|
||||
|
||||
:assert: PronoteSyncError est levée pour des dates de période invalides.
|
||||
"""
|
||||
holiday_data = {
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [
|
||||
{
|
||||
"start_date": "2026-11-02",
|
||||
"end_date": "2026-10-17", # Inversé
|
||||
"label": "Toussaint",
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "holidays.json"
|
||||
file_path.write_text(json.dumps(holiday_data), encoding="utf-8")
|
||||
|
||||
with pytest.raises(PronoteSyncError):
|
||||
SchoolHolidayCalendar(file_path)
|
||||
|
||||
def test_empty_periods(self, tmp_path: Path) -> None:
|
||||
"""Teste qu'un fichier avec des périodes vides retourne toujours False.
|
||||
|
||||
:assert: is_holiday retourne False pour toutes les dates.
|
||||
"""
|
||||
holiday_data = {
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [],
|
||||
}
|
||||
file_path = tmp_path / "holidays.json"
|
||||
file_path.write_text(json.dumps(holiday_data), encoding="utf-8")
|
||||
|
||||
calendar = SchoolHolidayCalendar(file_path)
|
||||
assert calendar.is_holiday(date(2026, 10, 20)) is False
|
||||
assert calendar.is_holiday(date(2026, 1, 1)) is False
|
||||
|
||||
def test_load_from_fixture(self) -> None:
|
||||
"""Teste le chargement du fichier de fixture et vérifie une date connue.
|
||||
|
||||
:assert: is_holiday retourne True pour une date de vacances connue.
|
||||
"""
|
||||
fixture_path = Path(__file__).parent.parent / "fixtures" / "school_holidays.json"
|
||||
calendar = SchoolHolidayCalendar(fixture_path)
|
||||
# Date dans les vacances de Toussaint (17 oct - 2 nov 2026)
|
||||
assert calendar.is_holiday(date(2026, 10, 20)) is True
|
||||
# Date dans les vacances de Noël (19 déc 2026 - 4 janv 2027)
|
||||
assert calendar.is_holiday(date(2026, 12, 25)) is True
|
||||
# Date en dehors des vacances
|
||||
assert calendar.is_holiday(date(2026, 9, 1)) is False
|
||||
201
tests/unit/test_theoretical_model.py
Normal file
201
tests/unit/test_theoretical_model.py
Normal file
@@ -0,0 +1,201 @@
|
||||
"""Tests unitaires pour les modèles de parsing de l'agenda théorique.
|
||||
|
||||
Ce module contient les tests pour les classes :class:`TheoreticalLessonEntry`
|
||||
et :class:`TheoreticalAgendaFile` du module
|
||||
:mod:`pronote_sync.sources.theoretical.model`.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import pytest
|
||||
from pydantic import ValidationError
|
||||
|
||||
from pronote_sync.sources.theoretical.model import (
|
||||
TheoreticalAgendaFile,
|
||||
TheoreticalLessonEntry,
|
||||
)
|
||||
|
||||
|
||||
class TestTheoreticalLessonEntry:
|
||||
"""Tests pour la classe TheoreticalLessonEntry."""
|
||||
|
||||
def test_valid_lesson_entry(self) -> None:
|
||||
"""Teste la construction d'une entrée de cours valide.
|
||||
|
||||
:assert: Tous les champs sont correctement initialisés.
|
||||
"""
|
||||
entry = TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="08:00",
|
||||
end_time="09:00",
|
||||
subject="Mathématiques",
|
||||
teachers=("Mme Martin",),
|
||||
rooms=("101",),
|
||||
id="math-1",
|
||||
)
|
||||
assert entry.week == "all"
|
||||
assert entry.day_of_week == 0
|
||||
assert entry.start_time == "08:00"
|
||||
assert entry.end_time == "09:00"
|
||||
assert entry.subject == "Mathématiques"
|
||||
assert entry.teachers == ("Mme Martin",)
|
||||
assert entry.rooms == ("101",)
|
||||
assert entry.id == "math-1"
|
||||
|
||||
def test_invalid_time_format(self) -> None:
|
||||
"""Teste qu'une heure invalide (25:00) lève une ValidationError.
|
||||
|
||||
:assert: ValidationError est levée pour start_time="25:00".
|
||||
"""
|
||||
with pytest.raises(ValidationError) as exc_info:
|
||||
TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="25:00",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
assert "start_time" in str(exc_info.value)
|
||||
|
||||
def test_invalid_time_format_minutes(self) -> None:
|
||||
"""Teste qu'une minute invalide (60) lève une ValidationError.
|
||||
|
||||
:assert: ValidationError est levée pour start_time="08:60".
|
||||
"""
|
||||
with pytest.raises(ValidationError) as exc_info:
|
||||
TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="08:60",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
assert "start_time" in str(exc_info.value)
|
||||
|
||||
def test_end_before_start(self) -> None:
|
||||
"""Teste qu'une fin avant le début lève une ValidationError.
|
||||
|
||||
:assert: ValidationError est levée pour end_time < start_time.
|
||||
"""
|
||||
with pytest.raises(ValidationError) as exc_info:
|
||||
TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="10:00",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
assert "end_time" in str(exc_info.value)
|
||||
|
||||
def test_end_equal_start(self) -> None:
|
||||
"""Teste qu'une fin égale au début lève une ValidationError.
|
||||
|
||||
:assert: ValidationError est levée pour end_time == start_time.
|
||||
"""
|
||||
with pytest.raises(ValidationError) as exc_info:
|
||||
TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="09:00",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
assert "end_time" in str(exc_info.value)
|
||||
|
||||
def test_invalid_week(self) -> None:
|
||||
"""Teste qu'une semaine invalide lève une ValidationError.
|
||||
|
||||
:assert: ValidationError est levée pour week="weekly".
|
||||
"""
|
||||
with pytest.raises(ValidationError) as exc_info:
|
||||
TheoreticalLessonEntry(
|
||||
week="weekly", # type: ignore[arg-type]
|
||||
day_of_week=0,
|
||||
start_time="08:00",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
assert "week" in str(exc_info.value)
|
||||
|
||||
def test_invalid_day_of_week(self) -> None:
|
||||
"""Teste qu'un jour de semaine invalide (7) lève une ValidationError.
|
||||
|
||||
:assert: ValidationError est levée pour day_of_week=7.
|
||||
"""
|
||||
with pytest.raises(ValidationError) as exc_info:
|
||||
TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=7,
|
||||
start_time="08:00",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
assert "day_of_week" in str(exc_info.value)
|
||||
|
||||
def test_optional_fields_defaults(self) -> None:
|
||||
"""Teste que les champs optionnels ont des valeurs par défaut.
|
||||
|
||||
:assert: teachers et rooms valent () par défaut.
|
||||
"""
|
||||
entry = TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="08:00",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
assert entry.teachers == ()
|
||||
assert entry.rooms == ()
|
||||
|
||||
def test_frozen_model(self) -> None:
|
||||
"""Teste que le modèle est immuable (frozen).
|
||||
|
||||
:assert: La tentative de mutation lève une exception.
|
||||
"""
|
||||
entry = TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="08:00",
|
||||
end_time="09:00",
|
||||
subject="Test",
|
||||
)
|
||||
with pytest.raises((ValidationError, AttributeError)):
|
||||
entry.subject = "Nouveau"
|
||||
|
||||
|
||||
class TestTheoreticalAgendaFile:
|
||||
"""Tests pour la classe TheoreticalAgendaFile."""
|
||||
|
||||
def test_agenda_file_valid(self) -> None:
|
||||
"""Teste la construction d'un fichier d'agenda valide.
|
||||
|
||||
:assert: version == 1 et lessons a le bon nombre d'entrées.
|
||||
"""
|
||||
lessons = [
|
||||
TheoreticalLessonEntry(
|
||||
week="all",
|
||||
day_of_week=0,
|
||||
start_time="08:00",
|
||||
end_time="09:00",
|
||||
subject="Mathématiques",
|
||||
),
|
||||
TheoreticalLessonEntry(
|
||||
week="even",
|
||||
day_of_week=1,
|
||||
start_time="10:00",
|
||||
end_time="11:00",
|
||||
subject="Anglais",
|
||||
),
|
||||
]
|
||||
agenda = TheoreticalAgendaFile(version=1, lessons=tuple(lessons))
|
||||
assert agenda.version == 1
|
||||
assert len(agenda.lessons) == 2
|
||||
|
||||
def test_agenda_file_default_version(self) -> None:
|
||||
"""Teste que la version par défaut est 1.
|
||||
|
||||
:assert: version vaut 1 par défaut.
|
||||
"""
|
||||
agenda = TheoreticalAgendaFile(lessons=())
|
||||
assert agenda.version == 1
|
||||
116
tests/unit/test_theoretical_parity.py
Normal file
116
tests/unit/test_theoretical_parity.py
Normal file
@@ -0,0 +1,116 @@
|
||||
"""Tests unitaires pour le service de parité des semaines.
|
||||
|
||||
Ce module contient les tests pour la classe :class:`WeekParityService`
|
||||
du module :mod:`pronote_sync.sources.theoretical.parity`.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
from datetime import date
|
||||
|
||||
from pronote_sync.sources.theoretical.parity import WeekParityService
|
||||
|
||||
|
||||
class TestWeekParityService:
|
||||
"""Tests pour la classe WeekParityService."""
|
||||
|
||||
def test_same_week_as_anchor_even(self) -> None:
|
||||
"""Teste qu'une date dans la même semaine que l'ancrage pair retourne "even".
|
||||
|
||||
:assert: parity_for retourne "even" pour une date dans la même semaine.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 1) # Mardi
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# Même semaine (lundi 31 août 2026)
|
||||
target_date = date(2026, 9, 1)
|
||||
assert service.parity_for(target_date) == "even"
|
||||
|
||||
def test_one_week_after_anchor_even(self) -> None:
|
||||
"""Teste qu'une date une semaine après l'ancrage pair retourne "odd".
|
||||
|
||||
:assert: parity_for retourne "odd" pour une date une semaine après.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 1) # Mardi
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# Une semaine après (mardi 8 septembre 2026)
|
||||
target_date = date(2026, 9, 8)
|
||||
assert service.parity_for(target_date) == "odd"
|
||||
|
||||
def test_two_weeks_after_anchor_even(self) -> None:
|
||||
"""Teste qu'une date deux semaines après l'ancrage pair retourne "even".
|
||||
|
||||
:assert: parity_for retourne "even" pour une date deux semaines après.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 1) # Mardi
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# Deux semaines après (mardi 15 septembre 2026)
|
||||
target_date = date(2026, 9, 15)
|
||||
assert service.parity_for(target_date) == "even"
|
||||
|
||||
def test_same_week_as_anchor_odd(self) -> None:
|
||||
"""Teste qu'une date dans la même semaine que l'ancrage impair retourne "odd".
|
||||
|
||||
:assert: parity_for retourne "odd" pour une date dans la même semaine.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 1) # Mardi
|
||||
service = WeekParityService(anchor_date, "odd")
|
||||
target_date = date(2026, 9, 1)
|
||||
assert service.parity_for(target_date) == "odd"
|
||||
|
||||
def test_one_week_before_anchor(self) -> None:
|
||||
"""Teste qu'une date une semaine avant l'ancrage retourne la parité opposée.
|
||||
|
||||
:assert: parity_for retourne la parité opposée pour une date une semaine avant.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 8) # Mardi
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# Une semaine avant (mardi 1er septembre 2026)
|
||||
target_date = date(2026, 9, 1)
|
||||
assert service.parity_for(target_date) == "odd"
|
||||
|
||||
def test_many_weeks_later(self) -> None:
|
||||
"""Teste qu'une date 10 semaines après l'ancrage pair retourne "even".
|
||||
|
||||
:assert: parity_for retourne "even" pour une date 10 semaines après.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 1) # Mardi
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# 10 semaines après (70 jours)
|
||||
target_date = date(2026, 11, 10)
|
||||
assert service.parity_for(target_date) == "even"
|
||||
|
||||
def test_negative_offset(self) -> None:
|
||||
"""Teste qu'une date loin avant l'ancrage calcule correctement la parité.
|
||||
|
||||
:assert: parity_for retourne la parité correcte pour une date loin dans le passé.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 1) # Mardi
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# 10 semaines avant (70 jours)
|
||||
target_date = date(2026, 6, 23)
|
||||
assert service.parity_for(target_date) == "even"
|
||||
|
||||
def test_different_day_in_same_week(self) -> None:
|
||||
"""Teste que lundi et vendredi de la même semaine ont la même parité.
|
||||
|
||||
:assert: parity_for retourne la même parité pour lundi et vendredi de la même semaine.
|
||||
"""
|
||||
anchor_date = date(2026, 9, 1) # Mardi
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# Lundi de la même semaine
|
||||
monday = date(2026, 8, 31)
|
||||
# Vendredi de la même semaine
|
||||
friday = date(2026, 9, 4)
|
||||
assert service.parity_for(monday) == "even"
|
||||
assert service.parity_for(friday) == "even"
|
||||
|
||||
def test_crosses_year_boundary(self) -> None:
|
||||
"""Teste que le calcul de parité fonctionne à cheval sur une année.
|
||||
|
||||
:assert: parity_for retourne la parité correcte à cheval sur une année.
|
||||
"""
|
||||
anchor_date = date(2026, 12, 29) # Mardi (semaine 53)
|
||||
service = WeekParityService(anchor_date, "even")
|
||||
# Date dans la semaine suivante (année 2027)
|
||||
target_date = date(2027, 1, 5) # Mardi de la semaine suivante
|
||||
assert service.parity_for(target_date) == "odd"
|
||||
722
tests/unit/test_theoretical_provider.py
Normal file
722
tests/unit/test_theoretical_provider.py
Normal file
@@ -0,0 +1,722 @@
|
||||
"""Tests unitaires pour le fournisseur d'agenda théorique basé sur fichier JSON.
|
||||
|
||||
Ce module contient les tests pour la classe :class:`JsonTheoreticalAgendaProvider`
|
||||
du module :mod:`pronote_sync.sources.theoretical.file`.
|
||||
"""
|
||||
|
||||
from __future__ import annotations
|
||||
|
||||
import json
|
||||
from datetime import date
|
||||
from pathlib import Path
|
||||
|
||||
import pytest
|
||||
|
||||
from pronote_sync.errors import PronoteSyncError
|
||||
from pronote_sync.sources.theoretical.file import JsonTheoreticalAgendaProvider, normalize_subject
|
||||
from pronote_sync.sources.theoretical.holidays import SchoolHolidayCalendar
|
||||
from pronote_sync.sources.theoretical.parity import WeekParityService
|
||||
|
||||
|
||||
class TestJsonTheoreticalAgendaProvider:
|
||||
"""Tests pour la classe JsonTheoreticalAgendaProvider."""
|
||||
|
||||
@pytest.fixture
|
||||
def fixture_path(self) -> Path:
|
||||
"""Retourne le chemin du fichier de fixture theoretical.json."""
|
||||
return Path(__file__).parent.parent / "fixtures" / "theoretical.json"
|
||||
|
||||
@pytest.fixture
|
||||
def holidays_path(self) -> Path:
|
||||
"""Retourne le chemin du fichier de fixture school_holidays.json."""
|
||||
return Path(__file__).parent.parent / "fixtures" / "school_holidays.json"
|
||||
|
||||
@pytest.fixture
|
||||
def all_only_path(self, tmp_path: Path) -> Path:
|
||||
"""Crée un fichier JSON avec uniquement des cours "all"."""
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"id": "theoretical-maths-monday-1",
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Mathématiques",
|
||||
"teachers": ["Mme Martin"],
|
||||
"rooms": ["101"],
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "09:00",
|
||||
"end_time": "10:00",
|
||||
"subject": "Français",
|
||||
"teachers": ["M. Dupont"],
|
||||
"rooms": ["102"],
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "11:00",
|
||||
"end_time": "12:00",
|
||||
"subject": "Histoire-Géographie",
|
||||
"teachers": ["Mme Petit"],
|
||||
"rooms": ["103"],
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 2,
|
||||
"start_time": "14:00",
|
||||
"end_time": "15:00",
|
||||
"subject": "Sciences",
|
||||
"teachers": [],
|
||||
"rooms": ["203"],
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 4,
|
||||
"start_time": "09:00",
|
||||
"end_time": "10:00",
|
||||
"subject": "Arts plastiques",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
},
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "all_only.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
return file_path
|
||||
|
||||
@pytest.fixture
|
||||
def provider_no_parity_no_holidays(self, all_only_path: Path) -> JsonTheoreticalAgendaProvider:
|
||||
"""Fournisseur sans service de parité ni calendrier de vacances."""
|
||||
return JsonTheoreticalAgendaProvider(
|
||||
file_path=str(all_only_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
|
||||
@pytest.fixture
|
||||
def provider_with_parity(self, fixture_path: Path) -> JsonTheoreticalAgendaProvider:
|
||||
"""Fournisseur avec service de parité (ancrage sur 2026-09-01, even)."""
|
||||
parity_service = WeekParityService(date(2026, 9, 1), "even")
|
||||
return JsonTheoreticalAgendaProvider(
|
||||
file_path=str(fixture_path),
|
||||
parity_service=parity_service,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
|
||||
@pytest.fixture
|
||||
def provider_with_holidays(
|
||||
self, fixture_path: Path, holidays_path: Path
|
||||
) -> JsonTheoreticalAgendaProvider:
|
||||
"""Fournisseur avec calendrier de vacances."""
|
||||
holiday_calendar = SchoolHolidayCalendar(holidays_path)
|
||||
return JsonTheoreticalAgendaProvider(
|
||||
file_path=str(fixture_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=holiday_calendar,
|
||||
)
|
||||
|
||||
@pytest.fixture
|
||||
def provider_full(
|
||||
self, fixture_path: Path, holidays_path: Path
|
||||
) -> JsonTheoreticalAgendaProvider:
|
||||
"""Fournisseur avec service de parité et calendrier de vacances."""
|
||||
parity_service = WeekParityService(date(2026, 9, 1), "even")
|
||||
holiday_calendar = SchoolHolidayCalendar(holidays_path)
|
||||
return JsonTheoreticalAgendaProvider(
|
||||
file_path=str(fixture_path),
|
||||
parity_service=parity_service,
|
||||
holiday_calendar=holiday_calendar,
|
||||
)
|
||||
|
||||
def test_get_lessons_all_weeks(
|
||||
self, provider_no_parity_no_holidays: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste la récupération des cours pour un lundi (jour 0) sans parité.
|
||||
|
||||
:assert: Les cours "all" pour le lundi sont retournés.
|
||||
"""
|
||||
# Lundi 2026-08-31 (weekday = 0)
|
||||
target_date = date(2026, 8, 31)
|
||||
lessons = provider_no_parity_no_holidays.get_lessons(target_date)
|
||||
# Le fichier all_only a 3 cours "all" pour le lundi (day_of_week=0)
|
||||
assert len(lessons) == 3
|
||||
subjects = [lesson.subject for lesson in lessons]
|
||||
assert "Mathématiques" in subjects
|
||||
assert "Français" in subjects
|
||||
assert "Histoire-Géographie" in subjects
|
||||
|
||||
def test_get_lessons_even_week(
|
||||
self, provider_with_parity: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste la récupération des cours pour une semaine paire.
|
||||
|
||||
:assert: Les cours "even" pour le mardi sont retournés.
|
||||
"""
|
||||
# Mardi 2026-09-01 (weekday = 1), semaine paire (ancrage 2026-09-01 even)
|
||||
# Note: 2026-09-01 est mardi (weekday=1)
|
||||
target_date = date(2026, 9, 1)
|
||||
lessons = provider_with_parity.get_lessons(target_date)
|
||||
# Le fixture a 2 cours "even" pour le mardi (day_of_week=1)
|
||||
subjects = [lesson.subject for lesson in lessons]
|
||||
assert "Anglais" in subjects
|
||||
assert "Technologie" in subjects
|
||||
|
||||
def test_get_lessons_odd_week(
|
||||
self, provider_with_parity: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste la récupération des cours pour une semaine impaire.
|
||||
|
||||
:assert: Les cours "odd" pour le mardi sont retournés.
|
||||
"""
|
||||
# Mardi 2026-09-08 (weekday = 1), semaine impaire (1 semaine après l'ancrage 2026-09-01)
|
||||
target_date = date(2026, 9, 8)
|
||||
lessons = provider_with_parity.get_lessons(target_date)
|
||||
# Le fixture a 2 cours "odd" pour le mardi (day_of_week=1)
|
||||
subjects = [lesson.subject for lesson in lessons]
|
||||
assert "Espagnol" in subjects
|
||||
assert "Éducation musicale" in subjects
|
||||
|
||||
def test_get_lessons_holiday_returns_empty(
|
||||
self, provider_full: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste qu'une date en vacances retourne une liste vide.
|
||||
|
||||
:assert: get_lessons retourne [] pour une date en vacances.
|
||||
"""
|
||||
# Date pendant les vacances de Toussaint (17 oct - 2 nov 2026)
|
||||
target_date = date(2026, 10, 20)
|
||||
lessons = provider_full.get_lessons(target_date)
|
||||
assert lessons == []
|
||||
|
||||
def test_get_lessons_no_holiday_calendar(
|
||||
self, provider_with_parity: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste que sans calendrier de vacances, les cours sont retournés même en vacances.
|
||||
|
||||
:assert: Les cours sont retournés pour une date en vacances.
|
||||
"""
|
||||
# Date pendant les vacances de Toussaint, mais sans calendrier de vacances
|
||||
target_date = date(2026, 10, 20) # Mardi (weekday = 1)
|
||||
lessons = provider_with_parity.get_lessons(target_date)
|
||||
# Sans calendrier de vacances, les cours "even" pour le mardi sont retournés
|
||||
assert len(lessons) == 2
|
||||
|
||||
def test_get_lessons_sorted_by_id(
|
||||
self, provider_no_parity_no_holidays: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste que les cours sont triés par identifiant.
|
||||
|
||||
:assert: Les cours sont triés par id.
|
||||
"""
|
||||
# Lundi 2026-08-31 (weekday = 0)
|
||||
target_date = date(2026, 8, 31)
|
||||
lessons = provider_no_parity_no_holidays.get_lessons(target_date)
|
||||
ids = [lesson.id for lesson in lessons]
|
||||
assert ids == sorted(ids)
|
||||
|
||||
def test_get_lessons_deterministic(
|
||||
self, provider_no_parity_no_holidays: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste que get_lessons retourne des résultats identiques pour la même date.
|
||||
|
||||
:assert: Deux appels avec la même date retournent des résultats identiques.
|
||||
"""
|
||||
# Lundi 2026-08-31 (weekday = 0)
|
||||
target_date = date(2026, 8, 31)
|
||||
lessons1 = provider_no_parity_no_holidays.get_lessons(target_date)
|
||||
lessons2 = provider_no_parity_no_holidays.get_lessons(target_date)
|
||||
assert lessons1 == lessons2
|
||||
|
||||
def test_even_odd_different_subjects_different_ids(
|
||||
self, provider_with_parity: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste que les cours even/odd sur le même créneau avec des matières différentes ont des IDs différents.
|
||||
|
||||
:assert: Les IDs des cours even et odd sont différents.
|
||||
"""
|
||||
# Mardi 2026-09-01 (semaine paire, même semaine que l'ancrage)
|
||||
even_lessons = provider_with_parity.get_lessons(date(2026, 9, 1))
|
||||
# Mardi 2026-09-08 (semaine impaire, 1 semaine après l'ancrage)
|
||||
odd_lessons = provider_with_parity.get_lessons(date(2026, 9, 8))
|
||||
|
||||
# Les deux semaines ont des cours sur le même créneau (10:00-11:00)
|
||||
# mais avec des matières différentes (Anglais/Technologie vs Espagnol/Éducation musicale)
|
||||
even_subjects = {lesson.subject for lesson in even_lessons}
|
||||
odd_subjects = {lesson.subject for lesson in odd_lessons}
|
||||
|
||||
# Les matières doivent être différentes
|
||||
assert "Anglais" in even_subjects
|
||||
assert "Espagnol" in odd_subjects
|
||||
# Les IDs ne doivent pas être identiques
|
||||
even_ids = {lesson.id for lesson in even_lessons}
|
||||
odd_ids = {lesson.id for lesson in odd_lessons}
|
||||
assert even_ids.isdisjoint(odd_ids)
|
||||
|
||||
def test_even_odd_same_subject_different_ids(self, tmp_path: Path) -> None:
|
||||
"""Vérifie que les leçons paire/impaire sur le même créneau avec la même matière ont des IDs distincts.
|
||||
|
||||
Utilise la même matière pour isoler la parité comme seul différenciateur.
|
||||
|
||||
:assert: Les IDs des cours even et odd sont différents, avec la même matière.
|
||||
"""
|
||||
json_content = json.dumps(
|
||||
{
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"week": "even",
|
||||
"day_of_week": 1,
|
||||
"start_time": "10:00",
|
||||
"end_time": "11:00",
|
||||
"subject": "Langue vivante",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
},
|
||||
{
|
||||
"week": "odd",
|
||||
"day_of_week": 1,
|
||||
"start_time": "10:00",
|
||||
"end_time": "11:00",
|
||||
"subject": "Langue vivante",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
},
|
||||
],
|
||||
}
|
||||
)
|
||||
file_path = tmp_path / "theoretical.json"
|
||||
file_path.write_text(json_content, encoding="utf-8")
|
||||
|
||||
anchor_date = date(2026, 9, 1) # Tuesday
|
||||
parity = WeekParityService(anchor_date, "even")
|
||||
provider = JsonTheoreticalAgendaProvider(file_path=str(file_path), parity_service=parity)
|
||||
|
||||
# Tuesday in even week
|
||||
even_tuesday = date(2026, 9, 1) # Same week as anchor (even)
|
||||
odd_tuesday = date(2026, 9, 8) # One week later (odd)
|
||||
|
||||
even_lessons = provider.get_lessons(even_tuesday)
|
||||
odd_lessons = provider.get_lessons(odd_tuesday)
|
||||
|
||||
assert len(even_lessons) == 1
|
||||
assert len(odd_lessons) == 1
|
||||
assert even_lessons[0].id != odd_lessons[0].id
|
||||
# The only difference in the ID should be the week type
|
||||
assert "even" in even_lessons[0].id
|
||||
assert "odd" in odd_lessons[0].id
|
||||
|
||||
def test_explicit_id_preserved(
|
||||
self, provider_no_parity_no_holidays: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste qu'un ID explicite est préservé.
|
||||
|
||||
:assert: L'ID explicite "theoretical-maths-monday-1" est utilisé.
|
||||
"""
|
||||
# Lundi 2026-08-31 (weekday = 0)
|
||||
target_date = date(2026, 8, 31)
|
||||
lessons = provider_no_parity_no_holidays.get_lessons(target_date)
|
||||
ids = [lesson.id for lesson in lessons]
|
||||
assert "theoretical-maths-monday-1" in ids
|
||||
|
||||
def test_generated_id_includes_week(
|
||||
self, provider_no_parity_no_holidays: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste qu'un ID généré inclut le type de semaine.
|
||||
|
||||
:assert: L'ID généré contient le type de semaine.
|
||||
"""
|
||||
# Lundi 2026-08-31 (weekday = 0)
|
||||
target_date = date(2026, 8, 31)
|
||||
lessons = provider_no_parity_no_holidays.get_lessons(target_date)
|
||||
# Trouver un cours sans ID explicite (Français ou Histoire-Géographie)
|
||||
for lesson in lessons:
|
||||
if lesson.subject in ("Français", "Histoire-Géographie"):
|
||||
assert "all" in lesson.id
|
||||
break
|
||||
|
||||
def test_no_parity_service_with_all_only_lessons(self, all_only_path: Path) -> None:
|
||||
"""Teste qu'un fournisseur sans service de parité fonctionne avec des cours "all".
|
||||
|
||||
:assert: Les cours "all" sont retournés correctement.
|
||||
"""
|
||||
provider = JsonTheoreticalAgendaProvider(
|
||||
file_path=str(all_only_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
# Lundi 2026-08-31 (weekday = 0)
|
||||
target_date = date(2026, 8, 31)
|
||||
lessons = provider.get_lessons(target_date)
|
||||
assert len(lessons) == 3
|
||||
|
||||
def test_even_lessons_without_parity_service_error(
|
||||
self, tmp_path: Path, caplog: pytest.LogCaptureFixture
|
||||
) -> None:
|
||||
"""Teste qu'un fichier avec des cours even/odd sans service de parité lève une erreur.
|
||||
|
||||
:assert: PronoteSyncError est levée.
|
||||
"""
|
||||
# Créer un fichier JSON avec uniquement des cours even/odd
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"week": "even",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Test",
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "even_only.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
JsonTheoreticalAgendaProvider(
|
||||
file_path=str(file_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
assert "ancre de parité" in str(exc_info.value)
|
||||
|
||||
def test_invalid_json_file(self, tmp_path: Path, caplog: pytest.LogCaptureFixture) -> None:
|
||||
"""Teste qu'un fichier JSON invalide lève une PronoteSyncError.
|
||||
|
||||
:assert: PronoteSyncError est levée pour un JSON invalide.
|
||||
"""
|
||||
file_path = tmp_path / "invalid.json"
|
||||
file_path.write_text("{ invalid json }", encoding="utf-8")
|
||||
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
JsonTheoreticalAgendaProvider(
|
||||
file_path=str(file_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
assert "invalide" in str(exc_info.value)
|
||||
|
||||
def test_get_lessons_for_range(
|
||||
self, provider_no_parity_no_holidays: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste la récupération des cours pour une plage de 5 jours.
|
||||
|
||||
:assert: Tous les cours uniques sont retournés, triés par ID.
|
||||
"""
|
||||
# Lundi 2026-08-31 à Vendredi 2026-09-04
|
||||
start_date = date(2026, 8, 31) # Lundi
|
||||
end_date = date(2026, 9, 4) # Vendredi
|
||||
lessons = provider_no_parity_no_holidays.get_lessons_for_range(start_date, end_date)
|
||||
|
||||
# Le fichier all_only a des cours pour lundi (3), mercredi (1), vendredi (1)
|
||||
# Total: 3 + 1 + 1 = 5 cours uniques
|
||||
assert len(lessons) == 5
|
||||
ids = [lesson.id for lesson in lessons]
|
||||
assert ids == sorted(ids)
|
||||
|
||||
def test_get_lessons_for_range_with_holidays(
|
||||
self, provider_full: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste la récupération des cours pour une plage incluant des jours de vacances.
|
||||
|
||||
:assert: Les jours de vacances ne contribuent pas de cours.
|
||||
"""
|
||||
# Plage incluant des vacances de Toussaint (17 oct - 2 nov 2026)
|
||||
# Le 15 oct 2026 est un mercredi (day_of_week=2), le fixture a un cours "all" pour mercredi
|
||||
# Le 16 oct 2026 est un jeudi (day_of_week=3), pas de cours dans le fixture
|
||||
# Le 17 oct 2026 est un vendredi (day_of_week=4), le fixture a un cours "all" pour vendredi
|
||||
# Mais le 17 oct est le début des vacances, donc pas de cours
|
||||
start_date = date(2026, 10, 15) # Mercredi (avant vacances)
|
||||
end_date = date(2026, 10, 16) # Jeudi (avant vacances)
|
||||
lessons = provider_full.get_lessons_for_range(start_date, end_date)
|
||||
|
||||
# Le 15 oct (mercredi) devrait avoir un cours "all" pour Sciences
|
||||
# Le 16 oct (jeudi) n'a pas de cours dans le fixture
|
||||
# Donc on devrait avoir au moins 1 cours
|
||||
assert len(lessons) >= 1
|
||||
|
||||
def test_get_lessons_for_range_empty(
|
||||
self, provider_full: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste qu'une plage où tous les jours sont en vacances retourne une liste vide.
|
||||
|
||||
:assert: get_lessons_for_range retourne [] pour une plage entièrement en vacances.
|
||||
"""
|
||||
# Plage entièrement pendant les vacances de Toussaint
|
||||
start_date = date(2026, 10, 17)
|
||||
end_date = date(2026, 10, 24)
|
||||
lessons = provider_full.get_lessons_for_range(start_date, end_date)
|
||||
assert lessons == []
|
||||
|
||||
def test_get_lessons_sunday(
|
||||
self, provider_no_parity_no_holidays: JsonTheoreticalAgendaProvider
|
||||
) -> None:
|
||||
"""Teste qu'un dimanche retourne une liste vide.
|
||||
|
||||
:assert: get_lessons retourne [] pour un dimanche.
|
||||
"""
|
||||
# Dimanche 2026-09-06 (weekday = 6)
|
||||
target_date = date(2026, 9, 6)
|
||||
lessons = provider_no_parity_no_holidays.get_lessons(target_date)
|
||||
# Aucun cours n'est prévu pour le dimanche dans le fichier all_only
|
||||
assert lessons == []
|
||||
|
||||
def test_get_lessons_for_range_dedup_across_weeks(self, tmp_path: Path) -> None:
|
||||
"""Vérifie que get_lessons_for_range déduplique les leçons récurrentes.
|
||||
|
||||
:assert: Une leçon récurrente sur plusieurs semaines n'apparaît qu'une fois.
|
||||
"""
|
||||
# Créer un fichier JSON avec une seule leçon "all" le lundi 08:00-09:00 "Maths"
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0, # Lundi
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Maths",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "dedup_test.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
|
||||
provider = JsonTheoreticalAgendaProvider(
|
||||
file_path=str(file_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
|
||||
# Plage du 31 août 2026 (lundi) au 11 septembre 2026 (vendredi)
|
||||
# Cela couvre 2 lundis (31 août et 7 septembre)
|
||||
start_date = date(2026, 8, 31)
|
||||
end_date = date(2026, 9, 11)
|
||||
lessons = provider.get_lessons_for_range(start_date, end_date)
|
||||
|
||||
# La leçon récurrente devrait apparaître une seule fois
|
||||
assert len(lessons) == 1
|
||||
assert lessons[0].subject == "Maths"
|
||||
|
||||
def test_duplicate_explicit_ids_rejected(self, tmp_path: Path) -> None:
|
||||
"""Vérifie que les IDs explicites dupliqués sont rejetés.
|
||||
|
||||
:assert: PronoteSyncError est levée pour des IDs explicites dupliqués.
|
||||
"""
|
||||
# Créer un fichier JSON avec 2 leçons ayant le même ID explicite
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"id": "dup-id",
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Maths",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
},
|
||||
{
|
||||
"id": "dup-id",
|
||||
"week": "all",
|
||||
"day_of_week": 1,
|
||||
"start_time": "09:00",
|
||||
"end_time": "10:00",
|
||||
"subject": "Français",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
},
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "duplicate_ids.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
JsonTheoreticalAgendaProvider(
|
||||
file_path=str(file_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
assert "Conflit d'identifiant" in str(exc_info.value) or "identifiant" in str(
|
||||
exc_info.value
|
||||
)
|
||||
|
||||
def test_generated_id_collision_rejected(self, tmp_path: Path) -> None:
|
||||
"""Vérifie que les collisions d'IDs générés sont détectées.
|
||||
|
||||
:assert: PronoteSyncError est levée pour des IDs générés identiques.
|
||||
"""
|
||||
# Créer un fichier JSON avec 2 leçons qui produisent le même ID généré
|
||||
# Même week, day_of_week, start_time, end_time, subject mais enseignants différents
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Maths",
|
||||
"teachers": ["Prof1"],
|
||||
"rooms": [],
|
||||
},
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Maths",
|
||||
"teachers": ["Prof2"],
|
||||
"rooms": [],
|
||||
},
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "generated_id_collision.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
JsonTheoreticalAgendaProvider(
|
||||
file_path=str(file_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
assert "Conflit d'identifiant" in str(exc_info.value) or "identifiant" in str(
|
||||
exc_info.value
|
||||
)
|
||||
|
||||
def test_get_lessons_for_range_mixed_holidays_and_normal(self, tmp_path: Path) -> None:
|
||||
"""Vérifie qu'une plage mixte (jours normaux et vacances) retourne les leçons des jours non vacanciers.
|
||||
|
||||
:assert: Les leçons des jours non vacanciers sont retournées, les jours de vacances sont ignorés.
|
||||
"""
|
||||
# Créer un fichier JSON avec une leçon "all" le jeudi 14:00-15:00 "Sciences"
|
||||
# Note: 2026-10-15 est un jeudi (weekday=3)
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"week": "all",
|
||||
"day_of_week": 3, # Jeudi
|
||||
"start_time": "14:00",
|
||||
"end_time": "15:00",
|
||||
"subject": "Sciences",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
}
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "mixed_holidays.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
|
||||
# Créer un fichier de vacances avec une période du 16 au 20 octobre 2026
|
||||
holidays_data = {
|
||||
"zone": "A",
|
||||
"school_year": "2026-2027",
|
||||
"periods": [
|
||||
{"start_date": "2026-10-16", "end_date": "2026-10-20", "label": "Test Vacances"}
|
||||
],
|
||||
}
|
||||
holidays_path = tmp_path / "test_holidays.json"
|
||||
holidays_path.write_text(json.dumps(holidays_data), encoding="utf-8")
|
||||
|
||||
holiday_calendar = SchoolHolidayCalendar(holidays_path)
|
||||
provider = JsonTheoreticalAgendaProvider(
|
||||
file_path=str(file_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=holiday_calendar,
|
||||
)
|
||||
|
||||
# Plage du 15 octobre (jeudi, pas en vacances) au 17 octobre (samedi, en vacances)
|
||||
start_date = date(2026, 10, 15) # Jeudi
|
||||
end_date = date(2026, 10, 17) # Samedi
|
||||
lessons = provider.get_lessons_for_range(start_date, end_date)
|
||||
|
||||
# Seule la leçon du 15 octobre (jeudi) devrait être retournée
|
||||
assert len(lessons) == 1
|
||||
assert lessons[0].subject == "Sciences"
|
||||
|
||||
def test_normalize_subject_variants_produce_same_id(self, tmp_path: Path) -> None:
|
||||
"""Vérifie que des variantes de casse, d'espacement et d'Unicode produisent le même ID.
|
||||
|
||||
:assert: Les variantes de la même matière produisent le même ID normalisé.
|
||||
"""
|
||||
# Test the normalize_subject function directly
|
||||
# Note: hyphens are removed entirely (not replaced with spaces) by normalize_subject
|
||||
variants = [
|
||||
"Mathématiques avancées",
|
||||
"mathématiques avancées",
|
||||
"Mathématiques avancées",
|
||||
"MATHÉMATIQUES AVANCÉES",
|
||||
]
|
||||
normalized = [normalize_subject(variant) for variant in variants]
|
||||
# All should normalize to the same value
|
||||
assert all(n == normalized[0] for n in normalized)
|
||||
# Should be lowercase, no extra spaces, no punctuation
|
||||
assert normalized[0] == "mathématiques avancées"
|
||||
|
||||
def test_collision_error_no_secret_leak(
|
||||
self, tmp_path: Path, caplog: pytest.LogCaptureFixture
|
||||
) -> None:
|
||||
"""Vérifie qu'une sentinelle dans un ID dupliqué n'apparaît pas dans l'erreur.
|
||||
|
||||
:assert: PronoteSyncError est levée et la sentinelle n'apparaît pas dans l'erreur.
|
||||
"""
|
||||
# Use a secret pattern that the redaction system will actually catch
|
||||
# The _ISOLATED_SECRET_PATTERN looks for things like secret=value or secret: value
|
||||
sentinel_value = "SENTINELLE_M6_SECRET"
|
||||
# Create an ID that contains a pattern like "secret=value" which will be redacted
|
||||
secret_pattern = f"secret={sentinel_value}"
|
||||
|
||||
# Créer un fichier JSON avec 2 entrées ayant le même ID explicite contenant la sentinelle
|
||||
data = {
|
||||
"version": 1,
|
||||
"lessons": [
|
||||
{
|
||||
"id": f"theoretical-{secret_pattern}-1",
|
||||
"week": "all",
|
||||
"day_of_week": 0,
|
||||
"start_time": "08:00",
|
||||
"end_time": "09:00",
|
||||
"subject": "Maths",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
},
|
||||
{
|
||||
"id": f"theoretical-{secret_pattern}-1",
|
||||
"week": "all",
|
||||
"day_of_week": 1,
|
||||
"start_time": "09:00",
|
||||
"end_time": "10:00",
|
||||
"subject": "Français",
|
||||
"teachers": [],
|
||||
"rooms": [],
|
||||
},
|
||||
],
|
||||
}
|
||||
file_path = tmp_path / "collision_test.json"
|
||||
file_path.write_text(json.dumps(data), encoding="utf-8")
|
||||
|
||||
with caplog.at_level("ERROR"):
|
||||
with pytest.raises(PronoteSyncError) as exc_info:
|
||||
JsonTheoreticalAgendaProvider(
|
||||
file_path=str(file_path),
|
||||
parity_service=None,
|
||||
holiday_calendar=None,
|
||||
)
|
||||
# Check that the sentinel value does not appear in the error message
|
||||
assert sentinel_value not in str(exc_info.value)
|
||||
# Check that the sentinel value does not appear in the logs
|
||||
assert sentinel_value not in caplog.text
|
||||
# Check that the secret pattern was redacted (should contain REDACTED)
|
||||
assert "REDACTED" in str(exc_info.value)
|
||||
# Check that the sentinel does not appear in the cause
|
||||
if exc_info.value.__cause__ is not None:
|
||||
assert sentinel_value not in repr(exc_info.value.__cause__)
|
||||
Reference in New Issue
Block a user