Create data_fetcher.py

data_fetcher.py

@@ -0,0 +1,47 @@
+# 🔍 data_fetcher.py
+from firestore_client import get_firestore_client
+
+db = get_firestore_client()
+
+# Utility function to convert Gemini-style filters into Firestore queries
+def apply_filters(query_ref, filters):
+    for f in filters:
+        field = f.get("field")
+        op = f.get("op", "==")
+        value = f.get("value")
+        if field and value is not None:
+            query_ref = query_ref.where(field, op, value)
+    return query_ref
+
+def fetch_data_from_firestore(instruction):
+    """
+    instruction: dict like
+    {
+      "collections": [
+        {
+          "name": "participants",
+          "filters": [
+            {"field": "companyCode", "op": "==", "value": "QTX"},
+            {"field": "status", "op": "==", "value": "active"}
+          ],
+          "limit": 100
+        },
+        ...
+      ]
+    }
+    """
+    results = {}
+    for col in instruction.get("collections", []):
+        name = col.get("name")
+        filters = col.get("filters", [])
+        limit = col.get("limit", 50)
+
+        try:
+            col_ref = db.collection(name)
+            col_ref = apply_filters(col_ref, filters)
+            docs = col_ref.limit(limit).stream()
+            results[name] = [doc.to_dict() for doc in docs]
+        except Exception as e:
+            results[name] = {"error": str(e)}
+
+    return results