hi FdZddlZddlZddlmZddlmZddlmZmZm Z m Z m Z ddl m Z ddlmZddlmZdd lmZddlZdd lmZmZmZdd lmZmZmZmZmZmZm Z dd l!m"Z"dd l#m$Z$ddl%m&Z&ddl'm(Z(ddlm)Z)m*Z*m+Z+m,Z,eejZZ.e.j_ej`dddddddejbZ2e2jge.e2jiejjedefdZ6eddde6ddd d!d"d#d$i%Z7e7jqed&gd'd&gd&g(e7jsd)e d*d+gd,d-.e d/d01e d2d34e dd54e dd64e dd74e dd84e dd94eefd:e:d;e:de:d?e:d@e:dAefdBZ? KK1$u=> KK/vV<= KK yy=045@A KKO KK%& KKO  KK12 KK,-1 , qc*++,s1AHGE:H G=G82H8G==Hu🤖 WhatsApp CV Bot APIuj ## Bot WhatsApp intelligent pour collecter CVs et profils LinkedIn ### Fonctionnalités - ✅ Collecte automatisée via WhatsApp - ✅ Parsing intelligent de CV avec Google Gemini - ✅ Scraping LinkedIn avec Apify - ✅ Base de données PostgreSQL - ✅ API REST complète ### Stack Technique - **Framework**: FastAPI (async) - **Base de données**: PostgreSQL + SQLAlchemy - **WhatsApp**: Twilio API - **IA CV**: Google Gemini Flash - **LinkedIn**: Apify Scraper ### Webhooks Twilio Configurez le webhook Twilio sur `/webhook/whatsapp` 2.0.0r1r2zOmar - GDE Flutterzsupport@exemple.com)nameemailrCMIT)title descriptionversionrAdocs_url redoc_urlcontact license_info*T) allow_originsallow_credentials allow_methods allow_headersr.zWebhooks TwiliozWebhook principal WhatsAppu=Point d'entrée pour recevoir les messages WhatsApp de Twilio)response_class status_codetagssummaryrG.u*Numéro expéditeur (whatsapp:+1234567890))rGr5zContenu du message texte)defaultrGuNombre de médias jointsuURL du premier médiauType MIME du médiau%Texte du bouton cliqué (Quick Reply)u(Payload de la commande du bouton cliquéFromBodyNumMedia MediaUrl0MediaContentType0 ButtonText ButtonPayloaddbc K |r|n|}|r tjd|d|d|dntjd|tj||||||} t j || y#t $rC} tjd| d  t j |d n#YnxYwYd } ~ yd } ~ wwxYww) u Webhook Twilio pour recevoir les messages WhatsApp. Twilio envoie les données en form-data. Pour les clics sur boutons (Quick Reply), ButtonPayload contient la commande complète. u🔘 Bouton cliqué par z: text='z ' payload=''u📨 Webhook de )r_ from_number message_body num_media media_urlmedia_content_typer5u❌ Erreur webhook: T)exc_infou'❌ Erreur. Réessayez ou tapez /reset.N)r6r7rprocess_messager send_messager8r9) rXrYrZr[r\r]r^r_effective_body response_textr>s r@whatsapp_webhookrls0*7T  KK24& KXeWffgh i KK*4&1 2-<<'0   ##D-8  +A3/$ ?   ' '.W X   sGCA1A65C6 C?B=B10B=1B53B=8C=CCz/webhook/statuszCallback statut des messages)rSrTrUrV MessageSid MessageStatuscBKtjd|d|yw)z/Webhook pour les updates de statut des messagesu 📊 Status: z = r5)r6r7)rmrns r@status_callbackrps$ KK- |3}o>? s/u GénéralzPage d'accueil de l'API)rUrVc 2Kddddddddd d d d d dddSw)ud Point d'entrée de l'API. Retourne les informations de base et la liste des endpoints. zWhatsApp CV Bot APIrBrunningr PostgreSQLzGoogle Gemini FlashApify) cv_parserlinkedin_scraperr.r0r/ /api/usersr1r2)webhookhealthstatsusersdocsredoc)rCrHr frameworkdatabaseai endpointsrr@homersE& . ' +!   sr0 Monitoringz Health checku<Vérifie l'état de santé du service et de ses dépendances)response_modelrUrVrGcK |jdd} tj}|rdnd}tdt j ||S#d}YBxYw#d}Y0xYww)u^ Endpoint de santé pour monitoring. Vérifie: - PostgreSQL - Twilio zSELECT 1 connected disconnectedhealthy)r timestamprtwilio)executerget_account_inforrutcnow)r_ db_status twilio_info twilio_statuss r@ health_checkrsp # : '$557 '2   //#  #" '& s,A%AA!A%AA%A" A%r/ StatistiqueszStatistiques globalesz-Obtenir les statistiques d'utilisation du botcK t}|j|}tdi|S#t$r3}tj d|t dt|d}~wwxYww)u Statistiques globales du bot. Retourne: - Nombre total d'utilisateurs - Inscriptions complétées - CVs reçus - Profils LinkedIn - Taux de complétion u❌ Erreur stats: rTdetailNr)r get_statsrr8r6r9rstr)r_ user_servicer{r>s r@rrsd$<"} &&r*%u%% < )!-.CF;; =L  & &r7 3D ,  Ks.0z/api/users/{phone_number}uDétails d'un utilisateuru9Récupérer les informations d'un utilisateur spécifique phone_numbercK|jdsd|z}t}|j||}|s tdd|Sw)ut Récupérer un utilisateur par numéro de téléphone. - **phone_number**: Numéro avec ou sans + +rrr) startswithrget_user_by_phoner)rr_rrs r@get_userrmsV  " "3 '\) =L  ) )"l ;D ,  KsAAz/api/search-profileszRechercher des profilsuYRechercher des candidats selon des critères (compétences, expérience, formation, etc.)requestc @K tj||\}}g}|D]-}|jt|dt d i|d/t |||S#t $r3}tjd|tdt|d}~wwxYww) u Recherche avancée de profils avec scoring automatique. **Critères disponibles:** - **skills**: Liste de compétences (ex: ["Python", "React", "AWS"]) - **min_years_experience**: Années d'expérience minimum - **max_years_experience**: Années d'expérience maximum - **companies**: Entreprises ciblées (ex: ["Google", "Microsoft"]) - **positions**: Postes recherchés (ex: ["Senior Developer", "Tech Lead"]) - **education_degrees**: Diplômes (ex: ["Master", "PhD"]) - **education_institutions**: Établissements (ex: ["MIT", "Stanford"]) - **languages**: Langues parlées (ex: ["Français", "Anglais"]) - **location**: Localisation (ex: "Paris", "Remote") **Options:** - **match_all_skills**: true = toutes les compétences requises, false = au moins une - **match_threshold**: Score minimum (0.0 à 1.0) pour filtrer les résultats - **limit**: Nombre de résultats (max 100) - **offset**: Pagination **Scoring:** - Score global calculé automatiquement (0.0 à 1.0) - Pondération: Compétences 40%, Expérience 35%, Formation 25% - Résultats triés par score décroissant **Exemple de requête:** ```json { "skills": ["Python", "Django", "PostgreSQL"], "min_years_experience": 3, "companies": ["Google", "Microsoft"], "match_all_skills": false, "match_threshold": 0.5, "limit": 10 } ``` r match_score)rr) total_resultsresultssearch_criteriau❌ Erreur recherche: rrNr) rsearch_profilesappendrrrr8r6r9rr)rr_rtotalformatted_resultsresultr>s r@rrs`</??GL F  $ $# 1 JF=4I J  %%#  < -aS12CF;;s r@ test_messagers~ < --gjj'//J)0%  6F   < (,-CF;;C?BC C;C  CCrc<Kddt|jdSw)NFuEndpoint non trouvé)rr9path)rurlrexcs r@not_found_handlerr/s$'GKK  srcDKtjd|dddSw)Nu❌ Erreur serveur: FzErreur interne du serveur)rr9)r6r9rs r@internal_error_handlerr8s* LL'u-., s __main__r,r-r3r4z app.main:appz0.0.0.0r7)hostr?reload log_level)S__doc__r;loggingr contextlibrfastapirrrrr fastapi.responsesr fastapi.middleware.corsr sqlalchemy.ormr dotenvr colorlog app.databaserrr app.schemasrrrrrrrapp.services.user_servicer!app.services.conversation_handlerrapp.services.twilio_servicer#app.services.profile_search_servicerrrrr StreamHandlerhandler setFormatterColoredFormatter getLoggerr6 addHandlersetLevelr%rAr*add_middlewarepostrr:rlrpgetrrrlistrrrrrrirexception_handlerrr__name__uvicornr<r?rrunrrr@rs *AA/2"A@2B6Fkk  !( ".X..5"       ' #.#.#.N $(   $&  =!H%%% $   (O  S&RSR-GH0JK$4KL!$ss z yryy& 'D RYY} % 6FGKK    r