Function test_debug_delete_fencing

src/catalog/tests/debug.rs:459–541

(state_builder: TestCatalogStateBuilder)

}

async fn test_debug_delete_fencing(state_builder: TestCatalogStateBuilder) {
    let mut state = state_builder
        .clone()
        .with_default_deploy_generation()
        .unwrap_build()
        .await
        .open(SYSTEM_TIME().into(), &test_bootstrap_args())
        .await
        .unwrap()
        .0;
    // Drain state updates.
    let _ = state.sync_to_current_updates().await;

    let mut txn = state.transaction().await.unwrap();
    txn.set_config("joe".to_string(), Some(666)).unwrap();
    let commit_ts = txn.upper();
    txn.commit(commit_ts).await.unwrap();

    let mut debug_state = state_builder
        .clone()
        .unwrap_build()
        .await
        .open_debug()
        .await
        .unwrap();

    // State isn't fenced yet.
    assert_ok!(state.snapshot().await);
    assert_ok!(state.transaction().await);

    // Delete from catalog via debug_state.
    debug_state
        .delete::<SettingCollection>(proto::SettingKey {
            name: "joe".to_string(),
        })
        .await
        .unwrap();

    // Now state should be fenced.
    let err = state.snapshot().await.unwrap_err();
    assert!(
        matches!(
            err,
            CatalogError::Durable(DurableCatalogError::Fence(FenceError::Epoch { .. }))
        ),
        "unexpected err: {err:?}"
    );

    let err = state.transaction().await.unwrap_err();
    assert!(
        matches!(
            err,
            CatalogError::Durable(DurableCatalogError::Fence(FenceError::Epoch { .. }))
        ),
        "unexpected err: {err:?}"
    );

    // Open another state to fence the debug state.