Updated cv_analyzer_search.py with new features or bug fixes

cv_analyzer_search.py

@@ -19,6 +19,11 @@ import os
 import logging
 
 
+def make_clickable_link(link):
+    return f'<a href="{link}" target="_blank">{link}</a>'
+
+
+
 os.environ['GROQ_API_KEY'] = os.getenv("GROQ_API_KEY")
 groq_api_key = os.getenv("GROQ_API_KEY")
 
@@ -87,15 +92,15 @@ class JobSuggestionEngine:
 
             logger.debug(f"Calling Groq API with prompt: {prompt[:100]}...") # start of api call
             
-            # Make the API call to the Groq client for chat completions
+            # API call to the Groq client for chat completions
             chat_completion = self.client.chat.completions.create(
                 messages=[
                     {"role": "system", "content": "You are a career advisor generating job suggestions based on resume details."},
                     {"role": "user", "content": prompt}
                 ],
-                model="llama3-8b-8192",  # Replace with the correct model name if needed
-                temperature=0.7,  # Adjust temperature for randomness
-                max_tokens=1024,  # Limit the number of tokens
+                model="llama3-8b-8192",  
+                temperature=0.7,  
+                max_tokens=1024, 
                 top_p=1,
                 stop=None,
                 stream=False
@@ -107,7 +112,7 @@ class JobSuggestionEngine:
 
             logger.info(f"Job suggestions generated: {len(suggestions_data.get('job_suggestions', []))} found")
             
-            # Return job suggestions, defaulting to an empty list if not found
+            # Return job suggestions, if not found -> empty list 
             return suggestions_data.get('job_suggestions', [])
         
         except Exception as e:
@@ -117,8 +122,34 @@ class JobSuggestionEngine:
 
 def Job_assistant():
     st.title("📄 Job Suggestion & Search Assistant")
+
+    # Initialize session state for resume analysis tab
+    if 'uploaded_resume' not in st.session_state:
+        st.session_state.uploaded_resume = None
+    if 'resume_data' not in st.session_state:
+        st.session_state.resume_data = None
+    if 'job_suggestions' not in st.session_state:
+        st.session_state.job_suggestions = []
+    if 'improvement_suggestions' not in st.session_state:
+        st.session_state.improvement_suggestions = {}
     
-    # Tabs for different functionalities
+    # Initialize session state for job search tab
+    if 'site_name' not in st.session_state:
+        st.session_state.site_name = ["indeed", "glassdoor"]
+    if 'search_term' not in st.session_state:
+        st.session_state.search_term = "software engineer"
+    if 'location' not in st.session_state:
+        st.session_state.location = "San Francisco, CA"
+    if 'results_wanted' not in st.session_state:
+        st.session_state.results_wanted = 20
+    if 'hours_old' not in st.session_state:
+        st.session_state.hours_old = 72
+    if 'country_indeed' not in st.session_state:
+        st.session_state.country_indeed = "USA"
+    if 'job_search_results' not in st.session_state:
+        st.session_state.job_search_results = pd.DataFrame()
+    
+    # Tabs for functionalities
     tab1, tab2 = st.tabs(["Resume Analysis", "Direct Job Search"])
     
     
@@ -143,6 +174,7 @@ def Job_assistant():
         #     st.stop()
         
         if uploaded_resume:
+            st.session_state.uploaded_resume = uploaded_resume
             # Process Resume
             with st.spinner("Analyzing Resume..."):
                 try:
@@ -158,6 +190,8 @@ def Job_assistant():
                         logger.error("No candidates extracted from resume")
                         st.stop()
                     
+                    st.session_state.resume_data = candidates[0]
+
                     # Display extracted candidate information
                     st.subheader("Resume Analysis")
                     display_candidates_info(candidates)
@@ -170,19 +204,23 @@ def Job_assistant():
                     st.stop()
             
             # Initialize Job Suggestion Engine
-            suggestion_engine = JobSuggestionEngine()
-            logger.info("Job_Suggestion_Engine initialized")
-            
-            # Generate Job Suggestions
-            job_suggestions = suggestion_engine.generate_job_suggestions(resume_data)
-            logger.info(f"Generated {len(job_suggestions)} job suggestions")
-            
-            # Display Job Suggestions
-            st.header("🎯 Job Suggestions")
-            for suggestion in job_suggestions:
-                with st.expander(f"{suggestion.get('role', 'Unnamed Role')}"):
-                    st.write(f"**Description:** {suggestion.get('description', 'No description')}")
-                    st.write(f"**Suitability:** {suggestion.get('suitability_reason', 'Not specified')}")
+            if st.session_state.resume_data:
+                suggestion_engine = JobSuggestionEngine()
+                logger.info("Job_Suggestion_Engine initialized")
+                
+                # Generate Job Suggestions
+                job_suggestions = suggestion_engine.generate_job_suggestions(resume_data)
+                logger.info(f"Generated {len(job_suggestions)} job suggestions")
+
+                st.session_state.job_suggestions = job_suggestions
+
+                # Display Job Suggestions
+                st.header("🎯 Job Suggestions")
+                # for suggestion in job_suggestions:
+                for suggestion in st.session_state.job_suggestions:
+                    with st.expander(f"{suggestion.get('role', 'Unnamed Role')}"):
+                        st.write(f"**Description:** {suggestion.get('description', 'No description')}")
+                        st.write(f"**Suitability:** {suggestion.get('suitability_reason', 'Not specified')}")
 
 
             try:
@@ -190,14 +228,15 @@ def Job_assistant():
                     resume_text = process_file(uploaded_resume)
                     logger.info("Resume text extracted again for improvement suggestions")
 
-                    # Initialize Improvement Engine
+                    # Initialize Resume Improvement Engine
                     improvement_engine = ResumeImprovementEngine()
                     
                     # Generate Improvement Suggestions
                     improvement_suggestions = improvement_engine.generate_resume_improvement_suggestions(resume_text)
                     logger.info("Resume improvement suggestions generated")
+                    st.session_state.improvement_suggestions = improvement_suggestions
 
-                    # Display Improvement Suggestions
+                    # Display Suggestions
                     st.subheader("🔍 Comprehensive Resume Analysis")
                     
                     # Overall Assessment
@@ -271,39 +310,51 @@ def Job_assistant():
         st.header("🔍 Direct Job Search")
         
         # Job Search Parameters
-        col1, col2, col3, col4 = st.columns(4)
-        
-        with col1:
-            site_name = st.multiselect(
-                "Select Job Sites", 
-                ["indeed", "linkedin", "zip_recruiter", "glassdoor", "google"], 
-                default=["indeed", "linkedin"]
-            )
-        
-        with col2:
-            search_term = st.text_input("Search Term", "software engineer")
-        
-        with col3:
-            location = st.text_input("Location", "San Francisco, CA")
-        
-        with col4:
-            results_wanted = st.number_input("Number of Results", min_value=1, max_value=100, value=20)
-        
-        # Additional parameters
-        col5, col6 = st.columns(2)
-        
-        with col5:
-            hours_old = st.number_input("Jobs Posted Within (hours)", min_value=1, max_value=168, value=72)
-        
-        with col6:
-            country_indeed = st.text_input("Country (for Indeed)", "USA")
-        
-        # Search Button
-        if st.button("Search Jobs"):
+
+        with st.form(key='job_search_form'):
+    # Job Search Parameters
+                col1, col2, col3, col4 = st.columns(4)
+                
+                with col1:
+                    site_name = st.multiselect(
+                        "Select Job Sites", 
+                        ["indeed", "linkedin", "zip_recruiter", "glassdoor", "google"], 
+                        default=st.session_state.site_name
+                    )
+
+                with col2:
+                    search_term = st.text_input("Search Term", st.session_state.search_term)
+                
+                with col3:
+                    location = st.text_input("Location", st.session_state.location)
+                
+                with col4:
+                    results_wanted = st.number_input("Number of Results", min_value=1, max_value=100, value=st.session_state.results_wanted)
+
+                # Additional parameters
+                col5, col6 = st.columns(2)
+                
+                with col5:
+                    hours_old = st.number_input("Jobs Posted Within (hours)", min_value=1, max_value=168, value=st.session_state.hours_old)
+
+                with col6:
+                    country_indeed = st.text_input("Country (for Indeed)", st.session_state.country_indeed)
+
+                # Submit button inside the form
+                submit_button = st.form_submit_button("Search Jobs")
+
+                # Only run search when form is submitted
+        if submit_button:
+            st.session_state.site_name = site_name
+            st.session_state.search_term = search_term
+            st.session_state.location = location
+            st.session_state.results_wanted = results_wanted
+            st.session_state.hours_old = hours_old
+            st.session_state.country_indeed = country_indeed
+
             with st.spinner("Searching Jobs..."):
-                # Perform job search
                 try:
-                    logger.info(f"Performing job search with {search_term} in {location}")
+                    # Your existing job search code here
                     jobs = scrape_jobs(
                         site_name=site_name,
                         search_term=search_term,
@@ -313,16 +364,15 @@ def Job_assistant():
                         hours_old=hours_old,
                         country_indeed=country_indeed,
                     )
+                    st.session_state.job_search_results = jobs
 
                     if len(jobs) > 0:
                         st.success(f"Found {len(jobs)} jobs")
                         
                         jobs_filtered = jobs[['site', 'job_url', 'title', 'company', 'location', 'date_posted']]
-                        # Display job data in a table
-                        # st.dataframe(jobs)
-                        st.dataframe(jobs_filtered)
-
-                        # Option to download jobs
+                        jobs_filtered['job_url'] = jobs_filtered['job_url'].apply(make_clickable_link)
+                        st.write(jobs_filtered.to_html(escape=False), unsafe_allow_html=True)
+                        
                         csv_file = jobs.to_csv(index=False)
                         st.download_button(
                             label="Download Jobs as CSV",
@@ -336,6 +386,95 @@ def Job_assistant():
                 except Exception as e:
                     st.error(f"Job Search Error: {e}")
                     logger.error(f"Job Search Error: {e}")
+        # col1, col2, col3, col4 = st.columns(4)
+        
+        # with col1:
+        #     site_name = st.multiselect(
+        #         "Select Job Sites", 
+        #         ["indeed", "linkedin", "zip_recruiter", "glassdoor", "google"], 
+        #         default=st.session_state.site_name
+        #         # default=["indeed", "glassdoor"]
+        #     )
+        #     st.session_state.site_name = site_name
+
+        # with col2:
+        #     search_term = st.text_input("Search Term", st.session_state.search_term)
+        #     st.session_state.search_term = search_term
+        
+        # with col3:
+        #     location = st.text_input("Location", st.session_state.location)
+        #     st.session_state.location = location
+
+        
+        # with col4:
+        #     results_wanted = st.number_input("Number of Results", min_value=1, max_value=100, value=st.session_state.results_wanted)
+        #     st.session_state.results_wanted = results_wanted
+
+        # # Additional parameters
+        # col5, col6 = st.columns(2)
+        
+        # with col5:
+        #     hours_old = st.number_input("Jobs Posted Within (hours)", min_value=1, max_value=168, value=st.session_state.hours_old)
+        #     st.session_state.hours_old = hours_old
+
+        # with col6:
+        #     country_indeed = st.text_input("Country (for Indeed)", st.session_state.country_indeed)
+        #     st.session_state.country_indeed = country_indeed
+
+        # search_button_clicked = st.button("Search Jobs") 
+
+        # # Search Button
+        # # if st.button("Search Jobs"):
+        # if search_button_clicked:
+        #     with st.spinner("Searching Jobs..."):
+        #         # Perform job search
+        #         try:
+        #             logger.info(f"Performing job search with {search_term} in {location}")
+        #             # jobs = scrape_jobs(
+        #             #     site_name=site_name,
+        #             #     search_term=search_term,
+        #             #     google_search_term=f"{search_term} jobs near {location}",
+        #             #     location=location,
+        #             #     results_wanted=results_wanted,
+        #             #     hours_old=hours_old,
+        #             #     country_indeed=country_indeed,
+        #             # )
+        #             jobs = scrape_jobs(
+        #                 site_name=st.session_state.site_name,
+        #                 search_term=st.session_state.search_term,
+        #                 google_search_term=f"{st.session_state.search_term} jobs near {st.session_state.location}",
+        #                 location=st.session_state.location,
+        #                 results_wanted=st.session_state.results_wanted,
+        #                 hours_old=st.session_state.hours_old,
+        #                 country_indeed=st.session_state.country_indeed,
+        #             )
+        #             st.session_state.job_search_results = jobs
+
+        #             if len(jobs) > 0:
+        #                 st.success(f"Found {len(jobs)} jobs")
+                        
+        #                 jobs_filtered = jobs[['site', 'job_url', 'title', 'company', 'location', 'date_posted']]
+        #                 # Display job data in a table
+        #                 # st.dataframe(jobs)
+        #                 jobs_filtered['job_url'] = jobs_filtered['job_url'].apply(make_clickable_link)
+        #                 st.write(jobs_filtered.to_html(escape=False), unsafe_allow_html=True)
+                        
+        #                 # st.dataframe(jobs_filtered)
+
+        #                 # Option to download jobs
+        #                 csv_file = jobs.to_csv(index=False)
+        #                 st.download_button(
+        #                     label="Download Jobs as CSV",
+        #                     data=csv_file,
+        #                     file_name='job_search_results.csv',
+        #                     mime='text/csv'
+        #                 )
+        #             else:
+        #                 st.warning("No jobs found")
+                
+        #         except Exception as e:
+        #             st.error(f"Job Search Error: {e}")
+        #             logger.error(f"Job Search Error: {e}")