adding send_feedback feature and refactor code

.dockerignore

@@ -11,4 +11,4 @@ venv/
 .venv/
 node_modules/
 npm-debug.log
-logs/
+data/

.gitignore

@@ -11,4 +11,4 @@ venv/
 .venv/
 node_modules/
 npm-debug.log
-logs/
+data/

Dockerfile

@@ -9,12 +9,13 @@ RUN apt-get update && \
     apt-get install -y nodejs && \
     rm -rf /var/lib/apt/lists/*
 
-# Create logs directory as root and set permissions
-RUN mkdir -p logs
+# Create logs directory as root
+RUN mkdir -p /app/data
 
 # Create a non-root user and set permissions
 RUN useradd -m -u 1000 user && \
-    chown -R user:user /app
+    chown -R user:user /app \
+    && chown -R user:user /app/data
 
 # Switch to non-root user
 USER user

README.md

@@ -15,34 +15,39 @@ tags:
   - coaching
 ---
 
-# Career Coach AI Assistant
+# Career Coach Agent
 
-A FastAPI-based AI assistant that helps users with career development, powered by Llama-3.3-70B-Instruct and LangChain.
-
-## Features
-
-- Interactive chat interface
-- Career-focused AI assistant using Llama-3.3-70B-Instruct model
-- FastAPI backend with RESTful endpoints
-- LangChain integration for advanced prompt handling and tool usage
-- System prompts and templates managed through YAML configuration
+An AI-powered career coaching assistant that helps users create personalized development plans and provides career guidance.
 
 ## Project Structure
 
 ```
 career-coach-agent/
 ├── app.py              # Main FastAPI application with agent setup
-├── prompts.yaml        # System prompts and templates
+├── main.py            # Application entry point
+├── prompts.yaml       # System prompts and templates
+├── output_parser.py   # Response parsing and validation
+├── frontend/          # React frontend application
+│   ├── src/
+│   │   ├── components/    # React components
+│   │   ├── types/        # TypeScript type definitions
+│   │   └── App.tsx       # Main application component
 ├── tools/             # Tool implementations
 │   ├── visit_webpage.py    # Web page content fetcher
 │   ├── wikipedia_tool.py   # Wikipedia search tool
 │   ├── python_repl.py      # Python code execution tool
-│   └── internet_search.py  # Internet search tool
+│   ├── internet_search.py  # Internet search tool
+│   ├── google_jobs_search.py # Google Jobs search tool
+│   └── date_and_time.py    # Date and time utilities
+├── helpers/           # Helper functions
+│   ├── helper.py         # General helper functions
+│   └── feedback_handler.py # Feedback processing
 └── README.md          # This file
 ```
 
 ## Requirements
 
+### Backend
 - Python 3.12+
 - FastAPI
 - LangChain
@@ -52,6 +57,19 @@ career-coach-agent/
   - markdownify
   - wikipedia
   - duckduckgo-search
+  - pytz
+  - python-multipart
+  - uvicorn
+
+### Frontend
+- Node.js 16+
+- React
+- TypeScript
+- Additional dependencies:
+  - styled-components
+  - axios
+  - @types/react
+  - @types/styled-components
 
 ## Environment Variables
 
@@ -68,24 +86,51 @@ git clone <repository-url>
 cd career-coach-agent
 ```
 
-2. Install dependencies:
+2. Install backend dependencies:
 ```bash
-pip install fastapi langchain langchain_huggingface pydantic python-multipart uvicorn requests markdownify wikipedia duckduckgo-search
+pip install -r requirements.txt
 ```
 
-3. Set up your Hugging Face API token as an environment variable.
+3. Install frontend dependencies:
+```bash
+cd frontend
+npm install
+```
+
+4. Set up your Hugging Face API token as an environment variable.
 
 ## Running the Application
 
-Start the application:
+### Development Mode
+
+1. Start the backend:
+```bash
+uvicorn main:app --reload
+```
+
+2. Start the frontend development server:
+```bash
+cd frontend
+npm start
+```
+
+### Production Mode
+
+1. Build the frontend:
+```bash
+cd frontend
+npm run build
+```
+
+2. Start the application:
 ```bash
-uvicorn app:app --reload
+uvicorn main:app
 ```
 
 The application will be available at:
-- Web Interface: http://localhost:8000
-- API Documentation: http://localhost:8000/docs
-- Alternative API Documentation: http://localhost:8000/redoc
+- Web Interface: http://localhost:7860
+- API Documentation: http://localhost:7860/docs
+- Alternative API Documentation: http://localhost:7860/redoc
 
 ## API Endpoints
 
@@ -101,6 +146,30 @@ Request body:
 }
 ```
 
+### `/agent/feedback` (POST)
+Submit user feedback.
+
+Request body:
+```json
+{
+    "contact": "string",
+    "feedback": "string"
+}
+```
+
+### `/pdp-generator` (POST)
+Generate a Personal Development Plan.
+
+Request body:
+```json
+{
+    "file": "PDF file",
+    "career_goal": "string",
+    "additional_context": "string (optional)",
+    "target_date": "string"
+}
+```
+
 ## Available Tools
 
 The AI assistant has access to the following tools:
@@ -124,9 +193,29 @@ The AI assistant has access to the following tools:
    - Returns relevant search results
    - Useful for finding current information
 
-## Technical Features
+5. **Google Jobs Search**
+   - Searches for job listings on Google Jobs
+   - Returns relevant job opportunities
+   - Helps with career research
+
+6. **Date and Time**
+   - Provides current date and time information
+   - Supports multiple timezones
+   - Useful for scheduling and planning
+
+## Features
 
-- Real-time chat interface
+### Frontend
+- Modern, responsive UI built with React and TypeScript
+- Real-time chat interface with message history
+- Personal Development Plan (PDP) generation
+- PDF upload and processing
+- User feedback system
+- Mobile-friendly design
+
+### Backend
+- FastAPI-based REST API
+- LangChain-powered AI agent
 - Conversation memory and context management
 - Error handling and graceful degradation
 - CORS support
@@ -136,11 +225,18 @@ The AI assistant has access to the following tools:
 
 ## Architecture
 
-- **FastAPI**: Handles HTTP requests and API endpoints
-- **LangChain**: Manages the AI agent and tools
-- **Llama-3.3-70B-Instruct**: Powers the AI responses
-- **YAML Configuration**: Manages system prompts and templates
-- **Tools Integration**: Wikipedia, Web, Python, and Search capabilities
+- **Frontend**:
+  - React with TypeScript
+  - Styled Components for styling
+  - Axios for API communication
+  - Responsive design for all devices
+
+- **Backend**:
+  - FastAPI: Handles HTTP requests and API endpoints
+  - LangChain: Manages the AI agent and tools
+  - Llama-3.3-70B-Instruct: Powers the AI responses
+  - YAML Configuration: Manages system prompts and templates
+  - Tools Integration: Wikipedia, Web, Python, Search, and more
 
 ## Contributing
 

app.py

@@ -7,14 +7,10 @@ from langchain_community.document_loaders import PyPDFLoader
 from langchain_core.tools.render import render_text_description
 from langchain.text_splitter import RecursiveCharacterTextSplitter
 
-from tools.visit_webpage import visit_webpage
-from tools.wikipedia_tool import wikipedia_search
-from tools.python_repl import run_python_code
-from tools.internet_search import internet_search
-from tools.google_jobs_search import google_job_search
-from tools.date_and_time import current_date_and_time
 from output_parser import FlexibleOutputParser, clean_llm_response, validate_pdp_response
-from tools import create_pdp_pdf
+from tools import *
+from helpers import *
+
 
 import os
 import yaml
@@ -100,12 +96,11 @@ chat_model_with_stop = llm.bind(
     stop=["\nHuman:", "Human:", "\n\nHuman", "\nUser:"] 
 )
 
-# Update the agent to include chat_history
 agent = (
     {
         "input": lambda x: x["input"],
         "agent_scratchpad": lambda x: format_log_to_str(x["intermediate_steps"]) if x["intermediate_steps"] else "",
-        "chat_history": lambda x: x.get("chat_history", [])  # Add this line!
+        "chat_history": lambda x: x.get("chat_history", []) 
     }
     | prompt
     | chat_model_with_stop
@@ -152,6 +147,18 @@ class PDPRequest(BaseModel):
     cv_content: str = ""  # To store extracted CV text
 
 # API Routes
+@app.post("/agent/feedback")
+async def feedback(contact: str, feedback: str):
+    """
+    Receive and store user feedback
+    """
+    try:
+        print("Feedback: ",contact, feedback)
+        result = store_feedback(contact, feedback)
+        return result
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+
 @app.post("/agent/cancel/{thread_id}")
 async def cancel_request(thread_id: str):
     if thread_id in active_requests:
@@ -224,6 +231,7 @@ async def pdp_generator(
         # Generate PDP using the agent
         pdp_query = f"""
         Create a comprehensive Personal Development Plan for transitioning to {pdp_request.career_goal} by {pdp_request.target_date}.
+        DO NOT ASK FOR CONFIRMATION OF THIS REQUEST!
 
         Based on this CV content: {pdp_request.cv_content}
         Additional context: {pdp_request.additional_context}
@@ -265,6 +273,7 @@ async def pdp_generator(
                 # Validate the response
                 if validate_pdp_response(pdp_response):
                     # Create PDF only if validation passes
+                    print("raw-pdp_response: ",pdp_response)
                     try:
                         pdf_buffer = create_pdp_pdf(
                             pdp_content=pdp_response,
@@ -278,6 +287,14 @@ async def pdp_generator(
                         safe_career_goal = re.sub(r'[-\s]+', '-', safe_career_goal)
                         pdf_filename = f"PDP_{safe_career_goal}_{datetime.now().strftime('%Y%m%d')}.pdf"
 
+                        # Add PDP request to chat history memory
+                        user_pdp_message = f"User requested a Personal Development Plan.\nCareer Goal: {pdp_request.career_goal}\nTarget Date: {pdp_request.target_date}\nAdditional Context: {pdp_request.additional_context or 'None'}\nCV Provided: {'Yes' if cv_content.strip() else 'No'}"
+                        assistant_pdp_ack = "Okay, I 've successfully generated you PDP PDF file"
+                        memory.save_context(
+                            {"input": user_pdp_message},
+                            {"output": assistant_pdp_ack}
+                        )
+
                         return StreamingResponse(
                             BytesIO(pdf_buffer.read()),
                             media_type="application/pdf",

frontend/package.json

@@ -38,5 +38,11 @@
       "last 1 safari version"
     ]
   },
-  "proxy": "http://localhost:7860"
+  "proxy": "http://localhost:7860",
+  "devDependencies": {
+    "@types/react": "^18.2.66",
+    "@types/react-dom": "^18.2.22",
+    "@types/styled-components": "^5.1.34",
+    "@types/axios": "^0.14.0"
+  }
 }

frontend/src/components/ChatBot.tsx

@@ -5,7 +5,8 @@ import ChatHeader from './ChatHeader';
 import ChatWindow from './ChatWindow';
 import ChatInput from './ChatInput';
 import PDPDialog, { PDPFormData } from './PDPDialog';
-import { Message, ChatResponse } from '../types';
+import SendFeedback from './SendFeedback';
+import { Message, ChatResponse, FeedbackFormData } from '../types';
 
 const ChatContainer = styled.div`
   display: flex;
@@ -22,6 +23,7 @@ const ChatBot: React.FC = () => {
   const [threadId, setThreadId] = useState<string | null>(null);
   const [isLoading, setIsLoading] = useState(false);
   const [isPDPDialogOpen, setIsPDPDialogOpen] = useState(false);
+  const [isSendFeedbackDialogOpen, setIsSendFeedbackDialogOpen] = useState(false);
   const cancelTokenRef = useRef<AbortController | null>(null);
 
   // Add welcome message when component mounts
@@ -221,12 +223,38 @@ const ChatBot: React.FC = () => {
       setIsLoading(false);
     }
   };
-  
+
   // The pdpDialog function as requested
   const pdpDialog = () => {
     openPDPDialog();
   };
 
+  const closeSendFeedbackDialog = () => {
+    setIsSendFeedbackDialogOpen(false);
+  };
+
+  const handleSendFeedbackSubmit = async (data: FeedbackFormData) => {
+    try {
+      console.log('Sending feedback data:', JSON.stringify(data));
+      const url = new URL('/agent/feedback', window.location.origin);
+      url.searchParams.append('contact', data.contact);
+      url.searchParams.append('feedback', data.feedback);
+
+      const response = await fetch(url.toString(), {
+        method: 'POST'
+      });
+
+      if (!response.ok) {
+        throw new Error('Failed to submit feedback');
+      }
+
+      alert('Thank you for your feedback!');
+    } catch (error) {
+      console.error('Error submitting feedback:', error);
+      alert('Failed to submit feedback. Please try again later.');
+    }
+  };
+
   return (
     <ChatContainer>
       <ChatHeader 
@@ -240,7 +268,13 @@ const ChatBot: React.FC = () => {
       <ChatInput 
         onSendMessage={sendMessage} 
         onCancelRequest={cancelRequest}
-        isLoading={isLoading} 
+        isLoading={isLoading}
+        onOpenFeedback={() => setIsSendFeedbackDialogOpen(true)}
+      />
+      <SendFeedback 
+        isOpen={isSendFeedbackDialogOpen}
+        onClose={closeSendFeedbackDialog}
+        onSubmit={handleSendFeedbackSubmit}
       />
       <PDPDialog
         isOpen={isPDPDialogOpen}

frontend/src/components/ChatInput.tsx

@@ -1,5 +1,7 @@
-import React, { useState } from 'react';
+import React, { useState, FormEvent, ChangeEvent } from 'react';
 import styled from 'styled-components';
+import SendFeedback from './SendFeedback';
+import { FeedbackFormData, FeedbackResponse } from '../types';
 
 const InputContainer = styled.div`
   display: flex;
@@ -52,16 +54,32 @@ const StopButton = styled.button`
   }
 `;
 
+const FeedbackButton = styled.button`
+  margin-left: 10px;
+  padding: 10px 15px;
+  background-color:rgb(131, 138, 145);
+  color: white;
+  border: none;
+  border-radius: 20px;
+  cursor: pointer;
+  font-size: 16px;
+  
+  &:hover {
+    background-color: #5a6268;
+  }
+`;
+
 interface ChatInputProps {
   onSendMessage: (message: string) => void;
   onCancelRequest: () => void;
   isLoading: boolean;
+  onOpenFeedback: () => void;
 }
 
-const ChatInput: React.FC<ChatInputProps> = ({ onSendMessage, onCancelRequest, isLoading }) => {
+const ChatInput: React.FC<ChatInputProps> = ({ onSendMessage, onCancelRequest, isLoading, onOpenFeedback }) => {
   const [message, setMessage] = useState('');
 
-  const handleSubmit = (e: React.FormEvent) => {
+  const handleSubmit = (e: FormEvent<HTMLFormElement>) => {
     e.preventDefault();
     if (message.trim() && !isLoading) {
       onSendMessage(message);
@@ -72,10 +90,13 @@ const ChatInput: React.FC<ChatInputProps> = ({ onSendMessage, onCancelRequest, i
   return (
     <InputContainer>
       <form onSubmit={handleSubmit} style={{ display: 'flex', width: '100%' }}>
+        <FeedbackButton type="button" onClick={onOpenFeedback}>
+          Send Feedback
+        </FeedbackButton>
         <Input
           type="text"
           value={message}
-          onChange={(e) => setMessage(e.target.value)}
+          onChange={(e: ChangeEvent<HTMLInputElement>) => setMessage(e.target.value)}
           placeholder="Type your message..."
           disabled={isLoading}
         />
@@ -87,7 +108,7 @@ const ChatInput: React.FC<ChatInputProps> = ({ onSendMessage, onCancelRequest, i
           <StopButton type="button" onClick={onCancelRequest}>
             Stop
           </StopButton>
-        )}
+        )}      
       </form>
     </InputContainer>
   );

frontend/src/components/SendFeedback.tsx

@@ -0,0 +1,255 @@
+import React, { useState, FormEvent, ChangeEvent } from 'react';
+import styled from 'styled-components';
+import { FeedbackFormData } from '../types';
+
+const Overlay = styled.div`
+  position: fixed;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background-color: rgba(0, 0, 0, 0.5);
+  display: flex;
+  justify-content: center;
+  align-items: center;
+  z-index: 1000;
+`;
+
+const Modal = styled.div`
+  background: white;
+  padding: 30px;
+  border-radius: 8px;
+  width: 90%;
+  max-width: 500px;
+  box-shadow: 0 4px 6px rgba(0, 0, 0, 0.1);
+
+  @media screen and (max-width: 768px) {
+    padding: 20px;
+    width: 95%;
+  }
+
+  @media screen and (max-width: 480px) {
+    padding: 15px;
+    width: 100%;
+    margin: 10px;
+  }
+`;
+
+const Title = styled.h2`
+  margin: 0 0 20px 0;
+  color: #333;
+  font-size: 24px;
+
+  @media screen and (max-width: 768px) {
+    font-size: 20px;
+    margin-bottom: 15px;
+  }
+
+  @media screen and (max-width: 480px) {
+    font-size: 18px;
+    margin-bottom: 12px;
+  }
+`;
+
+const Form = styled.form`
+  display: flex;
+  flex-direction: column;
+  gap: 15px;
+
+  @media screen and (max-width: 768px) {
+    gap: 12px;
+  }
+
+  @media screen and (max-width: 480px) {
+    gap: 10px;
+  }
+`;
+
+const Label = styled.label`
+  font-weight: bold;
+  color: #555;
+  font-size: 16px;
+
+  @media screen and (max-width: 768px) {
+    font-size: 14px;
+  }
+
+  @media screen and (max-width: 480px) {
+    font-size: 13px;
+  }
+`;
+
+const Input = styled.input`
+  padding: 10px;
+  border: 1px solid #ddd;
+  border-radius: 4px;
+  font-size: 16px;
+
+  @media screen and (max-width: 768px) {
+    padding: 8px;
+    font-size: 14px;
+  }
+
+  @media screen and (max-width: 480px) {
+    padding: 6px;
+    font-size: 13px;
+  }
+`;
+
+const TextArea = styled.textarea`
+  padding: 10px;
+  border: 1px solid #ddd;
+  border-radius: 4px;
+  font-size: 16px;
+  min-height: 100px;
+  resize: vertical;
+
+  @media screen and (max-width: 768px) {
+    padding: 8px;
+    font-size: 14px;
+    min-height: 80px;
+  }
+
+  @media screen and (max-width: 480px) {
+    padding: 6px;
+    font-size: 13px;
+    min-height: 70px;
+  }
+`;
+
+const ButtonGroup = styled.div`
+  display: flex;
+  gap: 10px;
+  justify-content: flex-end;
+  margin-top: 20px;
+
+  @media screen and (max-width: 768px) {
+    gap: 8px;
+    margin-top: 15px;
+  }
+
+  @media screen and (max-width: 480px) {
+    gap: 6px;
+    margin-top: 12px;
+  }
+`;
+
+const Button = styled.button`
+  padding: 10px 20px;
+  border: none;
+  border-radius: 4px;
+  cursor: pointer;
+  font-size: 16px;
+
+  @media screen and (max-width: 768px) {
+    padding: 8px 16px;
+    font-size: 14px;
+  }
+
+  @media screen and (max-width: 480px) {
+    padding: 6px 12px;
+    font-size: 13px;
+  }
+`;
+
+const SubmitButton = styled(Button)`
+  background-color: #0084ff;
+  color: white;
+  
+  &:hover {
+    background-color: #0073e6;
+  }
+  
+  &:disabled {
+    background-color: #ccc;
+    cursor: not-allowed;
+  }
+
+  @media (hover: none) {
+    &:hover {
+      background-color: #0084ff;
+    }
+  }
+`;
+
+const CancelButton = styled(Button)`
+  background-color: #6c757d;
+  color: white;
+  
+  &:hover {
+    background-color: #5a6268;
+  }
+
+  @media (hover: none) {
+    &:hover {
+      background-color: #6c757d;
+    }
+  }
+`;
+
+interface SendFeedbackProps {
+  isOpen: boolean;
+  onClose: () => void;
+  onSubmit: (data: FeedbackFormData) => void;
+}
+
+const SendFeedback: React.FC<SendFeedbackProps> = ({ isOpen, onClose, onSubmit }) => {
+  const [contact, setContact] = useState('');
+  const [feedbackContent, setFeedbackContent] = useState('');
+
+  const handleSubmit = (e: FormEvent<HTMLFormElement>) => {
+    e.preventDefault();
+    onSubmit({
+      contact: contact,
+      feedback: feedbackContent
+    });
+    setContact('');
+    setFeedbackContent('');
+    onClose();
+  };
+
+  if (!isOpen) return null;
+
+  return (
+    <Overlay onClick={onClose}>
+      <Modal onClick={(e: React.MouseEvent) => e.stopPropagation()}>
+        <Title>Send Feedback</Title>
+        <Form onSubmit={handleSubmit}>
+          <div>
+            <Label htmlFor="contact">Contact Information (Email/Name):</Label>
+            <Input
+              id="contact"
+              type="text"
+              value={contact}
+              onChange={(e: ChangeEvent<HTMLInputElement>) => setContact(e.target.value)}
+              placeholder="your email or name"
+              required
+            />
+          </div>
+          
+          <div>
+            <Label htmlFor="feedback">Feedback:</Label>
+            <TextArea
+              id="feedback"
+              value={feedbackContent}
+              onChange={(e: ChangeEvent<HTMLTextAreaElement>) => setFeedbackContent(e.target.value)}
+              placeholder="Please share your feedback, suggestions, or report any issues..."
+              required
+            />
+          </div>
+          
+          <ButtonGroup>
+            <CancelButton type="button" onClick={onClose}>
+              Cancel
+            </CancelButton>
+            <SubmitButton type="submit">
+              Send Feedback
+            </SubmitButton>
+          </ButtonGroup>
+        </Form>
+      </Modal>
+    </Overlay>
+  );
+};
+
+export default SendFeedback;

frontend/src/types.ts

@@ -18,4 +18,14 @@ export interface PDPResponse {
   filename: string;
   career_goal: string;
   target_date: string;
+}
+
+export interface FeedbackFormData {
+  contact: string;
+  feedback: string;
+}
+
+export interface FeedbackResponse {
+  status: string;
+  message: string;
 }

helpers/__init__.py

@@ -0,0 +1,4 @@
+from .helper import create_pdp_pdf, clean_input
+from .feedback_handler import store_feedback
+
+__all__ = ["create_pdp_pdf", "store_feedback", "clean_input"] 

helpers/feedback_handler.py

@@ -0,0 +1,161 @@
+import json
+import os
+from datetime import datetime
+from typing import Dict, Any, List
+import shutil
+
+def store_feedback(contact: str, feedback: str) -> Dict[str, Any]:
+    """
+    Store feedback to a file in /data directory for Hugging Face Spaces
+
+    Args:
+        contact (str): Contact information (email/name)
+        feedback (str): Feedback content
+
+    Returns:
+        Dict[str, Any]: Result dictionary with status and message
+
+    Raises:
+        Exception: If there's an error saving the feedback
+    """
+    try:
+        # Validate inputs
+        if not contact or not contact.strip():
+            raise ValueError("Contact information is required")
+
+        if not feedback or not feedback.strip():
+            raise ValueError("Feedback content is required")
+
+        # Create feedback entry
+        feedback_entry = {
+            "timestamp": datetime.now().isoformat(),
+            "contact": contact.strip(),
+            "feedback": feedback.strip()
+        }
+
+        # Ensure /data/feedback directory exists
+        feedback_dir = "/app/data/feedback"
+        try:
+            os.makedirs(feedback_dir, exist_ok=True)
+            if not os.access(feedback_dir, os.W_OK):
+                raise PermissionError(f"No write permission for directory: {feedback_dir}")
+        except Exception as e:
+            raise Exception(f"Failed to create or access feedback directory: {str(e)}")
+
+        # Create filename with date
+        date_str = datetime.now().strftime('%Y-%m-%d')
+        filename = os.path.join(feedback_dir, f"feedback_{date_str}.json")
+        temp_filename = f"{filename}.tmp"
+
+        # Read existing feedback for the day or create new list
+        feedback_list = _read_feedback_file(filename)
+
+        # Add new feedback
+        feedback_list.append(feedback_entry)
+
+        # Write to temporary file first
+        try:
+            _write_feedback_file(temp_filename, feedback_list)
+            
+            # Verify the temporary file was written correctly
+            if not os.path.exists(temp_filename):
+                raise Exception("Failed to create temporary feedback file")
+            
+            # Verify the temporary file contains valid JSON
+            try:
+                with open(temp_filename, 'r', encoding='utf-8') as f:
+                    json.load(f)
+            except json.JSONDecodeError:
+                raise Exception("Failed to write valid JSON to temporary file")
+            
+            # If everything is good, replace the original file
+            backup_filename = None # Initialize backup_filename
+            if os.path.exists(filename):
+                # Create backup of original file
+                backup_filename = f"{filename}.bak"
+                shutil.copy2(filename, backup_filename)
+            
+            # Move temporary file to final location
+            shutil.move(temp_filename, filename)
+            
+            # Remove backup if everything succeeded
+            if backup_filename and os.path.exists(backup_filename):
+                os.remove(backup_filename)
+                
+        except Exception as e:
+            # Clean up temporary file if it exists
+            if os.path.exists(temp_filename):
+                os.remove(temp_filename)
+            raise Exception(f"Failed to write feedback file: {str(e)}")
+
+        # Log to console for immediate visibility
+        _log_feedback_to_console(feedback_entry, filename)
+
+        return {
+            "status": "success",
+            "message": "Feedback saved successfully",
+            "timestamp": feedback_entry["timestamp"],
+            "filename": filename
+        }
+
+    except Exception as e:
+        error_msg = f"Error saving feedback: {str(e)}"
+        print(error_msg)
+        raise Exception(error_msg)
+
+
+def _read_feedback_file(filename: str) -> List[Dict[str, Any]]:
+    """Read feedback from JSON file"""
+    try:
+        if not os.path.exists(filename):
+            return []
+            
+        if not os.access(filename, os.R_OK):
+            raise PermissionError(f"No read permission for file: {filename}")
+            
+        with open(filename, 'r', encoding='utf-8') as f:
+            try:
+                return json.load(f)
+            except json.JSONDecodeError as e:
+                # If file is corrupted, try to read backup
+                backup_filename = f"{filename}.bak"
+                if os.path.exists(backup_filename):
+                    print(f"Warning: Corrupted feedback file {filename}, trying backup")
+                    with open(backup_filename, 'r', encoding='utf-8') as backup_f:
+                        return json.load(backup_f)
+                else:
+                    print(f"Warning: Corrupted feedback file {filename}, starting fresh")
+                    return []
+    except Exception as e:
+        print(f"Error reading feedback file: {str(e)}")
+        return []
+
+
+def _write_feedback_file(filename: str, feedback_list: List[Dict[str, Any]]) -> None:
+    """Write feedback to JSON file"""
+    try:
+        # Ensure the directory exists
+        os.makedirs(os.path.dirname(filename), exist_ok=True)
+        
+        # Write to file with proper encoding and formatting
+        with open(filename, 'w', encoding='utf-8') as f:
+            json.dump(feedback_list, f, indent=2, ensure_ascii=False)
+            
+        # Verify the file was written
+        if not os.path.exists(filename):
+            raise Exception(f"Failed to create file: {filename}")
+            
+    except Exception as e:
+        raise Exception(f"Failed to write feedback file: {str(e)}")
+
+
+def _log_feedback_to_console(feedback_entry: Dict[str, Any], filename: str) -> None:
+    """Log feedback to console for immediate visibility"""
+    print("\n" + "="*60)
+    print("NEW FEEDBACK RECEIVED")
+    print("="*60)
+    print(f"Timestamp: {feedback_entry['timestamp']}")
+    print(f"Contact: {feedback_entry['contact']}")
+    print(f"Feedback: {feedback_entry['feedback']}")
+    print(f"Saved to: {filename}")
+    print("="*60 + "\n")

{tools → helpers}/helper.py

@@ -5,7 +5,6 @@ from reportlab.lib.styles import getSampleStyleSheet, ParagraphStyle
 from reportlab.lib.units import inch
 from reportlab.lib.colors import HexColor
 from io import BytesIO
-import re
 from datetime import datetime
 
 def clean_input(input: str) -> str:

prompts.yaml

@@ -48,6 +48,7 @@ system_prompt: |-
   - Focus on practical career advice
   - Do NOT execute code or perform technical analysis
   - Do NOT use tools unless specifically needed for research
+  - You can use internet_search to check for proper books, trainings or courses
   - Keep responses focused and professional
 
   **NEVER:**

tools/__init__.py

@@ -4,6 +4,5 @@ from .python_repl import run_python_code
 from .internet_search import internet_search
 from .google_jobs_search import google_job_search
 from .date_and_time import current_date_and_time
-from .helper import create_pdp_pdf
  
-__all__ = ["get_current_time", "visit_webpage"] 
+__all__ = ["current_date_and_time", "visit_webpage", "wikipedia_search", "run_python_code", "internet_search", "google_job_search"] 

tools/date_and_time.py

@@ -1,7 +1,7 @@
 from langchain_core.tools import tool
 from datetime import datetime
 import pytz
-from .helper import clean_input
+from helpers.helper import clean_input
 
 @tool
 def current_date_and_time(timezone: str) -> str:

tools/google_jobs_search.py

@@ -1,7 +1,7 @@
 from langchain_community.tools.google_jobs import GoogleJobsQueryRun
 from langchain_community.utilities.google_jobs import GoogleJobsAPIWrapper
 from langchain_core.tools import tool
-from .helper import clean_input
+from helpers.helper import clean_input
 import os
 
 if not os.getenv('SERPAPI_API_KEY'):

tools/internet_search.py

@@ -1,6 +1,6 @@
 from langchain_core.tools import tool
 from langchain_community.tools import DuckDuckGoSearchResults
-from .helper import clean_input
+from helpers.helper import clean_input
 
 
 @tool

tools/python_repl.py

@@ -1,6 +1,6 @@
 from langchain_core.tools import tool
 from langchain_experimental.utilities import PythonREPL
-from .helper import clean_input
+from helpers.helper import clean_input
 
 @tool
 def run_python_code(code: str) -> str:

tools/visit_webpage.py

@@ -3,7 +3,7 @@ import requests
 import markdownify
 import re
 from requests.exceptions import RequestException
-from .helper import clean_input
+from helpers.helper import clean_input
 
 @tool
 def visit_webpage(url: str) -> str:

tools/wikipedia_tool.py

@@ -1,7 +1,7 @@
 from langchain_core.tools import tool
 from langchain_community.tools import WikipediaQueryRun
 from langchain_community.utilities import WikipediaAPIWrapper
-from .helper import clean_input
+from helpers.helper import clean_input
 
 @tool
 def wikipedia_search(topic: str) -> str: