fix: ebay token conflicts

Author: Leoglme

api/services/ebay_oauth_service.py

@@ -3,6 +3,7 @@
 from __future__ import annotations
 
 import base64
+import json
 import logging
 from typing import Any
 from urllib.parse import urlencode
@@ -20,6 +21,57 @@
 ]
 
 
+class EbayOAuthError(RuntimeError):
+    """Erreur OAuth eBay exploitable côté UI (code + message lisibles)."""
+
+    def __init__(self, code: str, message: str, *, status: int | None = None) -> None:
+        super().__init__(code)
+        self.code = code
+        self.message = message
+        self.status = status
+
+    def __str__(self) -> str:
+        return self.message or self.code
+
+
+def _describe_ebay_oauth_error(status: int, body: str) -> EbayOAuthError:
+    """Transforme un body 4xx eBay (`{"error": "...", "error_description": "..."}`)
+    en exception `RuntimeError` lisible, avec un code applicatif stable pour l'UI."""
+    payload: dict[str, Any] = {}
+    try:
+        parsed = json.loads(body) if body else {}
+        if isinstance(parsed, dict):
+            payload = parsed
+    except ValueError:
+        payload = {}
+    err = str(payload.get("error") or "").strip()
+    desc = str(payload.get("error_description") or "").strip()
+
+    if err == "invalid_scope":
+        return EbayOAuthError(
+            "ebay_scope_mismatch",
+            "Votre consentement eBay n'inclut pas tous les scopes demandés. "
+            "Reconnectez votre compte eBay dans les Paramètres pour accorder les nouveaux accès.",
+            status=status,
+        )
+    if err in {"invalid_grant", "invalid_token"}:
+        return EbayOAuthError(
+            "ebay_refresh_token_invalid",
+            "Le refresh token eBay a expiré ou a été révoqué. Reconnectez votre compte eBay.",
+            status=status,
+        )
+    if err == "invalid_client":
+        return EbayOAuthError(
+            "ebay_client_invalid",
+            "Identifiants application eBay invalides (client_id / client_secret). "
+            "Vérifiez la configuration serveur.",
+            status=status,
+        )
+
+    message = desc or err or f"Erreur eBay ({status})."
+    return EbayOAuthError(err or "ebay_token_http_error", message, status=status)
+
+
 def _auth_base_url(app: AppSettings) -> str:
     return "https://auth.sandbox.ebay.com" if app.ebay_use_sandbox else "https://auth.ebay.com"
 
@@ -78,19 +130,28 @@ async def exchange_authorization_code(code: str, *, app: AppSettings | None = No
         resp = await client.post(url, data=data, headers=headers)
     if resp.status_code >= 400:
         logger.warning("eBay token exchange failed: %s %s", resp.status_code, resp.text[:500])
-        resp.raise_for_status()
+        raise _describe_ebay_oauth_error(resp.status_code, resp.text)
     return resp.json()
 
 
 async def refresh_user_access_token(refresh_token: str, *, app: AppSettings | None = None) -> dict[str, Any]:
+    """Rafraîchit l'access token utilisateur.
+
+    On ne force **volontairement pas** le paramètre ``scope`` : eBay renvoie alors
+    un token portant les scopes tels qu'ils ont été consentis au moment de la
+    connexion. C'est indispensable quand ``EBAY_SCOPES`` évolue (ajout de
+    ``sell.fulfillment`` par exemple) : les utilisateurs déjà connectés avant
+    l'ajout continuent de publier (inventory + account) sans reconsentement ;
+    les fonctionnalités nécessitant le nouveau scope détecteront son absence et
+    proposeront la reconnexion.
+    """
     s = app or get_settings()
     if not ebay_oauth_configured(s):
         raise RuntimeError("ebay_oauth_not_configured")
     url = f"{_api_base_url(s)}/identity/v1/oauth2/token"
     data = {
         "grant_type": "refresh_token",
         "refresh_token": refresh_token.strip(),
-        "scope": " ".join(EBAY_SCOPES),
     }
     headers = {
         "Content-Type": "application/x-www-form-urlencoded",
@@ -100,5 +161,5 @@ async def refresh_user_access_token(refresh_token: str, *, app: AppSettings | No
         resp = await client.post(url, data=data, headers=headers)
     if resp.status_code >= 400:
         logger.warning("eBay refresh failed: %s %s", resp.status_code, resp.text[:500])
-        resp.raise_for_status()
+        raise _describe_ebay_oauth_error(resp.status_code, resp.text)
     return resp.json()

api/services/ebay_publish_service.py

@@ -285,9 +285,15 @@ async def publish_article_to_ebay(
     try:
         await _emit_ebay(progress, "auth", "Connecting to the eBay API…")
         token = await ensure_ebay_access_token(db, user, app=s)
-    except RuntimeError as exc:
-        await _emit_ebay(progress, "error", "Could not obtain an eBay token.", detail=str(exc))
-        return {"ok": False, "detail": str(exc)}
+    except Exception as exc:
+        # Inclut RuntimeError (ebay_not_connected, ebay_oauth_not_configured, …)
+        # et EbayOAuthError (invalid_scope, invalid_grant, …). On ne laisse plus
+        # fuir httpx.HTTPStatusError : le log « auth → error » doit toujours être
+        # émis pour que le Journal des publications affiche la vraie raison.
+        logger.warning("eBay token acquisition failed for user=%s: %s", user.id, exc)
+        detail = str(exc) or exc.__class__.__name__
+        await _emit_ebay(progress, "error", "Could not obtain an eBay token.", detail=detail)
+        return {"ok": False, "detail": detail}
 
     await _emit_ebay(progress, "auth", "eBay token obtained.")
     root = _api_base_url(s)

web/app/composables/useVintedPublishStream.ts

@@ -112,6 +112,21 @@ export function useVintedPublishStream() {
             close()
             const v = data.vinted
             const eb = data.ebay
+            if (context === 'logs') {
+              // Journal des publications : on matérialise les échecs dans la
+              // liste de logs (sinon l'utilisateur ne voit qu'un `done` muet).
+              if (v && v.published === false) {
+                const detail
+                  = v.detail === 'missing_vinted_credentials'
+                    ? "Identifiants Vinted manquants (profil ou variables d'environnement)."
+                    : String(v.detail ?? 'Publication non confirmée.')
+                logEntries.value.push({ text: `[Vinted · Erreur] ${detail}` })
+              }
+              if (eb && eb.published === false) {
+                const detail = String(eb.detail ?? 'Échec ou annulation.')
+                logEntries.value.push({ text: `[eBay · Erreur] ${detail}` })
+              }
+            }
             if (context !== 'logs') {
               if (v) {
                 if (v.published) {