File size: 2,348 Bytes
0b0acf7 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 | #!/usr/bin/env python3
"""
Interactive CLI for QModel (FAISS + BM25 + Ollama/GGUF).
Run directly in your terminal to query the full Islamic RAG system.
"""
import os
import sys
import json
import asyncio
import logging
# Suppress verbose warnings
os.environ.setdefault("KMP_DUPLICATE_LIB_OK", "TRUE")
os.environ.setdefault("OMP_NUM_THREADS", "1")
logging.basicConfig(level=logging.WARNING)
from app.config import cfg
from app.state import state, _build_lookup_tables, run_rag_pipeline
from app.llm import get_llm_provider
from sentence_transformers import SentenceTransformer
import faiss
async def init_qmodel():
print("⏳ Loading QModel Islamic RAG System...")
print(f" • Loading metadata: {cfg.METADATA_FILE}")
with open(cfg.METADATA_FILE, "r", encoding="utf-8") as f:
state.dataset = json.load(f)
print(" • Building BM25 & scripture lookup tables...")
_build_lookup_tables(state.dataset)
print(f" • Loading dense embeddings ({cfg.EMBED_MODEL})...")
state.embed_model = SentenceTransformer(cfg.EMBED_MODEL)
print(f" • Loading FAISS vector index ({cfg.FAISS_INDEX})...")
state.faiss_index = faiss.read_index(cfg.FAISS_INDEX)
print(f" • Connecting to LLM backend ({cfg.LLM_BACKEND})...")
state.llm = get_llm_provider()
state.ready = True
print("✅ QModel is ready!\n" + "=" * 60)
async def main():
await init_qmodel()
print("🕌 Sheikh QModel — Islamic Knowledge Assistant (Quran, Tafsir, Hadith, Fatwa)")
print("Type your question below (or 'exit' / 'quit' to exit):\n")
while True:
try:
query = input("Q: ").strip()
except (EOFError, KeyboardInterrupt):
print("\nوداعاً — مع السلامة.")
break
if not query:
continue
if query.lower() in ("exit", "quit", "q"):
print("مع السلامة.")
break
print("\n⏳ جاري البحث في الفهرس والتحقق من النصوص...")
try:
res = await run_rag_pipeline(query)
print("\n" + res["answer"] + "\n")
print("-" * 60)
except Exception as exc:
print(f"❌ حدث خطأ: {exc}\n")
if __name__ == "__main__":
try:
asyncio.run(main())
except KeyboardInterrupt:
pass
|