Bootstrap rooted metadata fixtures through their actual database configuration (#95)

Use production rooted metadata provisioning for ordinary snapshot, view operations, and native push fixtures. Retain schema ownership, generic history behavior, native queue timing, and all existing test assertions. Validation is source-only: owned nightly format checks and Git whitespace checks; native builds, database tests, and performance runs are deferred.

Author: Ivanbeethoven

src/api/router/snapshot_content_tests.rs

@@ -679,7 +679,7 @@ impl Fixture {
         config.mst2.auth_token = Some(TOKEN.to_string());
         let backend = build_object_storage(&config.object_storage).await.unwrap();
         let counts = Arc::new(ReadCounts::default());
-        let (mut storage, schema) = if rebuildable {
+        let (mut storage, schema) = if rebuildable || !generic_history {
             let (database, schema) = test_db_config(temp.path()).await;
             config.database = database;
             let assembly = async {

src/jupiter/service/native_publication_push_tests.rs

@@ -8,14 +8,36 @@ use crate::jupiter::utils::converter::FromMegaModel;
 
 const NATIVE_INSTANCE: &str = "6ab219b0-4275-45ba-9d7b-7b0b633018cd";
 
-async fn native_fixture() -> (tempfile::TempDir, crate::jupiter::storage::Storage, git_internal::internal::object::commit::Commit, String) {
+async fn native_fixture() -> (
+    tempfile::TempDir,
+    crate::jupiter::storage::Storage,
+    git_internal::internal::object::commit::Commit,
+    String,
+) {
     let temp = tempfile::tempdir().unwrap();
     let mut config = crate::config::testing::isolated_config(temp.path().join("config"));
     config.monorepo.push_policy = PushPolicy::Trunk;
     config.mst2.enabled = true;
     config.mst2.publication_enabled = true;
     config.mst2.instance_uuid = Some(NATIVE_INSTANCE.to_owned());
-    let storage = crate::jupiter::tests::test_storage_with_config(temp.path(), config).await;
+    let (database, schema) = crate::jupiter::tests::test_db_config(temp.path()).await;
+    config.database = database;
+    let mut connection = crate::jupiter::storage::init::database_connection(&config.database)
+        .await
+        .unwrap();
+    connection.set_metric_callback(move |_| {
+        let _held_by_the_connection = &schema;
+    });
+    let mut storage = crate::jupiter::storage::Storage::new_with_connection(
+        Arc::new(config),
+        Arc::new(connection),
+        crate::jupiter::storage::object_storage::mock_object_storage(),
+    )
+    .await
+    .unwrap();
+    storage.push_queue_service = storage
+        .push_queue_service
+        .with_timeouts(Duration::from_secs(30), Duration::from_millis(20));
     let storage = crate::jupiter::tests::with_test_vault(storage, temp.path()).await;
     let name = format!("native-{}", uuid::Uuid::new_v4().simple());
     use git_internal::internal::object::{

src/jupiter/storage/view_ops_tests.rs

@@ -15,14 +15,14 @@ use crate::{
     ceres::view::filter::parse_for_registration,
     config::testing::isolated_config,
     jupiter::{
-        migration::apply_migrations,
         service::{
             view_metrics::ViewMetrics,
             view_projection_service::{CatchUpOutcome, ViewProjectionService},
         },
         storage::{
             Storage,
             git_db_storage::fu18_support::single_connection,
+            init::database_connection,
             object_storage::mock_object_storage,
             view_root_chain::RootChainOutcome,
             view_storage::ViewLockMode,
@@ -31,7 +31,7 @@ use crate::{
                 seed_unrelated_root_history,
             },
         },
-        tests::test_db_connection,
+        tests::{TestSchemaGuard, test_db_config},
     },
 };
 
@@ -58,6 +58,7 @@ struct OpsFixture {
     filter_a: i64,
     filter_b: i64,
     filter_a_id: String,
+    _schema: TestSchemaGuard,
 }
 
 fn fixed_time() -> chrono::NaiveDateTime {
@@ -222,9 +223,10 @@ async fn insert_warming_filter(
 
 async fn ops_fixture() -> OpsFixture {
     let temp = tempfile::tempdir().unwrap();
-    let db = test_db_connection(temp.path()).await;
-    apply_migrations(&db, true).await.unwrap();
-    let config = isolated_config(temp.path().join("config"));
+    let (database, schema) = test_db_config(temp.path()).await;
+    let mut config = isolated_config(temp.path().join("config"));
+    config.database = database;
+    let db = database_connection(&config.database).await.unwrap();
     let storage = Storage::new_with_connection(
         Arc::new(config),
         Arc::new(db.clone()),
@@ -406,6 +408,7 @@ async fn ops_fixture() -> OpsFixture {
         filter_a: filter_a.id,
         filter_b: filter_b.id,
         filter_a_id: filter_a.filter_id,
+        _schema: schema,
     }
 }