fix: ssse ordered requests

Author: Leoglme

api/routes/articles.py

@@ -216,6 +216,15 @@ def start_ebay_batch(
                 detail=f"Article {aid} needs at least one HTTPS image for eBay.",
             )
 
+    # Enregistre les canaux SSE **avant** de retourner 202 : `BackgroundTasks`
+    # ne démarre qu'après l'envoi de la réponse, et le front ouvre
+    # `GET /articles/{id}/listing-progress` dès réception → sans ces registers
+    # upfront, l'ouverture du SSE gagne la course et on renvoie l'erreur
+    # « Aucune session de publication pour cet article. » alors que la publication
+    # va en fait se dérouler juste après sans logs visibles côté UI.
+    for aid in unique_ids:
+        vinted_progress_hub.register(aid)
+
     background_tasks.add_task(
         EbayBackgroundService.run_ebay_batch_sequential,
         user.id,

api/services/vinted_progress_session_service.py

@@ -80,7 +80,18 @@ async def finish(cls, article_id: int, payload: dict[str, Any]) -> None:
 
     @classmethod
     async def event_stream(cls, article_id: int) -> AsyncIterator[dict[str, Any]]:
+        # Petit filet de sécurité : si une route a enregistré la session via
+        # `BackgroundTasks` (donc après le retour HTTP) ou si le front ouvre le
+        # SSE très vite après un POST 202, on laisse jusqu'à ~1,5 s pour que
+        # `register()` soit appelé. Au-delà on considère qu'il n'y a vraiment
+        # pas de publication en cours pour cet article.
         s = cls._sessions.get(article_id)
+        if s is None:
+            for _ in range(15):
+                await asyncio.sleep(0.1)
+                s = cls._sessions.get(article_id)
+                if s is not None:
+                    break
         if s is None:
             yield {"type": "error", "message": "Aucune session de publication pour cet article."}
             return