Upload app.py with huggingface_hub

app.py

@@ -1,15 +1,33 @@
-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)
 
-st.set_page_config(page_title="Citadel Recovery", page_icon="🏛️")
-st.title("🏛️ Node Recovery: Active")
+@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
 
-# Self-Diagnostic
-st.write("### 🛠️ System Check")
-st.write(f"Stability: $9,293$")
-if os.environ.get("GDRIVE_SERVICE_ACCOUNT_JSON"):
-    st.success("✅ Service Badge Detected")
-else:
-    st.warning("⚠️ Service Badge Missing - Check Secrets")
+@app.route('/', methods=['GET'])
+def health_check():
+    return jsonify({"status": "SWARM_NODE_ONLINE"})
 
-st.info("Awaiting Logic Shard Ingestion from Librarian...")
+if __name__ == "__main__":
+    app.run(host="0.0.0.0", port=7860)