app.py

# app.py
import streamlit as st
import os
import tempfile
from io import BytesIO
from PyPDF2 import PdfReader
from langchain.text_splitter import RecursiveCharacterTextSplitter
from langchain_community.embeddings import HuggingFaceEmbeddings
from langchain_community.vectorstores import FAISS
from langchain_community.docstore.in_memory import InMemoryDocstore
from langchain_community.llms import HuggingFaceHub
from langchain.chains import RetrievalQA
from langchain.prompts import PromptTemplate
import faiss
import uuid
from dotenv import load_dotenv

# Load environment variables
load_dotenv()
HUGGINGFACEHUB_API_TOKEN = os.getenv("HUGGINGFACEHUB_API_TOKEN")
RAG_ACCESS_KEY = os.getenv("RAG_ACCESS_KEY")

# Initialize session state
if "vectorstore" not in st.session_state:
    st.session_state.vectorstore = None
if "history" not in st.session_state:
    st.session_state.history = []
if "authenticated" not in st.session_state:
    st.session_state.authenticated = False

# Sidebar
with st.sidebar:
    # BSNL Logo (local file with error handling)
    try:
        st.image(
            "bsnl_logo.png",
            width=200
        )
    except FileNotFoundError:
        st.warning("BSNL logo not found. Please ensure 'bsnl_logo.png' exists in the project root.")
    st.header("RAG Control Panel")
    api_key_input = st.text_input("Enter RAG Access Key", type="password")
    
    # Authentication
    if st.button("Authenticate"):
        if api_key_input == RAG_ACCESS_KEY:
            st.session_state.authenticated = True
            st.success("Authentication successful!")
        else:
            st.error("Invalid API key.")
    
    # File uploader
    if st.session_state.authenticated:
        input_data = st.file_uploader("Upload a PDF file", type=["pdf"])
        
        if st.button("Process File") and input_data is not None:
            try:
                vector_store = process_input(input_data)
                st.session_state.vectorstore = vector_store
                st.success("File processed successfully. You can now ask questions.")
            except (PermissionError, OSError) as e:
                st.error(f"Error processing file: {str(e)}. Check file permissions or server configuration.")
    
    # Display chat history
    st.subheader("Chat History")
    for i, (q, a) in enumerate(st.session_state.history):
        st.write(f"**Q{i+1}:** {q}")
        st.write(f"**A{i+1}:** {a}")
        st.markdown("---")

# Main app
def main():
    # Inject CSS for simple color scheme and clean styling
    st.markdown("""
        <style>
        @import url('https://fonts.googleapis.com/css2?family=Roboto:wght@400;700&display=swap');
        .stApp {
            background-color: #FFFFFF; /* White background */
            font-family: 'Roboto', sans-serif;
            color: #333333;
        }
        .stTextInput > div > div > input {
            background-color: #FFFFFF;
            color: #333333;
            border-radius: 8px;
            border: 1px solid #007BFF;
            padding: 10px;
            box-shadow: 0 2px 4px rgba(0,0,0,0.1);
        }
        .stButton > button {
            background-color: #007BFF;
            color: white;
            border-radius: 8px;
            padding: 10px 20px;
            border: none;
            transition: all 0.3s ease;
            box-shadow: 0 2px 4px rgba(0,0,0,0.2);
        }
        .stButton > button:hover {
            background-color: #0056b3;
            transform: scale(1.05);
        }
        .stSidebar {
            background-color: #F5F5F5; /* Light gray */
            padding: 20px;
            border-right: 2px solid #007BFF;
        }
        h1, h2, h3 {
            color: #333333;
        }
        .stSpinner > div > div {
            border-color: #007BFF transparent transparent transparent;
        }
        </style>
    """, unsafe_allow_html=True)
    
    st.title("RAG Q&A App with Mistral AI")
    st.markdown("Welcome to the BSNL RAG App! Upload your PDF files and ask questions with ease.", unsafe_allow_html=True)
    
    if not st.session_state.authenticated:
        st.warning("Please authenticate with your API key in the sidebar.")
        return
    
    if st.session_state.vectorstore is None:
        st.info("Please upload and process a PDF file in the sidebar.")
        return
    
    query = st.text_input("Enter your question:")
    if st.button("Submit") and query:
        with st.spinner("Generating answer..."):
            answer = answer_question(st.session_state.vectorstore, query)
            st.session_state.history.append((query, answer))
            st.write("**Answer:**", answer)

def process_input(input_data):
    # Create uploads directory with proper permissions
    try:
        os.makedirs("uploads", exist_ok=True)
        os.chmod("uploads", 0o777)  # Ensure write permissions
    except PermissionError as e:
        st.error(f"Failed to create uploads directory: {str(e)}")
        raise
    
    # Initialize progress bar and status
    progress_bar = st.progress(0)
    status = st.status("Processing PDF file...", expanded=True)
    
    # Step 1: Save file temporarily
    status.update(label="Saving PDF file...")
    progress_bar.progress(0.20)
    
    with tempfile.NamedTemporaryFile(delete=False, dir="uploads", suffix=".pdf") as tmp_file:
        tmp_file.write(input_data.read())
        tmp_file_path = tmp_file.name
    
    # Step 2: Read PDF file
    status.update(label="Reading PDF file...")
    progress_bar.progress(0.40)
    
    try:
        pdf_reader = PdfReader(tmp_file_path)
        documents = ""
        for page in pdf_reader.pages:
            documents += page.extract_text() or ""
    finally:
        os.remove(tmp_file_path)  # Clean up temporary file
    
    # Step 3: Split text
    status.update(label="Splitting text into chunks...")
    progress_bar.progress(0.60)
    
    text_splitter = RecursiveCharacterTextSplitter(chunk_size=1000, chunk_overlap=100)
    texts = text_splitter.split_text(documents)
    
    # Step 4: Create embeddings
    status.update(label="Creating embeddings...")
    progress_bar.progress(0.80)
    
    hf_embeddings = HuggingFaceEmbeddings(
        model_name="sentence-transformers/all-mpnet-base-v2",
        model_kwargs={'device': 'cpu'}
    )
    
    # Step 5: Initialize FAISS vector store
    status.update(label="Building vector store...")
    progress_bar.progress(0.90)
    
    dimension = len(hf_embeddings.embed_query("sample text"))
    index = faiss.IndexFlatL2(dimension)
    vector_store = FAISS(
        embedding_function=hf_embeddings,
        index=index,
        docstore=InMemoryDocstore({}),
        index_to_docstore_id={}
    )
    
    # Add texts to vector store
    uuids = [str(uuid.uuid4()) for _ in range(len(texts))]
    vector_store.add_texts(texts, ids=uuids)
    
    # Save vector store locally
    vector_store.save_local("vectorstore/faiss_index")
    
    # Complete processing
    status.update(label="Processing complete!", state="complete")
    progress_bar.progress(1.0)
    
    return vector_store

def answer_question(vectorstore, query):
    llm = HuggingFaceHub(
        repo_id="mistralai/Mistral-7B-Instruct-v0.1",
        model_kwargs={"temperature": 0.7, "max_length": 512},
        huggingfacehub_api_token=HUGGINGFACEHUB_API_TOKEN
    )
    
    retriever = vectorstore.as_retriever(search_kwargs={"k": 3})
    
    prompt_template = PromptTemplate(
        template="Use the provided context to answer the question concisely:\n\nContext: {context}\n\nQuestion: {question}\n\nAnswer:",
        input_variables=["context", "question"]
    )
    
    qa_chain = RetrievalQA.from_chain_type(
        llm=llm,
        chain_type="stuff",
        retriever=retriever,
        return_source_documents=False,
        chain_type_kwargs={"prompt": prompt_template}
    )
    
    result = qa_chain({"query": query})
    return result["result"].split("Answer:")[-1].strip()

if __name__ == "__main__":
    main()