u2i ddlmZmZmZmZmZddlmZddlm Z ddl m Z m Z m Z mZmZmZmZmZddlmZddlmZddlmZddlmZdd lmZdd lmZdd lm Z dd l!m"Z"dd l#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*m+Z+ddl,m-Z-ddl.m.Z.ddl/Z/ddl0Z0ddl1Z1ddl2Z2e2jfe4Z5dZ6Gdde Z7eZ8e Z9e"Z:eZ;eZ<eZ=eZ>eZ?eZ@e$ZAe&ZBe(ZCe8jde de fdZEe8jdede fdZFe8jdeededfde*ed eGfd!ZHe8jd"dId#eIfd$ZJe8jd%dJd&e+eIfd'ZLe8jd(d)eGfd*ZMe8jd+d)eGfd,ZOe8jd-d)eGfd.ZQe8jd/d0ZRe8jd1edededededed2fd3eGd4eGd5eGd6eGd7eId8eIf d9ZSe8jd:dKd;eGdZUe8jd?dKd;eGd>'"9"9:L$**>z?O?O?QRN   g &N4F4Fw4OPPJ9!YY[( <789,?? KO   w 'O4G4G4PQQ.JJ:WaWgWgWij   +6QRcRgRghoRpQq4rss J *  8 %.W    )" s%BFFCF-F= FFz/index/reset-for-testingcountcK ddlm}|jdjddddddii}dd |j|d S#t $r}d t |d cYd }~Sd }~wwxYww)z Reset indexed status for a few jobseekers for testing purposes Args: count: Number of jobseekers to reset (default: 10) Returns: dict: Reset operation results rrH jobseekersrjindexedz$setrTz Reset indexed status for testing)rgrk reset_countrequested_countFrgrfN)services.mongo_servicerHget_collection update_manymodified_count Exceptionr$)r~rHresultes r. reset_indexed_status_for_testingrs 8--l;GGQ ' i^ $  9!00$     V   s4A'>AA' A$ AA$A'A$$A'z /index/bulk max_totalcK tfd}tj|djddduddS#t$r}dt |d cYd}~Sd}~wwxYww) a Bulk index all unindexed jobseekers (status=1, indexed=0) to OpenSearch Runs in background to avoid blocking other API calls Args: max_total: Maximum number of jobseekers to index - If None: Process ALL unindexed jobseekers (suitable for cron) - If number: Limit processing for testing Returns: dict: Immediate response - indexing runs in background c tjdtj}tjd|y#t$r+}tj dt |Yd}~yd}~wwxYw)Nz1Starting background bulk indexing with max_total=)rz$Background bulk indexing completed: z!Background bulk indexing failed: )loggerinforEbulk_index_jobseekersrrfr$)rrrs r.background_bulk_indexingz4bulk_index_resumes..background_bulk_indexingsr K OPY{[\+AAIAV B6(KL K @QIJJ KsAA A>!A99A>T)targetdaemonz#Bulk indexing started in backgroundNz-Check logs for progress and completion status)rgrk processed_allnoteFr)y threadingThreadstartrr$)rrrs` r.bulk_index_resumesrss   K  8FLLN<&$.C    V   s1A"8>A" A AAA"AA"z/index/single/{jobseeker_id} jobseeker_idcK tj|}|rdd|dSdd|dS#t$r}dt|dcYd}~Sd}~wwxYww)z Index a single jobseeker resume to OpenSearch Args: jobseeker_id: The jobseeker ID to index Returns: dict: Success status and message Tz Successfully indexed jobseeker: rgrkFzFailed to index jobseeker: rN)rE add_resumerr$rrgrs r.index_single_resumerss $// = =l^L  !6|nE   V   9A+A+A A  AA AA  Az/index/reindex/{jobseeker_id}cK tj|}|rdd|dSdd|dS#t$r}dt|dcYd}~Sd}~wwxYww)z Reindex a specific jobseeker resume (reset indexed status and re-index) Args: jobseeker_id: The jobseeker ID to reindex Returns: dict: Success status and message Tz"Successfully reindexed jobseeker: rFzFailed to reindex jobseeker: rN)rEreindex_jobseekerrr$rs r.reindex_resumerss $66|D ? ~N  !8G   V   rz/index/{jobseeker_id}cK tj|}|rdd|dSdd|dS#t$r}dt|dcYd}~Sd}~wwxYww)z Delete a jobseeker resume from OpenSearch index Args: jobseeker_id: The jobseeker ID to delete from index Returns: dict: Success status and message Tz!Successfully deleted from index: rFzFailed to delete from index: rN)rE delete_resumerr$rs r.delete_from_indexr!ss $22<@ >|nM  !8G   V   rz /index/statuscLK ddlm}|jd}|jddi}|jddd}|jdddd iidd iddigd }|dkDr||z d znd}|||t |d dS#t $r}dt |icYd }~Sd }~wwxYww)zl Get current OpenSearch indexing status Returns: dict: Indexing status with counts rrrrjrrrz$existsFN)rjz$ord)total_active_jobseekers indexed_countunindexed_countcompletion_percentagerf)rrHrcount_documentsroundrr$)rHjobseeker_collection total_activerrrrs r.get_indexing_statusr?s 8,;;LI+;;XqMJ ,<<VW=XY />>Y./D!A@  IUWXHX!=!C^_(4*.%*+@!%D     SV   s5B$AcRK ddlm}i}|r!|jj|d<|rA|j dDcgc]#}|js|j%c}|d<|r|j|d<|r |dkDr||d<|} | j |||} g} | j dgD](} | j d i} | j| j d | j d d| j d d | j dd | j dd | j dd | j dd | j dg| j dd | j dd | j ddt| j dd dkDr| j dd dddzn| j dd d +dt| || dScc}w#t$r}dt|gdcYd}~Sd}~wwxYww)a Advanced resume search with filtering by country, skills, education, experience Args: query: Job description or search query country_code: Country header code to filter by (e.g. 'ae', 'bd', 'in') skills: Comma-separated list of skills to filter by education: Education level to filter by min_experience: Minimum years of experience top_k: Number of results to return (default: 50) Returns: SearchResponse: Filtered search results with detailed candidate info rrcountry_header_code,rrmin_experience_yearsrpayloadrJscore first_namerc last_nameemail country_namecurrent_designationhighest_educationexperience_yearsprofile_summaryN...) rJrrrrrrrrrrrT)rg total_resultsfilters_appliedr?F)rgrfr?) services.embeddingsrrmlowersplitsearch_with_filtersrprrrurr$)rrrrrr>rfiltersskillr@r?formatted_resultsrrrs r.search_resumes_advancedrhsF.1 0 -9-?-?-A-G-G-IG) * #E MC$78 ''!";"1_#5q9(-.>(B)   $1#$5#6a!8/0'   5\G,  V   srC5CC5C CC CC5 C C !C?ACC5 C C2 C-'C2(C5-C22C5z#/vector-search-simple/{search_text}c K tj||}|jdsd|ddgdS|d}d}|Dcgc]}|jdd|k\r|}}|s d|dd dgd St|Dcgc]}|jddc}}g} |D]}|jd ijd } |jdd} | |z d z} | sA| |d zk\sJ| j | t | dt | d|jd ijdddddzdd|d|d zdt | | dScc}wcc}w#t$r} dt| dcYd} ~ Sd} ~ wwxYww)a Simple vector search endpoint - provide search text in URL for semantic search with minimum matching threshold Args: search_text: Text to search semantically limit: Number of results (default: 10) min_threshold: Minimum similarity threshold (default: 0.5 = 50%) Returns: dict: Simple vector search results with match percentages r=rTvector_semanticr)rgr search_typerr?rrz:No semantically relevant matches found. Query too generic.)rgrrrkrr?rrJrrrtextrcNrr)rJsimilarity_scorer matched_textr)rgrrrrr?Fr) r@search_with_qdrantrprrrrrurr$)rrrrN raw_resultsabsolute_min_similarityrrmax_similarityr?rJrrrs r.vector_search_simpler<sB !44[4N!!(+$0   %X. #&"- zz'1%)@@    $0W   CSTfjj!4TU& F 9b155kBI%zz'15 !1> ASH --#2EF!*(-.>(B(-.>(B$*JJy"$=$A$A&"$Mds$SV[$[     ,$1#$5#6a!8w<   E U6  V   suE9/EE9 EE  E)E9* E3E A EE!A)E E9 E E6 E1+E6,E91E66E9z/job-matching/{job_emp_id}cK |r|jsdddStj|j}|S#t$r}dt ||dcYd}~Sd}~wwxYww)ab Start job matching process for a specific job ID This endpoint immediately returns success and processes job matching in background: 1. Fetches job details from third-party API 2. Searches candidates using both OpenSearch and Vector search 3. Filters candidates with 50%+ match threshold 4. Generates AI analysis (strengths, weaknesses, match justification) 5. Stores results in screenings collection Args: job_emp_id: The employer job ID to process Returns: dict: Immediate success response - actual processing happens in background Frdrrgrfjob_idN)rmjob_matching_serviceprocess_job_matching_asyncrr$)r_rrs r.start_job_matchingrso$ !1!1!3 E  &@@AQAQAST  V    s=A%AA%$AA% A" AA"A%A""A%z./job-matching/specific-candidates/{job_emp_id}cK |r|jsdddS|jrt|jdk(rdddSg}|jD]$} t|}|dkDr|j |&|sdddStj|j|}dd||t||d d S#t t f$rYxwxYw#t$r}dt||d cYd }~Sd }~wwxYww) a Analyze specific jobseeker IDs for a job position with background processing This endpoint: 1. Takes a job ID and array of specific jobseeker IDs 2. Checks if jobseekers are indexed, indexes them if needed 3. Generates AI analysis (strengths, weaknesses, match justification) 4. Stores results in screenings collection with type=1 5. Processes in background and returns immediately Args: job_emp_id: The employer job ID to process jobseeker_ids: Array of jobseeker IDs to analyze Returns: dict: Immediate success response - actual processing happens in background Frdrrz3jobseeker_ids array is required and cannot be emptyzNo valid jobseeker IDs providedTz0Specific candidate analysis started for job ID: rh)rgrkrjobseeker_countr1rjrN) rmr1rur5rr ValueError TypeErrorr!process_specific_candidates_asyncrr$)r_r: valid_idsjidvalid_idrrs r.analyze_specific_candidatesrs2&/ !1!1!3 E  $$G,A,A(Ba(G N   (( C s8a<$$X.   :  &GG HXHXHZ\efI*V "9~&*    *  ,  V    szC3CC3(CC3C!B97C?C38C8C39C C C  C C0C+%C0&C3+C00C3z/generate-offer-letterc K |j|j|j|j|j|j |j |jd}tj|}t|d|jd|jdS#t$r#}tddt|cYd }~Sd }~wwxYww) a Generate an offer letter using AI based on provided candidate and job information This endpoint: 1. Takes candidate information (name, job title, department, etc.) 2. Uses OfferLetterService to generate a professional offer letter 3. Returns the generated offer letter text Args: request: OfferLetterRequest containing all required candidate and job details Returns: OfferLetterResponse: Generated offer letter or error message )candidate_name job_title department company_name start_datesalaryemployment_typebenefitsrg offer_letterrf)rgr rfFzError generating offer letter: rN)rrrrrr r r offer_letter_servicegenerate_offer_letterrrprr$)r:candidate_datarrs r.rrs  &44 **!,,#00!,,nn&66((  &;;NK"9%N3**W%   "3CF8<   s5CBB#"C# C,C CC CCz/test-api-keyscP Kddl}ddl}ddlm}|ddid} ddlm}|r dd d |d d <n d dd |d d < |jd}|jd}|jd}t|||gs ddd |d d<nOddl m } | |ddg||fd} | jj} dd| jddd |d d<|jd} |jd} |jd }|jd!}t| | ||gs#dd"| rd#nd$| rd#nd$|rd#nd$|rd#nd$d%d&|d d'<n|d(d)}i} | }|j||d*+}|jd,k(rd-|d.<nd/|j|d.< | d1|}|j||d*+}|jd,k(r9|j!}d2|vr|d2jd3d}d4|d5|d6<nBd7|d6<n<|jd8k(rd9|d6<n'|jd:k(rd;|d6<nd/|j|d6< | j#d<d<}|j||d*+}|jd,k(rE|j!}|jd2ijd=g}d4t%|d>|d?<nd/|j|d?<td@|j'DrdA}n%t)dB|j'DrdC}ndD}||| | ||r|ddEdFndGdHdI|d d'<|d j'Dcgc]}|d }}tdJ|DrdK|dL<nt)dM|DrdN|dL<ndO|dL<g}dP|d jd'ijddQvr|j+dRdP|d jdijddQvr|j+dSdP|d jd ijddQvr|j+dT|s|j+dU||dV<|S#t $r}dt|d |d d <Yd}~3d}~wwxYw#t $r}d t|d |d d<Yd}~d}~wwxYw#t $r}d0t||d.<Yd}~&d}~wwxYw#t $r}d0t||d6<Yd}~d}~wwxYw#t $r}d0t||d?<Yd}~Ed}~wwxYwcc}ww)Wz Test all API keys and configurations for Qdrant, OpenSearch, and MongoDB Returns: dict: Comprehensive test results for all services rN) load_dotenvz2024-12-02T10:00:00z checking...) timestampoverall_statusservices)is_database_connectedu ✅ ConnectedzDatabase connection successful)rjdetailsrmongodbu❌ Connection FailedzCannot connect to MongoDBu ❌ ErrorOPENSEARCH_HOSTOPENSEARCH_USEROPENSEARCH_PASSWORDu❌ Configuration Missingz2OpenSearch credentials not complete in environment opensearch) OpenSearchi)hostportT)hosts http_authuse_sslzCluster status: rjunknownQDRANT_API_URLQDRANT_SEARCH_URLQDRANT_API_KEYQDRANT_COLLECTION_NAMEz)Qdrant environment variables not completeu✅ Setu ❌ Missing)r#r$r%r&)rjrconfigqdrantzapplication/json)zapi-keyz Content-Type )headerstimeoutru ✅ Healthyhealthu ❌ Status u ❌ Error: /r points_countu✅ Accessible (z points) collectionu"✅ Accessible (structure unknown)iu8❌ Collection 'resumes' not found - needs to be creatediu❌ Access forbiddenz /collections collectionsz collections)collections_listc3$K|]}d|v ywu✅Nr7.0rjs r. z$test_all_api_keys..sC6uCu✅ Fully Functionalc3$K|]}d|v ywr3r7r4s r.r6z$test_all_api_keys..sEV&Er7u⚠️ Partial Accessu ❌ No AccessrzNot set)api_url search_urlr/api_key_preview)rjtestsr'c3$K|]}d|v ywr3r7r4s r.r6z$test_all_api_keys..s =v5F? =r7u✅ All Systems Operationalrc3$K|]}d|v yw)❌Nr7r4s r.r6z$test_all_api_keys..s ?Uf_ ?r7u❌ Critical Issues Detectedu⚠️ Some Issues Detectedr@rcu2🔧 Update Qdrant API key with proper permissionsu2🔧 Check OpenSearch credentials and connectivityu'🔧 Verify MongoDB connection settingsu'✨ All services are working correctly!recommendations)osrequestsdotenvrservices.databaserrr$getenvall opensearchpyrclusterr,rprajsonrstripruvaluesanyrr) rBrCr test_resultsrropensearch_hostopensearch_useropensearch_passwordrclientr,r#r$r%r&r* qdrant_testsbase_urlhealth_responsecollection_urlcollection_responsecollection_infor.collections_urlcollections_responsecollections_datar1 qdrant_statusserviceall_services_statusrAs r.test_all_api_keysr_'s*"M+'L ; ");3L $Y / 263L $Y /  #"))$56#"))$56'bii(=>O_6IJK5O6L $\ 2 0 /=>*,?@F^^**,F*-fjj9.M-NO6L $\ 2RYY/0N! "56RYY/0N&RYY'?@  1>CYZ [1B/=)=2CY/=)=7M)S`  . Z *&.    <%H*hll8WbQO**c1)6 X&+67R7R6S)T X&  @ 12!4J3KLN".(,,~wXZ"[ "..#5"5":":"<.#28#<#@#@QR#SL3CL>QY1ZL.1UL.$00C7-g \*$00C7-C \*/:;N;Z;Z:[-\ \* F!2!9!9.!I J,WO#/8<<Z\#] #//36#7#<#<#> #3#7#7"#E#I#I-Y[#\ 5EcJZF[E\\i3j /05@AUAaAa@b3c /0 C\-@-@-BC C2M E|/B/B/DE E3M+M$!)/4BPnSb&9%:##>V_  . Z *=I ? ?)G %&)F %&O Z(,,Xr:>>xLLST Z(,,\2>BB8RPPST Z(,,Y;??"MMHI HI&5L"# }  !1v/ Z + F  -1v2 Z . R <'23q6(%;L " <( @+6s1vh)?L & @ F1#BT&%>R)$B SBS9A8T& T!C;T& Q;Q60T&6Q;;T&> R&R!T&!R&&T&) S2S T& ST& S6S1+T&1S66T&9 TTT&TT&)r))N)r)g?)[fastapirrrrrfastapi.responsesrpydanticr schemas.request_responser r r r rrrrrrservices.qdrant_servicerservices.opensearch_servicerrrservices.rankingrservices.explainrservices.ai_servicerservices.resume_parserrservices.job_matching_servicerservices.resume_upload_servicerservices.offer_letter_servicertypingrrbsonr r!rrBrClogging getLoggerr2rr(r0apprY resume_parserr@rCrErHrFrKrrnr postrTr]r$r}r5rrprrputrdeleterrrfloatrrrrrr_r7r8r.rwsBB*rrr(795)+)6<><!    8 $  i [ #% :$&&("$   )++-)+)N3,O,4,,*\2+3/*=>7;CyTXY\T]9D$49c9?9x $% # & B%  % % P () C * : () s * : #$ # % :% % P cT t*$Zt*b G G G  G  G  G  G G Z &'A CA A A (A J ./N CN N QVN 0N b &'" " (" J :;A #A @YA <A J "3FG) );) H) X ~~r8