add final code

app.py

@@ -0,0 +1,73 @@
+import streamlit as st
+import asyncio
+import os
+from money_rag import MoneyRAG
+
+st.set_page_config(page_title="MoneyRAG", layout="wide")
+
+# Sidebar for Authentication
+with st.sidebar:
+    st.header("Authentication")
+    provider = st.selectbox("LLM Provider", ["Google", "OpenAI"])
+    
+    if provider == "Google":
+        models = ["gemini-3-flash-preview", "gemini-3-pro-image-preview", "gemini-2.5-pro", "gemini-2.5-flash", "gemini-2.5-flash-lite"]
+        embeddings = ["text-embedding-004"]
+    else:
+        models = ["gpt-5-mini", "gpt-5-nano", "gpt-4o-mini", "gpt-4o"]
+        embeddings = ["text-embedding-3-small", "text-embedding-3-large", "text-embedding-ada-002"]
+        
+    model_name = st.selectbox("Choose Decoder Model", models)
+    embed_name = st.selectbox("Choose Embedding Model", embeddings)
+    api_key = st.text_input("API Key", type="password")
+    
+    auth_button = st.button("Authenticate")
+    if auth_button and api_key:
+        st.session_state.rag = MoneyRAG(provider, model_name, embed_name, api_key)
+        st.success("Authenticated!")
+
+# Main Window
+st.title("MoneyRAG 💰")
+st.subheader("Where is my money?")
+st.markdown("""
+This app helps you analyze your personal finances using AI. 
+Upload your bank/credit card CSV statements to chat with your data semantically.
+""")
+
+if "rag" in st.session_state:
+    uploaded_files = st.file_uploader("Upload CSV transactions", accept_multiple_files=True, type=['csv'])
+    
+    if uploaded_files:
+        if st.button("Ingest Data"):
+            temp_paths = []
+            for uploaded_file in uploaded_files:
+                path = os.path.join(st.session_state.rag.temp_dir, uploaded_file.name)
+                with open(path, "wb") as f:
+                    f.write(uploaded_file.getbuffer())
+                temp_paths.append(path)
+            
+            with st.spinner("Ingesting and vectorizing..."):
+                asyncio.run(st.session_state.rag.setup_session(temp_paths))
+            st.success("Data ready for chat!")
+
+    # Chat Interface
+    st.divider()
+    if "messages" not in st.session_state:
+        st.session_state.messages = []
+
+    for message in st.session_state.messages:
+        with st.chat_message(message["role"]):
+            st.markdown(message["content"])
+
+    if prompt := st.chat_input("Ask about your spending..."):
+        st.session_state.messages.append({"role": "user", "content": prompt})
+        with st.chat_message("user"):
+            st.markdown(prompt)
+
+        with st.chat_message("assistant"):
+            with st.spinner("Thinking..."):
+                response = asyncio.run(st.session_state.rag.chat(prompt))
+                st.markdown(response)
+        st.session_state.messages.append({"role": "assistant", "content": response})
+else:
+    st.info("Please authenticate in the sidebar to start.")

mcp_server.py

@@ -1,7 +1,7 @@
 from fastmcp import FastMCP
 from langchain_qdrant import QdrantVectorStore
 from qdrant_client import QdrantClient
-from langchain_google_vertexai import VertexAIEmbeddings
+from langchain_google_genai import GoogleGenerativeAIEmbeddings
 from dotenv import load_dotenv
 import os
 
@@ -60,7 +60,6 @@ def get_database_schema() -> str:
     """Complete schema information for the money_rag database."""
     return get_schema_info()
 
-
 @mcp.tool()
 def query_database(query: str) -> str:
     """Execute a SELECT query on the money_rag SQLite database.
@@ -122,9 +121,8 @@ def query_database(query: str) -> str:
 
 def get_vector_store():
     """Initialize connection to the Qdrant vector store"""
-    # Initialize Embedding Model
-    # Uses environment variables/default gcloud auth
-    embeddings = VertexAIEmbeddings(model_name="text-embedding-005")
+    # Initialize Embedding Model using Google AI Studio
+    embeddings = GoogleGenerativeAIEmbeddings(model="text-embedding-004")
 
     # Connect to Qdrant (Persistent Disk Mode at specific path)
     # We ensure the directory exists so Qdrant can write to it.
@@ -196,4 +194,4 @@ def clear_database() -> str:
 
 if __name__ == "__main__":
     # Runs the server over stdio
-    mcp.run()
+    mcp.run(transport="stdio")

money_rag.py

@@ -0,0 +1,255 @@
+import os
+import uuid
+import asyncio
+import pandas as pd
+import sqlite3
+import shutil
+import tempfile
+from typing import List, Optional
+from dataclasses import dataclass
+
+from langchain.chat_models import init_chat_model
+from langchain_core.prompts import ChatPromptTemplate
+from langchain_core.output_parsers import JsonOutputParser
+from langchain_core.tools import tool
+from langchain_community.utilities import SQLDatabase
+from langchain_qdrant import QdrantVectorStore
+from qdrant_client import QdrantClient
+from qdrant_client.http.models import Distance, VectorParams
+from langgraph.runtime import get_runtime
+from langgraph.checkpoint.memory import InMemorySaver
+from langchain.agents import create_agent
+from langchain_community.tools import DuckDuckGoSearchRun
+from langchain_mcp_adapters.client import MultiServerMCPClient  
+
+# Import specific embeddings
+from langchain_google_genai import GoogleGenerativeAIEmbeddings
+from langchain_openai import OpenAIEmbeddings
+
+class MoneyRAG:
+    def __init__(self, llm_provider: str, model_name: str, embedding_model_name: str, api_key: str):
+        self.llm_provider = llm_provider.lower()
+        self.model_name = model_name
+        self.embedding_model_name = embedding_model_name
+        
+        # Set API Keys
+        if self.llm_provider == "google":
+            os.environ["GOOGLE_API_KEY"] = api_key
+            self.embeddings = GoogleGenerativeAIEmbeddings(model=embedding_model_name)
+            provider_name = "google_genai"
+        else:
+            os.environ["OPENAI_API_KEY"] = api_key
+            self.embeddings = OpenAIEmbeddings(model=embedding_model_name)
+            provider_name = "openai"
+
+        # Initialize LLM
+        self.llm = init_chat_model(
+            self.model_name,
+            model_provider=provider_name,
+        )
+
+        # Temporary paths for this session
+        self.temp_dir = tempfile.mkdtemp()
+        os.environ["DATA_DIR"] = self.temp_dir # Harmonize with mcp_server.py 
+        self.db_path = os.path.join(self.temp_dir, "money_rag.db")
+        self.qdrant_path = os.path.join(self.temp_dir, "qdrant_db")
+        
+        self.db: Optional[SQLDatabase] = None
+        self.vector_store: Optional[QdrantVectorStore] = None
+        self.agent = None
+        self.mcp_client: Optional[MultiServerMCPClient] = None
+        self.search_tool = DuckDuckGoSearchRun()
+        self.merchant_cache = {}  # Session-based cache for merchant enrichment
+
+    async def setup_session(self, csv_paths: List[str]):
+        """Ingests CSVs and sets up DBs."""
+        for path in csv_paths:
+            await self._ingest_csv(path)
+        
+        self.db = SQLDatabase.from_uri(f"sqlite:///{self.db_path}")
+        self.vector_store = self._sync_to_qdrant()
+        await self._init_agent()
+
+    async def _ingest_csv(self, file_path):
+        df = pd.read_csv(file_path)
+        headers = df.columns.tolist()
+        sample_data = df.head(10).to_json()
+
+        prompt = ChatPromptTemplate.from_template("""
+        Act as a financial data parser. Analyze this CSV data:
+        Filename: {filename}
+        Headers: {headers}
+        Sample Data: {sample}
+
+        TASK:
+        1. Map the CSV columns to standard fields: date, description, amount, and category.
+        2. Determine the 'sign_convention' for spending.
+        
+        RULES:
+        - If the filename suggests 'Discover' credit card, spending are usually POSITIVE.
+        - If the filename suggests 'Chase' credit card, spending are usually NEGATIVE.
+                                                
+        - Analyze the 'sign_convention' for spending (outflows):
+            - Look at the sample data for known merchants or spending patterns.
+            - If spending (like a restaurant or store) is NEGATIVE (e.g., -25.00), the convention is 'spending_is_negative'.
+            - If spending is POSITIVE (e.g., 25.00), the convention is 'spending_is_positive'.
+
+        OUTPUT FORMAT (JSON ONLY):
+        {{
+        "date_col": "column_name",
+        "desc_col": "column_name",
+        "amount_col": "column_name",
+        "category_col": "column_name or null",
+        "sign_convention": "spending_is_negative" | "spending_is_positive"
+        }}
+        """)
+        
+        chain = prompt | self.llm | JsonOutputParser()
+        mapping = await chain.ainvoke({"headers": headers, "sample": sample_data, "filename": os.path.basename(file_path)})
+
+        standard_df = pd.DataFrame()
+        standard_df['id'] = [str(uuid.uuid4()) for _ in range(len(df))]
+        standard_df['transaction_date'] = pd.to_datetime(df[mapping['date_col']])
+        standard_df['description'] = df[mapping['desc_col']]
+        
+        raw_amounts = pd.to_numeric(df[mapping['amount_col']])
+        standard_df['amount'] = raw_amounts * -1 if mapping['sign_convention'] == "spending_is_negative" else raw_amounts
+        standard_df['category'] = df[mapping.get('category_col')] if mapping.get('category_col') else 'Uncategorized'
+        standard_df['source_file'] = os.path.basename(file_path)
+
+        # --- Async Enrichment Step ---
+        print(f"   ✨ Enriching descriptions for {os.path.basename(file_path)}...")
+        unique_descriptions = standard_df['description'].unique()
+        sem = asyncio.Semaphore(5)
+
+        async def get_merchant_info(description):
+            if description in self.merchant_cache:
+                return self.merchant_cache[description]
+            
+            async with sem:
+                try:
+                    await asyncio.sleep(0.05) # Jitter
+                    print(f"      🔍 Web searching: {description}...")
+                    result = await self.search_tool.ainvoke(f"What type of business / store is '{description}'?")
+                    self.merchant_cache[description] = result
+                    return result
+                except Exception as e:
+                    print(f"      ⚠️ Search failed for {description}: {e}")
+                    return "Unknown"
+
+        tasks = [get_merchant_info(desc) for desc in unique_descriptions]
+        enrichment_results = await asyncio.gather(*tasks)
+        
+        desc_map = dict(zip(unique_descriptions, enrichment_results))
+        standard_df['enriched_info'] = standard_df['description'].map(desc_map).fillna("")
+
+        conn = sqlite3.connect(self.db_path)
+        standard_df.to_sql("transactions", conn, if_exists="append", index=False)
+        conn.close()
+
+    def _sync_to_qdrant(self):
+        client = QdrantClient(path=self.qdrant_path)
+        collection = "transactions"
+        
+        conn = sqlite3.connect(self.db_path)
+        df = pd.read_sql_query("SELECT * FROM transactions", conn)
+        conn.close()
+        
+        # Check for empty dataframe
+        if df.empty:
+            raise ValueError("No transactions found in database. Please ingest CSV files first.")
+        
+        # Dynamically detect embedding dimension
+        sample_embedding = self.embeddings.embed_query("test")
+        embedding_dim = len(sample_embedding)
+
+        client.recreate_collection(
+            collection_name=collection,
+            vectors_config=VectorParams(size=embedding_dim, distance=Distance.COSINE),
+        )
+        
+        vs = QdrantVectorStore(client=client, collection_name=collection, embedding=self.embeddings)
+        
+        # Use description + category + enrichment for vectorization
+        texts = []
+        for _, row in df.iterrows():
+            enriched = row.get('enriched_info', '')
+            base_text = f"{row['description']} ({row['category']})"
+            if enriched and enriched != "Unknown" and enriched != "":
+                texts.append(f"{base_text} - {enriched}")
+            else:
+                texts.append(base_text)
+        
+        metadatas = df[['id', 'amount', 'category', 'transaction_date']].to_dict('records')
+        for m in metadatas: m['transaction_date'] = str(m['transaction_date'])
+        
+        vs.add_texts(texts=texts, metadatas=metadatas)
+        return vs
+
+    async def _init_agent(self):
+        # 1. Initialize MCP client with absolute path to server
+        server_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), "mcp_server.py")
+        
+        self.mcp_client = MultiServerMCPClient(
+            {
+                "money_rag": {
+                    "transport": "stdio",
+                    "command": "python",
+                    "args": [server_path],
+                    "env": os.environ.copy(),
+                }
+            }
+        )
+
+        # 2. Get tools from MCP server
+        mcp_tools = await self.mcp_client.get_tools()
+
+        # 3. Define the Agent with MCP Tools
+        system_prompt = (
+            "You are a financial analyst. Use the provided tools to query the database "
+            "and perform semantic searches. Spending is POSITIVE (>0). "
+            "Always explain your findings clearly."
+        )
+        
+        self.agent = create_agent(
+            model=self.llm,
+            tools=mcp_tools,
+            system_prompt=system_prompt,
+            checkpointer=InMemorySaver(),
+        )
+
+    async def chat(self, query: str):
+        config = {"configurable": {"thread_id": "session_1"}}
+        
+        result = await self.agent.ainvoke(
+            {"messages": [{"role": "user", "content": query}]},
+            config,
+        )
+        
+        # Extract content - handle both string and list formats
+        content = result["messages"][-1].content
+        
+        # If content is a list (Gemini format), extract text from blocks
+        if isinstance(content, list):
+            text_parts = []
+            for block in content:
+                if isinstance(block, dict) and block.get("type") == "text":
+                    text_parts.append(block.get("text", ""))
+            return "\n".join(text_parts)
+        
+        # If content is already a string (OpenAI format), return as-is
+        return content
+
+    async def cleanup(self):
+        """Delete temporary session files and close MCP client."""
+        if self.mcp_client:
+            try:
+                await self.mcp_client.close()
+            except Exception as e:
+                print(f"Warning: Failed to close MCP client: {e}")
+        
+        if os.path.exists(self.temp_dir):
+            try:
+                shutil.rmtree(self.temp_dir)
+            except Exception as e:
+                print(f"Warning: Failed to remove temp directory: {e}")

notebooks/1_test_pdf_reader.ipynb

@@ -211,9 +211,150 @@
      "text": [
       "📂 Processing /Users/sawale/Documents/learning/money_rag/demo_data/Discover-AllAvailable-20260110.csv...\n",
       "   ✨ Enriching descriptions (Async)...\n",
+      "   🔍 Web searching for: BACK MARKET BROOKLYN NY...\n",
+      "   🔍 Web searching for: TEMU.COM 8884958368 DE...\n",
+      "   🔍 Web searching for: WALMART STORE 00332 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: $100 STATEMENT CREDIT W 1ST PU...\n",
+      "   🔍 Web searching for: PY *KUNG-FU TEA AL HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: MADISON MONTGOMERY AL...\n",
+      "   🔍 Web searching for: INTERNET PAYMENT - THANK YOU...\n",
+      "   🔍 Web searching for: GRUBHUB - UNIVERSITY OF HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: MINT MOBILE 800-683-7392 CA...\n",
+      "   🔍 Web searching for: POPEYES 2577 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: 88 BUFFET HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: VIET HUONG VIETNAMESE RE HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: CASHBACK BONUS REDEMPTION PYMT/STMT CRDT...\n",
+      "   🔍 Web searching for: SPO*THECURRYMODERNINDIAN HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: H&M 0273HUNTSVILLE HUNTSVILLE ALUS0273001241222182740...\n",
+      "   🔍 Web searching for: INDIAN BAZAAR HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: HANDELS HOMEMADE HUNTSVI HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: UAH COLLEGE 256-824-6170 AL...\n",
+      "   🔍 Web searching for: UAH COLLEGE FSF 800-346-9252 MA...\n",
+      "   🔍 Web searching for: CHIPOTLE 1687 NASHVILLE TN...\n",
+      "   🔍 Web searching for: TST*PIE TOWN TACOS - F NASHVILLE TN00153526022200965677AA...\n",
+      "   🔍 Web searching for: INDIAN BAZAAR HUNTSVILLE ALGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: INDIA MART HUNTSVILLE ALGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: PAYPAL *KEVDUDE1186 KEV 888-221-1161 CA...\n",
+      "   🔍 Web searching for: LYFT *RIDE WED 10AM 8552800278 CA...\n",
+      "   🔍 Web searching for: SKECHERS USA INC 1069 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: STORE HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: LYFT *RIDE WED 3PM 8552800278 CA...\n",
+      "   🔍 Web searching for: SQ *TAQUERIA LAS ADELI HUNTSVILLE AL0002305843021411201895...\n",
+      "   🔍 Web searching for: UAH HUNTSVILLE DUNKIN HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: WALMART.COM 800-925-6278 AR...\n",
+      "   🔍 Web searching for: WALMART.COM 8009256278 BENTONVILLE AR...\n",
+      "   🔍 Web searching for: TOUS LES JOURS - HUNTSVI HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: MARSHALLS #422 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: ROSS STORE #2436 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: SPRINTAX NR TAX 8882038900 NY...\n",
+      "   🔍 Web searching for: USPS PO 0142460804 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: CHIPOTLE 1796 HUNTSVILLE ALGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: TST*POURHOUSE HUNTSVILLE AL00031984024314246667AA...\n",
+      "   🔍 Web searching for: TST*WOKS UP HUNTSVILLE AL00075396024313993332AA...\n",
+      "   🔍 Web searching for: SPIRIT AIRLINES 8014012222 FL...\n",
+      "   🔍 Web searching for: CHIPOTLE 1796 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: UAH BURSARS OFFICE HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: STARS AND STRIKES - HUNT HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: ROSS STORES #620 HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: TST*KAMADO RAMEN - MID HUNTSVILLE AL00006963025030352515AA...\n",
+      "   🔍 Web searching for: SQ *MOM'SCLAYCO HARVEST AL0002305843022068424398...\n",
+      "   🔍 Web searching for: DOLLARTREE HUNTSVILLE AL...\n",
+      "   🔍 Web searching for: SLIM & HUSKIES NASHVILLE TN...\n",
+      "   🔍 Web searching for: CHIPOTLE 1392 SANTA MONICA CA...\n",
+      "   🔍 Web searching for: DOLLAR TREE LAS VEGAS NV...\n",
+      "   🔍 Web searching for: LYFT *RIDE TUE 12AM 8552800278 CA...\n",
+      "   🔍 Web searching for: SQ *SHIKU GCM LOS ANGELES CA0001152921515467218869...\n",
+      "   🔍 Web searching for: SQ *SHIKU GCM LOS ANGELES CA0001152921515467211997...\n",
+      "   🔍 Web searching for: WALMART STORE 05686 BURBANK CA...\n",
+      "   🔍 Web searching for: CAFE BELLA NEWPORT SAN DIEGO CAGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: CHIPOTLE 2883 NORTH LAS VEGNVGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: SHELL10006319007 HESPERIA CAGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: PANDA EXPRESS #1964 LAS VEGAS NV...\n",
+      "   🔍 Web searching for: DENNY'S #0141 QR LAS VEGAS NVGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: LAS VEGAS SOUVENIRS AND LAS VEGAS NV...\n",
+      "   🔍 Web searching for: CTLP*FIRST CLASS VENDI BELLGARDENS CA...\n",
+      "   🔍 Web searching for: SHELL12874333011 FRANKLIN TN...\n",
+      "   🔍 Web searching for: AMARAVATI INDIAN CUISINE BRENTWOOD TNGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: CENTRAL MARKET NASHVILLE TN...\n",
+      "   🔍 Web searching for: TST*PRINCES HOT CHICKE NASHVILLE TN00104605025320544723AA...\n",
+      "   🔍 Web searching for: TST*PRINCES HOT CHICKE NASHVILLE TN00104605025321087148AA...\n",
+      "   🔍 Web searching for: WALMART STORE 05616 NASHVILLE TN...\n",
+      "   🔍 Web searching for: PY *KUNG-FU TEA AL HUNTSVILLE ALGOOGLE PAY ENDING IN 8984...\n",
+      "   🔍 Web searching for: 2LEVY R&C CHATTANOOGA TNGOOGLE PAY ENDING IN 8984...\n",
       "✅ Ingested 124 rows from Discover-AllAvailable-20260110.csv. Logic: spending_is_positive\n",
       "📂 Processing /Users/sawale/Documents/learning/money_rag/demo_data/Chase5282_Activity20240110_20260110_20260111.CSV...\n",
       "   ✨ Enriching descriptions (Async)...\n",
+      "   🔍 Web searching for: TOUS LES JOURS - HUNTSVIL...\n",
+      "   🔍 Web searching for: Payment Thank You-Mobile...\n",
+      "   🔍 Web searching for: INDIAN BAZAAR...\n",
+      "   🔍 Web searching for: TST*BLUE OAK BBQ-HUNTSVI...\n",
+      "   🔍 Web searching for: AMC 4112 VAL BEND 18...\n",
+      "   🔍 Web searching for: HANDELS HOMEMADE JONES V...\n",
+      "   🔍 Web searching for: PAYYOURSELFBACK CREDIT...\n",
+      "   🔍 Web searching for: TST* HYDERABAD HOUSE...\n",
+      "   🔍 Web searching for: PATEL BROTHERS NASHVILLE...\n",
+      "   🔍 Web searching for: CITY OF HUNTSVILLE...\n",
+      "   🔍 Web searching for: WM SUPERCENTER #332...\n",
+      "   🔍 Web searching for: WAL-MART #0332...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*OS1RI3LN3...\n",
+      "   🔍 Web searching for: TST* HATTIE B'S HUNTSVILL...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BI23Z6JR0...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BI9IW9OS2...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BI0296OJ2...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BB71A2881...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BB3FU2UQ2...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BI03P1OX2...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BB92U9QK2...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BB9TA14Q0...\n",
+      "   🔍 Web searching for: 88 BUFFET...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*BB0DC71B1...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*B20NN4ID0...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*B273C1WY2...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*B27IN41E1...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*B250Z60P1...\n",
+      "   🔍 Web searching for: BEST BUY      00005140...\n",
+      "   🔍 Web searching for: DAVES HOT CHICKEN 1282...\n",
+      "   🔍 Web searching for: SQ *VIETCUISINE LLC...\n",
+      "   🔍 Web searching for: CHICK-FIL-A #00579...\n",
+      "   🔍 Web searching for: COSTCO WHSE #0356...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*NK4AM43Q2...\n",
+      "   🔍 Web searching for: HUNTSVILLE FLV...\n",
+      "   🔍 Web searching for: AMAZON MKTPL*NM1H055K0...\n",
+      "   🔍 Web searching for: MAPCO EXPRESS #3403...\n",
+      "   🔍 Web searching for: DUNKIN #346212 Q35...\n",
+      "   🔍 Web searching for: CENTRAL MARKET...\n",
+      "   🔍 Web searching for: TARA INTERNATIONAL MARKET...\n",
+      "   🔍 Web searching for: BOTAN MARKET INC...\n",
+      "   🔍 Web searching for: AMARAVATI INDIAN CUISINE...\n",
+      "   🔍 Web searching for: GRUBHUB - UNIVERSITY OF A...\n",
+      "   🔍 Web searching for: BURGER KING #4959...\n",
+      "   🔍 Web searching for: PANDA EXPRESS #3013...\n",
+      "   🔍 Web searching for: MCDONALD'S F2431...\n",
+      "   🔍 Web searching for: ENDZONE COLLECTIBLES...\n",
+      "   🔍 Web searching for: ZIMMAD EVE* ZIMMAD JOI...\n",
+      "   🔍 Web searching for: SQ *SPILL COFFEE AND CREA...\n",
+      "   🔍 Web searching for: 10267 CAVA WHITESBURG...\n",
+      "   🔍 Web searching for: SPO*DRAGONSFORGECAFE...\n",
+      "   🔍 Web searching for: UAH BURSARS OFFICE...\n",
+      "   🔍 Web searching for: MARATHON PETRO42804...\n",
+      "   🔍 Web searching for: TST*NOTHING BUT NOODLES...\n",
+      "   🔍 Web searching for: VEDA INDIAN CUISINE...\n",
+      "   🔍 Web searching for: DOLLARTREE...\n",
+      "   🔍 Web searching for: TARGET        00013466...\n",
+      "   🔍 Web searching for: POPEYES 2577...\n",
+      "   🔍 Web searching for: DEORALI GROCERY...\n",
+      "   🔍 Web searching for: HELLO ATLANTA #33...\n",
+      "   🔍 Web searching for: SKY VIEW ATLANTA...\n",
+      "   🔍 Web searching for: STARBUCKS 25111...\n",
+      "   🔍 Web searching for: BP#8998205AM/PM WADE GRE...\n",
+      "   🔍 Web searching for: Waffle House 0857...\n",
+      "   🔍 Web searching for: CINEMARK 1131 BOXCON...\n",
+      "   🔍 Web searching for: CINEMARK 1131 RSTBAR...\n",
+      "   🔍 Web searching for: HOMEGOODS # 0568...\n",
+      "   🔍 Web searching for: ASIAN MARKET...\n",
+      "   🔍 Web searching for: PANDA EXPRESS #2005...\n",
+      "   🔍 Web searching for: STARS AND STRIKES - HUNTS...\n",
+      "   🔍 Web searching for: WAL-MART #332...\n",
       "✅ Ingested 126 rows from Chase5282_Activity20240110_20260110_20260111.CSV. Logic: spending_is_negative\n"
      ]
     }
@@ -275,7 +416,7 @@
        "  <tbody>\n",
        "    <tr>\n",
        "      <th>0</th>\n",
-       "      <td>5712be16-98a8-41d7-94de-15ecff7793da</td>\n",
+       "      <td>cf2f48c5-34ab-4544-b1f4-542681fd5017</td>\n",
        "      <td>2024-10-17 00:00:00</td>\n",
        "      <td>BACK MARKET BROOKLYN NY</td>\n",
        "      <td>231.19</td>\n",
@@ -285,7 +426,7 @@
        "    </tr>\n",
        "    <tr>\n",
        "      <th>1</th>\n",
-       "      <td>cea08bf8-440c-4d05-b06c-5c0d2e3b2997</td>\n",
+       "      <td>16913dce-52bf-43f4-853d-7bb55e09aac5</td>\n",
        "      <td>2024-10-18 00:00:00</td>\n",
        "      <td>TEMU.COM 8884958368 DE</td>\n",
        "      <td>16.51</td>\n",
@@ -295,27 +436,27 @@
        "    </tr>\n",
        "    <tr>\n",
        "      <th>2</th>\n",
-       "      <td>b021b290-36fc-4667-993c-6f620da3a54a</td>\n",
+       "      <td>5917cb10-f0e6-49fa-9987-776cee28688c</td>\n",
        "      <td>2024-10-18 00:00:00</td>\n",
        "      <td>WALMART STORE 00332 HUNTSVILLE AL</td>\n",
        "      <td>146.73</td>\n",
        "      <td>Merchandise</td>\n",
        "      <td>Discover-AllAvailable-20260110.csv</td>\n",
-       "      <td>Walmart Inc. is an American multinational reta...</td>\n",
+       "      <td>Posts Walmart Huntsville - University Drive De...</td>\n",
        "    </tr>\n",
        "    <tr>\n",
        "      <th>3</th>\n",
-       "      <td>d260bc87-ca63-4238-ad9e-3482273c49fb</td>\n",
+       "      <td>bd66a49e-5064-43ca-bdb2-94947297b6d5</td>\n",
        "      <td>2024-10-18 00:00:00</td>\n",
        "      <td>$100 STATEMENT CREDIT W 1ST PU</td>\n",
        "      <td>-100.00</td>\n",
        "      <td>Awards and Rebate Credits</td>\n",
        "      <td>Discover-AllAvailable-20260110.csv</td>\n",
-       "      <td>All U.S. Bank credit cards offer contactless c...</td>\n",
+       "      <td>That said, I woke up yesterday and saw a $ 100...</td>\n",
        "    </tr>\n",
        "    <tr>\n",
        "      <th>4</th>\n",
-       "      <td>2c06fe8e-8ef2-49f1-bed6-dd282effec85</td>\n",
+       "      <td>8b9b16d4-dd81-4ebe-820f-62fdc827a0bb</td>\n",
        "      <td>2024-11-02 00:00:00</td>\n",
        "      <td>PY *KUNG-FU TEA AL HUNTSVILLE AL</td>\n",
        "      <td>8.09</td>\n",
@@ -335,27 +476,27 @@
        "    </tr>\n",
        "    <tr>\n",
        "      <th>245</th>\n",
-       "      <td>6a6167f7-dc54-480f-8a15-0561c7b877da</td>\n",
+       "      <td>239f983e-2ed8-4454-90ad-0e8477bf7893</td>\n",
        "      <td>2025-06-18 00:00:00</td>\n",
        "      <td>PANDA EXPRESS #2005</td>\n",
        "      <td>52.87</td>\n",
        "      <td>Food &amp; Drink</td>\n",
        "      <td>Chase5282_Activity20240110_20260110_20260111.CSV</td>\n",
-       "      <td>This is a list of notable current and former f...</td>\n",
+       "      <td>Aug 29, 2025 · The group's headquarters is loc...</td>\n",
        "    </tr>\n",
        "    <tr>\n",
        "      <th>246</th>\n",
-       "      <td>2a01f41e-8f1e-4a10-9e7f-3ac29795607b</td>\n",
+       "      <td>0ecba974-5491-4ef2-ba52-bf3c37d6e854</td>\n",
        "      <td>2025-06-14 00:00:00</td>\n",
        "      <td>Payment Thank You-Mobile</td>\n",
        "      <td>-62.07</td>\n",
        "      <td>None</td>\n",
        "      <td>Chase5282_Activity20240110_20260110_20260111.CSV</td>\n",
-       "      <td>Locate a mobile phone | GSM locator of mobile ...</td>\n",
+       "      <td>Sep 25, 2025 · Thank You Mobile is not a compa...</td>\n",
        "    </tr>\n",
        "    <tr>\n",
        "      <th>247</th>\n",
-       "      <td>f7648015-85a6-4412-87d5-1499ac29fce6</td>\n",
+       "      <td>fb966472-d77a-4723-a9e6-15e63bda4cd2</td>\n",
        "      <td>2025-06-12 00:00:00</td>\n",
        "      <td>STARS AND STRIKES - HUNTS</td>\n",
        "      <td>21.80</td>\n",
@@ -365,23 +506,23 @@
        "    </tr>\n",
        "    <tr>\n",
        "      <th>248</th>\n",
-       "      <td>2edd49e5-9f4f-46d4-b94f-f9d7661bcdab</td>\n",
+       "      <td>b6bc2e1d-d68b-4acd-a201-46d8cf5175e5</td>\n",
        "      <td>2025-06-11 00:00:00</td>\n",
        "      <td>WAL-MART #332</td>\n",
        "      <td>4.47</td>\n",
        "      <td>Groceries</td>\n",
        "      <td>Chase5282_Activity20240110_20260110_20260111.CSV</td>\n",
-       "      <td>From toys and video games to fashionable cloth...</td>\n",
+       "      <td>3 days ago · Walmart Inc. is an American multi...</td>\n",
        "    </tr>\n",
        "    <tr>\n",
        "      <th>249</th>\n",
-       "      <td>1d2ecebf-4994-4cdd-8d09-b6751655cd3f</td>\n",
+       "      <td>e896adcc-5445-4626-b14c-09ebd5c9f658</td>\n",
        "      <td>2025-06-11 00:00:00</td>\n",
        "      <td>WAL-MART #332</td>\n",
        "      <td>57.60</td>\n",
        "      <td>Groceries</td>\n",
        "      <td>Chase5282_Activity20240110_20260110_20260111.CSV</td>\n",
-       "      <td>From toys and video games to fashionable cloth...</td>\n",
+       "      <td>3 days ago · Walmart Inc. is an American multi...</td>\n",
        "    </tr>\n",
        "  </tbody>\n",
        "</table>\n",
@@ -390,17 +531,17 @@
       ],
       "text/plain": [
        "                                       id     transaction_date  \\\n",
-       "0    5712be16-98a8-41d7-94de-15ecff7793da  2024-10-17 00:00:00   \n",
-       "1    cea08bf8-440c-4d05-b06c-5c0d2e3b2997  2024-10-18 00:00:00   \n",
-       "2    b021b290-36fc-4667-993c-6f620da3a54a  2024-10-18 00:00:00   \n",
-       "3    d260bc87-ca63-4238-ad9e-3482273c49fb  2024-10-18 00:00:00   \n",
-       "4    2c06fe8e-8ef2-49f1-bed6-dd282effec85  2024-11-02 00:00:00   \n",
+       "0    cf2f48c5-34ab-4544-b1f4-542681fd5017  2024-10-17 00:00:00   \n",
+       "1    16913dce-52bf-43f4-853d-7bb55e09aac5  2024-10-18 00:00:00   \n",
+       "2    5917cb10-f0e6-49fa-9987-776cee28688c  2024-10-18 00:00:00   \n",
+       "3    bd66a49e-5064-43ca-bdb2-94947297b6d5  2024-10-18 00:00:00   \n",
+       "4    8b9b16d4-dd81-4ebe-820f-62fdc827a0bb  2024-11-02 00:00:00   \n",
        "..                                    ...                  ...   \n",
-       "245  6a6167f7-dc54-480f-8a15-0561c7b877da  2025-06-18 00:00:00   \n",
-       "246  2a01f41e-8f1e-4a10-9e7f-3ac29795607b  2025-06-14 00:00:00   \n",
-       "247  f7648015-85a6-4412-87d5-1499ac29fce6  2025-06-12 00:00:00   \n",
-       "248  2edd49e5-9f4f-46d4-b94f-f9d7661bcdab  2025-06-11 00:00:00   \n",
-       "249  1d2ecebf-4994-4cdd-8d09-b6751655cd3f  2025-06-11 00:00:00   \n",
+       "245  239f983e-2ed8-4454-90ad-0e8477bf7893  2025-06-18 00:00:00   \n",
+       "246  0ecba974-5491-4ef2-ba52-bf3c37d6e854  2025-06-14 00:00:00   \n",
+       "247  fb966472-d77a-4723-a9e6-15e63bda4cd2  2025-06-12 00:00:00   \n",
+       "248  b6bc2e1d-d68b-4acd-a201-46d8cf5175e5  2025-06-11 00:00:00   \n",
+       "249  e896adcc-5445-4626-b14c-09ebd5c9f658  2025-06-11 00:00:00   \n",
        "\n",
        "                           description  amount                   category  \\\n",
        "0              BACK MARKET BROOKLYN NY  231.19                Merchandise   \n",
@@ -431,15 +572,15 @@
        "                                         enriched_info  \n",
        "0    Online Retailer in New York, NY . See BBB rati...  \n",
        "1    Temu ' s business model has allowed it to beco...  \n",
-       "2    Walmart Inc. is an American multinational reta...  \n",
-       "3    All U.S. Bank credit cards offer contactless c...  \n",
+       "2    Posts Walmart Huntsville - University Drive De...  \n",
+       "3    That said, I woke up yesterday and saw a $ 100...  \n",
        "4    Jan 22, 2021 · Best part to me--besides the ro...  \n",
        "..                                                 ...  \n",
-       "245  This is a list of notable current and former f...  \n",
-       "246  Locate a mobile phone | GSM locator of mobile ...  \n",
+       "245  Aug 29, 2025 · The group's headquarters is loc...  \n",
+       "246  Sep 25, 2025 · Thank You Mobile is not a compa...  \n",
        "247  At our Huntsville , AL location , we pride our...  \n",
-       "248  From toys and video games to fashionable cloth...  \n",
-       "249  From toys and video games to fashionable cloth...  \n",
+       "248  3 days ago · Walmart Inc. is an American multi...  \n",
+       "249  3 days ago · Walmart Inc. is an American multi...  \n",
        "\n",
        "[250 rows x 7 columns]"
       ]
@@ -646,9 +787,9 @@
      "name": "stdout",
      "output_type": "stream",
      "text": [
-      "Match: CASHBACK BONUS REDEMPTION PYMT/STMT CRDT - What is this charge? Cashback bonus redemption pymt / stmt crdt . Cash - back from mogl 858-36958. His IP address, location , Internet provider, what browser he uses and operating system? You can find out all this using \"2IP spy\".It serves two main functions. It provides the network location of the host and identifies the host or network interface. What is the purpose of an IP address? Cashback bonus redemption pymt / stmt crdt .March is the month in which I had most number of transcations. I think this is because I visited the store next to me very frequently for small purchases. Cashback bonus redemption pymt / stmt crdt . Redemption Activity This Period is the total amount of Rewards you redeemed during the statement period and includes Miles partners, gift cards, account credits, electronic deposits and charitable donations. Cashback bonus redemption pymt / stmt crdt .Question2 : What was the frequency(number of occurences) of each category in terms of expenses made over the entire time period?. | Metadata: {'id': '96dca195-03e6-4a7f-8836-fc71659a5379', 'amount': -11.32, 'category': 'Awards and Rebate Credits', 'transaction_date': '2025-03-18 00:00:00', '_id': 'ed7d701418bc4c96b42143671dc16464', '_collection_name': 'transactions'}\n",
-      "Match: CASHBACK BONUS REDEMPTION PYMT/STMT CRDT - What is this charge? Cashback bonus redemption pymt / stmt crdt . Cash - back from mogl 858-36958. His IP address, location , Internet provider, what browser he uses and operating system? You can find out all this using \"2IP spy\".It serves two main functions. It provides the network location of the host and identifies the host or network interface. What is the purpose of an IP address? Cashback bonus redemption pymt / stmt crdt .March is the month in which I had most number of transcations. I think this is because I visited the store next to me very frequently for small purchases. Cashback bonus redemption pymt / stmt crdt . Redemption Activity This Period is the total amount of Rewards you redeemed during the statement period and includes Miles partners, gift cards, account credits, electronic deposits and charitable donations. Cashback bonus redemption pymt / stmt crdt .Question2 : What was the frequency(number of occurences) of each category in terms of expenses made over the entire time period?. | Metadata: {'id': '70d72fc3-f61f-4a26-982f-0a71a1c48e30', 'amount': -9.0, 'category': 'Awards and Rebate Credits', 'transaction_date': '2025-05-15 00:00:00', '_id': 'e90a36aa56ed4b50a496a0b1d468d4e6', '_collection_name': 'transactions'}\n",
-      "Match: CASHBACK BONUS REDEMPTION PYMT/STMT CRDT - What is this charge? Cashback bonus redemption pymt / stmt crdt . Cash - back from mogl 858-36958. His IP address, location , Internet provider, what browser he uses and operating system? You can find out all this using \"2IP spy\".It serves two main functions. It provides the network location of the host and identifies the host or network interface. What is the purpose of an IP address? Cashback bonus redemption pymt / stmt crdt .March is the month in which I had most number of transcations. I think this is because I visited the store next to me very frequently for small purchases. Cashback bonus redemption pymt / stmt crdt . Redemption Activity This Period is the total amount of Rewards you redeemed during the statement period and includes Miles partners, gift cards, account credits, electronic deposits and charitable donations. Cashback bonus redemption pymt / stmt crdt .Question2 : What was the frequency(number of occurences) of each category in terms of expenses made over the entire time period?. | Metadata: {'id': 'a4803064-dde5-48a5-be3b-34b17cbb0fbc', 'amount': -2.55, 'category': 'Awards and Rebate Credits', 'transaction_date': '2025-11-06 00:00:00', '_id': 'a10a1f901da54e0599b3578e66ff3fcb', '_collection_name': 'transactions'}\n"
+      "Match: TST*WOKS UP HUNTSVILLE AL00075396024313993332AA - Take a look at these nine new businesses that have just opened or announced an opening here in the Rocket City. Check Dress Up - Huntsville in Huntsville , AL, 920 Bob Wallace Ave SW #317 on Cylex and find ☎ (256) 585-2..., contact info, ⌚ opening hours. We're posted at the WeUp location for just a couple more hours —so if you're hungry, now's the time to pull up ! We've had some amazing folks swing through today, including the owner of Ms. Juju's Kitchen and one of your favorite local barbers Mike —and YES, they're repeat customers because the food speaks for itself! Detailed info and reviews on 27 top companies and startups in Huntsville in 2026. Get the latest updates on their products, jobs, funding, investors, founders and more. Check Your Statement: Look for entries starting with \"TST\" on your debit card statement. Note the date, amount, and any additional details like a business name or code. Match with Receipts: Compare the charge to recent purchases, especially at restaurants, cafes, or bars. The amount should match your receipt or include a tip. | Metadata: {'id': '737481c4-fc9c-48a5-8cd9-9f2a02844c12', 'amount': 15.21, 'category': 'Restaurants', 'transaction_date': '2025-04-14 00:00:00', '_id': 'd461cada0bc542e6803cd9d14460ad05', '_collection_name': 'transactions'}\n",
+      "Match: TST*KAMADO RAMEN - MID HUNTSVILLE AL00006963025030352515AA - Kamado Ramen in Huntsville rated 4.7 out of 5 on Restaurant Guru: 896 reviews by visitors, 205 photos & 5 videos. Explore menu, check opening hours and order delivery Kamado Ramen : Spicy Miso Ramen 1022 Mid City Drive Huntsville , AL & 3414 Governors Dr. Huntsville , AL ( Mid City location and Stovehouse Food Garden Location ) Ramen is a hearty soup with quick-cooking noodles, often loaded with vegetables, meat, and egg. These two locations vary but carry similar items. Get address, phone number, hours, reviews, photos and more for Kamado Ramen Midcity | 1022 MidCity Drive, Huntsville , AL 35806, USA on usarestaurants.info Check Your Statement: Look for entries starting with \"TST\" on your debit card statement. Note the date, amount, and any additional details like a business name or code. Match with Receipts: Compare the charge to recent purchases, especially at restaurants, cafes, or bars. The amount should match your receipt or include a tip. Kamado Ramen at MidCity 1022 Mid City Drive, Huntsville , AL 35806 About Discussion 4 went 35 interested 3 shares | Metadata: {'id': 'cb6d01a0-0bab-4617-aba9-7e587b3ea32d', 'amount': 16.29, 'category': 'Restaurants', 'transaction_date': '2025-05-16 00:00:00', '_id': '9dc318e6b9e04a2f91e1a85ffbb375b8', '_collection_name': 'transactions'}\n",
+      "Match: AMAZON MKTPL*B27IN41E1 - In these cases, Amazon charges your payment method when each part of the order is shipped. This is why you have separate charges on your statement. Access Your Transactions to match the charge amounts and dates on your statement with the associated order number. Amazon is one of the world's most valuable brands and is one of the big five American information technology companies, along with Alphabet, Apple, Meta, and Microsoft. Some items Amazon sells include Show some love to small businesses . Donate to Kiva.org today to provide loans to local entrepreneurs and the Tripadvisor Foundation will match it, up to $150,000 USD collectively. Terms apply. Amazon mktpl ZG27L7451. General operating fund. Buildings and grounds.The UPS store 5242. General operating fund. Police department. Политика обработки персональных данных Согласие на обработку персональных данных Агентский Договор Все бренды. Мобильное приложение. Скачать в App Store Скачать в Google Play. | Metadata: {'id': 'ea13dad8-5978-442b-b4e4-7b22c226d72f', 'amount': 86.38, 'category': 'Shopping', 'transaction_date': '2025-11-24 00:00:00', '_id': '88754c75d8154f9e9912cf46cc51ade3', '_collection_name': 'transactions'}\n"
      ]
     }
    ],
@@ -675,22 +816,35 @@
      "text": [
       "================================\u001b[1m Human Message \u001b[0m=================================\n",
       "\n",
-      "is there anything i need to be worried about in my spending over the last 2 months?\n",
+      "ow much did i spend in haircuts\n",
       "==================================\u001b[1m Ai Message \u001b[0m==================================\n",
+      "Tool Calls:\n",
+      "  semantic_search (f8fc4ebf-658f-4c58-a163-6bc4308ae46a)\n",
+      " Call ID: f8fc4ebf-658f-4c58-a163-6bc4308ae46a\n",
+      "  Args:\n",
+      "    topk: 10.0\n",
+      "    query: haircuts\n",
+      "=================================\u001b[1m Tool Message \u001b[0m=================================\n",
+      "Name: semantic_search\n",
       "\n",
-      "I can't tell you if there's anything to \"worry about\" as that's a subjective judgment. However, I can help you analyze your spending in various ways. For example, I can:\n",
-      "\n",
-      "*   Show you your total spending over the last two months.\n",
-      "*   Break down your spending by category or merchant.\n",
-      "*   Identify your largest transactions.\n",
-      "*   Find transactions related to specific keywords (e.g., \"fast food,\" \"online shopping\").\n",
+      "Result: TST*WOKS UP HUNTSVILLE AL00075396024313993332AA - Take a look at these nine new businesses that have just opened or announced an opening here in the Rocket City. Check Dress Up - Huntsville in Huntsville , AL, 920 Bob Wallace Ave SW #317 on Cylex and find ☎ (256) 585-2..., contact info, ⌚ opening hours. We're posted at the WeUp location for just a couple more hours —so if you're hungry, now's the time to pull up ! We've had some amazing folks swing through today, including the owner of Ms. Juju's Kitchen and one of your favorite local barbers Mike —and YES, they're repeat customers because the food speaks for itself! Detailed info and reviews on 27 top companies and startups in Huntsville in 2026. Get the latest updates on their products, jobs, funding, investors, founders and more. Check Your Statement: Look for entries starting with \"TST\" on your debit card statement. Note the date, amount, and any additional details like a business name or code. Match with Receipts: Compare the charge to recent purchases, especially at restaurants, cafes, or bars. The amount should match your receipt or include a tip. | Metadata: {'id': '737481c4-fc9c-48a5-8cd9-9f2a02844c12', 'amount': 15.21, 'category': 'Restaurants', 'transaction_date': '2025-04-14 00:00:00', '_id': 'd461cada0bc542e6803cd9d14460ad05', '_collection_name': 'transactions'}\n",
+      "Result: BEST BUY      00005140 - Visit your local Best Buy at 20290 Katy Fwy in Katy, TX for electronics, computers, appliances, cell phones, video games & more new tech. In- store pickup & free shipping. Learn about the \" Best Buy 00005140 Huntsville Al\" charge and why it appears on your credit card statement. First seen on March 20, 2023, Last updated on March 20, 2023. What is it?Also Appears on Statements As. Chkcardbest buy 00005140 huntsville al. Is it time you ditched store - bought bread and started making your own, being in total control of the ingredients and your health? You might just do that when you learn about the differences between homemade bread vs. store - bought bread. Best Buy Goes Out Of Business ?? Why Best Buy Is Tanking Hard - YouTube. Best Buy has closed 18 stores , but physical locations still key to strategy. Typically during the weekdays, AT&T store hours are from 9 AM to 9 PM on Monday through Friday. The weekend begins in a similar fashion, and the AT&T store will open at 9 AM and close at 9 PM as well for most locations . | Metadata: {'id': '112c618f-6a83-4bfd-bb37-1193a2632a80', 'amount': 816.42, 'category': 'Shopping', 'transaction_date': '2025-11-22 00:00:00', '_id': '2e1ced908f6e44e3936e32cb8352e625', '_collection_name': 'transactions'}\n",
+      "Result: SLIM & HUSKIES NASHVILLE TN - Slim & Husky ’s has quickly become one of Nashville ’s fastest-growing businesses , and their mission to support the Nashville community is very ... While this isn ’ t their only location around the city, Emmy Squared: The Gulch is located in the heart of Nashville . ... of experience in WordPress development , we deliver powerful, scalable WordPress development in Nashville , TN —delivering custom development and ... Whether your business is based in Nashville , or you want to give a national feel, our comfortable and spacious meeting room will provide a creative ... ... Reviews: Reviews ordered by recency and descriptiveness of user-identified themes such as wait time, length of visit, general tips, and location ... | Metadata: {'id': '536147de-9359-4206-84b5-08e316fbd784', 'amount': 16.9, 'category': 'Restaurants', 'transaction_date': '2025-05-19 00:00:00', '_id': '6f3179b1f3364948a07bd5188e95b836', '_collection_name': 'transactions'}\n",
+      "Result: HUNTSVILLE FLV - Huntsville FLV is a local establishment in Huntsville, AL that offers a variety of services to its customers. Specializing in providing solutions for everyday needs, Huntsville FLV aims to cater to the diverse needs of the community. Now that we've got the long-awaited Trader Joe's, Dave & Busters, Top Golf, and Cheesecake Factory in town, what is the next business you'd like to see come to Hsv? Dec 16, 2024 · Take a look at these three new businesses that have opened or are about to open here in the Huntsville area. With four unique services— Huntsville International Airport, Rail and Air Cargo, Space Port, and Jetplex Industrial Park—we deliver opportunities for businesses and travelers. Whether by land, air, or space, we link people to places and products to markets. Jan 3, 2024 · Find the best Retail Stores in Huntsville , AL. Search Huntsville , AL Retail Stores to find the top rated Retail Stores . | Metadata: {'id': 'f6171537-bbe6-4c47-9b75-81b443e2d3ad', 'amount': 3.25, 'category': 'Food & Drink', 'transaction_date': '2025-10-25 00:00:00', '_id': 'f65cd50fdc7d4d7f8d5ad2ff4e307a78', '_collection_name': 'transactions'}\n",
+      "Result: HUNTSVILLE FLV - Huntsville FLV is a local establishment in Huntsville, AL that offers a variety of services to its customers. Specializing in providing solutions for everyday needs, Huntsville FLV aims to cater to the diverse needs of the community. Now that we've got the long-awaited Trader Joe's, Dave & Busters, Top Golf, and Cheesecake Factory in town, what is the next business you'd like to see come to Hsv? Dec 16, 2024 · Take a look at these three new businesses that have opened or are about to open here in the Huntsville area. With four unique services— Huntsville International Airport, Rail and Air Cargo, Space Port, and Jetplex Industrial Park—we deliver opportunities for businesses and travelers. Whether by land, air, or space, we link people to places and products to markets. Jan 3, 2024 · Find the best Retail Stores in Huntsville , AL. Search Huntsville , AL Retail Stores to find the top rated Retail Stores . | Metadata: {'id': '5aad4b5a-848f-4539-9d3a-54dfce7f3ed9', 'amount': 3.25, 'category': 'Food & Drink', 'transaction_date': '2025-10-30 00:00:00', '_id': 'ed5ee1ae725b452983b42bda99cd129b', '_collection_name': 'transactions'}\n",
+      "Result: HUNTSVILLE FLV - Huntsville FLV is a local establishment in Huntsville, AL that offers a variety of services to its customers. Specializing in providing solutions for everyday needs, Huntsville FLV aims to cater to the diverse needs of the community. Now that we've got the long-awaited Trader Joe's, Dave & Busters, Top Golf, and Cheesecake Factory in town, what is the next business you'd like to see come to Hsv? Dec 16, 2024 · Take a look at these three new businesses that have opened or are about to open here in the Huntsville area. With four unique services— Huntsville International Airport, Rail and Air Cargo, Space Port, and Jetplex Industrial Park—we deliver opportunities for businesses and travelers. Whether by land, air, or space, we link people to places and products to markets. Jan 3, 2024 · Find the best Retail Stores in Huntsville , AL. Search Huntsville , AL Retail Stores to find the top rated Retail Stores . | Metadata: {'id': 'ea82ce94-0253-4e76-bdfa-2ca89be58129', 'amount': 3.25, 'category': 'Food & Drink', 'transaction_date': '2025-10-26 00:00:00', '_id': '6f27f08b44aa462282a2267ff5b2c339', '_collection_name': 'transactions'}\n",
+      "Result: LAS VEGAS SOUVENIRS AND LAS VEGAS NV - Earn $$ as a professional gift shop owner. Take your first steps and register today. Become a professional gift shop owner from the comfort of your home. Register today. amazon.com has been visited by 1M+ users in the past month Read Customer Reviews & Find Best Sellers. Free, Easy Returns On Millions Of Items. Shop Chairs, Tables, Place Mats, Chandeliers, Pendant Light Fixtures and More. faire.com has been visited by 100K+ users in the past month Empowering Independent Entrepreneurs To Chase Their Dreams, Shop From Over 100,000 Brands. Buy Wholesale Products Easily & Risk Free on Faire With Free Returns On Your First Order. Organic · Eco-Friendly · Free & Easy Returns · Small Batch Bonanza Gift Shop - The World's Largest Gift Shop located in Las Vegas , Nevada . 40,000 square feet of Vegas souvenirs, apparel, collectibles, Native American art and more since 1980. Open daily 9AM-midnight. This is a review for souvenir shops in Las Vegas , NV : \"Morris & Co is a high-end souvenir shop of luxury items like jewelry, clothing, gifts, accessories, snacks, and many other cool items like LIV nightclub accessories. M&M’s World Las Vegasis located inside a showcase mall on Las Vegas Blvd. The impressive four-level store was the first ever M&M store ! This isn’t a traditional gift shop, but that doesn’t mean you won’t find plenty of fun gifts and Las Vegas souvenirs . Guests can create their M&M design or choose from several premade, Vegas -themed designs. This is ... See full list on vegasfoodandfun.com Coca-Cola has been a staple in American homes for decades. If you’re one of the many Coca-Cola lovers, this gift shop is for you! The store features a variety of Coca-Cola and Las Vegas -themed merchandise. Many of the products sold in the Coca-Cola storeare vintage or limited edition items that can’t be purchased anywhere else. If the gifts aren’t ... See full list on vegasfoodandfun.com Welcome to Las Vegas has multiple gift shops around Sin City, but the store on Las Vegas Blvd inside The Venetian at Grand Canal Shoppesis the most impressive. The whole store is dedicated to celebrating fabulous Las Vegas ! You’ll find t-shirts, shot glasses, snow globes, onesies, and anything else you can imagine in Las Vegas memorabilia form. Thi... See full list on vegasfoodandfun.com Downtown Container Parkis a hub for shopping, dining, and entertainment in Downtown Las Vegas . The park is made of repurposed shipping containers, hence the unique name. The best part about visiting the Downtown Container Park is wandering from one store to another with amazing food in between. The park focuses on local retailers, so you’ll find a ... See full list on vegasfoodandfun.com Tokyo Discount is a store on Maryland Pkwy, Las Vegas , NV , that brings Japanese culture to Sin City. The discount shop has all things Tokyo including Hello Kitty, Japanese snacks, Pokemon, and Japanese decor. The downtown location makes it easy to explore Tokyo Discount during your Las Vegas trip! Whether you buy something Vegas -themed or something... See full list on vegasfoodandfun.com Local Oasis is a shop in the art district of Las Vegas that a local artist opened in 2020. The small shop sells art, gifts, and items from local brand owners. What better souvenir for your Vegas trip than a one- of -a-kind art piece? It’s important to remember this shop doesn’t have a huge selection of cheesy Las Vegas souvenirs , but that’s why many ... See full list on vegasfoodandfun.com Karma Connection is a shop that specializes in all things psychic, crystals, and natural healing. If you’re interested in those things, you’ll find this store is overflowing with possibilities! You can buy a new crystal to keep as your Las Vegas souvenir or get a personalized psychic reading. This gift shop is usually filled with like-minded people... See full list on vegasfoodandfun.com The Gamblers General Store has been appealing to casino lovers since 1984. The store is located on S Main Street, and it’s one of the only souvenir shops in Las Vegas that caters to people who love gambling. You’ll find an inventory that includes playing cards, customized chips, and casino memorabilia. There’s even a book section with books that te... See full list on vegasfoodandfun.com Hudson News is the best place to get a gift when entering Las Vegas via Harry Reid Airport, formerly known as McCarran International Airport. They have a lot of the same stuff you’d find in gift shops outside the airport, but it’s way more convenient! Grab a t-shirt, mugs, key chains, and several other airport-friendly last-minute gifts. You can al... See full list on vegasfoodandfun.com Bonanza Gift Shop is much more than just another souvenir shop on the Strip. It’s the world’s largest gift shop! The inventory at Bonanza doesn’t just compete with other souvenir shops. It blows those shops out of the water! Bonanza has reasonable prices and a prime location , making it a fan favorite over the years. The world’s largest gift shop ca... See full list on vegasfoodandfun.com Jan 24, 2024 · The store was established in 1984 and has since been a staple of Las Vegas as the one and only Gamblers general store. You won’t miss any gamblers’ favorite items; ranging from hand to find items to popular selections. This guide will give you all the best places to get souvenirs, the different types of gifts to expect in the shops, and even tips on how to get them back home. Get your shopping lists ready because you’ll check off everyone—and find a few fun items for your own keepsake. Just a short walk away, M&M’s Las Vegas at Showcase Mall is a four-story candy wonderland, where you can create personalized M&M’s in minutes. Whether you're a chocolate fanatic or just looking for a fun stop, these iconic stores are the sweetest attractions on the Strip! Because we are here \"in the heart of it\" we are able to offer you ALL the popular Las Vegas Souvenirs and Las Vegas Gift Items you will see around Vegas in the various giftshops. We continually strive to bring you what you see and want from Las Vegas in the form of Quality Products. Earn $$ as a professional gift shop owner. Take your first steps and register today. Become a professional gift shop owner from the comfort of your home. Register today. amazon.com has been visited by 1M+ users in the past month Read Customer Reviews & Find Best Sellers. Free, Easy Returns On Millions Of Items. Shop Chairs, Tables, Place Mats, Chandeliers, Pendant Light Fixtures and More. faire.com has been visited by 100K+ users in the past month Empowering Independent Entrepreneurs To Chase Their Dreams, Shop From Over 100,000 Brands. Buy Wholesale Products Easily & Risk Free on Faire With Free Returns On Your First Order. Organic · Eco-Friendly · Free & Easy Returns · Small Batch | Metadata: {'id': 'bac13cd8-cfcc-48f3-8dfa-18c3a3b2cc59', 'amount': 15.14, 'category': 'Merchandise', 'transaction_date': '2025-05-24 00:00:00', '_id': '415f62d03ac949f2b5ab56ef8cc8d105', '_collection_name': 'transactions'}\n",
+      "Result: UAH BURSARS OFFICE - The Bursar 's Office oversees the billing and collection of fees, adding funds to student accounts, and student refunds.Student Services Building, Room 123 301 Sparkman Drive Huntsville, AL 35899. 256.824.6226 bursar @ uah .edu. UAH Bursar Welcome to the Office of the Bursar The Bursar ’s Office manages student accounts, including the billing and collection of fees, and student refunds. Located in the Student Services… cs_ office . Dismiss.Your personal data will be processed and information from your device (cookies, unique identifiers, and other device data) may be stored by, accessed by and shared with 156 TCF vendor(s) and 81 ad partner(s), or used specifically by this site. UAH 1 199,50Цена предложения: UAH 1 199,50.Политика отмены PS Store . Меры предосторожности. О рейтингах. Searching for an Advance Auto Parts close to you? Advance has locations across North America which provide quality auto parts, advice and accessories for your car. | Metadata: {'id': 'eea3224b-1289-40bd-bf02-a54a6a7a7ce7', 'amount': 50.0, 'category': 'Education', 'transaction_date': '2025-08-21 00:00:00', '_id': '775b6f5066bd4435837a5f3c1b613aea', '_collection_name': 'transactions'}\n",
+      "Result: HANDELS HOMEMADE JONES V - Jan 2, 2026 · Monty Python's Life of Brian is a 1979 British surreal biblical black comedy film starring and written by the comedy group Monty Python It was directed by ... Nov 24, 2025 · In 1861, Welsh entrepreneur Pryce Pryce-Jones formed the first mail order business, an idea which would change the nature of retail. Selling Welsh flannel ... Dec 10, 2025 · Christmas music comprises a variety of genres of music regularly performed or heard around the Christmas season. Enter your address to see if Handel ' s Homemade Ice Cream - Jones Valley delivery is available to your location in Huntsville.What are some other stores nearby Handel ' s Homemade Ice Cream - Jones Valley? store locator pin Store Finder. All Our Fun-Filled Flavors. We have a collection of over 100 flavors. Below is a full list of our flavors. Be sure to check your local store to discover the flavors they are currently serving. | Metadata: {'id': '1c5b9d0f-8ecf-4d06-baa5-e6f036102eb0', 'amount': 8.18, 'category': 'Food & Drink', 'transaction_date': '2025-12-30 00:00:00', '_id': '8e207351ec57437aae0343b6c81ea434', '_collection_name': 'transactions'}\n",
+      "Result: SQ *SPILL COFFEE AND CREA - **Free refills of hot and iced brewed coffee and tea during same store visit. Excludes Cold Brew, Nitro Cold Brew, Iced Tea Lemonade, flavored Iced Tea and Starbucks Refreshers® base. At participating stores . Find out my IP address, public IPv4 and IPv6, IP location , ISP with additional information like the country, city, user agent, your browser and OS. osu! farm pp maps and beatmap recommendations... Square register is the POS software that’s simple, powerful, and free. Grand Tour Around Island 16 Locations plus Snorkeling. 4.9. (7,365).Donate to Kiva.org today to provide loans to local entrepreneurs and the Tripadvisor Foundation will match it, up to $150,000 USD collectively. Terms apply. | Metadata: {'id': 'b7708547-c125-427e-9e9e-f330ea66af71', 'amount': 4.39, 'category': 'Food & Drink', 'transaction_date': '2025-08-30 00:00:00', '_id': '5b48543fabe44e468e8db6844d868baf', '_collection_name': 'transactions'}\n",
+      "==================================\u001b[1m Ai Message \u001b[0m==================================\n",
       "\n",
-      "What kind of spending insights would be most helpful for you?\n"
+      "I couldn't find any transactions related to haircuts.\n"
      ]
     }
    ],
    "source": [
-    "question = \"is there anything i need to be worried about in my spending over the last 2 months?\"\n",
+    "question = \"ow much did i spend in haircuts\"\n",
     "steps = []\n",
     "\n",
     "for step in agent.stream(\n",

notebooks/2_test_vectordb.ipynb

@@ -1,76 +1,118 @@
 {
  "cells": [
+  {
+   "cell_type": "markdown",
+   "metadata": {},
+   "source": [
+    "# Test MCP Server (Local Mode)\n",
+    "\n",
+    "This notebook demonstrates how to use the `mcp_server.py` tools directly within a LangChain workflow. \n",
+    "This simulates how an Agent would interact with your Local or Cloud MCP Server."
+   ]
+  },
   {
    "cell_type": "code",
-   "execution_count": 3,
+   "execution_count": null,
    "metadata": {},
    "outputs": [],
    "source": [
-    "%reload_ext autoreload\n",
-    "%autoreload 2"
+    "import sys\n",
+    "import os\n",
+    "import pandas as pd\n",
+    "from dotenv import load_dotenv\n",
+    "from langchain_core.tools import StructuredTool\n",
+    "from langchain_google_vertexai import ChatVertexAI\n",
+    "from langgraph.prebuilt import create_react_agent\n",
+    "\n",
+    "# 1. Setup Path to import mcp_server from parent directory\n",
+    "sys.path.append(\"..\")\n",
+    "\n",
+    "# 2. Setup Environment\n",
+    "load_dotenv()\n",
+    "\n",
+    "# POINT DATABASE TO A LOCAL FOLDER FOR THIS NOTEBOOK\n",
+    "# This ensures we don't mess with deployment default paths, or we explicitly stick to 'temp_data'\n",
+    "# mcp_server defaults to using 'DATA_DIR' env var if set\n",
+    "os.environ[\"DATA_DIR\"] = os.path.abspath(\"../temp_data_notebook_test\")\n",
+    "print(f\"Using Data Dir: {os.environ['DATA_DIR']}\")\n",
+    "\n",
+    "# 3. Import Tools directly from Server Code\n",
+    "# (In a real remote scenario, you would use MCPClient instead)\n",
+    "from mcp_server import ingest_transactions, get_database_schema, query_database, semantic_search, clear_database\n",
+    "\n",
+    "# 4. Wrap as LangChain Tools\n",
+    "tools = [\n",
+    "     StructuredTool.from_function(ingest_transactions),\n",
+    "     StructuredTool.from_function(clear_database),\n",
+    "     StructuredTool.from_function(get_database_schema),\n",
+    "     StructuredTool.from_function(query_database),\n",
+    "     StructuredTool.from_function(semantic_search),\n",
+    "]\n",
+    "\n",
+    "# 5. Initialize Agent\n",
+    "llm = ChatVertexAI(model=\"gemini-1.5-flash-001\", temperature=0)\n",
+    "agent_executor = create_react_agent(llm, tools)\n",
+    "\n",
+    "print(\"Agent and Tools loaded successfully!\")"
    ]
   },
   {
    "cell_type": "code",
-   "execution_count": 4,
+   "execution_count": null,
    "metadata": {},
-   "outputs": [
-    {
-     "data": {
-      "text/plain": [
-       "True"
-      ]
-     },
-     "execution_count": 4,
-     "metadata": {},
-     "output_type": "execute_result"
-    }
-   ],
+   "outputs": [],
    "source": [
-    "import pandas as pd\n",
-    "import sqlite3\n",
-    "from langchain.chat_models import init_chat_model\n",
-    "from langchain_core.prompts import ChatPromptTemplate\n",
-    "from langchain_core.output_parsers import JsonOutputParser\n",
+    "# --- STEP 1: LOAD & INGEST DATA ---\n",
+    "# We will read one of the CSVs from demo_data and send it to the 'ingest_transactions' tool.\n",
     "\n",
-    "from dotenv import load_dotenv\n",
-    "load_dotenv()"
+    "# Read Local File\n",
+    "csv_path = \"../demo_data/Chase5282_Activity20240110_20260110_20260111.CSV\"\n",
+    "\n",
+    "if os.path.exists(csv_path):\n",
+    "    with open(csv_path, 'r') as f:\n",
+    "        csv_content = f.read()\n",
+    "\n",
+    "    print(f\"Read {len(csv_content)} bytes from CSV.\")\n",
+    "    \n",
+    "    # Run the Agent to Ingest\n",
+    "    print(\"\\n--- Ingesting Data via Agent ---\")\n",
+    "    response = agent_executor.invoke(\n",
+    "        {\"messages\": [(\"user\", f\"Please clear the database first, then ingest this transaction data:\\n\\n{csv_content}\")]}\n",
+    "    )\n",
+    "    print(response[\"messages\"][-1].content)\n",
+    "else:\n",
+    "    print(f\"File not found: {csv_path}\")"
    ]
   },
   {
    "cell_type": "code",
    "execution_count": null,
    "metadata": {},
-   "outputs": [
-    {
-     "name": "stderr",
-     "output_type": "stream",
-     "text": [
-      "/Users/sawale/Documents/learning/money_rag/.venv/lib/python3.12/site-packages/google/cloud/aiplatform/models.py:52: FutureWarning: Support for google-cloud-storage < 3.0.0 will be removed in a future version of google-cloud-aiplatform. Please upgrade to google-cloud-storage >= 3.0.0.\n",
-      "  from google.cloud.aiplatform.utils import gcs_utils\n"
-     ]
-    },
-    {
-     "data": {
-      "text/plain": [
-       "langchain_google_vertexai.chat_models.ChatVertexAI"
-      ]
-     },
-     "execution_count": 5,
-     "metadata": {},
-     "output_type": "execute_result"
-    }
-   ],
+   "outputs": [],
    "source": [
-    "# Initialize the Gemini model via Vertex AI\n",
-    "vertex_llm = init_chat_model(\n",
-    "    \"gemini-2.5-flash\", \n",
-    "    model_provider=\"google_vertexai\",\n",
-    "    project='gen-lang-client-0311515393',\n",
-    "    location='us-central1',\n",
-    ")\n",
+    "# --- STEP 2: TEST RETRIEVAL (RAG) ---\n",
     "\n",
-    "type(vertex_llm)"
+    "queries = [\n",
+    "    \"What is the database schema?\",\n",
+    "    \"How much did I spend at McDonalds?\",\n",
+    "    \"Show me the top 3 most expensive transactions.\",\n",
+    "    \"What is my total spending on Food & Drink?\" \n",
+    "]\n",
+    "\n",
+    "for q in queries:\n",
+    "    print(f\"\\nUser: {q}\")\n",
+    "    result = agent_executor.invoke({\"messages\": [(\"user\", q)]})\n",
+    "    print(f\"AI: {result['messages'][-1].content}\")"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": 3,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "%reload_ext autoreload\n",
+    "%autoreload 2"
    ]
   },
   {

requirements.txt

@@ -1,156 +1,42 @@
-ddgs>=9.10.0
-duckduckgo-search>=8.1.1
-fastmcp>=2.14.3
-google-api-core>=2.29.0
-google-auth>=2.47.0
-google-cloud-aiplatform>=1.133.0
-google-cloud-bigquery>=3.40.0
-google-cloud-core>=2.5.0
-google-cloud-resource-manager>=1.15.0
-google-cloud-storage>=2.19.0
-google-crc32c>=1.8.0
-google-genai>=1.57.0
-google-resumable-media>=2.8.0
-googleapis-common-protos>=1.72.0
-grpc-google-iam-v1>=0.14.3
-grpcio>=1.76.0
-grpcio-status>=1.76.0
-h11>=0.16.0
-h2>=4.3.0
-hpack>=4.1.0
-httpcore>=1.0.9
-httpx>=0.28.1
-httpx-sse>=0.4.3
-hyperframe>=6.1.0
-idna>=3.11
-importlib-metadata>=8.7.1
-ipykernel>=7.1.0
-ipython>=9.9.0
-ipython-pygments-lexers>=1.1.1
-jaraco-classes>=3.4.0
-jaraco-context>=6.1.0
-jaraco-functools>=4.4.0
-jedi>=0.19.2
-jiter>=0.12.0
-jsonpatch>=1.33
-jsonpointer>=3.0.0
-jsonschema>=4.26.0
-jsonschema-path>=0.3.4
-jsonschema-specifications>=2025.9.1
-jupyter-client>=8.8.0
-jupyter-core>=5.9.1
-keyring>=25.7.0
+# --- Core AI Orchestration ---
 langchain>=1.2.3
-langchain-classic>=1.0.1
-langchain-community>=0.3.31
+langchain-community>=0.4.1
 langchain-core>=1.2.7
+langgraph>=1.0.6
+pydantic>=2.12.5
+
+# --- Model Providers ---
+# Google / Vertex AI
 langchain-google-vertexai>=2.1.2
-langchain-mcp>=0.2.1
-langchain-openai>=0.3.35
-langchain-qdrant>=1.1.0
-langchain-text-splitters>=0.3.11
-langgraph>=1.0.5
-langgraph-checkpoint>=3.0.1
-langgraph-prebuilt>=1.0.5
-langgraph-sdk>=0.3.2
-langsmith>=0.6.2
-lupa>=2.6
-lxml>=6.0.2
-markdown-it-py>=4.0.0
-marshmallow>=3.26.2
-matplotlib-inline>=0.2.1
-mcp>=1.25.0
-mdurl>=0.1.2
-more-itertools>=10.8.0
-multidict>=6.7.0
-mypy-extensions>=1.1.0
-nest-asyncio>=1.6.0
-numexpr>=2.14.1
-numpy>=2.4.1
+langchain-google-genai>=2.0.0
+google-cloud-aiplatform>=1.133.0
+google-genai>=1.57.0
+
+# OpenAI
+langchain-openai>=1.1.7
 openai>=2.15.0
-openapi-pydantic>=0.5.1
-opentelemetry-api>=1.39.1
-opentelemetry-exporter-prometheus>=0.60b1
-opentelemetry-instrumentation>=0.60b1
-opentelemetry-sdk>=1.39.1
-opentelemetry-semantic-conventions>=0.60b1
-orjson>=3.11.5
-ormsgpack>=1.12.1
-packaging>=25.0
-pandas>=2.3.3
-parso>=0.8.5
-pathable>=0.4.4
-pathvalidate>=3.3.1
-pexpect>=4.9.0
-platformdirs>=4.5.1
-portalocker>=3.2.0
-primp>=0.15.0
-prometheus-client>=0.24.1
-prompt-toolkit>=3.0.52
-propcache>=0.4.1
-proto-plus>=1.27.0
-protobuf>=6.33.3
-psutil>=7.2.1
-ptyprocess>=0.7.0
-pure-eval>=0.2.3
-py-key-value-aio>=0.3.0
-py-key-value-shared>=0.3.0
-pyarrow>=21.0.0
-pyasn1>=0.6.1
-pyasn1-modules>=0.4.2
-pycparser>=2.23
-pydantic>=2.12.5
-pydantic-core>=2.41.5
-pydantic-settings>=2.12.0
-pydocket>=0.16.6
-pygments>=2.19.2
-pyjwt>=2.10.1
-pyperclip>=1.11.0
-python-dateutil>=2.9.0.post0
-python-dotenv>=1.2.1
-python-json-logger>=4.0.0
-python-multipart>=0.0.21
-pytz>=2025.2
-pyyaml>=6.0.3
-pyzmq>=27.1.0
+
+# --- MCP & Tooling ---
+fastmcp>=2.14.3
+mcp>=1.25.0
+# langchain-mcp>=0.2.1
+langchain-mcp-adapters>=0.2.1
+duckduckgo-search>=8.1.1
+
+# --- Vector DB & Data ---
 qdrant-client>=1.16.2
-redis>=7.1.0
-referencing>=0.36.2
-regex>=2025.11.3
-requests>=2.32.5
-requests-toolbelt>=1.0.0
-rich>=14.2.0
-rich-rst>=1.3.2
-rpds-py>=0.30.0
-rsa>=4.9.1
-shellingham>=1.5.4
-six>=1.17.0
-sniffio>=1.3.1
-socksio>=1.0.0
-sortedcontainers>=2.4.0
+langchain-qdrant>=1.1.0
 sqlalchemy>=2.0.45
-sse-starlette>=3.1.2
-stack-data>=0.6.3
+pandas>=2.3.3
+redis>=7.1.0
+
+# --- Infrastructure & API ---
+uvicorn>=0.40.0
 starlette>=0.51.0
-tabulate>=0.9.0
+python-dotenv>=1.2.1
+httpx>=0.28.1
+requests>=2.32.5
 tenacity>=9.1.2
-tiktoken>=0.12.0
-tornado>=6.5.4
-tqdm>=4.67.1
-traitlets>=5.14.3
-typer>=0.21.1
-typing-extensions>=4.15.0
-typing-inspect>=0.9.0
-typing-inspection>=0.4.2
-tzdata>=2025.3
-urllib3>=2.6.3
-uuid-utils>=0.13.0
-uvicorn>=0.40.0
-validators>=0.35.0
-wcwidth>=0.2.14
-websockets>=15.0.1
-wrapt>=1.17.3
-xxhash>=3.6.0
-yarl>=1.22.0
-zipp>=3.23.0
-zstandard>=0.25.0
+
+
+streamlit

utils/data_ingestion.py

@@ -1,84 +0,0 @@
-import pandas as pd
-import sqlite3
-from langchain.chat_models import init_chat_model
-from langchain_core.prompts import ChatPromptTemplate
-from langchain_core.output_parsers import JsonOutputParser
-
-def ingest_csv(file_path, llm, db_path="money_rag.db"):
-    df = pd.read_csv(file_path)
-    headers = df.columns.tolist()
-    sample_data = df.head(5).to_json() # Increased sample to 5 for better context
-
-    prompt = ChatPromptTemplate.from_template("""
-    I have a CSV with these headers: {headers}
-    Sample data: {sample}
-    
-    Tasks:
-    1. Map headers to my standard schema: date_col, desc_col, amount_col, category_col, type
-    2. Identify type:
-        - type = payment type, use sign from amount to extract the type 
-        - If it is a credit, return "credit"
-        - If it is a debit, return "debit"
-        - Sign conventions are of two types:
-            - Positive : Positive means credit
-            - Negative: Negative means debit 
-        - {filename} : from the filename find the source
-                - Positive convention : if the source is Discover 
-                - Negative convention : if the source is Chase
-            
-             
-    3. Remove the sign from amount to map to amount_col 
-                                        
-    2. Identify 'sign_convention': 
-       - Look at the 'amount_col' column. 
-       - If a 'Payment' or 'Credit' is a NEGATIVE number, return "payment_is_negative".
-       - If a 'Payment' or 'Credit' is a POSITIVE number, return "payment_is_positive".
-    
-    Return ONLY JSON with keys: date_col, desc_col, amount_col, category_col, sign_convention.
-                                              
-    Understand that the conventions work like this:
-    1. Credit convention: 
-    """)
-    
-    chain = prompt | llm | JsonOutputParser()
-    mapping = chain.invoke({"headers": headers, "sample": sample_data, "filename": file_path})
-
-    standard_df = pd.DataFrame()
-    standard_df['transaction_date'] = pd.to_datetime(df[mapping['date_col']])
-    standard_df['description'] = df[mapping['desc_col']]
-    
-    # --- Normalization Logic ---
-    raw_amounts = pd.to_numeric(df[mapping['amount_col']])
-    
-    # We want a standard: Spending is POSITIVE, Payments/Refunds are NEGATIVE
-    if mapping.get('sign_convention') == "payment_is_positive":
-        # Flip the signs so payments become negative
-        standard_df['amount'] = raw_amounts * -1
-    else:
-        # Already consistent (spending +, payments -)
-        standard_df['amount'] = raw_amounts
-    
-    standard_df['category'] = df[mapping['category_col']] if mapping.get('category_col') else 'Uncategorized'
-    standard_df['source_file'] = file_path
-
-    conn = sqlite3.connect(db_path)
-    standard_df.to_sql("transactions", conn, if_exists="append", index=False)
-    conn.close()
-    
-    print(f"✅ Ingested {len(standard_df)} rows. Convention: {mapping.get('sign_convention')}")
-
-# --- Example Usage with Different Providers ---
-
-# To use Gemini, you'd install: pip install -U langchain-google-genai
-# To use Vertex AI, you'd install: pip install -qU langchain-google-vertexai
-
-# Option A: OpenAI
-# llm = init_chat_model("gpt-4o", model_provider="openai", temperature=0)
-
-# Option B: Google Gemini (Developer API)
-# llm_gemini = init_chat_model("gemini-2.5-flash", model_provider="google_genai", temperature=0)
-
-# Option C: Google Vertex AI (GCP Enterprise)
-# llm_vertex = init_chat_model("gemini-1.5-pro", model_provider="google_vertexai", temperature=0)
-
-# ingest_csv("discover_june.csv", llm_gemini)