Update app.py

app.py

@@ -1,33 +1,73 @@
-
+import streamlit as st
 import os
-from flask import Flask, request, jsonify
-from huggingface_hub import HfApi
-
-app = Flask(__name__)
-TOKEN = os.getenv("HF_TOKEN")
-VAULT_ID = "DJ-Goanna-Coding/Mapping-and-Inventory-storage" # All feed the Librarian Vault
-api = HfApi(token=TOKEN)
-
-@app.route('/ignite_harvest', methods=['POST'])
-def catch_payload():
-    if not TOKEN:
-        return jsonify({"status": "ERROR", "message": "HF_TOKEN missing"}), 500
-    try:
-        payload = request.json
-        filename = payload.get("fileName", "swarm_shard.9293")
-        api.upload_file(
-            path_or_fileobj=payload.get("content", "").encode('utf-8'),
-            path_in_repo=f"ingested_core/{filename}",
-            repo_id=VAULT_ID,
-            repo_type="dataset"
-        )
-        return jsonify({"status": "CAUGHT_BY_SWARM", "file": filename}), 200
-    except Exception as e:
-        return jsonify({"status": "ERROR", "message": str(e)}), 500
-
-@app.route('/', methods=['GET'])
-def health_check():
-    return jsonify({"status": "SWARM_NODE_ONLINE"})
-
-if __name__ == "__main__":
-    app.run(host="0.0.0.0", port=7860)
+from smolagents import CodeAgent, HfApiModel, DuckDuckGoSearchTool
+from llama_index.core import VectorStoreIndex, SimpleDirectoryReader, StorageContext, load_index_from_storage
+
+# --- 1. THE BRAIN (LLM Setup) ---
+# Powered by Qwen 2.5 72B for high-tier reasoning
+model = HfApiModel(model_id="Qwen/Qwen2.5-72B-Instruct", token=os.getenv("HF_TOKEN"))
+agent = CodeAgent(tools=[DuckDuckGoSearchTool()], model=model)
+
+st.set_page_config(page_title="TIA-ARCHITECT-CORE", page_icon="🧠", layout="wide")
+
+# --- 2. THE MEMORY (RAG Intelligence) ---
+INDEX_DIR = "./citadel_index"
+DATA_DIR = "./ingested_core"
+
+def initialize_memory():
+    if os.path.exists(DATA_DIR) and any(os.scandir(DATA_DIR)):
+        if not os.path.exists(INDEX_DIR):
+            documents = SimpleDirectoryReader(DATA_DIR).load_data()
+            index = VectorStoreIndex.from_documents(documents)
+            index.storage_context.persist(persist_dir=INDEX_DIR)
+        else:
+            storage_context = StorageContext.from_defaults(persist_dir=INDEX_DIR)
+            index = load_index_from_storage(storage_context)
+        return index
+    return None
+
+citadel_memory = initialize_memory()
+
+# --- 3. THE HUD (UI) ---
+st.title("🧠 TIA-ARCHITECT-CORE: SOVEREIGN ORACLE")
+st.subheader("777.1122 Alignment | Citadel Mesh Coordination")
+
+with st.sidebar:
+    st.success("NODE ONLINE")
+    if citadel_memory:
+        st.info("📚 Librarian Memory: Phase-Locked")
+    else:
+        st.warning("⚠️ Memory Substrate: Awaiting Harvest")
+    
+    st.markdown("---")
+    st.write("**Operational Districts:** D01 - D46")
+
+# --- 4. THE INTERFACE (Where the AI helps you) ---
+st.write("### 💬 Execute Command")
+query = st.chat_input("Commander, what is our next objective?")
+
+if query:
+    with st.chat_message("user"):
+        st.write(query)
+    
+    with st.chat_message("assistant"):
+        st.write("🚀 *Consulting Citadel Mesh...*")
+        
+        # Priority 1: Search RAG Memory if available
+        if citadel_memory:
+            query_engine = citadel_memory.as_query_engine()
+            context_response = query_engine.query(query)
+            st.markdown(f"**Citadel Memory:** {context_response}")
+            
+        # Priority 2: Agentic Reasoning/Action
+        agent_response = agent.run(query)
+        st.write(agent_response)
+
+# --- 5. TELEMETRY ---
+with st.expander("📡 Node Telemetry"):
+    st.json({
+        "status": "OPERATOR_GRADE",
+        "alignment": "9,293",
+        "version": "v25.0.OMNI++",
+        "substrate": "Forever_Learning (321GB)"
+    })