separates syncing

app.py

@@ -39,7 +39,7 @@ if not all([FV_CLIENT_ID, FV_CLIENT_SECRET, FV_PAT, FV_ORG_ID, FV_USER_ID]):
     print("[WARN] Missing one or more Filevine env vars — dashboard will fail until set.")
 
 # --- Cache ---
-from cache import project_cache
+# No longer using cache - projects are stored in Firestore
 
 PHASES = {
     209436: "Nonpayment File Review",
@@ -93,7 +93,7 @@ def get_user_profile(uid: str):
 
 
 def fetch_all_projects():
-    """Fetch all projects for a user and cache them"""
+    """Fetch all projects for a user and store them in Firestore"""
 
     print("Fetching projects....")
     # Get bearer token
@@ -101,17 +101,14 @@ def fetch_all_projects():
 
     # List projects (all pages)
     projects = list_all_projects(bearer)
-    # todo, only 10 projects
-    projects = projects[:50]
+    projects = projects[:250]
 
     # Fetch details for each
     detailed_rows = []
     for p in projects:
         pid = (p.get("projectId") or {}).get("native")
         c = fetch_client(bearer, (p.get("clientId") or {}).get("native"))
-        print("fetched client")
         cs = fetch_contacts(bearer, pid)
-        print("fetched contacts")
 
         if pid is None:
             continue
@@ -151,7 +148,6 @@ def fetch_all_projects():
         motion_to_quash_hearing_date = dates_and_deadlines.get("mTQHearingDate") or ''
         other_motion_hearing_date = dates_and_deadlines.get("otherMotion1HearingDate") or ''
         
-        pprint(dates_and_deadlines)
         # Extract MSC details
         msc_date = dates_and_deadlines.get("mSCDate") or ''
         msc_time = dates_and_deadlines.get("mSCTime") or ''
@@ -248,36 +244,23 @@ def fetch_all_projects():
         }
         detailed_rows.append(row)
 
-    # Cache the results
-    project_cache.set_projects(detailed_rows)
+    # Store the results in Firestore
+    projects_ref = db.collection("projects")
+    # Clear existing projects
+    projects_ref.stream()
+    for doc in projects_ref.stream():
+        doc.reference.delete()
+    
+    # Add new projects
+    for row in detailed_rows:
+        project_id = str(row.get("ProjectId"))
+        if project_id:
+            projects_ref.document(project_id).set(row)
+    
+    print(f"Stored {len(detailed_rows)} projects in Firestore")
     return detailed_rows
 
-import time
-import threading
-
-def async_cache_projects():
-    from threading import Thread
-
-    def cache_loop():
-        while True:
-            try:
-                # Check if cache is already being updated to avoid concurrent updates
-                if not project_cache.is_updating():
-                    project_cache.set_updating(True)
-                    fetch_all_projects()
-                    project_cache.set_updating(False)
-                else:
-                    print("Cache update already in progress, skipping this cycle")
-            except Exception as e:
-                print(f"Error in cache loop: {e}")
-                project_cache.set_updating(False)
-
-            # Wait for 15 minutes before next update
-            time.sleep(15 * 60)  # 15 minutes in seconds
-
-    thread = Thread(target=cache_loop, args=())
-    thread.daemon = True
-    thread.start()
+# No longer using cache - projects are stored in Firestore
 
 # --- Routes ---
 @app.route("/")
@@ -317,8 +300,6 @@ def session_login():
         # Optional: short session
         session["expires_at"] = (datetime.utcnow() + timedelta(hours=8)).isoformat()
 
-        async_cache_projects()
-
         return jsonify({"ok": True})
     except Exception as e:
         print("[ERR] session_login:", e)
@@ -368,25 +349,32 @@ def list_all_projects(bearer: str):
         "x-fv-userid": str(FV_USER_ID),
     }
     results = []
-    last_id = None
+    last_count = None
     tries = 0
+    offset = 0
     # TODO we probably need to sync the data with fierbase
-    while len(results) < 200:
+    cnt = 0
+    while len(results) < 250:
         cnt = len(results)
-        print(f"list try {tries}, last_id {last_id}, count {cnt}")
+        print(f"list try {tries}, starting at {offset}, previous count {last_count}, currently at {cnt}")
         tries += 1
         url = base
         params = {}
-        if last_id is not None:
+        if last_count is not None:
             # Some deployments use LastID/Offset pagination; adapt if needed
-            params["lastID"] = last_id
+            offset = offset + last_count
+            print(f"OFFSET f{offset}")
+            params["offset"] = offset
         r = requests.get(url, headers=headers, params=params, timeout=30)
         r.raise_for_status()
         page = r.json()
+        from pprint import pprint
         items = page.get("items", [])
         results.extend(items)
         has_more = page.get("hasMore")
-        last_id = page.get("lastID")
+        last_count = page.get("count")
+        from pprint import pprint
+        pprint(page)
         if not has_more:
             break
         # Safety valve
@@ -494,23 +482,20 @@ def dashboard():
     if not case_email:
         return redirect(url_for("welcome"))
 
-    # Check cache first
-    cached_projects = project_cache.get_projects()
-    if cached_projects is not None:
-        detailed_rows = cached_projects
-        print("USING CACHE")
-    else:
-        # Fetch and cache projects
-        detailed_rows = fetch_all_projects()
-        print("FETCHING")
+    # Read projects directly from Firestore
+    projects_ref = db.collection("projects")
+    docs = projects_ref.stream()
+    detailed_rows = []
+    
+    for doc in docs:
+        detailed_rows.append(doc.to_dict())
+    
+    print(f"Retrieved {len(detailed_rows)} projects from Firestore")
 
-    print("HI", len(detailed_rows))
-
-    # 5) Render table
+    # Render table
     return render_template("dashboard.html", rows=detailed_rows, case_email=case_email)
 
 
 # GAE compatibility
 if __name__ == "__main__":
-    async_cache_projects()
     app.run(debug=True, host="0.0.0.0", port=int(os.environ.get("PORT", "5004")))