Create web_ingest.py

web_ingest.py

@@ -0,0 +1,31 @@
+# web_ingest.py
+
+import requests
+from datetime import datetime
+
+# Example public endpoints (replace or extend)
+PUBLIC_SOURCES = {
+    "gold_price": "https://api.metals.live/v1/spot/gold",
+    "oil_price": "https://api.oilpriceapi.com/v1/prices/latest",  # example
+}
+
+def fetch_public_signal(name: str):
+    try:
+        r = requests.get(PUBLIC_SOURCES[name], timeout=5)
+        r.raise_for_status()
+        return {
+            "source": name,
+            "timestamp": datetime.utcnow().isoformat(),
+            "data": r.json()
+        }
+    except Exception as e:
+        return {
+            "source": name,
+            "error": str(e)
+        }
+
+def ingest_all():
+    signals = {}
+    for name in PUBLIC_SOURCES:
+        signals[name] = fetch_public_signal(name)
+    return signals