import logging from typing import List, Optional from fastapi import APIRouter, Depends, HTTPException, status, Query from services.france_travail_offer_service import france_travail_offer_service # Assuming these imports are still needed for your project context, # even if not directly used in the current problem scope. # from core.security import get_current_user # from models.user import User from schemas.france_travail import FranceTravailSearchResponse, OffreDetail, Offre router = APIRouter() logger = logging.getLogger(__name__) @router.get("/search", response_model=FranceTravailSearchResponse) async def search_france_travail_offers( motsCles: Optional[str] = Query(None, description="Mots-clés de recherche (ex: 'développeur full stack')"), commune_input: Optional[str] = Query(None, alias="commune", description="Nom de la commune (ex: 'Paris', 'Marseille'). Si spécifié, le code départemental sera automatiquement dérivé."), distance: Optional[int] = Query(10, description="Distance maximale en km autour de la commune ou du code postal. Applicable avec 'commune' ou 'codePostal', 'latitude'/'longitude'."), codePostal: Optional[str] = Query(None, description="Code postal spécifique (ex: '75001')"), latitude: Optional[float] = Query(None, description="Latitude du point de recherche (ex: 48.8566)"), longitude: Optional[float] = Query(None, description="Longitude du point de recherche (ex: 2.3522)"), # codeDepartement: Optional[str] = Query(None, description="Code départemental sur 2 chiffres (ex: '75' pour Paris). Prioritaire sur les autres paramètres de localisation."), # Ce paramètre est maintenant géré en interne par le service page: int = Query(0, description="Numéro de la page de résultats (commence à 0)"), limit: int = Query(15, description="Nombre d'offres par page (max 100 pour l'API France Travail)"), contrat: Optional[str] = Query(None, description="Type de contrat (ex: 'CDI', 'CDD', 'MIS'). Plusieurs séparés par des virgules."), experience: Optional[str] = Query(None, description="Niveau d'expérience (ex: 'E' pour expérimenté, 'D' pour débutant). Plusieurs séparés par des virgules.") # current_user: User = Depends(get_current_user) # Décommentez si l'authentification est nécessaire ): """ Recherche des offres d'emploi via l'API France Travail. La localisation peut être spécifiée par commune (le département sera dérivé), code postal, ou latitude/longitude. """ logger.info(f"Requête de recherche d'offres reçue: motsCles='{motsCles}', commune_input='{commune_input}', codePostal='{codePostal}', latitude='{latitude}', longitude='{longitude}', distance={distance}, page={page}, limit={limit}") range_start = page * limit range_end = range_start + limit - 1 logger.info(f"Paramètre 'range' calculé pour l'API France Travail: {range_start}-{range_end}") # Convertir les chaînes de contrats et expériences en listes contrats_list = contrat.split(',') if contrat else None experiences_list = experience.split(',') if experience else None # Les paramètres de localisation sont passés directement au service, # qui gérera la dérivation du département et la priorité. try: response = await france_travail_offer_service.search_offers( motsCles=motsCles, commune=commune_input, # Passe le nom de la commune directement codePostal=codePostal, latitude=latitude, longitude=longitude, distance=distance, # codeDepartement n'est plus passé ici, il est dérivé dans le service range_start=range_start, range_end=range_end, typeContrat=contrats_list, experience=experiences_list ) return response except RuntimeError as e: logger.error(f"Erreur lors de la recherche d'offres France Travail: {e}") raise HTTPException( status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, detail=f"Impossible de récupérer les offres de France Travail: {e}" ) @router.get("/{offer_id}", response_model=OffreDetail) async def get_france_travail_offer_details( offer_id: str, # current_user: User = Depends(get_current_user) ): """ Récupère les détails d'une offre d'emploi spécifique de l'API France Travail par son ID. Nécessite une authentification. """ try: details = await france_travail_offer_service.get_offer_details(offer_id) return details except RuntimeError as e: logger.error(f"Erreur lors de la récupération des détails de l'offre {offer_id} de France Travail: {e}") raise HTTPException( status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, detail=f"Impossible de récupérer les détails de l'offre {offer_id}: {e}" )