Upgraded to Groq RAG Engine with Secure Env Vars

ai_brain.py

@@ -0,0 +1,34 @@
+import os
+from sentence_transformers import SentenceTransformer
+from supabase import create_client, Client
+
+# 1. Put your real URL and Key inside the quotation marks below!
+SUPABASE_URL = "https://hnrexbxxhdjksyllcmgg.supabase.co"
+SUPABASE_KEY = "sb_publishable_t69puYMhsUaZ7GlYTXu6gQ_dg4pCHg5"
+
+supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
+
+def test_ai_database():
+    print("Downloading AI tool (this takes a few seconds)...")
+    model = SentenceTransformer("sentence-transformers/all-MiniLM-L6-v2")
+    
+    print("Converting text into numbers...")
+    # This turns English text into numbers so the database can search it later
+    embedding_numbers = model.encode("Farmers get 6000 rupees a year").tolist()
+    
+    print("Saving to Supabase...")
+    data = {
+        "scheme_title": "Farmer Test Scheme",
+        "chunk_text": "Farmers get 6000 rupees a year",
+        "embedding": embedding_numbers,
+        "source_url": "test.com"
+    }
+    
+    try:
+        supabase.table("document_chunks").insert(data).execute()
+        print("✅ SUCCESS! The data is saved in your database!")
+    except Exception as e:
+        print(f"❌ Error: {e}")
+
+if __name__ == "__main__":
+    test_ai_database()

api.py

@@ -0,0 +1,80 @@
+import os
+from fastapi import FastAPI
+from fastapi.responses import StreamingResponse
+from pydantic import BaseModel
+from sentence_transformers import SentenceTransformer
+from supabase import create_client, Client
+from groq import Groq
+from fastapi.middleware.cors import CORSMiddleware
+
+# --- 1. YOUR SECRET KEYS (SECURED) ---
+SUPABASE_URL = os.environ.get("SUPABASE_URL")
+SUPABASE_KEY = os.environ.get("SUPABASE_KEY")
+GROQ_API_KEY = os.environ.get("GROQ_API_KEY")
+
+# --- 2. INITIALIZE CLIENTS ---
+supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
+groq_client = Groq(api_key=GROQ_API_KEY)
+
+app = FastAPI()
+model = SentenceTransformer("sentence-transformers/all-MiniLM-L6-v2")
+
+# Allow React to talk to this API
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+class SearchQuery(BaseModel):
+    question: str
+
+# --- 3. THE TRUE RAG ENGINE ---
+# Notice we changed the URL path to match Claude's blueprint!
+@app.post("/api/rag/query")
+async def rag_query(query: SearchQuery):
+    print(f"Citizen asked: {query.question}")
+    
+    # STEP A: RETRIEVAL (Find the math matches)
+    query_numbers = model.encode(query.question).tolist()
+    result = supabase.rpc("match_documents", {
+        "query_embedding": query_numbers,
+        "match_count": 5
+    }).execute()
+    
+    chunks = result.data
+    
+    # STEP B: CONTEXT ASSEMBLY (Package the data for the AI to read)
+    if not chunks:
+        context = "No relevant schemes found in the database."
+    else:
+        context = "\n\n---\n\n".join([
+            f"[Document: {c.get('scheme_title', 'Unknown')}]\n{c.get('chunk_text', '')}"
+            for c in chunks
+        ])
+
+    # STEP C: GENERATION (Ask Llama-3 to write a beautiful answer)
+    def stream_answer():
+        response = groq_client.chat.completions.create(
+            model="llama-3.3-70b-versatile",
+            messages=[
+                {"role": "system", "content": 
+                 "You are GovBridge AI, a helpful assistant for Indian citizens. "
+                 "Answer the user's question using ONLY the provided context. "
+                 "Always cite the official scheme names. If the context does not "
+                 "contain the answer, clearly say 'This information is not available in our database.'"},
+                {"role": "user", "content": f"Context:\n{context}\n\nQuestion: {query.question}"}
+            ],
+            temperature=0.1, # Low temperature means it stays highly factual!
+            max_tokens=1024,
+            stream=True
+        )
+        for chunk in response:
+            delta = chunk.choices[0].delta.content or ""
+            if delta:
+                yield delta
+
+    # Stream the text back to the website exactly like ChatGPT does!
+    return StreamingResponse(stream_answer(), media_type="text/plain")

ask_brain.py

@@ -0,0 +1,45 @@
+import os
+from sentence_transformers import SentenceTransformer
+from supabase import create_client, Client
+
+# 1. Put your real URL and Key inside the quotation marks below!
+SUPABASE_URL = "https://hnrexbxxhdjksyllcmgg.supabase.co"
+SUPABASE_KEY = "sb_publishable_t69puYMhsUaZ7GlYTXu6gQ_dg4pCHg5"
+
+supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
+
+def ask_question():
+    print("Waking up the AI...")
+    model = SentenceTransformer("sentence-transformers/all-MiniLM-L6-v2")
+    
+    # We are asking about a "kisan" (which we didn't save in the database)
+    user_question = "How can a kisan get financial help?"
+    print(f"\nQuestion: '{user_question}'")
+    
+    print("Converting question into numbers...")
+    query_numbers = model.encode(user_question).tolist()
+    
+    print("Searching Supabase...")
+    try:
+        # Ask Supabase to run the 'match_documents' SQL function
+        response = supabase.rpc("match_documents", {
+            "query_embedding": query_numbers,
+            "match_count": 1
+        }).execute()
+        
+        matches = response.data
+        
+        if matches:
+            best_match = matches[0]
+            print("\n✨ --- AI FOUND A MATCH! --- ✨")
+            print(f"Scheme: {best_match['scheme_title']}")
+            print(f"Details: {best_match['chunk_text']}")
+            print(f"Accuracy Score: {best_match['similarity']:.2f}")
+        else:
+            print("\n❌ No documents found.")
+            
+    except Exception as e:
+        print(f"❌ Error: {e}")
+
+if __name__ == "__main__":
+    ask_question()

render.yaml

@@ -0,0 +1,6 @@
+services:
+  - type: web
+    name: govbridge-api
+    runtime: python
+    buildCommand: pip install -r requirements.txt
+    startCommand: uvicorn api:app --host 0.0.0.0 --port $PORT

requirements.txt

@@ -0,0 +1,6 @@
+fastapi
+uvicorn
+pydantic
+sentence-transformers
+supabase
+groq