app.py

import time
import streamlit as st
from langchain.document_loaders import PyPDFLoader
from langchain.text_splitter import RecursiveCharacterTextSplitter
from langchain.embeddings.base import Embeddings
from langchain.vectorstores import FAISS
from langchain.indexes import VectorstoreIndexCreator
from langchain.chains import RetrievalQA
from langchain.chat_models import ChatOpenAI
from typing import List
from together import Together

# ----------------- تنظیمات صفحه -----------------
import streamlit as st

st.set_page_config(page_title="رزم یار ارتش", page_icon="🪖", layout="wide")

st.markdown("""
    <style>
    /* فونت و راست‌چین */
    @import url('https://fonts.googleapis.com/css2?family=Vazirmatn:wght@400;700&display=swap');
    html, body, [class*="css"] {
        font-family: 'Vazirmatn', Tahoma, sans-serif;
        direction: rtl;
        text-align: right;
        background-color: #f0f4f7;
    }

    /* پس زمینه صفحه اصلی */
    .stApp {
        background: linear-gradient(rgba(0, 0, 0, 0.5), rgba(0, 0, 0, 0.5)), 
                    url("./military_bg.jpeg") no-repeat center center fixed;
        background-size: cover;
        backdrop-filter: blur(2px);
    }

    /* استایل پیام‌های چت */
    .stChatMessage {
        background-color: rgba(255, 255, 255, 0.85);
        border: 2px solid #4e8a3e;
        border-radius: 16px;
        padding: 18px;
        margin-bottom: 18px;
        box-shadow: 0 4px 12px rgba(0,0,0,0.3);
        animation: fadeIn 0.5s ease-in-out;
    }

    /* استایل ورودی کاربر */
    .stTextInput > div > input, .stTextArea textarea {
        background-color: rgba(255, 255, 255, 0.95) !important;
        border: 1px solid #ccc !important;
        border-radius: 10px !important;
        padding: 10px;
        direction: rtl;
        text-align: right;
        font-family: 'Vazirmatn', Tahoma;
        font-size: 16px;
    }

    /* استایل دکمه */
    .stButton>button {
        background-color: #4e8a3e !important;
        color: white !important;
        font-weight: bold;
        border-radius: 12px;
        padding: 10px 24px;
        transition: all 0.3s ease;
        font-size: 16px;
    }
    .stButton>button:hover {
        background-color: #3c6d30 !important;
        transform: scale(1.05);
    }

    /* سربرگ اصلی */
    .header-text {
        text-align: center;
        margin-top: 30px;
        margin-bottom: 40px;
        background-color: rgba(255, 255, 255, 0.8);
        padding: 30px;
        border-radius: 24px;
        box-shadow: 0 6px 16px rgba(0,0,0,0.25);
        animation: fadeIn 0.6s ease-in-out;
    }
    .header-text h1 {
        font-size: 48px;
        color: #2c3e50;
        margin: 0;
        font-weight: 900;
    }
    .subtitle {
        font-size: 20px;
        color: #34495e;
        margin-top: 10px;
        font-weight: bold;
    }

    /* انیمیشن */
    @keyframes fadeIn {
        from { opacity: 0; transform: translateY(20px); }
        to { opacity: 1; transform: translateY(0); }
    }
    </style>
""", unsafe_allow_html=True)

# ----------------- سربرگ با لوگو -----------------
col1, col2, col3 = st.columns([1, 0.5, 1])
with col2:
    st.image("log.png", width=220)

st.markdown("""
    <div class="header-text">
        <h1>رزم یار ارتش</h1>
        <div class="subtitle">دستیار هوشمند نیروهای مسلح</div>
    </div>
""", unsafe_allow_html=True)

# ----------------- لود PDF و ساخت ایندکس -----------------
class TogetherEmbeddings(Embeddings):
    def __init__(self, model_name: str, api_key: str):
        self.model_name = model_name
        self.client = Together(api_key=api_key)

    def embed_documents(self, texts: List[str]) -> List[List[float]]:
        response = self.client.embeddings.create(model=self.model_name, input=texts)
        return [item.embedding for item in response.data]

    def embed_query(self, text: str) -> List[float]:
        return self.embed_documents([text])[0]

@st.cache_resource
def get_pdf_index():
    with st.spinner('📄 در حال پردازش فایل PDF...'):
        loader = [PyPDFLoader('test12.pdf')]
        embeddings = TogetherEmbeddings(
            model_name="togethercomputer/m2-bert-80M-8k-retrieval",
            api_key="0291f33aee03412a47fa5d8e562e515182dcc5d9aac5a7fb5eefdd1759005979"
        )
        return VectorstoreIndexCreator(
            embedding=embeddings,
            text_splitter=RecursiveCharacterTextSplitter(chunk_size=300, chunk_overlap=0)
        ).from_loaders(loader)

index = get_pdf_index()

llm = ChatOpenAI(
    base_url="https://api.together.xyz/v1",
    api_key='0291f33aee03412a47fa5d8e562e515182dcc5d9aac5a7fb5eefdd1759005979',
    model="meta-llama/Llama-3.3-70B-Instruct-Turbo-Free"
)

chain = RetrievalQA.from_chain_type(
    llm=llm,
    chain_type='stuff',
    retriever=index.vectorstore.as_retriever(),
    input_key='question'
)

if 'messages' not in st.session_state:
    st.session_state.messages = []

if 'pending_prompt' not in st.session_state:
    st.session_state.pending_prompt = None

for msg in st.session_state.messages:
    with st.chat_message(msg['role']):
        st.markdown(f"🗨️ {msg['content']}", unsafe_allow_html=True)

prompt = st.chat_input("چطور می‌تونم کمک کنم؟")

if prompt:
    st.session_state.messages.append({'role': 'user', 'content': prompt})
    st.session_state.pending_prompt = prompt
    st.rerun()

if st.session_state.pending_prompt:
    with st.chat_message('ai'):
        thinking = st.empty()
        thinking.markdown("🤖 در حال فکر کردن...")

        response = chain.run(f'پاسخ را فقط به زبان فارسی جواب بده به هیچ عنوان از زبان چینی در پاسخ استفاده نکن. سوال: {st.session_state.pending_prompt}')
        answer = response.split("Helpful Answer:")[-1].strip()
        if not answer:
            answer = "متأسفم، اطلاعات دقیقی در این مورد ندارم."

        thinking.empty()
        full_response = ""
        placeholder = st.empty()
        for word in answer.split():
            full_response += word + " "
            placeholder.markdown(full_response + "▌")
            time.sleep(0.03)

        placeholder.markdown(full_response)
        st.session_state.messages.append({'role': 'ai', 'content': full_response})
        st.session_state.pending_prompt = None