Upload 3 files

persistent_data_gate.py

@@ -77,6 +77,7 @@ def ensure_temp_databases(base_dir: Path, api_client) -> None:
     temp_dir = base_dir / "temp"
     temp_dir.mkdir(parents=True, exist_ok=True)
 
+    print(f"[ensure_temp_databases] data_origin={data_origin}")
     if data_origin == "internal":
         source_dir = base_dir / "data"
         print(f"[ensure_temp_databases] data_origin=internal, source_dir={source_dir}")
@@ -91,22 +92,40 @@ def ensure_temp_databases(base_dir: Path, api_client) -> None:
         else:
             print(f"[ensure_temp_databases] WARNING: source_dir does not exist!")
     else:
-        # Mode external: descargar BDs del engine y descomprimir en temp/
-        if api_client is None:
-            print("[ensure_temp_databases] api_client is None, skipping import")
-            return
-        try:
-            resp = api_client.import_databases()
-            zip_bytes = resp.get("zip_bytes") if isinstance(resp, dict) else None
-            if zip_bytes:
-                _extract_zip_bytes(zip_bytes, temp_dir)
-                print(f"[ensure_temp_databases] Extracted DBs to {temp_dir}")
-            else:
-                err = resp.get("error") if isinstance(resp, dict) else "unknown"
-                print(f"[ensure_temp_databases] No zip_bytes in response: {err}")
-        except Exception as e:
-            print(f"[ensure_temp_databases] Exception: {e}")
-            return
+        # Mode external: descarregar BDs del backend una sola vegada per sessió del servidor
+        marker_file = temp_dir / ".external_db_imported"
+        missing = [name for name in ("events.db", "feedback.db", "users.db", "videos.db") if not (temp_dir / name).exists()]
+        needs_import = not marker_file.exists() or missing
+
+        if not needs_import:
+            print("[ensure_temp_databases] External data already present, skipping import")
+        else:
+            if missing:
+                print(f"[ensure_temp_databases] Missing files detected: {missing}")
+                try:
+                    marker_file.unlink(missing_ok=True)  # type: ignore[arg-type]
+                except Exception:
+                    pass
+
+            if api_client is None:
+                print("[ensure_temp_databases] api_client is None, skipping import")
+                return
+            try:
+                resp = api_client.import_databases()
+                zip_bytes = resp.get("zip_bytes") if isinstance(resp, dict) else None
+                if zip_bytes:
+                    _extract_zip_bytes(zip_bytes, temp_dir)
+                    print(f"[ensure_temp_databases] Extracted DBs to {temp_dir}")
+                    try:
+                        marker_file.write_text("imported", encoding="utf-8")
+                    except Exception:
+                        pass
+                else:
+                    err = resp.get("error") if isinstance(resp, dict) else "unknown"
+                    print(f"[ensure_temp_databases] No zip_bytes in response: {err}")
+            except Exception as e:
+                print(f"[ensure_temp_databases] Exception: {e}")
+                return
 
     # Un cop les BDs estan a temp/, crear una còpia de seguretat a temp/backup
     backup_dir = temp_dir / "backup"